[jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

2024-02-09 Thread Sebastien Pereira (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815957#comment-17815957 ] Sebastien Pereira commented on FLINK-28693: --- We are facing similar issue in 1.

Re: [PR] [FLINK-34410][ci] Disables the nightly trigger workflow for forks [flink]

2024-02-09 Thread via GitHub
XComp merged PR #24291: URL: https://github.com/apache/flink/pull/24291 -- 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.

Re: [PR] [FLINK-34386][state] Add RocksDB bloom filter metrics [flink]

2024-02-09 Thread via GitHub
hejufang commented on PR #24274: URL: https://github.com/apache/flink/pull/24274#issuecomment-1935521846 @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] [Closed] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

2024-02-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34394. Resolution: Fixed > Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of >

[jira] [Commented] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

2024-02-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815962#comment-17815962 ] Timo Walther commented on FLINK-34394: -- Hi [~lincoln.86xy], this feature is rather

[jira] [Resolved] (FLINK-34410) Disable nightly trigger in forks

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34410. --- Fix Version/s: 1.20.0 Resolution: Fixed master: [d2abd744621c6f0f65e7154a2c1b53bcaf7

[jira] [Comment Edited] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

2024-02-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815962#comment-17815962 ] Timo Walther edited comment on FLINK-34394 at 2/9/24 8:36 AM:

[jira] [Commented] (FLINK-30275) TaskExecutorTest.testSharedResourcesLifecycle fails

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

[jira] [Comment Edited] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

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

[jira] [Commented] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

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

[jira] [Created] (FLINK-34418) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots fail

2024-02-09 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34418: - Summary: YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots failed due to disk space

[jira] [Commented] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

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

[jira] [Commented] (FLINK-34411) "Wordcount on Docker test (custom fs plugin)" timed out with some strange issue while setting the test up

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

[jira] [Comment Edited] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

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

[jira] [Commented] (FLINK-34411) "Wordcount on Docker test (custom fs plugin)" timed out with some strange issue while setting the test up

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815973#comment-17815973 ] Matthias Pohl commented on FLINK-34411: --- Thanks for looking into it, [~ferenc-csak

[jira] [Comment Edited] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

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

[jira] [Commented] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

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

[jira] [Commented] (FLINK-34273) git fetch fails

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

[jira] [Updated] (FLINK-34411) "Wordcount on Docker test (custom fs plugin)" timed out with some strange issue while setting the test up

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34411: -- Affects Version/s: (was: 1.20.0) > "Wordcount on Docker test (custom fs plugin)" timed out

Re: [PR] [FLINK-34267][CI] Update miniconda install script to fix build on MacOS [flink-connector-shared-utils]

2024-02-09 Thread via GitHub
gaborgsomogyi commented on PR #34: URL: https://github.com/apache/flink-connector-shared-utils/pull/34#issuecomment-1935633037 @pvary Thanks! Now I remember that the newest conda version would work when the connector would bump Flink version. Merging... -- This is an automated message fr

Re: [PR] [FLINK-34267][CI] Update miniconda install script to fix build on MacOS [flink-connector-shared-utils]

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

[jira] [Resolved] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

2024-02-09 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-34267. --- Resolution: Fixed [{{e6e1426}}|https://github.com/apache/flink-connector-shared-utils/commit

Re: [PR] [FLINK-34267][CI] Update miniconda install script to fix build on MacOS [flink-connector-shared-utils]

2024-02-09 Thread via GitHub
gaborgsomogyi commented on PR #34: URL: https://github.com/apache/flink-connector-shared-utils/pull/34#issuecomment-1935638003 Thanks for the fix! -- 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

[jira] [Assigned] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

2024-02-09 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-34267: - Assignee: Aleksandr Pilipenko > Python connector test fails when running on MacBook wit

[jira] [Closed] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

2024-02-09 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-34267. - > Python connector test fails when running on MacBook with m1 processor > --

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816007#comment-17816007 ] Matthias Pohl commented on FLINK-34282: --- The {{dev-1.19}} branch in [apache/flink

Re: [PR] [FLINK-34282][docker] Merge commit 44f05828 (pre-FLINK-34282 dev-master) into dev-1.19 [flink-docker]

2024-02-09 Thread via GitHub
XComp commented on PR #179: URL: https://github.com/apache/flink-docker/pull/179#issuecomment-1935691236 hm, handling the merge commit through GitHub seems to be not working as expected. I'm gonna close this PR and move the discussion into [FLINK-34282|https://issues.apache.org/jira/browse/

[jira] [Commented] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816011#comment-17816011 ] Matthias Pohl commented on FLINK-34403: --- [~dsaisharath] what's a heap size that wo

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816015#comment-17816015 ] Martijn Visser commented on FLINK-34282: [~mapohl] You mean force-pushing `dev-1

Re: [PR] feat: remove scala dependency [flink-connector-cassandra]

2024-02-09 Thread via GitHub
yuranye closed pull request #27: feat: remove scala dependency URL: https://github.com/apache/flink-connector-cassandra/pull/27 -- 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] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816016#comment-17816016 ] Matthias Pohl commented on FLINK-34282: --- correct, I will go ahead and do that then

Re: [PR] feat: remove scala dependency [flink-connector-cassandra]

2024-02-09 Thread via GitHub
boring-cyborg[bot] commented on PR #27: URL: https://github.com/apache/flink-connector-cassandra/pull/27#issuecomment-1935719123 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816018#comment-17816018 ] Jing Ge commented on FLINK-34282: - [~mapohl] please go ahead, thanks! > Create a releas

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-09 Thread via GitHub
mateczagany commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1484178999 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -106,7 +107,13 @@ public void scale(Context ctx) throws

[jira] [Created] (FLINK-34419) flink-docker's .github/workflows/snapshot.yml doesn't support JDK 17 and 21

2024-02-09 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34419: - Summary: flink-docker's .github/workflows/snapshot.yml doesn't support JDK 17 and 21 Key: FLINK-34419 URL: https://issues.apache.org/jira/browse/FLINK-34419 Project

[jira] [Updated] (FLINK-33163) Support Java 21 (LTS)

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33163: -- Fix Version/s: 1.19.0 > Support Java 21 (LTS) > - > > Key:

[jira] [Updated] (FLINK-34419) flink-docker's .github/workflows/snapshot.yml doesn't support JDK 17 and 21

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34419: -- Labels: starter (was: ) > flink-docker's .github/workflows/snapshot.yml doesn't support JDK 1

[PR] [FLINK-34282][docker] Updates snapshot workflow configuration [flink-docker]

2024-02-09 Thread via GitHub
XComp opened a new pull request, #180: URL: https://github.com/apache/flink-docker/pull/180 This way we are aligned with what's described in the [README.md](https://github.com/apache/flink-docker/blob/master/README.md#development-workflow) again. -- This is an automated message from the

[jira] [Updated] (FLINK-33163) Support Java 21 (LTS)

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33163: -- Fix Version/s: (was: 1.19.0) > Support Java 21 (LTS) > - > >

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816022#comment-17816022 ] Matthias Pohl commented on FLINK-34282: --- I rebased {{dev-1.19}} to {{dev-master~1}

Re: [PR] [FLINK-34282][docker] Merge commit 44f05828 (pre-FLINK-34282 dev-master) into dev-1.19 [flink-docker]

2024-02-09 Thread via GitHub
XComp commented on PR #179: URL: https://github.com/apache/flink-docker/pull/179#issuecomment-1935753499 This merge commit PR can be closed. I force-pushed a rebase to {{dev-master~1}} ([44f05828](https://github.com/apache/flink-docker/commit/44f058287cc956a620b12b6f8ed214e44dc3db77)) afte

Re: [PR] [FLINK-34282][docker] Merge commit 44f05828 (pre-FLINK-34282 dev-master) into dev-1.19 [flink-docker]

2024-02-09 Thread via GitHub
XComp closed pull request #179: [FLINK-34282][docker] Merge commit 44f05828 (pre-FLINK-34282 dev-master) into dev-1.19 URL: https://github.com/apache/flink-docker/pull/179 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] [FLINK-34282][docker] Updates snapshot workflow configuration [flink-docker]

2024-02-09 Thread via GitHub
JingGe commented on code in PR #180: URL: https://github.com/apache/flink-docker/pull/180#discussion_r1484202025 ## .github/workflows/snapshot.yml: ## @@ -38,14 +38,14 @@ jobs: matrix: java_version: [8, 11] build: - - flink_version: 1.19-SNAPSHO

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

2024-02-09 Thread via GitHub
dawidwys commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484177231 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to the A

Re: [PR] [HOTFIX][Doc] update readme to clarify that generate-stackbrew-library-docker.sh should be run on local machine directly. [flink-docker]

2024-02-09 Thread via GitHub
JingGe merged PR #163: URL: https://github.com/apache/flink-docker/pull/163 -- 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.apa

Re: [PR] [FLINK-34386][state] Add RocksDB bloom filter metrics [flink]

2024-02-09 Thread via GitHub
JingGe commented on PR #24274: URL: https://github.com/apache/flink/pull/24274#issuecomment-1935899938 There some issue while building the hadoop image: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=57409&view=logs&j=ef799394-2d67-5ff4-b2e5-410b80c9c0af&t=9e5768bc-da

Re: [PR] [hotfix] Bumps Flink snapshot version and related flink-shaded version [flink-benchmarks]

2024-02-09 Thread via GitHub
snuyanzin commented on code in PR #86: URL: https://github.com/apache/flink-benchmarks/pull/86#discussion_r1484312133 ## pom.xml: ## @@ -45,8 +45,8 @@ under the License. UTF-8 - 1.19-SNAPSHOT - 16.1 + 1.20-SNA

Re: [PR] [hotfix] Bumps Flink snapshot version and related flink-shaded version [flink-benchmarks]

2024-02-09 Thread via GitHub
snuyanzin commented on code in PR #86: URL: https://github.com/apache/flink-benchmarks/pull/86#discussion_r1484312133 ## pom.xml: ## @@ -45,8 +45,8 @@ under the License. UTF-8 - 1.19-SNAPSHOT - 16.1 + 1.20-SNA

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1935945569 Hi @JingGe , thank you for your advice, it is my first time participating in the Flink project. i have added 2 commits with your suggestion, Please review it when you have free time,

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1935949613 > Thanks @lxliyou001 for your contribution. I just left some comments. Hi @JingGe , thank you for your advice, it is my first time participating in the Flink project. i have added 2

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-02-09 Thread via GitHub
rkhachatryan commented on PR #24292: URL: https://github.com/apache/flink/pull/24292#issuecomment-1935958746 @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 comme

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1935962036 Hi @JingGe , thank you for your advice, it is my first time participating in the Flink project. i have added 2 commits with your suggestion, Please review it when you have free time, t

Re: [PR] [hotfix] Bumps Flink snapshot version and related flink-shaded version [flink-benchmarks]

2024-02-09 Thread via GitHub
XComp closed pull request #86: [hotfix] Bumps Flink snapshot version and related flink-shaded version URL: https://github.com/apache/flink-benchmarks/pull/86 -- 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 t

[jira] [Commented] (FLINK-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

2024-02-09 Thread Kumar Mallikarjuna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816077#comment-17816077 ] Kumar Mallikarjuna commented on FLINK-34239: Thank you, [~zjureel] ! > Intr

Re: [PR] Fix typo on schema_evolution.md [flink]

2024-02-09 Thread via GitHub
rafaelzimmermann closed pull request #22943: Fix typo on schema_evolution.md URL: https://github.com/apache/flink/pull/22943 -- 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

Re: [PR] [FLINK-34282][docker] Updates snapshot workflow configuration [flink-docker]

2024-02-09 Thread via GitHub
XComp commented on code in PR #180: URL: https://github.com/apache/flink-docker/pull/180#discussion_r1484401070 ## .github/workflows/snapshot.yml: ## @@ -38,14 +38,14 @@ jobs: matrix: java_version: [8, 11] build: - - flink_version: 1.19-SNAPSHOT

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

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

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

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

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

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

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484427940 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484430188 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484427940 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125

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

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

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484427940 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125

Re: [PR] [FLINK-34282][docker] Updates snapshot workflow configuration [flink-docker]

2024-02-09 Thread via GitHub
XComp commented on code in PR #180: URL: https://github.com/apache/flink-docker/pull/180#discussion_r1484449607 ## .github/workflows/snapshot.yml: ## @@ -38,14 +38,14 @@ jobs: matrix: java_version: [8, 11] build: - - flink_version: 1.19-SNAPSHOT

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

2024-02-09 Thread via GitHub
dawidwys commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484467843 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125 @@

Re: [PR] [FLINK-33958] Fix IntervalJoin restore test flakiness [flink]

2024-02-09 Thread via GitHub
bvarghese1 commented on PR #24196: URL: https://github.com/apache/flink/pull/24196#issuecomment-1936127479 > @bvarghese1 Could you please explain how does this improve the test reliability? Previously the input was: ``` Row.of(7, 3, "2020-04-15 08:00:16"), Row.of(

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

2024-02-09 Thread via GitHub
dawidwys commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484473796 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-21227) Upgrade Protobof 3.7.0 for (power)ppc64le support

2024-02-09 Thread Nathan Taylor Armstrong Lewis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816116#comment-17816116 ] Nathan Taylor Armstrong Lewis commented on FLINK-21227: --- Is there

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

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

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

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

[jira] [Commented] (FLINK-28747) "target_id can not be missing" in HTTP statefun request

2024-02-09 Thread Nathan Taylor Armstrong Lewis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816124#comment-17816124 ] Nathan Taylor Armstrong Lewis commented on FLINK-28747: --- In Protob

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

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

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484524404 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484526273 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484526273 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484532093 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484532480 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484533063 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

Re: [PR] [FLINK-33936][table] Outputting Identical Results in Mini-Batch Aggregation with Set TTL [flink]

2024-02-09 Thread via GitHub
hackergin commented on PR #24290: URL: https://github.com/apache/flink/pull/24290#issuecomment-1936224206 @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.

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-02-09 Thread via GitHub
rkhachatryan commented on PR #24292: URL: https://github.com/apache/flink/pull/24292#issuecomment-1936234814 @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 comme

Re: [PR] [FLINK-28693][table] Fix janino compile failed because the code generated refers the class in table-planner [flink]

2024-02-09 Thread via GitHub
seb-pereira commented on PR #24280: URL: https://github.com/apache/flink/pull/24280#issuecomment-1936306609 I have tested this change on 1.18.0 in same conditions as reported in [FLINK-28693](https://issues.apache.org/jira/browse/FLINK-28693?focusedCommentId=17815957&page=com.atlassian.jira.

Re: [PR] [FLINK-33402] 2 CONTINUED [flink]

2024-02-09 Thread via GitHub
varun1729DD commented on PR #24055: URL: https://github.com/apache/flink/pull/24055#issuecomment-1936474945 @tweise requesting your review on this. I added additional details above ^ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-02-09 Thread via GitHub
rkhachatryan commented on PR #24292: URL: https://github.com/apache/flink/pull/24292#issuecomment-1936575490 @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 comme

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2024-02-09 Thread via GitHub
mtfelisb commented on code in PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1484848274 ## flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriterITCase.java: ## @@ -0,0 +1,27

[PR] [FLINK-34407][Connectors/Kinesis] Fix unstable test [flink-connector-aws]

2024-02-09 Thread via GitHub
z3d1k opened a new pull request, #128: URL: https://github.com/apache/flink-connector-aws/pull/128 ## Purpose of the change Tests that use `FakeKinesisFanOutBehavioursFactory` occasionally run into issue while creating mock for Kinesis shard subscription: ``` java.lang.ClassCast

[jira] [Updated] (FLINK-34407) Flaky tests causing workflow timeout

2024-02-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34407: --- Labels: pull-request-available (was: ) > Flaky tests causing workflow timeout > ---

[jira] [Commented] (FLINK-34129) MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired

2024-02-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816250#comment-17816250 ] Jeyhun Karimov commented on FLINK-34129: Hi [~loserwang1024], [~xuyangzhong] I

[jira] [Commented] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816252#comment-17816252 ] Jeyhun Karimov commented on FLINK-34378: Hi [~xuyangzhong] the ordering is diffe

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1936765976 @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

Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]

2024-02-09 Thread via GitHub
AlanConfluent commented on code in PR #24224: URL: https://github.com/apache/flink/pull/24224#discussion_r1484927246 ## docs/content/docs/dev/table/functions/udfs.md: ## @@ -846,6 +847,119 @@ If you intend to implement or call functions in Python, please refer to the [Pyt {{

Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]

2024-02-09 Thread via GitHub
AlanConfluent commented on PR #24224: URL: https://github.com/apache/flink/pull/24224#issuecomment-1936807100 @MartijnVisser I updated the documentation. Please tell me if anything else is required to make the deadline. -- This is an automated message from the Apache Git Service. To resp

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

2024-02-09 Thread via GitHub
hanyuzheng7 commented on PR #22951: URL: https://github.com/apache/flink/pull/22951#issuecomment-1936835154 @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 commen

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1936858432 @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

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1936908761 @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