[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r551760064 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/security/FlinkUserSecurityManagerTest.java ## @@ -0,0 +1,187 @@ +/* + * Licensed to t

[GitHub] [flink] twalthr closed pull request #14420: [FLINK-19981][core][table] Add name-based field mode for Row

twalthr closed pull request #14420: URL: https://github.com/apache/flink/pull/14420 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] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r551774866 ## File path: flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ## @@ -490,4 +490,25 @@

[jira] [Closed] (FLINK-19981) Improve dealing with Row in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-19981. Fix Version/s: 1.13.0 Resolution: Fixed Fixed in 1.13.0: d2e9aeb55d5c7bfaa65f92163a142f5320

[GitHub] [flink] flinkbot edited a comment on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

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

[jira] [Commented] (FLINK-20735) Support configurable log level

[ https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258744#comment-17258744 ] zlzhang0122 commented on FLINK-20735: - [~trohrmann] Thanks for your reply. Indeed On

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * 8b920eb9c1f70c08f663154e15c60f6ed331394b Azure: [FAILURE](https://dev.azure.com/apache-flin

[GitHub] [flink] flinkbot edited a comment on pull request #14506: [FLINK-20782][table-planner-blink] Separate implementation of BatchExecRank

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

[GitHub] [flink] flinkbot edited a comment on pull request #14556: [FLINK-20848][connector/kafka] Fix Kafka consumer client ID with subtask ID suffix

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

[GitHub] [flink] xiaoHoly commented on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disable for

xiaoHoly commented on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-754492059 hi,@PatrickRen . Do you have a good idea to judge that the stop offset is not specified?.all Stopping offset is initialized as NoStoppingOffsetsInitializer object.there is not

[GitHub] [flink] xiaoHoly commented on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disable for

xiaoHoly commented on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-754492541 hi,@becketqin WDYT? This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] curcur commented on a change in pull request #14546: [FLINK-20488][runtime][checkpoint] Show checkpoint type in the Web-UI…

curcur commented on a change in pull request #14546: URL: https://github.com/apache/flink/pull/14546#discussion_r551790228 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.html ## @@ -91,6 +91,7 @@ P

[GitHub] [flink] curcur commented on pull request #14546: [FLINK-20488][runtime][checkpoint] Show checkpoint type in the Web-UI…

curcur commented on pull request #14546: URL: https://github.com/apache/flink/pull/14546#issuecomment-754495311 > The changes generally LGTM but not to spotless :) Please fix formatting. > I ran a test job and I think aggregation can be added later as a separate PR. hoops, forget

[GitHub] [flink] dawidwys commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

dawidwys commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551790684 ## File path: docs/dev/datastream_execution_mode.md ## @@ -1,8 +1,6 @@ --- title: "Execution Mode (Batch/Streaming)" -nav-id: datastream_execution_mode

[GitHub] [flink] becketqin opened a new pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

becketqin opened a new pull request #14557: URL: https://github.com/apache/flink/pull/14557 ## What is the purpose of the change This patch is a band-aid patch that prevent NPE thrown from SourceOperator after it is closed. The root cause of the NPE is in the out of order mailbox

[jira] [Updated] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

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

[GitHub] [flink] flinkbot commented on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

flinkbot commented on pull request #14557: URL: https://github.com/apache/flink/pull/14557#issuecomment-754498276 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] dawidwys commented on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

dawidwys commented on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-754499351 What is the plan for mixed keyed/non-keyed inputs in multiple inputs? If I am not mistaken the implementation in the `StreamMultipleInputProcessorFactory` is not complete and i

[GitHub] [flink] flinkbot edited a comment on pull request #14506: [FLINK-20782][table-planner-blink] Separate implementation of BatchExecRank

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

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r551774866 ## File path: flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ## @@ -490,4 +490,25 @@

[GitHub] [flink] flinkbot commented on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

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

[jira] [Commented] (FLINK-18795) Support for HBase 2

[ https://issues.apache.org/jira/browse/FLINK-18795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258772#comment-17258772 ] Tang Yan commented on FLINK-18795: -- [~mgergely] Is this new feature included in Flink1.

[GitHub] [flink] PatrickRen commented on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disable fo

PatrickRen commented on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-754512467 @xiaoHoly What about `instanceof NoStoppingOffsetInitializer`? It is indeed possible that a user provides a custom `OffsetsInitializer` which is semantically equivale

[jira] [Commented] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258774#comment-17258774 ] Till Rohrmann commented on FLINK-20833: --- Thanks for creating this ticket [~Zhenqiu

[GitHub] [flink] rkhachatryan commented on a change in pull request #14546: [FLINK-20488][runtime][checkpoint] Show checkpoint type in the Web-UI…

rkhachatryan commented on a change in pull request #14546: URL: https://github.com/apache/flink/pull/14546#discussion_r551808435 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.html ## @@ -91,6 +91,7 @@

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r551809166 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java ## @@ -210,7 +211,12 @@ public String getDescription() th

[jira] [Assigned] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-19970: Assignee: Dawid Wysakowicz > State leak in CEP Operators (expired events/keys not

[GitHub] [flink] flinkbot edited a comment on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

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

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r551763905 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/security/FlinkUserSecurityManager.java ## @@ -0,0 +1,168 @@ +/* + * Licensed to the A

[jira] [Assigned] (FLINK-20845) Drop support for Scala 2.11

[ https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20845: Assignee: Nick Burkard > Drop support for Scala 2.11 > --

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258785#comment-17258785 ] Aljoscha Krettek commented on FLINK-20309: -- Another one: https://dev.azure.com

[GitHub] [flink] xiaoHoly commented on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disable for

xiaoHoly commented on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-754526783 @PatrickRen SGTM This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r551822019 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/security/FlinkUserSecurityManagerTest.java ## @@ -0,0 +1,187 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258789#comment-17258789 ] Aljoscha Krettek commented on FLINK-13414: -- [~NickBurkard] or [~bobanahalf]: if

[GitHub] [flink] aljoscha commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

aljoscha commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r551824176 ## File path: docs/dev/datastream_execution_mode.md ## @@ -1,8 +1,6 @@ --- title: "Execution Mode (Batch/Streaming)" -nav-id: datastream_execution_mode

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r551824883 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -705,9 +715,11 @@ public final void canc

[GitHub] [flink] rmetzger commented on a change in pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

rmetzger commented on a change in pull request #14499: URL: https://github.com/apache/flink/pull/14499#discussion_r551828818 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -527,38 +528,48 @@ protected void before

[GitHub] [flink] echauchot opened a new pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

echauchot opened a new pull request #14558: URL: https://github.com/apache/flink/pull/14558 ## What is the purpose of the change Make _MiniClusterJobClient#getAccumulators()_ non-blocking in Streaming mode ## Brief change log Get the serialized accumulators from the exec

[GitHub] [flink] tillrohrmann commented on a change in pull request #14554: [FLINK-20798] add kubernates config in ha doc

tillrohrmann commented on a change in pull request #14554: URL: https://github.com/apache/flink/pull/14554#discussion_r551830902 ## File path: docs/deployment/ha/kubernetes_ha.md ## @@ -52,6 +52,10 @@ In order to identify the Flink cluster, you have to specify a `kubernetes.cl

[GitHub] [flink] flinkbot commented on pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

flinkbot commented on pull request #14558: URL: https://github.com/apache/flink/pull/14558#issuecomment-754536948 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] aljoscha commented on a change in pull request #14544: [FLINK-20845] Drop Scala 2.11 support

aljoscha commented on a change in pull request #14544: URL: https://github.com/apache/flink/pull/14544#discussion_r551832278 ## File path: pom.xml ## @@ -822,53 +822,6 @@ under the License. - - scala-2.11 -

[jira] [Updated] (FLINK-20845) Drop support for Scala 2.11

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

[jira] [Commented] (FLINK-20735) Support configurable log level

[ https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258801#comment-17258801 ] Till Rohrmann commented on FLINK-20735: --- When using a session cluster, then you ca

[jira] [Comment Edited] (FLINK-20735) Support configurable log level

[ https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258801#comment-17258801 ] Till Rohrmann edited comment on FLINK-20735 at 1/5/21, 10:09 AM: -

[jira] [Comment Edited] (FLINK-20735) Support configurable log level

[ https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258801#comment-17258801 ] Till Rohrmann edited comment on FLINK-20735 at 1/5/21, 10:10 AM: -

[GitHub] [flink] tillrohrmann commented on a change in pull request #14553: [FLINK-20846] Decouple checkpoint services and CheckpointCoordinator

tillrohrmann commented on a change in pull request #14553: URL: https://github.com/apache/flink/pull/14553#discussion_r551836428 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphDeploymentTest.java ## @@ -742,25 +731,11 @@ private

[GitHub] [flink] tillrohrmann commented on a change in pull request #14553: [FLINK-20846] Decouple checkpoint services and CheckpointCoordinator

tillrohrmann commented on a change in pull request #14553: URL: https://github.com/apache/flink/pull/14553#discussion_r551837596 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerUtils.java ## @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

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

[GitHub] [flink] flinkbot edited a comment on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

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

[GitHub] [flink] flinkbot commented on pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

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

[GitHub] [flink] wenlong88 commented on a change in pull request #14478: [FLINK-20737][table-planner-blink] Separate the implementation of stream group aggregate nodes

wenlong88 commented on a change in pull request #14478: URL: https://github.com/apache/flink/pull/14478#discussion_r551806728 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGlobalGroupAggregate.java ###

[GitHub] [flink] tillrohrmann commented on pull request #14553: [FLINK-20846] Decouple checkpoint services and CheckpointCoordinator

tillrohrmann commented on pull request #14553: URL: https://github.com/apache/flink/pull/14553#issuecomment-754545450 Thanks for the review @zentol. I've addressed your comments and pushed an update. Merging once AZP gives green light. -

[jira] [Updated] (FLINK-20801) Using asynchronous methods in operators causes serialization problems

[ https://issues.apache.org/jira/browse/FLINK-20801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20801: - Fix Version/s: (was: 1.11.2) > Using asynchronous methods in operators causes serial

[jira] [Commented] (FLINK-18795) Support for HBase 2

[ https://issues.apache.org/jira/browse/FLINK-18795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258805#comment-17258805 ] Chesnay Schepler commented on FLINK-18795: -- [~Tang Yan] yes, it is included in

[jira] [Updated] (FLINK-18795) Support for HBase 2

[ https://issues.apache.org/jira/browse/FLINK-18795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18795: - Fix Version/s: 1.12.0 > Support for HBase 2 > --- > > Ke

[GitHub] [flink] aljoscha opened a new pull request #14559: [minor] Update IDE setup guide, to apply Save Actions only to Java files

aljoscha opened a new pull request #14559: URL: https://github.com/apache/flink/pull/14559 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

[GitHub] [flink] flinkbot commented on pull request #14559: [minor] Update IDE setup guide, to apply Save Actions only to Java files

flinkbot commented on pull request #14559: URL: https://github.com/apache/flink/pull/14559#issuecomment-754549406 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] zentol commented on a change in pull request #14559: [minor] Update IDE setup guide, to apply Save Actions only to Java files

zentol commented on a change in pull request #14559: URL: https://github.com/apache/flink/pull/14559#discussion_r551844811 ## File path: docs/flinkDev/ide_setup.md ## @@ -106,6 +106,7 @@ formatting on saving with these steps: 5. Install the [Save Actions plugin](https://pl

[GitHub] [flink] zentol commented on a change in pull request #14559: [minor] Update IDE setup guide, to apply Save Actions only to Java files

zentol commented on a change in pull request #14559: URL: https://github.com/apache/flink/pull/14559#discussion_r551844811 ## File path: docs/flinkDev/ide_setup.md ## @@ -106,6 +106,7 @@ formatting on saving with these steps: 5. Install the [Save Actions plugin](https://pl

[GitHub] [flink] zentol commented on a change in pull request #14559: [minor] Update IDE setup guide, to apply Save Actions only to Java files

zentol commented on a change in pull request #14559: URL: https://github.com/apache/flink/pull/14559#discussion_r551844811 ## File path: docs/flinkDev/ide_setup.md ## @@ -106,6 +106,7 @@ formatting on saving with these steps: 5. Install the [Save Actions plugin](https://pl

[GitHub] [flink] zentol commented on pull request #14409: [FLINK-20634][dist] Remove start-scala-shell.sh in bin folder when co…

zentol commented on pull request #14409: URL: https://github.com/apache/flink/pull/14409#issuecomment-754552033 @paul8263 I'll take it from here ;) This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #14409: [FLINK-20634][dist] Remove start-scala-shell.sh in bin folder when co…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * fd8cbf90a807292b0db7b85bda26f1e717b8

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

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

[GitHub] [flink] flinkbot edited a comment on pull request #14553: [FLINK-20846] Decouple checkpoint services and CheckpointCoordinator

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

[GitHub] [flink] flinkbot edited a comment on pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

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

[GitHub] [flink] flinkbot commented on pull request #14559: [minor] Update IDE setup guide, to apply Save Actions only to Java files

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

[GitHub] [flink] KarmaGYZ opened a new pull request #14560: [FLINK-20837] Refactor dynamic SlotID

KarmaGYZ opened a new pull request #14560: URL: https://github.com/apache/flink/pull/14560 ## What is the purpose of the change Refactor dynamic SlotID. In FLINK-14189, we specified that the SlotID whose slot number is -1 represents the dynamic slot. However, the SlotID with a

[jira] [Updated] (FLINK-20837) Refactor dynamic SlotID

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

[GitHub] [flink] flinkbot commented on pull request #14560: [FLINK-20837] Refactor dynamic SlotID

flinkbot commented on pull request #14560: URL: https://github.com/apache/flink/pull/14560#issuecomment-754554960 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] tillrohrmann closed pull request #14425: [FLINK-19773][runtime] Implement ExponentialDelayStrategy

tillrohrmann closed pull request #14425: URL: https://github.com/apache/flink/pull/14425 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 g

[jira] [Closed] (FLINK-19773) Exponential backoff restart strategy

[ https://issues.apache.org/jira/browse/FLINK-19773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-19773. - Fix Version/s: 1.13.0 Resolution: Fixed Fixed via 13b7b3e6050ee716d01c9d3d74d08702f93953a

[GitHub] [flink] tillrohrmann commented on pull request #14425: [FLINK-19773][runtime] Implement ExponentialDelayStrategy

tillrohrmann commented on pull request #14425: URL: https://github.com/apache/flink/pull/14425#issuecomment-754558779 Really good work @mareksabo! This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551855298 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551856516 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551856697 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink] KarmaGYZ opened a new pull request #14561: [FLINK-20836] Register TaskManager with total and default slot resource profile in SlotManager

KarmaGYZ opened a new pull request #14561: URL: https://github.com/apache/flink/pull/14561 ## What is the purpose of the change In FLINK-14188 and FLINK-14189, the TaskExecutor will derive and register to ResourceManager with the total/default slot resource profile. We need to pa

[GitHub] [flink] flinkbot edited a comment on pull request #14409: [FLINK-20634][dist] Remove start-scala-shell.sh in bin folder when co…

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

[jira] [Updated] (FLINK-20836) Register TaskManager with total and default slot resource profile in SlotManager

[ https://issues.apache.org/jira/browse/FLINK-20836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20836: --- Labels: pull-request-available (was: ) > Register TaskManager with total and default slot r

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

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

[GitHub] [flink] flinkbot edited a comment on pull request #14553: [FLINK-20846] Decouple checkpoint services and CheckpointCoordinator

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

[GitHub] [flink] flinkbot edited a comment on pull request #14559: [minor] Update IDE setup guide, to apply Save Actions only to Java files

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

[GitHub] [flink] flinkbot commented on pull request #14560: [FLINK-20837] Refactor dynamic SlotID

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

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551858801 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink] curcur commented on a change in pull request #14546: [FLINK-20488][runtime][checkpoint] Show checkpoint type in the Web-UI…

curcur commented on a change in pull request #14546: URL: https://github.com/apache/flink/pull/14546#discussion_r551859021 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -297,6 +297,11 @@ pu

[GitHub] [flink] flinkbot commented on pull request #14561: [FLINK-20836] Register TaskManager with total and default slot resource profile in SlotManager

flinkbot commented on pull request #14561: URL: https://github.com/apache/flink/pull/14561#issuecomment-754563356 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] [Commented] (FLINK-20735) Support configurable log level

[ https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258834#comment-17258834 ] zlzhang0122 commented on FLINK-20735: - [~trohrmann] Yep, this's exactly what I mean.

[GitHub] [flink] curcur commented on pull request #14546: [FLINK-20488][runtime][checkpoint] Show checkpoint type in the Web-UI…

curcur commented on pull request #14546: URL: https://github.com/apache/flink/pull/14546#issuecomment-754567585 I re-tested after updates. This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551863451 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551865672 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551865672 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink] klion26 commented on pull request #13488: [FLINK-19381][docs] Fix docs for savepoint relocation

klion26 commented on pull request #13488: URL: https://github.com/apache/flink/pull/13488#issuecomment-754570820 @StephanEwen thanks for the review. @carp84 @NicoK Do you have any more comments? If there are no more comments, could anyone of you approve this then I can merge it. than

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551866588 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551866779 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551867412 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[GitHub] [flink-web] MarkSfik commented on a change in pull request #403: [blog] Add Pulsar Flink Connector blog

MarkSfik commented on a change in pull request #403: URL: https://github.com/apache/flink-web/pull/403#discussion_r551867894 ## File path: _posts/2020-12-22-pulsar-flink-connector-270.md ## @@ -0,0 +1,171 @@ +--- +layout: post +title: "What's New in Pulsar Flink Connector 2.7

[jira] [Commented] (FLINK-20735) Support configurable log level

[ https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258843#comment-17258843 ] Till Rohrmann commented on FLINK-20735: --- With the current implementation this is n

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * fd8cbf90a807292b0db7b85bda26f1e717b8

  1   2   3   4   >