[GitHub] [flink] fredia commented on a diff in pull request #20585: [FLINK-28976][state/changelog] Don't add extra delay to the 1st materialization

2022-08-25 Thread GitBox
fredia commented on code in PR #20585: URL: https://github.com/apache/flink/pull/20585#discussion_r955709811 ## flink-state-backends/flink-statebackend-common/src/test/java/org/apache/flink/state/common/PeriodicMaterializationManagerTest.java: ## @@ -0,0 +1,66 @@ +/* + * License

[jira] [Commented] (FLINK-26394) CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator executor.

2022-08-25 Thread Gen Luo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585177#comment-17585177 ] Gen Luo commented on FLINK-26394: - Hi [~gezhiwei8899], The issue should be existing in a

[GitHub] [flink] WencongLiu commented on pull request #20678: [FLINK-29097][sql-gateway]Moving json se/deserializers from sql-gateway-api to sql-gateway

2022-08-25 Thread GitBox
WencongLiu commented on PR #20678: URL: https://github.com/apache/flink/pull/20678#issuecomment-1228110260 @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

[GitHub] [flink] pltbkd commented on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-08-25 Thread GitBox
pltbkd commented on PR #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1228108645 @gezhiwei8899 The commit is revert on 1.15 due to FLINK-27148. Both of the issues are now fixed on the master branch, but are not included in any 1.15 branch. I'm now trying to back po

[GitHub] [flink] pltbkd commented on pull request #20683: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.15

2022-08-25 Thread GitBox
pltbkd commented on PR #20683: URL: https://github.com/apache/flink/pull/20683#issuecomment-1228103758 @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. T

[GitHub] [flink] pltbkd commented on pull request #20682: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.14

2022-08-25 Thread GitBox
pltbkd commented on PR #20682: URL: https://github.com/apache/flink/pull/20682#issuecomment-1228103695 @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. T

[jira] [Commented] (FLINK-28968) Release Testing: Verify FLIP-234 LOOKUP Hint

2022-08-25 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585173#comment-17585173 ] xuyang commented on FLINK-28968: Hi,[~lincoln.86xy]. The testing work is finished, and i

[GitHub] [flink] pltbkd commented on pull request #20681: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.13.

2022-08-25 Thread GitBox
pltbkd commented on PR #20681: URL: https://github.com/apache/flink/pull/20681#issuecomment-1228103654 @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. T

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

2022-08-25 Thread nobleyd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585171#comment-17585171 ] nobleyd commented on FLINK-27341: - Hi, I want to known which release will fix this issue

[jira] [Updated] (FLINK-28928) Add E2E test for hybrid shuffle mode

2022-08-25 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28928: - Issue Type: Improvement (was: Bug) > Add E2E test for hybrid shuffle mode > ---

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

2022-08-25 Thread zhilinli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585169#comment-17585169 ] zhilinli commented on FLINK-25336: -- Is the ultimate solution only to upgrade Kafkfa? >

[jira] [Commented] (FLINK-29105) KubernetesStateHandleStoreTest.testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents failed with AssertionFailedError

2022-08-25 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585166#comment-17585166 ] Xingbo Huang commented on FLINK-29105: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29018) KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException

2022-08-25 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585165#comment-17585165 ] Xingbo Huang commented on FLINK-29018: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot commented on pull request #20682: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.14

2022-08-25 Thread GitBox
flinkbot commented on PR #20682: URL: https://github.com/apache/flink/pull/20682#issuecomment-1228083861 ## CI report: * 0d74aae52de1e81fc295d75ce17c22b6381767b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #20683: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.15

2022-08-25 Thread GitBox
flinkbot commented on PR #20683: URL: https://github.com/apache/flink/pull/20683#issuecomment-1228083915 ## CI report: * 2df58244ec548ed59efc136f9a978a5a19953a53 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pltbkd commented on pull request #20683: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.15

2022-08-25 Thread GitBox
pltbkd commented on PR #20683: URL: https://github.com/apache/flink/pull/20683#issuecomment-1228083279 @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. T

[jira] [Commented] (FLINK-29107) Upgrade spotless version to improve spotless check efficiency

