[jira] [Comment Edited] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-20 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818693#comment-17818693 ] Jing Ge edited comment on FLINK-34202 at 2/20/24 8:01 AM: -- Than

[jira] [Comment Edited] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-20 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818693#comment-17818693 ] Jing Ge edited comment on FLINK-34202 at 2/20/24 8:04 AM: -- Than

Re: [PR] [FLINK-34371][runtime] Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment [flink]

2024-02-20 Thread via GitHub
Sxnan commented on code in PR #24272: URL: https://github.com/apache/flink/pull/24272#discussion_r1495348233 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java: ## @@ -780,6 +780,9 @@ private void onTaskExecutionStateUpdate( // only not

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-20 Thread Lorenzo Affetti (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818698#comment-17818698 ] Lorenzo Affetti commented on FLINK-34202: - Sure thing (y) > python tests take s

Re: [PR] [FLINK-33182][table] Allow metadata columns in Ndu-analyze with ChangelogNormalize [flink]

2024-02-20 Thread via GitHub
twalthr closed pull request #24121: [FLINK-33182][table] Allow metadata columns in Ndu-analyze with ChangelogNormalize URL: https://github.com/apache/flink/pull/24121 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-20 Thread via GitHub
1996fanrui commented on code in PR #24340: URL: https://github.com/apache/flink/pull/24340#discussion_r1495400609 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java: ## @@ -341,7 +343,7 @@ public void testCheckpointRescalingNonPartitionedS

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-20 Thread via GitHub
1996fanrui commented on code in PR #24340: URL: https://github.com/apache/flink/pull/24340#discussion_r1495401227 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java: ## @@ -163,6 +163,8 @@ public void setup() throws Exception {

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-20 Thread via GitHub
1996fanrui commented on code in PR #24340: URL: https://github.com/apache/flink/pull/24340#discussion_r1495400609 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java: ## @@ -341,7 +343,7 @@ public void testCheckpointRescalingNonPartitionedS

[jira] [Closed] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

2024-02-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-33182. Fix Version/s: 1.20.0 (was: 1.19.0) Resolution: Fixed Fixed in maste

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-20 Thread via GitHub
1996fanrui commented on code in PR #24340: URL: https://github.com/apache/flink/pull/24340#discussion_r1495400609 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java: ## @@ -341,7 +343,7 @@ public void testCheckpointRescalingNonPartitionedS

Re: [PR] [FLINK-33948][table] Cleanup usage of deprecated org.apache.flink.tab… [flink]

2024-02-20 Thread via GitHub
HuangXingBo merged PR #23996: URL: https://github.com/apache/flink/pull/23996 -- 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.a

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

2024-02-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-34452: -- Assignee: Weijie Guo > Release Testing: Verify FLINK-15959 Add min number of slots configurat

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-20 Thread via GitHub
1996fanrui commented on code in PR #24340: URL: https://github.com/apache/flink/pull/24340#discussion_r1495400609 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java: ## @@ -341,7 +343,7 @@ public void testCheckpointRescalingNonPartitionedS

[jira] [Closed] (FLINK-33948) Cleanup usage of org.apache.flink.table.api.dataview.MapView#MapView

2024-02-20 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacky Lau closed FLINK-33948. - Resolution: Fixed merged c24e2c9a8c77406f0f4ca6b5b50e8d2b2ac5d811 > Cleanup usage of org.apache.flink.t

[jira] [Assigned] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

2024-02-20 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-34467: - Assignee: Zhenqiu Huang > Implement Lineage Interface in Jdbc Connector > -

[jira] [Assigned] (FLINK-34468) Implement Lineage Interface in Cassandra Connector

2024-02-20 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-34468: - Assignee: Zhenqiu Huang > Implement Lineage Interface in Cassandra Connector >

Re: [PR] [hotfix][docs] Integrate mongodb v1.1 docs [flink]

2024-02-20 Thread via GitHub
leonardBang merged PR #24341: URL: https://github.com/apache/flink/pull/24341 -- 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.a

[jira] [Assigned] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-02-20 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-34466: - Assignee: Zhenqiu Huang > Implement Lineage Interface in Kafka Connector >

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-20 Thread via GitHub
XComp commented on code in PR #24340: URL: https://github.com/apache/flink/pull/24340#discussion_r1495440125 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java: ## @@ -341,7 +343,7 @@ public void testCheckpointRescalingNonPartitionedStateC

Re: [PR] [BP-1.19][hotfix][docs] Update the versions of mongodb supported by mongodb-connector [flink]

2024-02-20 Thread via GitHub
Jiabao-Sun merged PR #24342: URL: https://github.com/apache/flink/pull/24342 -- 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.ap

Re: [PR] [BP-1.18][hotfix][docs] Update the versions of mongodb supported by mongodb-connector [flink]

2024-02-20 Thread via GitHub
Jiabao-Sun merged PR #24343: URL: https://github.com/apache/flink/pull/24343 -- 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.ap

Re: [PR] [BP-1.17][hotfix][docs] Update the versions of mongodb supported by mongodb-connector [flink]

2024-02-20 Thread via GitHub
Jiabao-Sun merged PR #24345: URL: https://github.com/apache/flink/pull/24345 -- 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.ap

Re: [PR] [FLINK-34314] Update CI Node Actions from NodeJS 16 to NodeJS 20 [flink-connector-shared-utils]

2024-02-20 Thread via GitHub
MartijnVisser merged PR #35: URL: https://github.com/apache/flink-connector-shared-utils/pull/35 -- 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] [Closed] (FLINK-34314) Update CI Node Actions from NodeJS 16 to NodeJS 20

2024-02-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34314. -- Resolution: Fixed Fixed in apache/flink-connector-shared-utils:ci_utils ec546068089dac4c41928

Re: [PR] [FLINK-34152] Tune all directly observable memory types [flink-kubernetes-operator]

2024-02-20 Thread via GitHub
1996fanrui commented on code in PR #778: URL: https://github.com/apache/flink-kubernetes-operator/pull/778#discussion_r1495444567 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java: ## @@ -80,57 +85,93 @@ public static Configuration tuneTaskM

Re: [PR] [Draft][bugfix] Move the deserialization of shuffleDescriptor to a separate … [flink]

2024-02-20 Thread via GitHub
caodizhou commented on PR #24115: URL: https://github.com/apache/flink/pull/24115#issuecomment-1953816916 @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.

[PR] [FLINK-34363] Set artifact version to $project_version if $FLINK_VERSION is not set [flink-connector-shared-utils]

2024-02-20 Thread via GitHub
echauchot opened a new pull request, #38: URL: https://github.com/apache/flink-connector-shared-utils/pull/38 [FLINK-34363](https://issues.apache.org/jira/browse/FLINK-34363) This script change was tested as following: - **with $FLINK_VERSION not set**: to build flink-connector-pa

[jira] [Updated] (FLINK-34363) Connectors release utils should allow to not specify flink version in stage_jars.sh

2024-02-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34363: --- Labels: pull-request-available (was: ) > Connectors release utils should allow to not speci

Re: [PR] [FLINK-34363] Set artifact version to $project_version if $FLINK_VERSION is not set [flink-connector-shared-utils]

2024-02-20 Thread via GitHub
echauchot commented on code in PR #38: URL: https://github.com/apache/flink-connector-shared-utils/pull/38#discussion_r1495554959 ## stage_jars.sh: ## @@ -37,8 +37,13 @@ function deploy_staging_jars { echo "Jars should not be created for SNAPSHOT versions. Use 'update_bra

[jira] [Created] (FLINK-34471) Tune the network memroy in Autoscaler

2024-02-20 Thread Rui Fan (Jira)
Rui Fan created FLINK-34471: --- Summary: Tune the network memroy in Autoscaler Key: FLINK-34471 URL: https://issues.apache.org/jira/browse/FLINK-34471 Project: Flink Issue Type: Improvement

Re: [PR] Add JDBC 3.1.2 connector [flink-web]

2024-02-20 Thread via GitHub
leonardBang commented on code in PR #707: URL: https://github.com/apache/flink-web/pull/707#discussion_r1495565382 ## docs/data/flink_connectors.yml: ## @@ -44,11 +44,11 @@ gcp-pubsub: compatibility: ["1.16.x", "1.17.x"] jdbc: - name: "Apache Flink JDBC Connector 3.1.1" -

[jira] [Commented] (FLINK-34471) Tune the network memroy in Autoscaler

2024-02-20 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818735#comment-17818735 ] Rui Fan commented on FLINK-34471: - cc  [~mxm] [~gyfora]  It is mentioned in this commen

Re: [PR] Add JDBC 3.1.2 connector [flink-web]

2024-02-20 Thread via GitHub
snuyanzin commented on code in PR #707: URL: https://github.com/apache/flink-web/pull/707#discussion_r1495578490 ## docs/data/flink_connectors.yml: ## @@ -44,11 +44,11 @@ gcp-pubsub: compatibility: ["1.16.x", "1.17.x"] jdbc: - name: "Apache Flink JDBC Connector 3.1.1" -

Re: [PR] Add JDBC 3.1.2 connector [flink-web]

2024-02-20 Thread via GitHub
leonardBang commented on code in PR #707: URL: https://github.com/apache/flink-web/pull/707#discussion_r1495584009 ## docs/data/flink_connectors.yml: ## @@ -44,11 +44,11 @@ gcp-pubsub: compatibility: ["1.16.x", "1.17.x"] jdbc: - name: "Apache Flink JDBC Connector 3.1.1" -

Re: [PR] Add JDBC 3.1.2 connector [flink-web]

2024-02-20 Thread via GitHub
leonardBang commented on code in PR #707: URL: https://github.com/apache/flink-web/pull/707#discussion_r1495586503 ## docs/data/flink_connectors.yml: ## @@ -44,11 +44,11 @@ gcp-pubsub: compatibility: ["1.16.x", "1.17.x"] jdbc: - name: "Apache Flink JDBC Connector 3.1.1" -

[jira] [Commented] (FLINK-34399) Release Testing: Verify FLINK-33644 Make QueryOperations SQL serializable

2024-02-20 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818745#comment-17818745 ] Ferenc Csaky commented on FLINK-34399: -- Thank you [~lincoln.86xy], I'll proceed wit

[PR] [hotfix] Use 1.16.0 as minimum supported Flink version in pom [flink-connector-jdbc]

2024-02-20 Thread via GitHub
snuyanzin opened a new pull request, #102: URL: https://github.com/apache/flink-connector-jdbc/pull/102 This is a follow up task for comments at https://github.com/apache/flink-web/pull/707#discussion_r1495584009 -- This is an automated message from the Apache Git Service. To respond to t

Re: [PR] Add JDBC 3.1.2 connector [flink-web]

2024-02-20 Thread via GitHub
snuyanzin commented on code in PR #707: URL: https://github.com/apache/flink-web/pull/707#discussion_r1495609351 ## docs/data/flink_connectors.yml: ## @@ -44,11 +44,11 @@ gcp-pubsub: compatibility: ["1.16.x", "1.17.x"] jdbc: - name: "Apache Flink JDBC Connector 3.1.1" -

Re: [PR] [FLINK-32443][docs-zh] Translate "State Processor API" page into Chinese [flink]

2024-02-20 Thread via GitHub
Zakelly commented on code in PR #23496: URL: https://github.com/apache/flink/pull/23496#discussion_r1495572575 ## docs/content.zh/docs/libs/state_processor_api.md: ## @@ -27,77 +27,62 @@ under the License. # State Processor API -Apache Flink's State Processor API provides p

[PR] [hotfix] Remove redundant call to remove(). [flink]

2024-02-20 Thread via GitHub
StefanRRichter opened a new pull request, #24346: URL: https://github.com/apache/flink/pull/24346 Code was removing a handle from a list twice, so the second call to remove has no effect and can be deleted. -- This is an automated message from the Apache Git Service. To respond to the mes

Re: [PR] [hotfix] Remove redundant call to remove(). [flink]

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

Re: [PR] [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese [flink]

2024-02-20 Thread via GitHub
Zakelly commented on code in PR #22582: URL: https://github.com/apache/flink/pull/22582#discussion_r1495629446 ## docs/content.zh/docs/ops/state/checkpointing_under_backpressure.md: ## @@ -111,43 +111,38 @@ env.getCheckpointConfig().setAlignedCheckpointTimeout(Duration.ofSecond

[jira] [Updated] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2024-02-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24696: --- Labels: pull-request-available (was: ) > Translate how to configure unaligned checkpoints i

Re: [PR] [FLINK-34446][table] Apply workaround to allow parsing of cross join with lateral [flink]

2024-02-20 Thread via GitHub
JingGe commented on code in PR #24317: URL: https://github.com/apache/flink/pull/24317#discussion_r1495629504 ## flink-table/flink-sql-parser/pom.xml: ## @@ -252,6 +252,7 @@ under the License. it under ${project.build.directory} where all freemarker templa

Re: [PR] [FLINK-34437][SQL Client] Fix typo [flink]

2024-02-20 Thread via GitHub
JingGe merged PR #24310: URL: https://github.com/apache/flink/pull/24310 -- 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-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-20 Thread via GitHub
JingGe commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1953984465 > hi @JingGe , I have done with it, is that OK for you to merge this PR? thanks a lot. sure, let's wait until the CI passed -- This is an automated message from the Apache Git Ser

[jira] [Assigned] (FLINK-34331) Enable Apache INFRA runners for nightly builds

2024-02-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-34331: - Assignee: Matthias Pohl > Enable Apache INFRA runners for nightly builds >

[PR] [FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner [flink]

2024-02-20 Thread via GitHub
XComp opened a new pull request, #24347: URL: https://github.com/apache/flink/pull/24347 ## What is the purpose of the change The goal is to enable Apache-hosted runners for the main repo but allow forks to use the GitHub-hosted runners. ## Brief change log * Adds reusab

[jira] [Updated] (FLINK-34331) Enable Apache INFRA runners for nightly builds

2024-02-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34331: --- Labels: pull-request-available (was: ) > Enable Apache INFRA runners for nightly builds > -

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

2024-02-20 Thread via GitHub
gyfora merged PR #777: URL: https://github.com/apache/flink-kubernetes-operator/pull/777 -- 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

Re: [PR] [FLINK-34266] Compute Autoscaler metrics correctly over metric window [flink-kubernetes-operator]

2024-02-20 Thread via GitHub
gyfora merged PR #774: URL: https://github.com/apache/flink-kubernetes-operator/pull/774 -- 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] [Closed] (FLINK-34266) Output ratios should be computed over the whole metric window instead of averaged

2024-02-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34266. -- Fix Version/s: kubernetes-operator-1.8.0 Resolution: Fixed merged to main 0a7588c084e7197f73e65

[jira] [Closed] (FLINK-34213) Consider using accumulated busy time instead of busyMsPerSecond

2024-02-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34213. -- Fix Version/s: kubernetes-operator-1.8.0 Resolution: Fixed merged to main 0a7588c084e7197f73e65

[jira] [Closed] (FLINK-34438) Kubernetes Operator doesn't wait for TaskManager deletion in native mode

2024-02-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34438. -- Fix Version/s: kubernetes-operator-1.8.0 Resolution: Fixed merged to main a8fd19429e93428e8a249

Re: [PR] [hotfix] Update high-availability configs to newer syntax [flink-kubernetes-operator]

2024-02-20 Thread via GitHub
gyfora closed pull request #764: [hotfix] Update high-availability configs to newer syntax URL: https://github.com/apache/flink-kubernetes-operator/pull/764 -- 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

Re: [PR] [hotfix] Update high-availability configs to newer syntax [flink-kubernetes-operator]

2024-02-20 Thread via GitHub
gyfora commented on PR #764: URL: https://github.com/apache/flink-kubernetes-operator/pull/764#issuecomment-1954007608 Closing this PR, should be reopened once the minimum supported version is 1.16 -- This is an automated message from the Apache Git Service. To respond to the message, pl

Re: [PR] [FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner [flink]

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

Re: [PR] [FLINK-34446][table] Apply workaround to allow parsing of cross join with lateral [flink]

2024-02-20 Thread via GitHub
snuyanzin commented on code in PR #24317: URL: https://github.com/apache/flink/pull/24317#discussion_r1495657249 ## flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java: ## @@ -107,6 +107,10 @@ void testExplainAsDot() {} void te

Re: [PR] Adding affinity rule. [flink-kubernetes-operator]

2024-02-20 Thread via GitHub
gyfora commented on PR #737: URL: https://github.com/apache/flink-kubernetes-operator/pull/737#issuecomment-1954008843 @Anshul1128 are you still working on this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-33930] Canceled stop job status exception [flink-kubernetes-operator]

2024-02-20 Thread via GitHub
gyfora commented on PR #740: URL: https://github.com/apache/flink-kubernetes-operator/pull/740#issuecomment-1954009553 Should we close this? @hunter-cloud09 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

Re: [PR] [FLINK-34446][table] Apply workaround to allow parsing of cross join with lateral [flink]

2024-02-20 Thread via GitHub
snuyanzin commented on code in PR #24317: URL: https://github.com/apache/flink/pull/24317#discussion_r1495660945 ## flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj: ## @@ -0,0 +1,8469 @@ +/* Review Comment: IIRC we could extend it if we want something compl

Re: [PR] [hotfix] Remove redundant call to remove(). [flink]

2024-02-20 Thread via GitHub
StefanRRichter merged PR #24346: URL: https://github.com/apache/flink/pull/24346 -- 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...@flin

Re: [PR] [FLINK-33728] Do not rewatch when KubernetesResourceManagerDriver wat… [flink]

2024-02-20 Thread via GitHub
zhougit86 commented on PR #24163: URL: https://github.com/apache/flink/pull/24163#issuecomment-1954032190 @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-33241][doc] Align config option generation documentation for Flink's config documentation. [flink]

2024-02-20 Thread via GitHub
zhuzhurk merged PR #24344: URL: https://github.com/apache/flink/pull/24344 -- 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] [Closed] (FLINK-33241) Align config option generation documentation for Flink's config documentation

2024-02-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-33241. --- Fix Version/s: 1.19.0 Resolution: Fixed Fixed via 8fe005cf1325b7477d7e1808a46bd80798165029 > Align c

Re: [PR] [FLINK-32443][docs-zh] Translate "State Processor API" page into Chinese [flink]

2024-02-20 Thread via GitHub
fredia commented on PR #23496: URL: https://github.com/apache/flink/pull/23496#issuecomment-1954097677 @Zakelly Thanks for the detailed review, I have addressed them, please take another look! thanks! -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-34358] Fix some tests that failed in Flink 1.19 [flink-connector-jdbc]

2024-02-20 Thread via GitHub
snuyanzin commented on PR #101: URL: https://github.com/apache/flink-connector-jdbc/pull/101#issuecomment-1954112543 LGTM thanks for working on it -- 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

Re: [PR] [FLINK-34358] Fix some tests that failed in Flink 1.19 [flink-connector-jdbc]

2024-02-20 Thread via GitHub
snuyanzin commented on PR #101: URL: https://github.com/apache/flink-connector-jdbc/pull/101#issuecomment-1954115641 I'm going to merge it to unblock other PRs and nightlies -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

Re: [PR] [FLINK-34358] Fix some tests that failed in Flink 1.19 [flink-connector-jdbc]

2024-02-20 Thread via GitHub
snuyanzin merged PR #101: URL: https://github.com/apache/flink-connector-jdbc/pull/101 -- 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] [Commented] (FLINK-34358) flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"

2024-02-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818793#comment-17818793 ] Sergey Nuyanzin commented on FLINK-34358: - Merged to main as [5d6bd2e12bcdd488e

Re: [PR] [hotfix] Use 1.16.0 as minimum supported Flink version in pom [flink-connector-jdbc]

2024-02-20 Thread via GitHub
snuyanzin closed pull request #102: [hotfix] Use 1.16.0 as minimum supported Flink version in pom URL: https://github.com/apache/flink-connector-jdbc/pull/102 -- 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

[jira] [Resolved] (FLINK-34358) flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"

2024-02-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-34358. - Fix Version/s: jdbc-3.2.0 Resolution: Fixed > flink-connector-jdbc nightly fails

Re: [PR] [hotfix] Use 1.16.0 as minimum supported Flink version in pom [flink-connector-jdbc]

2024-02-20 Thread via GitHub
snuyanzin commented on PR #102: URL: https://github.com/apache/flink-connector-jdbc/pull/102#issuecomment-1954131495 rebased because of blocker issue FLINK-34358 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-34252][table] Fix lastRecordTime tracking in WatermarkAssignerOperator [flink]

2024-02-20 Thread via GitHub
pnowojski commented on code in PR #24211: URL: https://github.com/apache/flink/pull/24211#discussion_r1495762047 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/WatermarkAssignerOperator.java: ## @@ -100,11 +100,14 @@ public

[jira] [Created] (FLINK-34472) loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThread().getContextClassLoader()) may can not find class because The current

2024-02-20 Thread jeremyMu (Jira)
jeremyMu created FLINK-34472: Summary: loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThread().getContextClassLoader()) may can not find class because The current thread class loader may not contain this

[jira] [Commented] (FLINK-34305) Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-02-20 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818800#comment-17818800 ] SuDewei commented on FLINK-34305: - [~lincoln.86xy] I will complete this document before

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThread().getContextClassLoader()) may can not find class because The current

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Issue Type: Bug (was: Improvement) > loading class of protobuf format descriptor by Class.forName(class

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThread().getContextClassLoader()) may can not find class because The current

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Attachment: sourcecode.jpg > loading class of protobuf format descriptor by Class.forName(className, tru

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThread().getContextClassLoader()) may can not find class because the current

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Summary: loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThr

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThread().getContextClassLoader()) may can not find class because The current

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Affects Version/s: 1.16.2 > loading class of protobuf format descriptor by Class.forName(className, true

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThread().getContextClassLoader()) may can not find class because he current t

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Summary: loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThr

