[GitHub] [flink] syhily commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r960281854 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SharedSplitAssigner.java: ## @@ -83,66 +75,8 @@ publ

[GitHub] [flink] syhily commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r960280066 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumStateSerializer.java: ## @@ -54,57 +55,37 @@

[GitHub] [flink] syhily commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r960280066 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumStateSerializer.java: ## @@ -54,57 +55,37 @@

[GitHub] [flink] syhily commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r960277130 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java: ## @@ -114,7 +135,12 @@ public v

[GitHub] [flink] imaffe commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

imaffe commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r960272872 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SharedSplitAssigner.java: ## @@ -83,66 +75,8 @@ publ

[GitHub] [flink] syhily commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r960274803 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java: ## @@ -164,7 +164,7 @@ private void readObject

[jira] [Created] (FLINK-29165) Operator quickstart examples using code

Gaurav Miglani created FLINK-29165: -- Summary: Operator quickstart examples using code Key: FLINK-29165 URL: https://issues.apache.org/jira/browse/FLINK-29165 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-29164) There is a problem when compiling Flink 1.15.rc-2 in Windows operations

mindest liu created FLINK-29164: --- Summary: There is a problem when compiling Flink 1.15.rc-2 in Windows operations Key: FLINK-29164 URL: https://issues.apache.org/jira/browse/FLINK-29164 Project: Flink

[jira] [Commented] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

