flinkStreamSQL icon indicating copy to clipboard operation
flinkStreamSQL copied to clipboard

基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法

Results 90 flinkStreamSQL issues
Sort by recently updated
recently updated
newest added

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...

dependencies

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...

dependencies

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. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=org.apache.hadoop:hadoop-common&package-manager=maven&previous-version=2.7.3&new-version=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...

dependencies

这个如何引入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...

dependencies

根据文档中描述,kudu sink类型的插件中writeMode类型为非必须项,且带有默认值,但实际配置运行中,未配置该参数会抛出NULLPointerException异常,导致任务失败 ![image](https://user-images.githubusercontent.com/18161585/141933514-78805f16-1ab9-4bd5-a582-a37f6fbf8fe1.png)

源文档中缺少双引号

有无对sql 语法校验的方法