dinky icon indicating copy to clipboard operation
dinky copied to clipboard
verified publisher icon DataLinkDC

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

Open sdjfpop opened this issue 1 year ago • 3 comments

Search before asking

  • [X] 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?

  • [X] Yes I am willing to submit a PR!

Code of Conduct

sdjfpop avatar Jan 07 '25 02:01 sdjfpop

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。如有任何问题，可以评论回复。

github-actions[bot] avatar Jan 07 '25 02:01 github-actions[bot]

Add sink.url in your CDCSOURCE config.

aiwenmo avatar Jan 15 '25 12:01 aiwenmo

Hello @, this issue has not been active for more than 30 days. This issue will be closed in 7 days if there is no response. If you have any questions, you can comment and reply.

你好 @, 这个 issue 30 天内没有活跃，7 天后将关闭，如需回复，可以评论回复。

github-actions[bot] avatar Mar 01 '25 00:03 github-actions[bot]