COMMENT '备注',
`deleted` INT COMMENT '是否删除(0.,否 1.是)'
) WITH(
'connector' = 'mysql-cdc',
'hostname' = '192.168.171.19',
'port' = '3306',
'username' = '***',
'password' = '***',
'database-name' = 'test_db',
'table-name' = 'user'
);
插入语句:
INSERT INTO default_catalog.default_database.kafka_user
SELECT *
FROM default_catalog.default_database.mysql_user;
Flink入门选手,
希望大佬帮助解答!
maker_d...@foxmail.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
hi
从报错上看是缺少了 Flink-sql-kafka 那个包,把这个包添加到 Flink/lib 下面再跑一下
-
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Flink集成到CDH集群,Flink重启后web页面打不开,有没有遇到同样情况的,大家交流一下。
maker_d...@foxmail.com
去yarn后台,看看am落在哪个机器上面,地址就是那个。
---原始邮件---
发件人: "maker_d...@foxmail.com"
: Illegal use of
'NULL'
经过观察,我发现我的insert语句中,多个列的值为NULL。
请问,这种情况要如何解决,要一列一列的转化吗?(这张表非常大,列很多)
到Doris表数据不同步是否也是这个的原因?
请求各位帮助。
maker_d...@foxmail.com
sets()
val kafkaDataStream: DataStream[String] = env.addSource(kafkaConsumer)
...在网上搜索基本都是说依赖版本问题,但我检查了lib,与scala相关的都是2.12版本的。找不到问题在哪儿,请各位指教,谢谢!
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
;,
'password' = 'XXX',
'sink.batch.size' = '1'
);
insert into datacollect_business_doris select * from datacollect_business_kafka;
在网上查找信息,flink-conf.yaml文件中添加:env.java.opts: "-Dfile.encoding=UTF-8”
flink版本:1.12.4
部署模式:on yarn
希望各位大佬帮助。
谢谢!
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
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
at java.lang.Thread.run(Thread.java:748)
Shutting down the session...
done.
不知道是哪里出问题了,在yarn上看flink-session任务是正常的,其中的其他任务都正常运行,就是不能提交了。
请求各位大佬帮助。
maker_d...@foxmail.com
e read
from '/data/mysql/storage/logs/bin_log/bin.001086' at 426321679.
at
com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:937)
... 3 more
maker_d...@foxmail.com
时隔一个月又遇到了这个问题,现在有人能帮忙解决一下吗?
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同步多个表
14 matches
Mail list logo