[jira] [Comment Edited] (FLINK-26793) Flink Cassandra connector performance issue

2022-03-22 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510394#comment-17510394 ] Etienne Chauchot edited comment on FLINK-26793 at 3/22/22, 10:37 AM: -

[jira] [Commented] (FLINK-26793) Flink Cassandra connector performance issue

2022-03-22 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510394#comment-17510394 ] Etienne Chauchot commented on FLINK-26793: -- I just saw this ticket. I think sol

[jira] [Closed] (FLINK-26376) Replace TableConfig with PlannerConfig in PlannerContext

2022-03-22 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas closed FLINK-26376. --- Resolution: Invalid This issue is not valid anymore, as it's superseded by the work in http

[GitHub] [flink] flinkbot edited a comment on pull request #19176: [FLINK-26477][python] Support WindowedStream.aggregate in Python DataStream API

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

[GitHub] [flink] zentol commented on a change in pull request #18983: [FLINK-25543][flink-yarn] [JUnit5 Migration] Module: flink-yarn

2022-03-22 Thread GitBox
zentol commented on a change in pull request #18983: URL: https://github.com/apache/flink/pull/18983#discussion_r832012052 ## File path: flink-yarn/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension ## @@ -0,0 +1,16 @@ +# Licensed to the Apache Soft

[jira] [Closed] (FLINK-26747) [JUnit5 Migration] Module: flink-external-resources

2022-03-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26747. Fix Version/s: 1.16.0 Assignee: RocMarshal Resolution: Fixed master: a9f95

[jira] [Closed] (FLINK-26765) Document RBAC model

