[jira] [Created] (FLINK-30186) Bump Flink version to 1.15.3

2022-11-24 Thread Jeff Yang (Jira)
Jeff Yang created FLINK-30186: - Summary: Bump Flink version to 1.15.3 Key: FLINK-30186 URL: https://issues.apache.org/jira/browse/FLINK-30186 Project: Flink Issue Type: Improvement Comp

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #180: [FLINK-30159] Add Transformer for ANOVATest

2022-11-24 Thread GitBox
jiangxin369 commented on code in PR #180: URL: https://github.com/apache/flink-ml/pull/180#discussion_r1031158177 ## flink-ml-lib/src/test/java/org/apache/flink/ml/stats/ANOVATestTest.java: ## @@ -0,0 +1,411 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one +

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031158777 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateChunkReaderTest.java: ## @@ -35,31 +35,44 @@ import static org.apache.flink.

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031158777 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateChunkReaderTest.java: ## @@ -35,31 +35,44 @@ import static org.apache.flink.

[GitHub] [flink-table-store] JingsongLi merged pull request #395: [FLINK-30125] Projection pushdown is not work for partial update

2022-11-24 Thread GitBox
JingsongLi merged PR #395: URL: https://github.com/apache/flink-table-store/pull/395 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@

[jira] [Updated] (FLINK-29711) Topic notification not present in metadata after 60000 ms.

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29711: --- Fix Version/s: (was: 1.16.0) > Topic notification not present in metadata after 6 ms

[jira] [Closed] (FLINK-30125) Projection pushdown is not work for partial update

2022-11-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30125. Fix Version/s: (was: table-store-0.2.2) Resolution: Fixed master: 2b8fd32140ed0bf05aa5f

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #180: [FLINK-30159] Add Transformer for ANOVATest

2022-11-24 Thread GitBox
jiangxin369 commented on code in PR #180: URL: https://github.com/apache/flink-ml/pull/180#discussion_r1031162643 ## flink-ml-lib/src/test/java/org/apache/flink/ml/stats/ANOVATestTest.java: ## @@ -0,0 +1,411 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one +

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031164160 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateChunkReaderTest.java: ## @@ -35,31 +35,44 @@ import static org.apache.flink.

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031165675 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateChunkReaderTest.java: ## @@ -68,27 +81,28 @@ public void testBufferRecycledOnSu

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031166317 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateChunkReaderTest.java: ## @@ -68,27 +81,28 @@ public void testBufferRecycledOnSu

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031166917 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateChunkReaderTest.java: ## @@ -68,27 +81,28 @@ public void testBufferRecycledOnSu

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

2022-11-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638164#comment-17638164 ] Yun Gao commented on FLINK-30131: - Hi [~landlord]  sorry for the later response, first m

[GitHub] [flink-kubernetes-operator] yangjf2019 opened a new pull request, #451: [FLINK-30186] Bump Flink version to 1.15.3

2022-11-24 Thread GitBox
yangjf2019 opened a new pull request, #451: URL: https://github.com/apache/flink-kubernetes-operator/pull/451 ## What is the purpose of the change * Bump Flink version to 1.15.3. ## Brief change log * I modified some files in the project. ## Verifying t

[GitHub] [flink] zentol merged pull request #21346: [FLINK-26037][coordination] TMRunner waits for metric registry shutdown

2022-11-24 Thread GitBox
zentol merged PR #21346: URL: https://github.com/apache/flink/pull/21346 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Updated] (FLINK-30186) Bump Flink version to 1.15.3

2022-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30186: --- Labels: pull-request-available (was: ) > Bump Flink version to 1.15.3 > ---

[GitHub] [flink] gaoyunhaii commented on pull request #21371: [FLINK-30166][Connector/FileSystem] Refactor tests that use the deprecated StreamingFileSink instead of FileSink

2022-11-24 Thread GitBox
gaoyunhaii commented on PR #21371: URL: https://github.com/apache/flink/pull/21371#issuecomment-1326097684 Very thanks for the fix! I'll have a look. -- 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] [Closed] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26037. Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed master: 72fce3779

