bigdata-examples

bigdata-examples copied to clipboard

Bumps [mysql-connector-java](https://github.com/mysql/mysql-connector-j) from 8.0.16 to 8.0.28. Changelog Sourced from mysql-connector-java's changelog. Changelog https://dev.mysql.com/doc/relnotes/connector-j/8.0/en/ Version 8.0.29 Fix for Bug#21978230, COMMENT PARSING NOT PROPER IN PREPSTMT.EXECUTEBATCH(). Fix for Bug#81468 (23312764), MySQL server...

dependabot[bot]

Bumps hadoop-common from 2.8.3 to 3.2.3. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) You can trigger a rebase of this PR by commenting `@dependabot rebase`. [//]: # (dependabot-automerge-start) [//]: # (dependabot-automerge-end) --- Dependabot commands...

dependabot[bot]

Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.2.5 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...

dependabot[bot]

Error: Could not find or load main class org.apache.flink.yarn.entrypoint.YarnApplicationClusterEntryPoint

10

window下远程提交出错

londing

flink的application模式下执行job

14

//存放flink集群相关的jar包目录 String flinkLibs = "hdfs://hadoopcluster/data/flink/libs"; //用户jar String userJarPath = "hdfs://hadoopcluster/data/flink/user-lib/TopSpeedWindowing.jar"; String flinkDistJar = "hdfs://hadoopcluster/data/flink/libs/flink-yarn_2.11-1.11.0.jar"; 请问SubmitJobApplicationMode类里的这几个路径，flinkLibs里面放的jar包是有哪些？userJarPath 是执行job的上传jar包吗？

chenzhaoplus

Flink reads the data in real time and reports an error. Before querying, use flink to delete the existing primary key values in real time. The relevant codes are as...

tuziling

你好 想请问下 连接redis集群模式 你是怎么设置密码的

xjxjin

flink 1.11.0官方代码中 关于watermark的提取

3

官方代码中对于watermark的提取 org.apache.flink.table.filesystem.stream.PartitionTimeCommitTigger#committablePartitions方法中 toMills方法已经修改为本地时区了。

zjw-zjw

Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.11.0 to 2.13.4.1. Commits See full diff in compare view [](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...

dependabot[bot]

Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.2.5 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]