flinkStreamSQL
flinkStreamSQL copied to clipboard
基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法
Bumps [vertx-core](https://github.com/eclipse/vert.x) from 3.5.2 to 3.5.4. Commits 771b499 Releasing 3.5.4 269a583 CVE-2018-12541: When a WebSocket upgrade has a body > 8192 send an appropriat... 616a034 Use public visibiliy for converters...
Bumps [vertx-core](https://github.com/eclipse/vert.x) from 3.5.2 to 3.5.4. Commits 771b499 Releasing 3.5.4 269a583 CVE-2018-12541: When a WebSocket upgrade has a body > 8192 send an appropriat... 616a034 Use public visibiliy for converters...
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: com.dtstack.flink.sql.source.kafka.KafkaConsumer010 ClassLoader info: URL ClassLoader: file: '/tmp/blobStore-dd4fe0b4-6a39-4861-a8df-23e15edff435/job_c9083b2bd69fb054f32ec09a355bc42b/blob_p-7889a2fe7bceb057b33c276d297c5ad5f0b159d0-945f7d983ebb50b43255ffba6b539cc7' (valid JAR) Class not resolvable through given classloader. at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:236) at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:104) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:267) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) at java.lang.Thread.run(Thread.java:745)...
Bumps hadoop-common from 2.7.3 to 3.2.3. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
这个如何引入flink-connector-hive啊,写入hive
Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.2.2 to 42.3.3. Changelog Sourced from postgresql's changelog. Changelog Notable changes since version 42.0.0, read the complete History of Changes. The format is based on Keep a...
根据文档中描述,kudu sink类型的插件中writeMode类型为非必须项,且带有默认值,但实际配置运行中,未配置该参数会抛出NULLPointerException异常,导致任务失败 
源文档中缺少双引号
基于Flink 1.12
有无对sql 语法校验的方法