时隔一个月又遇到了这个问题，现在有人能帮忙解决一下吗？
maker_d...@foxmail.com
发件人： maker_d...@foxmail.com
发送时间： 2022-02-15 14:13
收件人： user-zh@flink.apache.org
主题： flinkcdc:slave with the same server_uuid/server_id as this slave has
connected to the master;
flink version：flink-1.13.5
cdc version：2.1.1
在使用flinkcdc同步多个表
.001086' at 426321679.
at
com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:937)
... 3 more
maker_d...@foxmail.com
ap.java:74)
at java.lang.Thread.run(Thread.java:748)
Shutting down the session...
done.
不知道是哪里出问题了，在yarn上看flink-session任务是正常的，其中的其他任务都正常运行，就是不能提交了。
请求各位大佬帮助。
maker_d...@foxmail.com
)
at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952)
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
... 4 more
不知道是哪里配置有问题还是缺少什么jar包之类的。
请各位帮忙解答。
maker_d...@foxmail.com
大家好，
我将flink部署在k8s集群上，使用官方文档上的session模式进行部署，可以正常提交任务。
现在我想使用sqlclient，在提交任务时提示 ：
[ERROR] Could not execute SQL statement. Reason:
java.net.UnknownHostException: flink-cluster
请问大家，如何使用sqlclient连接k8s上的flink session。
flink版本 1.12.4.
maker_d...@foxmail.com
UTF-8”
flink版本：1.12.4
部署模式：on yarn
希望各位大佬帮助。
谢谢！
maker_d...@foxmail.com
:14,538 INFO org.apache.flink.yarn.YarnClusterDescriptor
[] - Deleting files in
file:/root/.flink/application_1623148752688_0041.
maker_d...@foxmail.com
sets()
val kafkaDataStream: DataStream[String] = env.addSource(kafkaConsumer)
...在网上搜索基本都是说依赖版本问题，但我检查了lib，与scala相关的都是2.12版本的。找不到问题在哪儿，请各位指教，谢谢！
maker_d...@foxmail.com
: Illegal use of
'NULL'
经过观察，我发现我的insert语句中，多个列的值为NULL。
请问，这种情况要如何解决，要一列一列的转化吗？（这张表非常大，列很多）
到Doris表数据不同步是否也是这个的原因？
请求各位帮助。
maker_d...@foxmail.com
去yarn后台，看看am落在哪个机器上面，地址就是那个。
---原始邮件---
发件人: "maker_d...@foxmail.com"
Flink集成到CDH集群，Flink重启后web页面打不开，有没有遇到同样情况的，大家交流一下。
maker_d...@foxmail.com
hi
从报错上看是缺少了 Flink-sql-kafka 那个包,把这个包添加到 Flink/lib 下面再跑一下
-
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/
您好，
flink-sql-connector-kafka_2.11-1.11.3.jar
这个包已经在flink的lib目录下了。
maker_d...@foxmail.com
发件人： JasonLee
发送时间： 2021-04-25 17:56
收件人： user-zh
主题： Re: 提交FlinkSQLKafka表报异常cannt load user class
hi
从报错上看是缺少了 Flink-sql-kafka 那个包,把这个包添加到 Flink/lib 下面再跑一下
-
Best Wishes
JasonLee
--
Sent
SELECT *
FROM default_catalog.default_database.mysql_user;
Flink入门选手，
希望大佬帮助解答！
maker_d...@foxmail.com
14 matches
Mail list logo
