[jira] [Updated] (FLINK-29914) KafkaTableITCase.testKafkaSourceSink fails

2022-11-24 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-29914: -- Release Note: (was: Please re-open it if the issue comes again.) Please re-open it if the

[jira] [Commented] (FLINK-29914) KafkaTableITCase.testKafkaSourceSink fails

2022-11-24 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638550#comment-17638550 ] Gabor Somogyi commented on FLINK-29914: --- Moved to comment section, where it belongs. Thanks for

[jira] [Commented] (FLINK-29914) KafkaTableITCase.testKafkaSourceSink fails

2022-11-24 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638548#comment-17638548 ] Gabor Somogyi commented on FLINK-29914: --- Oh gosh, I've put it into the wrong place :/ >

[jira] [Closed] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

2022-11-24 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30126. -- Resolution: Later [~melin] [~hackergin] Please open a discussion thread on the Dev mailing

[GitHub] [flink] Zakelly commented on a diff in pull request #21362: [FLINK-29430] Add sanity check when setCurrentKeyGroupIndex

2022-11-24 Thread GitBox
Zakelly commented on code in PR #21362: URL: https://github.com/apache/flink/pull/21362#discussion_r1032087008 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperatorTest.java: ## @@ -556,9 +559,27 @@ public void

[jira] [Resolved] (FLINK-28185) "Invalid negative offset" when using OffsetsInitializer.timestamp(.)

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

[GitHub] [flink] MartijnVisser merged pull request #20370: [FLINK-28185][Connector/Kafka] handle missing timestamps when there are empty partitions for the TimestampOffsetsInitializer

2022-11-24 Thread GitBox
MartijnVisser merged PR #20370: URL: https://github.com/apache/flink/pull/20370 -- 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:

[jira] [Commented] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638535#comment-17638535 ] Matthias Pohl commented on FLINK-25813: --- [~TsReaper] any update on this issue? The PR seems to

[jira] [Commented] (FLINK-29835) NoClassDefFoundError in PulsarSourceUnorderedE2ECase

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638533#comment-17638533 ] Matthias Pohl commented on FLINK-29835: --- [~syhily] could you have a look at it? >

[GitHub] [flink] XComp commented on pull request #21365: [FLINK-29427] Fix unstable test LookupJoinITCase by compiling Projection class in advance using userCodeClassLoader

2022-11-24 Thread GitBox
XComp commented on PR #21365: URL: https://github.com/apache/flink/pull/21365#issuecomment-1327092141 hm, I tried to reproduce the issue using AzureCI in [SmirAlex/PR #1](https://github.com/SmirAlex/flink/pull/1) but failed. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] MartijnVisser commented on pull request #21390: [FLINK-30197][Logging] Update slf4j from 1.7.32 to 1.7.36

2022-11-24 Thread GitBox
MartijnVisser commented on PR #21390: URL: https://github.com/apache/flink/pull/21390#issuecomment-1327090324 @flinkbot run azure -- 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

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #182: [FLINK-30160] Add Transformer for FValueTest

2022-11-24 Thread GitBox
yunfengzhou-hub commented on code in PR #182: URL: https://github.com/apache/flink-ml/pull/182#discussion_r1031974363 ## flink-ml-lib/src/main/java/org/apache/flink/ml/stats/fvaluetest/FValueTest.java: ## @@ -0,0 +1,370 @@ +/* Review Comment: Let's add this class to the

[jira] [Comment Edited] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638492#comment-17638492 ] Matthias Pohl edited comment on FLINK-29405 at 11/25/22 4:45 AM: -

[jira] [Created] (FLINK-30202) DataGeneratorSourceITCase.testGatedRateLimiter failed

2022-11-24 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30202: - Summary: DataGeneratorSourceITCase.testGatedRateLimiter failed Key: FLINK-30202 URL: https://issues.apache.org/jira/browse/FLINK-30202 Project: Flink

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638492#comment-17638492 ] Matthias Pohl commented on FLINK-29405: ---

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638491#comment-17638491 ] Matthias Pohl commented on FLINK-29461: ---