[ https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598755#comment-17598755 ] Yun Gao commented on FLINK-28941: - Hi [~hxb] Sorry for the delay, I'm still confirming t

[GitHub] [flink] imaffe commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

imaffe commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r960176312 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java: ## @@ -114,7 +135,12 @@ public v

[GitHub] [flink] coder-zjh commented on a diff in pull request #20724: [FLINK-27291][docs-zh] Translate the "List of Data Types" section of "Data Types" in to Chinese'

coder-zjh commented on code in PR #20724: URL: https://github.com/apache/flink/pull/20724#discussion_r960239167 ## .idea/vcs.xml: ## @@ -22,4 +22,4 @@ - + Review Comment: Yes,I don't know when this file changed and I still committed it... -- This is an au

[GitHub] [flink] liuzhuang2017 commented on pull request #19950: [hotfix] [docs] Translate a Chinese comment into English

liuzhuang2017 commented on PR #19950: URL: https://github.com/apache/flink/pull/19950#issuecomment-1233760978 @diohabara Sorry, I don't have permission to merge this. @dianfu , Sorry to bother you, can you help @diohabara merge it? Thank you. -- This is an automated message from the Apac

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19964: [FLINK-27291][docs-zh] Translate the "List of Data Types" section of…

ChengkaiYang2022 commented on PR #19964: URL: https://github.com/apache/flink/pull/19964#issuecomment-1233739560 No response from the @cason0126. Open another [PR](https://github.com/apache/flink/pull/20724) to continue the rest work. -- This is an automated message from the Apache Git Se

[GitHub] [flink] HuangXingBo commented on pull request #20726: [FLINK-29161][tests] Fix the built docker image name

HuangXingBo commented on PR #20726: URL: https://github.com/apache/flink/pull/20726#issuecomment-1233739320 https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=2060&view=logs&j=d63a5fc4-24ea-51df-9ade-fa4330af161c&t=977479f1-49ea-5c4c-884c-4646ed1443ab my private Azure has pass

[GitHub] [flink] dianfu commented on a diff in pull request #20685: [FLINK-28429][python] Optimize PyFlink tests

dianfu commented on code in PR #20685: URL: https://github.com/apache/flink/pull/20685#discussion_r960158570 ## flink-python/dev/dev-requirements.txt: ## @@ -30,7 +30,7 @@ numpy>=1.21.4,<1.22.0; python_version >= '3.7' numpy>=1.14.3,<1.20; python_version < '3.7' fastavro>=1.1.

[GitHub] [flink] ChengkaiYang2022 commented on pull request #20724: Datatypes translate

ChengkaiYang2022 commented on PR #20724: URL: https://github.com/apache/flink/pull/20724#issuecomment-1233738503 Please change the title to '[FLINK-27291][docs-zh] Translate the "List of Data Types" section of "Data Types" in to Chinese'] and the git message should start with '[FLINK-2729

[GitHub] [flink] ChengkaiYang2022 commented on a diff in pull request #20724: Datatypes translate

ChengkaiYang2022 commented on code in PR #20724: URL: https://github.com/apache/flink/pull/20724#discussion_r960213049 ## .idea/vcs.xml: ## @@ -22,4 +22,4 @@ - + Review Comment: Maybe we shouldn't change vcs.xml file? ## docs/content.zh/docs/dev/ta

[GitHub] [flink-table-store] SteNicholas opened a new pull request, #283: Bump Flink version to 1.15.2

SteNicholas opened a new pull request, #283: URL: https://github.com/apache/flink-table-store/pull/283 Flink 1.15.2 version has already released. Bump Flink version to 1.15.2. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [flink] flinkbot commented on pull request #20729: [BP-1.14][FLINK-29138][table-planner] fix project can not be pushed into lookup source

flinkbot commented on PR #20729: URL: https://github.com/apache/flink/pull/20729#issuecomment-1233715031 ## CI report: * eb171ec69ac540cad0cc61410af02dc6c0ece78a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] lincoln-lil opened a new pull request, #20729: [BP-1.14][FLINK-29138][table-planner] fix project can not be pushed into lookup source

lincoln-lil opened a new pull request, #20729: URL: https://github.com/apache/flink/pull/20729 backport to 1.14 -- 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 unsubscri

[GitHub] [flink] lincoln-lil commented on pull request #20728: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

lincoln-lil commented on PR #20728: URL: https://github.com/apache/flink/pull/20728#issuecomment-1233710239 this branch has irrelevant commits -- 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

[GitHub] [flink] lincoln-lil closed pull request #20728: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

lincoln-lil closed pull request #20728: [FLINK-29138][table-planner] fix project can not be pushed into lookup source URL: https://github.com/apache/flink/pull/20728 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #20728: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

flinkbot commented on PR #20728: URL: https://github.com/apache/flink/pull/20728#issuecomment-1233707505 ## CI report: * a74117653bfa49eac4adbc0a0dc1af28a156060c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] lincoln-lil opened a new pull request, #20728: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

lincoln-lil opened a new pull request, #20728: URL: https://github.com/apache/flink/pull/20728 backport to 1.14 -- 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 unsubscri

[jira] [Created] (FLINK-29163) There is a problem when compiling Flink 1.15.rc-2 and flink-1.14.3-rc1 in Windows operations

mindest liu created FLINK-29163: --- Summary: There is a problem when compiling Flink 1.15.rc-2 and flink-1.14.3-rc1 in Windows operations Key: FLINK-29163 URL: https://issues.apache.org/jira/browse/FLINK-29163

[GitHub] [flink] flinkbot commented on pull request #20727: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

flinkbot commented on PR #20727: URL: https://github.com/apache/flink/pull/20727#issuecomment-1233698241 ## CI report: * 8df9102dd267fc2f9d66cf935c008d09c1c0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-29160) 在windows 编译flink 1.15.rc-2和flink-1.14.3-rc1 时出现问题 There is a problem when compiling Flink 1.15.rc-2 and flink-1.14.3-rc1 in windows operations

[ https://issues.apache.org/jira/browse/FLINK-29160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598726#comment-17598726 ] mindest liu commented on FLINK-29160: - Compile Flink 1.14.3-rc1 on Windows platform

[jira] [Closed] (FLINK-29053) Hybrid shuffle has concurrent modification of buffer when compression is enabled

[ https://issues.apache.org/jira/browse/FLINK-29053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29053. Resolution: Fixed master (1.16): 8b8245ba46b25c2617d91cff3d3a44b99879d9f2 > Hybrid shuffle has co

[GitHub] [flink] xintongsong closed pull request #20647: [FLINK-29053] Hybrid shuffle has concurrent modification of buffer when compression is enabled

xintongsong closed pull request #20647: [FLINK-29053] Hybrid shuffle has concurrent modification of buffer when compression is enabled URL: https://github.com/apache/flink/pull/20647 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] lincoln-lil opened a new pull request, #20727: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

lincoln-lil opened a new pull request, #20727: URL: https://github.com/apache/flink/pull/20727 backport to 1.15 -- 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 unsubscri

[jira] [Updated] (FLINK-29160) 在windows 编译flink 1.15.rc-2和flink-1.14.3-rc1 时出现问题 There is a problem when compiling Flink 1.15.rc-2 and flink-1.14.3-rc1 in windows operations

[ https://issues.apache.org/jira/browse/FLINK-29160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mindest liu updated FLINK-29160: Description: Compile Flink 1.15.2 on Windows platform and it appears   Error creating assembly a

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #281: [FLINK-29154] Support LookupTableSource for table store

JingsongLi commented on code in PR #281: URL: https://github.com/apache/flink-table-store/pull/281#discussion_r960178500 ## flink-table-store-common/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java: ## @@ -91,15 +91,17 @@ public Predicate visit(C

[jira] [Commented] (FLINK-29093) LookupJoinITCase failed with InternalCompilerException

[ https://issues.apache.org/jira/browse/FLINK-29093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598718#comment-17598718 ] Xingbo Huang commented on FLINK-29093: -- [~renqs] Any progress on this issue？ > Loo

[jira] [Commented] (FLINK-29093) LookupJoinITCase failed with InternalCompilerException

[ https://issues.apache.org/jira/browse/FLINK-29093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598717#comment-17598717 ] Xingbo Huang commented on FLINK-29093: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29153) KafkaConsumerThread should catch WakeupException when committing offsets

[ https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598715#comment-17598715 ] Xingbo Huang commented on FLINK-29153: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

[ https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598714#comment-17598714 ] Xingbo Huang commented on FLINK-28941: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598711#comment-17598711 ] Zhu Zhu commented on FLINK-28980: - Thanks for helping with the release testing! [~SleePy

[jira] [Closed] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28980. --- Resolution: Done > Release Testing: Verify FLIP-168 speculative execution >

[GitHub] [flink] flinkbot commented on pull request #20726: [FLINK-29161][tests] Fix the built docker image name

flinkbot commented on PR #20726: URL: https://github.com/apache/flink/pull/20726#issuecomment-1233676027 ## CI report: * 8c5483755820f92828d21c348c7643400f1dee49 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-29162) missCounter and loadCount metrics also increase even if cache hint

dalongliu created FLINK-29162: - Summary: missCounter and loadCount metrics also increase even if cache hint Key: FLINK-29162 URL: https://issues.apache.org/jira/browse/FLINK-29162 Project: Flink

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #148: [FLINK-28906] Add AlgoOperator for AgglomerativeClustering

zhipeng93 commented on code in PR #148: URL: https://github.com/apache/flink-ml/pull/148#discussion_r960175355 ## flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/agglomerativeclustering/AgglomerativeClusteringParams.java: ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Ap

[jira] [Updated] (FLINK-29161) Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found

[ https://issues.apache.org/jira/browse/FLINK-29161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29161: - Affects Version/s: 1.15.2 1.14.5 > Run kubernetes application HA test fai

[jira] [Updated] (FLINK-29161) Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found

[ https://issues.apache.org/jira/browse/FLINK-29161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29161: --- Labels: pull-request-available test-stability (was: test-stability) > Run kubernetes applic

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #148: [FLINK-28906] Add AlgoOperator for AgglomerativeClustering

zhipeng93 commented on code in PR #148: URL: https://github.com/apache/flink-ml/pull/148#discussion_r958225992 ## flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/agglomerativeclustering/AgglomerativeClusteringParams.java: ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Ap

[GitHub] [flink] HuangXingBo opened a new pull request, #20726: [FLINK-29161][tests] Fix the built docker image name

HuangXingBo opened a new pull request, #20726: URL: https://github.com/apache/flink/pull/20726 ## What is the purpose of the change *This pull request will fix the built docker image name since we have switch from debian to ubuntu in https://github.com/apache/flink-docker/pull/130*

[jira] [Updated] (FLINK-29161) Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found

[ https://issues.apache.org/jira/browse/FLINK-29161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29161: - Component/s: flink-docker > Run kubernetes application HA test failed with unable to prepare con

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #148: [FLINK-28906] Add AlgoOperator for AgglomerativeClustering

yunfengzhou-hub commented on code in PR #148: URL: https://github.com/apache/flink-ml/pull/148#discussion_r960171818 ## flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/AgglomerativeClusteringTest.java: ## @@ -0,0 +1,312 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] lsyldliu commented on pull request #20628: [FLINK-29022][docs][table] Add document for CREATE FUNCTIOn USING JAR feature

lsyldliu commented on PR #20628: URL: https://github.com/apache/flink/pull/20628#issuecomment-1233670779 @wuchong -- 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 unsubsc

[GitHub] [flink] lsyldliu commented on pull request #20630: [FLINK-29023][docs][table] Updating Jar statement document

lsyldliu commented on PR #20630: URL: https://github.com/apache/flink/pull/20630#issuecomment-1233670577 @wuchong -- 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 unsubs

[GitHub] [flink] lsyldliu commented on pull request #20713: [FLINK-28897][runtime] Fix bug of failing to generate Jobgraph when using scalar udf and enable checkpoint

lsyldliu commented on PR #20713: URL: https://github.com/apache/flink/pull/20713#issuecomment-1233670182 cc @zhuzhurk @wuchong -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific commen

[jira] [Assigned] (FLINK-29161) Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found

[ https://issues.apache.org/jira/browse/FLINK-29161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-29161: Assignee: Xingbo Huang > Run kubernetes application HA test failed with unable to prepare

[GitHub] [flink] PatrickRen commented on pull request #20676: [FLINK-28948][table] Increase test coverage for lookup full caching + fix metrics

PatrickRen commented on PR #20676: URL: https://github.com/apache/flink/pull/20676#issuecomment-1233658928 @SmirAlex looks like there are new code merged in master 😞 Could you resolve these conflicts? Thanks -- This is an automated message from the Apache Git Service. To respond to the m

[jira] [Created] (FLINK-29161) Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found

Xingbo Huang created FLINK-29161: Summary: Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found Key: FLINK-29161 URL: https://issues.

[jira] [Closed] (FLINK-18778) Support the SupportsProjectionPushDown interface for LookupTableSource

[ https://issues.apache.org/jira/browse/FLINK-18778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18778. Resolution: Duplicate > Support the SupportsProjectionPushDown interface for LookupTableSource > -

[GitHub] [flink] JingsongLi merged pull request #20717: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

JingsongLi merged PR #20717: URL: https://github.com/apache/flink/pull/20717 -- 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

[jira] [Commented] (FLINK-29160) 在windows 编译flink 1.15.rc-2时出现问题

[ https://issues.apache.org/jira/browse/FLINK-29160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598702#comment-17598702 ] Xingbo Huang commented on FLINK-29160: -- Please use English to create JIRA > 在windo

[jira] [Created] (FLINK-29160) 在windows 编译flink 1.15.rc-2时出现问题

mindest liu created FLINK-29160: --- Summary: 在windows 编译flink 1.15.rc-2时出现问题 Key: FLINK-29160 URL: https://issues.apache.org/jira/browse/FLINK-29160 Project: Flink Issue Type: Bug Compo

[GitHub] [flink] xintongsong commented on pull request #20647: [FLINK-29053] Hybrid shuffle has concurrent modification of buffer when compression is enabled

xintongsong commented on PR #20647: URL: https://github.com/apache/flink/pull/20647#issuecomment-1233640320 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific commen

[jira] [Commented] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

[ https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598699#comment-17598699 ] Xingbo Huang commented on FLINK-28941: -- Hi [~gaoyunhaii] Is there any progress on t

[jira] [Commented] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

[ https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598698#comment-17598698 ] Xingbo Huang commented on FLINK-28941: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Closed] (FLINK-28974) Add doc for the API and Option of sql gateway rest endpoint

[ https://issues.apache.org/jira/browse/FLINK-28974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28974. Fix Version/s: 1.16.0 Resolution: Done master (1.16): 55902053a4cf6bf125f7d94c0cf397eaf9154

[GitHub] [flink] xintongsong closed pull request #20622: [FLINK-28974][sql-gateway]Add doc for the API and Option of sql gateway

xintongsong closed pull request #20622: [FLINK-28974][sql-gateway]Add doc for the API and Option of sql gateway URL: https://github.com/apache/flink/pull/20622 -- 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

[GitHub] [flink] lincoln-lil commented on pull request #20717: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

lincoln-lil commented on PR #20717: URL: https://github.com/apache/flink/pull/20717#issuecomment-1233631619 an unstable connector case: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=40566&view=ms.vss-test-web.build-test-results-tab successed in my own pipeline

[GitHub] [flink] lincoln-lil commented on pull request #20717: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

lincoln-lil commented on PR #20717: URL: https://github.com/apache/flink/pull/20717#issuecomment-1233627474 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific commen

[GitHub] [flink] mas-chen commented on a diff in pull request #20215: [FLINK-27479] [Connectors / Common] introduce availability helper to manage future for hybr…

mas-chen commented on code in PR #20215: URL: https://github.com/apache/flink/pull/20215#discussion_r960134253 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java: ## @@ -231,16 +236,7 @@ private void setCu

[GitHub] [flink] mas-chen commented on a diff in pull request #20215: [FLINK-27479] [Connectors / Common] introduce availability helper to manage future for hybr…

mas-chen commented on code in PR #20215: URL: https://github.com/apache/flink/pull/20215#discussion_r960131874 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/MultipleFuturesAvailabilityHelper.java: ## @@ -57,13 +57,17 @@ public CompletableFuture getA

[GitHub] [flink] mas-chen commented on a diff in pull request #20215: [FLINK-27479] [Connectors / Common] introduce availability helper to manage future for hybr…

mas-chen commented on code in PR #20215: URL: https://github.com/apache/flink/pull/20215#discussion_r960131874 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/MultipleFuturesAvailabilityHelper.java: ## @@ -57,13 +57,17 @@ public CompletableFuture getA

[jira] [Updated] (FLINK-25009) Output slotSharingGroup as part of JsonGraph

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

[jira] [Updated] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25813: --- Labels: pull-request-available stale-assigned test-stability (was: pull-request-available t

[jira] [Updated] (FLINK-25358) New File Sink end-to-end test failed due to TM could not connect to RM

[ https://issues.apache.org/jira/browse/FLINK-25358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25358: --- Labels: auto-deprioritized-major auto-deprioritized-minor test-stability (was: auto-depri

[jira] [Updated] (FLINK-24867) E2e tests take longer than the maximum 310 minutes on AZP

[ https://issues.apache.org/jira/browse/FLINK-24867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24867: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor test

[jira] [Updated] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27916: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-25319) Quickstarts Scala nightly end-to-end test failed due to akka rpc server failed to start

[ https://issues.apache.org/jira/browse/FLINK-25319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25319: --- Labels: auto-deprioritized-major auto-deprioritized-minor test-stability (was: auto-depri

[GitHub] [flink] MartijnVisser commented on pull request #20235: [Flink-14101][Connectors][Jdbc] SQL Server dialect

MartijnVisser commented on PR #20235: URL: https://github.com/apache/flink/pull/20235#issuecomment-1233254758 Since we are currently in feature freeze, this can only be merged when the release branch is cut in the next week or so -- This is an automated message from the Apache Git Service

[GitHub] [flink] qingwei91 commented on pull request #20235: [Flink-14101][Connectors][Jdbc] SQL Server dialect

qingwei91 commented on PR #20235: URL: https://github.com/apache/flink/pull/20235#issuecomment-1233231023 Hi @JingGe thanks for the approval, what else do we need to be able to merge this? Should I reach out to other contributor/committer? -- This is an automated message from the Apache G

[GitHub] [flink] flinkbot commented on pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

flinkbot commented on PR #20725: URL: https://github.com/apache/flink/pull/20725#issuecomment-1233223200 ## CI report: * 74eda3cfacd7ca83e48da4ebd4d9900584e7553a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28934) Pulsar Source put all the splits to only one parallelism when using Exclusive subscription

[ https://issues.apache.org/jira/browse/FLINK-28934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28934: --- Labels: bug pull-request-available stale-critical (was: bug stale-critical) > Pulsar Source

[GitHub] [flink] syhily opened a new pull request, #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily opened a new pull request, #20725: URL: https://github.com/apache/flink/pull/20725 ## What is the purpose of the change Pulsar Source put all the splits to only one parallelism when using Exclusive subscription. This is because we misunderstand the lifecycle of the `SourceEnum

[GitHub] [flink] flinkbot commented on pull request #20724: Datatypes translate

flinkbot commented on PR #20724: URL: https://github.com/apache/flink/pull/20724#issuecomment-1233218845 ## CI report: * 1f2c62c331249fc1f5bf0da42410efcb61790b2a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] coder-zjh opened a new pull request, #20724: Datatypes translate

coder-zjh opened a new pull request, #20724: URL: https://github.com/apache/flink/pull/20724 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] diohabara commented on pull request #19950: [hotfix] [docs] Translate a Chinese comment into English

diohabara commented on PR #19950: URL: https://github.com/apache/flink/pull/19950#issuecomment-1233199027 @liuzhuang2017 please merge 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 above to go to the sp

[jira] [Closed] (FLINK-29100) Deployment with last-state upgrade mode stuck after initial error

[ https://issues.apache.org/jira/browse/FLINK-29100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed FLINK-29100. Resolution: Fixed > Deployment with last-state upgrade mode stuck after initial error > --

[jira] [Updated] (FLINK-29100) Deployment with last-state upgrade mode stuck after initial error

[ https://issues.apache.org/jira/browse/FLINK-29100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-29100: - Fix Version/s: kubernetes-operator-1.2.0 > Deployment with last-state upgrade mode stuck after i

[GitHub] [flink-kubernetes-operator] tweise merged pull request #356: [FLINK-29100] Relax upgrade checks to allow stateless restart when no stable spec is present

tweise merged PR #356: URL: https://github.com/apache/flink-kubernetes-operator/pull/356 -- 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

[GitHub] [flink] ferenc-csaky commented on pull request #20265: [FLINK-25910][runtime][security] Propagate obtained delegation tokens to TaskManagers

ferenc-csaky commented on PR #20265: URL: https://github.com/apache/flink/pull/20265#issuecomment-1233134897 > > One general question: is catching Throwable a good thing here? I see that there are rethrowIfFatalError calls and it is a common pattern in the existing code, but that method onl

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: stdout > Release Testing: Verify FLIP-168 speculative execution > --

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: flink-root-taskexecutor-0-VM_199_24_centos.log > Release Testing: Verify FLIP-168 speculativ

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: screenshot1 > Release Testing: Verify FLIP-168 speculative execution > -

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: screenshot2 > Release Testing: Verify FLIP-168 speculative execution > -

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: flink-root-taskexecutor-0-VM_38_195_centos.log > Release Testing: Verify FLIP-168 speculativ

[jira] [Updated] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-28980: - Attachment: flink-root-standalonesession-0-VM_38_195_centos.log > Release Testing: Verify FLIP-168 specu

[jira] [Commented] (FLINK-28980) Release Testing: Verify FLIP-168 speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598422#comment-17598422 ] Biao Liu commented on FLINK-28980: -- I've tested the scenario, and it looks good to me.

[GitHub] [flink-kubernetes-operator] tweise commented on pull request #356: [FLINK-29100] Relax upgrade checks to allow stateless restart when no stable spec is present

tweise commented on PR #356: URL: https://github.com/apache/flink-kubernetes-operator/pull/356#issuecomment-1233013804 Created https://issues.apache.org/jira/browse/FLINK-29159 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Created] (FLINK-29159) Revisit/harden initial deployment logic

Thomas Weise created FLINK-29159: Summary: Revisit/harden initial deployment logic Key: FLINK-29159 URL: https://issues.apache.org/jira/browse/FLINK-29159 Project: Flink Issue Type: Technical

[GitHub] [flink] lincoln-lil commented on pull request #20717: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

lincoln-lil commented on PR #20717: URL: https://github.com/apache/flink/pull/20717#issuecomment-1233008395 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific commen

[jira] [Updated] (FLINK-27919) Add FLIP-27-based Data Generator Source

[ https://issues.apache.org/jira/browse/FLINK-27919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27919: - Fix Version/s: 1.17.0 > Add FLIP-27-based Data Generator Source > --

[jira] [Commented] (FLINK-29110) Support to mount a dynamically-created pvc for JM and TM in standalone mode with StatefulSet.

[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598390#comment-17598390 ] Peng Yuan commented on FLINK-29110: --- [~gyfora] Okay, I will make a FLIP to describe th

[GitHub] [flink-kubernetes-operator] Grypse commented on pull request #357: [FLINK-29110] Use StatefulSet instead of Deployment to deploy JM and …

Grypse commented on PR #357: URL: https://github.com/apache/flink-kubernetes-operator/pull/357#issuecomment-1232956892 @gyfora @wangyang0918 @morhidi @usamj Thanks for yours review. I will make a FLIP to describe the proposal. -- This is an automated message from the Apache Git Service.

[GitHub] [flink-kubernetes-operator] tweise commented on a diff in pull request #356: [FLINK-29100] Relax upgrade checks to allow stateless restart when no stable spec is present

tweise commented on code in PR #356: URL: https://github.com/apache/flink-kubernetes-operator/pull/356#discussion_r959559030 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -98,12 +99,39 @@

[GitHub] [flink-kubernetes-operator] tweise commented on a diff in pull request #356: [FLINK-29100] Relax upgrade checks to allow stateless restart when no stable spec is present

tweise commented on code in PR #356: URL: https://github.com/apache/flink-kubernetes-operator/pull/356#discussion_r959557420 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -98,12 +99,39 @@

  1   2   3   >