实时计算 Flink版

Flink的vvr 1.17的ds连接器什么时候发呀？ 以下为热心网友提供的参考意见 上周有问题没发，这周发上去的时候跟大家说。此回答整理自钉群“实时计算Flink产品交流群”

使用CTAS 把mysql 表同步数据 到hologres ，Flink有什么参数可以使hologres 的字段都小写吗？因为mysql 有大写也有小写，比较混乱，我想holo做个…

在机器学习PAI用的逻辑回归这一步会报错是因为什么？org.apache.flink.runtime.JobException: Recovery is suppressed by…

FlinkCDC使用MySQLSource为什么将并行度从1提高，fromSource（）这就会卡住 以下为热心网友提供的参考意见 Flink CDC (Change Data C…

Flink cdc oracle 2.11Flink 1.13.6“` SourceFunction sourceFunction = OracleSource.bui…

我往Hologres里面插入数据。为什么老是报错？ Caused by: org.apache.flink.table.api.TableException: Could not …

Flink应该如何保存savepoint呢？我写的保存语句如下。也不对，是吗？bin/flink stop \–savepointPath /tmp/savepoint…

Flink 发行版在 conf 目录中附带了以下 log4j 配置文件，如果启用了 Log4j 2，则会自动使用如下文件： log4j-cli.properties：Flink 命…

flink1.17.2，在代码中使用下面的方式注册函数时不能使用using jar，必须把jar放到任务依赖里面，一旦使用using jar语法，那么会报下面的错误，使用sqlcl…

关于flink cdc3.0的问题:我按照官网 demo 测试,初始快照阶段,可以把库表结构和数据同步到 starrocks,但后续新增数据无法同步过来,flink 上没有日志没有…

filnk-operator 不用强制在服务器上在搞一个jdk11 版本吧。 我现在用k8s 上安装了operator1.6 版本，我的flink 任务也正常跑起来了啊。 有大佬知…

麻烦问一下，这个–allownonrestoredstate（-n）参数，支持加在flinksql的任务上吗？ 以下为热心网友提供的参考意见 是的，支持加在 Flink…