问题一:Flink vvr这边会支持整库同步数据到MaxCompute吗?
Flink vvr这边会支持整库同步数据到MaxCompute吗?
参考答案:
会安排,不过还没定具体实现时间。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/603870
问题二:请问Flink这种场景怎么处理?
我现在接入的是MySQL的业务数据,Hologres里面建表时设置的binlog ttl是3天,现在下游统计作业统计出来的数据有问题,想重新跑整个统计表的数据,但是清空了数据无状态启动之后发现只有最近3天的统计数据,我希望能从整个明细表进行统计,请问Flink这种场景怎么处理?
参考答案:
你用flink的batch ,从hologres ods层批处理跑一遍,binlog ttl 就可以不用管了,流批一体的数据回填场景。 https://help.aliyun.com/zh/flink/developer-reference/hologres-connector/?spm=a2c4g.11186623.0.i37#section-r91-f4z-7lp
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/603866
问题三:Flink中怎么判断源表是否支持startTime呢?
Flink中怎么判断源表是否支持startTime呢?
参考答案:
看各 Connector 文档,如 sls with 参数有startTime 就是支持的。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/603865
问题四:Flink这个时间是选的上游表的binlog生成的时间吗?
Flink这个时间是选的上游表的binlog生成的时间吗?
参考答案:
这个时间是指你指定启动的时间,自定义启动时间,
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/603864
问题五:Flink SLS的connector不支持JSON 的formatter?
Flink SLS的connector不支持JSON 的formatter?
参考答案:
SLS的connector目前不支持json的formatter。不过可以使用下面这几种方法实现
使用json_value函数解析JSON字符串中的特定字段。详细信息可参考阿里云文档:https://help.aliyun.com/document_detail/207984.html。
使用json_tuple函数解析JSON字符串中的多个字段。详细信息可参考阿里云文档:https://help.aliyun.com/document_detail/207993.html?spm=a2c4g.45029.0.i2。
将整个JSON字符串作为一个整体的varchar类型字段接收,并将其下发到结果表。这样,您可以在后续的处理中自行解析JSON数据。
使用Flink内置的JSON_STRING函数将非JSON格式的数据转换为JSON格式的字符串。关于更多Flink内置函数,请参阅官方文档:https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/dev/table/functions/systemfunctions/ 。
关于本问题的更多回答可点击进行查看: