[jira] [Updated] (FLINK-20048) Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-20048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20048: - Description: in the case where approximate_failover is enabled, *only source task* is scheduled to be d

[GitHub] [flink] curcur commented on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-723579230 https://issues.apache.org/jira/browse/FLINK-20048 Make a ticket to track this issue: Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy

[jira] [Created] (FLINK-20048) Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy

Yuan Mei created FLINK-20048: Summary: Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy Key: FLINK-20048 URL: https://issues.apache.org/jira/browse/FLINK-20048 Project: Fl

[GitHub] [flink] flinkbot commented on pull request #13984: [FLINK-20030][checkpointing] Revert adding barrier announcements

flinkbot commented on pull request #13984: URL: https://github.com/apache/flink/pull/13984#issuecomment-723579025 ## CI report: * ea343966d3a21779482fe4e42bcc6acfa51da891 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

flinkbot edited a comment on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-721560528 ## CI report: * 40316e6699356e6156b20e5eb6fd7de6af882960 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13982: [FLINK-20047][coordination] DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

flinkbot edited a comment on pull request #13982: URL: https://github.com/apache/flink/pull/13982#issuecomment-723555393 ## CI report: * fc067a1ed3c615bcc9b8c2bc74a054eed2ce0bf7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

flinkbot edited a comment on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-706309837 ## CI report: * 95a2052bdb6586122683e9531f157230ec75cd37 UNKNOWN * 8de0f73bc4abfc12f7996a26b7753431fcf885d3 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

flinkbot edited a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * a4b291d58c664776ac81ace1f3b020239993f893 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13984: [FLINK-20030][checkpointing] Revert adding barrier announcements

flinkbot commented on pull request #13984: URL: https://github.com/apache/flink/pull/13984#issuecomment-723576151 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

