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

flinkbot edited a comment on pull request #18991: URL: https://github.com/apache/flink/pull/18991#issuecomment-1060268498 ## CI report: * de1583bca2dc4062ce5773f7dfaaeb532e1c1e27 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-26545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504067#comment-17504067 ] Matyas Orhidi commented on FLINK-26545: --- [~wangyang0918] you can enable it from helm. > Ingress

[GitHub] [flink] Kwafoor commented on pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

Kwafoor commented on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1063763070 > This to me sounds more like something that should be logged; we generally avoid exposing inherently constant values as metrics. Not inherently constant values.This

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

flinkbot edited a comment on pull request #18991: URL: https://github.com/apache/flink/pull/18991#issuecomment-1060268498 ## CI report: * de1583bca2dc4062ce5773f7dfaaeb532e1c1e27 Azure:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

JingsongLi commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823433452 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/TestDataReadWrite.java ## @@ -75,20

[GitHub] [flink] flinkbot edited a comment on pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

flinkbot edited a comment on pull request #18989: URL: https://github.com/apache/flink/pull/18989#issuecomment-1060121028 ## CI report: * 1da5d40f751ebb3d9bc2382fb7ef5ab52c69bf4f Azure:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

JingsongLi commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823432457 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReaderTest.java ## @@

[jira] [Updated] (FLINK-26574) Allow definining Operator configuration in Helm chart Values

