Re: flink mysql cdc支持mysql的json格式吗？

[hk__lrzy]

https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-basic-types
支持



--
Sent from: http://apache-flink.147419.n8.nabble.com/

关于Table和DataStream相互转化的问题

[lp]

官网关于Table和DataStream相互转化部分：
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/data_stream_api/#converting-between-datastream-and-table

①样例代码中，
// interpret the insert-only Table as a DataStream again
DataStream resultStream = tableEnv.toDataStream(resultTable);

但是查询了StreamTableEnvironment中没有toDataStream(Table resultTable);这个方法


②样例代码中：https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/common/#emit-a-table

tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(new Csv().fieldDelimiter('|').deriveSchema())
.withSchema(schema)
.createTemporaryTable("CsvSinkTable");


我的依赖中没有new Csv()，如果我要这样使用，需要额外的引入什么依赖包吗

谢谢！！！



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink checkpoint 数据清理问题

[hk__lrzy]

1. state.checkpoints.num-retained 设置保存checkpoint的数量。
2. 因为你写的本地文件，所以JM侧的集群是否只在checkpoint的metadata信息，而其他机器上保存着具体的state状态



--
Sent from: http://apache-flink.147419.n8.nabble.com/

关于 flinksql 维表的问题

[WeiXubin]

我想实现将MySQL中的 A 表数据预先查询出来进行缓存，用于给流表 B 进行 join关联。接下来定时查询并更新 A 表内的缓存数据，请问目前
FlinkSQL 可以实现吗？



--
Sent from: http://apache-flink.147419.n8.nabble.com/