[jira] [Commented] (FLINK-34305) Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-02-20 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818802#comment-17818802 ] lincoln lee commented on FLINK-34305: - [~sudewei.sdw] Sound good! Actually we don't

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentThread().getContextClassLoader())" may can not find class because the curren

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Summary: loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentT

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentThread().getContextClassLoader())" may can not find class because the curren

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Description: Caused by: java.lang.IllegalArgumentException: get test.ProtobufTest1 descriptors error!  

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentThread().getContextClassLoader())" may can not find class because the curren

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Fix Version/s: 1.20.0 (was: 1.18.1) > loading class of protobuf format descriptor

[jira] [Updated] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-02-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34429: --- Labels: pull-request-available (was: ) > Adding K8S Annotations to Internal Service > -

[PR] [FLINK-34429] [flink-kubernetes] Adding K8S Annotations to Internal Service [flink]

2024-02-20 Thread via GitHub
barakbn opened a new pull request, #24348: URL: https://github.com/apache/flink/pull/24348 ## What is the purpose of the change Flink currently supports adding Annotations to the Rest Service (with the configuration key: kubernetes.rest-service.annotations). This PR

[jira] [Created] (FLINK-34473) Migrate FlinkPruneEmptyRules

2024-02-20 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34473: - Summary: Migrate FlinkPruneEmptyRules Key: FLINK-34473 URL: https://issues.apache.org/jira/browse/FLINK-34473 Project: Flink Issue Type: Bug Components:

