You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by "bestchinacoder (via GitHub)" <gi...@apache.org> on 2023/04/20 20:55:20 UTC
[GitHub] [incubator-seatunnel] bestchinacoder commented on issue #4466: The flink engine source is mysqlcdc reporting an error
bestchinacoder commented on issue #4466:
URL: https://github.com/apache/incubator-seatunnel/issues/4466#issuecomment-1516937112
> @zorrofox @EricJoy2048 Thank you for your answer，According to the prompt of the error log, Please implement the `SupportCoordinate` marker interface on the SeaTunnel source. Then I downloaded the source code, found the SeaTunnelSource interface through SeaTunnelFlink of the seatunnel-flink-15-starter module, implemented the SupportCoordinate interface according to the log information,  and compiled Packaging, just use the compiled flink engine to execute. Then it can be executed successfully, but I have a question  There is a judgment here. It turned out that this interface was not implemented, and all of them would go else. Now that this interface is implemented, all of them will go above.   Is there any difference between these two? The judgment here is that the official has not yet made a fine-grained distinction?
Your method does work, but it's not perfect. It can only fetch the data that is already in MySQL, the changed data cannot be synchronized.
--
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: commits-unsubscribe@seatunnel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org