Cannot deserialize value of type `int` from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid `int` value #4128

sdjfpop · 2025-01-07T02:04:42Z

Search before asking

I had searched in the issues and found no similar issues.

What happened

doris does not build tables and databases. Using CDCSOURCE method, MSQL whole library to doris has an error.
Does doris support automatic table creation for target data sources?

EXECUTE CDCSOURCE demo_doris WITH ( 'connector' = 'mysql-cdc', 'hostname' = 'xxxx', 'port' = '3306', 'username' = 'root', 'password' = 'xxxx', 'checkpoint' = '10000', 'scan.startup.mode' = 'initial', 'parallelism' = '1', 'table-name' = 'flink_test_copy\..*', 'sink.connector' = 'doris', 'sink.fenodes' = 'xxxx:8030', 'sink.username' = 'root', 'sink.password' = 'xxxx', 'sink.doris.batch.size' = '1', 'sink.sink.max-retries' = '1', 'sink.sink.db' = 'db_test_copy', 'sink.sink.properties.format' ='json', 'sink.sink.properties.read_json_by_line' ='true', 'sink.table.identifier' = '#{schemaName}.#{tableName}', 'sink.sink.label-prefix' = '4654' );

What you expected to happen

CDCSOURCE is Successful

How to reproduce

DataBase(flink_test_copy):

