【详述】Java flink-core 版本1.90 ; flink-connector-starrocks版本 1.2.3_flink-1.15 启动flinkjob报找不到方法。在1.90版本的fink-core 对应类中无此方法,1.15版本中确实存在此方法。,请问是否支持1.90版本?如果支持 flink-connector-starrocks 应该下载哪个版本?
【导入/导出方式】JSON格式最后Sink到StarRock
【背景】
【业务影响】任务启动失败
【StarRocks版本】例如:1.2.3
【导入或者导出方式】Flink
【附件】
java.lang.NoSuchMethodError: org.apache.flink.configuration.ConfigOptions$OptionBuilder.stringType()Lorg/apache/flink/configuration/ConfigOptions$TypedConfigOptionBuilder;
https://github.com/StarRocks/starrocks-connector-for-apache-flink/releases 根据flink版本选择对应的flink-connector-starrocks
看了下最早的版本是flink1.11的,如果是1.9.0的flink版本兼容么?
您好这个目前还不兼容呢。
请问,相较于flink从kafka导数据中断重启之后有offset保证增量获取数据,flink从starRocks导入数据中断后是如何保证增量获取数据的呢?
执行show routine load语句后可以获得offset,新建任务指定下offset即可