2022-08-25 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585163#comment-17585163 ] Yun Tang commented on FLINK-29107: -- [~chesnay]  Unfortunately to hear this:(, could you

[GitHub] [flink] pltbkd commented on pull request #20682: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.14

2022-08-25 Thread GitBox
pltbkd commented on PR #20682: URL: https://github.com/apache/flink/pull/20682#issuecomment-1228082950 @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. T

[GitHub] [flink] flinkbot commented on pull request #20681: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.13.

2022-08-25 Thread GitBox
flinkbot commented on PR #20681: URL: https://github.com/apache/flink/pull/20681#issuecomment-1228081391 ## CI report: * 7a9135403876f4cd10d02758f2992cc30d534480 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pltbkd commented on pull request #20681: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.13.

2022-08-25 Thread GitBox
pltbkd commented on PR #20681: URL: https://github.com/apache/flink/pull/20681#issuecomment-1228080726 @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. T

[GitHub] [flink] pltbkd opened a new pull request, #20683: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.15

2022-08-25 Thread GitBox
pltbkd opened a new pull request, #20683: URL: https://github.com/apache/flink/pull/20683 ## 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 on

[GitHub] [flink] pltbkd opened a new pull request, #20682: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.14

2022-08-25 Thread GitBox
pltbkd opened a new pull request, #20682: URL: https://github.com/apache/flink/pull/20682 ## 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 on

[GitHub] [flink] pltbkd opened a new pull request, #20681: [Flink-26394][FLINK-27148] Fix checkpoint coordinator triggering issue on 1.13.

2022-08-25 Thread GitBox
pltbkd opened a new pull request, #20681: URL: https://github.com/apache/flink/pull/20681 ## 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 on

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

2022-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585152#comment-17585152 ] Gyula Fora commented on FLINK-29110: What would be the benefit of adding support for

[GitHub] [flink] wangyang0918 commented on pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-25 Thread GitBox
wangyang0918 commented on PR #20673: URL: https://github.com/apache/flink/pull/20673#issuecomment-1228046277 @XComp Oh, my bad. I should not introduce this concurrent issue here. Either the `callbackInvocationCount` needs to be asserted in the whenComplete, or I should execute `CompletableF

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

2022-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29110: --- Issue Type: Improvement (was: New Feature) > Support to mount a dynamically-created pvc for JM and

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

2022-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29110: --- Component/s: Kubernetes Operator (was: Deployment / Kubernetes) > Support to mo

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

2022-08-25 Thread Peng Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585133#comment-17585133 ] Peng Yuan commented on FLINK-29110: --- [~wangyang0918] [~gyfora] [~usamj]  > Support to

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

2022-08-25 Thread Peng Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Yuan updated FLINK-29110: -- Description: Use StatefulSet instead of Deployment to deploy JM and TM to support mount a dynamically

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

2022-08-25 Thread Peng Yuan (Jira)
Peng Yuan created FLINK-29110: - Summary: Support to mount a dynamically-created pvc for JM and TM in standalone mode with StatefulSet. Key: FLINK-29110 URL: https://issues.apache.org/jira/browse/FLINK-29110

[GitHub] [flink] akshathsk closed pull request #20680: Fixed Flaky Test Case CheckpointCoordinatorTest#testTriggerAndDeclineCheckpointComplex

2022-08-25 Thread GitBox
akshathsk closed pull request #20680: Fixed Flaky Test Case CheckpointCoordinatorTest#testTriggerAndDeclineCheckpointComplex URL: https://github.com/apache/flink/pull/20680 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] akshathsk opened a new pull request, #20680: Fixed Flaky Test Case CheckpointCoordinatorTest#testTriggerAndDeclineCheckpointComplex

2022-08-25 Thread GitBox
akshathsk opened a new pull request, #20680: URL: https://github.com/apache/flink/pull/20680 ## 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

[jira] [Commented] (FLINK-28939) Release Testing: Verify FLIP-241 ANALYZE TABLE

2022-08-25 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585118#comment-17585118 ] Yunhong Zheng commented on FLINK-28939: --- Hi, [~godfreyhe] , I have finished the te

[jira] [Closed] (FLINK-27773) Introduce the E2E tests for SQL Gateway

