Hi Joost
Could you share your flink version and the two records in debezium-json format
which produced by two MS SQL UPDATE statement ?
Best,
Leonard
> 2022年5月2日 下午9:59,Joost Molenaar 写道:
>
> Hello all,
>
> I'm trying to use Flink-SQL to monitor a Kafka topic that's populated by
> Debezium,
Hi Team,
Yes we can change the parallelism of flink job. So going through the roadmap ,
what I understand that we have put the standalone mode as second priority due
to right reasons. So , if possible can I be of any help to accelerate this as
we have a tight release schedule so would want to c
Hi Jay!
I will take a closer look into this and see if we can use the parallelism
in the scale subresource.
If you could experiment with this and see if it works with the current CRD
that would be helpful . Not sure if we need to change the status or
anything as parallelism is only part of the sp
Thanks all for the valuable feedback.
It seems most people are overall positive about using Slack for dev
discussions, as long as they are properly reflected back to the MLs.
- We definitely need a code of conduct that clearly specifies what people
should / should not do.
- Contributors pinging we
Hi folks,
It looks like flink 1.15 changes its binary distribution because of scala
free. The flink-table-planner_2.12-1.15.0.jar is put under the opt folder.
Now I would like to use it for my scala flink app, so I move it to the lib
folder, but after that, I can not start sql-client. Is it expect
Hi, you can move the flink-table-planner-loader to the /opt. See more in [
https://issues.apache.org/jira/browse/FLINK-25128 |
https://issues.apache.org/jira/browse/FLINK-25128 ]
Best regards,
Yuxia
发件人: "Jeff Zhang"
收件人: "User"
发送时间: 星期六, 2022年 5 月 07日 下午 10:05:55
主题: Unable to start
Hi Users !
What is the recommended way to package custom java code(which has
boilerplate source setup code, custom sql format code) and make it
available in python classpath for local pipeline tests ?
For staging and production, I have the java libraries in the
FLINK_HOME/lib directory and i