flinkx

flinkx copied to clipboard

json例子 { "job" : { "content" : [ { "reader" : { "parameter" : { "databaseName":"inventory", "tableList": ["inventory.orders"], "username" : "sa", "password" : "Password@,", "cat" : "insert,delete,update", "url" : "jdbc:sqlserver://192.168.1.153:1433;databaseName=inventory",...

xiazhiliangfeng

hive或者hdfs同步数据到mysql或者tidb，flink webui看不到日志

mztt-elfine

example: execute the command as follows: 1. savepoint 使用 ./bin/flinkx -mode standalone -jobType sql -flinkxDistDir flinkx-dist -job flinkx-examples/sql/develp/cp.sql -flinkLibDir ../flink-1.12.7/lib -flinkConfDir ../flink-1.12.7/conf -confProp "{\"sql.checkpoint.mode\":\"EXACTLY_ONCE\",\"execution.checkpointing.interval\":\"6000\"}" -s hdfs://dswhhadoop-3:8020/warehouse/tablespace/managed/checkpoint/0aa6ad6d5daafd265bebb8de6c2d8bd4 结果报错! 显示没有-s这个参数选项，无法恢复savepoint 2. 另外一种方式...

kehaohao

maven package 一直 {s}->https://github.com:443: Connection reset

1

按quickstart进行到 mvn clean package -DskipTests 时 一直在下载包，持续一个多小时，一直： Downloading: https://github.com/dtstack/maven-repository/raw/master/org/apache/flink/flink-hadoop-compatibility_2.12/1.12.7/flink-hadoop-compatibility_2.12-1.12.7.pom Apr 15, 2022 6:01:23 PM org.apache.maven.wagon.providers.http.httpclient.impl.execchain.RetryExec execute INFO: I/O exception (java.net.SocketException) caught when processing request to {s}->https://github.com:443: Connection reset Apr 15,...

linbaicome