[jira] [Updated] (FLINK-26362) "IndexOutOfBoundsException" when subquery select all field from using hive dialect

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26362: - Description: With hive dialect, can be reproduced using following code: {code:java} tableEnv.executeSql

[jira] [Updated] (FLINK-26362) "IndexOutOfBoundsException" when subquery select all field from using hive dialect

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26362: - Description: With hive dialect, can be reproduced using following code: {code:java} tableEnv.executeSql

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #31: [FLINK-26293] Store log offsets in snapshot

2022-03-09 Thread GitBox
JingsongLi commented on a change in pull request #31: URL: https://github.com/apache/flink-table-store/pull/31#discussion_r823271958 ## File path: flink-table-store-core/src/test/java/org/apache/flink/table/store/file/TestFileStore.java ## @@ -188,6 +191,9 @@ public FileStoreE

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * ecd80ec7a11dae690b258377aab2428872a0abdb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] LadyForest commented on pull request #19007: [FLINK-26495][table-planner] Prohibit hints(dynamic table options) on view

2022-03-09 Thread GitBox
LadyForest commented on pull request #19007: URL: https://github.com/apache/flink/pull/19007#issuecomment-1063581072 Hi, @godfreyhe, do you have time to take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * ecd80ec7a11dae690b258377aab2428872a0abdb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] luoyuxia commented on pull request #19012: [FLINK-26540][hive] Support handle join involving complex types in on…

2022-03-09 Thread GitBox
luoyuxia commented on pull request #19012: URL: https://github.com/apache/flink/pull/19012#issuecomment-1063581742 @beyond1920 @wuchong Could you please help review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink] luoyuxia commented on pull request #18994: [FLINK-26505][hive] Support non equality condition for left semi join…

2022-03-09 Thread GitBox
luoyuxia commented on pull request #18994: URL: https://github.com/apache/flink/pull/18994#issuecomment-1063582946 @beyond1920 @wuchong Could you please help review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] luoyuxia commented on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
luoyuxia commented on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1063583082 @beyond1920 @wuchong Could you please help review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-23190) Make task-slot allocation much more evenly

2022-03-09 Thread loyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503952#comment-17503952 ] loyi commented on FLINK-23190: -- Thank you both for your kind replies.  > Make task-slot al

[GitHub] [flink] zhuzhurk closed pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-09 Thread GitBox
zhuzhurk closed pull request #19003: URL: https://github.com/apache/flink/pull/19003 -- 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-unsubs

[jira] [Closed] (FLINK-26517) Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-26517. --- Resolution: Fixed master/release-1.15: 4d42c642cc3c45acf25d41172f6a2132d4c6c60b > Normalize the decided par

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2022-03-09 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503954#comment-17503954 ] Kezhu Wang commented on FLINK-21564: [~pedrosbs] [~renqs] I think it has been fixed

[GitHub] [flink-ml] lindong28 commented on a change in pull request #68: [FLINK-26404] support non-local file systems

2022-03-09 Thread GitBox
lindong28 commented on a change in pull request #68: URL: https://github.com/apache/flink-ml/pull/68#discussion_r823277283 ## File path: flink-ml-core/src/test/java/org/apache/flink/ml/util/ReadWriteUtilsTest.java ## @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 2b4ab65d7d448a28cc214e4096bb188593b7da6f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 2b4ab65d7d448a28cc214e4096bb188593b7da6f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-ml] mumuhhh commented on a change in pull request #68: [FLINK-26404] support non-local file systems

2022-03-09 Thread GitBox
mumuhhh commented on a change in pull request #68: URL: https://github.com/apache/flink-ml/pull/68#discussion_r823281177 ## File path: flink-ml-core/src/test/java/org/apache/flink/ml/util/ReadWriteUtilsTest.java ## @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache Software Foun

[GitHub] [flink-ml] lindong28 commented on a change in pull request #68: [FLINK-26404] support non-local file systems

2022-03-09 Thread GitBox
lindong28 commented on a change in pull request #68: URL: https://github.com/apache/flink-ml/pull/68#discussion_r823282248 ## File path: flink-ml-core/src/test/java/org/apache/flink/ml/util/ReadWriteUtilsTest.java ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink] flinkbot edited a comment on pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19022: URL: https://github.com/apache/flink/pull/19022#issuecomment-1062855606 ## CI report: * 84a227bab9edfc98a6ee7318377e609d0c0ac164 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-ml] mumuhhh commented on a change in pull request #68: [FLINK-26404] support non-local file systems

