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

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

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

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

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

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

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

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

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

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

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

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]

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

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

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

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:

Activate bloom filter in RocksDB State Backend via Flink configuration

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 |

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

[VOTE] FLIP-152: Hive Query Syntax Compatibility

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]