[GitHub] [flink-table-store] tsreaper commented on pull request #267: [hotfix] Fix github workflow build-different-versions.yaml

tsreaper commented on PR #267: URL: https://github.com/apache/flink-table-store/pull/267#issuecomment-1216223634 Tests passed in https://github.com/tsreaper/flink-table-store/actions -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Updated] (FLINK-28265) Inconsistency in Kubernetes HA service: broken state handle

[ https://issues.apache.org/jira/browse/FLINK-28265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28265: --- Labels: pull-request-available (was: ) > Inconsistency in Kubernetes HA service: broken sta

[GitHub] [flink] wangyang0918 opened a new pull request, #20590: [FLINK-28265][k8s] Do not discard state when the AlreadyExistException is caused by retries

wangyang0918 opened a new pull request, #20590: URL: https://github.com/apache/flink/pull/20590 ## What is the purpose of the change If something is temporarily wrong with the JobManager network, `Fabric8FlinkKubeClient#checkAndUpdateConfigMap` failed with `KubernetesExceptio

[jira] [Commented] (FLINK-28986) UNNEST function with nested fails to generate plan

[ https://issues.apache.org/jira/browse/FLINK-28986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580082#comment-17580082 ] godfrey he commented on FLINK-28986: [~qingyue] Thanks for reporting this, assign to

[jira] [Assigned] (FLINK-28986) UNNEST function with nested fails to generate plan

[ https://issues.apache.org/jira/browse/FLINK-28986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-28986: -- Assignee: Jane Chan > UNNEST function with nested fails to generate plan > --

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

[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 ] Zhu Zhu updated FLINK-28980: Labels: release-testing (was: test-stability) > Release Testing: Verify FLIP-168 speculative execution >

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28981: Labels: release-testing (was: test-stability) > Release Testing: Verify FLIP-245 sources speculative exec

[jira] [Comment Edited] (FLINK-28986) UNNEST function with nested fails to generate plan

[ https://issues.apache.org/jira/browse/FLINK-28986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580080#comment-17580080 ] Jane Chan edited comment on FLINK-28986 at 8/16/22 6:37 AM:

[jira] [Commented] (FLINK-28986) UNNEST function with nested fails to generate plan

[ https://issues.apache.org/jira/browse/FLINK-28986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580080#comment-17580080 ] Jane Chan commented on FLINK-28986: --- The reason is that during the decorrelation rewri

[jira] [Updated] (FLINK-28986) UNNEST function with nested fails to generate plan

[ https://issues.apache.org/jira/browse/FLINK-28986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-28986: -- Attachment: image-2022-08-16-14-36-07-061.png > UNNEST function with nested fails to generate plan > -

[jira] [Commented] (FLINK-28912) Add Part of "Who Use Flink" In ReadMe file and https://flink.apache.org/

[ https://issues.apache.org/jira/browse/FLINK-28912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580077#comment-17580077 ] Zhou Yao commented on FLINK-28912: -- Great~,thanks > Add Part of "Who Use Flink" In Rea

[jira] [Updated] (FLINK-28986) UNNEST function with nested fails to generate plan

[ https://issues.apache.org/jira/browse/FLINK-28986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-28986: -- Description: h3. How to reproduce add the following case to TableEnvironmentITCase {code:scala} @Test

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

[ https://issues.apache.org/jira/browse/FLINK-28939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-28939: -- Assignee: Yunhong Zheng > Release Testing: Verify FLIP-241 ANALYZE TABLE > --

[jira] [Created] (FLINK-28986) UNNEST function with nested fails to generate plan

Jane Chan created FLINK-28986: - Summary: UNNEST function with nested fails to generate plan Key: FLINK-28986 URL: https://issues.apache.org/jira/browse/FLINK-28986 Project: Flink Issue Type: Bug

[GitHub] [flink-table-store] tsreaper opened a new pull request, #267: [hotfix] Fix github workflow build-different-versions.yaml

tsreaper opened a new pull request, #267: URL: https://github.com/apache/flink-table-store/pull/267 Fix syntax of `build-different-versions.yaml`. -- 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-27199) Bump Pulsar to 2.10.0 for fixing the unstable Pulsar test environment.

[ https://issues.apache.org/jira/browse/FLINK-27199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-27199: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Bump Pulsar to 2.10.0 f

[jira] [Assigned] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-28927: Assignee: ChangjiGuo > Can not clean up the uploaded shared files when the checkpoint fails > ---

[jira] [Commented] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580068#comment-17580068 ] Yun Tang commented on FLINK-28927: -- [~ChangjiGuo] It seems you did not give a clear ide

[jira] [Closed] (FLINK-27199) Bump Pulsar to 2.10.0 for fixing the unstable Pulsar test environment.

[ https://issues.apache.org/jira/browse/FLINK-27199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-27199. - Resolution: Fixed 1.15 via 65f79130e4b24a2b9d7035bc0751842889729f63 Closed. > Bump Pulsar to 2.10.0 fo

[jira] [Updated] (FLINK-28967) Fix Hive multi-version support for Table Store

[ https://issues.apache.org/jira/browse/FLINK-28967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28967: - Fix Version/s: (was: table-store-0.3.0) > Fix Hive multi-version support for Table Store > -

[jira] [Updated] (FLINK-27199) Bump Pulsar to 2.10.0 for fixing the unstable Pulsar test environment.

[ https://issues.apache.org/jira/browse/FLINK-27199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-27199: -- Fix Version/s: (was: 1.14.6) > Bump Pulsar to 2.10.0 for fixing the unstable Pulsar test environme

[jira] [Closed] (FLINK-28967) Fix Hive multi-version support for Table Store

[ https://issues.apache.org/jira/browse/FLINK-28967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28967. Assignee: Caizhi Weng Resolution: Fixed master: 6652905c4c0ff7f2533353c2d7d3d6552eb978e3 rel

[GitHub] [flink] tisonkun commented on pull request #20582: [BK-1.15][FLINK-27199][Connector/Pulsar] Bump pulsar to 2.10.0

tisonkun commented on PR #20582: URL: https://github.com/apache/flink/pull/20582#issuecomment-1216187797 Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsub

[GitHub] [flink] tisonkun merged pull request #20582: [BK-1.15][FLINK-27199][Connector/Pulsar] Bump pulsar to 2.10.0

tisonkun merged PR #20582: URL: https://github.com/apache/flink/pull/20582 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[GitHub] [flink-table-store] JingsongLi merged pull request #266: [FLINK-28967] Fix Hive multi-version support for Table Store

JingsongLi merged PR #266: URL: https://github.com/apache/flink-table-store/pull/266 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-28981: --- Priority: Blocker (was: Major) > Release Testing: Verify FLIP-245 sources 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 ] godfrey he updated FLINK-28980: --- Priority: Blocker (was: Major) > Release Testing: Verify FLIP-168 speculative execution > -

[jira] [Updated] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-28981: --- Labels: test-stability (was: ) > Release Testing: Verify FLIP-245 sources 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 ] godfrey he updated FLINK-28980: --- Labels: test-stability (was: ) > Release Testing: Verify FLIP-168 speculative execution > -

[jira] [Commented] (FLINK-28925) Fix the concurrency problem in hybrid shuffle

[ https://issues.apache.org/jira/browse/FLINK-28925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580062#comment-17580062 ] godfrey he commented on FLINK-28925: [~Weijie Guo] would you like to fix it ? > Fix

[jira] [Commented] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

[ https://issues.apache.org/jira/browse/FLINK-28984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580061#comment-17580061 ] Yun Tang commented on FLINK-28984: -- I think the second analysis looks a bit weird. If t

[GitHub] [flink-table-store] SteNicholas commented on pull request #266: [FLINK-28967] Fix Hive multi-version support for Table Store

SteNicholas commented on PR #266: URL: https://github.com/apache/flink-table-store/pull/266#issuecomment-1216181701 @tsreaper, the Hive 2.1 and 2.2 use the latest version 2.1.1 and 2.2.0, hence does the Hive 2.3 need to support the latest version 2.3.9? -- This is an automated message fr

[jira] [Updated] (FLINK-28429) Reduce pyflink tests time

[ https://issues.apache.org/jira/browse/FLINK-28429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28429: - Labels: (was: test-stability) > Reduce pyflink tests time > - > >

[jira] [Resolved] (FLINK-28920) Release Testing: Verify Python DataStream Window

[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-28920. -- Resolution: Done > Release Testing: Verify Python DataStream Window >

[jira] [Resolved] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-28918. -- Resolution: Done > Release Testing: Verify FLIP-206 in Python DataStream API > ---

[jira] [Updated] (FLINK-28983) using serviceaccount in FlinkDeployment not works when sink to aws s3

[ https://issues.apache.org/jira/browse/FLINK-28983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lichuan Shang updated FLINK-28983: -- Description: I am deploying a Flink CDC job using sql-runner example from official examples(s

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #141: [FLINK-28805] Add Transformer for HashingTF

yunfengzhou-hub commented on code in PR #141: URL: https://github.com/apache/flink-ml/pull/141#discussion_r946314824 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java: ## @@ -0,0 +1,193 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Commented] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580058#comment-17580058 ] Huang Xingbo commented on FLINK-28918: -- [~ana4] Thanks a lot for the test. > Relea

[jira] [Commented] (FLINK-28920) Release Testing: Verify Python DataStream Window

[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580057#comment-17580057 ] Huang Xingbo commented on FLINK-28920: -- [~ana4] Thanks a lot for the test. > Relea

[GitHub] [flink] syhily commented on a diff in pull request #20567: [FLINK-27917][Connector/Pulsar] Fix message assert error in PulsarUnorderedPartitionSplitReaderTest

syhily commented on code in PR #20567: URL: https://github.com/apache/flink/pull/20567#discussion_r946357858 ## flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java: ## @@ -198,7 +213,

[jira] [Commented] (FLINK-28920) Release Testing: Verify Python DataStream Window

[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580053#comment-17580053 ] Luning Wang commented on FLINK-28920: - This test can successfully run on an M1 chip.

[jira] [Commented] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580054#comment-17580054 ] Luning Wang commented on FLINK-28918: - This test can successfully run on an M1 chip.

[jira] [Comment Edited] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580044#comment-17580044 ] ChangjiGuo edited comment on FLINK-28927 at 8/16/22 5:31 AM: -

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

waywtdcc created FLINK-28985: Summary: support create table like view Key: FLINK-28985 URL: https://issues.apache.org/jira/browse/FLINK-28985 Project: Flink Issue Type: Improvement Comp

[jira] [Updated] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

[ https://issues.apache.org/jira/browse/FLINK-28984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-28984: --- Description: If the checkpoint is aborted, AsyncSnapshotCallable will close the snapshotCloseableRe

[jira] [Updated] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

[ https://issues.apache.org/jira/browse/FLINK-28984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-28984: --- External issue URL: https://issues.apache.org/jira/browse/FLINK-28927 > FsCheckpointStateOutputStrea

[jira] [Updated] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

[ https://issues.apache.org/jira/browse/FLINK-28984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-28984: --- External issue URL: (was: https://issues.apache.org/jira/browse/FLINK-28927) > FsCheckpointStateO

[jira] [Comment Edited] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580044#comment-17580044 ] ChangjiGuo edited comment on FLINK-28927 at 8/16/22 5:15 AM: -

[jira] [Commented] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580044#comment-17580044 ] ChangjiGuo commented on FLINK-28927: I also found another problem when debugging the

[jira] [Updated] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

[ https://issues.apache.org/jira/browse/FLINK-28984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-28984: --- Description: If the checkpoint is aborted, AsyncSnapshotCallable will close the snapshotCloseableRe

[jira] [Assigned] (FLINK-28954) Release Testing: Verify FLIP-223 HiveServer2 Endpoint

[ https://issues.apache.org/jira/browse/FLINK-28954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28954: --- Assignee: luoyuxia > Release Testing: Verify FLIP-223 HiveServer2 Endpoint > --

[jira] [Created] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

ChangjiGuo created FLINK-28984: -- Summary: FsCheckpointStateOutputStream is not being released normally Key: FLINK-28984 URL: https://issues.apache.org/jira/browse/FLINK-28984 Project: Flink Iss

[jira] [Assigned] (FLINK-28952) Release Testing: Veify Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28952: --- Assignee: Shengkai Fang > Release Testing: Veify Hive dialect > --

[jira] [Updated] (FLINK-28983) using serviceaccount in FlinkDeployment not works when sink to aws s3

[ https://issues.apache.org/jira/browse/FLINK-28983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lichuan Shang updated FLINK-28983: -- Description: I am deploying a Flink CDC job using sql-runner example from official examples(s

[jira] [Created] (FLINK-28983) using serviceaccount in FlinkDeployment not works when sink to aws s3

Lichuan Shang created FLINK-28983: - Summary: using serviceaccount in FlinkDeployment not works when sink to aws s3 Key: FLINK-28983 URL: https://issues.apache.org/jira/browse/FLINK-28983 Project: Flin

[GitHub] [flink] imaffe commented on a diff in pull request #20567: [FLINK-27917][Connector/Pulsar] Fix message assert error in PulsarUnorderedPartitionSplitReaderTest

imaffe commented on code in PR #20567: URL: https://github.com/apache/flink/pull/20567#discussion_r946332754 ## flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java: ## @@ -198,7 +213,

[GitHub] [flink] tisonkun commented on a diff in pull request #20567: [FLINK-27917][Connector/Pulsar] Fix message assert error in PulsarUnorderedPartitionSplitReaderTest

tisonkun commented on code in PR #20567: URL: https://github.com/apache/flink/pull/20567#discussion_r946324038 ## flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java: ## @@ -198,7 +21

[jira] [Assigned] (FLINK-28965) Should create empty partition when it's for dynamic partition

[ https://issues.apache.org/jira/browse/FLINK-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28965: --- Assignee: tartarus > Should create empty partition when it's for dynamic partition > --

[jira] [Closed] (FLINK-28548) The commit partition base path is not created when no data is sent which may cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-28548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28548. --- Assignee: Liu Resolution: Fixed Fixed in master: f2abb51ac91c8b0e9bdd261de791d3aa1ba033dd > The commi

[GitHub] [flink] wuchong merged pull request #20269: [FLINK-28548][Connectors / FileSystem] Fix the exception FileNotFoundException when the commit partition base path is not created

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

[jira] [Closed] (FLINK-28003) Hive sql is wrongly modified by SqlCompleter in SQL client when using -f {file}

[ https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28003. --- Resolution: Fixed Fixed in master: 226f1602c047092cc1997f6e861aa37858df21f7 > Hive sql is wrongly modified

[jira] [Created] (FLINK-28982) Start TaskInterrupter when task switch from DEPLOYING to CANCELING

LI Mingkun created FLINK-28982: -- Summary: Start TaskInterrupter when task switch from DEPLOYING to CANCELING Key: FLINK-28982 URL: https://issues.apache.org/jira/browse/FLINK-28982 Project: Flink

[GitHub] [flink] wuchong merged pull request #20182: [FLINK-28003][Table SQL / Client] Disable SqlCompleter when using -f {file}

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

[jira] [Closed] (FLINK-28773) Fix Hive sink not write a success file after finish writing in batch mode

[ https://issues.apache.org/jira/browse/FLINK-28773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28773. --- Assignee: tartarus Resolution: Fixed Fixed in master: 00cded670753e2795c774c159facb801bbeb9927 to b66

[GitHub] [flink] wuchong merged pull request #20469: [FLINK-28773][hive] Fix Hive sink not write a success file after finish writing in batch mode

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

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

curcur commented on code in PR #20585: URL: https://github.com/apache/flink/pull/20585#discussion_r946315050 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java: ## @@ -118,7 +118,7 @@ public voi

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

curcur commented on code in PR #20585: URL: https://github.com/apache/flink/pull/20585#discussion_r946315050 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java: ## @@ -118,7 +118,7 @@ public voi

[jira] [Closed] (FLINK-28130) FLIP-224: Blocklist Mechanism

[ https://issues.apache.org/jira/browse/FLINK-28130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28130. --- Resolution: Done > FLIP-224: Blocklist Mechanism > - > > Key: FL

[jira] [Closed] (FLINK-28587) FLIP-249: Flink Web UI Enhancement for Speculative Execution

[ https://issues.apache.org/jira/browse/FLINK-28587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28587. --- Fix Version/s: 1.16.0 Resolution: Done > FLIP-249: Flink Web UI Enhancement for Speculative Execution

[jira] [Closed] (FLINK-28397) [FLIP-245] Source Supports Speculative Execution For Batch Job

[ https://issues.apache.org/jira/browse/FLINK-28397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28397. --- Resolution: Done > [FLIP-245] Source Supports Speculative Execution For Batch Job >

[GitHub] [flink-table-store] SteNicholas commented on pull request #266: [FLINK-28967] Fix Hive multi-version support for Table Store

SteNicholas commented on PR #266: URL: https://github.com/apache/flink-table-store/pull/266#issuecomment-1216113060 @tsreaper @JingsongLi , does the NOTICE file of this module need to be updated? -- This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Created] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

Zhu Zhu created FLINK-28981: --- Summary: Release Testing: Verify FLIP-245 sources speculative execution Key: FLINK-28981 URL: https://issues.apache.org/jira/browse/FLINK-28981 Project: Flink Issue T

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

[jira] [Commented] (FLINK-28920) Release Testing: Verify Python DataStream Window

[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580026#comment-17580026 ] Huang Xingbo commented on FLINK-28920: -- Thanks [~ana4] for the test. I have assigne

[jira] [Commented] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580027#comment-17580027 ] Huang Xingbo commented on FLINK-28918: -- Thanks [~ana4] for the test. I have assigne

[jira] [Assigned] (FLINK-28920) Release Testing: Verify Python DataStream Window

[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-28920: Assignee: Luning Wang > Release Testing: Verify Python DataStream Window > --

[jira] [Assigned] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-28918: Assignee: Luning Wang > Release Testing: Verify FLIP-206 in Python DataStream API > -

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

[jira] [Commented] (FLINK-28920) Release Testing: Verify Python DataStream Window

[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580025#comment-17580025 ] Luning Wang commented on FLINK-28920: - I will test this on M1 Chip. > Release Testi

[jira] [Commented] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580024#comment-17580024 ] Luning Wang commented on FLINK-28918: - I will test this on M1 Chip. > Release Testi

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

[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 ] Zhu Zhu updated FLINK-28980: Description: Speculative execution is introduced in Flink 1.16 to deal with temporary slow tasks caused b

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

Zhu Zhu created FLINK-28980: --- Summary: Release Testing: Verify FLIP-168 speculative execution Key: FLINK-28980 URL: https://issues.apache.org/jira/browse/FLINK-28980 Project: Flink Issue Type: Sub-

[jira] [Updated] (FLINK-27535) Optimize the unit test execution time

[ https://issues.apache.org/jira/browse/FLINK-27535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27535: --- Labels: pull-request-available (was: ) > Optimize the unit test execution time > --

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request, #143: [FLINK-27535] Optimize the unit test execution time

yunfengzhou-hub opened a new pull request, #143: URL: https://github.com/apache/flink-ml/pull/143 ## What is the purpose of the change This PR reduces the total execution time of Flink ML CIs so as to improve the efficiency of Flink ML development. This PR mainly focuses on opt

[jira] [Assigned] (FLINK-28926) Release Testing: Verify flip-235 hybrid shuffle mode

[ https://issues.apache.org/jira/browse/FLINK-28926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-28926: Assignee: Yu Chen > Release Testing: Verify flip-235 hybrid shuffle mode > --

[jira] [Commented] (FLINK-28926) Release Testing: Verify flip-235 hybrid shuffle mode

[ https://issues.apache.org/jira/browse/FLINK-28926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580019#comment-17580019 ] Weijie Guo commented on FLINK-28926: [~Yu Chen] Thank you for your interest. Yes, yo

[jira] [Commented] (FLINK-28915) Flink Native k8s mode jar localtion support s3 schema

[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580018#comment-17580018 ] Yang Wang commented on FLINK-28915: --- Thanks [~aitozi] and [~hjw] for the volunteering.

[jira] [Assigned] (FLINK-28915) Flink Native k8s mode jar localtion support s3 schema

[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-28915: - Assignee: hjw > Flink Native k8s mode jar localtion support s3 schema > --

[GitHub] [flink] flinkbot commented on pull request #20589: [FLINK-28972][python][connector/pulsar] Align Start/StopCursor method to java

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #139: [FLINK-28803] Add Transformer and Estimator for KBinsDiscretizer

yunfengzhou-hub commented on code in PR #139: URL: https://github.com/apache/flink-ml/pull/139#discussion_r946290131 ## flink-ml-lib/src/test/java/org/apache/flink/ml/feature/KBinsDiscretizerTest.java: ## @@ -0,0 +1,296 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Updated] (FLINK-28979) Add another owner into the JM deployment's owner references

[ https://issues.apache.org/jira/browse/FLINK-28979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Hao updated FLINK-28979: Description: This action will link the resources into the FlinkDeployment The JM deployment will look lik

[jira] [Created] (FLINK-28979) Add another owner into the JM deployment's owner references

Xin Hao created FLINK-28979: --- Summary: Add another owner into the JM deployment's owner references Key: FLINK-28979 URL: https://issues.apache.org/jira/browse/FLINK-28979 Project: Flink Issue Type

[jira] [Updated] (FLINK-28972) Add methods of StartCursor and StopCursor to align the Java

[ https://issues.apache.org/jira/browse/FLINK-28972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28972: --- Labels: pull-request-available (was: ) > Add methods of StartCursor and StopCursor to align

[GitHub] [flink] deadwind4 opened a new pull request, #20589: [FLINK-28972][python][connector/pulsar] Align Start/StopCursor method to java

deadwind4 opened a new pull request, #20589: URL: https://github.com/apache/flink/pull/20589 ## What is the purpose of the change Add fromPublishTime in the StartCursor class Add afterEventTime and afterPublishTime in the StopCursor class ## Brief change log - *Add f

  1   2   3   4   >