[jira] [Commented] (FLINK-30184) Save TM/JM thread stack periodically

2022-11-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638166#comment-17638166 ] Yun Gao commented on FLINK-30184: - Hi [~fanrui] perhaps [FlameGraph | https://nightlies

[jira] [Created] (FLINK-30187) Multi session job test is silently not checking the operator log for errors

2022-11-24 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-30187: - Summary: Multi session job test is silently not checking the operator log for errors Key: FLINK-30187 URL: https://issues.apache.org/jira/browse/FLINK-30187 Project

[jira] [Updated] (FLINK-26037) TaskManagerRunner may crash during shutdown sequence

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26037: - Summary: TaskManagerRunner may crash during shutdown sequence (was: TaskManagerRunnerTe

[jira] [Assigned] (FLINK-30187) Multi session job test is silently not checking the operator log for errors

2022-11-24 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-30187: - Assignee: Gabor Somogyi > Multi session job test is silently not checking the operator

[jira] [Closed] (FLINK-26632) JobManagerHAProcessFailureRecoveryITCase failed due to JVM exits with code 239

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-26632. - Resolution: Duplicate Closed in favor of FLINK-26037. I verified that all the builds failed due

[jira] [Closed] (FLINK-25587) HiveCatalogITCase crashed on Azure with exit code 239

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-25587. - Resolution: Duplicate Closed in favor of FLINK-26037. I verified that all the builds failed due

[jira] [Closed] (FLINK-30140) flink-runtime intergration tests fail due to Process Exit Code: 239

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30140. - Resolution: Duplicate Closed in favor of FLINK-26037. I verified that all the builds failed due

[jira] [Closed] (FLINK-30105) SubtaskExecutionAttemptAccumulatorsInfoTest failed with JVM exit code 239

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30105. - Resolution: Duplicate Closed in favor of FLINK-26037. I verified that all the builds failed due

[GitHub] [flink] MartijnVisser merged pull request #21375: [FLINK-30170][Parquet] Update Parquet version to 1.12.3

2022-11-24 Thread GitBox
MartijnVisser merged PR #21375: URL: https://github.com/apache/flink/pull/21375 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink

[jira] [Closed] (FLINK-30170) Update Parquet version to 1.12.3

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30170. -- Fix Version/s: 1.17.0 Assignee: Martijn Visser Resolution: Fixed Fixed in mast

[jira] [Updated] (FLINK-26037) TaskManagerRunner may crash during shutdown sequence

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26037: -- Affects Version/s: 1.16.0 > TaskManagerRunner may crash during shutdown sequence > ---

[GitHub] [flink] PatrickRen commented on a diff in pull request #20370: [FLINK-28185][Connector/Kafka] handle missing timestamps when there are empty partitions for the TimestampOffsetsInitializer

2022-11-24 Thread GitBox
PatrickRen commented on code in PR #20370: URL: https://github.com/apache/flink/pull/20370#discussion_r1031176628 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java: ## @@ -612,6 +612,10 @@ public

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #180: [FLINK-30159] Add Transformer for ANOVATest

2022-11-24 Thread GitBox
jiangxin369 commented on code in PR #180: URL: https://github.com/apache/flink-ml/pull/180#discussion_r1031178423 ## flink-ml-python/pyflink/ml/lib/tests/test_ml_lib_completeness.py: ## @@ -81,6 +83,9 @@ def module_name(self): def module(self): pass +def excl

[jira] [Commented] (FLINK-26037) TaskManagerRunner may crash during shutdown sequence

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638182#comment-17638182 ] Matthias Pohl commented on FLINK-26037: --- [~chesnay] any reason you didn't provide

[jira] [Closed] (FLINK-27320) When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27320. -- Resolution: Done > When using KafkaSink EXACTLY_ONCE semantics, frequent > OutOfOrderSequence

[jira] [Commented] (FLINK-30178) Kubernetes test failed with "crictl: command not found"

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638185#comment-17638185 ] Martijn Visser commented on FLINK-30178: Thanks :) > Kubernetes test failed wit

[jira] [Commented] (FLINK-27320) When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638183#comment-17638183 ] Martijn Visser commented on FLINK-27320: [~Tony Giao] That's good to hear. Since

[jira] [Updated] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30183: - Affects Version/s: (was: 1.17.0) > We should add a proper error message in case the

[jira] [Updated] (FLINK-30115) Include log4j-layout-template-json jar in the default operator image

2022-11-24 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30115: -- Description: Ussing logging processors/forwarders in Kubernetes is pretty comm

[GitHub] [flink-kubernetes-operator] yangjf2019 commented on pull request #451: [FLINK-30186] Bump Flink version to 1.15.3

2022-11-24 Thread GitBox
yangjf2019 commented on PR #451: URL: https://github.com/apache/flink-kubernetes-operator/pull/451#issuecomment-1326112139 The central repository has not yet generated the org.apache.flink:flink-kubernetes:1.15.2 dependency, so we may have to wait a bit. https://user-images.githubuserco

[GitHub] [flink] MartijnVisser merged pull request #21378: [FLINK-30177][Connectors/JDBC] Update pgjdbc to avoid CVE-2022-41946

2022-11-24 Thread GitBox
MartijnVisser merged PR #21378: URL: https://github.com/apache/flink/pull/21378 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #180: [FLINK-30159] Add Transformer for ANOVATest

2022-11-24 Thread GitBox
jiangxin369 commented on code in PR #180: URL: https://github.com/apache/flink-ml/pull/180#discussion_r1031178423 ## flink-ml-python/pyflink/ml/lib/tests/test_ml_lib_completeness.py: ## @@ -81,6 +83,9 @@ def module_name(self): def module(self): pass +def excl

[jira] [Assigned] (FLINK-30177) Update pgjdbc to fix CVE-2022-41946

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30177: -- Assignee: Sergey Nuyanzin > Update pgjdbc to fix CVE-2022-41946 > ---

[jira] [Closed] (FLINK-30177) Update pgjdbc to fix CVE-2022-41946

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30177. -- Fix Version/s: 1.17.0 Resolution: Fixed Fixed in master: e08b251cf11e6d4a6922e9e5a3653f

[jira] [Commented] (FLINK-29856) Triggering savepoint does not trigger source operator checkpoint

2022-11-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638190#comment-17638190 ] Yun Gao commented on FLINK-29856: - Hi [~mason6345]  may I have a double confirmation tha

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031185662 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateSerializerImplTest.java: ## @@ -145,15 +141,15 @@ private void readAndCheck(

[jira] [Created] (FLINK-30188) Partition finished state in ConsumedPartitionGroup is not updated correctly in dynamic graph

2022-11-24 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-30188: -- Summary: Partition finished state in ConsumedPartitionGroup is not updated correctly in dynamic graph Key: FLINK-30188 URL: https://issues.apache.org/jira/browse/FLINK-30188

[GitHub] [flink] JingsongLi commented on a diff in pull request #21182: [FLINK-29679][table] Migrate to new schema framework & show column comment

2022-11-24 Thread GitBox
JingsongLi commented on code in PR #21182: URL: https://github.com/apache/flink/pull/21182#discussion_r1031181983 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java: ## @@ -346,6 +346,41 @@ public Schema toSchema() { return build

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031187786 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImplTest.java: ## @@ -68,16 +67,16 @@ public void testCon

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031187786 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImplTest.java: ## @@ -68,16 +67,16 @@ public void testCon

[jira] [Commented] (FLINK-30184) Save TM/JM thread stack periodically

2022-11-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638192#comment-17638192 ] Rui Fan commented on FLINK-30184: - Hi [~gaoyunhaii] , thanks for your reply. I'm sorry,

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #396: [FLINK-27846] Schema evolution for reading data file

2022-11-24 Thread GitBox
JingsongLi commented on code in PR #396: URL: https://github.com/apache/flink-table-store/pull/396#discussion_r1031189498 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaEvolutionUtil.java: ## @@ -62,4 +72,193 @@ public static int[] createI

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031190841 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImplTest.java: ## @@ -73,8 +78,8 @@ private void testCloseA

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031191387 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImplTest.java: ## @@ -91,15 +96,15 @@ private void testSubm

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031191974 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImplTest.java: ## @@ -110,13 +115,13 @@ public void testCle

[jira] [Commented] (FLINK-29685) Add JM info into ExecutionGraph

2022-11-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638196#comment-17638196 ] Xintong Song commented on FLINK-29685: -- Agree with [~martijnvisser], I think this s

[GitHub] [flink-kubernetes-operator] gaborgsomogyi opened a new pull request, #452: [FLINK-30187] Get operator log considering namespace

2022-11-24 Thread GitBox
gaborgsomogyi opened a new pull request, #452: URL: https://github.com/apache/flink-kubernetes-operator/pull/452 ## What is the purpose of the change Multi session job test is silently not checking the operator log for errors: ``` Checking for operator log errors... error: You

[jira] [Closed] (FLINK-29685) Add JM info into ExecutionGraph

2022-11-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29685. Resolution: Won't Do > Add JM info into ExecutionGraph > --- > >

[jira] [Updated] (FLINK-30187) Multi session job test is silently not checking the operator log for errors

2022-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30187: --- Labels: pull-request-available (was: ) > Multi session job test is silently not checking th

[GitHub] [flink] YesOrNo828 commented on pull request #21381: [FLINK-30180][docs] Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

2022-11-24 Thread GitBox
YesOrNo828 commented on PR #21381: URL: https://github.com/apache/flink/pull/21381#issuecomment-1326126939 > Hi @MartijnVisser, Done with the Chinese documentation. Please have a look. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Commented] (FLINK-30184) Save TM/JM thread stack periodically

2022-11-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638198#comment-17638198 ] Yun Gao commented on FLINK-30184: - Thanks [~fanrui] for the explanation! Now I got the i

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031199426 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImplTest.java: ## @@ -37,51 +37,58 @@ import static org.apache.flink.ru

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031199977 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImplTest.java: ## @@ -37,51 +37,58 @@ import static org.apache.flink.ru

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

2022-11-24 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638199#comment-17638199 ] Hang Ruan commented on FLINK-29801: --- Hi,[~MengYue] , what is your e-mail? I will send

[jira] [Commented] (FLINK-29481) Show JobType on WebUI

2022-11-24 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638200#comment-17638200 ] Lijie Wang commented on FLINK-29481: Hi [~dangshazi] , any updates on this ticket? 

[GitHub] [flink] MartijnVisser merged pull request #21381: [FLINK-30180][docs] Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

2022-11-24 Thread GitBox
MartijnVisser merged PR #21381: URL: https://github.com/apache/flink/pull/21381 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

2022-11-24 Thread yuemeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638202#comment-17638202 ] yuemeng commented on FLINK-29801: - [~ruanhang1993]  Here is my email(272614...@qq.com)

[jira] [Assigned] (FLINK-30180) Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30180: -- Assignee: Xianxun Ye > Remove the description of Filesystem supporting for the lookup

[jira] [Closed] (FLINK-30180) Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30180. -- Fix Version/s: 1.17.0 Resolution: Fixed Fixed in master: 752321d31d1c43f5815f47927feb34

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031206763 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImplTest.java: ## @@ -135,145 +145,200 @@ public void testAbortOldAndStar

[jira] [Commented] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638204#comment-17638204 ] Chesnay Schepler commented on FLINK-30183: -- We already have a log message for t

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031211654 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/CheckpointInProgressRequestTest.java: ## @@ -55,7 +55,7 @@ public void testNoCancelTwice()

[jira] [Commented] (FLINK-29906) Address tabs/spaces in checkstyle/spotless

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638205#comment-17638205 ] Chesnay Schepler commented on FLINK-29906: -- > should do it on your repo or shou

[jira] [Commented] (FLINK-28973) Extending /jars/:jarid/plan API to support setting Flink configs

2022-11-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638208#comment-17638208 ] Yun Gao commented on FLINK-28973: - Very thanks [~ConradJam] for the update! [~Zhanghao C

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031214486 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImplTest.java: ## @@ -184,7 +186,7 @@ private Map> collectBuff

[jira] [Commented] (FLINK-29906) Address tabs/spaces in checkstyle/spotless

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638209#comment-17638209 ] Chesnay Schepler commented on FLINK-29906: -- FYI the .editorconfig that all othe

[jira] [Closed] (FLINK-28973) Extending /jars/:jarid/plan API to support setting Flink configs

2022-11-24 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-28973. -- Resolution: Duplicate > Extending /jars/:jarid/plan API to support setting Flink configs > ---

[GitHub] [flink-web] zhongjiajie closed pull request #331: Unify committer avatars size

2022-11-24 Thread GitBox
zhongjiajie closed pull request #331: Unify committer avatars size URL: https://github.com/apache/flink-web/pull/331 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscr

[GitHub] [flink] snuyanzin commented on pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-24 Thread GitBox
snuyanzin commented on PR #21368: URL: https://github.com/apache/flink/pull/21368#issuecomment-1326152140 In general looks good, i left some comments. May be a dummy question to clarify: is there a way to determine which tests are related to unaligned checkpoint and which are not based e.

[GitHub] [flink] XComp commented on a diff in pull request #21379: [FLINK-30179][runtime] Stop stringifying exception for logging

2022-11-24 Thread GitBox
XComp commented on code in PR #21379: URL: https://github.com/apache/flink/pull/21379#discussion_r1031225607 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java: ## @@ -1081,23 +1081,23 @@ private boolean transitionState( curren

[jira] [Created] (FLINK-30189) HsSubpartitionFileReader may load data that has been consumed from memory

2022-11-24 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-30189: -- Summary: HsSubpartitionFileReader may load data that has been consumed from memory Key: FLINK-30189 URL: https://issues.apache.org/jira/browse/FLINK-30189 Project: Flink

[jira] [Updated] (FLINK-30131) flink iterate will suspend when record is a bit large

2022-11-24 Thread Lu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-30131: --- Attachment: image-2022-11-24-17-10-45-651.png > flink iterate will suspend when record is a bit large >

[jira] [Updated] (FLINK-30131) flink iterate will suspend when record is a bit large

2022-11-24 Thread Lu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-30131: --- Attachment: image-2022-11-24-17-12-47-024.png > flink iterate will suspend when record is a bit large >

[jira] [Updated] (FLINK-30131) flink iterate will suspend when record is a bit large

2022-11-24 Thread Lu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-30131: --- Attachment: image-2022-11-24-17-12-02-129.png > flink iterate will suspend when record is a bit large >

[jira] [Updated] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30183: -- Description: A [user reported an issue|https://lists.apache.org/thread/yjv0hof5qqnzq22xcjf3y2

[jira] [Comment Edited] (FLINK-29906) Address tabs/spaces in checkstyle/spotless

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638209#comment-17638209 ] Chesnay Schepler edited comment on FLINK-29906 at 11/24/22 9:15 AM: --

[jira] [Created] (FLINK-30190) Update Cython from 0.29.24 to 0.29.32

2022-11-24 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30190: -- Summary: Update Cython from 0.29.24 to 0.29.32 Key: FLINK-30190 URL: https://issues.apache.org/jira/browse/FLINK-30190 Project: Flink Issue Type: Technic

[jira] [Created] (FLINK-30192) Update python-dateutil from 2.8.0 to 2.8.2

2022-11-24 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30192: -- Summary: Update python-dateutil from 2.8.0 to 2.8.2 Key: FLINK-30192 URL: https://issues.apache.org/jira/browse/FLINK-30192 Project: Flink Issue Type: Te

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-11-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638218#comment-17638218 ] Weijie Guo commented on FLINK-29419: Through further investigation, we found two pos

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

2022-11-24 Thread Lu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638219#comment-17638219 ] Lu commented on FLINK-30131: [~gaoyunhaii]  thanks for your apply. the pictures below show u

[jira] [Created] (FLINK-30191) Update py4j from 0.10.9.3 to 0.10.9.7

2022-11-24 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30191: -- Summary: Update py4j from 0.10.9.3 to 0.10.9.7 Key: FLINK-30191 URL: https://issues.apache.org/jira/browse/FLINK-30191 Project: Flink Issue Type: Technic

[GitHub] [flink] MartijnVisser opened a new pull request, #21386: [FLINK-30190][FLINK-30191][FLINK-30192][Python] Update cython, py4j and python-dateutil

2022-11-24 Thread GitBox
MartijnVisser opened a new pull request, #21386: URL: https://github.com/apache/flink/pull/21386 ## What is the purpose of the change * Update used dependencies to the latest patch version ## Brief change log * Created three separate commits for these updates to avoid ove

[jira] [Updated] (FLINK-30190) Update Cython from 0.29.24 to 0.29.32

2022-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30190: --- Labels: pull-request-available (was: ) > Update Cython from 0.29.24 to 0.29.32 > --

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #452: [FLINK-30187] Get operator log considering namespace

2022-11-24 Thread GitBox
gaborgsomogyi commented on PR #452: URL: https://github.com/apache/flink-kubernetes-operator/pull/452#issuecomment-1326175970 Seems like the fix works: https://github.com/apache/flink-kubernetes-operator/actions/runs/3539014809/jobs/5940447380#step:9:40 -- This is an automated message fr

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #452: [FLINK-30187] Get operator log considering namespace

2022-11-24 Thread GitBox
gaborgsomogyi commented on PR #452: URL: https://github.com/apache/flink-kubernetes-operator/pull/452#issuecomment-1326176132 cc @gyfora -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spec

[GitHub] [flink] flinkbot commented on pull request #21386: [FLINK-30190][FLINK-30191][FLINK-30192][Python] Update cython, py4j and python-dateutil

2022-11-24 Thread GitBox
flinkbot commented on PR #21386: URL: https://github.com/apache/flink/pull/21386#issuecomment-1326176722 ## CI report: * 65e9c3effca2796f68108d4a240b346b0162523b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #396: [FLINK-27846] Schema evolution for reading data file

2022-11-24 Thread GitBox
JingsongLi commented on code in PR #396: URL: https://github.com/apache/flink-table-store/pull/396#discussion_r1031267835 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaEvolutionUtil.java: ## @@ -62,4 +72,193 @@ public static int[] createI

[GitHub] [flink] XComp opened a new pull request, #21387: [FLINK-30183][metrics] Adds more descriptive error in case no default constructor is present.

2022-11-24 Thread GitBox
XComp opened a new pull request, #21387: URL: https://github.com/apache/flink/pull/21387 ## What is the purpose of the change There's already a log message stating that reflection-based reporter instantiation is deprecated. Instead, the user should use switch to the factory-based ins

[jira] [Updated] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

2022-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30183: --- Labels: pull-request-available starter (was: starter) > We should add a proper error messag

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #396: [FLINK-27846] Schema evolution for reading data file

2022-11-24 Thread GitBox
JingsongLi commented on code in PR #396: URL: https://github.com/apache/flink-table-store/pull/396#discussion_r1031291563 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/BulkFormatMapping.java: ## @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] flinkbot commented on pull request #21387: [FLINK-30183][metrics] Adds more descriptive error in case no default constructor is present.

2022-11-24 Thread GitBox
flinkbot commented on PR #21387: URL: https://github.com/apache/flink/pull/21387#issuecomment-1326195907 ## CI report: * 4e1f96318bbe9d60bc8eca15124f3db0b44cabe4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #396: [FLINK-27846] Schema evolution for reading data file

2022-11-24 Thread GitBox
JingsongLi commented on code in PR #396: URL: https://github.com/apache/flink-table-store/pull/396#discussion_r1031306773 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/BulkFormatMapping.java: ## @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache S

  1   2   3   >