[jira] [Created] (FLINK-22779) KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException

2021-05-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22779: - Summary: KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException Key: FLINK-22779 URL: https://issues.apache.org/jira/browse/FLINK-22779

The partition tracker should support remote shuffle properly

2021-05-25 Thread XING JIN
Hi devs ~ Recently our team designed and started to build Flink remote shuffle service based on 'pluggable shuffle service framework'[1] for batch processing jobs. We found some potential enhancements could be made on 'pluggable shuffle service' and created an umbrella JIRA[2]. I raise this

[jira] [Created] (FLINK-22778) Upgrade to JUnit 4.13

2021-05-25 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-22778: Summary: Upgrade to JUnit 4.13 Key: FLINK-22778 URL: https://issues.apache.org/jira/browse/FLINK-22778 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22777) Recover lost parts of Datastream API Try Flink example

2021-05-25 Thread Stefan Gloutnikov (Jira)
Stefan Gloutnikov created FLINK-22777: - Summary: Recover lost parts of Datastream API Try Flink example Key: FLINK-22777 URL: https://issues.apache.org/jira/browse/FLINK-22777 Project: Flink

[jira] [Created] (FLINK-22776) Delete casting to byte[]

2021-05-25 Thread Ada Wong (Jira)
Ada Wong created FLINK-22776: Summary: Delete casting to byte[] Key: FLINK-22776 URL: https://issues.apache.org/jira/browse/FLINK-22776 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

2021-05-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22775: - Summary: CassandraConnectorITCase.testCassandraTableSink Fail Key: FLINK-22775 URL: https://issues.apache.org/jira/browse/FLINK-22775 Project: Flink Issue Type:

Re: [DISCUSS] Watermark propagation with Sink API

2021-05-25 Thread Arvid Heise
Hi Eron, I think the FLIP is crisp and mostly good to go. Some smaller things/questions: 1. SinkFunction#writeWatermark could be named SinkFunction#invokeWatermark or invokeOnWatermark to keep it symmetric. 2. We could add the context parameter to both. For SinkWriter#Context, we

Re: [DISCUSS] Watermark propagation with Sink API

2021-05-25 Thread Eron Wright
Does anyone have further comment on FLIP-167? https://cwiki.apache.org/confluence/display/FLINK/FLIP-167%3A+Watermarks+for+Sink+API Thanks, Eron On Thu, May 20, 2021 at 5:02 PM Eron Wright wrote: > Filed FLIP-167: Watermarks for Sink API: > >

[VOTE] Release 1.13.1, release candidate #1

2021-05-25 Thread Dawid Wysakowicz
|Hi everyone,| |Please review and vote on the release candidate #1 for the version 1.13.1, as follows:| |[ ] +1, Approve the release| |[ ] -1, Do not approve the release (please provide specific comments)|     |The complete staging area is available for your review, which includes:| |* JIRA

[jira] [Created] (FLINK-22774) Package flink-sql-connector-kinesis with newer Guava version

2021-05-25 Thread Timo Walther (Jira)
Timo Walther created FLINK-22774: Summary: Package flink-sql-connector-kinesis with newer Guava version Key: FLINK-22774 URL: https://issues.apache.org/jira/browse/FLINK-22774 Project: Flink

[jira] [Created] (FLINK-22773) Optimize the construction of pipelined regions

2021-05-25 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-22773: Summary: Optimize the construction of pipelined regions Key: FLINK-22773 URL: https://issues.apache.org/jira/browse/FLINK-22773 Project: Flink Issue Type:

[jira] [Created] (FLINK-22772) Add TestContext to Python SDK

2021-05-25 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22772: Summary: Add TestContext to Python SDK Key: FLINK-22772 URL: https://issues.apache.org/jira/browse/FLINK-22772 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22771) Add TestContext to Java SDK

2021-05-25 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22771: Summary: Add TestContext to Java SDK Key: FLINK-22771 URL: https://issues.apache.org/jira/browse/FLINK-22771 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22770) Expose SET/RESET from the parser

2021-05-25 Thread Jira
Ingo Bürk created FLINK-22770: - Summary: Expose SET/RESET from the parser Key: FLINK-22770 URL: https://issues.apache.org/jira/browse/FLINK-22770 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-22769) yarnship do not support symbolic directory

2021-05-25 Thread Adrian Zhong (Jira)
Adrian Zhong created FLINK-22769: Summary: yarnship do not support symbolic directory Key: FLINK-22769 URL: https://issues.apache.org/jira/browse/FLINK-22769 Project: Flink Issue Type:

[jira] [Created] (FLINK-22768) ShuffleMaster supports to promote partitions

2021-05-25 Thread Jin Xing (Jira)
Jin Xing created FLINK-22768: Summary: ShuffleMaster supports to promote partitions Key: FLINK-22768 URL: https://issues.apache.org/jira/browse/FLINK-22768 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Moving to JUnit5

2021-05-25 Thread Till Rohrmann
Thanks for joining the discussion Qingsheng. In general, I am not opposed to upgrading our testing library to JUnit 5. Also, the idea of starting with individual modules and do it incrementally sounds reasonable. However, before starting to do it like this, the community should agree that we want

[jira] [Created] (FLINK-22767) Optimize the initialization of ExecutionSlotSharingGroupBuilder

2021-05-25 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-22767: Summary: Optimize the initialization of ExecutionSlotSharingGroupBuilder Key: FLINK-22767 URL: https://issues.apache.org/jira/browse/FLINK-22767 Project: Flink

[jira] [Created] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

2021-05-25 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-22766: - Summary: Report metrics of KafkaConsumer in Kafka new source Key: FLINK-22766 URL: https://issues.apache.org/jira/browse/FLINK-22766 Project: Flink Issue

[jira] [Created] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2021-05-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-22765: -- Summary: ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable Key: FLINK-22765 URL: https://issues.apache.org/jira/browse/FLINK-22765 Project: Flink

Re: [DISCUSS] Moving to JUnit5

2021-05-25 Thread Qingsheng Ren
Hi forks, I’d like to resume the discussion on migrating to JUnit 5. I’ve been working on a connector testing framework and recently have an exploration on JUnit 5. I think some features are very helpful for the development of the testing framework: • Extensions JUnit 5 introduces a new

[jira] [Created] (FLINK-22764) Disable Values Source node in streaming plan optimization

2021-05-25 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-22764: -- Summary: Disable Values Source node in streaming plan optimization Key: FLINK-22764 URL: https://issues.apache.org/jira/browse/FLINK-22764 Project: Flink Issue