Flink通过Phoenix写入Hbase，在IDEA中可以正常执行，但是打包后提交到集群就报这个异常，打包时已经吧需要的依赖打进去了，Hbase版本1.6.0
Phoenix版本4.16.1，Maven中
依赖如下：
org.apache.phoenix
phoenix-core
4.16.1
org.apache.phoenix
phoenix-server-hbase-1.6
4.16.1
org.apache.phoenix
phoenix-client-hbase-1.6
4.16.1
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
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
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
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
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
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
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,