[jira] [Commented] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638490#comment-17638490 ] Matthias Pohl commented on FLINK-28898: --- [~masteryhx] may you have another look? >

[jira] [Commented] (FLINK-29835) NoClassDefFoundError in PulsarSourceUnorderedE2ECase

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638489#comment-17638489 ] Matthias Pohl commented on FLINK-29835: ---

[GitHub] [flink] flinkbot commented on pull request #21397: [BP-1.15][FLINK-29899][runtime][test] Removes obsolete printStackTrace()

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

[GitHub] [flink] flinkbot commented on pull request #21396: [BP-1.16][FLINK-29899][runtime][test] Removes obsolete printStackTrace()

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

[jira] [Assigned] (FLINK-29899) Stacktrace printing in DefaultExecutionGraphCacheTest is confusing maven test log output

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-29899: - Assignee: Matthias Pohl > Stacktrace printing in DefaultExecutionGraphCacheTest is

[GitHub] [flink] flinkbot commented on pull request #21395: [FLINK-29899][runtime][test] Removes obsolete printStackTrace()

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

[GitHub] [flink] XComp opened a new pull request, #21397: [FLINK-29899][runtime][test] Removes obsolete printStackTrace()

2022-11-24 Thread GitBox
XComp opened a new pull request, #21397: URL: https://github.com/apache/flink/pull/21397 1.15 backport PR for parent PR https://github.com/apache/flink/pull/21395 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] XComp opened a new pull request, #21396: [FLINK-29899][runtime][test] Removes obsolete printStackTrace()

2022-11-24 Thread GitBox
XComp opened a new pull request, #21396: URL: https://github.com/apache/flink/pull/21396 1.16 backport PR for parent PR #21395 -- 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

[jira] [Updated] (FLINK-29899) Stacktrace printing in DefaultExecutionGraphCacheTest is confusing maven test log output

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

[GitHub] [flink] XComp opened a new pull request, #21395: [FLINK-29899][runtime][test] Removes obsolete printStackTrace()

2022-11-24 Thread GitBox
XComp opened a new pull request, #21395: URL: https://github.com/apache/flink/pull/21395 ## What is the purpose of the change The stacktrace printout must have been accidentally added with PR #14804. It ends up in the regular CI Maven log output for the tests and confuses developers

[jira] [Updated] (FLINK-29899) Stacktrace printing in DefaultExecutionGraphCacheTest is confusing maven test log output

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29899: -- Summary: Stacktrace printing in DefaultExecutionGraphCacheTest is confusing maven test log

