我们生产环境flink遇到数据写入时间比数据生成时间还早的情况,不知道是什么原因导致的。
通过flink的DorisSink,代码片段如下
setProperty("columns", "tenantId,requestId,version,date = now()")
还望官方给出疑问解答和分析方向,感谢!!
我们生产环境flink遇到数据写入时间比数据生成时间还早的情况,不知道是什么原因导致的。
通过flink的DorisSink,代码片段如下
setProperty("columns", "tenantId,requestId,version,date = now()")
还望官方给出疑问解答和分析方向,感谢!!