[jira] [Created] (FLINK-33034) Incorrect StateBackendTestBase#testGetKeysAndNamespaces

2023-09-04 Thread Dmitriy Linevich (Jira)
Dmitriy Linevich created FLINK-33034: Summary: Incorrect StateBackendTestBase#testGetKeysAndNamespaces Key: FLINK-33034 URL: https://issues.apache.org/jira/browse/FLINK-33034 Project: Flink

[GitHub] [flink] Taher-Ghaleb commented on pull request #23264: Refactor @Test(expected) with assertThrows

2023-09-04 Thread via GitHub
Taher-Ghaleb commented on PR #23264: URL: https://github.com/apache/flink/pull/23264#issuecomment-1705986579 Thanks @X-czh for your response. The purpose of this pull request was to get insights about why such cases as exception handling still exist in codebases though there exist better

[GitHub] [flink-kubernetes-operator] HuangZhenQiu opened a new pull request, #663: [FLINK-32777] add config for opt out okhttp hostname verification

2023-09-04 Thread via GitHub
HuangZhenQiu opened a new pull request, #663: URL: https://github.com/apache/flink-kubernetes-operator/pull/663 ## What is the purpose of the change Currently, Flink operator can't run in IPV6 environment due to a OKhttp host name verification bug. To mitigate the issue reported by

[jira] [Commented] (FLINK-32872) Add option to control the default partitioner when the parallelism of upstream and downstream operator does not match

2023-09-04 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761944#comment-17761944 ] Zhanghao Chen commented on FLINK-32872: --- [~huweihua] Looking forward to your suggestions on this

[jira] [Commented] (FLINK-32848) [JUnit5 Migration] The persistence, query, registration, rpc and shuffle packages of flink-runtime module

2023-09-04 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761941#comment-17761941 ] Zhanghao Chen commented on FLINK-32848: --- Hi [~fanrui], if you have time, could you help check the

[GitHub] [flink] X-czh commented on pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

2023-09-04 Thread via GitHub
X-czh commented on PR #20232: URL: https://github.com/apache/flink/pull/20232#issuecomment-1705930989 @huwh @1996fanrui I've updated the PR with two new commits that aligns the behavior of pretty printing taskmanager locations and updates the Web UI accordingly. Please help review again

[GitHub] [flink] wangzzu commented on pull request #23243: [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

2023-09-04 Thread via GitHub
wangzzu commented on PR #23243: URL: https://github.com/apache/flink/pull/23243#issuecomment-1705908682 @Jiabao-Sun thanks, i have fixed these -- 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

[jira] [Resolved] (FLINK-32810) Improve managed memory usage in ListStateWithCache

2023-09-04 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-32810. --- Fix Version/s: ml-2.4.0 Assignee: Fan Hong Resolution: Fixed > Improve

[jira] [Commented] (FLINK-33014) flink jobmanager raise java.io.IOException: Connection reset by peer

2023-09-04 Thread zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761930#comment-17761930 ] zhu commented on FLINK-33014: - [~mapohl]  [~wangyang0918] Is there any progress now? No operators can be

[jira] [Created] (FLINK-33033) Add haservice micro benchmark for olap

2023-09-04 Thread Fang Yong (Jira)
Fang Yong created FLINK-33033: - Summary: Add haservice micro benchmark for olap Key: FLINK-33033 URL: https://issues.apache.org/jira/browse/FLINK-33033 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-25356) Add benchmarks for performance in OLAP scenarios

2023-09-04 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-25356: -- Parent: (was: FLINK-25318) Issue Type: Technical Debt (was: Sub-task) > Add benchmarks

[jira] [Updated] (FLINK-30774) Introduce flink-utils module

2023-09-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30774: --- Labels: stale-major starter (was: starter) I am the [Flink Jira

[jira] [Updated] (FLINK-32454) deserializeStreamStateHandle of checkpoint read byte

2023-09-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32454: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-28372) Investigate Akka Artery

