[jira] [Created] (FLINK-23672) Add smoke-e2e-java for Java SDK smoke test

Evans Ye created FLINK-23672: Summary: Add smoke-e2e-java for Java SDK smoke test Key: FLINK-23672 URL: https://issues.apache.org/jira/browse/FLINK-23672 Project: Flink Issue Type: Sub-task

Re: Unable to read state Witten by Beam application with Flink runner using Flink's State Processor API

Hi Sandeep, I've stitched together a little working example of how to read Beam State using State Processor API. It's basically a thin wrapper around the existing API. From the example you can see, that accessing Beam state is far more complicated as it's another layer on top of Flink state

[jira] [Created] (FLINK-23671) Failed to inference type in correlate

Shengkai Fang created FLINK-23671: - Summary: Failed to inference type in correlate Key: FLINK-23671 URL: https://issues.apache.org/jira/browse/FLINK-23671 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23670) Add Scala formatting checks to training exercises

Nico Kruber created FLINK-23670: --- Summary: Add Scala formatting checks to training exercises Key: FLINK-23670 URL: https://issues.apache.org/jira/browse/FLINK-23670 Project: Flink Issue Type:

[jira] [Created] (FLINK-23669) Avoid using Scala >= 2.12.8 in Flink Training exercises

Nico Kruber created FLINK-23669: --- Summary: Avoid using Scala >= 2.12.8 in Flink Training exercises Key: FLINK-23669 URL: https://issues.apache.org/jira/browse/FLINK-23669 Project: Flink Issue

[jira] [Created] (FLINK-23668) Check Log Pollution for 1.14 release

Chesnay Schepler created FLINK-23668: Summary: Check Log Pollution for 1.14 release Key: FLINK-23668 URL: https://issues.apache.org/jira/browse/FLINK-23668 Project: Flink Issue Type:

[jira] [Created] (FLINK-23667) Fix training exercises IDE setup description for Scala

Nico Kruber created FLINK-23667: --- Summary: Fix training exercises IDE setup description for Scala Key: FLINK-23667 URL: https://issues.apache.org/jira/browse/FLINK-23667 Project: Flink Issue

[jira] [Created] (FLINK-23666) Flaky test: SQLClientSchemaRegistryITCase.testWriting

Gabor Somogyi created FLINK-23666: - Summary: Flaky test: SQLClientSchemaRegistryITCase.testWriting Key: FLINK-23666 URL: https://issues.apache.org/jira/browse/FLINK-23666 Project: Flink

[jira] [Created] (FLINK-23665) Flaky test: BlockingShuffleITCase.testBoundedBlockingShuffle

Gabor Somogyi created FLINK-23665: - Summary: Flaky test: BlockingShuffleITCase.testBoundedBlockingShuffle Key: FLINK-23665 URL: https://issues.apache.org/jira/browse/FLINK-23665 Project: Flink

[jira] [Created] (FLINK-23664) Write documentation for new KafkaSink

Fabian Paul created FLINK-23664: --- Summary: Write documentation for new KafkaSink Key: FLINK-23664 URL: https://issues.apache.org/jira/browse/FLINK-23664 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23663) Reduce state size in ChangelogNormalize through filter push down

Timo Walther created FLINK-23663: Summary: Reduce state size in ChangelogNormalize through filter push down Key: FLINK-23663 URL: https://issues.apache.org/jira/browse/FLINK-23663 Project: Flink

[jira] [Created] (FLINK-23662) Port Scala code in flink-rpc-akka to Java

Chesnay Schepler created FLINK-23662: Summary: Port Scala code in flink-rpc-akka to Java Key: FLINK-23662 URL: https://issues.apache.org/jira/browse/FLINK-23662 Project: Flink Issue

[jira] [Created] (FLINK-23661) Fix protobuf plugin proxy issue

Yubin Li created FLINK-23661: Summary: Fix protobuf plugin proxy issue Key: FLINK-23661 URL: https://issues.apache.org/jira/browse/FLINK-23661 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23660) Hive Catalog support truncate table

lixu created FLINK-23660: Summary: Hive Catalog support truncate table Key: FLINK-23660 URL: https://issues.apache.org/jira/browse/FLINK-23660 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-173: Support DAG of algorithms (Flink ML)

Hi Zhipeng, Yes, I agree that the key difference between the two options is how they support MIMO. My main concern for option 2 is potential inconsistent availability of algorithms in the two sets of API. In order to make an algorithm available to both sets of API, people have to implement the

Flink 1.14 Bi-weekly 2021-08-03

Hi all, Here's the latest update from the bi-weekly. Short summary: - Feature freeze remains August 16th. - Please start creating tickets for release testing tasks. Get all the updates on the release page. [1] *Feature Freeze* The feature freeze date remains August 16th, which is good for most

Re: [DISCUSS] FLIP-173: Support DAG of algorithms (Flink ML)

Hi Dong, Sorry for the late reply. I am a bit confused by this description of the semantic change. By "from > Data -> Data conversion to generic Table -> Table", do you mean "Table != > Data"? Yes, I think that Table and Data are not equivalent in this case. It might depend on what people

[jira] [Created] (FLINK-23659) Cleanup Prometheus reporter

Chesnay Schepler created FLINK-23659: Summary: Cleanup Prometheus reporter Key: FLINK-23659 URL: https://issues.apache.org/jira/browse/FLINK-23659 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23658) Cleanup JMX reporter

Chesnay Schepler created FLINK-23658: Summary: Cleanup JMX reporter Key: FLINK-23658 URL: https://issues.apache.org/jira/browse/FLINK-23658 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23657) Cleanup metric reporter modules

Chesnay Schepler created FLINK-23657: Summary: Cleanup metric reporter modules Key: FLINK-23657 URL: https://issues.apache.org/jira/browse/FLINK-23657 Project: Flink Issue Type: