flink-sql-demo

flink-sql-demo copied to clipboard

update docker compose for Apple Silicon chips

1

Hello, it must also be supported apple silicon chips in docker compose. I did the fix and I do attach it, here. I have already tested on my dev environment...

wh1ten0ise

Bumps log4j-core from 2.12.1 to 2.16.0. [](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...

dependabot[bot]

SwimSweet

Bumps [flink-core](https://github.com/apache/flink) from 1.10.0 to 1.10.1. Commits c5915cf Commit for release 1.10.1 a5714b6 [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encou... f99bd71 [FLINK-17403][test] Fix invalid classpath in...

dependabot[bot]

zhaozy521

org.apache.flink.table.api.ValidationException: Unsupported options found for connector 'elasticsearch-7'. Unsupported options: password username

vissul

flink-sql-connector-hbase_2.11 在哪里下载？

1

maven 编译时提示 【Cannot resolve org.apache.flink:flink-sql-connector-hbase_2.11:1.12-SNAPSHOT】 flink-sql-connector-elasticsearch7_2.11将 version 改为1.11.1就可以了，但flink-sql-connector-hbase 在maven库中没找到。

shamrockzhao

Bumps [junit](https://github.com/junit-team/junit4) from 4.12 to 4.13.1. Release notes Sourced from junit's releases. JUnit 4.13.1 Please refer to the release notes for details. JUnit 4.13 Please refer to the release notes...

dependabot[bot]

hi，云邪大神： 问题1：实现交易按类别分组全量统计的需求。我想问下历史数据怎么处理？历史数据有几千万难道都要重新发到kafka吗？怎么处理历史数据并平滑的迁移到flink sql有什么好建议吗？ https://flink.apache.org/2020/07/28/flink-sql-demo-building-e2e-streaming-application.html  问题2：接问题1，很多不同维度的统计需求，但是source都是一样的，可以同时输出不同维度的sink吗，多个sink好像会报错？  问题3：使用sql client怎么配置checkpoints？ 非常感谢

miaogr86

wuhulala