CREATE TABLE quick_chat_msg (
id bigint NOT NULL COMMENT '主键id',
from_id varchar(20) DEFAULT NULL COMMENT '账户id（发送人）',
to_id varchar(20) DEFAULT NULL COMMENT '账户id（接收人）',
relation_id varchar(50) DEFAULT NULL COMMENT '发送关联',
content varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '消息内容',
msg_type char(1) DEFAULT NULL COMMENT '消息类型（1：文字，2：语音，3：表情包，4：文件，5：语音通话，6：视频通话）',
extra_info varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '额外信息',
deleted char(1) DEFAULT NULL COMMENT '删除标识',
UNIQUE KEY copy_quick_chat_msg_unique (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

INSERT INTO flink_test_copy.quick_chat_msg
(id, from_id, to_id, relation_id, content, msg_type, extra_info, deleted)
VALUES(174, 'ZA7meDKXAS', 'K5YjNYxcd2', '71VABEaB6r', '9kJ9gW329M', '1', 'CSpPsp1zzs', '1');
INSERT INTO flink_test_copy.quick_chat_msg
(id, from_id, to_id, relation_id, content, msg_type, extra_info, deleted)
VALUES(180, 'VC6PKCDpCc', 'QtwgMMKofY', 'GyqUaLAJmA', 'E2lkLFbkB8', '2', 'lwSec7c0Zj', '1');
INSERT INTO flink_test_copy.quick_chat_msg
(id, from_id, to_id, relation_id, content, msg_type, extra_info, deleted)
VALUES(363, 'pBcJYUU4mh', 'oU6P6YAb9o', 'yFaPcZMAg4', 'KWmBtDET4l', '2', 'nP0fCdo6jf', '1');
INSERT INTO flink_test_copy.quick_chat_msg
(id, from_id, to_id, relation_id, content, msg_type, extra_info, deleted)
VALUES(968, 'KYAgEggmZp', 'QvQAnLF5O7', 'AX5foJTDcB', 'Dn5KaQ4R8p', '4', 'RXT3ho0uZ8', '0');
INSERT INTO flink_test_copy.quick_chat_msg
(id, from_id, to_id, relation_id, content, msg_type, extra_info, deleted)
VALUES(985, 'Y6Bm69xjNm', 'uuWWEsz7PZ', 'uPv0dfKiIL', 'YO1lz07xod', '5', 'LsIiFeGjwA', '0');
INSERT INTO flink_test_copy.quick_chat_msg
(id, from_id, to_id, relation_id, content, msg_type, extra_info, deleted)
VALUES(986, 'Y6Bm69xjNm', 'uuWWEsz7PZ', 'uPv0dfKiIL', 'YO1lz07xod', '5', 'LsIiFeGjwA', '0');
INSERT INTO flink_test_copy.quick_chat_msg
(id, from_id, to_id, relation_id, content, msg_type, extra_info, deleted)
VALUES(999, 'xxxx3', 'uuWWEsz7PZ', 'uPv0dfKiIL', 'YO1lz07xod', '5', 'LsIiFeGjwA', '0');

CREATE TABLE transaction_details (
transaction_id bigint NOT NULL,
user_id bigint NOT NULL,
transaction_amount decimal(18,2) DEFAULT NULL,
transaction_device varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,
transaction_region varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,
average_daily_amount decimal(18,2) DEFAULT NULL,
recent_transaction_count int DEFAULT NULL,
has_dispute_history int DEFAULT NULL,
risk_level varchar(500) DEFAULT NULL,
UNIQUE KEY transaction_details_unique (transaction_id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

INSERT INTO flink_test_copy.transaction_details
(transaction_id, user_id, transaction_amount, transaction_device, transaction_region, average_daily_amount, recent_transaction_count, has_dispute_history, risk_level)
VALUES(227, 110, 114.55, 'YMsjSP2swC', 'Kazakhstan', 350.08, 322, 25, '1N8ZfkRNaB');
INSERT INTO flink_test_copy.transaction_details
(transaction_id, user_id, transaction_amount, transaction_device, transaction_region, average_daily_amount, recent_transaction_count, has_dispute_history, risk_level)
VALUES(256, 591, 480.09, 'TovRvRSoPZ', 'Democratic Republic of the Congo', 436.38, 640, 95, 'F961DTDjPR');
INSERT INTO flink_test_copy.transaction_details
(transaction_id, user_id, transaction_amount, transaction_device, transaction_region, average_daily_amount, recent_transaction_count, has_dispute_history, risk_level)
VALUES(356, 537, 768.42, 'hpUWIzJjya', 'Slovenia', 790.01, 476, 18, 'NebXoE7aqS');
INSERT INTO flink_test_copy.transaction_details
(transaction_id, user_id, transaction_amount, transaction_device, transaction_region, average_daily_amount, recent_transaction_count, has_dispute_history, risk_level)
VALUES(523, 640, 329.52, 'u1MD6CE3gg', 'Uganda', 171.94, 99, 25, 'pP2BJgDqJS');
INSERT INTO flink_test_copy.transaction_details
(transaction_id, user_id, transaction_amount, transaction_device, transaction_region, average_daily_amount, recent_transaction_count, has_dispute_history, risk_level)
VALUES(573, 551, 918.46, 'uV62E6zN3J', 'Turkey', 310.84, 61, 3, 'izdz8Ok3uL');

Anything else

Start Process:FlinkSubmit/23
Start Process Step:SUBMIT_PRECHECK
2025-01-07 09:33:35.034 INFO org.dinky.service.impl.TaskServiceImpl(188): Start check and config task, task:MySQLCDC 整库到 Doris
Process Step SUBMIT_PRECHECK exit with status:FINISHED
Start Process Step:SUBMIT_EXECUTE
Start Process Step:SUBMIT_BUILD_CONFIG
2025-01-07 09:33:35.035 INFO org.dinky.service.impl.TaskServiceImpl(306): Start initialize FlinkSQLEnv:
2025-01-07 09:33:35.038 INFO org.dinky.service.impl.TaskServiceImpl(326): Initializing data permissions...
2025-01-07 09:33:35.041 INFO org.dinky.service.impl.TaskServiceImpl(328): Finish initialize FlinkSQLEnv.
2025-01-07 09:33:35.043 INFO org.dinky.service.impl.TaskServiceImpl(256): Init remote cluster
Process Step SUBMIT_BUILD_CONFIG exit with status:FINISHED
2025-01-07 09:33:35.056 INFO org.dinky.service.task.FlinkSqlTask(69): Initializing Flink job config...
2025-01-07 09:33:35.069 INFO org.dinky.trans.AbstractOperation(86): Start build CDCSOURCE Task...
2025-01-07 09:33:35.073 INFO org.dinky.trans.AbstractOperation(184): A total of 2 tables were detected...
2025-01-07 09:33:35.074 INFO org.dinky.trans.AbstractOperation(186): 1: flink_test_copy.quick_chat_msg
2025-01-07 09:33:35.074 INFO org.dinky.trans.AbstractOperation(186): 2: flink_test_copy.transaction_details
2025-01-07 09:33:35.075 INFO org.dinky.trans.AbstractOperation(195): Set parallelism: 1
2025-01-07 09:33:35.075 INFO org.dinky.trans.AbstractOperation(199): Set checkpoint: 10000
2025-01-07 09:33:35.075 INFO org.dinky.trans.AbstractOperation(202): Build mysql-cdc successful...
2025-01-07 09:33:35.076 INFO org.dinky.cdc.AbstractSinkBuilder(190): Build deserialize successful...
2025-01-07 09:33:35.077 INFO org.dinky.cdc.AbstractSinkBuilder(203): Build partitionBy successful...
2025-01-07 09:33:35.077 INFO org.dinky.cdc.AbstractSinkBuilder(205): Build shunt successful...
2025-01-07 09:33:35.078 INFO org.dinky.cdc.AbstractSinkBuilder(147): Build flink_test_copy.quick_chat_msg flatMap successful...
2025-01-07 09:33:35.078 INFO org.dinky.cdc.AbstractSinkBuilder(148): Start build flink_test_copy.quick_chat_msg sink...
2025-01-07 09:33:35.079 INFO org.dinky.cdc.AbstractSinkBuilder(53): Create VIEW_flink_test_copy_quick_chat_msg temporaryView successful...
2025-01-07 09:33:35.080 INFO org.dinky.cdc.AbstractSinkBuilder(84): CREATE TABLE IF NOT EXISTS quick_chat_msg (
id BIGINT NOT NULL
,from_id STRING
,to_id STRING
,relation_id STRING
,content STRING
,msg_type STRING
,extra_info STRING
,deleted STRING
,time TIMESTAMP
,date DATE
,PRIMARY KEY ( id ) NOT ENFORCED
) WITH (
'password' = '9JYzE8dMRQwvV1WVhv6EeuY6aAfpanwx',
'connector' = 'doris',
'sink.max-retries' = '1',
'fenodes' = '127.0.0.1:8030',
'doris.batch.size' = '1',
'sink.properties.read_json_by_line' = 'true',
'table.identifier' = 'db_test_copy.quick_chat_msg',
'sink.properties.format' = 'json',
'sink.label-prefix' = '4654',
'username' = 'root')

2025-01-07 09:33:35.082 INFO org.dinky.cdc.AbstractSinkBuilder(86): Create quick_chat_msg FlinkSQL DDL successful...
2025-01-07 09:33:35.083 INFO org.dinky.cdc.AbstractSinkBuilder(232): INSERT INTO quick_chat_msg SELECT
id
,from_id
,to_id
,relation_id
,content
,msg_type
,extra_info
,deleted
,time
,date
FROM VIEW_flink_test_copy_quick_chat_msg
2025-01-07 09:33:35.088 INFO org.dinky.cdc.AbstractSinkBuilder(235): Create quick_chat_msg FlinkSQL insert into successful...
2025-01-07 09:33:35.088 INFO org.dinky.cdc.AbstractSinkBuilder(147): Build flink_test_copy.transaction_details flatMap successful...
2025-01-07 09:33:35.089 INFO org.dinky.cdc.AbstractSinkBuilder(148): Start build flink_test_copy.transaction_details sink...
2025-01-07 09:33:35.090 INFO org.dinky.cdc.AbstractSinkBuilder(53): Create VIEW_flink_test_copy_transaction_details temporaryView successful...
2025-01-07 09:33:35.090 INFO org.dinky.cdc.AbstractSinkBuilder(84): CREATE TABLE IF NOT EXISTS transaction_details (
transaction_id BIGINT NOT NULL
,user_id BIGINT NOT NULL
,transaction_amount DECIMAL(18,2)
,transaction_device STRING
,transaction_region STRING
,average_daily_amount DECIMAL(18,2)
,recent_transaction_count INT
,has_dispute_history INT
,risk_level STRING
,PRIMARY KEY ( transaction_id ) NOT ENFORCED
) WITH (
'password' = '9JYzE8dMRQwvV1WVhv6EeuY6aAfpanwx',
'connector' = 'doris',
'sink.max-retries' = '1',
'fenodes' = '127.0.0.1:8030',
'doris.batch.size' = '1',
'sink.properties.read_json_by_line' = 'true',
'table.identifier' = 'db_test_copy.transaction_details',
'sink.properties.format' = 'json',
'sink.label-prefix' = '4654',
'username' = 'root')

2025-01-07 09:33:35.092 INFO org.dinky.cdc.AbstractSinkBuilder(86): Create transaction_details FlinkSQL DDL successful...
2025-01-07 09:33:35.093 INFO org.dinky.cdc.AbstractSinkBuilder(232): INSERT INTO transaction_details SELECT
transaction_id
,user_id
,transaction_amount
,transaction_device
,transaction_region
,average_daily_amount
,recent_transaction_count
,has_dispute_history
,risk_level
FROM VIEW_flink_test_copy_transaction_details
2025-01-07 09:33:35.096 INFO org.dinky.cdc.AbstractSinkBuilder(235): Create transaction_details FlinkSQL insert into successful...
2025-01-07 09:33:35.096 INFO org.dinky.cdc.AbstractSinkBuilder(207): Build sink successful...
2025-01-07 09:33:35.142 INFO org.apache.doris.flink.table.DorisDynamicTableSink(137): Send request to Doris FE 'http://127.0.0.1:8030/api/db_test_copy/quick_chat_msg/_schema' with user 'root'.
2025-01-07 09:33:35.147 ERROR org.apache.doris.flink.table.DorisDynamicTableSink(530): Doris FE's response cannot map to schema. res: "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy" org.apache.doris.shaded.com.fasterxml.jackson.databind.exc.InvalidFormatException: Cannot deserialize value of type int from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid int value
at [Source: (String)""errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy""; line: 1, column: 1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.exc.InvalidFormatException.from(InvalidFormatException.java:67) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.DeserializationContext.weirdStringException(DeserializationContext.java:1991) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.DeserializationContext.handleWeirdStringValue(DeserializationContext.java:1219) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.std.StdDeserializer._parseIntPrimitive(StdDeserializer.java:768) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.std.StdDeserializer._deserializeFromString(StdDeserializer.java:288) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromString(BeanDeserializerBase.java:1495) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
...................
at io.undertow.servlet.handlers.ServletInitialHandler$1.handleRequest(ServletInitialHandler.java:103) ~[undertow-servlet-2.2.28.Final.jar:2.2.28.Final]
at io.undertow.server.Connectors.executeRootHandler(Connectors.java:393) ~[undertow-core-2.2.28.Final.jar:2.2.28.Final]
at io.undertow.server.HttpServerExchange$1.run(HttpServerExchange.java:852) ~[undertow-core-2.2.28.Final.jar:2.2.28.Final]
at org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35) ~[jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:2019) ~[jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1558) ~[jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1449) ~[jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.xnio.XnioWorker$WorkerThreadFactory$1$1.run(XnioWorker.java:1282) ~[xnio-api-3.8.7.Final.jar:3.8.7.Final]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_432]

2025-01-07 09:33:35.154 ERROR org.dinky.trans.AbstractOperation(217): org.apache.doris.flink.exception.DorisException: Doris FE's response cannot map to schema. res: "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy" org.apache.doris.flink.exception.DorisRuntimeException: org.apache.doris.flink.exception.DorisException: Doris FE's response cannot map to schema. res: "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy"
at org.apache.doris.flink.rest.RestService.isUniqueKeyType(RestService.java:505) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.flink.table.DorisDynamicTableSink.getSinkRuntimeProvider(DorisDynamicTableSink.java:84) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecSink.createSinkTransformation(CommonExecSink.java:151) ~[flink-table-planner_2.12-1.20.0.jar:1.20.0]
at org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink.translateToPlanInternal(StreamExecSink.java:214) ~[flink-table-planner_2.12-1.20.0.jar:1.20.0]
at org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168) ~[flink-table-planner_2.12-1.20.0.jar:1.20.0]
...............
at io.undertow.server.HttpServerExchange$1.run(HttpServerExchange.java:852) ~[undertow-core-2.2.28.Final.jar:2.2.28.Final]
at org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35) ~[jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:2019) ~[jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1558) ~[jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1449) ~[jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.xnio.XnioWorker$WorkerThreadFactory$1$1.run(XnioWorker.java:1282) ~[xnio-api-3.8.7.Final.jar:3.8.7.Final]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_432]
Caused by: org.apache.doris.flink.exception.DorisException: Doris FE's response cannot map to schema. res: "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy"
at org.apache.doris.flink.rest.RestService.parseSchema(RestService.java:531) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.flink.rest.RestService.getSchema(RestService.java:438) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.flink.rest.RestService.isUniqueKeyType(RestService.java:503) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
... 191 more
Caused by: org.apache.doris.shaded.com.fasterxml.jackson.databind.exc.InvalidFormatException: Cannot deserialize value of type int from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid int value
at [Source: (String)""errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy""; line: 1, column: 1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.exc.InvalidFormatException.from(InvalidFormatException.java:67) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.DeserializationContext.weirdStringException(DeserializationContext.java:1991) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.DeserializationContext.handleWeirdStringValue(DeserializationContext.java:1219) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.std.StdDeserializer._parseIntPrimitive(StdDeserializer.java:768) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.std.StdDeserializer._deserializeFromString(StdDeserializer.java:288) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromString(BeanDeserializerBase.java:1495) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeOther(BeanDeserializer.java:196) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize(BeanDeserializer.java:186) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.deser.DefaultDeserializationContext.readRootValue(DefaultDeserializationContext.java:323) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4674) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3629) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.shaded.com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3597) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.flink.rest.RestService.parseSchema(RestService.java:523) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.flink.rest.RestService.getSchema(RestService.java:438) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
at org.apache.doris.flink.rest.RestService.isUniqueKeyType(RestService.java:503) ~[flink-doris-connector-1.20-24.0.1.jar:24.0.1]
... 191 more