2022-08-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-27773. - Resolution: Fixed > Introduce the E2E tests for SQL Gateway > -

[jira] [Commented] (FLINK-27773) Introduce the E2E tests for SQL Gateway

2022-08-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585117#comment-17585117 ] Shengkai Fang commented on FLINK-27773: --- Merged into master: 0fd718c03d891e5e235c

[jira] [Comment Edited] (FLINK-29006) PulsarSourceITCase failed with Could not acquire the minimum required resources.

2022-08-25 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585116#comment-17585116 ] Yufan Sheng edited comment on FLINK-29006 at 8/26/22 3:32 AM:

[jira] [Comment Edited] (FLINK-29006) PulsarSourceITCase failed with Could not acquire the minimum required resources.

2022-08-25 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585116#comment-17585116 ] Yufan Sheng edited comment on FLINK-29006 at 8/26/22 3:32 AM:

[jira] [Commented] (FLINK-29006) PulsarSourceITCase failed with Could not acquire the minimum required resources.

2022-08-25 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585116#comment-17585116 ] Yufan Sheng commented on FLINK-29006: - [~renqs] I have checked the log. It seems lik

[jira] (FLINK-29006) PulsarSourceITCase failed with Could not acquire the minimum required resources.

2022-08-25 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29006 ] Yufan Sheng deleted comment on FLINK-29006: - was (Author: syhily): [~hxbks2ks] This should get fixed in latest release-1.15. Can you check it? > PulsarSourceITCase failed with Could not acqu

[GitHub] [flink] fsk119 merged pull request #20609: [FLINK-27773][sql-gateway]Introduce the rest E2E tests for SQL Gateway

2022-08-25 Thread GitBox
fsk119 merged PR #20609: URL: https://github.com/apache/flink/pull/20609 -- 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

[jira] [Commented] (FLINK-29108) Kubernetes operator: Support queryable state

2022-08-25 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585114#comment-17585114 ] Hangxiang Yu commented on FLINK-29108: -- Hi, [~rcroc...@newrelic.com] . I see "Quera

[jira] [Commented] (FLINK-29006) PulsarSourceITCase failed with Could not acquire the minimum required resources.

2022-08-25 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585110#comment-17585110 ] Yufan Sheng commented on FLINK-29006: - [~hxbks2ks] This should get fixed in latest r

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

2022-08-25 Thread GitBox
SmirAlex commented on PR #20676: URL: https://github.com/apache/flink/pull/20676#issuecomment-1227979712 Successful pipeline - https://dev.azure.com/asmirnov1/Flink/_build/results?buildId=30&view=results -- This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Updated] (FLINK-27149) KafkaSourceE2ECase.testScaleUp failed on AZP

2022-08-25 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-27149: - Labels: test-stability (was: ) > KafkaSourceE2ECase.testScaleUp failed on AZP > ---

[jira] [Closed] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

2022-08-25 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-28177. Resolution: Fixed Merged into master via cdc4f4b100d3b2e66536a23685d7505c1f6670af > Elasticsearch

[jira] [Updated] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

2022-08-25 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28177: - Fix Version/s: 1.16.0 > Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed

[GitHub] [flink] HuangXingBo closed pull request #20362: [FLINK-28177][Connectors/ElasticSearch] add retry in elasticsearch ta…

2022-08-25 Thread GitBox
HuangXingBo closed pull request #20362: [FLINK-28177][Connectors/ElasticSearch] add retry in elasticsearch ta… URL: https://github.com/apache/flink/pull/20362 -- 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] leozhangsr commented on pull request #20389: [FLINK-28475] [Connector/kafka] stopping offset can be 0

2022-08-25 Thread GitBox
leozhangsr commented on PR #20389: URL: https://github.com/apache/flink/pull/20389#issuecomment-1227969108 > Commit message looks in sync with master As in pull request(https://github.com/apache/flink/pull/20234), PatrickRen asked for another two pull request for release-1.14 and release-

[GitHub] [flink] swuferhong commented on pull request #20664: [FLINK-29046][Connectors/Hive] Fix HiveTableSourceStatisticsReportTest fails with Hive 3.x

2022-08-25 Thread GitBox
swuferhong commented on PR #20664: URL: https://github.com/apache/flink/pull/20664#issuecomment-1227917280 @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