2022-03-22 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-26765. -- Resolution: Fixed Fixed via [{{c7265c2}}|https://github.com/apache/flink-kubernetes-operator/

[GitHub] [flink] flinkbot edited a comment on pull request #19086: [FLINK-26767][python] Update code to use the changes for TableConfig

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

[GitHub] [flink] zentol merged pull request #19169: [FLINK-26747][flink-external-resource-gpu][JUnit5 Migration] Module: flink-external-resources

2022-03-22 Thread GitBox
zentol merged pull request #19169: URL: https://github.com/apache/flink/pull/19169 -- 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] [Closed] (FLINK-26758) [JUnit5 Migration] Module: flink-container

2022-03-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26758. Fix Version/s: 1.16.0 Resolution: Fixed master: 950cd16c1fc4fd4e8fc5a4211d49e870410

[jira] [Assigned] (FLINK-26758) [JUnit5 Migration] Module: flink-container

2022-03-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-26758: Assignee: RocMarshal > [JUnit5 Migration] Module: flink-container > -

[GitHub] [flink] zentol merged pull request #19175: [FLINK-26758][container][JUnit5 Migration] Module: flink-container

2022-03-22 Thread GitBox
zentol merged pull request #19175: URL: https://github.com/apache/flink/pull/19175 -- 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-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832004245 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/OnlineKMeansTest.java ## @@ -0,0 +1,511 @@ +/* + * Licensed to the Apache So

[GitHub] [flink] flinkbot edited a comment on pull request #19191: [FLINK-26741][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19191: URL: https://github.com/apache/flink/pull/19191#issuecomment-1073952732 ## CI report: * 5df4f200865d40d4ae1c96cfc992d5b302dc6756 UNKNOWN * 02db7936cd90dbd4a7a2ac6ddf930ffb37504e6a Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19185: [hotfix][test-utils-junit] Improve assertion errors

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

[jira] [Updated] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-22 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-26568: Attachment: image-2022-03-22-18-19-53-171.png > BlockingShuffleITCase.testDeletePartitionFileOfBou

[jira] [Created] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

2022-03-22 Thread fanrui (Jira)
fanrui created FLINK-26803: -- Summary: Merge small ChannelState file for Unaligned Checkpoint Key: FLINK-26803 URL: https://issues.apache.org/jira/browse/FLINK-26803 Project: Flink Issue Type: Improv

[GitHub] [flink] flinkbot edited a comment on pull request #19135: [FLINK-26708] TimestampsAndWatermarksOperator should not propagate WatermarkStatus

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

[GitHub] [flink] wenlong88 commented on a change in pull request #19188: [FLINK-26770][table] Fix ArrayToArrayCastRule array type

2022-03-22 Thread GitBox
wenlong88 commented on a change in pull request #19188: URL: https://github.com/apache/flink/pull/19188#discussion_r832003274 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/ArrayToArrayCastRule.java ## @@ -109,7 +11

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 494ce3da2dae8331568c8acde895b935ef6229af Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19086: [FLINK-26767][python] Update code to use the changes for TableConfig

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

[GitHub] [flink] flinkbot edited a comment on pull request #19087: [FLINK-26467][table-planner] Compile RowDataToStringConverter lazily

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

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832001871 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,409 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832001871 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,409 @@ +/* + * Licensed to the Apache

[GitHub] [flink] pnowojski merged pull request #19145: [hotfix][streaming] rename local variable name and fix some typos

2022-03-22 Thread GitBox
pnowojski merged pull request #19145: URL: https://github.com/apache/flink/pull/19145 -- 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-unsub

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832001871 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,409 @@ +/* + * Licensed to the Apache

[jira] [Closed] (FLINK-26554) Clean termination of FlinkDeployment

2022-03-22 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26554. -- Resolution: Fixed merged to main: 758ed1c8a391b7abdac147af23f857c032186b0a > Clean termination of Fli

[GitHub] [flink] SteNicholas commented on a change in pull request #19179: [FLINK-26756][table-planner] Fix the deserialization error for match recognize

2022-03-22 Thread GitBox
SteNicholas commented on a change in pull request #19179: URL: https://github.com/apache/flink/pull/19179#discussion_r831998386 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeJsonSerializer.java ## @@ -39

[GitHub] [flink] flinkbot edited a comment on pull request #19197: [FLINK-26777][table-planner] Use TableConfig as a complete view of defined configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #19191: [FLINK-26741][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19191: URL: https://github.com/apache/flink/pull/19191#issuecomment-1073952732 ## CI report: * 5df4f200865d40d4ae1c96cfc992d5b302dc6756 UNKNOWN * 02db7936cd90dbd4a7a2ac6ddf930ffb37504e6a Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19185: [hotfix][test-utils-junit] Improve assertion errors

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

[GitHub] [flink] flinkbot edited a comment on pull request #19135: [FLINK-26708] TimestampsAndWatermarksOperator should not propagate WatermarkStatus

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

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 494ce3da2dae8331568c8acde895b935ef6229af Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19188: [FLINK-26770][table] Fix ArrayToArrayCastRule array type

2022-03-22 Thread GitBox
slinkydeveloper commented on a change in pull request #19188: URL: https://github.com/apache/flink/pull/19188#discussion_r831995668 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/casting/CastRulesTest.java ## @@ -1258,8 +12

[GitHub] [flink] flinkbot edited a comment on pull request #19087: [FLINK-26467][table-planner] Compile RowDataToStringConverter lazily

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

[jira] [Commented] (FLINK-26801) LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next res...

2022-03-22 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510382#comment-17510382 ] Zhipeng Zhang commented on FLINK-26801: --- another similar one: https://github.com/

[jira] [Resolved] (FLINK-25552) Support MinMaxScaler in FlinkML

2022-03-22 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-25552. --- Assignee: weibo zhao Resolution: Fixed Solved on master: 3ab327394769d5bd4f88be04428d3

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r831990504 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/util/MockKVStore.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] dawidwys commented on pull request #19135: [FLINK-26708] TimestampsAndWatermarksOperator should not propagate WatermarkStatus

2022-03-22 Thread GitBox
dawidwys commented on pull request #19135: URL: https://github.com/apache/flink/pull/19135#issuecomment-1074975016 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[GitHub] [flink] SteNicholas commented on a change in pull request #19179: [FLINK-26756][table-planner] Fix the deserialization error for match recognize

2022-03-22 Thread GitBox
SteNicholas commented on a change in pull request #19179: URL: https://github.com/apache/flink/pull/19179#discussion_r831989990 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeJsonDeserializer.java ## @@ -

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r831989881 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/util/TestMetricReporter.java ## @@ -0,0 +1,97 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink] flinkbot commented on pull request #19197: [FLINK-26777][table-planner] Use TableConfig as a complete view of defined configuration

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r831989288 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/StreamingKMeans.java ## @@ -0,0 +1,404 @@ +/* + * Licensed to the Apa

[GitHub] [flink] flinkbot edited a comment on pull request #19191: [FLINK-26741][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19191: URL: https://github.com/apache/flink/pull/19191#issuecomment-1073952732 ## CI report: * 5df4f200865d40d4ae1c96cfc992d5b302dc6756 UNKNOWN * 02db7936cd90dbd4a7a2ac6ddf930ffb37504e6a Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19183: [FLINK-26766][Runtime/StateBackends] Fix ChangelogStateHandleStreamImpl#getIntersection

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r831988352 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/StreamingKMeans.java ## @@ -0,0 +1,404 @@ +/* + * Licensed to the Apa

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 494ce3da2dae8331568c8acde895b935ef6229af Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r831986897 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/StreamingKMeans.java ## @@ -0,0 +1,404 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-26712) Metadata keys should not conflict with physical columns

2022-03-22 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510380#comment-17510380 ] Timo Walther commented on FLINK-26712: -- [~hackergin] Sorry, I somehow missed your c

[jira] [Commented] (FLINK-26759) Legacy source support waiting for recordWriter to be available

2022-03-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510379#comment-17510379 ] Martijn Visser commented on FLINK-26759: If there's no desire to change old code

[GitHub] [flink] matriv opened a new pull request #19197: [FLINK-26777][table-planner] Use TableConfig as a complete view of defined configuration

2022-03-22 Thread GitBox
matriv opened a new pull request #19197: URL: https://github.com/apache/flink/pull/19197 ## What is the purpose of the change Make use of `TableConfig` as a `ReadableConfig` to get the full view of the defined configuration, `rootConfiguration` (containing enviroment defined config

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

2022-03-22 Thread GitBox
zhipeng93 commented on pull request #54: URL: https://github.com/apache/flink-ml/pull/54#issuecomment-1074967174 Thanks @weibozhao for the PR and @lindong28 @yunfengzhou-hub for the review. Merging now. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on pull request #19191: [FLINK-26741][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19191: URL: https://github.com/apache/flink/pull/19191#issuecomment-1073952732 ## CI report: * 5df4f200865d40d4ae1c96cfc992d5b302dc6756 UNKNOWN * 02db7936cd90dbd4a7a2ac6ddf930ffb37504e6a Azure: [FAILURE](https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-22 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510376#comment-17510376 ] Alexander Preuss commented on FLINK-26281: -- Hi [~guoyangze], yes you can use al

[GitHub] [flink] flinkbot edited a comment on pull request #19190: [FLINK-13785][table] Port time functions to new type inference

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

[GitHub] [flink] flinkbot edited a comment on pull request #19137: [FLINK-26518][table] Support BridgingSqlFunction with SqlTableFunction for Scala implicits

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

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 494ce3da2dae8331568c8acde895b935ef6229af Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink-ml] zhipeng93 closed pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler

2022-03-22 Thread GitBox
zhipeng93 closed pull request #54: URL: https://github.com/apache/flink-ml/pull/54 -- 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] slinkydeveloper commented on a change in pull request #19188: [FLINK-26770][table] Fix ArrayToArrayCastRule array type

2022-03-22 Thread GitBox
slinkydeveloper commented on a change in pull request #19188: URL: https://github.com/apache/flink/pull/19188#discussion_r831978640 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/ArrayToArrayCastRule.java ## @@ -109

[GitHub] [flink] flinkbot edited a comment on pull request #19196: [FLINK-26741][BP-1.15][runtime] The CheckpointIDCounter.shutdown method should work idempotently

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

[GitHub] [flink] flinkbot edited a comment on pull request #19193: [FLINK-22315][SQL-API] Support ADD column/constraint/watermark for ALTER TABLE statement

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

[GitHub] [flink] flinkbot edited a comment on pull request #19191: [FLINK-26741][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19191: URL: https://github.com/apache/flink/pull/19191#issuecomment-1073952732 ## CI report: * 5df4f200865d40d4ae1c96cfc992d5b302dc6756 UNKNOWN * 02db7936cd90dbd4a7a2ac6ddf930ffb37504e6a Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19190: [FLINK-13785][table] Port time functions to new type inference

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

[jira] [Closed] (FLINK-26795) Fix the CI not fail fast after build failed

2022-03-22 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-26795. -- Resolution: Fixed Fixed via [{{c2a3ba9}}|https://github.com/apache/flink-kubernetes-operator/

[GitHub] [flink] flinkbot edited a comment on pull request #19137: [FLINK-26518][table] Support BridgingSqlFunction with SqlTableFunction for Scala implicits

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

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 494ce3da2dae8331568c8acde895b935ef6229af Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] dannycranmer commented on a change in pull request #18518: [FLINK-24229][connectors/dynamodb] Added DynamoDB connector

2022-03-22 Thread GitBox
dannycranmer commented on a change in pull request #18518: URL: https://github.com/apache/flink/pull/18518#discussion_r831969864 ## File path: flink-connectors/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSink.java ## @@ -0

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510372#comment-17510372 ] Yangze Guo commented on FLINK-26281: [~fpaul] Thanks, and very much looking forward

[jira] [Updated] (FLINK-26765) Document RBAC model

2022-03-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26765: --- Labels: pull-request-available (was: ) > Document RBAC model > --- > >

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

2022-03-22 Thread Johnson Okorie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510369#comment-17510369 ] Johnson Okorie commented on FLINK-26274: [~chesnay], have you had an opportunity

[GitHub] [flink] flinkbot edited a comment on pull request #19191: [FLINK-26741][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19191: URL: https://github.com/apache/flink/pull/19191#issuecomment-1073952732 ## CI report: * 5df4f200865d40d4ae1c96cfc992d5b302dc6756 UNKNOWN * 02db7936cd90dbd4a7a2ac6ddf930ffb37504e6a Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot commented on pull request #19196: [FLINK-26741][BP-1.15][runtime] The CheckpointIDCounter.shutdown method should work idempotently

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

[GitHub] [flink] flinkbot edited a comment on pull request #19190: [FLINK-13785][table] Port time functions to new type inference

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

[GitHub] [flink] flinkbot edited a comment on pull request #19180: [BP-1.15][FLINK-26633][elasticsearch] Add recordSend metric to elasticsearch sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 494ce3da2dae8331568c8acde895b935ef6229af Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] wenlong88 commented on a change in pull request #19188: [FLINK-26770][table] Fix ArrayToArrayCastRule array type

2022-03-22 Thread GitBox
wenlong88 commented on a change in pull request #19188: URL: https://github.com/apache/flink/pull/19188#discussion_r831959600 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/casting/CastRulesTest.java ## @@ -1258,8 +1258,8 @

[jira] [Updated] (FLINK-26802) StreamPhysicalOverAggregate doesn't support consuming update and delete changes which is produced by node Deduplicate

2022-03-22 Thread zhiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhiyuan updated FLINK-26802: Attachment: image-2022-03-22-17-37-09-443.png Description: Problem description: using topn to de-dup

[GitHub] [flink] zhoulii commented on pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source

2022-03-22 Thread GitBox
zhoulii commented on pull request #19152: URL: https://github.com/apache/flink/pull/19152#issuecomment-1074936494 > I found that after changing to new source, tpcds runs slower than before. This is probably mainly because the new csv source is slower than the legacy `CsvTableSource`. It on

[jira] [Created] (FLINK-26802) StreamPhysicalOverAggregate doesn't support consuming update and delete changes which is produced by node Deduplicate

2022-03-22 Thread zhiyuan (Jira)
zhiyuan created FLINK-26802: --- Summary: StreamPhysicalOverAggregate doesn't support consuming update and delete changes which is produced by node Deduplicate Key: FLINK-26802 URL: https://issues.apache.org/jira/browse/FL

[GitHub] [flink] XComp opened a new pull request #19196: [FLINK-26741][BP-1.15][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
XComp opened a new pull request #19196: URL: https://github.com/apache/flink/pull/19196 1.15 backport of PR #19191 No conflicts appeared during backport: ``` git cherry-pick ccd98ac920969204576161ac9a23e9660f6014e1 9d5feafa7d0d652ff58e9c067afd914fbee9abd0 ``` -- This is an autom

[GitHub] [flink] flinkbot edited a comment on pull request #19195: [FLINK-26798][runtime] Hardens test against unexpected heartbeat

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

[GitHub] [flink] flinkbot edited a comment on pull request #19190: [FLINK-13785][table] Port time functions to new type inference

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

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 494ce3da2dae8331568c8acde895b935ef6229af Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] XComp commented on pull request #19191: [FLINK-26741][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
XComp commented on pull request #19191: URL: https://github.com/apache/flink/pull/19191#issuecomment-1074931227 I did a slight change to the cleanup log message hotfix commit changing the wording a bit... -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] flinkbot commented on pull request #19195: [FLINK-26798][runtime] Hardens test against unexpected heartbeat

2022-03-22 Thread GitBox
flinkbot commented on pull request #19195: URL: https://github.com/apache/flink/pull/19195#issuecomment-1074927542 ## CI report: * 6d5c6695c39357426e075bb7c4b385a7832413a5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19190: [FLINK-13785][table] Port time functions to new type inference

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-997659194 ## CI report: * 849140b4515a43a19f74a3b5a38579f0955bf8a4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 494ce3da2dae8331568c8acde895b935ef6229af Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] XComp commented on pull request #19191: [FLINK-26741][runtime] The CheckpointIDCounter.shutdown method should work idempotently

2022-03-22 Thread GitBox
XComp commented on pull request #19191: URL: https://github.com/apache/flink/pull/19191#issuecomment-1074924947 CI failure caused by FLINK-26621. I will go ahead squashing everything and create a backport -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] wanglijie95 commented on pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source

2022-03-22 Thread GitBox
wanglijie95 commented on pull request #19152: URL: https://github.com/apache/flink/pull/19152#issuecomment-1074923533 I found that after changing to new source, tpcds runs slower than before. This is probably mainly because the new csv source is slower than the legacy `CsvTableSource`. It

[jira] [Comment Edited] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-22 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510356#comment-17510356 ] Konstantin Knauf edited comment on FLINK-26281 at 3/22/22, 9:20 AM: --

[jira] [Updated] (FLINK-26798) JobMaster.testJobFailureWhenTaskExecutorHeartbeatTimeout failed due to missing Execution

2022-03-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26798: --- Labels: pull-request-available test-stability (was: test-stability) > JobMaster.testJobFail

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-22 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510356#comment-17510356 ] Konstantin Knauf commented on FLINK-26281: -- I've done a couple of tests with ES

[GitHub] [flink] XComp opened a new pull request #19195: [FLINK-26798][runtime] Hardens test against unexpected heartbeat

2022-03-22 Thread GitBox
XComp opened a new pull request #19195: URL: https://github.com/apache/flink/pull/19195 ## What is the purpose of the change `testJobFailureWhenTaskExecutorHeartbeatTimeout` failed due to a heartbeat being processed during the test. The missing payload of the test implementation

[GitHub] [flink] flinkbot edited a comment on pull request #19190: [FLINK-13785][table] Port time functions to new type inference

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

[jira] [Updated] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

2022-03-22 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26683: - Affects Version/s: 1.14.4 > Terminate the job anyway if savepoint finished when stop-wit

[jira] [Updated] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

2022-03-22 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26683: - Fix Version/s: 1.16.0 > Terminate the job anyway if savepoint finished when stop-with-sa

[jira] [Comment Edited] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-03-22 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510351#comment-17510351 ] Lijie Wang edited comment on FLINK-26760 at 3/22/22, 9:12 AM:

[jira] [Updated] (FLINK-26798) JobMaster.testJobFailureWhenTaskExecutorHeartbeatTimeout failed due to missing Execution

2022-03-22 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26798: -- Affects Version/s: 1.14.4 > JobMaster.testJobFailureWhenTaskExecutorHeartbeatTimeout failed du

<    1   2   3   4   5   6   7   >