MOBIN-F commented on PR #4193: URL: https://github.com/apache/paimon/pull/4193#issuecomment-3056603251
> > > > @JingsongLi @yuzelin @zhuangchong can you help review this pr? tks~你能帮忙审核一下这个公关吗？谢谢~ > > > > > > > > > i have a question， if tableA and tableB have same field ， use table.col not col can reduce calculate，why use col, the reason is DataField only have name ,not have tableName ? 我有个问题，如果 tableA 和 tableB 有相同的字段，使用 table.col 而不是 col 可以减少计算，为什么要使用 col，原因是 DataField 只有名称，没有 tableName？@MOBIN-F > > > > > > hi,@dyp12 I recommend you to use the [pipeline of flink-cdc](https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/core-concept/data-pipeline/), which provides the same capabilities and is more flexible.你好，我推荐你使用 [flink-cdc 的管道 ](https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/core-concept/data-pipeline/)，它提供相同的功能并且更加灵活。 > > i need kafka->paimon,but the [pipeline of flink-cdc](https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/core-concept/data-pipeline/) not support，kafka only support sink，do you use this function is production environment ? 我需要 kafka->paimon，但是 [flink-cdc 的 pipeline](https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/core-concept/data-pipeline/) 不支持，kafka 只支持 sink，请问您在生产环境中使用这个功能吗？@MOBIN-F > > > > @JingsongLi @yuzelin @zhuangchong can you help review this pr? tks~ > > > > > > > > > i have a question， if tableA and tableB have same field ， use table.col not col can reduce calculate，why use col, the reason is DataField only have name ,not have tableName ? @MOBIN-F > > > > > > hi,@dyp12 I recommend you to use the [pipeline of flink-cdc](https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/core-concept/data-pipeline/), which provides the same capabilities and is more flexible. > > i need kafka->paimon,but the [pipeline of flink-cdc](https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/core-concept/data-pipeline/) not support，kafka only support sink，do you use this function is production environment ? @MOBIN-F Yes, this PR has been in our production application for a long time, mainly used to synchronize Kafka's canal-json->paimon There is no difference between using table.col or col, the calculated column is effective for every record -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