[GitHub] [flink] lincoln-lil commented on pull request #20577: [FLINK-28971][table-planner][doc] Adds user documentation for the new LOOKUP hint

2022-08-25 Thread GitBox
lincoln-lil commented on PR #20577: URL: https://github.com/apache/flink/pull/20577#issuecomment-1227913112 @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 co

[jira] [Created] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

2022-08-25 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-29109: Summary: Checkpoint path conflict with stateless upgrade mode Key: FLINK-29109 URL: https://issues.apache.org/jira/browse/FLINK-29109 Project: Flink Issue Ty

[jira] [Comment Edited] (FLINK-29088) Project push down cause the source reuse can not work

2022-08-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585069#comment-17585069 ] Aitozi edited comment on FLINK-29088 at 8/26/22 12:34 AM: -- I pr

[jira] [Commented] (FLINK-29088) Project push down cause the source reuse can not work

2022-08-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585069#comment-17585069 ] Aitozi commented on FLINK-29088: I propose to support this level reuse by this way: 1)

[jira] [Commented] (FLINK-28395) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi fails with Elasticsearch exception [type=index_not_found_exception, reason=no such index]

2022-08-25 Thread KurtDing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585062#comment-17585062 ] KurtDing commented on FLINK-28395: -- Pr is avaliable, need a reviewer > Elasticsearch6D

[jira] [Commented] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

2022-08-25 Thread KurtDing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585061#comment-17585061 ] KurtDing commented on FLINK-28177: -- Pr is avaliable ,need a reviewer > Elasticsearch6D

[GitHub] [flink-table-store] LadyForest opened a new pull request, #277: [hotfix] Fix the typo in DDL, and correct the SQL job restore description

2022-08-25 Thread GitBox
LadyForest opened a new pull request, #277: URL: https://github.com/apache/flink-table-store/pull/277 The current description for restoring a job from a savepoint only applies for jar jobs. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-11529) Support Chinese Documentation for Apache Flink

2022-08-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11529: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-ava

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

