[jira] [Commented] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292321#comment-17292321 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger][~trohrmann] I saw you are add

[jira] [Commented] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292316#comment-17292316 ] Kezhu Wang commented on FLINK-21467: Hi [~pnowojski], I think the "non deterministic

[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 * Unknown: [CANCELED](TBD) * 604cc59c9b3c73826307be63896d35264997aefd Azure: [PENDING]

[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 * Unknown: [CANCELED](TBD) * 604cc59c9b3c73826307be63896d35264997aefd UNKNOWN

[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-787394523 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pl

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15043: [FLINK-20658][connectors/jdbc] Establish connection through driver with given name

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

[GitHub] [flink] anlen321 commented on pull request #14684: [FLINK-20460][Connector-HBase] Support async lookup for HBase connector

anlen321 commented on pull request #14684: URL: https://github.com/apache/flink/pull/14684#issuecomment-787301167 Hi @leonardBang Thanks for your some comments，I've solved it. could you help to review this? This is an autom

[GitHub] [flink] flinkbot edited a comment on pull request #15043: [FLINK-20658][connectors/jdbc] Establish connection through driver with given name

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

[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 * 0c9ad2b789f7764306f3528840c1dbe7514bc2b3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

flinkbot edited a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-759361463 ## CI report: * 5d3fb87bb54b433d0ac3489edce397b7a9e8cb51 UNKNOWN * a283f5c426e943b90258a061a263733ce2ba62e4 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[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 * 0c9ad2b789f7764306f3528840c1dbe7514bc2b3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15043: [FLINK-20658][connectors/jdbc] Establish connection through driver with given name

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

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

flinkbot edited a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-759361463 ## CI report: * 5d3fb87bb54b433d0ac3489edce397b7a9e8cb51 UNKNOWN * cc9b29c05ee0a3ed5d6f8c2c67cbf47c39f2cb0c Azure: [CANCELED](https://dev.azure.com/apache-f

[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: * 838a0e31aaab263c0511f6e38300673662ad1db0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 * 14806f8dad9adbd320409538e25cad6f7830105d Azure: [PENDING](https://dev.azure.com/apache-fl

[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 * 14806f8dad9adbd320409538e25cad6f7830105d Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

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

[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 * 14806f8dad9adbd320409538e25cad6f7830105d Azure: [FAILURE](https://dev.azure.com/apache-fl

[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-787110771 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pl

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

liuyufei9527 removed a comment 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 mes

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

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

[GitHub] [flink] wangyang0918 commented on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-787104579 cc @tillrohrmann Comments addressed. Please have a look at your convenience. I have also changed a bit about the service account because of following reasons. * T

[GitHub] [flink] flinkbot edited a comment on pull request #15043: [FLINK-20658][connectors/jdbc] Establish connection through driver with given name

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

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r584124388 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -396,6 +405,74 @@ public static String get

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r584124388 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -396,6 +405,74 @@ public static String get

[GitHub] [flink] wangyang0918 removed a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 removed a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-787088549 cc @tillrohrmann comments addressed. Please have a look at your convenience. This is an automated m

[GitHub] [flink] flinkbot commented on pull request #15043: [FLINK-20658][connectors/jdbc] Establish connection through driver with given name

flinkbot commented on pull request #15043: URL: https://github.com/apache/flink/pull/15043#issuecomment-787097509 ## CI report: * 32b0ff6cb7a6243a081c2de941fd2b16ed075d55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] tillrohrmann commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

tillrohrmann commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r584140805 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManager.java ## @@ -0,0 +1,89 @@ +/* + * Licensed to the Apach

[GitHub] [flink] flinkbot commented on pull request #15043: [FLINK-20658][connectors/jdbc] Establish connection through driver with given name

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

[jira] [Updated] (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 ] ASF GitHub Bot updated FLINK-20658: --- Labels: pull-request-available (was: ) > Make sure jdbc connection is established by target

[GitHub] [flink] kezhuw opened a new pull request #15043: [FLINK-20658][connectors/jdbc] Establish connection through driver with given name

kezhuw opened a new pull request #15043: URL: https://github.com/apache/flink/pull/15043 ## What is the purpose of the change Establish jdbc connection through driver with given name. ## Brief change log * Establish jdb connection through driver with given name. ## Ve

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

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

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

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

[GitHub] [flink] flinkbot edited a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

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

[GitHub] [flink] wangyang0918 commented on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-787088549 cc @tillrohrmann comments addressed. Please have a look at your convenience. This is an automated message f

[GitHub] [flink] wangyang0918 removed a comment on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 removed a comment on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-787086316 cc @tillrohrmann comments addressed. This is an automated message from the Apache Git Service. To r

[jira] [Resolved] (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 resolved FLINK-21518. --- Release Note: Merged into master as 8c610fcd0719569dbc6479e133442003032eaa6d, into r

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

rkhachatryan merged pull request #15041: URL: https://github.com/apache/flink/pull/15041 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 g

[GitHub] [flink] wangyang0918 commented on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-787086316 cc @tillrohrmann comments addressed. This is an automated message from the Apache Git Service. To respond t

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14684: [FLINK-20460][Connector-HBase] Support async lookup for HBase connector

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

[jira] [Commented] (FLINK-21386) FromElements ignores returns()

[ https://issues.apache.org/jira/browse/FLINK-21386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292152#comment-17292152 ] Kezhu Wang commented on FLINK-21386: I think implementing {{OutputTypeConfigurable}}

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r584128985 ## File path: docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md ## @@ -324,4 +324,240 @@ $ kubectl create clusterrolebinding

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14684: [FLINK-20460][Connector-HBase] Support async lookup for HBase connector

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

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

kezhuw commented on pull request #15039: URL: https://github.com/apache/flink/pull/15039#issuecomment-787077506 Hi @XComp, I have pushed fixup commits to solve your concerns. Please take another look. This is an automated me

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

kezhuw commented on a change in pull request #15039: URL: https://github.com/apache/flink/pull/15039#discussion_r584126047 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java ## @@ -180,21 +241,54 @@ public MetricGroup addGroup(

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r584124798 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/InitJobManagerDecorator.java ## @@ -49,64 +50,104 @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r584124388 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -396,6 +405,74 @@ public static String get

[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_r584108968 ## 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_r584107904 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend fromA

[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_r584107904 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend fromA

[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_r584107904 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend fromA

[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 * 14806f8dad9adbd320409538e25cad6f7830105d Azure: [FAILURE](https://dev.azure.com/apache-fl

[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_r584107904 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend fromA

[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_r584107215 ## 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_r584107215 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend

[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: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] rkhachatryan commented on pull request #14883: [hotfix][state] Serialize KeyGroupsStateHandle in shared Incremental …

rkhachatryan commented on pull request #14883: URL: https://github.com/apache/flink/pull/14883#issuecomment-787049559 Build failure is unrealted, private build passed, merging. This is an automated message from the Apache Git

[GitHub] [flink] rkhachatryan merged pull request #14883: [hotfix][state] Serialize KeyGroupsStateHandle in shared Incremental …

rkhachatryan merged pull request #14883: URL: https://github.com/apache/flink/pull/14883 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 g

[GitHub] [flink] rkhachatryan merged pull request #14885: [hotfix][checkpointing] Log detailed statistic (TRACE)

rkhachatryan merged pull request #14885: URL: https://github.com/apache/flink/pull/14885 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 g

[GitHub] [flink] rkhachatryan commented on pull request #14885: [hotfix][checkpointing] Log detailed statistic (TRACE)

rkhachatryan commented on pull request #14885: URL: https://github.com/apache/flink/pull/14885#issuecomment-787049106 Failure is not related to this PR changes (FLINK-21312), merging. This is an automated message from the Apa

[GitHub] [flink] rkhachatryan merged pull request #14889: [hotfix][tests] Improve ProcessingTimeWindowCheckpointingITCase

rkhachatryan merged pull request #14889: URL: https://github.com/apache/flink/pull/14889 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 g

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

rkhachatryan merged pull request #14888: URL: https://github.com/apache/flink/pull/14888 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 g

[GitHub] [flink] rkhachatryan merged pull request #14884: [hotfix][state] Improve error messages in SharedStateRegistry and HeapRestoreOperation

rkhachatryan merged pull request #14884: URL: https://github.com/apache/flink/pull/14884 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 g

[GitHub] [flink] rkhachatryan merged pull request #15037: [FLINK-21518][tests] Fix testMinCheckpointPause instability

rkhachatryan merged pull request #15037: URL: https://github.com/apache/flink/pull/15037 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 g

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

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

[jira] [Resolved] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing

[ https://issues.apache.org/jira/browse/FLINK-21515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-21515. --- Resolution: Fixed > SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheS

[jira] [Commented] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing

[ https://issues.apache.org/jira/browse/FLINK-21515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292084#comment-17292084 ] Roman Khachatryan commented on FLINK-21515: --- Merged to master as c02efc60bbf5a

[GitHub] [flink] rkhachatryan merged pull request #15042: [BP-1.12][FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

rkhachatryan merged pull request #15042: URL: https://github.com/apache/flink/pull/15042 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 g

[GitHub] [flink] rkhachatryan merged pull request #15038: [FLINK-21515][tests] Fix testStopWithSavepointShouldNotInterruptTheSource

rkhachatryan merged pull request #15038: URL: https://github.com/apache/flink/pull/15038 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 g

[jira] [Assigned] (FLINK-21367) Support objectReuse in JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-21367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-21367: - Assignee: Jan Brusch > Support objectReuse in JDBC sink > -

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

kezhuw commented on a change in pull request #15039: URL: https://github.com/apache/flink/pull/15039#discussion_r584092349 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java ## @@ -59,6 +68,58 @@ private static final Log

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

kezhuw commented on a change in pull request #15039: URL: https://github.com/apache/flink/pull/15039#discussion_r584090439 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/MetricUtilsTest.java ## @@ -180,21 +241,54 @@ public MetricGroup addGroup(

[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 fromA

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

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