wmtbnbo
wmtbnbo
日志报错为： `[2022-03-30 14:25:13] KSqlParser.http-nio-8048-exec-8 - ERROR - Parser kafka sql has error, msg is java.lang.NullPointerException at org.smartloli.kafka.eagle.common.constant.KSqlParser.parseNode(KSqlParser.java:71) at org.smartloli.kafka.eagle.common.constant.KSqlParser.parseNode(KSqlParser.java:145) at org.smartloli.kafka.eagle.common.constant.KSqlParser.parserTopic(KSqlParser.java:49) at org.smartloli.kafka.eagle.core.factory.KafkaServiceImpl.segments(KafkaServiceImpl.java:583) at org.smartloli.kafka.eagle.core.factory.KafkaServiceImpl.parseSql(KafkaServiceImpl.java:516) at org.smartloli.kafka.eagle.core.sql.execute.KafkaSqlParser.execute(KafkaSqlParser.java:53) at org.smartloli.kafka.eagle.web.service.impl.TopicServiceImpl.execute(TopicServiceImpl.java:133) at...
是否可以考虑做成通用功能，直接通过配置api地址模板进行通知
你先禁用checkpoint然后提交任务到集群，查看jobmanager的日志，看是否存在异常
It supports function customization，The development method can refer to the flink official documents,Put the expansion package under directory `plugins/`.Use the following method to load functions in the SQL file： `create...
> 我分别测试了 FSStateBackend , RocksDBStateBackend,检查点保留策略也设置为了‘RETAIN_ON_CANCELLATION’，发现俩者效果都是一样的，当flink failover自动重启时，log打印信息如下： > `2020-11-06 08:41:38,722 INFO io.debezium.connector.mysql.MySqlConnectorTask [] - Found no existing offset, so preparing to perform a snapshot ` > 当我手动指定检查点启动任务时，log 打印信息如下： > `2020-11-06 09:21:12,289...
> 请问有解决了吗 没有，没有使用cdc了，自己用flink+kafka+canal实现了一个类似cdc的程序,cdc这个程序现在问题还有点多
Please,Have you solved this problem?
> obtaining JSON means,JSON fields are not supported in starrocks sources,But I need to read this type of field