[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

[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

[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

[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

[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] 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 #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 #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 #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 #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

[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 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

[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

[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

[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

[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

[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

[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-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 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

[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] [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=17503980#comment-17503980 ] Yun Gao commented on FLINK-26106: - 1.15: https://dev.azure.com/apache-flink/apache-flin

[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

[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] [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

[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-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] [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-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-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] [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] [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] [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] [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] [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-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] [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

[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] [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 > -

[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] [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

[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-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] 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

[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] 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-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] 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] 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-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] 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] 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

[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

[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

[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] [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] 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

[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 #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] 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-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

[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

[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.executeSq

[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.executeSq

[GitHub] [flink] flinkbot edited a comment 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
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 7d4fa8b9bc0e3c8fce18c6e5c267ef3d644f454e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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.executeSq

[jira] [Created] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes

2022-03-09 Thread bo zhao (Jira)
bo zhao created FLINK-26559: --- Summary: Support Customized Kubernetes Schedulers for Flink Kubernetes Key: FLINK-26559 URL: https://issues.apache.org/jira/browse/FLINK-26559 Project: Flink Issue Ty

[GitHub] [flink] flinkbot edited a comment 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
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 7d4fa8b9bc0e3c8fce18c6e5c267ef3d644f454e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #19031: Update joining.md

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

[GitHub] [flink] Yankee24 opened a new pull request #19031: Update joining.md

2022-03-09 Thread GitBox
Yankee24 opened a new pull request #19031: URL: https://github.com/apache/flink/pull/19031 intervalJoin 示例Java片段变量名称 ## 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 wa

[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: * 231fe94de30c0a3dee18cf92474084b9416917bd Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[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: * 11d5826f48b8879327f2baf80feb7c58103a6566 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19030: [FLINK-26557][docs] Extend CsvFormat documentation

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

[GitHub] [flink] flinkbot edited a comment on pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

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

[GitHub] [flink] flinkbot edited a comment on pull request #19024: [FLINK-26349][AvroParquet][test] add UT for reading reflect records from parquet file created with generic record schema.

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

[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: * 11d5826f48b8879327f2baf80feb7c58103a6566 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: * 11d5826f48b8879327f2baf80feb7c58103a6566 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: * 11d5826f48b8879327f2baf80feb7c58103a6566 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26558) Errors when reporting on Job status

2022-03-09 Thread Jeremy DeGroot (Jira)
Jeremy DeGroot created FLINK-26558: -- Summary: Errors when reporting on Job status Key: FLINK-26558 URL: https://issues.apache.org/jira/browse/FLINK-26558 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-26311) Test CsvFormat

2022-03-09 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503882#comment-17503882 ] Alexander Fedulov commented on FLINK-26311: --- [~gaoyunhaii] thanks a lot for th

[jira] [Comment Edited] (FLINK-26311) Test CsvFormat

2022-03-09 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503882#comment-17503882 ] Alexander Fedulov edited comment on FLINK-26311 at 3/9/22, 10:23 PM: -

[jira] [Comment Edited] (FLINK-26232) [JUnit5 Migration] Module: flink-avro

2022-03-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503518#comment-17503518 ] Chesnay Schepler edited comment on FLINK-26232 at 3/9/22, 10:20 PM: --

<    1   2   3   4   5   6   7   8   >