[jira] [Commented] (FLINK-34451) [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach

2024-02-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818126#comment-17818126 ] Gyula Fora commented on FLINK-34451: Before we can investigate the root cause it wou

[jira] [Updated] (FLINK-34452) Release Testing: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots

2024-02-16 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-34452: - Description: Test Suggestion: # Prepare configuration options: ** taskmanager.numberOfTaskSlot

[jira] [Updated] (FLINK-34452) Release Testing: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots

2024-02-16 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-34452: - Description: Test Suggestion: # Prepare configuration options: ** h5. taskmanager.numberOfTa

[jira] [Updated] (FLINK-34452) Release Testing: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots

2024-02-16 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-34452: - Description: Test Suggestion: # Prepare configuration options: taskmanager.numberOfTaskSlots =

[jira] [Updated] (FLINK-34452) Release Testing: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots

2024-02-16 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-34452: - Description: Test Suggestion: # Prepare configuration options: ## h5. taskmanager.numberOfTas

[jira] [Created] (FLINK-34452) Release Testing: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots

2024-02-16 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-34452: Summary: Release Testing: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots Key: FLINK-34452 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-34451) [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach

2024-02-16 Thread Alex Hoffer (Jira)
Alex Hoffer created FLINK-34451: --- Summary: [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach Key: FLINK-34451 URL: https://issues.apache.org/jira/browse/FLINK-34451

Re: [PR] [FLINK-22765][test] Fixes test instability in ExceptionUtilsITCase#testIsMetaspaceOutOfMemoryError [flink]

2024-02-16 Thread via GitHub
snuyanzin commented on code in PR #24315: URL: https://github.com/apache/flink/pull/24315#discussion_r1493019218 ## flink-core/src/test/java/org/apache/flink/testutils/ClassLoaderUtils.java: ## @@ -158,7 +170,7 @@ public ClassLoaderBuilder withParentClassLoader(ClassLoader clas

Re: [PR] [FLINK-22765][test] Fixes test instability in ExceptionUtilsITCase#testIsMetaspaceOutOfMemoryError [flink]

2024-02-16 Thread via GitHub
snuyanzin commented on code in PR #24315: URL: https://github.com/apache/flink/pull/24315#discussion_r1493015749 ## flink-core/src/test/java/org/apache/flink/testutils/ClassLoaderUtils.java: ## @@ -55,7 +58,7 @@ private static URLClassLoader createClassLoader(File root, ClassLo

Re: [PR] [FLINK-22765][test] Fixes test instability in ExceptionUtilsITCase#testIsMetaspaceOutOfMemoryError [flink]

2024-02-16 Thread via GitHub
snuyanzin commented on PR #24315: URL: https://github.com/apache/flink/pull/24315#issuecomment-1949378599 I guess if we migrate from junit4 to junit5 then we don't need to depend on `TestLogger` which contains JUnit4 rules instead need to use `@ExtendWith(TestLoggerExtension.class)` Al

Re: [PR] [FLINK-22765][test] Fixes test instability in ExceptionUtilsITCase#testIsMetaspaceOutOfMemoryError [flink]

2024-02-16 Thread via GitHub
snuyanzin commented on code in PR #24315: URL: https://github.com/apache/flink/pull/24315#discussion_r1493005612 ## flink-core/src/test/java/org/apache/flink/testutils/ClassLoaderUtils.java: ## @@ -55,7 +58,7 @@ private static URLClassLoader createClassLoader(File root, ClassLo

Re: [PR] [FLINK-34045][ci] Refactors docs build scripts and adds CI for pushing docs changes [flink]

2024-02-16 Thread via GitHub
flinkbot commented on PR #24318: URL: https://github.com/apache/flink/pull/24318#issuecomment-1948975635 ## CI report: * a7bc9fde90bf632e76b5a64de3d83e26411db23f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34045) Add docs generation to workflow

2024-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34045: --- Labels: github-actions pull-request-available (was: github-actions) > Add docs generation t

[PR] [FLINK-34045][ci] Refactors docs build scripts and adds CI for pushing docs changes [flink]

2024-02-16 Thread via GitHub
XComp opened a new pull request, #24318: URL: https://github.com/apache/flink/pull/24318 ## What is the purpose of the change tba ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job creation time as a persistent artifact* - *

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
hanyuzheng7 commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492752435 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -391,6 +391,16 @@ ANY, and(logical(LogicalTy

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
hanyuzheng7 commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492749138 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to

Re: [PR] [FLINK-34438] Wait for Deployments to be deleted on cluster shutdown [flink-kubernetes-operator]

2024-02-16 Thread via GitHub
gyfora commented on code in PR #777: URL: https://github.com/apache/flink-kubernetes-operator/pull/777#discussion_r1492764973 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -898,58 +899,50 @@ public JobDe

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
hanyuzheng7 commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492749138 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
hanyuzheng7 commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492749138 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
hanyuzheng7 commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492752435 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -391,6 +391,16 @@ ANY, and(logical(LogicalTy

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
hanyuzheng7 commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492749138 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
hanyuzheng7 commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492749138 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

2024-02-16 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818042#comment-17818042 ] david radley commented on FLINK-21672: -- Thanks [~martijnvisser]  - It looks like th

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
hanyuzheng7 commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492717866 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

2024-02-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818008#comment-17818008 ] Martijn Visser commented on FLINK-21672: I've assigned the ticket to you [~david

[jira] [Assigned] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

2024-02-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-21672: -- Assignee: david radley (was: David Radley) > End to end tests (streaming) aren't Jav

[jira] [Assigned] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

2024-02-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-21672: -- Assignee: David Radley > End to end tests (streaming) aren't Java vendor neutral (sun

[jira] [Commented] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

2024-02-16 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817997#comment-17817997 ] david radley commented on FLINK-21672: -- I see   [https://forums.oracle.com/ords/ape

Re: [PR] [hotfix] Add IssueNavigationLink in Intellij VCS config [flink-connector-aws]

2024-02-16 Thread via GitHub
hlteoh37 merged PR #130: URL: https://github.com/apache/flink-connector-aws/pull/130 -- 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] [Assigned] (FLINK-34045) Add docs generation to workflow

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-34045: - Assignee: Matthias Pohl > Add docs generation to workflow > ---

Re: [PR] [hotfix] Exclude whole tools directory instead of tools/releasing/shared from source release [flink-connector-shared-utils]

2024-02-16 Thread via GitHub
echauchot merged PR #37: URL: https://github.com/apache/flink-connector-shared-utils/pull/37 -- 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-unsu

Re: [PR] [hotfix] Exclude whole tools directory instead of tools/releasing/shared from source release [flink-connector-shared-utils]

2024-02-16 Thread via GitHub
echauchot commented on PR #37: URL: https://github.com/apache/flink-connector-shared-utils/pull/37#issuecomment-1948373853 Self merging -- 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 specif

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

2024-02-16 Thread Emre Kartoglu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817947#comment-17817947 ] Emre Kartoglu commented on FLINK-16686: --- I saw this happen in a Flink 1.15 app tod

[jira] [Commented] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

2024-02-16 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817944#comment-17817944 ] david radley commented on FLINK-21672: -- I notice [https://github.com/AdoptOpenJDK/

[jira] [Updated] (FLINK-32261) Add MAP_UNION support in SQL & Table API

2024-02-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32261: --- Fix Version/s: (was: 1.19.0) > Add MAP_UNION support in SQL & Table API > --

Re: [PR] [FLINK-34014][jdbc] Avoid executeBatch when buffer is empty [flink-connector-jdbc]

2024-02-16 Thread via GitHub
affo commented on code in PR #100: URL: https://github.com/apache/flink-connector-jdbc/pull/100#discussion_r1492358810 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java: ## @@ -52,11 +52,13 @@ public void

Re: [PR] [FLINK-34366][table] Add support to group rows by column ordinals [flink]

2024-02-16 Thread via GitHub
affo commented on code in PR #24270: URL: https://github.com/apache/flink/pull/24270#discussion_r1492347207 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/agg/AggregateReduceGroupingTest.xml: ## @@ -765,13 +765,13 @@ HashAggre

[jira] [Closed] (FLINK-34395) Release Testing Instructions: Verify FLINK-32514 Support using larger checkpointing interval when source is processing backlog

2024-02-16 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34395. --- Resolution: Won't Fix [~yunfengzhou] Thanks for your confirming! > Release Testing Instructions: Ve

Re: [PR] [FLINK-34447][test] Hardens ActiveResourceManagerTest#testWorkerRegistrationTimeoutNotCountingAllocationTime [flink]

2024-02-16 Thread via GitHub
XComp commented on PR #24314: URL: https://github.com/apache/flink/pull/24314#issuecomment-1948246322 @xintongsong Do you remember what the actual purpose of this test was? Am I missing something or can we actually remove this test because it still can be unstable on slower machines. :think

Re: [PR] [FLINK-34274][runtime] Implicitly disable resource wait timeout for A… [flink]

2024-02-16 Thread via GitHub
XComp commented on PR #24238: URL: https://github.com/apache/flink/pull/24238#issuecomment-1948205439 Could we finalize this one? :thinking: -- 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 s

[jira] [Created] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed

2024-02-16 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34450: - Summary: TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed Key: FLINK-34450 URL: https://issues.apache.org/jira/browse/FLINK-34450 Project: Fl

[jira] [Commented] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory:

2024-02-16 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817916#comment-17817916 ] Stefan Richter commented on FLINK-33555: [~mapohl] I did some work related to lo

[jira] [Updated] (FLINK-34446) SqlValidatorException with LATERAL TABLE and JOIN

2024-02-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-34446: Component/s: Table SQL / Ecosystem > SqlValidatorException with LATERAL TABLE and JOIN > -

[jira] [Updated] (FLINK-34446) SqlValidatorException with LATERAL TABLE and JOIN

2024-02-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-34446: Component/s: Table SQL / Planner > SqlValidatorException with LATERAL TABLE and JOIN > ---

[jira] [Commented] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager

2024-02-16 Thread Dheeraj Panangat (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817914#comment-17817914 ] Dheeraj Panangat commented on FLINK-32212: -- Facing the same issue. I see that o

[jira] [Commented] (FLINK-34443) YARNFileReplicationITCase.testPerJobModeWithCustomizedFileReplication failed when deploying job cluster

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817912#comment-17817912 ] Matthias Pohl commented on FLINK-34443: --- No disk space issues reported here: * ht

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817911#comment-17817911 ] Matthias Pohl commented on FLINK-22765: --- JDK17: https://github.com/apache/flink/a

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817910#comment-17817910 ] Sergey Nuyanzin commented on FLINK-29114: - {quote} you mean switching back to fo

[jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817909#comment-17817909 ] Matthias Pohl commented on FLINK-34224: --- https://github.com/apache/flink/actions/r

[jira] [Updated] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34224: -- Affects Version/s: 1.18.1 > ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorage

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817907#comment-17817907 ] Matthias Pohl commented on FLINK-29114: --- It failed for the GHA nightly quite regul

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817906#comment-17817906 ] Matthias Pohl commented on FLINK-29114: --- Good point, you mean switching back to fo

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
dawidwys commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492239042 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to the

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
dawidwys commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492238096 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to the

Re: [PR] [FLINK-31663][table] Add-ARRAY_EXCEPT-function. [flink]

2024-02-16 Thread via GitHub
dawidwys commented on code in PR #23173: URL: https://github.com/apache/flink/pull/23173#discussion_r1492228180 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -391,6 +391,16 @@ ANY, and(logical(LogicalTypeR

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817893#comment-17817893 ] Sergey Nuyanzin commented on FLINK-29114: - That might be the reason of more ofte

[jira] [Closed] (FLINK-26948) Add SORT_ARRAY supported in SQL & Table API

2024-02-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26948. Fix Version/s: 1.20.0 Assignee: Hanyu Zheng (was: Jörn Kottmann) Resolutio

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-16 Thread via GitHub
dawidwys merged PR #22951: URL: https://github.com/apache/flink/pull/22951 -- 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.apac

[jira] [Commented] (FLINK-34038) IncrementalGroupAggregateRestoreTest.testRestore fails

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817889#comment-17817889 ] Matthias Pohl commented on FLINK-34038: --- [~dwysakowicz] can you add the commit mes

[jira] [Updated] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory:

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33555: -- Attachment: FLINK-33555.log > LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkin

[jira] [Commented] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory:

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817885#comment-17817885 ] Matthias Pohl commented on FLINK-33555: --- [~srichter] Did any of you work on local

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817882#comment-17817882 ] Matthias Pohl commented on FLINK-29114: --- I bumped the priority to Major for now. W

[jira] [Updated] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29114: -- Attachment: FLINK-29114.log > TableSourceITCase#testTableHintWithLogicalTableScanReuse sometim

[jira] [Updated] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29114: -- Priority: Major (was: Critical) > TableSourceITCase#testTableHintWithLogicalTableScanReuse so

[jira] [Updated] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29114: -- Priority: Critical (was: Minor) > TableSourceITCase#testTableHintWithLogicalTableScanReuse so

Re: [PR] [FLINK-34014][jdbc] Avoid executeBatch when buffer is empty [flink-connector-jdbc]

2024-02-16 Thread via GitHub
morazow commented on code in PR #100: URL: https://github.com/apache/flink-connector-jdbc/pull/100#discussion_r1492149217 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java: ## @@ -52,11 +52,13 @@ public v

[jira] [Updated] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34448: -- Attachment: FLINK-34448.head.log.gz > ChangelogLocalRecoveryITCase#testRestartTM failed fatall

[jira] [Commented] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817877#comment-17817877 ] Matthias Pohl commented on FLINK-34448: --- [~roman] [~Wencong Liu] Can one of you lo

[jira] [Commented] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817876#comment-17817876 ] Matthias Pohl commented on FLINK-34448: --- The test execution stops in the middle of

[jira] [Comment Edited] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817869#comment-17817869 ] Matthias Pohl edited comment on FLINK-34448 at 2/16/24 8:28 AM: --

[jira] [Commented] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817869#comment-17817869 ] Matthias Pohl commented on FLINK-34448: --- FYI: {{GroupCombineITCase}} was being exe

[jira] [Updated] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34448: -- Summary: ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code (was: C

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817864#comment-17817864 ] Matthias Pohl commented on FLINK-18476: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-34449) Flink build took too long

2024-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34449: -- Labels: test-stability (was: ) > Flink build took too long > - > >

[jira] [Created] (FLINK-34449) Flink build took too long

2024-02-16 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34449: - Summary: Flink build took too long Key: FLINK-34449 URL: https://issues.apache.org/jira/browse/FLINK-34449 Project: Flink Issue Type: Bug Compone