Process Step SUBMIT_EXECUTE exit with status:FAILED
java.lang.Exception
at org.dinky.job.JobManager.executeSql(JobManager.java:307)
at org.dinky.service.task.FlinkSqlTask.execute(FlinkSqlTask.java:70)
at org.dinky.service.impl.TaskServiceImpl.executeJob(TaskServiceImpl.java:211)
at org.dinky.service.impl.TaskServiceImpl.executeJob(TaskServiceImpl.java:202)
at org.dinky.service.impl.TaskServiceImpl$$FastClassBySpringCGLIB$$22087f7c.invoke()
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAop
..............
at java.security.AccessController.doPrivileged(Native Method)
at io.undertow.servlet.handlers.ServletInitialHandler$1.handleRequest(ServletInitialHandler.java:103)
at io.undertow.server.Connectors.executeRootHandler(Connectors.java:393)
at io.undertow.server.HttpServerExchange$1.run(HttpServerExchange.java:852)
at org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35)
at org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:2019)
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1558)
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1449)
at org.xnio.XnioWorker$WorkerThreadFactory$1$1.run(XnioWorker.java:1282)
at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.NullPointerException
at org.dinky.executor.CustomTableResultImpl$Builder.build(CustomTableResultImpl.java:260)
at org.dinky.trans.ddl.CreateCDCSourceOperation.execute(CreateCDCSourceOperation.java:219)
at org.dinky.interceptor.FlinkInterceptor.build(FlinkInterceptor.java:53)
at org.dinky.executor.Executor.pretreatExecute(Executor.java:247)
at org.dinky.executor.Executor.executeSql(Executor.java:260)
at org.dinky.job.runner.JobPipelineRunner.run(JobPipelineRunner.java:76)
at org.dinky.job.JobManager.executeSql(JobManager.java:289)
... 166 more

