Guowei Ma created FLINK-22779:
-
Summary:
KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to
ConcurrentModificationException
Key: FLINK-22779
URL: https://issues.apache.org/jira/browse/FLINK-22779
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
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
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
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
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:
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
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:
>
>
|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
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
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:
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
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
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
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:
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
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
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
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
Robert Metzger created FLINK-22765:
--
Summary: ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is
unstable
Key: FLINK-22765
URL: https://issues.apache.org/jira/browse/FLINK-22765
Project: Flink
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
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
22 matches
Mail list logo