[jira] [Updated] (FLINK-29899) Stacktrace printing in

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29899: -- Summary: Stacktrace printing in (was: flink-runtime tests fail with exit code 137 returned

[jira] [Updated] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29899: -- Priority: Minor (was: Critical) > flink-runtime tests fail with exit code 137 returned from

[jira] [Updated] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29899: -- Affects Version/s: 1.15.3 > flink-runtime tests fail with exit code 137 returned from Docker

[jira] [Commented] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638485#comment-17638485 ] Matthias Pohl commented on FLINK-29899: --- You are right, [~zhuzh] . The error presented in the

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-24 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1031990672 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer/MongoJsonDeserializationSchema.java: ## @@ -0,0

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-24 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1031990672 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer/MongoJsonDeserializationSchema.java: ## @@ -0,0

[jira] [Commented] (FLINK-26082) CancelPartitionRequestTest.testDuplicateCancel failed on azure due to bind failed

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638480#comment-17638480 ] Matthias Pohl commented on FLINK-26082: ---

[jira] [Updated] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28766: -- Affects Version/s: 1.17.0 > UnalignedCheckpointStressITCase.runStressTest failed with

[jira] [Commented] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638479#comment-17638479 ] Matthias Pohl commented on FLINK-28766: --- [~akalashnikov] any updates on that issue. FYI: We're

[jira] [Commented] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638478#comment-17638478 ] Matthias Pohl commented on FLINK-28766: ---

[jira] [Updated] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28898: -- Fix Version/s: (was: 1.17.0) >

[jira] [Updated] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28898: -- Fix Version/s: 1.17.0 (was: 1.16.0) >

[jira] [Updated] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28898: -- Fix Version/s: 1.16.0 (was: 1.17.0) >

[jira] [Updated] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28898: -- Affects Version/s: 1.17.0 >

[jira] [Commented] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638476#comment-17638476 ] Matthias Pohl commented on FLINK-28898: ---

[jira] [Commented] (FLINK-29914) KafkaTableITCase.testKafkaSourceSink fails

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638475#comment-17638475 ] Matthias Pohl commented on FLINK-29914: --- [~gaborgsomogyi] what's the intention behind the release

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

2022-11-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-30188: -- Assignee: Weijie Guo > Partition finished state in ConsumedPartitionGroup is not updated

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

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

[GitHub] [flink] XComp commented on pull request #21394: [BP-1.15][FLINK-26037][coordination] TMRunner waits for metric registry shutdown

2022-11-24 Thread GitBox
XComp commented on PR #21394: URL: https://github.com/apache/flink/pull/21394#issuecomment-1326973692 force push was accidental with no actual change. -- 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

[jira] [Resolved] (FLINK-30133) HadoopModuleFactory creates error if the security module cannot be loaded

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30133. --- Fix Version/s: 1.17.0 1.16.1 1.15.4 Assignee:

[GitHub] [flink] XComp merged pull request #21384: [BP-1.15][FLINK-30133][hadoop] Changes log level and make log message more descriptive.

2022-11-24 Thread GitBox
XComp merged PR #21384: URL: https://github.com/apache/flink/pull/21384 -- 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:

[GitHub] [flink] XComp merged pull request #21383: [BP-1.16][FLINK-30133][hadoop] Changes log level and make log message more descriptive.

2022-11-24 Thread GitBox
XComp merged PR #21383: URL: https://github.com/apache/flink/pull/21383 -- 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:

[GitHub] [flink] XComp merged pull request #21382: [FLINK-30133][hadoop] Changes log level and make log message more descriptive.

2022-11-24 Thread GitBox
XComp merged PR #21382: URL: https://github.com/apache/flink/pull/21382 -- 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:

[GitHub] [flink] XComp commented on pull request #21382: [FLINK-30133][hadoop] Changes log level and make log message more descriptive.

2022-11-24 Thread GitBox
XComp commented on PR #21382: URL: https://github.com/apache/flink/pull/21382#issuecomment-1326969587 Error is unrelated to this change. I'm gonna go ahead and merge. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] XComp commented on pull request #21394: [FLINK-26037][coordination] TMRunner waits for metric registry shutdown

2022-11-24 Thread GitBox
XComp commented on PR #21394: URL: https://github.com/apache/flink/pull/21394#issuecomment-1326964142 Considering that `MetricRegistryImpl#shutdown` was already implemented in an asynchronous manner before FLINK-29488 was merged, I tend to believe that it might not be the cause of

[GitHub] [flink] flinkbot commented on pull request #21394: [FLINK-26037][coordination] TMRunner waits for metric registry shutdown

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

[GitHub] [flink] XComp opened a new pull request, #21394: [FLINK-26037][coordination] TMRunner waits for metric registry shutdown

2022-11-24 Thread GitBox
XComp opened a new pull request, #21394: URL: https://github.com/apache/flink/pull/21394 1.15 backport PR of PR #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.

[jira] [Created] (FLINK-30201) Function "unnest" can't process nesting JSON properly

2022-11-24 Thread zhangyue (Jira)
zhangyue created FLINK-30201: Summary: Function "unnest" can't process nesting JSON properly Key: FLINK-30201 URL: https://issues.apache.org/jira/browse/FLINK-30201 Project: Flink Issue Type:

[GitHub] [flink] fsk119 commented on a diff in pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

2022-11-24 Thread GitBox
fsk119 commented on code in PR #17830: URL: https://github.com/apache/flink/pull/17830#discussion_r1017909829 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/PromptHandler.java: ## @@ -0,0 +1,188 @@ +/* + * Licensed to the Apache Software

[jira] [Assigned] (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 reassigned FLINK-30183: - Assignee: Matthias Pohl > We should add a proper error message in case the deprecated

[GitHub] [flink] XComp commented on pull request #21382: [FLINK-30133][hadoop] Changes log level and make log message more descriptive.

2022-11-24 Thread GitBox
XComp commented on PR #21382: URL: https://github.com/apache/flink/pull/21382#issuecomment-1326944050 @flinkbot run azure -- 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.

[jira] [Assigned] (FLINK-30179) Stop stringifying exception for logging

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-30179: - Assignee: Mingliang Liu > Stop stringifying exception for logging >

[jira] [Resolved] (FLINK-30179) Stop stringifying exception for logging

2022-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30179. --- Fix Version/s: 1.17.0 Resolution: Fixed master:

[GitHub] [flink] XComp merged pull request #21379: [FLINK-30179][runtime] Stop stringifying exception for logging

2022-11-24 Thread GitBox
XComp merged PR #21379: URL: https://github.com/apache/flink/pull/21379 -- 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:

[jira] [Comment Edited] (FLINK-29982) Move cassandra connector to dedicated repo

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638448#comment-17638448 ] Chesnay Schepler edited comment on FLINK-29982 at 11/25/22 1:32 AM:

[jira] [Closed] (FLINK-29982) Move cassandra connector to dedicated repo

2022-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29982. Fix Version/s: cassandra-3.0.0 Resolution: Fixed cassandra-main:

[GitHub] [flink-connector-cassandra] zentol merged pull request #2: [FLINK-29982] move the existing Cassandra connector to external repository

2022-11-24 Thread GitBox
zentol merged PR #2: URL: https://github.com/apache/flink-connector-cassandra/pull/2 -- 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:

[jira] [Commented] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

2022-11-24 Thread melin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638440#comment-17638440 ] melin commented on FLINK-30126: --- Spark also does not support dynamic catalog, which is created through aop

[jira] [Updated] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

2022-11-24 Thread melin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-30126: -- Attachment: image-2022-11-25-09-12-59-477.png > Delay registration of the catalog, register the catalog as

[GitHub] [flink-connector-cassandra] zentol commented on pull request #2: [FLINK-29982] move the existing Cassandra connector to external repository

2022-11-24 Thread GitBox
zentol commented on PR #2: URL: https://github.com/apache/flink-connector-cassandra/pull/2#issuecomment-1326927799 Couldn't sleep so I just started fixing things myself. Squashed all your changes into a single commit. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-connector-cassandra] zentol commented on a diff in pull request #2: [FLINK-29982] move the existing Cassandra connector to external repository

2022-11-24 Thread GitBox
zentol commented on code in PR #2: URL: https://github.com/apache/flink-connector-cassandra/pull/2#discussion_r1031927029 ## flink-connector-cassandra/pom.xml: ## @@ -0,0 +1,367 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Comment Edited] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638418#comment-17638418 ] Mason Chen edited comment on FLINK-29856 at 11/24/22 9:15 PM: --

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

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638418#comment-17638418 ] Mason Chen commented on FLINK-29856: {quote}Without notifyCheckpointComplete, it isn't clear what

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

2022-11-24 Thread GitBox
MartijnVisser commented on PR #21386: URL: https://github.com/apache/flink/pull/21386#issuecomment-1326840384 @flinkbot run azure -- 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

[GitHub] [flink] snuyanzin commented on pull request #17867: [FLINK-24592][Table SQL/Client] FlinkSQL Client multiline parser improvements

2022-11-24 Thread GitBox
snuyanzin commented on PR #17867: URL: https://github.com/apache/flink/pull/17867#issuecomment-1326828268 @fsk119 , @twalthr could you please have a look once you have time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

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

2022-11-24 Thread GitBox
mas-chen commented on PR #20370: URL: https://github.com/apache/flink/pull/20370#issuecomment-1326818969 @PatrickRen Thanks! Regarding your earlier comment about the Public API change originally in this PR, I have filed https://issues.apache.org/jira/browse/FLINK-30200 and will followup

[jira] [Updated] (FLINK-30200) TimestampOffsetsInitializer allows configurable OffsetResetStrategy

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-30200: --- Description: Currently, the TimestampOffsetsInitializer defaults to `LATEST` and it would be

[jira] [Created] (FLINK-30200) TimestampOffsetsInitializer allows configurable OffsetResetStrategy

2022-11-24 Thread Mason Chen (Jira)
Mason Chen created FLINK-30200: -- Summary: TimestampOffsetsInitializer allows configurable OffsetResetStrategy Key: FLINK-30200 URL: https://issues.apache.org/jira/browse/FLINK-30200 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #21393: [Draft][FLINK-27246_master] - Split generated java methods - Work in progress

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

[GitHub] [flink] kristoffSC opened a new pull request, #21393: [Draft][FLINK-27246_master] - Split generated java methods - Work in progress

2022-11-24 Thread GitBox
kristoffSC opened a new pull request, #21393: URL: https://github.com/apache/flink/pull/21393 Signed-off-by: Krzysztof Chmielewski ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than

[GitHub] [flink] gaborgsomogyi commented on pull request #21392: DO_NOT_MERGE FLINK-29710 testing

2022-11-24 Thread GitBox
gaborgsomogyi commented on PR #21392: URL: https://github.com/apache/flink/pull/21392#issuecomment-1326804633 In general executing these tests locally are just horror: * The directories are not the same just like in maven (`target`, `../target`, `target/test/data`), it's hell *

[GitHub] [flink] gaborgsomogyi commented on pull request #21392: DO_NOT_MERGE FLINK-29710 testing

2022-11-24 Thread GitBox
gaborgsomogyi commented on PR #21392: URL: https://github.com/apache/flink/pull/21392#issuecomment-1326803109 What I've seen is basically timeout which may or may not solve the increase at the 3 places. I have the feeling that prohibited string is blown up: * Either because of

[GitHub] [flink] flinkbot commented on pull request #21392: DO_NOT_MERGE FLINK-29710 testing

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

[jira] [Comment Edited] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638394#comment-17638394 ] Mason Chen edited comment on FLINK-29856 at 11/24/22 6:45 PM: -- [~masteryhx]

[jira] [Comment Edited] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638394#comment-17638394 ] Mason Chen edited comment on FLINK-29856 at 11/24/22 6:44 PM: -- [~masteryhx]

[jira] [Created] (FLINK-30199) Add a script to run Kubernetes Operator e2e tests manually

2022-11-24 Thread Peter Vary (Jira)
Peter Vary created FLINK-30199: -- Summary: Add a script to run Kubernetes Operator e2e tests manually Key: FLINK-30199 URL: https://issues.apache.org/jira/browse/FLINK-30199 Project: Flink Issue

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

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638394#comment-17638394 ] Mason Chen commented on FLINK-29856: [~masteryhx] [~mxm] [~gaoyunhaii] I double checked that

[jira] [Updated] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-29856: --- Description: When I trigger a savepoint with the Flink K8s operator, I verified for two sources

[jira] [Updated] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-29856: --- Description: When I trigger a savepoint with the Flink K8s operator, I verified for two sources

[jira] [Updated] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-29856: --- Summary: Triggering savepoint does not trigger operator notifyCheckpointComplete (was: Triggering

[jira] [Commented] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

2022-11-24 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638382#comment-17638382 ] Feng Jin commented on FLINK-30126: -- We are currently facing a similar problem. Our current solution: In

[GitHub] [flink-connector-aws] hlteoh37 opened a new pull request, #29: [FLINK-29895] Further increase unit test coverage for DynamoDbSink

2022-11-24 Thread GitBox
hlteoh37 opened a new pull request, #29: URL: https://github.com/apache/flink-connector-aws/pull/29 ## What is the purpose of the change - Further increased test coverage for DynamoDbSink - Refactor DynamoDbSinkWriter to provide the client via constructor so that we can test logic in

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-24 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1031737091 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoKeyExtractor.java: ## @@ -0,0 +1,148 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-30134) Annotate all the public classes for the delegation token framework

2022-11-24 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-30134: -- Fix Version/s: 1.17.0 > Annotate all the public classes for the delegation token framework >

[jira] [Closed] (FLINK-30134) Annotate all the public classes for the delegation token framework

2022-11-24 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-30134. - > Annotate all the public classes for the delegation token framework >

[jira] [Resolved] (FLINK-30134) Annotate all the public classes for the delegation token framework

2022-11-24 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-30134. --- Resolution: Fixed master: a698232947ed778790d08bcb1fd00d2b77c2eddd > Annotate all the

[GitHub] [flink] zentol commented on pull request #21344: [FLINK-30083] Bump maven-shade-plugin version

2022-11-24 Thread GitBox
zentol commented on PR #21344: URL: https://github.com/apache/flink/pull/21344#issuecomment-1326708204 The rat plugin already has an exclusion for `**/target/**` though. Changing it to `target/**` had no effect, but explicitly listing `**/rat.txt` did. Still, I'd like to know what is

[GitHub] [flink] jnh5y commented on pull request #21344: [FLINK-30083] Bump maven-shade-plugin version

2022-11-24 Thread GitBox
jnh5y commented on PR #21344: URL: https://github.com/apache/flink/pull/21344#issuecomment-1326704652 > This seems to happen with every version since 3.3.0. > > For some reason the files in the root target directory are now included by the rat plugin. (-X shows the included/excluded

[GitHub] [flink] zentol commented on pull request #21344: [FLINK-30083] Bump maven-shade-plugin version

2022-11-24 Thread GitBox
zentol commented on PR #21344: URL: https://github.com/apache/flink/pull/21344#issuecomment-1326700020 This seems to happen with every version since 3.3.0. For some reason the files in the root target directory are now included by the rat plugin. (-X shows the included/excluded

[GitHub] [flink] jnh5y commented on a diff in pull request #20958: [FLINK-29486][sql-client] Add a new RemoteExecutor to send and retrieve messages form remote SQL gateway through rest endpoint

2022-11-24 Thread GitBox
jnh5y commented on code in PR #20958: URL: https://github.com/apache/flink/pull/20958#discussion_r1031725624 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/remote/RemoteExecutor.java: ## @@ -0,0 +1,423 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rmetzger commented on pull request #21344: [FLINK-30083] Bump maven-shade-plugin version

2022-11-24 Thread GitBox
rmetzger commented on PR #21344: URL: https://github.com/apache/flink/pull/21344#issuecomment-1326693114 I’m also confused. Updating rat doesn’t help. On Thu 24. Nov 2022 at 18:01 Chesnay Schepler ***@***.***> wrote: > Wow this even happens locally. mvn clean verify -N >

[GitHub] [flink] zentol commented on pull request #21344: [FLINK-30083] Bump maven-shade-plugin version

2022-11-24 Thread GitBox
zentol commented on PR #21344: URL: https://github.com/apache/flink/pull/21344#issuecomment-1326686909 Wow this even happens locally. `mvn clean verify -N` -- 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

[GitHub] [flink] zentol commented on pull request #21344: [FLINK-30083] Bump maven-shade-plugin version

2022-11-24 Thread GitBox
zentol commented on PR #21344: URL: https://github.com/apache/flink/pull/21344#issuecomment-1326683572 What the... ``` 3 Unknown Licenses * Files with unapproved licenses:

  1   2   3   >