Process FlinkSubmit/23 exit with status:FAILED

Version

1.2.0

Are you willing to submit PR?

Yes I am willing to submit a PR!

Code of Conduct

I agree to follow this project's Code of Conduct

The text was updated successfully, but these errors were encountered:

github-actions · 2025-01-07T02:04:54Z

Hello @sdjfpop, this issue is about CDC/CDCSOURCE, so I assign it to @aiwenmo. If you have any questions, you can comment and reply.

你好 @sdjfpop, 这个 issue 是关于 CDC/CDCSOURCE 的，所以我把它分配给了 @aiwenmo。如有任何问题，可以评论回复。

sdjfpop added Bug Something isn't working Waiting for reply Waiting for reply labels Jan 7, 2025

github-actions bot assigned aiwenmo Jan 7, 2025

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Cannot deserialize value of type `int` from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid `int` value #4128

Cannot deserialize value of type `int` from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid `int` value #4128

sdjfpop commented Jan 7, 2025 •

edited

Loading

github-actions bot commented Jan 7, 2025

Cannot deserialize value of type int from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid int value #4128

Cannot deserialize value of type int from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid int value #4128

Comments

sdjfpop commented Jan 7, 2025 • edited Loading

Search before asking

What happened

What you expected to happen

How to reproduce

Anything else

Version

Are you willing to submit PR?

Code of Conduct

github-actions bot commented Jan 7, 2025

Cannot deserialize value of type `int` from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid `int` value #4128

Cannot deserialize value of type `int` from String "errCode=7,detailMessage=unknowndatabases,dbName=db_test_copy": not a valid `int` value #4128

sdjfpop commented Jan 7, 2025 •

edited

Loading