2022-03-09 Thread GitBox
mumuhhh commented on a change in pull request #68: URL: https://github.com/apache/flink-ml/pull/68#discussion_r823283236 ## File path: flink-ml-core/src/test/java/org/apache/flink/ml/util/ReadWriteUtilsTest.java ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Apache Software Foun

[GitHub] [flink] Vancior commented on a change in pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
Vancior commented on a change in pull request #18957: URL: https://github.com/apache/flink/pull/18957#discussion_r823283875 ## File path: flink-python/pyflink/datastream/window.py ## @@ -517,3 +538,721 @@ def __init__(self, self.window_state_descriptor = window_state_d

[GitHub] [flink] flinkbot edited a comment on pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19022: URL: https://github.com/apache/flink/pull/19022#issuecomment-1062855606 ## CI report: * 84a227bab9edfc98a6ee7318377e609d0c0ac164 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26560) Make the threshold of the overlap fraction of incremental restoring configurable

2022-03-09 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-26560: --- Summary: Make the threshold of the overlap fraction of incremental restoring configurable (was: mak

[GitHub] [flink-ml] lindong28 commented on a change in pull request #68: [FLINK-26404] support non-local file systems

2022-03-09 Thread GitBox
lindong28 commented on a change in pull request #68: URL: https://github.com/apache/flink-ml/pull/68#discussion_r823284967 ## File path: flink-ml-core/src/test/java/org/apache/flink/ml/util/ReadWriteUtilsTest.java ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Apache Software Fo

[jira] [Created] (FLINK-26560) make the threshold of the overlap fraction of incremental restoring configurable

2022-03-09 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-26560: -- Summary: make the threshold of the overlap fraction of incremental restoring configurable Key: FLINK-26560 URL: https://issues.apache.org/jira/browse/FLINK-26560 Project:

[GitHub] [flink-ml] mumuhhh commented on a change in pull request #68: [FLINK-26404] support non-local file systems

2022-03-09 Thread GitBox
mumuhhh commented on a change in pull request #68: URL: https://github.com/apache/flink-ml/pull/68#discussion_r823288119 ## File path: flink-ml-core/src/test/java/org/apache/flink/ml/util/ReadWriteUtilsTest.java ## @@ -0,0 +1,107 @@ +/* + * Licensed to the Apache Software Foun

[jira] [Created] (FLINK-26561) Deployment Status cannot be updated

2022-03-09 Thread leinenglian (Jira)
leinenglian created FLINK-26561: --- Summary: Deployment Status cannot be updated Key: FLINK-26561 URL: https://issues.apache.org/jira/browse/FLINK-26561 Project: Flink Issue Type: Bug En

[jira] [Updated] (FLINK-26561) Deployment Status cannot be updated

2022-03-09 Thread leinenglian (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leinenglian updated FLINK-26561: Component/s: Kubernetes Operator > Deployment Status cannot be updated > -

[jira] [Closed] (FLINK-26489) FlinkDeploymentSpec add imagePullSecrets

2022-03-09 Thread leinenglian (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leinenglian closed FLINK-26489. --- Resolution: Fixed > FlinkDeploymentSpec add imagePullSecrets > -

[GitHub] [flink] Vancior commented on a change in pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
Vancior commented on a change in pull request #18957: URL: https://github.com/apache/flink/pull/18957#discussion_r823294596 ## File path: flink-python/pyflink/datastream/window.py ## @@ -517,3 +538,721 @@ def __init__(self, self.window_state_descriptor = window_state_d

[jira] [Commented] (FLINK-26322) Test FileSink compaction manually

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503968#comment-17503968 ] Yun Gao commented on FLINK-26322: - Very thanks [~alexanderpreuss] for the testing! We'll

[jira] [Commented] (FLINK-26501) Quickstarts Scala nightly end-to-end test failed on azure due to checkponts failed and logs contains exceptions

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503969#comment-17503969 ] Yun Gao commented on FLINK-26501: - 1.14: https://dev.azure.com/apache-flink/apache-flin

[jira] [Assigned] (FLINK-26560) Make the threshold of the overlap fraction of incremental restoring configurable

2022-03-09 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-26560: Assignee: Yanfei Lei > Make the threshold of the overlap fraction of incremental restoring > con

[jira] [Created] (FLINK-26562) Introduce table path option

2022-03-09 Thread Jane Chan (Jira)
Jane Chan created FLINK-26562: - Summary: Introduce table path option Key: FLINK-26562 URL: https://issues.apache.org/jira/browse/FLINK-26562 Project: Flink Issue Type: Sub-task Componen

[jira] [Commented] (FLINK-26560) Make the threshold of the overlap fraction of incremental restoring configurable

2022-03-09 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503971#comment-17503971 ] Yun Tang commented on FLINK-26560: -- Upgrade the priority to "Major". Once FLINK-23399

[jira] [Updated] (FLINK-26560) Make the threshold of the overlap fraction of incremental restoring configurable

2022-03-09 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-26560: - Fix Version/s: 1.16.0 > Make the threshold of the overlap fraction of incremental restoring > configura

[jira] [Updated] (FLINK-26560) Make the threshold of the overlap fraction of incremental restoring configurable

2022-03-09 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-26560: - Priority: Major (was: Minor) > Make the threshold of the overlap fraction of incremental restoring > c

[jira] [Assigned] (FLINK-26562) Introduce table path option

2022-03-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26562: Assignee: Jane Chan > Introduce table path option > --- > >

[jira] [Commented] (FLINK-26529) PyFlink 'tuple' object has no attribute '_values'

2022-03-09 Thread James Schulte (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503973#comment-17503973 ] James Schulte commented on FLINK-26529: --- Okay so the cause of this is that `Functi

[jira] [Commented] (FLINK-26563) HadoopS3RecoverableWriterITCase hang on azure

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503974#comment-17503974 ] Yun Gao commented on FLINK-26563: - This seems to due to the connection to S3 is unstable

[jira] [Created] (FLINK-26563) HadoopS3RecoverableWriterITCase hang on azure

2022-03-09 Thread Yun Gao (Jira)
Yun Gao created FLINK-26563: --- Summary: HadoopS3RecoverableWriterITCase hang on azure Key: FLINK-26563 URL: https://issues.apache.org/jira/browse/FLINK-26563 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-26322) Test FileSink compaction manually

2022-03-09 Thread Gen Luo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503975#comment-17503975 ] Gen Luo commented on FLINK-26322: - Thanks for the testing, [~alexanderpreuss]! 3 has be

[jira] [Created] (FLINK-26564) CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-09 Thread Gen Luo (Jira)
Gen Luo created FLINK-26564: --- Summary: CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests. Key: FLINK-26564 URL: https://issues.apache.org/jira/browse/FLINK-26564 Projec

[jira] [Assigned] (FLINK-26564) CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-26564: --- Assignee: Gen Luo > CompactCoordinatorStateHandler doesn't properly handle the > cleanup-in-progre

[jira] [Created] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

2022-03-09 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-26565: - Summary: Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter Key: FLINK-26565 URL: https://i

[GitHub] [flink] ZhangChaoming edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-09 Thread GitBox
ZhangChaoming edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1062751689 @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 t

[jira] [Closed] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26037. --- Resolution: Duplicate > TaskManagerRunnerTest JVM crash with exit code 239 > ---

[jira] [Updated] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

2022-03-09 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26565: -- Description: Use lateTrigger when the window maxtimestap of data is less than currentwatermark and  i

[jira] [Commented] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503979#comment-17503979 ] Yun Gao commented on FLINK-26037: - I'll first close this issue as it seems not only thes

[jira] [Commented] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503980#comment-17503980 ] Yun Gao commented on FLINK-26106: - 1.15: https://dev.azure.com/apache-flink/apache-flin

[jira] [Comment Edited] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503980#comment-17503980 ] Yun Gao edited comment on FLINK-26106 at 3/10/22, 3:32 AM: --- Ta

[jira] [Commented] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503981#comment-17503981 ] Yun Gao commented on FLINK-26106: - JobManagerHAProcessFailureRecoveryITCase@1.14 https:

[jira] [Updated] (FLINK-26562) Introduce table.path option for FileStoreOptions

2022-03-09 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26562: -- Summary: Introduce table.path option for FileStoreOptions (was: Introduce table.path option in FileSt

[jira] [Updated] (FLINK-26562) Introduce table.path option in FileStoreOptions

2022-03-09 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26562: -- Summary: Introduce table.path option in FileStoreOptions (was: Introduce table path option) > Introd

[GitHub] [flink-table-store] LadyForest opened a new pull request #39: [FLINK-26562] Introduce table.path option for FileStoreOptions

2022-03-09 Thread GitBox
LadyForest opened a new pull request #39: URL: https://github.com/apache/flink-table-store/pull/39 # What is the purpose of the change Currently, the `FileStoreOptions` only has the `FILE_PATH` option as the table store root dir, we should have another `TABLE_PATH` for generated SST

[jira] [Updated] (FLINK-26562) Introduce table.path option for FileStoreOptions

2022-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26562: --- Labels: pull-request-available (was: ) > Introduce table.path option for FileStoreOptions >

[GitHub] [flink] flinkbot edited a comment on pull request #18776: [FLINK-26151][streaming]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18776: URL: https://github.com/apache/flink/pull/18776#issuecomment-1040098864 ## CI report: * 0f86d63379ee403df5bf196f9f11b5188fed70a9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] pltbkd opened a new pull request #19032: [FLINK-26564] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-09 Thread GitBox
pltbkd opened a new pull request #19032: URL: https://github.com/apache/flink/pull/19032 ## What is the purpose of the change This pull request fixes the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests. ## Brief chan

[jira] [Updated] (FLINK-26564) CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26564: --- Labels: pull-request-available (was: ) > CompactCoordinatorStateHandler doesn't properly ha

[jira] [Updated] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

2022-03-09 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26565: -- Description: Use lateTrigger when the window maxtimestap of data is less than currentwatermark . The

[GitHub] [flink] flinkbot edited a comment on pull request #18776: [FLINK-26151][streaming]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18776: URL: https://github.com/apache/flink/pull/18776#issuecomment-1040098864 ## CI report: * 0f86d63379ee403df5bf196f9f11b5188fed70a9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #19032: [FLINK-26564] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-09 Thread GitBox
flinkbot commented on pull request #19032: URL: https://github.com/apache/flink/pull/19032#issuecomment-1063628708 ## CI report: * ec989afd8ee329068a0d11ddb6ac039ea3cd1a88 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-26566) FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed on azure

2022-03-09 Thread Yun Gao (Jira)
Yun Gao created FLINK-26566: --- Summary: FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed on azure Key: FLINK-26566 URL: https://issues.apache.org/jira/browse/FLINK-26566 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 2b4ab65d7d448a28cc214e4096bb188593b7da6f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18993: [FLINK-26565][TABLE][TRIGGER]use later trigger for delay window when laterTrigger is not null

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18993: URL: https://github.com/apache/flink/pull/18993#issuecomment-1060422581 ## CI report: * 03be4626006f1e34c10c8c83b1a904e6bd80b73f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19032: [FLINK-26564] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19032: URL: https://github.com/apache/flink/pull/19032#issuecomment-1063628708 ## CI report: * ec989afd8ee329068a0d11ddb6ac039ea3cd1a88 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * bc616fc3fc62c26ffb971528dc248078ab2dd378 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18993: [FLINK-26565][TABLE][TRIGGER]use later trigger for delay window when laterTrigger is not null

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18993: URL: https://github.com/apache/flink/pull/18993#issuecomment-1060422581 ## CI report: * 03be4626006f1e34c10c8c83b1a904e6bd80b73f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fsk119 commented on pull request #18871: [FLINK-26232][tests][JUnit5 migration] Module:flink-avro

2022-03-09 Thread GitBox
fsk119 commented on pull request #18871: URL: https://github.com/apache/flink/pull/18871#issuecomment-1063637584 @flinkbot run azure In my local environment, failed to compile `AvroTypeExractionTest`. -- This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [flink] fsk119 edited a comment on pull request #18871: [FLINK-26232][tests][JUnit5 migration] Module:flink-avro

2022-03-09 Thread GitBox
fsk119 edited a comment on pull request #18871: URL: https://github.com/apache/flink/pull/18871#issuecomment-1063637584 @flinkbot run azure In my local environment, failed to compile `AvroTypeExractionTest`. ![image](https://user-images.githubusercontent.com/33114724/15758

[jira] [Updated] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

2022-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26565: --- Labels: pull-request-available (was: ) > Use lateTrigger when the window maxtimestap of dat

[jira] [Commented] (FLINK-26545) Ingress rules should be created in the same namespace with FlinkDeployment CR

2022-03-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503983#comment-17503983 ] Yang Wang commented on FLINK-26545: --- It seems that the current behavior is not correct

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink-ml] lindong28 merged pull request #68: [FLINK-26404] support non-local file systems

2022-03-09 Thread GitBox
lindong28 merged pull request #68: URL: https://github.com/apache/flink-ml/pull/68 -- 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] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] RocMarshal commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-09 Thread GitBox
RocMarshal commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r823354258 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,30 @@ specific language governing permissions and limitations under

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink-table-store] JingsongLi merged pull request #39: [FLINK-26562] Introduce table.path option for FileStoreOptions

2022-03-09 Thread GitBox
JingsongLi merged pull request #39: URL: https://github.com/apache/flink-table-store/pull/39 -- 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: issue

[GitHub] [flink] flinkbot edited a comment on pull request #19031: Update joining.md

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19031: URL: https://github.com/apache/flink/pull/19031#issuecomment-1063550945 ## CI report: * 1eda3a65fbb575bfbd493fb507102f46d6467ad6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Closed] (FLINK-26330) Test Adaptive Batch Scheduler manually

2022-03-09 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-26330. -- > Test Adaptive Batch Scheduler manually > -- > > Key:

[GitHub] [flink-ml] lindong28 commented on pull request #68: [FLINK-26404] support non-local file systems

2022-03-09 Thread GitBox
lindong28 commented on pull request #68: URL: https://github.com/apache/flink-ml/pull/68#issuecomment-1063668484 Thanks for the update! LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Closed] (FLINK-26562) Introduce table.path option for FileStoreOptions

2022-03-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26562. Fix Version/s: table-store-0.1.0 Resolution: Fixed master: 36c365d48a6d5a7f009b1f15d9f27565

[jira] [Resolved] (FLINK-26330) Test Adaptive Batch Scheduler manually

2022-03-09 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang resolved FLINK-26330. Resolution: Done > Test Adaptive Batch Scheduler manually > --

[GitHub] [flink] RocMarshal commented on a change in pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-09 Thread GitBox
RocMarshal commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r823349610 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java ## @@ -505,10 +511,10 @@ void createTemp

[jira] [Commented] (FLINK-26529) PyFlink 'tuple' object has no attribute '_values'

2022-03-09 Thread James Schulte (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503995#comment-17503995 ] James Schulte commented on FLINK-26529: --- I believe this is realated to this pull r

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

2022-03-09 Thread GitBox
zhipeng93 commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823332320 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScaler.java ## @@ -0,0 +1,165 @@ +/* + * Licensed to the Apache So

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * ecd80ec7a11dae690b258377aab2428872a0abdb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 40b70a9b1e8479f25814ecf01e978ea011eb1021 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] fredia opened a new pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2022-03-09 Thread GitBox
fredia opened a new pull request #19033: URL: https://github.com/apache/flink/pull/19033 ## What is the purpose of the change Since the FRocksDB version was upgraded to 6.20.3 in 1.14, `deleteRange()` is now usable in production. This change was previously worked by @[lgo

[jira] [Created] (FLINK-26567) FileStoreSourceSplitReader should deal with value count

2022-03-09 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26567: Summary: FileStoreSourceSplitReader should deal with value count Key: FLINK-26567 URL: https://issues.apache.org/jira/browse/FLINK-26567 Project: Flink Issue

[GitHub] [flink-table-store] JingsongLi opened a new pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

2022-03-09 Thread GitBox
JingsongLi opened a new pull request #40: URL: https://github.com/apache/flink-table-store/pull/40 There is a keyAsRecord in FileStoreSourceSplitReader, but this should only be keyAsRecord. When keyAsRecord, it should emit the same number of records as value count. -- This is an a

[jira] [Updated] (FLINK-26567) FileStoreSourceSplitReader should deal with value count

2022-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26567: --- Labels: pull-request-available (was: ) > FileStoreSourceSplitReader should deal with value

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 3bf4e3c4e401ee8283f964089700c2b265643c23 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

<    2   3   4   5   6   7   8   >