2023-09-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28372: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-31070) Update jline to 3.22.0

2023-09-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31070: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-32262) Add MAP_ENTRIES support in SQL & Table API

2023-09-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32262: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[GitHub] [flink] MartijnVisser commented on pull request #23352: [FLINK-28513][Backport][release-1.18] Fix Flink Table API CSV streaming sink throws

2023-09-04 Thread via GitHub
MartijnVisser commented on PR #23352: URL: https://github.com/apache/flink/pull/23352#issuecomment-1705607330 > Do you think we want to backport this to Flink 1.18? Given this is a critical bug Yes, we can safely backport bugfixes, as long as they don't break any (API)

[jira] [Created] (FLINK-33032) [JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

2023-09-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-33032: -- Summary: [JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase) Key: FLINK-33032 URL: https://issues.apache.org/jira/browse/FLINK-33032 Project: Flink

[GitHub] [flink] Jiabao-Sun commented on pull request #23349: [FLINK-33023][table-planner][JUnit5 Migration] Module: flink-table-planner (TableTestBase)

2023-09-04 Thread via GitHub
Jiabao-Sun commented on PR #23349: URL: https://github.com/apache/flink/pull/23349#issuecomment-1705496284 Hi @leonardBang. Would you mind to help review this PR when you have time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot commented on pull request #23354: [FLINK-33031][table-planner][JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase)

2023-09-04 Thread via GitHub
flinkbot commented on PR #23354: URL: https://github.com/apache/flink/pull/23354#issuecomment-1705493439 ## CI report: * 8f96e6abbf9c7a12d655f0d18d64373b72e1b2a8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33031) [JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase)

2023-09-04 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761868#comment-17761868 ] Jiabao Sun commented on FLINK-33031: PR is Ready on https://github.com/apache/flink/pull/23354 >

[GitHub] [flink] Jiabao-Sun opened a new pull request, #23354: [FLINK-33031][table-planner][JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase)

2023-09-04 Thread via GitHub
Jiabao-Sun opened a new pull request, #23354: URL: https://github.com/apache/flink/pull/23354 ## What is the purpose of the change [FLINK-33031][table-planner][JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase) ## Brief change log JUnit5

[jira] [Created] (FLINK-33031) [JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase)

2023-09-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-33031: -- Summary: [JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase) Key: FLINK-33031 URL: https://issues.apache.org/jira/browse/FLINK-33031 Project: Flink

[jira] [Updated] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33021: Fix Version/s: aws-connector-4.2.0 > AWS nightly builds fails on architecture tests >

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761861#comment-17761861 ] Hong Liang Teoh commented on FLINK-33021: - Triggering the nightly build now. 

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761860#comment-17761860 ] Hong Liang Teoh commented on FLINK-33021: - Ah. I only saw this now :( But I'll link the PR for

[GitHub] [flink-connector-aws] hlteoh37 merged pull request #92: [hotfix] Add MiniClusterExtension to ITCase tests

2023-09-04 Thread via GitHub
hlteoh37 merged PR #92: URL: https://github.com/apache/flink-connector-aws/pull/92 -- 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-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761856#comment-17761856 ] Hong Liang Teoh edited comment on FLINK-28513 at 9/4/23 3:17 PM: -

[jira] [Updated] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-28513: Fix Version/s: 1.18.0 1.17.2 > Flink Table API CSV streaming sink

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761856#comment-17761856 ] Hong Liang Teoh commented on FLINK-28513: - > I dont have access to update the fix version .

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761855#comment-17761855 ] Hong Liang Teoh commented on FLINK-28513: - merged commit 

[GitHub] [flink] hlteoh37 commented on pull request #23352: [FLINK-28513][Backport][release-1.18] Fix Flink Table API CSV streaming sink throws

2023-09-04 Thread via GitHub
hlteoh37 commented on PR #23352: URL: https://github.com/apache/flink/pull/23352#issuecomment-1705433546 @MartijnVisser Do you think we want to backport this to Flink 1.18? Given this is a critical bug -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] hlteoh37 merged pull request #23351: [FLINK-28513][Backport][release-1.17] Fix Flink Table API CSV streaming sink throws

2023-09-04 Thread via GitHub
hlteoh37 merged PR #23351: URL: https://github.com/apache/flink/pull/23351 -- 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-33020) OpensearchSinkTest.testAtLeastOnceSink timed out

2023-09-04 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761839#comment-17761839 ] Andriy Redko commented on FLINK-33020: -- [~martijnvisser] yes, I think it happens from time to time

[jira] [Assigned] (FLINK-33029) Drop python 3.7 support

2023-09-04 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-33029: - Assignee: Gabor Somogyi > Drop python 3.7 support > --- > >

[jira] [Created] (FLINK-33030) Add python 3.11 support

2023-09-04 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-33030: - Summary: Add python 3.11 support Key: FLINK-33030 URL: https://issues.apache.org/jira/browse/FLINK-33030 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-33029) Drop python 3.7 support

2023-09-04 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-33029: - Summary: Drop python 3.7 support Key: FLINK-33029 URL: https://issues.apache.org/jira/browse/FLINK-33029 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761832#comment-17761832 ] Ryan Skraba commented on FLINK-33018: - _If I understand correctly_ -- the *"C"* element is meant to

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

2023-09-04 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761031#comment-17761031 ] Alexis Sarda-Espinosa edited comment on FLINK-16686 at 9/4/23 1:30 PM:

[GitHub] [flink] flinkbot commented on pull request #23353: [FLINK-33024][table-planner][JUnit5 Migration] Module: flink-table-planner (JsonPlanTestBase)

2023-09-04 Thread via GitHub
flinkbot commented on PR #23353: URL: https://github.com/apache/flink/pull/23353#issuecomment-1705260690 ## CI report: * d852cff5a660222835a26bc54d0c195c9e69c1b2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33024) [JUnit5 Migration] Module: flink-table-planner (JsonPlanTestBase)

2023-09-04 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761824#comment-17761824 ] Jiabao Sun commented on FLINK-33024: PR is ready on https://github.com/apache/flink/pull/23353 >

[GitHub] [flink] Jiabao-Sun opened a new pull request, #23353: [FLINK-33024][table-planner][JUnit5 Migration] Module: flink-table-planner (JsonPlanTestBase)

2023-09-04 Thread via GitHub
Jiabao-Sun opened a new pull request, #23353: URL: https://github.com/apache/flink/pull/23353 ## What is the purpose of the change [FLINK-33024][table-planner][JUnit5 Migration] Module: flink-table-planner (JsonPlanTestBase) ## Brief change log JUnit5 Migration

[jira] [Commented] (FLINK-32988) HiveITCase failed due to TestContainer not coming up

2023-09-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761820#comment-17761820 ] Matthias Pohl commented on FLINK-32988: --- [~fsk119] There is a temporal dependency between the test

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

2023-09-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761812#comment-17761812 ] Matthias Pohl commented on FLINK-32667: --- Sounds reasonable. (y) fyi: I might not be that

[jira] [Created] (FLINK-33028) FLIP-348: Make expanding behavior of virtual metadata columns configurable

2023-09-04 Thread Timo Walther (Jira)
Timo Walther created FLINK-33028: Summary: FLIP-348: Make expanding behavior of virtual metadata columns configurable Key: FLINK-33028 URL: https://issues.apache.org/jira/browse/FLINK-33028 Project:

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

2023-09-04 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761807#comment-17761807 ] Fang Yong commented on FLINK-32667: --- [~mapohl] As we discussed in the threads

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-04 Thread Aleksandr Pilipenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761797#comment-17761797 ] Aleksandr Pilipenko commented on FLINK-32962: - cc [~dianfu], [~hxbks2ks] > Failure to

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761794#comment-17761794 ] Samrat Deb commented on FLINK-28513: I dont have access to update the fix version . Please help

[GitHub] [flink] flinkbot commented on pull request #23352: [FLINK-28513] Fix Flink Table API CSV streaming sink throws

2023-09-04 Thread via GitHub
flinkbot commented on PR #23352: URL: https://github.com/apache/flink/pull/23352#issuecomment-1705123599 ## CI report: * e7167b273667e84ea7b01434ededc8e6aca0c8c5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761790#comment-17761790 ] Samrat Deb commented on FLINK-28513: Hi [~liangtl]  backport for 1.17 :- 

[GitHub] [flink] flinkbot commented on pull request #23351: [FLINK-28513] Fix Flink Table API CSV streaming sink throws

2023-09-04 Thread via GitHub
flinkbot commented on PR #23351: URL: https://github.com/apache/flink/pull/23351#issuecomment-1705116714 ## CI report: * 97c206b9ef38a715912a103763727af726f020c2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Samrat002 opened a new pull request, #23352: [FLINK-28513] Fix Flink Table API CSV streaming sink throws

2023-09-04 Thread via GitHub
Samrat002 opened a new pull request, #23352: URL: https://github.com/apache/flink/pull/23352 ## What is the purpose of the change Backport https://github.com/apache/flink/pull/21458 for 1.17 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23243: [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

2023-09-04 Thread via GitHub
Jiabao-Sun commented on code in PR #23243: URL: https://github.com/apache/flink/pull/23243#discussion_r1314789249 ## flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java: ## @@ -75,30 +70,30 @@ protected String

[GitHub] [flink] Samrat002 opened a new pull request, #23351: [FLINK-28513] Fix Flink Table API CSV streaming sink throws

2023-09-04 Thread via GitHub
Samrat002 opened a new pull request, #23351: URL: https://github.com/apache/flink/pull/23351 ## What is the purpose of the change Backport https://github.com/apache/flink/pull/21458 for 1.17 -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] wangzzu commented on a diff in pull request #23265: [FLINK-32853][runtime][JUnit5 Migration] The security, taskmanager an…

2023-09-04 Thread via GitHub
wangzzu commented on code in PR #23265: URL: https://github.com/apache/flink/pull/23265#discussion_r1314803293 ## flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskCancelAsyncProducerConsumerITCase.java: ## @@ -187,11 +185,11 @@ public void

[GitHub] [flink] zhougit86 commented on pull request #23323: [FLINK-32738][formats] PROTOBUF format supports projection push down

2023-09-04 Thread via GitHub
zhougit86 commented on PR #23323: URL: https://github.com/apache/flink/pull/23323#issuecomment-1705076440 > @zhougit86 Yes, I can review this, however, I have limited spare time, which means that I may respond slowly. Ok, take your time. Let me know if any clarification needed --

[GitHub] [flink] zhougit86 commented on pull request #23323: [FLINK-32738][formats] PROTOBUF format supports projection push down

2023-09-04 Thread via GitHub
zhougit86 commented on PR #23323: URL: https://github.com/apache/flink/pull/23323#issuecomment-1705075520 > Ok, take your time. Let me know if any clarification needed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761787#comment-17761787 ] Hong Liang Teoh commented on FLINK-28513: - [~samrat007]  Could we backport this bugfix to Flink

[jira] [Resolved] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-28513. - Fix Version/s: 1.19.0 Resolution: Fixed > Flink Table API CSV streaming sink

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761785#comment-17761785 ] Hong Liang Teoh commented on FLINK-28513: -  merged commit 

[GitHub] [flink] hlteoh37 merged pull request #21458: [FLINK-28513] Fix Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread via GitHub
hlteoh37 merged PR #21458: URL: https://github.com/apache/flink/pull/21458 -- 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-connector-hbase] boring-cyborg[bot] commented on pull request #18: [FLINK-30470] HBase change groupId for flink-connector-parent

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

[GitHub] [flink-connector-hbase] snuyanzin opened a new pull request, #18: [FLINK-30470] HBase change groupId for flink-connector-parent

2023-09-04 Thread via GitHub
snuyanzin opened a new pull request, #18: URL: https://github.com/apache/flink-connector-hbase/pull/18 The PR makes use of `org.apache.flink` for parent group id -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Closed] (FLINK-33008) Use KubernetesClient from JOSDK context

2023-09-04 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-33008. -- Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed merged to main

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #662: [FLINK-33008] Refactor to use KubernetesClient from JOSDK Context

2023-09-04 Thread via GitHub
gyfora merged PR #662: URL: https://github.com/apache/flink-kubernetes-operator/pull/662 -- 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] hlteoh37 commented on pull request #21458: [FLINK-28513] Fix Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread via GitHub
hlteoh37 commented on PR #21458: URL: https://github.com/apache/flink/pull/21458#issuecomment-170501 Ok this looks good to me. Thanks for fixing and testing @Samrat002 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Created] (FLINK-33027) Users should be able to change parallelism of excluded vertices

2023-09-04 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-33027: -- Summary: Users should be able to change parallelism of excluded vertices Key: FLINK-33027 URL: https://issues.apache.org/jira/browse/FLINK-33027 Project: Flink

[jira] [Assigned] (FLINK-33027) Users should be able to change parallelism of excluded vertices

2023-09-04 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-33027: -- Assignee: Gyula Fora > Users should be able to change parallelism of excluded vertices >

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-04 Thread Jayadeep Jayaraman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761774#comment-17761774 ] Jayadeep Jayaraman commented on FLINK-33018: I checked and looks like the test was flaky, I

[GitHub] [flink] flinkbot commented on pull request #23350: [FLINK-33026][doc] Fix the title of sql 'Performance Tuning' in the chinese index page

2023-09-04 Thread via GitHub
flinkbot commented on PR #23350: URL: https://github.com/apache/flink/pull/23350#issuecomment-1704989427 ## CI report: * dc0beaeff62124609ceaf9e2139c9bb7765c0d87 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

2023-09-04 Thread via GitHub
TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1314726683 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileReader.java: ## @@ -78,4 +91,165 @@ long getPriority(

[GitHub] [flink] lincoln-lil opened a new pull request, #23350: [FLINK-33026][doc] Fix the title of sql 'Performance Tuning' in the chinese index page

2023-09-04 Thread via GitHub
lincoln-lil opened a new pull request, #23350: URL: https://github.com/apache/flink/pull/23350 This is a minor fix for the page title, after fix, the preview page will be: ![image](https://github.com/apache/flink/assets/3712895/6d95c767-ab27-4c7f-a33d-c43379d2312b) -- This is

[GitHub] [flink-kubernetes-operator] darenwkt commented on a diff in pull request #662: [FLINK-33008] Refactor to use KubernetesClient from JOSDK Context

2023-09-04 Thread via GitHub
darenwkt commented on code in PR #662: URL: https://github.com/apache/flink-kubernetes-operator/pull/662#discussion_r1314722812 ## flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/listener/FlinkResourceListener.java: ## @@ -45,8 +44,6 @@

[jira] [Assigned] (FLINK-33026) The chinese doc of sql 'Performance Tuning' has a wrong title in the index page

2023-09-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-33026: --- Assignee: lincoln lee > The chinese doc of sql 'Performance Tuning' has a wrong title in

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-04 Thread Jayadeep Jayaraman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761768#comment-17761768 ] Jayadeep Jayaraman commented on FLINK-33018: Let me look into it and raise a PR > GCP

[jira] [Created] (FLINK-33026) The chinese doc of sql 'Performance Tuning' has a wrong title in the index page

2023-09-04 Thread lincoln lee (Jira)
lincoln lee created FLINK-33026: --- Summary: The chinese doc of sql 'Performance Tuning' has a wrong title in the index page Key: FLINK-33026 URL: https://issues.apache.org/jira/browse/FLINK-33026

[GitHub] [flink] echauchot commented on pull request #22985: [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler

2023-09-04 Thread via GitHub
echauchot commented on PR #22985: URL: https://github.com/apache/flink/pull/22985#issuecomment-1704964511 @1996fanrui I addressed all your comments and I think we are in sync. Can you resume you review ? -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761762#comment-17761762 ] Martijn Visser commented on FLINK-33018: [~jjayadeep] I don't know, if you think that's the fix

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761761#comment-17761761 ] Martijn Visser commented on FLINK-33021: [~liangtl] Ah, I think that shouldn't be fixed with a

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-04 Thread Jayadeep Jayaraman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761756#comment-17761756 ] Jayadeep Jayaraman commented on FLINK-33018: [~martijnvisser] - Shouldn't the assert just

[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761755#comment-17761755 ] Sergey Nuyanzin commented on FLINK-26644: -

[jira] [Commented] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

2023-09-04 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761754#comment-17761754 ] Weihua Hu commented on FLINK-32803: --- [~chesnay], Hi, is there any other scenarios you would like to

[jira] [Commented] (FLINK-32988) HiveITCase failed due to TestContainer not coming up

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761753#comment-17761753 ] Sergey Nuyanzin commented on FLINK-32988: -

[jira] [Updated] (FLINK-33025) BatchArrowPythonOverWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails on AZP

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33025: Affects Version/s: 1.16.3 >

[jira] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990 ] Sergey Nuyanzin deleted comment on FLINK-26990: - was (Author: sergey nuyanzin): 1.16:

[jira] [Commented] (FLINK-33025) BatchArrowPythonOverWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails on AZP

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761751#comment-17761751 ] Sergey Nuyanzin commented on FLINK-33025: - 1.16:

[jira] [Updated] (FLINK-33025) BatchArrowPythonOverWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails on AZP

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33025: Description: This build

[jira] [Created] (FLINK-33025) BatchArrowPythonOverWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails on AZP

2023-09-04 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33025: --- Summary: BatchArrowPythonOverWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails on AZP Key: FLINK-33025 URL:

[jira] [Updated] (FLINK-33025) BatchArrowPythonOverWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails on AZP

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33025: Affects Version/s: 1.19.0 >

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

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761749#comment-17761749 ] Sergey Nuyanzin commented on FLINK-26515: -

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761747#comment-17761747 ] Sergey Nuyanzin commented on FLINK-18356: -

[jira] [Comment Edited] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

2023-09-04 Thread Matt Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761745#comment-17761745 ] Matt Wang edited comment on FLINK-32804 at 9/4/23 9:07 AM: --- [~renqs] [~pgaref]

[jira] [Updated] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-26990: Affects Version/s: 1.16.2 (was: 1.16.0) >

[jira] [Comment Edited] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761746#comment-17761746 ] Sergey Nuyanzin edited comment on FLINK-26990 at 9/4/23 9:07 AM: - 1.16:

[jira] [Commented] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761746#comment-17761746 ] Sergey Nuyanzin commented on FLINK-26990: -

[jira] [Updated] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

2023-09-04 Thread Matt Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32804: -- Attachment: image-2023-09-04-17-04-21-682.png > Release Testing: Verify FLIP-304: Pluggable failure

[jira] [Comment Edited] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

2023-09-04 Thread Matt Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761745#comment-17761745 ] Matt Wang edited comment on FLINK-32804 at 9/4/23 9:05 AM: --- [~renqs] [~pgaref]

[jira] [Commented] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

2023-09-04 Thread Matt Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761745#comment-17761745 ] Matt Wang commented on FLINK-32804: --- [~renqs] [~pgaref] hi, I have tested the functions of LIFP-304

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

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-26515: Affects Version/s: 1.19.0 > RetryingExecutorTest. testDiscardOnTimeout failed on azure >

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

2023-09-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761744#comment-17761744 ] Sergey Nuyanzin commented on FLINK-26515: -

  1   2   >