Re: [PR] [FLINK-34429] [flink-kubernetes] Adding K8S Annotations to Internal Service [flink]

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

Re: [PR] [hotfix] Use 1.16.0 as minimum supported Flink version in pom [flink-connector-jdbc]

2024-02-20 Thread via GitHub
snuyanzin merged PR #102: URL: https://github.com/apache/flink-connector-jdbc/pull/102 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr..

[jira] [Updated] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

2024-02-20 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-29370: --- Fix Version/s: (was: 1.19.0) > Protobuf in flink-sql-protobuf is not shaded > --

[jira] [Commented] (FLINK-34472) loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentThread().getContextClassLoader())" may can not find class because the curr

2024-02-20 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818806#comment-17818806 ] Benchao Li commented on FLINK-34472: Is this duplicated with FLINK-32418? > loading

Re: [PR] [FLINK-34252][table] Fix lastRecordTime tracking in WatermarkAssignerOperator [flink]

2024-02-20 Thread via GitHub
pnowojski commented on code in PR #24211: URL: https://github.com/apache/flink/pull/24211#discussion_r1495762047 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/WatermarkAssignerOperator.java: ## @@ -100,11 +100,14 @@ public

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentThread().getContextClassLoader())" may can not find class because the curren

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Description: 1、Stack information: Caused by: java.lang.IllegalArgumentException: get test.ProtobufTest1

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentThread().getContextClassLoader())" may can not find class because the curren

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Attachment: sourcecode3.png > loading class of protobuf format descriptor by "Class.forName(className,

