flinkStreamSQL

flinkStreamSQL copied to clipboard

redis side和sink的文档描述大量错误请及时更正

2

hengyuan

通过Yarn模式提交任务时报错Caused by: java.lang.ClassNotFoundException: com.dtstack.flink.sql.source.kafka.KafkaConsumer010

3

**### sql文件内容如下：** CREATE TABLE sourceKafkaTable( id int as id, name varchar as name )WITH( type ='kafka10', bootstrapServers ='spark01:9092,spark02:9092', zookeeperQuorum ='spark01:2181,spark02:2181/brokers', offsetReset ='latest', topic ='flink1', parallelism ='1' ); CREATE TABLE sideMysqlTable(...

lijianfeng6666526

在kafka11可以找到consumerThread，但是在kafka2.0版本找不到consumerThread

chaozwn


maidou75293

为啥 服务端plugin 下面的 source jar 加载不了，难道必须放在hadoop-yarn 等目录下？

5

maidou75293

Windows系统下standalone模式下运行报错MiniCluster is not yet running.

4

Exception in thread "main" java.lang.IllegalStateException: MiniCluster is not yet running. at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195) at org.apache.flink.runtime.minicluster.MiniCluster.getHighAvailabilityServices(MiniCluster.java:223) at org.apache.flink.client.program.MiniClusterClient.(MiniClusterClient.java:61) at com.dtstack.flink.sql.launcher.ClusterClientFactory.createStandaloneClient(ClusterClientFactory.java:79) at com.dtstack.flink.sql.launcher.ClusterClientFactory.createClusterClient(ClusterClientFactory.java:66) at com.dtstack.flink.sql.launcher.LauncherMain.main(LauncherMain.java:98)

qiuqingyu

能否把source、sink插件放到共享存储，此共享存储可以被所有节点访问，然后使用remoteSqlPluginPath来指定这个地址

1

能否把source、sink插件放到共享存储，此共享存储可以被所有节点访问，然后使用remoteSqlPluginPath来指定这个地址？ 例如：plugins在oss的地址是：http://oss-aly-bj.com/plugins 在提交任务的时候配置参数 -remoteSqlPluginPath http://oss-aly-bj.com/plugins

durixu2007

1.8 版本 yarn 模式 提交不成功，什么问题

6

maidou75293

Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.2.2 to 42.4.1. Changelog Sourced from postgresql's changelog. [42.4.1] (2022-08-01 16:24:20 -0400) Security fix: CVE-2022-31197 Fixes SQL generated in PgResultSet.refresh() to escape column identifiers so as to...

dependabot[bot]

Bump org.postgresql:postgresql from 42.4.1 to 42.7.2 in /postgresql

1

Bumps [org.postgresql:postgresql](https://github.com/pgjdbc/pgjdbc) from 42.4.1 to 42.7.2. Release notes Sourced from org.postgresql:postgresql's releases. v42.7.1 Fixed regressions since 42.7.0 Revert "Use canonical DateStyle name (#2925)" @​vlsi (#3035) Revert "feat: support SET statements...

dependabot[bot]