[jira] [Created] (FLINK-31100) Support the short topic pattern subscriber on default tenant and namespace

Yufan Sheng created FLINK-31100: --- Summary: Support the short topic pattern subscriber on default tenant and namespace Key: FLINK-31100 URL: https://issues.apache.org/jira/browse/FLINK-31100 Project: Fli

[jira] [Commented] (FLINK-27800) addInEdge check state error

[ https://issues.apache.org/jira/browse/FLINK-27800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689597#comment-17689597 ] Lijie Wang commented on FLINK-27800: Fixed via master: 7568628ee7e81ca7b1b4ae80a

[jira] [Updated] (FLINK-27800) addInEdge check state error

[ https://issues.apache.org/jira/browse/FLINK-27800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-27800: --- Affects Version/s: 1.16.1 1.15.3 1.17.0 > addInEdge ch

[jira] [Updated] (FLINK-27800) addInEdge check state error

[ https://issues.apache.org/jira/browse/FLINK-27800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-27800: --- Fix Version/s: 1.17.0 1.15.4 1.16.2 (was

[jira] [Updated] (FLINK-27800) addInEdge check state error

[ https://issues.apache.org/jira/browse/FLINK-27800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-27800: --- Affects Version/s: (was: 1.14.4) > addInEdge check state error > --- > >

[jira] [Closed] (FLINK-27800) addInEdge check state error

[ https://issues.apache.org/jira/browse/FLINK-27800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-27800. -- Resolution: Fixed > addInEdge check state error > --- > > Key:

[GitHub] [flink] xuzhiwen1255 commented on pull request #21946: [hotfix] [doc] Fix typo in zh/docs/dev/datastream/overview.md

xuzhiwen1255 commented on PR #21946: URL: https://github.com/apache/flink/pull/21946#issuecomment-1432679977 @XComp Thank you, I understand. Later I will read the contribution document and understand the process related to the contribution code. Thank you for your review. -- This is a

[jira] [Updated] (FLINK-28985) support create table like view

[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-28985: - Fix Version/s: 1.18.0 (was: 1.17.0) > support create table like view > --

[GitHub] [flink] waywtdcc commented on pull request #21159: [FLINK-28985][table]Create table statement supports create table like view

waywtdcc commented on PR #21159: URL: https://github.com/apache/flink/pull/21159#issuecomment-1432682845 @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] [Updated] (FLINK-28985) support create table like view

[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-28985: - Issue Type: Improvement (was: New Feature) > support create table like view > -

[GitHub] [flink-connector-pulsar] reswqa commented on a diff in pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

reswqa commented on code in PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#discussion_r1108149599 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandlerTest.java: ## @@ -0,0 +1,314 @@ +/* + *

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689608#comment-17689608 ] Rui Fan commented on FLINK-31036: - {quote}Reverting FLINK-26803 by then sounds reasonabl

[jira] [Assigned] (FLINK-31100) Support the short topic pattern subscriber on default tenant and namespace

[ https://issues.apache.org/jira/browse/FLINK-31100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31100: -- Assignee: Yufan Sheng > Support the short topic pattern subscriber on default tenant and name

[jira] [Commented] (FLINK-31093) NullpointerException when restoring a FlinkSQL job from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689610#comment-17689610 ] Matthias Pohl commented on FLINK-31093: --- I see that FLINK-30683 touched the {{Exec

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689614#comment-17689614 ] Rui Fan commented on FLINK-31036: - I see that StateCheckpointedITCase fails when this co

[GitHub] [flink] XComp commented on pull request #21946: [hotfix] [doc] Fix typo in zh/docs/dev/datastream/overview.md

XComp commented on PR #21946: URL: https://github.com/apache/flink/pull/21946#issuecomment-1432708485 Starting as a new contributor is kind of challenging and can be frustrating. I didn't mean to encourage you with my comments but wanted to give you some pointers that might help you in impr

[GitHub] [flink-connector-pulsar] syhily commented on a diff in pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

syhily commented on code in PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#discussion_r1108172686 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandlerTest.java: ## @@ -0,0 +1,314 @@ +/* + *

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689624#comment-17689624 ] Fabian Paul commented on FLINK-30238: - Sorry for joining late I was on PTO. [~gaoyu

[jira] [Assigned] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-31098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31098: -- Assignee: jackylau > Add ARRAY_SIZE supported in SQL & Table API > --

[GitHub] [flink-connector-pulsar] reswqa commented on a diff in pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

reswqa commented on code in PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#discussion_r1108182869 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandlerTest.java: ## @@ -0,0 +1,309 @@ +/* + *

[jira] [Comment Edited] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689625#comment-17689625 ] Matthias Pohl edited comment on FLINK-31036 at 2/16/23 8:55 AM: --

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689625#comment-17689625 ] Matthias Pohl commented on FLINK-31036: --- Is this a copy&paste error? The commit [

[GitHub] [flink-connector-pulsar] reswqa commented on a diff in pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

reswqa commented on code in PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#discussion_r1108183510 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandlerTest.java: ## @@ -0,0 +1,309 @@ +/* + *

[jira] [Comment Edited] (FLINK-31093) NullpointerException when restoring a FlinkSQL job from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689610#comment-17689610 ] Matthias Pohl edited comment on FLINK-31093 at 2/16/23 8:56 AM: --

[GitHub] [flink-connector-pulsar] reswqa commented on a diff in pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

reswqa commented on code in PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#discussion_r1108185125 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandlerTest.java: ## @@ -0,0 +1,314 @@ +/* + *

[GitHub] [flink-connector-pulsar] syhily commented on a diff in pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

syhily commented on code in PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#discussion_r1108185267 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandlerTest.java: ## @@ -0,0 +1,309 @@ +/* + *

[GitHub] [flink-connector-pulsar] syhily commented on a diff in pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

syhily commented on code in PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#discussion_r1108186306 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandlerTest.java: ## @@ -0,0 +1,309 @@ +/* + *

[GitHub] [flink-connector-pulsar] reswqa commented on a diff in pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

reswqa commented on code in PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#discussion_r1108187362 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandlerTest.java: ## @@ -0,0 +1,309 @@ +/* + *

[jira] [Created] (FLINK-31101) Replace all the JUnit 5 assertions to AssertJ

Yufan Sheng created FLINK-31101: --- Summary: Replace all the JUnit 5 assertions to AssertJ Key: FLINK-31101 URL: https://issues.apache.org/jira/browse/FLINK-31101 Project: Flink Issue Type: Techn

[GitHub] [flink-connector-pulsar] syhily commented on pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

syhily commented on PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29#issuecomment-1432743690 Tks for @reswqa. You clear review is awesome and really helps me a lot. The remaining issue in this PR is the removal of JUnit 5 assertion. I have created a ticket for tracking

[jira] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238 ] Fabian Paul deleted comment on FLINK-30238: - was (Author: fabian.paul): Sorry for joining late I was on PTO. [~gaoyunhaii]  # I think your analysis is not fully correct. endOfInput() is als

[jira] [Comment Edited] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689628#comment-17689628 ] Rui Fan edited comment on FLINK-31036 at 2/16/23 9:06 AM: -- {quo

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689628#comment-17689628 ] Rui Fan commented on FLINK-31036: - {quote}Is this a copy&paste error? The commit  [331ab

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #192: [FLINK-30451] Add AlgoOperator for Swing

zhipeng93 commented on code in PR #192: URL: https://github.com/apache/flink-ml/pull/192#discussion_r1108207595 ## docs/content/docs/operators/recommendation/swing.md: ## @@ -0,0 +1,194 @@ +--- +title: "Swing" +type: docs +aliases: +- /operators/recommendation/swing.html +--- +

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #540: [FLINK-31087] Introduce insert-changes action

JingsongLi commented on code in PR #540: URL: https://github.com/apache/flink-table-store/pull/540#discussion_r1108217172 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/action/DeleteAction.java: ## @@ -115,8 +110,7 @@ public void run() throws

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #540: [FLINK-31087] Introduce insert-changes action

JingsongLi commented on code in PR #540: URL: https://github.com/apache/flink-table-store/pull/540#discussion_r1108217172 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/action/DeleteAction.java: ## @@ -115,8 +110,7 @@ public void run() throws

[jira] [Commented] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689636#comment-17689636 ] Piotr Nowojski commented on FLINK-18235: {quote} The question here is that it's

[jira] [Updated] (FLINK-31087) Introduce InsertChangesAction.

[ https://issues.apache.org/jira/browse/FLINK-31087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31087: --- Labels: pull-request-available (was: ) > Introduce InsertChangesAction. > -

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #540: [FLINK-31087] Introduce insert-changes action

JingsongLi commented on code in PR #540: URL: https://github.com/apache/flink-table-store/pull/540#discussion_r1108219002 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/action/InsertChangesAction.java: ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[jira] [Comment Edited] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689636#comment-17689636 ] Piotr Nowojski edited comment on FLINK-18235 at 2/16/23 9:27 AM: -

[GitHub] [flink-connector-mongodb] rozza commented on pull request #3: [FLINK-31063] Prevent duplicate reading when restoring from a checkpoint.

rozza commented on PR #3: URL: https://github.com/apache/flink-connector-mongodb/pull/3#issuecomment-1432780477 Hi @Jiabao-Sun, As indexes are mutable relying on the natural sort order of them is not going to guarantee the same order of data - so sorting is required, it may end up b

[GitHub] [flink] HuangXingBo closed pull request #21948: [FLINK-31099][python] Fix chained WindowOperator throws NPE in PyFlink Thread Mode

HuangXingBo closed pull request #21948: [FLINK-31099][python] Fix chained WindowOperator throws NPE in PyFlink Thread Mode URL: https://github.com/apache/flink/pull/21948 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Resolved] (FLINK-31099) Chained WindowOperator throws NPE in PyFlink ThreadMode

[ https://issues.apache.org/jira/browse/FLINK-31099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-31099. -- Resolution: Fixed Merged into master via ca770b3d905936d8a93071210bd6542b6733221d Merged into

[GitHub] [flink-connector-pulsar] reswqa merged pull request #29: [FLINK-28959][Stream] Add retry and rate limit for admin request. Use binary protocol for topic filtering.

reswqa merged PR #29: URL: https://github.com/apache/flink-connector-pulsar/pull/29 -- 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...@f

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689638#comment-17689638 ] Fabian Paul commented on FLINK-30238: - Sorry for joining late I was on PTO. [~gaoyu

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #540: [FLINK-31087] Introduce insert-changes action

JingsongLi commented on code in PR #540: URL: https://github.com/apache/flink-table-store/pull/540#discussion_r1108233048 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/action/InsertChangesAction.java: ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[jira] [Resolved] (FLINK-30965) git-repo-sync doesn't pick up the 2nd-most-recently published Flink version (even though it's still supported) after a new release branch is cut

[ https://issues.apache.org/jira/browse/FLINK-30965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30965. --- Resolution: Fixed The PR was merged and redeployed. I verified that the {{release-1.15}} is

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #540: [FLINK-31087] Introduce insert-changes action

JingsongLi commented on code in PR #540: URL: https://github.com/apache/flink-table-store/pull/540#discussion_r1108235271 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/action/InsertChangesAction.java: ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-30262) UpsertKafkaTableITCase failed when starting the container because waiting for a port timed out

[ https://issues.apache.org/jira/browse/FLINK-30262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689644#comment-17689644 ] Matthias Pohl commented on FLINK-30262: --- https://dev.azure.com/apache-flink/apache

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #540: [FLINK-31087] Introduce insert-changes action

JingsongLi commented on code in PR #540: URL: https://github.com/apache/flink-table-store/pull/540#discussion_r1108233513 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/action/InsertChangesAction.java: ## @@ -0,0 +1,192 @@ +/* + * Licensed to

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689645#comment-17689645 ] Matthias Pohl commented on FLINK-18356: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689646#comment-17689646 ] Matthias Pohl commented on FLINK-31036: --- Looks like it's not really a one-time thi

[jira] [Created] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API

jackylau created FLINK-31102: Summary: Add ARRAY_REMOVE supported in SQL & Table API Key: FLINK-31102 URL: https://issues.apache.org/jira/browse/FLINK-31102 Project: Flink Issue Type: Sub-task

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689649#comment-17689649 ] Matthias Pohl commented on FLINK-18356: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689650#comment-17689650 ] Weihua Hu commented on FLINK-31041: --- [~zhuzh] [~dannycranmer] I successfully reproduce

[jira] [Commented] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689651#comment-17689651 ] Weijie Guo commented on FLINK-28959: main(4.0) via 64bc829c17b8686d35f66b274cb241cca

[jira] [Closed] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-28959. -- Resolution: Fixed > 504 gateway timeout when consume large number of topics using TopicPatten > --

[jira] [Created] (FLINK-31103) Public Table API for table store

Jingsong Lee created FLINK-31103: Summary: Public Table API for table store Key: FLINK-31103 URL: https://issues.apache.org/jira/browse/FLINK-31103 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689653#comment-17689653 ] Zhu Zhu commented on FLINK-31041: - Thanks for the inputs! I took another look through t

[jira] [Commented] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689655#comment-17689655 ] Weijie Guo commented on FLINK-28959: [~martijnvisser] Sorry to bother you, but I wan

[jira] [Comment Edited] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689653#comment-17689653 ] Zhu Zhu edited comment on FLINK-31041 at 2/16/23 9:50 AM: -- Than

[jira] [Comment Edited] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689653#comment-17689653 ] Zhu Zhu edited comment on FLINK-31041 at 2/16/23 9:51 AM: -- Than

[jira] [Comment Edited] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689655#comment-17689655 ] Weijie Guo edited comment on FLINK-28959 at 2/16/23 9:51 AM: -

[jira] [Updated] (FLINK-31104) TPC-DS test timed out in query 36

[ https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31104: -- Description: There has a timeout happened in [apache-flink:flink-end-to-end-tests/flink-tpcds

[jira] [Created] (FLINK-31104) TPC-DS test timed out in query 36

Matthias Pohl created FLINK-31104: - Summary: TPC-DS test timed out in query 36 Key: FLINK-31104 URL: https://issues.apache.org/jira/browse/FLINK-31104 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-31104) TPC-DS test timed out in query 36

[ https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31104: -- Component/s: Table SQL / Runtime > TPC-DS test timed out in query 36 > ---

[jira] [Updated] (FLINK-31103) Public Table Reader API for table store

[ https://issues.apache.org/jira/browse/FLINK-31103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31103: - Summary: Public Table Reader API for table store (was: Public Table API for table store) > Pub

[GitHub] [flink] liuyongvs commented on pull request #20747: [FLINK-28929][table] Add built-in datediff function.

liuyongvs commented on PR #20747: URL: https://github.com/apache/flink/pull/20747#issuecomment-1432824764 hi @snuyanzin could you help review 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 to t

[GitHub] [flink] liuyongvs commented on pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

liuyongvs commented on PR #21947: URL: https://github.com/apache/flink/pull/21947#issuecomment-1432825144 @snuyanzin could you help review 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 to the

[jira] [Commented] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689664#comment-17689664 ] Martijn Visser commented on FLINK-28959: [~Weijie Guo] If it's an externalized c

[jira] [Commented] (FLINK-31093) NullpointerException when restoring a FlinkSQL job from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689666#comment-17689666 ] Junrui Li commented on FLINK-31093: --- [~mapohl] According to FLINK-29379, [ExecutionCo

[jira] [Commented] (FLINK-31104) TPC-DS test timed out in query 36

[ https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689668#comment-17689668 ] Matthias Pohl commented on FLINK-31104: --- With the limited artifacts that were coll

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689670#comment-17689670 ] Rui Fan commented on FLINK-31036: - {quote}Looks like it's not really a one-time thing: [

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on pull request #3: [FLINK-31063] Prevent duplicate reading when restoring from a checkpoint.

Jiabao-Sun commented on PR #3: URL: https://github.com/apache/flink-connector-mongodb/pull/3#issuecomment-1432841489 Thanks @rozza, That's very helpful for me. When recovering from a short-term failure, the offset may help.But when we resume reading after a long time, the result may

[jira] [Updated] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28959: --- Fix Version/s: pulsar-4.0.0 (was: 1.17.0) (was: 1.16.2)

[jira] [Updated] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28959: --- Affects Version/s: pulsar-3.0.0 pulsar-4.0.0 (was:

[jira] [Updated] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28959: --- Affects Version/s: (was: pulsar-4.0.0) > 504 gateway timeout when consume large number of topics

[jira] [Resolved] (FLINK-31093) NullpointerException when restoring a FlinkSQL job from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-31093. --- Resolution: Not A Problem args, you got me on that one - I did run the wrong sql client. I u

[jira] [Commented] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689674#comment-17689674 ] Weijie Guo commented on FLINK-28959: Got it, thanks for your explanation~ > 504 gat

[jira] [Updated] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28959: --- Affects Version/s: pulsar-4.0.0 (was: pulsar-3.0.0) > 504 gateway timeout

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689677#comment-17689677 ] Zhu Zhu commented on FLINK-31041: - [~huwh] I just see you comments. I think it's mostly

[jira] [Commented] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-31098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689678#comment-17689678 ] Sergey Nuyanzin commented on FLINK-31098: - Do we really need {{ARRAY_SIZE}}? I'm

[jira] [Comment Edited] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-31098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689678#comment-17689678 ] Sergey Nuyanzin edited comment on FLINK-31098 at 2/16/23 10:25 AM: ---

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689681#comment-17689681 ] Matthias Pohl commented on FLINK-31036: --- Yes, sorry for the confusion. I must have

[GitHub] [flink] FangYongs commented on pull request #21901: [FLINK-30968][sql-client] Sql client supports dynamic config to open session

FangYongs commented on PR #21901: URL: https://github.com/apache/flink/pull/21901#issuecomment-1432863685 Hi @JingsongLi Can you help to review this PR? THX -- 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] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689684#comment-17689684 ] Martijn Visser commented on FLINK-18356: [~mapohl] We should check if they still

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689645#comment-17689645 ] Matthias Pohl edited comment on FLINK-18356 at 2/16/23 10:31 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689686#comment-17689686 ] Matthias Pohl commented on FLINK-18356: --- I verified that [20230216.1|https://dev.

[jira] [Updated] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-31098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31098: Parent: FLINK-6810 Issue Type: Sub-task (was: New Feature) > Add ARRAY_SIZE suppo

[jira] [Commented] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-31098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689687#comment-17689687 ] Sergey Nuyanzin commented on FLINK-31098: - I converted it into a subtask of a mo

[GitHub] [flink] snuyanzin commented on pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

snuyanzin commented on PR #21947: URL: https://github.com/apache/flink/pull/21947#issuecomment-1432875363 Thank you for your contribution. To be honest I'm a bit skeptic about `ARRAY_SIZE`, please see at my comment in corresponding jira issue. -- This is an automated message from the A

[GitHub] [flink] snuyanzin commented on a diff in pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

snuyanzin commented on code in PR #21947: URL: https://github.com/apache/flink/pull/21947#discussion_r1108313393 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -160,6 +160,142 @@ Stream getTestSetSp

[GitHub] [flink] snuyanzin commented on a diff in pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

snuyanzin commented on code in PR #21947: URL: https://github.com/apache/flink/pull/21947#discussion_r1108313393 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -160,6 +160,142 @@ Stream getTestSetSp

[GitHub] [flink] snuyanzin commented on a diff in pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

snuyanzin commented on code in PR #21947: URL: https://github.com/apache/flink/pull/21947#discussion_r1108313393 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -160,6 +160,142 @@ Stream getTestSetSp

[GitHub] [flink] snuyanzin commented on a diff in pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

snuyanzin commented on code in PR #21947: URL: https://github.com/apache/flink/pull/21947#discussion_r1108331796 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -178,6 +178,35 @@ ANY, and(logical(LogicalType

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689697#comment-17689697 ] Piotr Nowojski commented on FLINK-31036: I will take a look. When trying to re

[jira] [Created] (FLINK-31105) SqlClient doesn't respond to QUIT or HELP command even though it's mentioned in the welcome message

Matthias Pohl created FLINK-31105: - Summary: SqlClient doesn't respond to QUIT or HELP command even though it's mentioned in the welcome message Key: FLINK-31105 URL: https://issues.apache.org/jira/browse/FLINK-31

[jira] [Updated] (FLINK-31105) SqlClient doesn't respond to QUIT or HELP command even though it's mentioned in the welcome message

[ https://issues.apache.org/jira/browse/FLINK-31105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31105: -- Description: I test it with 1.17 (21158c06) and 1.16.1: {code} [...] Welcome! Enter 'H

[jira] [Updated] (FLINK-31105) SqlClient doesn't respond to QUIT or HELP command even though it's mentioned in the welcome message

[ https://issues.apache.org/jira/browse/FLINK-31105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31105: -- Description: I test it with 1.17 (21158c06) and 1.16.1: {code} [...] Welcome! Enter 'H

[jira] [Comment Edited] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689697#comment-17689697 ] Piotr Nowojski edited comment on FLINK-31036 at 2/16/23 11:13 AM:

  1   2   3   4   >