[GitHub] [flink] sv3ndk commented on a change in pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

sv3ndk commented on a change in pull request #16060: URL: https://github.com/apache/flink/pull/16060#discussion_r663322708 ## File path: flink-table/flink-sql-client/src/test/resources/sql-client-help-command.out ## @@ -1,23 +1,19 @@ -CLEAR Clears the current

[GitHub] [flink] sv3ndk commented on a change in pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

sv3ndk commented on a change in pull request #16060: URL: https://github.com/apache/flink/pull/16060#discussion_r663322250 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -73,54 +58,41 @@ private CliStrings() {

[GitHub] [flink] sv3ndk commented on a change in pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

sv3ndk commented on a change in pull request #16060: URL: https://github.com/apache/flink/pull/16060#discussion_r663322250 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -73,54 +58,41 @@ private CliStrings() {

[jira] [Updated] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loyi updated FLINK-23190: - Flags: Patch > Make task-slot allocation much more evenly > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #16333: [FLINK-23182][connectors/rabbitmq] Fix connection leak in RMQSource

flinkbot edited a comment on pull request #16333: URL: https://github.com/apache/flink/pull/16333#issuecomment-871325206 ## CI report: * f5564b01415250bcd4ec2941024b8da554393794 Azure:

[jira] [Updated] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loyi updated FLINK-23190: - Description: FLINK-12122 only guarantees spreading out tasks across the set of TMs which are registered at the

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373893#comment-17373893 ] Yuan Mei edited comment on FLINK-22420 at 7/3/21, 4:28 AM: --- Have shared the

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373893#comment-17373893 ] Yuan Mei commented on FLINK-22420: -- Have shared the full log offline. Can not upload the full log here

[GitHub] [flink] flinkbot edited a comment on pull request #16333: [FLINK-23182][connectors/rabbitmq] Fix connection leak in RMQSource

flinkbot edited a comment on pull request #16333: URL: https://github.com/apache/flink/pull/16333#issuecomment-871325206 ## CI report: * 018d2a2aa104ee7d47d97e76926df1e7ec23587b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16333: [FLINK-23182][connectors/rabbitmq] Fix connection leak in RMQSource

