[GitHub] [flink] flinkbot edited a comment on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster

flinkbot edited a comment on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster URL: https://github.com/apache/flink/pull/11672#issuecomment-610981433 ## CI report: * f1faad82681c9b5c2fbda6c2cda5af3dd207ecdb Travis:

[jira] [Comment Edited] (FLINK-16864) Add idle metrics for Task

[ https://issues.apache.org/jira/browse/FLINK-16864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078339#comment-17078339 ] Piotr Nowojski edited comment on FLINK-16864 at 4/8/20, 2:33 PM: - I had

[jira] [Updated] (FLINK-17047) Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

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

[jira] [Assigned] (FLINK-17047) Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

[ https://issues.apache.org/jira/browse/FLINK-17047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17047: --- Assignee: Zhu Zhu > Simplify SchedulingStrategy#onPartitionConsumable(...) parameters >

[GitHub] [flink] zhuzhurk opened a new pull request #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

zhuzhurk opened a new pull request #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters URL: https://github.com/apache/flink/pull/11673 ## What is the purpose of the change This PR is to simplify SchedulingStrategy#onPartitionConsumable(...)

[GitHub] [flink] pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r405585586 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405612493 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

GJL commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405625039 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/Topology.java ## @@

[GitHub] [flink] wangyang0918 commented on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 commented on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-611035604 @azagrebin I have integrated your improvements and rebased the new master branch. Also i add the

[jira] [Updated] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9528: Component/s: (was: Table SQL / API) Table SQL / Planner > Incorrect results:

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078413#comment-17078413 ] Timo Walther commented on FLINK-9528: - I changed the component to Blink planner. > Incorrect

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405654821 ## File path:

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078507#comment-17078507 ] Aljoscha Krettek commented on FLINK-15362: -- I did the easy fixing of the reflective code but

[jira] [Updated] (FLINK-17054) TaskMailboxProcessorTest.testIdleTime() unstable

[ https://issues.apache.org/jira/browse/FLINK-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17054: --- Labels: test-stability (was: ) > TaskMailboxProcessorTest.testIdleTime() unstable >

[jira] [Updated] (FLINK-17054) TaskMailboxProcessorTest.testIdleTime() unstable

[ https://issues.apache.org/jira/browse/FLINK-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17054: --- Description: CI run:

[GitHub] [flink] pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r405550326 ## File path:

[jira] [Commented] (FLINK-17010) Streaming File Sink s3 end-to-end test fails with "Output hash mismatch"

[ https://issues.apache.org/jira/browse/FLINK-17010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078322#comment-17078322 ] Zhijiang commented on FLINK-17010: -- Great, this issue seems resolved. Sorry for misleading. >

[jira] [Comment Edited] (FLINK-16864) Add idle metrics for Task

[ https://issues.apache.org/jira/browse/FLINK-16864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078339#comment-17078339 ] Piotr Nowojski edited comment on FLINK-16864 at 4/8/20, 2:32 PM: - I had

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405600852 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405619864 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405620878 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11661: [FLINK-17036] Datadog EU site parameter

flinkbot edited a comment on issue #11661: [FLINK-17036] Datadog EU site parameter URL: https://github.com/apache/flink/pull/11661#issuecomment-610484150 ## CI report: * 0f579d60ce90b29817778c6a4a3370f32e4f9c89 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-610971753 ## CI report: * b7e5ae168bcf572e6321257246a778951e5bb6a0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Introduce Python dependency config options

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Introduce Python dependency config options URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 4e319d5b9d7f686b01d7691ec11c3b9303b9a693 UNKNOWN *

[jira] [Created] (FLINK-17054) TaskMailboxProcessorTest.testIdleTime() unstable

Robert Metzger created FLINK-17054: -- Summary: TaskMailboxProcessorTest.testIdleTime() unstable Key: FLINK-17054 URL: https://issues.apache.org/jira/browse/FLINK-17054 Project: Flink Issue

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405604653 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11649: [FLINK-15812][runtime] Archive jobs asynchronously

flinkbot edited a comment on issue #11649: [FLINK-15812][runtime] Archive jobs asynchronously URL: https://github.com/apache/flink/pull/11649#issuecomment-609980317 ## CI report: * 04f2e7a0bcfcc5b37a55d335f893f0d5f26685fd Travis:

[GitHub] [flink] GJL commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

GJL commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405625039 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/Topology.java ## @@

[GitHub] [flink] flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-610971753 ## CI report: * b7e5ae168bcf572e6321257246a778951e5bb6a0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11649: [FLINK-15812][runtime] Archive jobs asynchronously

flinkbot edited a comment on issue #11649: [FLINK-15812][runtime] Archive jobs asynchronously URL: https://github.com/apache/flink/pull/11649#issuecomment-609980317 ## CI report: * 04f2e7a0bcfcc5b37a55d335f893f0d5f26685fd Travis:

[jira] [Reopened] (FLINK-16864) Add idle metrics for Task

[ https://issues.apache.org/jira/browse/FLINK-16864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-16864: I had to revert this change because FLINK-17053 and FLINK-17054. reverted d69d3c0589 on

[jira] [Updated] (FLINK-17053) RecordWriterTest.testClearBuffersAfterInterruptDuringBlockingBufferRequest fails

[ https://issues.apache.org/jira/browse/FLINK-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17053: --- Affects Version/s: (was: 1.11.0) >

[jira] [Updated] (FLINK-17054) TaskMailboxProcessorTest.testIdleTime() unstable

[ https://issues.apache.org/jira/browse/FLINK-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17054: --- Affects Version/s: (was: 1.11.0) > TaskMailboxProcessorTest.testIdleTime() unstable >

[jira] [Closed] (FLINK-17053) RecordWriterTest.testClearBuffersAfterInterruptDuringBlockingBufferRequest fails

[ https://issues.apache.org/jira/browse/FLINK-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17053. -- Resolution: Fixed reverted d69d3c0589 on master >

[jira] [Closed] (FLINK-17054) TaskMailboxProcessorTest.testIdleTime() unstable

[ https://issues.apache.org/jira/browse/FLINK-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17054. -- Resolution: Fixed reverted d69d3c0589 on master > TaskMailboxProcessorTest.testIdleTime()

[jira] [Commented] (FLINK-17053) RecordWriterTest.testClearBuffersAfterInterruptDuringBlockingBufferRequest fails

[ https://issues.apache.org/jira/browse/FLINK-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078331#comment-17078331 ] Piotr Nowojski commented on FLINK-17053: SNAFU, bad mockito test exploded. After [~wenlong.lwl]

[GitHub] [flink] flinkbot commented on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

flinkbot commented on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters URL: https://github.com/apache/flink/pull/11673#issuecomment-611002897 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r405582156 ## File path:

[GitHub] [flink] flinkbot commented on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

flinkbot commented on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters URL: https://github.com/apache/flink/pull/11673#issuecomment-611013893 ## CI report: * fd54e769bcf790e72cdfe4b2253059df1b12b6aa UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN *

[GitHub] [flink] pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r405596704 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11668: [FLINK-17013][python] Support Python UDTF in old planner under batch mode

flinkbot edited a comment on issue #11668: [FLINK-17013][python] Support Python UDTF in old planner under batch mode URL: https://github.com/apache/flink/pull/11668#issuecomment-610845431 ## CI report: * 48fe02ae72da140602cba512125240025d54d0c0 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405675039 ## File path:

[jira] [Assigned] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15362: Assignee: Aljoscha Krettek (was: vinoyang) > Bump Kafka client version to 2.4.0

[GitHub] [flink] flinkbot edited a comment on issue #11592: [FLINK-16871][runtime] Make more build time information available at runtime

flinkbot edited a comment on issue #11592: [FLINK-16871][runtime] Make more build time information available at runtime URL: https://github.com/apache/flink/pull/11592#issuecomment-607128863 ## CI report: * d215e4df60dc9d647dcee1aa9a2114cbf49d0566 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

flinkbot edited a comment on issue #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#issuecomment-609754761 ## CI report: * d7e856fa40bbd1ee8da03ebfca9fae4e08ea08d5 Travis:

[GitHub] [flink] flinkbot commented on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster

flinkbot commented on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster URL: https://github.com/apache/flink/pull/11672#issuecomment-610981433 ## CI report: * f1faad82681c9b5c2fbda6c2cda5af3dd207ecdb UNKNOWN Bot

[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17055: - Description: The first command works fine. {code:java} ./bin/flink list -m yarn-cluster -yid 

[GitHub] [flink] flinkbot edited a comment on issue #11653: [FLINK-16951][parquet] Integrate parquet to file system connector

flinkbot edited a comment on issue #11653: [FLINK-16951][parquet] Integrate parquet to file system connector URL: https://github.com/apache/flink/pull/11653#issuecomment-610233812 ## CI report: * 24b9af733c519ceca287e189b2b290d3d6a0baf4 Travis:

[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17055: - Description: The first command works fine. {code:java} ./bin/flink list -m yarn-cluster -yid 

[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17055: - Description: The first command works fine. {code:java} ./bin/flink list -m yarn-cluster -yid 

[jira] [Commented] (FLINK-17053) RecordWriterTest.testClearBuffersAfterInterruptDuringBlockingBufferRequest fails

[ https://issues.apache.org/jira/browse/FLINK-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078315#comment-17078315 ] Aljoscha Krettek commented on FLINK-17053: -- Another occurrence:

[jira] [Updated] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17055: - Description: The first command works fine. {code:java} ./bin/flink list -m yarn-cluster -yid 

[jira] [Commented] (FLINK-17054) TaskMailboxProcessorTest.testIdleTime() unstable

[ https://issues.apache.org/jira/browse/FLINK-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078314#comment-17078314 ] Piotr Nowojski commented on FLINK-17054: [~wenlong.lwl], could you take a look ASAP? If the

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405635113 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405634642 ## File path:

[jira] [Created] (FLINK-17056) JMH main() methods call unrelated benchmarks

Nico Kruber created FLINK-17056: --- Summary: JMH main() methods call unrelated benchmarks Key: FLINK-17056 URL: https://issues.apache.org/jira/browse/FLINK-17056 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-17056) JMH main() methods call unrelated benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-17056: Description: Each benchmark class is accompanied by an according {{public static main (String[]

[jira] [Updated] (FLINK-16887) Refactor retraction rules to support inferring ChangelogMode

[ https://issues.apache.org/jira/browse/FLINK-16887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16887: --- Labels: pull-request-available (was: ) > Refactor retraction rules to support inferring

[GitHub] [flink] wuchong opened a new pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

wuchong opened a new pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674 ## What is the purpose of the change Current retraction machanism to support more message

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN *

[GitHub] [flink] flinkbot commented on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot commented on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * d8447d9c54212a7625a656a7ac3f03ae86e8c9b5 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

flinkbot edited a comment on issue #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#issuecomment-604812411 ## CI report: * c45cb2a911fbd9a775fee2725370081f5d15b764 UNKNOWN *

[jira] [Updated] (FLINK-17053) RecordWriterTest.testClearBuffersAfterInterruptDuringBlockingBufferRequest fails

[ https://issues.apache.org/jira/browse/FLINK-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17053: --- Priority: Critical (was: Major) >

[jira] [Updated] (FLINK-17053) RecordWriterTest.testClearBuffersAfterInterruptDuringBlockingBufferRequest fails

[ https://issues.apache.org/jira/browse/FLINK-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17053: --- Fix Version/s: 1.11.0 >

[jira] [Commented] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078363#comment-17078363 ] Zili Chen commented on FLINK-17055: --- cc [~kkl0u] > List jobs via bin/flink throws FlinkException

[GitHub] [flink] flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-595174225 ## CI report: * 8e8aca52ebd0560d829ef3945884817668976804

[GitHub] [flink] flinkbot edited a comment on issue #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

flinkbot edited a comment on issue #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#issuecomment-604812411 ## CI report: * c45cb2a911fbd9a775fee2725370081f5d15b764 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

flinkbot edited a comment on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters URL: https://github.com/apache/flink/pull/11673#issuecomment-611013893 ## CI report: * fd54e769bcf790e72cdfe4b2253059df1b12b6aa Travis:

[GitHub] [flink-docker] elanv opened a new pull request #10: Use FLINK_CONF_DIR environment variable to locate flink-conf.yaml

elanv opened a new pull request #10: Use FLINK_CONF_DIR environment variable to locate flink-conf.yaml URL: https://github.com/apache/flink-docker/pull/10 To use flink-conf.yaml outside Flink home directory, we should use FLINK_CONF_DIR. But despite of FLINK_CONF_DIR is set,

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405676332 ## File path:

[jira] [Created] (FLINK-17057) Add OpenSSL micro-benchmarks

Nico Kruber created FLINK-17057: --- Summary: Add OpenSSL micro-benchmarks Key: FLINK-17057 URL: https://issues.apache.org/jira/browse/FLINK-17057 Project: Flink Issue Type: New Feature

[GitHub] [flink] pnowojski edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

pnowojski edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-611095444 > I expect some conflicts (with #11507) in this part, so I'd rather keep these commits

[GitHub] [flink] pnowojski commented on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

pnowojski commented on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-611095444 > I expect some conflicts (with #11507) in this part, so I'd rather keep these commits separate.

[jira] [Commented] (FLINK-16423) test_ha_per_job_cluster_datastream.sh gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078304#comment-17078304 ] Robert Metzger commented on FLINK-16423: I fully agree that we need to fix this before releasing

[jira] [Updated] (FLINK-16423) test_ha_per_job_cluster_datastream.sh gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16423: --- Labels: test-stability (was: ) > test_ha_per_job_cluster_datastream.sh gets stuck >

[GitHub] [flink] pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r405587339 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r405587848 ## File path:

[jira] [Commented] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078362#comment-17078362 ] Zili Chen commented on FLINK-17055: --- I think it is by design because we use Flink configuration as

[jira] [Created] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

Canbin Zheng created FLINK-17055: Summary: List jobs via bin/flink throws FlinkException indicating no cluster id was specified Key: FLINK-17055 URL: https://issues.apache.org/jira/browse/FLINK-17055

[jira] [Updated] (FLINK-17054) TaskMailboxProcessorTest.testIdleTime() unstable

[ https://issues.apache.org/jira/browse/FLINK-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17054: --- Priority: Critical (was: Major) > TaskMailboxProcessorTest.testIdleTime() unstable >

[GitHub] [flink] flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-610971753 ## CI report: * b7e5ae168bcf572e6321257246a778951e5bb6a0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: *

[GitHub] [flink] rkhachatryan commented on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-610999535 > I guess these two commits

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot commented on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot commented on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611081869 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] zhijiangW commented on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

zhijiangW commented on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-611081806 > I expect some conflicts (with #11507) in this part, so I'd rather keep these commits separate.

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078558#comment-17078558 ] Piotr Nowojski commented on FLINK-15362: Yes, it looks you are right :( We could try some magic

[GitHub] [flink] azagrebin opened a new pull request #11675: [Flink 16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

azagrebin opened a new pull request #11675: [Flink 16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args URL: https://github.com/apache/flink/pull/11675 ## What is the purpose of the change `JobManagerProcessUtils#processSpecFromConfig` is used to get

[GitHub] [flink] flinkbot edited a comment on issue #11676: [FLINK-17011][tests] Introduce Builder to AbstractStreamOperatorTestHarness for testing

flinkbot edited a comment on issue #11676: [FLINK-17011][tests] Introduce Builder to AbstractStreamOperatorTestHarness for testing URL: https://github.com/apache/flink/pull/11676#issuecomment-69058 ## CI report: * f9a52c887d310f4175960dc54a710ccdf467836f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * d8447d9c54212a7625a656a7ac3f03ae86e8c9b5 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11661: [FLINK-17036] Datadog EU site parameter

flinkbot edited a comment on issue #11661: [FLINK-17036] Datadog EU site parameter URL: https://github.com/apache/flink/pull/11661#issuecomment-610484150 ## CI report: * 0f579d60ce90b29817778c6a4a3370f32e4f9c89 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-610941752 ## CI report: * 8fb1f48213ccb2ddcda1651388253dec83cb0234 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11592: [FLINK-16871][runtime] Make more build time information available at runtime

flinkbot edited a comment on issue #11592: [FLINK-16871][runtime] Make more build time information available at runtime URL: https://github.com/apache/flink/pull/11592#issuecomment-607128863 ## CI report: * 47099f663b7644056e9d87b262cd4dba034f513e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

flinkbot edited a comment on issue #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args URL: https://github.com/apache/flink/pull/11675#issuecomment-6 ## CI report: * 7bbe43688038441aa0592ee4ef2c8f81e8aef4c8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN *

  1   2   3   4   5   6   7   >