问题一:coordinate字段 是point类型 flink不支持怎么办 ?
coordinate字段 是point类型 flink不支持怎么办 ? 我在flinksql改成string的话 写入时报错
参考答案:
Flink SQL 支持 Point 类型,但是在写入时需要将 Point 类型的数据转换为字符串。你可以使用 ST_AsText() 函数将 Point 类型的数据转换为字符串。以下是一个示例:
INSERT INTO your_table (coordinate) SELECT ST_AsText(coordinate) FROM your_source_table;
这样,你就可以将 Point 类型的 coordinate 字段转换为字符串,并将其写入目标表中。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/586076
问题二:请教一个flink-stream 的问题,在自定义sink中如何读取该广播流 的数据?
请教一个flink-stream 的问题,在作业中我定义了一个 广播流,将该广播流将一些配置信息动态广播到下游算子中,也实现了BroadcastProcessFunction 类,可正常操作 广播流数据。但在自定义sink中如何读取该广播流 的数据?
参考答案:
getRuntimeContext().getBroadcastState(xxxx); ,
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/586075
问题三:请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog?
请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog?
参考答案:
flink必须写到配置文件里,kerberos配置只能从配置文件读
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/586072
问题四:flinkcdc读取mysql的启动模式是不是不支持timestamp模式?
flinkcdc读取mysql的启动模式是不是不支持timestamp模式?
参考答案:
是2.3還是2.4以上已經支持了
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/586071
问题五:Flink如果有两条流join,两条流的可变化时间周期跨度很大,这种场景应该怎么解决?
Flink如果有两条流join,两条流的可变化时间周期跨度很大,这种场景应该怎么解决?
参考答案:
云上有双流不同ttl可以解一下state太大的问题
关于本问题的更多回答可点击进行查看: