[GitHub] [flink] XComp edited a comment on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

XComp edited a comment on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-787030241 Sorry for not getting back earlier: Thanks for your work, @SteNicholas and thanks for looking into it already @wangyang0918. I second @wangyang0918's proposal. The code

[GitHub] [flink] XComp commented on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

XComp commented on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-787030241 Sorry for not getting back earlier: I second @wangyang0918 proposal. The code should be easier to test after the proposed change. Additionally, the `JarsOnClassPath` singleton

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * e6149ce7a3c9c98cae505ad885687419acf2633b Azure:

[jira] [Commented] (FLINK-21500) Failed to upload logs in Azure

[ https://issues.apache.org/jira/browse/FLINK-21500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292044#comment-17292044 ] Matthias commented on FLINK-21500: -- [~dwysakowicz] Out of curiosity: You closed it because it appears

[jira] [Commented] (FLINK-21519) SQLClientHBaseITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292040#comment-17292040 ] Jark Wu commented on FLINK-21519: - Will testcontainers be more stable? > SQLClientHBaseITCase hangs on

[jira] [Commented] (FLINK-20658) Make sure jdbc connection is established by target driver

[ https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292038#comment-17292038 ] Jark Wu commented on FLINK-20658: - Sounds good to me. > Make sure jdbc connection is established by

[jira] [Assigned] (FLINK-20658) Make sure jdbc connection is established by target driver

[ https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20658: --- Assignee: Kezhu Wang > Make sure jdbc connection is established by target driver >

[GitHub] [flink] XComp commented on a change in pull request #15039: [FLINK-19763][metrics][tests] Add testNonHeapMetricUsageNotStatic and refine testMetaspaceMetricUsageNotStatic

XComp commented on a change in pull request #15039: URL: https://github.com/apache/flink/pull/15039#discussion_r584052160 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java ## @@ -161,7 +222,7 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * e6149ce7a3c9c98cae505ad885687419acf2633b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * e6149ce7a3c9c98cae505ad885687419acf2633b Azure:

[GitHub] [flink] liuyufei9527 commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

liuyufei9527 commented on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-787015515 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-21517) Test harnesses are bypassing serialization stack for events

[ https://issues.apache.org/jira/browse/FLINK-21517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21517: --- Description: Since FLINK-19297

[jira] [Closed] (FLINK-21517) Test harnesses are bypassing serialization stack for events

[ https://issues.apache.org/jira/browse/FLINK-21517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-21517. -- Fix Version/s: 1.13.0 Resolution: Fixed merged commit 01352aa into apache:master >

[GitHub] [flink] pnowojski merged pull request #15036: [FLINK-21517][tests] Test harnesses should not bypass serialization stack for events

pnowojski merged pull request #15036: URL: https://github.com/apache/flink/pull/15036 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 #15017: [FLINK-12607][rest] Introduce a REST API that returns the maxParallelism

flinkbot edited a comment on pull request #15017: URL: https://github.com/apache/flink/pull/15017#issuecomment-785661508 ## CI report: * 138c39296ba439712c017184c3f146415489a582 Azure:

[jira] [Commented] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

[ https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292033#comment-17292033 ] Piotr Nowojski commented on FLINK-19682: Hey [~nicholasjiang], could we maybe take over this

[GitHub] [flink] carp84 commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

carp84 commented on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-787011656 Thanks for the update @liuyufei9527 , please check and fix the check style issue, and make sure the pre-commit build here could pass. Thanks. >

[GitHub] [flink] flinkbot edited a comment on pull request #14883: [hotfix][state] Serialize KeyGroupsStateHandle in shared Incremental …

flinkbot edited a comment on pull request #14883: URL: https://github.com/apache/flink/pull/14883#issuecomment-774469574 ## CI report: * ceb9d1c20456f6875add6c8069d3754a23fdbe32 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15041: [BP-1.12][FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15041: URL: https://github.com/apache/flink/pull/15041#issuecomment-786862901 ## CI report: * c87e460d5d61de32c3a6ef001ee50a9c9656cd6b UNKNOWN * 8120d81eeb36c13677b71ae7bac24a417113ae2d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15037: [FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15037: URL: https://github.com/apache/flink/pull/15037#issuecomment-786688538 ## CI report: * 5060e1c1831700083fbd0b71945f8d6c57a23f52 Azure:

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r584028084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java ## @@ -136,6 +138,15 @@ */ boolean

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r584028084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java ## @@ -136,6 +138,15 @@ */ boolean

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r584026554 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java ## @@ -136,6 +138,15 @@ */ boolean

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r584025488 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegateStateBackend.java ## @@ -0,0 +1,35 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r584025219 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegateKeyedStateBackend.java ## @@ -0,0 +1,35 @@ +/* + * Licensed to

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r584023097 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StateConfigUtil.java ## @@ -46,19 +46,24 @@ public

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

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

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

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

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

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

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

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

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r584023097 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StateConfigUtil.java ## @@ -46,19 +46,24 @@ public

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

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

[jira] [Comment Edited] (FLINK-21507) Reinterpreting stream as keyed breaks the upstream partitioning

[ https://issues.apache.org/jira/browse/FLINK-21507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291993#comment-17291993 ] Iaroslav Zeigerman edited comment on FLINK-21507 at 2/27/21, 1:13 AM:

[jira] [Commented] (FLINK-21507) Reinterpreting stream as keyed breaks the upstream partitioning

[ https://issues.apache.org/jira/browse/FLINK-21507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291993#comment-17291993 ] Iaroslav Zeigerman commented on FLINK-21507: The alternative (simpler) workaround is to

[jira] [Comment Edited] (FLINK-21507) Reinterpreting stream as keyed breaks the upstream partitioning

[ https://issues.apache.org/jira/browse/FLINK-21507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291993#comment-17291993 ] Iaroslav Zeigerman edited comment on FLINK-21507 at 2/27/21, 1:12 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #15036: [FLINK-21517][tests] Test harnesses should not bypass serialization stack for events

flinkbot edited a comment on pull request #15036: URL: https://github.com/apache/flink/pull/15036#issuecomment-786640472 ## CI report: * 7d25331986d21ddd29a182d1127dd5cc5f5ee7f1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14884: [hotfix][state] Improve error messages in SharedStateRegistry and HeapRestoreOperation

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

[GitHub] [flink] flinkbot edited a comment on pull request #15042: [BP-1.12][FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

flinkbot edited a comment on pull request #15042: URL: https://github.com/apache/flink/pull/15042#issuecomment-786862995 ## CI report: * bd1fc2232fa6964fbed05aa747c6f56edd648f7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15017: [FLINK-12607][rest] Introduce a REST API that returns the maxParallelism

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

[GitHub] [flink] flinkbot edited a comment on pull request #14888: [hotfix][tests] Disable incremental checkpoints in CEPOperatorTest

flinkbot edited a comment on pull request #14888: URL: https://github.com/apache/flink/pull/14888#issuecomment-774504757 ## CI report: * a735cd3b8c1a4a821b63619d0169bb1cf3377874 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14885: [hotfix][checkpointing] Log detailed statistic (TRACE)

flinkbot edited a comment on pull request #14885: URL: https://github.com/apache/flink/pull/14885#issuecomment-774469608 ## CI report: * 74044428e53f5ac3f0857104df0676460c4bfa0b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15017: [FLINK-12607][rest] Introduce a REST API that returns the maxParallelism

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

[GitHub] [flink] bytesandwich commented on a change in pull request #15017: [FLINK-12607][rest] Introduce a REST API that returns the maxParallelism

bytesandwich commented on a change in pull request #15017: URL: https://github.com/apache/flink/pull/15017#discussion_r583985928 ## File path: flink-runtime-web/src/test/resources/rest_api_v1.snapshot ## @@ -1,3195 +1,3204 @@ -{ - "calls" : [ { -"url" : "/cluster",

[GitHub] [flink-web] rkhachatryan commented on a change in pull request #418: Add Apache Flink 1.12.2 release

rkhachatryan commented on a change in pull request #418: URL: https://github.com/apache/flink-web/pull/418#discussion_r583976166 ## File path: _posts/2021-02-16-release-1.12.2.md ## @@ -0,0 +1,205 @@ +--- +layout: post +title: "Apache Flink 1.12.2 Released" +date:

[jira] [Updated] (FLINK-20977) can not use `use` command to switch database

[ https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20977: -- Fix Version/s: (was: 1.12.2) 1.12.3 > can not use `use`

[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 ] Roman Khachatryan updated FLINK-21358: -- Fix Version/s: (was: 1.12.3) > Missing snapshot version compatibility for 1.12 >

[jira] [Updated] (FLINK-21381) Kubernetes HA documentation does not state required service account and role

[ https://issues.apache.org/jira/browse/FLINK-21381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21381: -- Fix Version/s: (was: 1.12.3) > Kubernetes HA documentation does not state

[jira] [Updated] (FLINK-21412) pyflink DataTypes.DECIMAL is not available

[ https://issues.apache.org/jira/browse/FLINK-21412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21412: -- Fix Version/s: (was: 1.12.3) > pyflink DataTypes.DECIMAL is not available >

[jira] [Updated] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21213: -- Fix Version/s: (was: 1.12.3) > e2e test fail with 'As task is already not

[jira] [Updated] (FLINK-20580) Missing null value handling for SerializedValue's getByteArray()

[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20580: -- Fix Version/s: (was: 1.12.3) > Missing null value handling for SerializedValue's

[jira] [Updated] (FLINK-20536) Update migration tests in master to cover migration from release-1.12

[ https://issues.apache.org/jira/browse/FLINK-20536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20536: -- Fix Version/s: (was: 1.12.3) > Update migration tests in master to cover

[jira] [Updated] (FLINK-21486) Add sanity check when switching from Rocks to Heap timers

[ https://issues.apache.org/jira/browse/FLINK-21486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21486: -- Fix Version/s: (was: 1.12.3) > Add sanity check when switching from Rocks to Heap

[jira] [Updated] (FLINK-21351) Incremental checkpoint data would be lost once a non-stop savepoint completed

[ https://issues.apache.org/jira/browse/FLINK-21351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21351: -- Fix Version/s: (was: 1.12.3) > Incremental checkpoint data would be lost once a

[jira] [Updated] (FLINK-20534) Add Flink 1.12 MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-20534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20534: -- Fix Version/s: (was: 1.12.3) > Add Flink 1.12 MigrationVersion >

[jira] [Updated] (FLINK-21486) Add sanity check when switching from Rocks to Heap timers

[ https://issues.apache.org/jira/browse/FLINK-21486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21486: -- Fix Version/s: 1.12.2 > Add sanity check when switching from Rocks to Heap timers >

[jira] [Updated] (FLINK-20536) Update migration tests in master to cover migration from release-1.12

[ https://issues.apache.org/jira/browse/FLINK-20536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20536: -- Fix Version/s: 1.12.2 > Update migration tests in master to cover migration from

[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 ] Roman Khachatryan updated FLINK-21358: -- Fix Version/s: 1.12.2 > Missing snapshot version compatibility for 1.12 >

[jira] [Updated] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21213: -- Fix Version/s: 1.12.2 > e2e test fail with 'As task is already not running, no longer

[jira] [Updated] (FLINK-20580) Missing null value handling for SerializedValue's getByteArray()

[ https://issues.apache.org/jira/browse/FLINK-20580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20580: -- Fix Version/s: 1.12.2 > Missing null value handling for SerializedValue's

[jira] [Updated] (FLINK-21351) Incremental checkpoint data would be lost once a non-stop savepoint completed

[ https://issues.apache.org/jira/browse/FLINK-21351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21351: -- Fix Version/s: 1.12.2 > Incremental checkpoint data would be lost once a non-stop

[jira] [Updated] (FLINK-20534) Add Flink 1.12 MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-20534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20534: -- Fix Version/s: 1.12.2 > Add Flink 1.12 MigrationVersion >

[jira] [Updated] (FLINK-21381) Kubernetes HA documentation does not state required service account and role

[ https://issues.apache.org/jira/browse/FLINK-21381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21381: -- Fix Version/s: 1.12.2 > Kubernetes HA documentation does not state required service

[jira] [Updated] (FLINK-21412) pyflink DataTypes.DECIMAL is not available

[ https://issues.apache.org/jira/browse/FLINK-21412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21412: -- Fix Version/s: 1.12.2 > pyflink DataTypes.DECIMAL is not available >

[jira] [Updated] (FLINK-21518) CheckpointCoordinatorTest.testMinCheckpointPause fails fatally on AZP

[ https://issues.apache.org/jira/browse/FLINK-21518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21518: -- Fix Version/s: (was: 1.12.2) 1.12.3 >

[GitHub] [flink] flinkbot edited a comment on pull request #15038: [FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

flinkbot edited a comment on pull request #15038: URL: https://github.com/apache/flink/pull/15038#issuecomment-786699320 ## CI report: * d52c1e163109fb01b707872227debc8cbbe06df7 UNKNOWN * 96ff5ffb6b6df97de06ada7fa1ea33209a57c551 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14883: [hotfix][state] Serialize KeyGroupsStateHandle in shared Incremental …

flinkbot edited a comment on pull request #14883: URL: https://github.com/apache/flink/pull/14883#issuecomment-774469574 ## CI report: * 93db00fb22a856759121fb6fc63b33e6e0c4119e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15037: [FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15037: URL: https://github.com/apache/flink/pull/15037#issuecomment-786688538 ## CI report: * bb5acb053c0228390e10420426abd329a527d82f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15041: [BP-1.12][FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15041: URL: https://github.com/apache/flink/pull/15041#issuecomment-786862901 ## CI report: * 749709d4a3fca40580807140df5447308ddab8f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14883: [hotfix][state] Serialize KeyGroupsStateHandle in shared Incremental …

flinkbot edited a comment on pull request #14883: URL: https://github.com/apache/flink/pull/14883#issuecomment-774469574 ## CI report: * 93db00fb22a856759121fb6fc63b33e6e0c4119e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15041: [BP-1.12][FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15041: URL: https://github.com/apache/flink/pull/15041#issuecomment-786862901 ## CI report: * 749709d4a3fca40580807140df5447308ddab8f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15036: [FLINK-21517][tests] Test harnesses should not bypass serialization stack for events

flinkbot edited a comment on pull request #15036: URL: https://github.com/apache/flink/pull/15036#issuecomment-786640472 ## CI report: * d1e88f2bd30f12245a4b6a7b23fb15d88119f48b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15037: [FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15037: URL: https://github.com/apache/flink/pull/15037#issuecomment-786688538 ## CI report: * bb5acb053c0228390e10420426abd329a527d82f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15041: [BP-1.12][FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15041: URL: https://github.com/apache/flink/pull/15041#issuecomment-786862901 ## CI report: * 749709d4a3fca40580807140df5447308ddab8f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15038: [FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

flinkbot edited a comment on pull request #15038: URL: https://github.com/apache/flink/pull/15038#issuecomment-786699320 ## CI report: * d52c1e163109fb01b707872227debc8cbbe06df7 UNKNOWN * 99a8315fc9d819a850ef63d1d3078a85056ae24e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15036: [FLINK-21517][tests] Test harnesses should not bypass serialization stack for events

flinkbot edited a comment on pull request #15036: URL: https://github.com/apache/flink/pull/15036#issuecomment-786640472 ## CI report: * d1e88f2bd30f12245a4b6a7b23fb15d88119f48b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14883: [hotfix][state] Serialize KeyGroupsStateHandle in shared Incremental …

flinkbot edited a comment on pull request #14883: URL: https://github.com/apache/flink/pull/14883#issuecomment-774469574 ## CI report: * 93db00fb22a856759121fb6fc63b33e6e0c4119e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14884: [hotfix][state] Improve error messages in SharedStateRegistry and HeapRestoreOperation

flinkbot edited a comment on pull request #14884: URL: https://github.com/apache/flink/pull/14884#issuecomment-774469595 ## CI report: * dd22ae4eac69cbd4a30f2f43c2d7944971a36d31 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #15037: [FLINK-21518][tests] Fix testMinCheckpointPause instability

pnowojski commented on a change in pull request #15037: URL: https://github.com/apache/flink/pull/15037#discussion_r583904094 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -319,9 +320,14 @@ public void

[GitHub] [flink] pnowojski commented on a change in pull request #15036: [FLINK-21517][tests] Test harnesses should not bypass serialization stack for events

pnowojski commented on a change in pull request #15036: URL: https://github.com/apache/flink/pull/15036#discussion_r583896610 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/RecordOrEventCollectingResultPartitionWriter.java ## @@ -48,7

[GitHub] [flink] flinkbot edited a comment on pull request #15041: [BP-1.12][FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15041: URL: https://github.com/apache/flink/pull/15041#issuecomment-786862901 ## CI report: * 749709d4a3fca40580807140df5447308ddab8f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15039: [FLINK-19763][metrics][tests] Add testNonHeapMetricUsageNotStatic and refine testMetaspaceMetricUsageNotStatic

flinkbot edited a comment on pull request #15039: URL: https://github.com/apache/flink/pull/15039#issuecomment-786732475 ## CI report: * 531a679152616168a7d100942a046cbc3a22b0a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15042: [BP-1.12][FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

flinkbot edited a comment on pull request #15042: URL: https://github.com/apache/flink/pull/15042#issuecomment-786862995 ## CI report: * bd1fc2232fa6964fbed05aa747c6f56edd648f7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14888: [hotfix][tests] Disable incremental checkpoints in CEPOperatorTest

flinkbot edited a comment on pull request #14888: URL: https://github.com/apache/flink/pull/14888#issuecomment-774504757 ## CI report: * fa80066f8622a854edc8a4783eae23b2baa8273d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14885: [hotfix][checkpointing] Log detailed statistic (TRACE)

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

[GitHub] [flink] flinkbot edited a comment on pull request #14884: [hotfix][state] Improve error messages in SharedStateRegistry and HeapRestoreOperation

flinkbot edited a comment on pull request #14884: URL: https://github.com/apache/flink/pull/14884#issuecomment-774469595 ## CI report: * dd22ae4eac69cbd4a30f2f43c2d7944971a36d31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14883: [hotfix][state] Serialize KeyGroupsStateHandle in shared Incremental …

flinkbot edited a comment on pull request #14883: URL: https://github.com/apache/flink/pull/14883#issuecomment-774469574 ## CI report: * a3fecd024fbdbb18b19b514dab6e0314f6a8ad27 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #15036: [FLINK-21517][tests] Test harnesses should not bypass serialization stack for events

rkhachatryan commented on a change in pull request #15036: URL: https://github.com/apache/flink/pull/15036#discussion_r583892530 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/RecordOrEventCollectingResultPartitionWriter.java ## @@

[GitHub] [flink] flinkbot commented on pull request #15042: [BP-1.12][FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

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

[GitHub] [flink] flinkbot commented on pull request #15041: [BP-1.12][FLINK-21518][tests] Fix testMinCheckpointPause instability

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

[GitHub] [flink] flinkbot edited a comment on pull request #14888: [hotfix][tests] Disable incremental checkpoints in CEPOperatorTest

flinkbot edited a comment on pull request #14888: URL: https://github.com/apache/flink/pull/14888#issuecomment-774504757 ## CI report: * fa80066f8622a854edc8a4783eae23b2baa8273d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14885: [hotfix][checkpointing] Log detailed statistic (TRACE)

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

[GitHub] [flink] rkhachatryan commented on pull request #14888: [hotfix][tests] Disable incremental checkpoints in CEPOperatorTest

rkhachatryan commented on pull request #14888: URL: https://github.com/apache/flink/pull/14888#issuecomment-786857734 Updated commit message. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] rkhachatryan commented on pull request #14888: [hotfix][tests] Disable incremental checkpoints in CEPOperatorTest

rkhachatryan commented on pull request #14888: URL: https://github.com/apache/flink/pull/14888#issuecomment-786856014 If the snapshots that are created in `testKeyedCEPOperatorCheckpointingWithRocksDB` / `testKeyedCEPOperatorNFAUpdateWithRocksDB` are incremental then they may contain

[GitHub] [flink] flinkbot commented on pull request #15042: [BP-1.12][FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

flinkbot commented on pull request #15042: URL: https://github.com/apache/flink/pull/15042#issuecomment-786853824 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #15041: [BP-1.12][FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot commented on pull request #15041: URL: https://github.com/apache/flink/pull/15041#issuecomment-786853855 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] rkhachatryan opened a new pull request #15042: [BP-1.12][FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

rkhachatryan opened a new pull request #15042: URL: https://github.com/apache/flink/pull/15042 ## What is the purpose of the change **Backport of #15038 to 1.12.** ``` SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is unstable because the latch

[GitHub] [flink] rkhachatryan opened a new pull request #15041: [BP-1.12][FLINK-21518][tests] Fix testMinCheckpointPause instability

rkhachatryan opened a new pull request #15041: URL: https://github.com/apache/flink/pull/15041 ## What is the purpose of the change **Backport of #15037 to 1.12** ``` The instability is caused by last assertion depending on timing. Solve by waiting on condition.

[GitHub] [flink] rkhachatryan commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

rkhachatryan commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r583859020 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StateConfigUtil.java ## @@ -46,19 +46,24 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15037: [FLINK-21518][tests] Fix testMinCheckpointPause instability

flinkbot edited a comment on pull request #15037: URL: https://github.com/apache/flink/pull/15037#issuecomment-786688538 ## CI report: * bb5acb053c0228390e10420426abd329a527d82f Azure:

  1   2   3   4   5   >