[jira] [Commented] (FLINK-22221) Unclear purpose of spill directories

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338190#comment-17338190 ] Piotr Nowojski commented on FLINK-1: [~chesnay], what do you mean? Are you asking why do we

[jira] [Closed] (FLINK-22224) Nettys NativeLibraryLoader is quite noisy

[ https://issues.apache.org/jira/browse/FLINK-4?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-4. -- Resolution: Won't Fix Those messages are logged from {{io.netty.util.internal}} (it's shaded

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338198#comment-17338198 ] Robert Metzger commented on FLINK-19481: Hi Ben, thanks a lot for getting back on this ticket.

[GitHub] [flink] rmetzger commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

rmetzger commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-831048950 Note: There is some related activity in contributing another GCS FS implementation:

[GitHub] [flink] rkhachatryan commented on a change in pull request #15716: [FLINK-22368] Deque channel after releasing on EndOfPartition

rkhachatryan commented on a change in pull request #15716: URL: https://github.com/apache/flink/pull/15716#discussion_r624898638 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java ## @@ -889,13 +898,17 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #15716: [FLINK-22368] Deque channel after releasing on EndOfPartition

rkhachatryan commented on a change in pull request #15716: URL: https://github.com/apache/flink/pull/15716#discussion_r624899166 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java ## @@ -930,6 +943,10 @@

[GitHub] [flink] rkhachatryan merged pull request #15716: [FLINK-22368] Deque channel after releasing on EndOfPartition

rkhachatryan merged pull request #15716: URL: https://github.com/apache/flink/pull/15716 -- 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 the specific comment. For queries about this service,

[jira] [Reopened] (FLINK-19977) Add new StreamTableEnvironment.fromDataStream

[ https://issues.apache.org/jira/browse/FLINK-19977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-19977: -- > Add new StreamTableEnvironment.fromDataStream > - >

[jira] [Closed] (FLINK-19977) Add new StreamTableEnvironment.fromDataStream

[ https://issues.apache.org/jira/browse/FLINK-19977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-19977. Release Note: StreamTableEnvironment.fromDataStream has slightly different semantics now because

[jira] [Closed] (FLINK-21934) Add new StreamTableEnvironment.toDataStream

[ https://issues.apache.org/jira/browse/FLINK-21934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-21934. Release Note: StreamTableEnvironment.toDataStream has slightly different semantics now because it

[jira] [Reopened] (FLINK-21934) Add new StreamTableEnvironment.toDataStream

[ https://issues.apache.org/jira/browse/FLINK-21934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-21934: -- > Add new StreamTableEnvironment.toDataStream > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #15726: [BP-1.12][FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15726: URL: https://github.com/apache/flink/pull/15726#issuecomment-824941786 ## CI report: * fb27ce9e0d72de50d785f4e19c4ecc6ed9b9ca05 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15727: [BP-1.13][FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15727: URL: https://github.com/apache/flink/pull/15727#issuecomment-824941920 ## CI report: * 77eaa9e82f48fcb3e3613d2d77e6ca17f8625ee5 Azure:

[jira] [Commented] (FLINK-22221) Unclear purpose of spill directories

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338213#comment-17338213 ] Chesnay Schepler commented on FLINK-1: -- It is irrelevant what _I_ know; this is about what

[jira] [Updated] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22548: -- Affects Version/s: 1.13.0 > UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint

[jira] [Updated] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

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

[jira] [Updated] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

[ https://issues.apache.org/jira/browse/FLINK-22547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22547: -- Component/s: Runtime / Coordination > OperatorCoordinatorHolderTest. >

[jira] [Commented] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338219#comment-17338219 ] Till Rohrmann commented on FLINK-22548: --- cc [~pnowojski] >

[jira] [Updated] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

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

[jira] [Updated] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

[ https://issues.apache.org/jira/browse/FLINK-22547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22547: -- Affects Version/s: 1.13.0 > OperatorCoordinatorHolderTest. >

[jira] [Updated] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

[ https://issues.apache.org/jira/browse/FLINK-22547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22547: -- Fix Version/s: 1.13.1 1.14.0 > OperatorCoordinatorHolderTest. >

[jira] [Updated] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22548: -- Fix Version/s: 1.13.1 1.14.0 >

[jira] [Updated] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22545: -- Component/s: Runtime / Coordination > JVM crashes when runing >

[jira] [Updated] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22545: -- Priority: Critical (was: Major) > JVM crashes when runing >

[jira] [Commented] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

[ https://issues.apache.org/jira/browse/FLINK-22547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338220#comment-17338220 ] Till Rohrmann commented on FLINK-22547: --- cc [~sewen] > OperatorCoordinatorHolderTest. >

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338221#comment-17338221 ] Till Rohrmann commented on FLINK-22545: --- cc [~sewen] > JVM crashes when runing >

[jira] [Updated] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

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

[jira] [Updated] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22312: -- Fix Version/s: 1.14.0 >

[GitHub] [flink] flinkbot edited a comment on pull request #15726: [BP-1.12][FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15726: URL: https://github.com/apache/flink/pull/15726#issuecomment-824941786 ## CI report: * 2f90de6ba0331f60abc26790a7aa57e6eaff03b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15727: [BP-1.13][FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15727: URL: https://github.com/apache/flink/pull/15727#issuecomment-824941920 ## CI report: * 77eaa9e82f48fcb3e3613d2d77e6ca17f8625ee5 Azure:

[GitHub] [flink] tillrohrmann commented on pull request #15817: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

tillrohrmann commented on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-831080252 Nothing. I just wanted to see whether CI passes now. I will merge it later today. Thanks a lot for your contribution. -- This is an automated message from the Apache Git

[GitHub] [flink-web] dawidwys merged pull request #442: [hotfix] Adjust phrasing for FlameGraph performance

dawidwys merged pull request #442: URL: https://github.com/apache/flink-web/pull/442 -- 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 the specific comment. For queries about this service,

[jira] [Commented] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338400#comment-17338400 ] Roman Khachatryan commented on FLINK-22173: --- A recent failure (with commits in master up to 

[GitHub] [flink-web] zentol opened a new pull request #442: [hotfix] Adjust phrasing for FlameGraph performance

zentol opened a new pull request #442: URL: https://github.com/apache/flink-web/pull/442 The current 1.13 blog post contains a note for flamegraphs that they are a) expensive and b) may overload the metric system. Point b) is simply incorrect, while a) is not generally the case, and the

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338455#comment-17338455 ] Ben Augarten commented on FLINK-19481: -- Hey Robert and Galen, I appreciate you both weighing in. I

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * d4f85948ee5281b189ba948a8ec512f62587f979 Azure:

[jira] [Created] (FLINK-22554) Support Kafka Topic Patterns in Kafka Ingress

Seth Wiesman created FLINK-22554: Summary: Support Kafka Topic Patterns in Kafka Ingress Key: FLINK-22554 URL: https://issues.apache.org/jira/browse/FLINK-22554 Project: Flink Issue Type:

[jira] [Closed] (FLINK-22549) Flink HA with Zk in kubernetes standalone mode deployment is not working

[ https://issues.apache.org/jira/browse/FLINK-22549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-22549. Resolution: Won't Fix This issue is already discussed on this [mailing list

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * 057695465c326acc5c40576cf35ee9f0283d6cac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

flinkbot edited a comment on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * 9f9242917bedadece14b34ac0a7f98f91bdf4c82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * 46e1be2c4832080bf1cb48c509b77cd88872d024 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

rkhachatryan commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r625298504 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculatorTest.java ## @@ -149,18 +150,80 @@

[jira] [Created] (FLINK-22555) LGPL-2.1 files in flink-python jars

Henri Yandell created FLINK-22555: - Summary: LGPL-2.1 files in flink-python jars Key: FLINK-22555 URL: https://issues.apache.org/jira/browse/FLINK-22555 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * 46e1be2c4832080bf1cb48c509b77cd88872d024 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

flinkbot edited a comment on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * 9f9242917bedadece14b34ac0a7f98f91bdf4c82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

flinkbot edited a comment on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * df97ad0958eaf4e9064303479b040fbb83a493e8 Azure:

[jira] [Updated] (FLINK-22554) Support Kafka Topic Patterns in Kafka Ingress

[ https://issues.apache.org/jira/browse/FLINK-22554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22554: --- Labels: pull-request-available (was: ) > Support Kafka Topic Patterns in Kafka Ingress >

[GitHub] [flink-statefun] sjwiesman opened a new pull request #231: [FLINK-22554] Add topic subscription to KafkaIngress

sjwiesman opened a new pull request #231: URL: https://github.com/apache/flink-statefun/pull/231 Update the Kafka ingress to support Flinks Kafka topic discovery. This removes a common source of downtime from the statefun cluster, configuring new topics. Users can now configure their

[GitHub] [flink] flinkbot edited a comment on pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

flinkbot edited a comment on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * df97ad0958eaf4e9064303479b040fbb83a493e8 Azure:

[GitHub] [flink-web] afedulov opened a new pull request #441: [hotfix] fix bullet points list formatting

afedulov opened a new pull request #441: URL: https://github.com/apache/flink-web/pull/441 -- 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 the specific comment. For queries about this

[jira] [Commented] (FLINK-22133) SplitEmumerator does not provide checkpoint id in snapshot

[ https://issues.apache.org/jira/browse/FLINK-22133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338487#comment-17338487 ] Thomas Weise commented on FLINK-22133: -- [~jqin] [~sewen] what do you think about back porting this

[GitHub] [flink] akalash commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

akalash commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r625177400 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculatorTest.java ## @@ -149,18 +150,80 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15825: [FLINK-22406][coordination][tests] Stabilize ReactiveModeITCase

flinkbot edited a comment on pull request #15825: URL: https://github.com/apache/flink/pull/15825#issuecomment-831225399 ## CI report: * e1a425301eee0b46c812866d12284125f5bde104 Azure:

[jira] [Assigned] (FLINK-22554) Support Kafka Topic Patterns in Kafka Ingress

[ https://issues.apache.org/jira/browse/FLINK-22554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-22554: Assignee: Seth Wiesman > Support Kafka Topic Patterns in Kafka Ingress >

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338418#comment-17338418 ] Galen Warren commented on FLINK-19481: -- Hi all, I'm the author of the other

[GitHub] [flink-web] zentol merged pull request #441: [hotfix] fix bullet points list formatting

zentol merged pull request #441: URL: https://github.com/apache/flink-web/pull/441 -- 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 the specific comment. For queries about this service, please

[jira] [Comment Edited] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338400#comment-17338400 ] Roman Khachatryan edited comment on FLINK-22173 at 5/3/21, 2:48 PM:

[jira] [Created] (FLINK-22553) Improve error reporting on TM connection failures

Roman Khachatryan created FLINK-22553: - Summary: Improve error reporting on TM connection failures Key: FLINK-22553 URL: https://issues.apache.org/jira/browse/FLINK-22553 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * d4f85948ee5281b189ba948a8ec512f62587f979 Azure:

[jira] [Updated] (FLINK-22554) Support Kafka Topic Patterns in Kafka Ingress

[ https://issues.apache.org/jira/browse/FLINK-22554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-22554: - Description: Flink's Kafka source supports subscription patterns, where it will consume all

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Assigned] (FLINK-22555) LGPL-2.1 files in flink-python jars

[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-22555: Assignee: Chesnay Schepler > LGPL-2.1 files in flink-python jars >

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * 0bba0d971d9d4b8530cf90c6513ce68d91cad54e Azure:

[jira] [Commented] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338745#comment-17338745 ] Bhagi commented on FLINK-22139: --- Hi Till, I was able to see the logs inside container in Non HA mode..

[jira] [Updated] (FLINK-22555) LGPL-2.1 files in flink-python jars

[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22555: - Affects Version/s: 1.13.0 1.12.3 > LGPL-2.1 files in

[jira] [Updated] (FLINK-22555) LGPL-2.1 files in flink-python jars

[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22555: - Fix Version/s: 1.12.4 1.13.1 > LGPL-2.1 files in flink-python jars >

[jira] [Updated] (FLINK-22555) LGPL-2.1 files in flink-python jars

[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22555: - Priority: Blocker (was: Major) > LGPL-2.1 files in flink-python jars >

[GitHub] [flink] flinkbot edited a comment on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

flinkbot edited a comment on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-824189664 ## CI report: * f2fe08ada02c5c9e20ed397163d3ab7a34594994 UNKNOWN * 5fdb0880e9465be2711e8ac4b9df01388fc5aa2f Azure:

[jira] [Commented] (FLINK-22555) LGPL-2.1 files in flink-python jars

[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338687#comment-17338687 ] Chesnay Schepler commented on FLINK-22555: -- This seems to be bundled in

[GitHub] [flink] flinkbot edited a comment on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

flinkbot edited a comment on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-824189664 ## CI report: * 71ecabae057e85596265ea48d6b44662ad069bce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

flinkbot edited a comment on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * 323d87e5394e8968856741d0bfd48463e38ddc8a Azure:

[jira] [Commented] (FLINK-22555) LGPL-2.1 files in flink-python jars

[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338692#comment-17338692 ] Chesnay Schepler commented on FLINK-22555: -- Out of curiosity, how did you discover this? >

[GitHub] [flink] hehuiyuan commented on a change in pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

hehuiyuan commented on a change in pull request #15712: URL: https://github.com/apache/flink/pull/15712#discussion_r625459401 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java ## @@ -531,6

[GitHub] [flink] flinkbot edited a comment on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

flinkbot edited a comment on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-824189664 ## CI report: * 71ecabae057e85596265ea48d6b44662ad069bce Azure:

[GitHub] [flink] rkhachatryan opened a new pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

rkhachatryan opened a new pull request #15823: URL: https://github.com/apache/flink/pull/15823 -- 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 the specific comment. For queries about this

[jira] [Updated] (FLINK-22462) JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients.

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

[jira] [Closed] (FLINK-14393) add an option to enable/disable cancel job in web ui

[ https://issues.apache.org/jira/browse/FLINK-14393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14393. - Resolution: Fixed Fixed via a1b3fba418baaa17cc7ac5acd48e2267daf7ab5e > add an option to

[GitHub] [flink] tillrohrmann closed pull request #15817: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

tillrohrmann closed pull request #15817: URL: https://github.com/apache/flink/pull/15817 -- 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 the specific comment. For queries about this service,

[GitHub] [flink] flinkbot commented on pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

flinkbot commented on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831096652 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

[GitHub] [flink] flinkbot edited a comment on pull request #15726: [BP-1.12][FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15726: URL: https://github.com/apache/flink/pull/15726#issuecomment-824941786 ## CI report: * 2f90de6ba0331f60abc26790a7aa57e6eaff03b2 Azure:

[GitHub] [flink] flinkbot commented on pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

flinkbot commented on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * 9f9242917bedadece14b34ac0a7f98f91bdf4c82 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot edited a comment on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830052015 ## CI report: * c11e6cb0c0817a53ef456462f610e3d079f590f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15726: [BP-1.12][FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15726: URL: https://github.com/apache/flink/pull/15726#issuecomment-824941786 ## CI report: * 2f90de6ba0331f60abc26790a7aa57e6eaff03b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15823: [FLINK-22462][tests] Set max_connections to 200 in pgsql

flinkbot edited a comment on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * 9f9242917bedadece14b34ac0a7f98f91bdf4c82 Azure:

[jira] [Created] (FLINK-22549) Flink HA with Zk in kubernetes standalone mode deployment is not working

Bhagi created FLINK-22549: - Summary: Flink HA with Zk in kubernetes standalone mode deployment is not working Key: FLINK-22549 URL: https://issues.apache.org/jira/browse/FLINK-22549 Project: Flink

[jira] [Commented] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338256#comment-17338256 ] Piotr Nowojski commented on FLINK-22284: I think the name

[jira] [Closed] (FLINK-22332) ConnectedComponentsWithObjectMapITCase.testJobWithoutObjectReuse failed due to NPE when calling "notifyDataAvailable"

[ https://issues.apache.org/jira/browse/FLINK-22332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22332. -- Resolution: Duplicate > ConnectedComponentsWithObjectMapITCase.testJobWithoutObjectReuse

[jira] [Assigned] (FLINK-20383) DataSet allround end-to-end test fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-20383: -- Assignee: Piotr Nowojski (was: Arvid Heise) > DataSet allround end-to-end test

[jira] [Reopened] (FLINK-20383) DataSet allround end-to-end test fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-20383: Missing backport to 1.11.x (FIINK-22332). > DataSet allround end-to-end test fails with

[GitHub] [flink] rkhachatryan commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

rkhachatryan commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r625010241 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculatorTest.java ## @@ -149,18 +150,80 @@

[GitHub] [flink] zentol commented on a change in pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

zentol commented on a change in pull request #15741: URL: https://github.com/apache/flink/pull/15741#discussion_r625016153 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -340,108 +319,54 @@ public void testExecute() throws

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Commented] (FLINK-22530) RuntimeException after subsequent windowed grouping in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-22530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338361#comment-17338361 ] Christopher Rost commented on FLINK-22530: -- @libenchao Seems that you had a similar issue with

[GitHub] [flink-web] dawidwys closed pull request #436: Add Apache Flink release 1.13.0

dawidwys closed pull request #436: URL: https://github.com/apache/flink-web/pull/436 -- 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 the specific comment. For queries about this service,

[GitHub] [flink-web] dawidwys commented on pull request #436: Add Apache Flink release 1.13.0

dawidwys commented on pull request #436: URL: https://github.com/apache/flink-web/pull/436#issuecomment-831266920 Merged... -- 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 the specific comment.

[GitHub] [flink] pnowojski commented on a change in pull request #15683: [FLINK-22362]Don't appear target address when taskmanager connect to jobmanager error

pnowojski commented on a change in pull request #15683: URL: https://github.com/apache/flink/pull/15683#discussion_r624983898 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java ## @@ -352,7 +352,7 @@ private static boolean

  1   2   >