[ https://issues.apache.org/jira/browse/FLINK-20030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20030: --- Labels: pull-request-available (was: ) > Barrier announcement causes outdated RemoteInputCh

[jira] [Closed] (FLINK-19888) Migrate Hive source to FLIP-27 source interface for streaming

[ https://issues.apache.org/jira/browse/FLINK-19888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19888. Assignee: Rui Li Resolution: Fixed master (1.12): fc581da73fcb9bbaa443604d36498c9a5dbdf0cd

[GitHub] [flink] rkhachatryan opened a new pull request #13984: [FLINK-20030][checkpointing] Revert adding barrier announcements

rkhachatryan opened a new pull request #13984: URL: https://github.com/apache/flink/pull/13984 TBD This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink] JingsongLi merged pull request #13963: [FLINK-19888][hive] Migrate Hive source to FLIP-27 source interface for streaming

JingsongLi merged pull request #13963: URL: https://github.com/apache/flink/pull/13963 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot commented on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

flinkbot commented on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * a4b291d58c664776ac81ace1f3b020239993f893 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

flinkbot edited a comment on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-720433086 ## CI report: * aab0707fbff82e09fdfc6eda215fc66867b666e2 UNKNOWN * 62bcae939623fc86ad02a3b2288570b1114b6a95 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

flinkbot commented on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723572278 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-19989) Add collect operation in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19989: --- Labels: pull-request-available (was: ) > Add collect operation in Python DataStream API > -

[GitHub] [flink] SteNicholas opened a new pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

SteNicholas opened a new pull request #13983: URL: https://github.com/apache/flink/pull/13983 ## What is the purpose of the change *`DataStream.executeAndCollect()` has already been supported in FLINK-19508. `DataStream` should also support `executeAndCollect` interface in the Python

[GitHub] [flink] flinkbot edited a comment on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

flinkbot edited a comment on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-720433086 ## CI report: * aab0707fbff82e09fdfc6eda215fc66867b666e2 UNKNOWN * 62bcae939623fc86ad02a3b2288570b1114b6a95 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] curcur commented on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-723570652 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[jira] [Comment Edited] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227979#comment-17227979 ] Alexander Alexandrov edited comment on FLINK-20043 at 11/8/20, 12:06 PM: -

[jira] [Comment Edited] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227979#comment-17227979 ] Alexander Alexandrov edited comment on FLINK-20043 at 11/8/20, 12:06 PM: -

[jira] [Comment Edited] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227979#comment-17227979 ] Alexander Alexandrov edited comment on FLINK-20043 at 11/8/20, 12:05 PM: -

[jira] [Comment Edited] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227979#comment-17227979 ] Alexander Alexandrov edited comment on FLINK-20043 at 11/8/20, 12:05 PM: -

[jira] [Comment Edited] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227979#comment-17227979 ] Alexander Alexandrov edited comment on FLINK-20043 at 11/8/20, 12:05 PM: -

[jira] [Commented] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227979#comment-17227979 ] Alexander Alexandrov commented on FLINK-20043: -- BTW the 2.11 and 2.12 jars

[GitHub] [flink] flinkbot edited a comment on pull request #13977: [Mirror] [FLINK-19238] Sanity check for RocksDB arena block size

flinkbot edited a comment on pull request #13977: URL: https://github.com/apache/flink/pull/13977#issuecomment-723460604 ## CI report: * 39cc0db6968c005405244145a452dbada545cba9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

flinkbot edited a comment on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-720433086 ## CI report: * aab0707fbff82e09fdfc6eda215fc66867b666e2 UNKNOWN * 62bcae939623fc86ad02a3b2288570b1114b6a95 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13981: [FLINK-19937][Connectors / FileSystem]Support sink parallelism config…

flinkbot edited a comment on pull request #13981: URL: https://github.com/apache/flink/pull/13981#issuecomment-723548422 ## CI report: * 48b39908b8a2586ffd67a90b9b456134e61dba9e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13963: [FLINK-19888][hive] Migrate Hive source to FLIP-27 source interface for streaming

flinkbot edited a comment on pull request #13963: URL: https://github.com/apache/flink/pull/13963#issuecomment-723044893 ## CI report: * 292f7debbab2b02b317b2578421edb9eed5cdb48 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

flinkbot edited a comment on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-720433086 ## CI report: * aab0707fbff82e09fdfc6eda215fc66867b666e2 UNKNOWN * efd6909b4a1f648205c952d43ae1b95f9bb2da55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] curcur edited a comment on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur edited a comment on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-723563200 Hey Till @tillrohrmann, thanks so much for reviewing!! Addressed your comments. Left some consideration why put the `isApproximateLocalRecoveryEnabled ` chec

[GitHub] [flink] curcur commented on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-723563200 Addressed comments. Left some consideration why put the `isApproximateLocalRecoveryEnabled ` check vs `PipelinedRegionScheduler` in the current place. --

[GitHub] [flink] curcur edited a comment on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur edited a comment on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-723563200 Hey Till, thanks so much for reviewing!!Addressed @tillrohrmann 's comments. Left some consideration why put the `isApproximateLocalRecoveryEnabled ` check vs `Pipe

[jira] [Commented] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227969#comment-17227969 ] Alexander Alexandrov commented on FLINK-20043: -- {quote}are we allowed to sh

[jira] [Updated] (FLINK-20043) Add flink-sql-connector-kinesis package

[ https://issues.apache.org/jira/browse/FLINK-20043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Alexandrov updated FLINK-20043: - Attachment: third-party-report.html > Add flink-sql-connector-kinesis package >

[GitHub] [flink] flinkbot edited a comment on pull request #13981: [FLINK-19937][Connectors / FileSystem]Support sink parallelism config…

flinkbot edited a comment on pull request #13981: URL: https://github.com/apache/flink/pull/13981#issuecomment-723548422 ## CI report: * 48b39908b8a2586ffd67a90b9b456134e61dba9e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[jira] [Closed] (FLINK-20031) Keep the UID of SinkWriter same as the SinkTransformation

[ https://issues.apache.org/jira/browse/FLINK-20031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20031. Fix Version/s: 1.12.0 Resolution: Implemented master: dd17dc749948d328d086d1d8a920e

[GitHub] [flink] aljoscha closed pull request #13970: [FLINK-20031] Keep the uid of SinkWriter same as the SinkTransformation

aljoscha closed pull request #13970: URL: https://github.com/apache/flink/pull/13970 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] aljoscha commented on pull request #13970: [FLINK-20031] Keep the uid of SinkWriter same as the SinkTransformation

aljoscha commented on pull request #13970: URL: https://github.com/apache/flink/pull/13970#issuecomment-723560075 Merged! Good work! 👌 This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Commented] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

[ https://issues.apache.org/jira/browse/FLINK-20011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227965#comment-17227965 ] Dian Fu commented on FLINK-20011: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Closed] (FLINK-19850) Add E2E tests for the new streaming case of the new FileSink

[ https://issues.apache.org/jira/browse/FLINK-19850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19850. Resolution: Implemented master: a6bea224ed012e5594ee755526f54ae7f3b0d22f > Add E2E tests

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[GitHub] [flink] flinkbot edited a comment on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

flinkbot edited a comment on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-720433086 ## CI report: * aab0707fbff82e09fdfc6eda215fc66867b666e2 UNKNOWN * efd6909b4a1f648205c952d43ae1b95f9bb2da55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN * 6cc4a796b26b66b761f50730f7534c36afad

[GitHub] [flink] dianfu commented on pull request #13750: [FLINK-19394][docs-zh] Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

dianfu commented on pull request #13750: URL: https://github.com/apache/flink/pull/13750#issuecomment-723559345 @RocMarshal I'd like to leave it to @klion26 who is more professional in this area and have also reviewed this PR. @klion26 Feel free to merge this PR if you think it's OK to mer

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[GitHub] [flink] flinkbot edited a comment on pull request #13982: [FLINK-20047][coordination] DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

flinkbot edited a comment on pull request #13982: URL: https://github.com/apache/flink/pull/13982#issuecomment-723555393 ## CI report: * fc067a1ed3c615bcc9b8c2bc74a054eed2ce0bf7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

flinkbot edited a comment on pull request #13880: URL: https://github.com/apache/flink/pull/13880#issuecomment-720433086 ## CI report: * aab0707fbff82e09fdfc6eda215fc66867b666e2 UNKNOWN * efd6909b4a1f648205c952d43ae1b95f9bb2da55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] becketqin commented on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

becketqin commented on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-723556790 @StephanEwen Thanks for the comment. I have updated the patch. Would you help take a look? I have also left some thoughts regarding the performance impact. Please let

[GitHub] [flink] flinkbot commented on pull request #13982: [FLINK-20047][coordination] DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

flinkbot commented on pull request #13982: URL: https://github.com/apache/flink/pull/13982#issuecomment-723555393 ## CI report: * fc067a1ed3c615bcc9b8c2bc74a054eed2ce0bf7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Closed] (FLINK-18774) Support debezium-avro format

[ https://issues.apache.org/jira/browse/FLINK-18774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18774. --- Resolution: Fixed Implemented in master (1.12.0): - bff7da11cb0148ab6e63acac7844deb922458999 - edec6aa895

[GitHub] [flink] flinkbot edited a comment on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

flinkbot edited a comment on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-721560528 ## CI report: * f273fc5035aadc9d3933a7ceccd4deb8b6969cb1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN * 6cc4a796b26b66b761f50730f7534c36afad

[GitHub] [flink] flinkbot edited a comment on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

flinkbot edited a comment on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-706309837 ## CI report: * 95a2052bdb6586122683e9531f157230ec75cd37 UNKNOWN * 8de0f73bc4abfc12f7996a26b7753431fcf885d3 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] wuchong merged pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

wuchong merged pull request #13296: URL: https://github.com/apache/flink/pull/13296 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

wuchong commented on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-723554488 It has been passed in my private Azure: https://dev.azure.com/imjark/Flink/_build/results?buildId=326&view=results -

[GitHub] [flink] flinkbot commented on pull request #13982: [FLINK-20047][coordination] DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

flinkbot commented on pull request #13982: URL: https://github.com/apache/flink/pull/13982#issuecomment-723553364 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] wangyang0918 commented on pull request #13982: [FLINK-20047][coordination] DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

wangyang0918 commented on pull request #13982: URL: https://github.com/apache/flink/pull/13982#issuecomment-723553323 cc @tillrohrmann Could you please have a look? This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

flinkbot edited a comment on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-721560528 ## CI report: * f273fc5035aadc9d3933a7ceccd4deb8b6969cb1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN * 6cc4a796b26b66b761f50730f7534c36afad

[jira] [Updated] (FLINK-20047) DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

[ https://issues.apache.org/jira/browse/FLINK-20047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20047: --- Labels: pull-request-available (was: ) > DefaultLeaderRetrievalService should only notify t

[GitHub] [flink] wangyang0918 opened a new pull request #13982: [FLINK-20047][coordination] DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

wangyang0918 opened a new pull request #13982: URL: https://github.com/apache/flink/pull/13982 ## What is the purpose of the change Currently, in `DefaultLeaderRetrievalService` we are notifying the `LeaderRetrievalListener` even though the leader is not truly changed. In Ku

[GitHub] [flink] flinkbot edited a comment on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

flinkbot edited a comment on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-706309837 ## CI report: * 95a2052bdb6586122683e9531f157230ec75cd37 UNKNOWN * 8de0f73bc4abfc12f7996a26b7753431fcf885d3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] becketqin commented on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

becketqin commented on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-723551306 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #13981: [FLINK-19937][Connectors / FileSystem]Support sink parallelism config…

flinkbot edited a comment on pull request #13981: URL: https://github.com/apache/flink/pull/13981#issuecomment-723548422 ## CI report: * 48b39908b8a2586ffd67a90b9b456134e61dba9e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN * 6cc4a796b26b66b761f50730f7534c36afad

[GitHub] [flink] flinkbot commented on pull request #13981: [FLINK-19937][Connectors / FileSystem]Support sink parallelism config…

flinkbot commented on pull request #13981: URL: https://github.com/apache/flink/pull/13981#issuecomment-723548422 ## CI report: * 48b39908b8a2586ffd67a90b9b456134e61dba9e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13963: [FLINK-19888][hive] Migrate Hive source to FLIP-27 source interface for streaming

flinkbot edited a comment on pull request #13963: URL: https://github.com/apache/flink/pull/13963#issuecomment-723044893 ## CI report: * 873f52f02d69a32b1f78822fa6e0fe850833807f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN * 6cc4a796b26b66b761f50730f7534c36afad

[GitHub] [flink] shouweikun commented on pull request #13981: [FLINK-19937][Connectors / FileSystem]Support sink parallelism config…

shouweikun commented on pull request #13981: URL: https://github.com/apache/flink/pull/13981#issuecomment-723547825 @wuchong @JingsongLi Would u guys take a glimpse of this pr? This is an automated message from the A

[GitHub] [flink] flinkbot commented on pull request #13981: [FLINK-19937][Connectors / FileSystem]Support sink parallelism config…

flinkbot commented on pull request #13981: URL: https://github.com/apache/flink/pull/13981#issuecomment-723547675 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19937: --- Labels: pull-request-available (was: ) > Support sink parallelism option for all connectors

[GitHub] [flink] shouweikun opened a new pull request #13981: [FLINK-19937][Connectors / FileSystem]Support sink parallelism config…

shouweikun opened a new pull request #13981: URL: https://github.com/apache/flink/pull/13981 …uration to FileSystem connector ## What is the purpose of the change give user access to configuring the sink parallelism of FileSystem. ## Brief change log - add SI

[GitHub] [flink] curcur commented on a change in pull request #13880: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

curcur commented on a change in pull request #13880: URL: https://github.com/apache/flink/pull/13880#discussion_r519263840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -288,10 +288,24 @@ private void conf

[GitHub] [flink] flinkbot edited a comment on pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

flinkbot edited a comment on pull request #13574: URL: https://github.com/apache/flink/pull/13574#issuecomment-706309837 ## CI report: * 95a2052bdb6586122683e9531f157230ec75cd37 UNKNOWN * 8de0f73bc4abfc12f7996a26b7753431fcf885d3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

flinkbot edited a comment on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193 ## CI report: * c266341c63cc4cdc28a6585a82294710fd8ebbc5 UNKNOWN * 1d4db76b21faf3bb2835be6e529f1d2478237272 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13977: [Mirror] [FLINK-19238] Sanity check for RocksDB arena block size

flinkbot edited a comment on pull request #13977: URL: https://github.com/apache/flink/pull/13977#issuecomment-723460604 ## CI report: * 39cc0db6968c005405244145a452dbada545cba9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

<    1   2   3