[ https://issues.apache.org/jira/browse/FLINK-26574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26574: --- Description: Currently the Helm chart hardodes the flink-operator-config and flink-default-config

[jira] [Updated] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional

[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26537: --- Labels: pull-request-available (was: ) > Allow disabling StatefulFunctionsConfigValidator

[GitHub] [flink-statefun] FilKarnicki opened a new pull request #307: [FLINK-26537][statefun] Allow disabling StatefulFunctionsConfigValida…

FilKarnicki opened a new pull request #307: URL: https://github.com/apache/flink-statefun/pull/307 ### What is the purpose of the change The goal of this PR is to add the ability to define when a statefun job is run from an uber jar. This then disables the validation of

[jira] [Commented] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504053#comment-17504053 ] Roman Khachatryan commented on FLINK-26573: --- [~gaoyunhaii], yes, I think FLINK-26318 is

[jira] [Created] (FLINK-26574) Allow definining Operator configuration in Helm chart Values

Gyula Fora created FLINK-26574: -- Summary: Allow definining Operator configuration in Helm chart Values Key: FLINK-26574 URL: https://issues.apache.org/jira/browse/FLINK-26574 Project: Flink

[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

flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 8f35bb7e2717b5776683522b074eebabe2824734 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

flinkbot edited a comment on pull request #18989: URL: https://github.com/apache/flink/pull/18989#issuecomment-1060121028 ## CI report: * 1da5d40f751ebb3d9bc2382fb7ef5ab52c69bf4f Azure:

[GitHub] [flink] smattheis commented on pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

smattheis commented on pull request #18991: URL: https://github.com/apache/flink/pull/18991#issuecomment-1063757856 @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

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

LadyForest commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823428099 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReaderTest.java ## @@

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

LadyForest commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823428099 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReaderTest.java ## @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

rkhachatryan commented on a change in pull request #18989: URL: https://github.com/apache/flink/pull/18989#discussion_r823426495 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java

[jira] [Commented] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504049#comment-17504049 ] Yun Gao commented on FLINK-26573: - Perhaps cc [~roman] [~ym] >

[jira] [Comment Edited] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504049#comment-17504049 ] Yun Gao edited comment on FLINK-26573 at 3/10/22, 7:43 AM: --- Perhaps cc

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

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823425316 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerParams.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26573: Description: {code:java} 2022-03-09T18:27:58.5345435Z Mar 09 18:27:58 [ERROR] Tests run: 6, Failures: 0,

[jira] [Updated] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26573: Priority: Critical (was: Major) > ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on

[jira] [Commented] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504046#comment-17504046 ] Yun Gao commented on FLINK-26573: -

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

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

[jira] [Created] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure

Yun Gao created FLINK-26573: --- Summary: ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure Key: FLINK-26573 URL: https://issues.apache.org/jira/browse/FLINK-26573 Project: Flink

[GitHub] [flink] Myasuka commented on pull request #19029: [FLINK-26418][runtime][test] Use java.io.tmpdir for tmpWorkingDir

Myasuka commented on pull request #19029: URL: https://github.com/apache/flink/pull/19029#issuecomment-1063749872 I think this patch could resolve some problems, but I am not sure whether this fix could avoid to make all local test directories stay in the working directory. -- This is

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

LadyForest commented on a change in pull request #40: URL: https://github.com/apache/flink-table-store/pull/40#discussion_r823420125 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/TestDataReadWrite.java ## @@ -75,20

[jira] [Created] (FLINK-26572) Re-schedule reconcile more often until job is in ready state

Gyula Fora created FLINK-26572: -- Summary: Re-schedule reconcile more often until job is in ready state Key: FLINK-26572 URL: https://issues.apache.org/jira/browse/FLINK-26572 Project: Flink

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

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823414741 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerParams.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-26571) Savepoint trigger/tracking improvements

Gyula Fora created FLINK-26571: -- Summary: Savepoint trigger/tracking improvements Key: FLINK-26571 URL: https://issues.apache.org/jira/browse/FLINK-26571 Project: Flink Issue Type: Sub-task

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

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

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

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

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

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823413341 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/feature/MinMaxScalerTest.java ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache Software

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

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823412958 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasOutputCol.java ## @@ -0,0 +1,39 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] dawidwys commented on pull request #19029: [FLINK-26418][runtime][test] Use java.io.tmpdir for tmpWorkingDir

dawidwys commented on pull request #19029: URL: https://github.com/apache/flink/pull/19029#issuecomment-1063739269 cc @Myasuka -- 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

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

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823410761 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerModel.java ## @@ -0,0 +1,179 @@ +/* + * Licensed to the

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

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823407289 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerModel.java ## @@ -0,0 +1,179 @@ +/* + * Licensed to the

[GitHub] [flink] Myasuka commented on a change in pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

Myasuka commented on a change in pull request #18989: URL: https://github.com/apache/flink/pull/18989#discussion_r823406204 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java ## @@

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

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

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823402845 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/feature/MinMaxScalerTest.java ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] matriv commented on pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

matriv commented on pull request #18980: URL: https://github.com/apache/flink/pull/18980#issuecomment-1063728285 @twalthr Please check, I hope I've addressed all the comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

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

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

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19014: [FLINK-24586][table-planner] JSON_VALUE should return STRING instead of VARCHAR(2000)

flinkbot edited a comment on pull request #19014: URL: https://github.com/apache/flink/pull/19014#issuecomment-1062677742 ## CI report: * 1019aa38945c228bd2b619ec83b75fe4d495df49 Azure:

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

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

LadyForest edited a comment on pull request #19007: URL: https://github.com/apache/flink/pull/19007#issuecomment-1063581072 Hi, @JingsongLi, 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

[jira] [Comment Edited] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504032#comment-17504032 ] Matthias Pohl edited comment on FLINK-25771 at 3/10/22, 6:50 AM: - I'm

[jira] [Comment Edited] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504032#comment-17504032 ] Matthias Pohl edited comment on FLINK-25771 at 3/10/22, 6:50 AM: - I'm

[GitHub] [flink] flinkbot edited a comment on pull request #19014: [FLINK-24586][table-planner] JSON_VALUE should return STRING instead of VARCHAR(2000)

flinkbot edited a comment on pull request #19014: URL: https://github.com/apache/flink/pull/19014#issuecomment-1062677742 ## CI report: * 1019aa38945c228bd2b619ec83b75fe4d495df49 Azure:

[jira] [Reopened] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-25771: --- I'm going to reopen this issue because we experienced the same build failure in [this

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

[jira] [Updated] (FLINK-26530) Introduce TableStore API and refactor ITCases

[ https://issues.apache.org/jira/browse/FLINK-26530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26530: - Summary: Introduce TableStore API and refactor ITCases (was: Introduce TableStore API) >

[jira] [Created] (FLINK-26570) Remote module configuration interpolation

Fil Karnicki created FLINK-26570: Summary: Remote module configuration interpolation Key: FLINK-26570 URL: https://issues.apache.org/jira/browse/FLINK-26570 Project: Flink Issue Type:

[GitHub] [flink-table-store] JingsongLi removed a comment on pull request #36: [FLINK-26530] Introduce TableStore API

JingsongLi removed a comment on pull request #36: URL: https://github.com/apache/flink-table-store/pull/36#issuecomment-1062600574 TODO refactor itcases based on new API. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-26569) testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing

[ https://issues.apache.org/jira/browse/FLINK-26569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504031#comment-17504031 ] Matthias Pohl commented on FLINK-26569: --- I had to update the issue: The build failure actually

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

[jira] [Updated] (FLINK-26569) testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing

[ https://issues.apache.org/jira/browse/FLINK-26569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26569: -- Summary:

[jira] [Updated] (FLINK-26569) testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing on master

[ https://issues.apache.org/jira/browse/FLINK-26569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26569: -- Fix Version/s: (was: 1.15.0) >

[jira] [Updated] (FLINK-26569) testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing on master

[ https://issues.apache.org/jira/browse/FLINK-26569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26569: -- Affects Version/s: 1.13.6 (was: 1.15.0) >

[jira] [Created] (FLINK-26569) testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing on master

Matthias Pohl created FLINK-26569: - Summary: testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing on master Key: FLINK-26569 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

flinkbot edited a comment on pull request #18980: URL: https://github.com/apache/flink/pull/18980#issuecomment-1059275933 ## CI report: * 900b4763d3add6404a15588dacce66be5dbf67bd Azure:

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

flinkbot edited a comment on pull request #18980: URL: https://github.com/apache/flink/pull/18980#issuecomment-1059275933 ## CI report: * 900b4763d3add6404a15588dacce66be5dbf67bd Azure:

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504026#comment-17504026 ] Matthias Pohl commented on FLINK-26568: --- It was identified on a branch that only adds logs to an

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

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

Matthias Pohl created FLINK-26568: - Summary: BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure Key: FLINK-26568 URL: https://issues.apache.org/jira/browse/FLINK-26568

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

ChengkaiYang2022 commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r823384807 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,30 @@ specific language governing permissions and limitations

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

[jira] [Assigned] (FLINK-123) Strange (and faulty) Iterations Behaviour

[ https://issues.apache.org/jira/browse/FLINK-123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-123: --- Assignee: Ufuk Celebi (was: Matthias Pohl) > Strange (and faulty) Iterations Behaviour >

[jira] [Assigned] (FLINK-123) Strange (and faulty) Iterations Behaviour

[ https://issues.apache.org/jira/browse/FLINK-123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-123: --- Assignee: Matthias Pohl > Strange (and faulty) Iterations Behaviour >

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

flinkbot edited a comment on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1063699541 ## CI report: * 7d1dbec66de54a97fb4a1a9a9304806bbe4da9af Azure:

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * d9ffed1defa7514c27d3ba9a9e3008de8b84bc68 Azure:

[GitHub] [flink] flinkbot commented on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

flinkbot commented on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1063699541 ## CI report: * 7d1dbec66de54a97fb4a1a9a9304806bbe4da9af UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure:

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

flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 3bf4e3c4e401ee8283f964089700c2b265643c23 Azure:

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

[ 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-table-store] JingsongLi opened a new pull request #40: [FLINK-26567] FileStoreSourceSplitReader should deal with value count

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

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

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

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

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

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

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 40b70a9b1e8479f25814ecf01e978ea011eb1021 Azure:

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

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * ecd80ec7a11dae690b258377aab2428872a0abdb Azure:

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-26529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503995#comment-17503995 ] James Schulte commented on FLINK-26529: --- I believe this is realated to this pull request -

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

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

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

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

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

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

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

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

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

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

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

flinkbot edited a comment on pull request #19031: URL: https://github.com/apache/flink/pull/19031#issuecomment-1063550945 ## CI report: * 1eda3a65fbb575bfbd493fb507102f46d6467ad6 Azure:

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

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

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure:

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

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:

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

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure:

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

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:

  1   2   3   4   5   6   7   8   >