2022-08-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28934: --- Labels: bug stale-critical (was: bug) I am the [Flink Jira Bot|https://github.com/apache/fl

[jira] [Updated] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

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

[jira] [Updated] (FLINK-28424) JdbcExactlyOnceSinkE2eTest hangs on Azure

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

[jira] [Updated] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

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

[jira] [Created] (FLINK-29108) Kubernetes operator: Support queryable state

2022-08-25 Thread Ron Crocker (Jira)
Ron Crocker created FLINK-29108: --- Summary: Kubernetes operator: Support queryable state Key: FLINK-29108 URL: https://issues.apache.org/jira/browse/FLINK-29108 Project: Flink Issue Type: New Fe

[jira] [Commented] (FLINK-29107) Upgrade spotless version to improve spotless check efficiency

2022-08-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585020#comment-17585020 ] Chesnay Schepler commented on FLINK-29107: -- we cant upgrade spotless. The curre

[jira] [Commented] (FLINK-29107) Upgrade spotless version to improve spotless check efficiency

2022-08-25 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584911#comment-17584911 ] Yun Tang commented on FLINK-29107: -- An interesting feature. [~Yu Chen] , already assign

[jira] [Assigned] (FLINK-29107) Upgrade spotless version to improve spotless check efficiency

2022-08-25 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-29107: Assignee: Yu Chen > Upgrade spotless version to improve spotless check efficiency > -

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #351: [FLINK-28646] Handle scaling operation separately in reconciler/service

2022-08-25 Thread GitBox
morhidi commented on code in PR #351: URL: https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r955084321 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -122,1

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #351: [FLINK-28646] Handle scaling operation separately in reconciler/service

2022-08-25 Thread GitBox
morhidi commented on code in PR #351: URL: https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r955077692 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/diff/SpecDiffTest.java: ## @@ -0,0 +1,171 @@ +/* + * Licensed

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #351: [FLINK-28646] Handle scaling operation separately in reconciler/service

2022-08-25 Thread GitBox
morhidi commented on code in PR #351: URL: https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r955077692 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/diff/SpecDiffTest.java: ## @@ -0,0 +1,171 @@ +/* + * Licensed

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #351: [FLINK-28646] Handle scaling operation separately in reconciler/service

2022-08-25 Thread GitBox
morhidi commented on code in PR #351: URL: https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r955074814 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/diff/SpecDiffTest.java: ## @@ -0,0 +1,171 @@ +/* + * Licensed

[jira] [Updated] (FLINK-29107) Upgrade spotless version to improve spotless check efficiency

2022-08-25 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-29107: Description: I noticed a [discussion|https://github.com/diffplug/spotless/issues/927] in the spotless Git

[jira] [Updated] (FLINK-29107) Upgrade spotless version to improve spotless check efficiency

2022-08-25 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-29107: Summary: Upgrade spotless version to improve spotless check efficiency (was: Bump up spotless version to

[jira] [Created] (FLINK-29107) Bump up spotless version to improve efficiently

2022-08-25 Thread Yu Chen (Jira)
Yu Chen created FLINK-29107: --- Summary: Bump up spotless version to improve efficiently Key: FLINK-29107 URL: https://issues.apache.org/jira/browse/FLINK-29107 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-29059) The existing column stats are deleted incorrectly when analyze table for partial columns

2022-08-25 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-29059. -- Resolution: Fixed Fixed in master: fe392645421d10923c75cd5438b91d9ed55900d3 > The existing column sta

[jira] [Assigned] (FLINK-29059) The existing column stats are deleted incorrectly when analyze table for partial columns

2022-08-25 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29059: -- Assignee: Yunhong Zheng > The existing column stats are deleted incorrectly when analyze tabl

[GitHub] [flink] godfreyhe closed pull request #20672: [FLINK-29059][table-planner] Fix the existing column stats are deleted incorrectly when analyze table for partial columns

2022-08-25 Thread GitBox
godfreyhe closed pull request #20672: [FLINK-29059][table-planner] Fix the existing column stats are deleted incorrectly when analyze table for partial columns URL: https://github.com/apache/flink/pull/20672 -- This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] jaumebecks commented on pull request #20343: [FLINK-25916][connector-kafka] Using upsert-kafka with a flush buffer…

2022-08-25 Thread GitBox
jaumebecks commented on PR #20343: URL: https://github.com/apache/flink/pull/20343#issuecomment-1227296392 Hi, any plans on merging this? :smile: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-08-25 Thread Simonas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simonas updated FLINK-28695: Description: After upgrade to *1.15.1* we started getting error while running JOB   {code:java} org.apach

[GitHub] [flink] swuferhong commented on pull request #20664: [FLINK-29046][Connectors/Hive] Fix HiveTableSourceStatisticsReportTest fails with Hive 3.x

2022-08-25 Thread GitBox
swuferhong commented on PR #20664: URL: https://github.com/apache/flink/pull/20664#issuecomment-1227234108 hi, @HuangXingBo, @luoyuxia, @godfreyhe , hive3 and hadoop3 tests passed, I revert the test commits to run hive2. ![image](https://user-images.githubusercontent.com/27358654/18667

[GitHub] [flink] swuferhong commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-25 Thread GitBox
swuferhong commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r954896567 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,244 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink] XComp commented on pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-25 Thread GitBox
XComp commented on PR #20673: URL: https://github.com/apache/flink/pull/20673#issuecomment-1227172486 hm, is the failure happening because we're not explicitly setting the direct executor for the initial `CompletableFuture` that gets created through `CompletableFuture.supplyAsync`. That way

[jira] [Closed] (FLINK-29106) value of metric 'idleTimeMsPerSecond' more than 1000

2022-08-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29106. Resolution: Duplicate > value of metric 'idleTimeMsPerSecond' more than 1000 > --

[GitHub] [flink] swuferhong commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-25 Thread GitBox
swuferhong commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r954868511 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,244 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink] ganlute commented on pull request #20542: [FLINK-28910][Connectors/hbase]CDC From Mysql To Hbase Bugs

2022-08-25 Thread GitBox
ganlute commented on PR #20542: URL: https://github.com/apache/flink/pull/20542#issuecomment-1227154498 @wuchong @dannycranmer could you please help me review the changes?Thank you.😄 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Updated] (FLINK-29106) value of metric 'idleTimeMsPerSecond' more than 1000

2022-08-25 Thread chenyuzhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenyuzhi updated FLINK-29106: -- Description:  As the picture shown below, the value of metric 'idleTimeMsPerSecond' is more than 1000

[jira] [Updated] (FLINK-29106) value of metric 'idleTimeMsPerSecond' more than 1000

2022-08-25 Thread chenyuzhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenyuzhi updated FLINK-29106: -- Attachment: image-2022-08-25-19-18-52-755.png > value of metric 'idleTimeMsPerSecond' more than 1000

[jira] [Created] (FLINK-29106) value of metric 'idleTimeMsPerSecond' more than 1000

2022-08-25 Thread chenyuzhi (Jira)
chenyuzhi created FLINK-29106: - Summary: value of metric 'idleTimeMsPerSecond' more than 1000 Key: FLINK-29106 URL: https://issues.apache.org/jira/browse/FLINK-29106 Project: Flink Issue Type: B

[GitHub] [flink] WencongLiu commented on pull request #20609: [FLINK-27773][sql-gateway]Introduce the rest E2E tests for SQL Gateway

2022-08-25 Thread GitBox
WencongLiu commented on PR #20609: URL: https://github.com/apache/flink/pull/20609#issuecomment-1227104472 @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

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

2022-08-25 Thread GitBox
SmirAlex commented on PR #20676: URL: https://github.com/apache/flink/pull/20676#issuecomment-1227099921 Successful pipeline - https://dev.azure.com/asmirnov1/Flink/_build/results?buildId=30&view=results -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] WencongLiu commented on pull request #20678: [FLINK-29097][sql-gateway]Moving json se/deserializers from sql-gateway-api to sql-gateway

2022-08-25 Thread GitBox
WencongLiu commented on PR #20678: URL: https://github.com/apache/flink/pull/20678#issuecomment-1227082549 @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

[GitHub] [flink] flinkbot commented on pull request #20679: [FLINK-28738][table-planner] Adds a user doc about the determinism in streaming

2022-08-25 Thread GitBox
flinkbot commented on PR #20679: URL: https://github.com/apache/flink/pull/20679#issuecomment-1227069404 ## CI report: * a8ff03d9242f439a91aad367ee8738c6dbab14f1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28738) [doc] Add a user doc about the correctness for non-deterministic updates

2022-08-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28738: --- Labels: pull-request-available (was: ) > [doc] Add a user doc about the correctness for non

[GitHub] [flink] lincoln-lil opened a new pull request, #20679: [FLINK-28738][table-planner] Adds a user doc about the determinism in streaming

2022-08-25 Thread GitBox
lincoln-lil opened a new pull request, #20679: URL: https://github.com/apache/flink/pull/20679 ## What is the purpose of the change This is the documentation followup work of [FLINK-27849](https://issues.apache.org/jira/browse/FLINK-27849). Mainly illustrates the determinism in streami

[jira] [Assigned] (FLINK-27491) Support env replacement in flink-kubernetes-operator CR

2022-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27491: -- Assignee: Peter Vary > Support env replacement in flink-kubernetes-operator CR >

[GitHub] [flink] swuferhong commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-25 Thread GitBox
swuferhong commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r954770285 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,244 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink] swuferhong commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-25 Thread GitBox
swuferhong commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r954770026 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,244 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink] swuferhong commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-25 Thread GitBox
swuferhong commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r954768543 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,244 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink] swuferhong commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-25 Thread GitBox
swuferhong commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r954767542 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,244 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[jira] [Updated] (FLINK-28261) Consider Using Dependent Resources for Ingress

2022-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28261: --- Affects Version/s: (was: kubernetes-operator-1.1.0) > Consider Using Dependent Resources for Ing

[jira] [Closed] (FLINK-28436) test_multi_sessionjob.sh is failing intermittently

2022-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28436. -- Resolution: Not A Problem > test_multi_sessionjob.sh is failing intermittently > -

[jira] [Assigned] (FLINK-28272) Handle TLS Certificate Renewal in Webhook

2022-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-28272: -- Assignee: Gabor Somogyi > Handle TLS Certificate Renewal in Webhook > ---

  1   2   >