[jira] [Created] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. th

2021-04-24 Thread Jira
张健 created FLINK-22441: -- Summary: In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. thx Key: FLINK-22441 U

[jira] [Created] (FLINK-22442) Using scala api to change the TimeCharacteristic of the PatternStream is invalid

2021-04-24 Thread Cedric Chen (Jira)
Cedric Chen created FLINK-22442: --- Summary: Using scala api to change the TimeCharacteristic of the PatternStream is invalid Key: FLINK-22442 URL: https://issues.apache.org/jira/browse/FLINK-22442 Projec

[jira] [Created] (FLINK-22443) can not be execute an extreme long sql under batch mode

2021-04-24 Thread macdoor615 (Jira)
macdoor615 created FLINK-22443: -- Summary: can not be execute an extreme long sql under batch mode Key: FLINK-22443 URL: https://issues.apache.org/jira/browse/FLINK-22443 Project: Flink Issue Typ

[jira] [Created] (FLINK-22444) Drop async checkpoint description of state backends in Chinese docs

2021-04-24 Thread Yun Tang (Jira)
Yun Tang created FLINK-22444: Summary: Drop async checkpoint description of state backends in Chinese docs Key: FLINK-22444 URL: https://issues.apache.org/jira/browse/FLINK-22444 Project: Flink

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

2021-04-24 Thread Becket Qin
Sorry for the late reply. Starting from a specific connector sounds reasonable to me. That said, I would suggest to keep the possibility of future generalization as much as possible. We have already seen some variation of source combinations from different users, HDFS + Kafka, S3 + Kafka, S3 + SQL

[jira] [Created] (FLINK-22445) Add more examples of row-based operations in PyFlink doc

2021-04-24 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22445: Summary: Add more examples of row-based operations in PyFlink doc Key: FLINK-22445 URL: https://issues.apache.org/jira/browse/FLINK-22445 Project: Flink Issu

when should `FlinkYarnSessionCli` be included for parsing CLI arguments?

2021-04-24 Thread Tony Wei
Hi Experts, I recently tried to run yarn-application mode on my yarn cluster, and I had a problem related to configuring `execution.target`. After reading the source code and doing some experiments, I found that there should be some room of improvement for `FlinkYarnSessionCli` or `AbstractYarnCli

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-24 Thread Rui Li
Hi Dawid, I have just merged the doc change for hive dialect [1], which talks about how to use hive dialect to run hive queries. Do you think we can have another RC to include it? Sorry for the trouble. [1] https://issues.apache.org/jira/browse/FLINK-22119 On Sat, Apr 24, 2021 at 1:36 AM Dawid W

[jira] [Created] (FLINK-22446) Relocate dependencies in hive connector uber jar

2021-04-24 Thread Rui Li (Jira)
Rui Li created FLINK-22446: -- Summary: Relocate dependencies in hive connector uber jar Key: FLINK-22446 URL: https://issues.apache.org/jira/browse/FLINK-22446 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-22447) when job failed and restore from rocksdb, it produced a exception "Could not load the native RocksDB library"

2021-04-24 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-22447: --- Summary: when job failed and restore from rocksdb, it produced a exception "Could not load the native RocksDB library" Key: FLINK-22447 URL: https://issues.apache.org/jira/browse/FL