[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 * 6cc4a796b26b66b761f50730f7534c36afad

[GitHub] [flink] rmetzger commented on pull request #14936: [FLINK-20580][core] Don't support nullable value for SerializedValue

rmetzger commented on pull request #14936: URL: https://github.com/apache/flink/pull/14936#issuecomment-779020882 The most reliable way of triggering another Azure build is by pushing to the branch again. It seemed to have worked this time. I'll ask Chesnay to look into the reason why th

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284587#comment-17284587 ] Dawid Wysakowicz commented on FLINK-20329: -- https://dev.azure.com/apache-flink/

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284586#comment-17284586 ] Dawid Wysakowicz commented on FLINK-21214: -- https://dev.azure.com/apache-flink/

[jira] [Updated] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

[ https://issues.apache.org/jira/browse/FLINK-21234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-21234: - Affects Version/s: 1.12.2 > testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, fo

[jira] [Commented] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

[ https://issues.apache.org/jira/browse/FLINK-21234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284585#comment-17284585 ] Dawid Wysakowicz commented on FLINK-21234: -- https://dev.azure.com/apache-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 * 6cc4a796b26b66b761f50730f7534c36afad

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[jira] [Updated] (FLINK-21358) Missing snapshot version compatibility for 1.12

[ https://issues.apache.org/jira/browse/FLINK-21358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21358: - Fix Version/s: (was: 1.12.2) 1.12.3 > Missing snapshot version compatibility for

[GitHub] [flink] rmetzger commented on pull request #14283: [FLINK-15649] Support mounting volumes

rmetzger commented on pull request #14283: URL: https://github.com/apache/flink/pull/14283#issuecomment-778993856 I assume we can close this PR, because it is subsumed by FLINK-15656. This is an automated message from the Apa

[jira] [Commented] (FLINK-21358) Missing snapshot version compatibility for 1.12

[ https://issues.apache.org/jira/browse/FLINK-21358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284559#comment-17284559 ] Matthias commented on FLINK-21358: -- I looked through the the [1.12 Release Announcemen

[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&focusedCommentId=17284553#comment-17284553 ] Partha Pradeep Mishra commented on FLINK-20376: --- [~pnowojski] {{uid("a")}}

[GitHub] [flink] kezhuw commented on pull request #14936: [FLINK-20580][core] Don't support nullable value for SerializedValue

kezhuw commented on pull request #14936: URL: https://github.com/apache/flink/pull/14936#issuecomment-778963716 @flinkbot attention @tillrohrmann This is an automated message from the Apache Git Service. To respond to the me

[jira] [Commented] (FLINK-21370) flink-1.12.1 - JDBCExecutionOptions defaults config JDBCDynamicTableFactory default config is not consistent

[ https://issues.apache.org/jira/browse/FLINK-21370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284543#comment-17284543 ] 谢波 commented on FLINK-21370: Yes, i used JdbcSink. so {{JDBCExecutionOptions}}  defaults now

[GitHub] [flink] MyLanPangzi closed pull request #14933: [FLINK-21370][Connectors-JDBC] flink-1.12.1 - JDBCExecutionOptions defaults config JDBCDynamicTableFactory default config is not consistent

MyLanPangzi closed pull request #14933: URL: https://github.com/apache/flink/pull/14933 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] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284542#comment-17284542 ] Dong Lin commented on FLINK-18634: -- There is no Kafka 2.4.2 release. And we can not sim

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[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 * 6cc4a796b26b66b761f50730f7534c36afad

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

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284518#comment-17284518 ] Xintong Song edited comment on FLINK-11838 at 2/15/21, 12:06 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284518#comment-17284518 ] Xintong Song edited comment on FLINK-11838 at 2/15/21, 12:05 AM: -

[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&focusedCommentId=17284518#comment-17284518 ] Xintong Song commented on FLINK-11838: -- Thanks [~galenwarren], I think we are good

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[GitHub] [flink] StephanEwen commented on pull request #14890: [FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset()

StephanEwen commented on pull request #14890: URL: https://github.com/apache/flink/pull/14890#issuecomment-778856937 One question out of curiosity: How does Pravega's recovery and Flink's regional failover go together today?. If Flink recovers only a part of the graph (regional failo

[GitHub] [flink] StephanEwen commented on pull request #14890: [FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset()

StephanEwen commented on pull request #14890: URL: https://github.com/apache/flink/pull/14890#issuecomment-778856699 I think this PR is fine. It means that the `reset()` method of the Master Hooks is always invoked, also on partial failover and on starting a new job. Given that this is an

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[GitHub] [flink] flinkbot edited a comment on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

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

[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&focusedCommentId=17284476#comment-17284476 ] Galen Warren commented on FLINK-11838: -- {quote}Maybe for the first step, it's good

[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 * 94d299053103c1bec5dfefaf4089ed0b31c4

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284445#comment-17284445 ] Dong Lin commented on FLINK-18634: -- - According to the log [1] from Till, testScaleUpA

[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 * 6cc4a796b26b66b761f50730f7534c36afad

[GitHub] [flink] wuchong commented on a change in pull request #14938: [FLINK-21296][sql-client] Use module name to perform module factory discovery

wuchong commented on a change in pull request #14938: URL: https://github.com/apache/flink/pull/14938#discussion_r575832709 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ModuleEntry.java ## @@ -61,6 +62,15 @@ private stat

[GitHub] [flink] wuchong commented on a change in pull request #14938: [FLINK-21296][sql-client] Use module name to perform module factory discovery

wuchong commented on a change in pull request #14938: URL: https://github.com/apache/flink/pull/14938#discussion_r575832556 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/ExecutionContextTest.java ## @@ -169,15 +172,33 @@ p

[GitHub] [flink] beyond1920 commented on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

beyond1920 commented on pull request #14905: URL: https://github.com/apache/flink/pull/14905#issuecomment-778799299 @wuchong LGTM This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] LadyForest commented on a change in pull request #14938: [FLINK-21296][sql-client] Use module name to perform module factory discovery

LadyForest commented on a change in pull request #14938: URL: https://github.com/apache/flink/pull/14938#discussion_r575828726 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ModuleEntry.java ## @@ -61,6 +62,15 @@ private s

[GitHub] [flink] LadyForest commented on a change in pull request #14938: [FLINK-21296][sql-client] Use module name to perform module factory discovery

LadyForest commented on a change in pull request #14938: URL: https://github.com/apache/flink/pull/14938#discussion_r575827407 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/ExecutionContextTest.java ## @@ -169,15 +172,33 @

[GitHub] [flink] LadyForest commented on a change in pull request #14938: [FLINK-21296][sql-client] Use module name to perform module factory discovery

LadyForest commented on a change in pull request #14938: URL: https://github.com/apache/flink/pull/14938#discussion_r575826777 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ModuleEntry.java ## @@ -61,6 +62,15 @@ private s

[GitHub] [flink] flinkbot edited a comment on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

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

[GitHub] [flink] wuchong commented on a change in pull request #14938: [FLINK-21296][sql-client] Use module name to perform module factory discovery

wuchong commented on a change in pull request #14938: URL: https://github.com/apache/flink/pull/14938#discussion_r575821838 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ModuleEntry.java ## @@ -61,6 +62,15 @@ private stat

[GitHub] [flink] flinkbot edited a comment on pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

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

[GitHub] [flink] wuchong commented on a change in pull request #14905: [FLINK-19608][table-planner-blink] Support TVF based window aggreagte in planner

wuchong commented on a change in pull request #14905: URL: https://github.com/apache/flink/pull/14905#discussion_r575821151 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/PushWindowTableFunctionIntoWindowAgg

[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 * 354eb574c98bbc5fdaedabc9f3ca7e4acfaa

[jira] [Created] (FLINK-21374) Upgrade built-in Hive to 2.3.8

Yuming Wang created FLINK-21374: --- Summary: Upgrade built-in Hive to 2.3.8 Key: FLINK-21374 URL: https://issues.apache.org/jira/browse/FLINK-21374 Project: Flink Issue Type: Improvement

[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 * 354eb574c98bbc5fdaedabc9f3ca7e4acfaa

[jira] [Commented] (FLINK-16491) Add compression support for ParquetAvroWriters

[ https://issues.apache.org/jira/browse/FLINK-16491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284392#comment-17284392 ] Tomoyuki NAKAMURA commented on FLINK-16491: --- Is there any progress on this tic

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781157 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration shortcut nam

[jira] [Commented] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

[ https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284383#comment-17284383 ] Huyen Levan commented on FLINK-9940: Thank you [~maguowei] > File source continuous

[GitHub] [flink] lvhuyen commented on pull request #6613: [FLINK-9940] [API/DataStream][File source] out-of-order files were missed in continuous monitoring

lvhuyen commented on pull request #6613: URL: https://github.com/apache/flink/pull/6613#issuecomment-778756649 Thank you @guoweiM This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781718 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Ap

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781718 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Ap

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781718 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Ap

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575781157 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration shortcut nam

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575780979 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +216,11 @@ public static StateBackend fromA

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

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

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r575780943 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration shortcut nam

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

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