[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285075#comment-17285075 ] Piotr Nowojski commented on FLINK-20376: Thanks for the update. Does it mean that without the

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

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

[jira] [Created] (FLINK-21378) Rescale pointwise connection during unaligned checkpoint recovery

Arvid Heise created FLINK-21378: --- Summary: Rescale pointwise connection during unaligned checkpoint recovery Key: FLINK-21378 URL: https://issues.apache.org/jira/browse/FLINK-21378 Project: Flink

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * e8f856d50dc6d345439dc180aa7300fa8d3bbd15 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * 42b4ee86db8aa0191d4d054f21fb2db9754321c4 Azure:

[jira] [Closed] (FLINK-21259) Add DeclarativeScheduler / Failing state

[ https://issues.apache.org/jira/browse/FLINK-21259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21259. -- Resolution: Fixed Impl:

[GitHub] [flink] rmetzger closed pull request #14910: [FLINK-21259] Add Failing state for DeclarativeScheduler

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

[jira] [Assigned] (FLINK-21347) Extract interface out of ExecutionGraph for better testability

[ https://issues.apache.org/jira/browse/FLINK-21347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21347: -- Assignee: Robert Metzger > Extract interface out of ExecutionGraph for better

[GitHub] [flink] rmetzger commented on pull request #14910: [FLINK-21259] Add Failing state for DeclarativeScheduler

rmetzger commented on pull request #14910: URL: https://github.com/apache/flink/pull/14910#issuecomment-779609292 Thanks for the review! I'll merge this now. This is an automated message from the Apache Git Service. To

[GitHub] [flink] rmetzger commented on a change in pull request #14910: [FLINK-21259] Add Failing state for DeclarativeScheduler

rmetzger commented on a change in pull request #14910: URL: https://github.com/apache/flink/pull/14910#discussion_r576570468 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/MockExecutionGraph.java ## @@ -69,15 +73,22 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * 42b4ee86db8aa0191d4d054f21fb2db9754321c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14945: [FLINK-21252][quickstarts][scala] Forward target java version

flinkbot edited a comment on pull request #14945: URL: https://github.com/apache/flink/pull/14945#issuecomment-779476279 ## CI report: * f2a22dee2c998b0fe470e9c41ee62d3f6cce77ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * 62b0b348eef30dec31ea29ebe602b106f91de323 Azure:

[jira] [Commented] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285035#comment-17285035 ] Zhenqiu Huang commented on FLINK-20461: --- [~trohrmann][~dwysakowicz] I am not able to reproduce

[jira] [Comment Edited] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285032#comment-17285032 ] Partha Pradeep Mishra edited comment on FLINK-20376 at 2/16/21, 5:00 AM:

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285032#comment-17285032 ] Partha Pradeep Mishra commented on FLINK-20376: --- [~pnowojski] Upgrade from 1.9.0 to 1.9.3

[jira] [Comment Edited] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285028#comment-17285028 ] Lari Hotari edited comment on FLINK-16947 at 2/16/21, 4:38 AM: --- I came

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285028#comment-17285028 ] Lari Hotari commented on FLINK-16947: - I came across a similar issue in Apache Pulsar's build. The

[GitHub] [flink] LadyForest commented on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

LadyForest commented on pull request #14944: URL: https://github.com/apache/flink/pull/14944#issuecomment-779555304 Hi @wuchong can you help review this PR when you are free? This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #14819: [FLINK-16152] Translate "Operator/index" into Chinese

flinkbot edited a comment on pull request #14819: URL: https://github.com/apache/flink/pull/14819#issuecomment-770318086 ## CI report: * 701cc544e8d2581d76ff9357c47dc36fcdea7528 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * aa11c3a56df1220308dc2d6fb6ce9371eb29d684 UNKNOWN * a63f91ca287d6a68e1bab682e82a0ba80d227ad0 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14819: [FLINK-16152] Translate "Operator/index" into Chinese

flinkbot edited a comment on pull request #14819: URL: https://github.com/apache/flink/pull/14819#issuecomment-770318086 ## CI report: * 3b55294a34fea9ba31744e8f7fb7456c3faf46ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14819: [FLINK-16152] Translate "Operator/index" into Chinese

flinkbot edited a comment on pull request #14819: URL: https://github.com/apache/flink/pull/14819#issuecomment-770318086 ## CI report: * 3b55294a34fea9ba31744e8f7fb7456c3faf46ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * aa11c3a56df1220308dc2d6fb6ce9371eb29d684 UNKNOWN * ab3dc6709c23de8100d2ab79170b9ccb549e70ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * aa11c3a56df1220308dc2d6fb6ce9371eb29d684 UNKNOWN * ab3dc6709c23de8100d2ab79170b9ccb549e70ae Azure:

[GitHub] [flink] xintongsong edited a comment on pull request #14904: [FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

xintongsong edited a comment on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-779289434 Passed CI here: * master (1.13): https://dev.azure.com/tonysong820/Flink/_build/results?buildId=157=results * release-1.12:

[jira] [Commented] (FLINK-21373) Port RabbitMQ Sink to FLIP-143 API

[ https://issues.apache.org/jira/browse/FLINK-21373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284983#comment-17284983 ] Dominik Wosiński commented on FLINK-21373: -- Can I tackle this one ?? > Port RabbitMQ Sink to

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

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

[GitHub] [flink] dijkwxyz commented on a change in pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

dijkwxyz commented on a change in pull request #14773: URL: https://github.com/apache/flink/pull/14773#discussion_r576302353 ## File path: docs/dev/stream/operators/windows.zh.md ## @@ -491,10 +464,10 @@ An `AggregateFunction` can be defined and used like this: */ private

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14945: [FLINK-21252][quickstarts][scala] Forward target java version

flinkbot edited a comment on pull request #14945: URL: https://github.com/apache/flink/pull/14945#issuecomment-779476279 ## CI report: * f2a22dee2c998b0fe470e9c41ee62d3f6cce77ef Azure:

[GitHub] [flink] flinkbot commented on pull request #14945: [FLINK-21252][quickstarts][scala] Forward target java version

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

[GitHub] [flink] flinkbot commented on pull request #14945: [FLINK-21252][quickstarts][scala] Forward target java version

flinkbot commented on pull request #14945: URL: https://github.com/apache/flink/pull/14945#issuecomment-779471792 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-21252) Scala quickstarts should specify -target jvm version

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

[GitHub] [flink] zentol opened a new pull request #14945: [FLINK-21252][quickstarts][scala] Forward target java version

zentol opened a new pull request #14945: URL: https://github.com/apache/flink/pull/14945 The scala quickstarts now use the same jvm version as the `-target` as the main project; this ensures that the experience for scala users is identical to what we see when we write tests or use the

[jira] [Assigned] (FLINK-21252) Scala quickstarts should specify -target jvm version

[ https://issues.apache.org/jira/browse/FLINK-21252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-21252: Assignee: Chesnay Schepler > Scala quickstarts should specify -target jvm

[jira] [Commented] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284960#comment-17284960 ] Joey Pereira commented on FLINK-21321: -- It turns out the feature was no longer marked as

[GitHub] [flink] flinkbot edited a comment on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

flinkbot edited a comment on pull request #14944: URL: https://github.com/apache/flink/pull/14944#issuecomment-779315396 ## CI report: * c5cdcc96806e803647e8e34be2a3a112cf16d4f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS pass with declarative scheduler

flinkbot edited a comment on pull request #14942: URL: https://github.com/apache/flink/pull/14942#issuecomment-779287504 ## CI report: * 994ed10c20564e7dc215a62f79912d528e0df7a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14928: [FLINK-21360][coordination] Make resource timeout configurable

flinkbot edited a comment on pull request #14928: URL: https://github.com/apache/flink/pull/14928#issuecomment-14828 ## CI report: * fa4a474ab1addab8caafd64686a1a9d029843556 Azure:

[GitHub] [flink] zentol commented on a change in pull request #14928: [FLINK-21360][coordination] Make resource timeout configurable

zentol commented on a change in pull request #14928: URL: https://github.com/apache/flink/pull/14928#discussion_r576252689 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -392,6 +394,25 @@

[jira] [Closed] (FLINK-21365) Visibility issue in FutureUtils.ResultConjunctFuture.handleCompletedFuture

[ https://issues.apache.org/jira/browse/FLINK-21365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-21365. -- Resolution: Not A Problem It turned out to be a non-issue. Contract clarified as commit

[GitHub] [flink] pnowojski merged pull request #14940: [FLINK-21365][runtime] Document and make the contract of FutureUtilsResultConjunctFuture more explicit

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

[GitHub] [flink] flinkbot edited a comment on pull request #14940: [FLINK-21365][runtime] Document and make the contract of FutureUtilsResultConjunctFuture more explicit

flinkbot edited a comment on pull request #14940: URL: https://github.com/apache/flink/pull/14940#issuecomment-779216297 ## CI report: * 566b6c0c967e6e76830b02f7120554ffcb0d1f50 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14910: [FLINK-21259] Add Failing state for DeclarativeScheduler

flinkbot edited a comment on pull request #14910: URL: https://github.com/apache/flink/pull/14910#issuecomment-775986669 ## CI report: * 723dc6290b3c32381684f2dd9052baf927bb47fd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * aa11c3a56df1220308dc2d6fb6ce9371eb29d684 UNKNOWN * ab3dc6709c23de8100d2ab79170b9ccb549e70ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14913: [FLINK-21344] Support switching from/to rocks db with heap timers

flinkbot edited a comment on pull request #14913: URL: https://github.com/apache/flink/pull/14913#issuecomment-776225670 ## CI report: * 341578b2d03693afbd8179683c6f2696c229 UNKNOWN * 9ef552dc3d5ef4cb214d6d1d9c012d633721889a Azure:

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284896#comment-17284896 ] Galen Warren commented on FLINK-11838: -- Ah, OK – I see. It will take me a couple of days to get

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * af8de65a4905ae47ab704a75acfcd1b2e897d915 UNKNOWN * 772e076ed9d773e16713236c942f4e30b659d6eb UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14940: [FLINK-21365][runtime] Document and make the contract of FutureUtilsResultConjunctFuture more explicit

flinkbot edited a comment on pull request #14940: URL: https://github.com/apache/flink/pull/14940#issuecomment-779216297 ## CI report: * a3874616728639b6a9e8b273bfa0a4d89d753ba1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * aa11c3a56df1220308dc2d6fb6ce9371eb29d684 UNKNOWN * 8bc7297b9b8336691d9778d301c37930d61e0a57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * aa11c3a56df1220308dc2d6fb6ce9371eb29d684 UNKNOWN * 8bc7297b9b8336691d9778d301c37930d61e0a57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * ec78762bddcb8c064ecf990b1922b132fd002b92 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #14910: [FLINK-21259] Add Failing state for DeclarativeScheduler

tillrohrmann commented on a change in pull request #14910: URL: https://github.com/apache/flink/pull/14910#discussion_r576312246 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/MockExecutionGraph.java ## @@ -69,15 +73,22 @@ public

[GitHub] [flink] tillrohrmann commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

tillrohrmann commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r576311046 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java ## @@ -605,6 +625,414 @@ public void

[GitHub] [flink] tillrohrmann commented on a change in pull request #14904: [FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

tillrohrmann commented on a change in pull request #14904: URL: https://github.com/apache/flink/pull/14904#discussion_r576310043 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/HybridMemorySegment.java ## @@ -357,4 +385,9 @@ public final void put(int

[jira] [Commented] (FLINK-21372) Arranging cluster tests, on RISC-V

[ https://issues.apache.org/jira/browse/FLINK-21372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284817#comment-17284817 ] Till Rohrmann commented on FLINK-21372: --- You find Flink's dev mailing list

[GitHub] [flink] dijkwxyz commented on a change in pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

dijkwxyz commented on a change in pull request #14773: URL: https://github.com/apache/flink/pull/14773#discussion_r576221879 ## File path: docs/dev/stream/operators/windows.zh.md ## @@ -327,65 +312,63 @@ input {% highlight scala %} val input: DataStream[T] = ... - -//

[jira] [Comment Edited] (FLINK-21354) Add ChangelogStateBackend (proxy-everything)

[ https://issues.apache.org/jira/browse/FLINK-21354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284797#comment-17284797 ] Yuan Mei edited comment on FLINK-21354 at 2/15/21, 4:23 PM:

[GitHub] [flink] flinkbot edited a comment on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

flinkbot edited a comment on pull request #14944: URL: https://github.com/apache/flink/pull/14944#issuecomment-779315396 ## CI report: * c5cdcc96806e803647e8e34be2a3a112cf16d4f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * 62b0b348eef30dec31ea29ebe602b106f91de323 Azure:

[jira] [Commented] (FLINK-21354) Add ChangelogStateBackend (proxy-everything)

[ https://issues.apache.org/jira/browse/FLINK-21354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284797#comment-17284797 ] Yuan Mei commented on FLINK-21354: -- https://github.com/apache/flink/pull/14943 moves

[GitHub] [flink] flinkbot edited a comment on pull request #14838: [FLINK-19503][state] Add StateChangelog API

flinkbot edited a comment on pull request #14838: URL: https://github.com/apache/flink/pull/14838#issuecomment-772060058 ## CI report: * 1506a66da8f77069706d654fc43335e21fcf154e Azure:

[GitHub] [flink] dijkwxyz commented on a change in pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

dijkwxyz commented on a change in pull request #14773: URL: https://github.com/apache/flink/pull/14773#discussion_r576302353 ## File path: docs/dev/stream/operators/windows.zh.md ## @@ -491,10 +464,10 @@ An `AggregateFunction` can be defined and used like this: */ private

[GitHub] [flink] flinkbot commented on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

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

[GitHub] [flink] flinkbot commented on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot commented on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * 62b0b348eef30dec31ea29ebe602b106f91de323 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14838: [FLINK-19503][state] Add StateChangelog API

flinkbot edited a comment on pull request #14838: URL: https://github.com/apache/flink/pull/14838#issuecomment-772060058 ## CI report: * 38b7950b0c94efc6ed0dfc70828712e3b353ca65 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * ec78762bddcb8c064ecf990b1922b132fd002b92 Azure:

[GitHub] [flink] dijkwxyz commented on a change in pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

dijkwxyz commented on a change in pull request #14773: URL: https://github.com/apache/flink/pull/14773#discussion_r576289605 ## File path: docs/dev/stream/operators/windows.zh.md ## @@ -327,65 +312,63 @@ input {% highlight scala %} val input: DataStream[T] = ... - -//

[GitHub] [flink] flinkbot commented on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

flinkbot commented on pull request #14944: URL: https://github.com/apache/flink/pull/14944#issuecomment-779311077 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] dijkwxyz commented on a change in pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

dijkwxyz commented on a change in pull request #14773: URL: https://github.com/apache/flink/pull/14773#discussion_r576286806 ## File path: docs/dev/stream/operators/windows.zh.md ## @@ -23,137 +23,131 @@ specific language governing permissions and limitations under the

[jira] [Updated] (FLINK-21297) Support 'LOAD/UNLOAD MODULE' syntax

[ https://issues.apache.org/jira/browse/FLINK-21297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21297: --- Labels: pull-request-available (was: ) > Support 'LOAD/UNLOAD MODULE' syntax >

[GitHub] [flink] curcur commented on pull request #14904: [FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

curcur commented on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-779305230 thanks! This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] LadyForest opened a new pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

LadyForest opened a new pull request #14944: URL: https://github.com/apache/flink/pull/14944 ## What is the purpose of the change This pull request supports loading/unloading modules by `LOAD/UNLOAD MODULE` syntax. ## Brief change log This PR contains 3 commits

[GitHub] [flink] XComp commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

XComp commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r576278350 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -908,38 +909,57 @@ public void

[jira] [Commented] (FLINK-21372) Arranging cluster tests, on RISC-V

[ https://issues.apache.org/jira/browse/FLINK-21372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284787#comment-17284787 ] Ivan Serdyuk commented on FLINK-21372: -- [~trohrmann] , are you assuming

[GitHub] [flink] XComp commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

XComp commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r576278350 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -908,38 +909,57 @@ public void

[GitHub] [flink] zentol commented on pull request #14941: Release 1.12 flink standalone cluster run in different tasknode fail with Exception

zentol commented on pull request #14941: URL: https://github.com/apache/flink/pull/14941#issuecomment-779298945 Please open tickets in [JIRA](https://issues.apache.org/jira/browse/FLINK). This is an automated message from

[GitHub] [flink] zentol closed pull request #14941: Release 1.12 flink standalone cluster run in different tasknode fail with Exception

zentol closed pull request #14941: URL: https://github.com/apache/flink/pull/14941 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] flinkbot edited a comment on pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS pass with declarative scheduler

flinkbot edited a comment on pull request #14942: URL: https://github.com/apache/flink/pull/14942#issuecomment-779287504 ## CI report: * 994ed10c20564e7dc215a62f79912d528e0df7a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14941: Release 1.12 flink standalone cluster run in different tasknode fail with Exception

flinkbot edited a comment on pull request #14941: URL: https://github.com/apache/flink/pull/14941#issuecomment-779248055 ## CI report: * 1345c0f9a606a6e5ccffda59bb28a6ccfe054263 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14928: [FLINK-21360][coordination] Make resource timeout configurable

flinkbot edited a comment on pull request #14928: URL: https://github.com/apache/flink/pull/14928#issuecomment-14828 ## CI report: * f2be4ac1ab7e9faeb7d1aac40fe003903edff497 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14930: [FLINK-21339][tests] Enable and fix ExceptionUtilsITCase

flinkbot edited a comment on pull request #14930: URL: https://github.com/apache/flink/pull/14930#issuecomment-778161603 ## CI report: * 2871d67e16ca1a58ab47320fcac05f36c1011662 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

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

[GitHub] [flink] flinkbot commented on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot commented on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779297849 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] curcur opened a new pull request #14943: Implement a StateChangelogStateBackend to forward state changes to St…

curcur opened a new pull request #14943: URL: https://github.com/apache/flink/pull/14943 …ateChangleLog Move StateChangelogStateBackend to a separate module. This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20663. Fix Version/s: (was: 1.12.3) 1.13.0 1.12.2

[GitHub] [flink] xintongsong closed pull request #14904: [FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

xintongsong closed pull request #14904: URL: https://github.com/apache/flink/pull/14904 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] xintongsong commented on pull request #14904: [FLINK-20663][runtime] Instantly release unsafe memory on freeing segment.

xintongsong commented on pull request #14904: URL: https://github.com/apache/flink/pull/14904#issuecomment-779289434 Passed CI here: * master (1.13): https://dev.azure.com/tonysong820/Flink/_build/results?buildId=157=results * release-1.12:

[GitHub] [flink] lovelock commented on pull request #14848: [FLINK-21268]Fix scrolling issue in Firefox

lovelock commented on pull request #14848: URL: https://github.com/apache/flink/pull/14848#issuecomment-779288383 > @vthinkxie I just download the master zip and do the same to it, it only stuck at npm thing(which is related to great firewall) and the OOM is gone. So I guess the OOM comes

[GitHub] [flink] flinkbot commented on pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS pass with declarative scheduler

flinkbot commented on pull request #14942: URL: https://github.com/apache/flink/pull/14942#issuecomment-779287504 ## CI report: * 994ed10c20564e7dc215a62f79912d528e0df7a4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14928: [FLINK-21360][coordination] Make resource timeout configurable

flinkbot edited a comment on pull request #14928: URL: https://github.com/apache/flink/pull/14928#issuecomment-14828 ## CI report: * f2be4ac1ab7e9faeb7d1aac40fe003903edff497 Azure:

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284771#comment-17284771 ] Xintong Song commented on FLINK-11838: -- [~galenwarren], What makes the original PR not easy to

[GitHub] [flink] flinkbot commented on pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS pass with declarative scheduler

flinkbot commented on pull request #14942: URL: https://github.com/apache/flink/pull/14942#issuecomment-779277958 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] zentol commented on a change in pull request #14928: [FLINK-21360][coordination] Make resource timeout configurable

zentol commented on a change in pull request #14928: URL: https://github.com/apache/flink/pull/14928#discussion_r576252689 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -392,6 +394,25 @@

[GitHub] [flink] zentol opened a new pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS pass with declarative scheduler

zentol opened a new pull request #14942: URL: https://github.com/apache/flink/pull/14942 - moves JobMaster QS tests to separate file, because the existing JobMasterTest file is big enough as is - apply various refactorings/cleanup to these tests - remove many unnecessary components

[jira] [Updated] (FLINK-21377) Adjust queryable-state JobMaster tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #14940: [FLINK-21365][runtime] Document and make the contract of FutureUtilsResultConjunctFuture more explicit

flinkbot edited a comment on pull request #14940: URL: https://github.com/apache/flink/pull/14940#issuecomment-779216297 ## CI report: * a3874616728639b6a9e8b273bfa0a4d89d753ba1 Azure:

  1   2   3   4   >