[jira] [Updated] (FLINK-34472) loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentThread().getContextClassLoader())" may can not find class because the curren

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremyMu updated FLINK-34472: - Attachment: sourcecode2.png > loading class of protobuf format descriptor by "Class.forName(className,

[jira] [Commented] (FLINK-34472) loading class of protobuf format descriptor by "Class.forName(className, true, Thread.currentThread().getContextClassLoader())" may can not find class because the curr

2024-02-20 Thread jeremyMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818814#comment-17818814 ] jeremyMu commented on FLINK-34472: -- It's the same problem > loading class of protobuf

[jira] [Created] (FLINK-34474) After failed deserialization with ConfluentRegistryAvroDeserializationSchema all subsequent deserialization fails

2024-02-20 Thread Grzegorz Liter (Jira)
Grzegorz Liter created FLINK-34474: -- Summary: After failed deserialization with ConfluentRegistryAvroDeserializationSchema all subsequent deserialization fails Key: FLINK-34474 URL: https://issues.apache.org/jira

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-20 Thread via GitHub
1996fanrui commented on PR #24340: URL: https://github.com/apache/flink/pull/24340#issuecomment-1954319134 CI passed, 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 specific comment

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-20 Thread via GitHub
1996fanrui merged PR #24340: URL: https://github.com/apache/flink/pull/24340 -- 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.ap

  1   2   3   >