flinkbot edited a comment on pull request #16333: URL: https://github.com/apache/flink/pull/16333#issuecomment-871325206 ## CI report: * 018d2a2aa104ee7d47d97e76926df1e7ec23587b Azure:

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22663: --- Labels: YARN auto-deprioritized-major pull-request-available (was: YARN

[jira] [Updated] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11654: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20975: --- Labels: auto-deprioritized-critical auto-unassigned test-stability (was: auto-unassigned

[jira] [Updated] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19863: --- Labels: auto-deprioritized-critical auto-unassigned pull-request-available test-stability

[jira] [Updated] (FLINK-21755) Remove flink-runtime dependency from metric reporters

[ https://issues.apache.org/jira/browse/FLINK-21755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21755: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-21573) Support expression reuse in codegen

[ https://issues.apache.org/jira/browse/FLINK-21573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21573: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18894: --- Labels: auto-deprioritized-critical auto-unassigned stale-major (was:

[jira] [Updated] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13400: --- Labels: auto-deprioritized-critical auto-unassigned stale-major (was:

[jira] [Updated] (FLINK-22749) Apply a robust default State Backend Configuration

[ https://issues.apache.org/jira/browse/FLINK-22749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22749: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-23016) Job client must be a Coordination Request Gateway when submit a job on web ui

[ https://issues.apache.org/jira/browse/FLINK-23016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23016: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was:

[jira] [Updated] (FLINK-22785) Kafka transaction failing when there are two producers

[ https://issues.apache.org/jira/browse/FLINK-22785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22785: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22836) OffsetsInitializerTest.testTimestampOffsetsInitializer fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22836: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-22841) how to update configuration of the native kubernetes deployment model flink cluster?

[ https://issues.apache.org/jira/browse/FLINK-22841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22841: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22662: --- Labels: pull-request-available stale-assigned test-stability (was: pull-request-available

[jira] [Updated] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

[ https://issues.apache.org/jira/browse/FLINK-23032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23032: --- Labels: stale-assigned (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22848) Deprecate unquoted options for SET / RESET

[ https://issues.apache.org/jira/browse/FLINK-22848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22848: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19916: --- Labels: auto-deprioritized-major (was: auto-deprioritized-major stale-major)

[jira] [Updated] (FLINK-22884) Select view columns fail when store metadata with hive

[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22884: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[GitHub] [flink] flinkbot edited a comment on pull request #16361: [FLINK-23201][streaming] Prints a warning about a possible problem wi…

flinkbot edited a comment on pull request #16361: URL: https://github.com/apache/flink/pull/16361#issuecomment-873149764 ## CI report: * 2215565f50376a4bbfa749fdfbb20af2396cb620 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 2221bb12ad60d7566534b3ed14364bc1e7b69b5b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 0556f30737fd827a1b18f9ec585faa1b26a43793 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15972: Add common source and operator metrics.

flinkbot edited a comment on pull request #15972: URL: https://github.com/apache/flink/pull/15972#issuecomment-844955772 ## CI report: * 9223b2bfe148ae335891393f244dc2c29f39d2ee UNKNOWN * 1e6b0f37803e0fa5326184c17b3a1f3669667de2 UNKNOWN *

[jira] [Assigned] (FLINK-23201) The check on alignmentDurationNanos seems to be too strict

[ https://issues.apache.org/jira/browse/FLINK-23201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-23201: -- Assignee: Anton Kalashnikov (was: Piotr Nowojski) > The check on

[jira] [Assigned] (FLINK-23201) The check on alignmentDurationNanos seems to be too strict

[ https://issues.apache.org/jira/browse/FLINK-23201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-23201: -- Assignee: Piotr Nowojski > The check on alignmentDurationNanos seems to be too

[GitHub] [flink] flinkbot edited a comment on pull request #16351: [FLINK-22972][datastream] Remove StreamOperator#dispose in favour of close and finish

flinkbot edited a comment on pull request #16351: URL: https://github.com/apache/flink/pull/16351#issuecomment-872790645 ## CI report: * b50852d7f680e9ded20aec7724f6dc99dfe67066 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 718d13ecfaabf072ef2f7fe9c13a5cf4ef3645ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16361: [FLINK-23201][streaming] Prints a warning about a possible problem wi…

flinkbot edited a comment on pull request #16361: URL: https://github.com/apache/flink/pull/16361#issuecomment-873149764 ## CI report: * 2215565f50376a4bbfa749fdfbb20af2396cb620 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 0556f30737fd827a1b18f9ec585faa1b26a43793 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #16361: [FLINK-23201][streaming] Prints a warning about a possible problem wi…

flinkbot commented on pull request #16361: URL: https://github.com/apache/flink/pull/16361#issuecomment-873149764 ## CI report: * 2215565f50376a4bbfa749fdfbb20af2396cb620 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16360: [FLINK-23095][runtime] Close the channel unspilling thread pool after restore

flinkbot edited a comment on pull request #16360: URL: https://github.com/apache/flink/pull/16360#issuecomment-873015774 ## CI report: * df9bb7a13987c2db1bf7a26d1357af48d4f52f99 Azure:

[GitHub] [flink] zentol commented on a change in pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

zentol commented on a change in pull request #16332: URL: https://github.com/apache/flink/pull/16332#discussion_r663141052 ## File path: tools/azure-pipelines/jobs-template.yml ## @@ -243,3 +278,9 @@ jobs: inputs: targetPath: $(DEBUG_FILES_OUTPUT_DIR)

[GitHub] [flink] flinkbot edited a comment on pull request #16358: [FLINK-23220] MailboxProcessor should wait for default action available even if there are no mails

flinkbot edited a comment on pull request #16358: URL: https://github.com/apache/flink/pull/16358#issuecomment-872973679 ## CI report: * 90e8e0f44962a333a42b03a6014dccc29822e64d Azure:

[GitHub] [flink] zentol edited a comment on pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

zentol edited a comment on pull request #16345: URL: https://github.com/apache/flink/pull/16345#issuecomment-873088656 > Could we add it as provided into the test scope (so Maven has to build it for test execution) and then extract the path from it? That's how I'd approach this issue in

[GitHub] [flink] flinkbot commented on pull request #16361: [FLINK-23201][streaming] Prints a warning about a possible problem wi…

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

[jira] [Updated] (FLINK-23201) The check on alignmentDurationNanos seems to be too strict

[ https://issues.apache.org/jira/browse/FLINK-23201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23201: --- Labels: pull-request-available (was: ) > The check on alignmentDurationNanos seems to be

[GitHub] [flink] akalash opened a new pull request #16361: [FLINK-23201][streaming] Prints a warning about a possible problem wi…

akalash opened a new pull request #16361: URL: https://github.com/apache/flink/pull/16361 …th monotony of time ## What is the purpose of the change *PR adds the check about markAlignmentEnd was called after markAlignmentStart * ## Brief change log

[GitHub] [flink] tillrohrmann commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

tillrohrmann commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663113670 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcSystem.java ## @@ -51,6 +51,9 @@ RpcServiceBuilder

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 964ffaaef082ffc00b971c41c53623824ba7c140 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

pnowojski commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r663119956 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -288,9 +288,7 @@

[GitHub] [flink] pnowojski commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

pnowojski commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r663119956 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -288,9 +288,7 @@

[jira] [Closed] (FLINK-21086) Support checkpoint alignment with finished input channels

[ https://issues.apache.org/jira/browse/FLINK-21086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21086. Resolution: Fixed Implemented in

[GitHub] [flink] tillrohrmann commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

tillrohrmann commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663113670 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcSystem.java ## @@ -51,6 +51,9 @@ RpcServiceBuilder

[GitHub] [flink] dawidwys merged pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

dawidwys merged pull request #15055: URL: https://github.com/apache/flink/pull/15055 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] dawidwys commented on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

dawidwys commented on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-873101511 Thanks again for the PR! Really good work here! Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 964ffaaef082ffc00b971c41c53623824ba7c140 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 0556f30737fd827a1b18f9ec585faa1b26a43793 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15972: Add common source and operator metrics.

flinkbot edited a comment on pull request #15972: URL: https://github.com/apache/flink/pull/15972#issuecomment-844955772 ## CI report: * 9223b2bfe148ae335891393f244dc2c29f39d2ee UNKNOWN * 1e6b0f37803e0fa5326184c17b3a1f3669667de2 UNKNOWN *

[GitHub] [flink] sjwiesman closed pull request #16356: [hotfix][streaming] Fix the boundary condition when collect limited records from streaming job

sjwiesman closed pull request #16356: URL: https://github.com/apache/flink/pull/16356 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] sjwiesman commented on pull request #16356: [hotfix][streaming] Fix the boundary condition when collect limited records from streaming job

sjwiesman commented on pull request #16356: URL: https://github.com/apache/flink/pull/16356#issuecomment-873093806 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] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * 43550b885f3b52e7db0f82cbbf84c4086b66456c UNKNOWN * fa503187bbfe6ea1cff04d4d03132675c36305e3 Azure:

[GitHub] [flink] tillrohrmann closed pull request #16256: [hotfix][release-notes] Update release notes for 1.11, 1.12, 1.13 with accumulators semantics change in MiniClusterJobClient

tillrohrmann closed pull request #16256: URL: https://github.com/apache/flink/pull/16256 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373612#comment-17373612 ] Arvid Heise commented on FLINK-22085: - I think having `notifyDataAvailable` at the end of recovery

[GitHub] [flink] tillrohrmann commented on pull request #16256: [hotfix][release-notes] Update release notes for 1.11, 1.12, 1.13 with accumulators semantics change in MiniClusterJobClient

tillrohrmann commented on pull request #16256: URL: https://github.com/apache/flink/pull/16256#issuecomment-873089696 I think I might have given you bad advice. FLINK-18685 seems to be only fixed in Flink 1.13.0. Hence we only need to update the release docs for 1.13. I will update the PR

[GitHub] [flink] zentol commented on pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

zentol commented on pull request #16345: URL: https://github.com/apache/flink/pull/16345#issuecomment-873088656 > Could we add it as provided into the test scope (so Maven has to build it for test execution) and then extract the path from it? That's how I'd approach this issue in gradle

[GitHub] [flink] zentol commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

zentol commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663099339 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginLoader.java ## @@ -177,16 +177,16 @@ public P next() {

[GitHub] [flink] AHeise commented on pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

AHeise commented on pull request #16345: URL: https://github.com/apache/flink/pull/16345#issuecomment-873087027 > yes, I also thought about having a separate location in dist for production use-cases, and rely on the tmp dir only for tests. But then the question is when do we extract the

[GitHub] [flink] zentol commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

zentol commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663097653 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginLoader.java ## @@ -177,16 +177,16 @@ public P next() {

[GitHub] [flink] flinkbot edited a comment on pull request #16359: [FLINK-23222]Translate page 'Application Profiling & Debugging' into Chinese

flinkbot edited a comment on pull request #16359: URL: https://github.com/apache/flink/pull/16359#issuecomment-872999229 ## CI report: * 069fb525e2734b4854fc4c829730030c187e21c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16357: [FLINK-23209] Introduce HeartbeatListener.notifyTargetUnreachable

flinkbot edited a comment on pull request #16357: URL: https://github.com/apache/flink/pull/16357#issuecomment-872940369 ## CI report: * 25d8a08a42245175f94694e651c37f156484bb71 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 964ffaaef082ffc00b971c41c53623824ba7c140 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 0556f30737fd827a1b18f9ec585faa1b26a43793 UNKNOWN *

[GitHub] [flink] leonardBang commented on pull request #16356: [hotfix][streaming] Fix the boundary condition when collect limited records from streaming job

leonardBang commented on pull request #16356: URL: https://github.com/apache/flink/pull/16356#issuecomment-873082262 The CI has passed, Could you help merge ? @sjwiesman Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] tillrohrmann commented on a change in pull request #16315: FLINK-23174 Log improvement in Task throws Error

tillrohrmann commented on a change in pull request #16315: URL: https://github.com/apache/flink/pull/16315#discussion_r663092289 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java ## @@ -243,8

[GitHub] [flink] zentol commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

zentol commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663091576 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcSystem.java ## @@ -86,8 +95,28 @@ static RpcSystem load() { *

[jira] [Updated] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23216: -- Issue Type: Improvement (was: Bug) > RM keeps allocating and freeing slots after a TM lost

[jira] [Commented] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373598#comment-17373598 ] Till Rohrmann commented on FLINK-23216: --- Thanks for reporting this issue [~pltbkd]. I think you

[jira] [Updated] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23216: -- Affects Version/s: 1.12.4 > RM keeps allocating and freeing slots after a TM lost until its

[GitHub] [flink] AHeise commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

AHeise commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663086556 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginLoader.java ## @@ -177,16 +177,16 @@ public P next() {

[GitHub] [flink] AHeise commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

AHeise commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663083723 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcSystem.java ## @@ -86,8 +95,28 @@ static RpcSystem load() { *

[GitHub] [flink] AHeise commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

AHeise commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663082940 ## File path: flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java ## @@ -137,6 +138,13 @@ public AkkaRpcService(

[GitHub] [flink] AHeise commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

AHeise commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r663082363 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java ## @@ -83,16 +81,24 @@ public void

[GitHub] [flink] rkhachatryan commented on a change in pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

rkhachatryan commented on a change in pull request #16341: URL: https://github.com/apache/flink/pull/16341#discussion_r663079965 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogStorageLoader.java ## @@ -18,26 +18,81 @@ package

[GitHub] [flink] rkhachatryan commented on a change in pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

rkhachatryan commented on a change in pull request #16341: URL: https://github.com/apache/flink/pull/16341#discussion_r663058564 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -1088,6 +1091,7 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 0ff177795d6fb3b36e514d0102df23fe61093180 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16342: [FLINK-23202][rpc] Fail rpc requests for unreachable recipients eagerly

flinkbot edited a comment on pull request #16342: URL: https://github.com/apache/flink/pull/16342#issuecomment-872257117 ## CI report: * 66ef8dd6b21dc48f196f8dbc997ba269559718d6 UNKNOWN * 087259d7b87ca4bebf99d67b4120d6a139794d14 Azure:

[GitHub] [flink] XComp commented on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

XComp commented on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-873055234 I rebased the PR to make the `JobMasterITCase` succeed in the AzureCI builds -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * 43550b885f3b52e7db0f82cbbf84c4086b66456c UNKNOWN * 5f9eab4789753e95a08a7c8bc8ed113987cd71bf Azure:

[jira] [Updated] (FLINK-23223) When flushAlways is enabled the subpartition may lose notification of data availability

[ https://issues.apache.org/jira/browse/FLINK-23223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23223: --- Fix Version/s: 1.14.0 > When flushAlways is enabled the subpartition may lose notification

[jira] [Updated] (FLINK-23223) When flushAlways is enabled the subpartition may lose notification of data availability

[ https://issues.apache.org/jira/browse/FLINK-23223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23223: --- Priority: Critical (was: Major) > When flushAlways is enabled the subpartition may lose

[jira] [Assigned] (FLINK-23223) When flushAlways is enabled the subpartition may lose notification of data availability

[ https://issues.apache.org/jira/browse/FLINK-23223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-23223: -- Assignee: Yun Gao > When flushAlways is enabled the subpartition may lose

[jira] [Updated] (FLINK-23223) When flushAlways is enabled the subpartition may lose notification of data availability

[ https://issues.apache.org/jira/browse/FLINK-23223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23223: Description: When the flushAways is enabled (namely set buffer timeout to 0), there might be cases like:

[jira] [Updated] (FLINK-22893) ResumeCheckpointManuallyITCase hangs on azure

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

[jira] [Updated] (FLINK-22893) ResumeCheckpointManuallyITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22893: --- Fix Version/s: 1.14.0 > ResumeCheckpointManuallyITCase hangs on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #16360: [FLINK-23095][runtime] Close the channel unspilling thread pool after restore

flinkbot edited a comment on pull request #16360: URL: https://github.com/apache/flink/pull/16360#issuecomment-873015774 ## CI report: * df9bb7a13987c2db1bf7a26d1357af48d4f52f99 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 0ff177795d6fb3b36e514d0102df23fe61093180 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 0556f30737fd827a1b18f9ec585faa1b26a43793 UNKNOWN *

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373570#comment-17373570 ] Piotr Nowojski commented on FLINK-22643: Thanks for the explanation, I think +1 from my side for

[GitHub] [flink] flinkbot edited a comment on pull request #15972: Add common source and operator metrics.

flinkbot edited a comment on pull request #15972: URL: https://github.com/apache/flink/pull/15972#issuecomment-844955772 ## CI report: * 9223b2bfe148ae335891393f244dc2c29f39d2ee UNKNOWN * 1e6b0f37803e0fa5326184c17b3a1f3669667de2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * 43550b885f3b52e7db0f82cbbf84c4086b66456c UNKNOWN * 8760bc88bd5aded39b6114687623e7ed16aea930 Azure:

  1   2   3   4   >