[jira] [Created] (FLINK-21319) hadoop-mapreduce jars are not loaded into classpath when submiting flink on yarn jobs.

2021-02-07 Thread Tang Yan (Jira)
Tang Yan created FLINK-21319: Summary: hadoop-mapreduce jars are not loaded into classpath when submiting flink on yarn jobs. Key: FLINK-21319 URL: https://issues.apache.org/jira/browse/FLINK-21319 Projec

[jira] [Created] (FLINK-21318) ExecutionContextTest.testCatalogs fail

2021-02-07 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21318: - Summary: ExecutionContextTest.testCatalogs fail Key: FLINK-21318 URL: https://issues.apache.org/jira/browse/FLINK-21318 Project: Flink Issue Type: Bug Co

Re: [VOTE] FLIP-152: Hive Query Syntax Compatibility

2021-02-07 Thread Jark Wu
Thanks for driving this. +1 Best, Jark On Mon, 8 Feb 2021 at 09:47, Kurt Young wrote: > +1 > > Best, > Kurt > > > On Sun, Feb 7, 2021 at 7:24 PM Rui Li wrote: > > > Hi everyone, > > > > I think we have reached some consensus on FLIP-152 [1] in the discussion > > thread [2]. So I'd like to sta

[jira] [Created] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-02-07 Thread Kezhu Wang (Jira)
Kezhu Wang created FLINK-21317: -- Summary: Downstream keyed state not work after FlinkKafkaShuffle Key: FLINK-21317 URL: https://issues.apache.org/jira/browse/FLINK-21317 Project: Flink Issue Typ

[jira] [Created] (FLINK-21316) E2E tests exceed 250 minutes.

2021-02-07 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21316: - Summary: E2E tests exceed 250 minutes. Key: FLINK-21316 URL: https://issues.apache.org/jira/browse/FLINK-21316 Project: Flink Issue Type: Bug Components:

Re: Need help on Upsert-kafka connector with confluent schema registry

2021-02-07 Thread Shengkai Fang
Hi Shamit, I think the main problem is the wrong usage of the upsert kafka ddl. In the ddl, you use avro as the format rather than avro-confluent. The dev mail list is used to discuss implementation details. Please send emails to user mail list for help. [1] https://flink.apache.org/gettinghelp.

Re: [VOTE] FLIP-152: Hive Query Syntax Compatibility

2021-02-07 Thread Kurt Young
+1 Best, Kurt On Sun, Feb 7, 2021 at 7:24 PM Rui Li wrote: > Hi everyone, > > I think we have reached some consensus on FLIP-152 [1] in the discussion > thread [2]. So I'd like to start the vote for this FLIP. > > The vote will be open for 72 hours, until Feb. 10 2021 01:00 PM UTC, unless > th

[jira] [Created] (FLINK-21315) Support to set operator names in state processor API

2021-02-07 Thread Jun Qin (Jira)
Jun Qin created FLINK-21315: --- Summary: Support to set operator names in state processor API Key: FLINK-21315 URL: https://issues.apache.org/jira/browse/FLINK-21315 Project: Flink Issue Type: Improv

Activate bloom filter in RocksDB State Backend via Flink configuration

2021-02-07 Thread Jun Qin
Hi, Activating bloom filter in the RocksDB state backend improves read performance. Currently activating bloom filter can only be done by implementing a custom ConfigurableRocksDBOptionsFactory. I think we should provide an option to activate bloom filter via Flink configuration. What do you

[jira] [Created] (FLINK-21314) Airflow |

2021-02-07 Thread ohad (Jira)
ohad created FLINK-21314: Summary: Airflow | Key: FLINK-21314 URL: https://issues.apache.org/jira/browse/FLINK-21314 Project: Flink Issue Type: New Feature Reporter: ohad -- This me

[VOTE] FLIP-152: Hive Query Syntax Compatibility

2021-02-07 Thread Rui Li
Hi everyone, I think we have reached some consensus on FLIP-152 [1] in the discussion thread [2]. So I'd like to start the vote for this FLIP. The vote will be open for 72 hours, until Feb. 10 2021 01:00 PM UTC, unless there's an objection. [1] https://cwiki.apache.org/confluence/display/FLINK/F