[jira] [Created] (FLINK-27002) Optimize batch multiple partitions inserting

Jingsong Lee created FLINK-27002: Summary: Optimize batch multiple partitions inserting Key: FLINK-27002 URL: https://issues.apache.org/jira/browse/FLINK-27002 Project: Flink Issue Type: Sub-

[GitHub] [flink-ml] weibozhao commented on a change in pull request #56: [FLINK-25616] Add Transformer for VectorAssembler

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

[jira] [Commented] (FLINK-26515) RetryingExecutorTest.testTimeout failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516237#comment-17516237 ] Yun Tang commented on FLINK-26515: -- Another instance https://dev.azure.com/fredia/flin

[GitHub] [flink-benchmarks] fredia edited a comment on pull request #23: [FLINK-23399][state] Add a benchmark for rescaling

fredia edited a comment on pull request #23: URL: https://github.com/apache/flink-benchmarks/pull/23#issuecomment-1086559519 hi @pnowojski, I updated this PR according to the suggestion above, would you please take a review again? I move some code to [flink-state-backends](https://gith

[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_r841022328 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala ## @@ -656,13 +656,48 @@ class Tabl

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

yunfengzhou-hub commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r841022266 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/Benchmark.java ## @@ -0,0 +1,136 @@ +/* + * Licensed to the Apache Soft

[jira] [Closed] (FLINK-26911) Introduce parallelism setter for table store

[ https://issues.apache.org/jira/browse/FLINK-26911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26911. Resolution: Fixed master: 118d5cf61f3086afc1885bf6880dc78162cc8ba7 > Introduce parallelism setter

[GitHub] [flink-table-store] JingsongLi merged pull request #67: [FLINK-26911] Introduce parallelism setter for table store

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

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #73: [FLINK-26626] Add Transformer and Estimator for StandardScaler

zhipeng93 commented on a change in pull request #73: URL: https://github.com/apache/flink-ml/pull/73#discussion_r841019214 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScalerParams.java ## @@ -0,0 +1,54 @@ +/* + * Licensed to the

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

yunfengzhou-hub commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r841020736 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasOutputCols.java ## @@ -19,15 +19,13 @@ package org.apache.flink.ml.com

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #73: [FLINK-26626] Add Transformer and Estimator for StandardScaler

zhipeng93 commented on a change in pull request #73: URL: https://github.com/apache/flink-ml/pull/73#discussion_r841019214 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScalerParams.java ## @@ -0,0 +1,54 @@ +/* + * Licensed to the

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

yunfengzhou-hub commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r841018540 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/Benchmark.java ## @@ -0,0 +1,136 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink] flinkbot edited a comment on pull request #19328: [FLINK-26969][Examples] Write operation examples of tumbling window, sliding window, session window and count window based on pyflink

flinkbot edited a comment on pull request #19328: URL: https://github.com/apache/flink/pull/19328#issuecomment-1085814902 ## CI report: * 689fb5060be833f77a3fe849b327185353a0a659 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-benchmarks] fredia commented on pull request #23: [FLINK-23399][state] Add a benchmark for rescaling

fredia commented on pull request #23: URL: https://github.com/apache/flink-benchmarks/pull/23#issuecomment-1086559519 hi @pnowojski, I updated this PR according to the suggestion above, would you please take a review again? I move some code to [flink-state-backends](https://github.com/

[GitHub] [flink] flinkbot edited a comment on pull request #19333: [FLINK-26190][python] Remove getTableConfig from ExecNodeConfiguration

flinkbot edited a comment on pull request #19333: URL: https://github.com/apache/flink/pull/19333#issuecomment-1086447112 ## CI report: * 0ae998978c02b08d84eb814e3c9fd95b15883f3b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19328: [FLINK-26969][Examples] Write operation examples of tumbling window, sliding window, session window and count window based on pyflink

flinkbot edited a comment on pull request #19328: URL: https://github.com/apache/flink/pull/19328#issuecomment-1085814902 ## CI report: * 689fb5060be833f77a3fe849b327185353a0a659 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19333: [FLINK-26190][python] Remove getTableConfig from ExecNodeConfiguration

flinkbot edited a comment on pull request #19333: URL: https://github.com/apache/flink/pull/19333#issuecomment-1086447112 ## CI report: * 0ae998978c02b08d84eb814e3c9fd95b15883f3b 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 #56: [FLINK-25616] Add Transformer for VectorAssembler

lindong28 commented on a change in pull request #56: URL: https://github.com/apache/flink-ml/pull/56#discussion_r841016863 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasHandleInvalid.java ## @@ -37,13 +37,14 @@ public interface HasHandleInvalid

[GitHub] [flink-ml] lindong28 commented on a change in pull request #56: [FLINK-25616] Add Transformer for VectorAssembler

lindong28 commented on a change in pull request #56: URL: https://github.com/apache/flink-ml/pull/56#discussion_r841016785 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java ## @@ -0,0 +1,183 @@ +/* + * Licensed to the Apa

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

JingsongLi commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841016700 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java ## @@ -1713,4 +1748,74

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

JingsongLi commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841016680 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java ## @@ -1713,4 +1748,74

[GitHub] [flink] ZhangChaoming commented on pull request #19325: [FLINK-26943][table] Add DATE_ADD supported in SQL & Table API

ZhangChaoming commented on pull request #19325: URL: https://github.com/apache/flink/pull/19325#issuecomment-1086557594 @slinkydeveloper OK, I try use new stack. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

JingsongLi commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841016341 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/TableStoreSource.java ## @@ -130,15 +135,2

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

ZhangChaoming commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r841015721 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala ## @@ -656,13 +656,48 @@ class T

[GitHub] [flink-ml] lindong28 commented on a change in pull request #73: [FLINK-26626] Add Transformer and Estimator for StandardScaler

lindong28 commented on a change in pull request #73: URL: https://github.com/apache/flink-ml/pull/73#discussion_r841012351 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScalerParams.java ## @@ -0,0 +1,54 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516222#comment-17516222 ] RocMarshal commented on FLINK-25738: Hi [~martijnvisser] , I notice that the related

[jira] [Created] (FLINK-27001) Support to specify the resource of the operator

Aitozi created FLINK-27001: -- Summary: Support to specify the resource of the operator Key: FLINK-27001 URL: https://issues.apache.org/jira/browse/FLINK-27001 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27000) Support to set JVM args for operator

Aitozi created FLINK-27000: -- Summary: Support to set JVM args for operator Key: FLINK-27000 URL: https://issues.apache.org/jira/browse/FLINK-27000 Project: Flink Issue Type: Improvement Co

[jira] [Comment Edited] (FLINK-26982) strike a balance between reuse the same RelNode and project/filter/limit/partition push down

[ https://issues.apache.org/jira/browse/FLINK-26982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516221#comment-17516221 ] zoucao edited comment on FLINK-26982 at 4/2/22 5:25 AM: I think

[jira] [Commented] (FLINK-26982) strike a balance between reuse the same RelNode and project/filter/limit/partition push down

[ https://issues.apache.org/jira/browse/FLINK-26982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516221#comment-17516221 ] zoucao commented on FLINK-26982: I think we can optimize it in 2 ways: 1). add a new met

[jira] [Updated] (FLINK-20808) Remove redundant checkstyle rules

[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-20808: --- Attachment: (was: image-2022-04-02-12-46-11-005.png) > Remove redundant checkstyle rules > -

[jira] [Commented] (FLINK-26999) Introduce ClickHouse Connector

[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516218#comment-17516218 ] RocMarshal commented on FLINK-26999: [~monster#12]  Thanks for the operation. Rece

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-20808) Remove redundant checkstyle rules

[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516216#comment-17516216 ] Aitozi commented on FLINK-20808: No need to answer, after some search, I found it can be

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Updated] (FLINK-20808) Remove redundant checkstyle rules

[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-20808: --- Attachment: image-2022-04-02-12-46-28-065.png > Remove redundant checkstyle rules >

[jira] [Updated] (FLINK-20808) Remove redundant checkstyle rules

[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-20808: --- Attachment: image-2022-04-02-12-46-11-005.png > Remove redundant checkstyle rules >

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-20808) Remove redundant checkstyle rules

[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516211#comment-17516211 ] Aitozi commented on FLINK-20808: Hi [~chesnay]  sorry to bother you here, I run into a c

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

LadyForest commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841007101 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java ## @@ -1713,4 +1748,74

[GitHub] [flink] flinkbot edited a comment on pull request #19333: [FLINK-26190][python] Remove getTableConfig from ExecNodeConfiguration

flinkbot edited a comment on pull request #19333: URL: https://github.com/apache/flink/pull/19333#issuecomment-1086447112 ## CI report: * 0ae998978c02b08d84eb814e3c9fd95b15883f3b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

flinkbot edited a comment on pull request #19329: URL: https://github.com/apache/flink/pull/19329#issuecomment-1085879092 ## CI report: * ae35684951a5222b165af15c667c66ac09076958 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

LadyForest commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841006084 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java ## @@ -1713,4 +1748,74

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

LadyForest commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841005753 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java ## @@ -1713,4 +1748,74

[GitHub] [flink] syhily commented on pull request #19285: [FLINK-26931][Connector/pulsar] Make the producer name and consumer name unique in Pulsar

syhily commented on pull request #19285: URL: https://github.com/apache/flink/pull/19285#issuecomment-1086542049 > LGTM. Do you want to backport to 1.15? Yep, backport to 1.15 is required. -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

LadyForest commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841005052 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/TableStoreSource.java ## @@ -130,15 +135,2

[jira] [Updated] (FLINK-26999) Introduce ClickHouse Connector

[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-26999: Description: [https://cwiki.apache.org/confluence/display/FLINK/FLIP-202%3A+Introduce+ClickHouse+C

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r841004650 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/BenchmarkUtils.java ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Softw

[jira] [Created] (FLINK-26999) Introduce ClickHouse Connector

ZhuoYu Chen created FLINK-26999: --- Summary: Introduce ClickHouse Connector Key: FLINK-26999 URL: https://issues.apache.org/jira/browse/FLINK-26999 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-26999) Introduce ClickHouse Connector

[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-26999: Issue Type: New Feature (was: Improvement) > Introduce ClickHouse Connector > ---

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r841001187 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/data/DataGenerator.java ## @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache So

[GitHub] [flink] flinkbot edited a comment on pull request #19336: [hive] support select null literal

flinkbot edited a comment on pull request #19336: URL: https://github.com/apache/flink/pull/19336#issuecomment-1086539420 ## CI report: * 61021e38b76698a321b365c648060b78465a3754 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

LadyForest commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841004556 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStore.java ## @@ -298,17 +316,26 @@ private

[GitHub] [flink] Myasuka commented on a change in pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

Myasuka commented on a change in pull request #19335: URL: https://github.com/apache/flink/pull/19335#discussion_r841004243 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ## @@ -60,9 +

[GitHub] [flink] flinkbot commented on pull request #19336: [hive] support select null literal

flinkbot commented on pull request #19336: URL: https://github.com/apache/flink/pull/19336#issuecomment-1086539420 ## CI report: * 61021e38b76698a321b365c648060b78465a3754 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-26998) Remove log-related configuration from predefined options in RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-26998: Assignee: Zakelly Lan > Remove log-related configuration from predefined options in RocksDB state

[jira] [Updated] (FLINK-26998) Remove log-related configuration from predefined options in RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-26998: - Fix Version/s: 1.16.0 > Remove log-related configuration from predefined options in RocksDB state > bac

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

luoyuxia commented on pull request #19012: URL: https://github.com/apache/flink/pull/19012#issuecomment-1086538955 @beyond1920 Hi, could you please help merge? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #67: [FLINK-26911] Introduce parallelism setter for table store

LadyForest commented on a change in pull request #67: URL: https://github.com/apache/flink-table-store/pull/67#discussion_r841003912 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStore.java ## @@ -260,6 +273,11 @@ public So

[GitHub] [flink] luoyuxia opened a new pull request #19336: [hive] support select null literal

luoyuxia opened a new pull request #19336: URL: https://github.com/apache/flink/pull/19336 ## 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 way we avoid re-transferring them o

[GitHub] [flink] flinkbot edited a comment on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

flinkbot edited a comment on pull request #19335: URL: https://github.com/apache/flink/pull/19335#issuecomment-1086537086 ## CI report: * d42501cf46bfae3cd30b2927aa4ce23fffd0d81f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

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

[jira] [Updated] (FLINK-26998) Remove log-related configuration from predefined options in RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-26998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26998: --- Labels: pull-request-available (was: ) > Remove log-related configuration from predefined o

[GitHub] [flink] Zakelly opened a new pull request #19335: [FLINK-26998] Remove log-related configuration from predefined options in RocksDB state backend

Zakelly opened a new pull request #19335: URL: https://github.com/apache/flink/pull/19335 ## What is the purpose of the change After FLINK-23791, the RocksDB log should be enabled by default. However, the log-related configuration remains in ```PredefinedOptions```, which will overr

[GitHub] [flink] LB-Yu commented on pull request #16859: [FLINK-23719] [connectors/hbase] Support switch WAL in Flink SQL DDL options for HBase sink

LB-Yu commented on pull request #16859: URL: https://github.com/apache/flink/pull/16859#issuecomment-1086533939 Hi @wuchong, could you review the PR? -- 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

[jira] [Created] (FLINK-26998) Remove log-related configuration from predefined options in RocksDB state backend

Zakelly Lan created FLINK-26998: --- Summary: Remove log-related configuration from predefined options in RocksDB state backend Key: FLINK-26998 URL: https://issues.apache.org/jira/browse/FLINK-26998 Proj

[GitHub] [flink] flinkbot edited a comment on pull request #19334: [FLINK-26858][client]Add error reporting information and correct the …

flinkbot edited a comment on pull request #19334: URL: https://github.com/apache/flink/pull/19334#issuecomment-1086523291 ## CI report: * 5d62f31b0e3c15fff9bd7873a0310ee46bdbcbe9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r840999157 ## File path: flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java ## @@ -0,0 +1,163 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r840999097 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/clustering/kmeans/KMeansModelDataGenerator.java ## @@ -0,0 +1,64 @@ +/* + * L

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r840998966 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/clustering/kmeans/KMeansInputsGenerator.java ## @@ -0,0 +1,66 @@ +/* + * Lice

[GitHub] [flink] flinkbot commented on pull request #19334: [FLINK-26858][client]Add error reporting information and correct the …

flinkbot commented on pull request #19334: URL: https://github.com/apache/flink/pull/19334#issuecomment-1086523291 ## CI report: * 5d62f31b0e3c15fff9bd7873a0310ee46bdbcbe9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r840998630 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/Benchmark.java ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache Software Fo

[jira] [Closed] (FLINK-26997) Add table store links to flink web

[ https://issues.apache.org/jira/browse/FLINK-26997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26997. Resolution: Fixed asf-site: fcdd0c9fb58629ed7fd66677089cc6942236a7d2 97d9f8b04a306c106ef1cab6404

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r840998428 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java ## @@ -94,25 +95,29 @@ */ public static void saveMetadat

[jira] [Updated] (FLINK-26997) Add table store links to flink web

[ https://issues.apache.org/jira/browse/FLINK-26997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26997: - Summary: Add table store links to flink web (was: Add table store links to Community page) > A

[GitHub] [flink] dianfu commented on a change in pull request #19328: [FLINK-26969][Examples] Write operation examples of tumbling window, sliding window, session window and count window based on pyfl

dianfu commented on a change in pull request #19328: URL: https://github.com/apache/flink/pull/19328#discussion_r840997492 ## File path: flink-python/pyflink/examples/datastream/windowing/sliding_windowing.py ## @@ -0,0 +1,70 @@ +###

[GitHub] [flink] defineqq opened a new pull request #19334: [FLINK-26858][client]Add error reporting information and correct the …

defineqq opened a new pull request #19334: URL: https://github.com/apache/flink/pull/19334 …error reporting guidance when misleading the command line ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

[jira] [Updated] (FLINK-26997) Add table store links to Community page

[ https://issues.apache.org/jira/browse/FLINK-26997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26997: --- Labels: pull-request-available (was: ) > Add table store links to Community page >

[GitHub] [flink-web] JingsongLi merged pull request #523: [FLINK-26997] Add table store links to Community page

JingsongLi merged pull request #523: URL: https://github.com/apache/flink-web/pull/523 -- 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-unsu

[GitHub] [flink-ml] weibozhao commented on a change in pull request #56: [FLINK-25616] Add Transformer for VectorAssembler

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r840997700 ## File path: flink-ml-benchmark/README.md ## @@ -0,0 +1,169 @@ +# Flink ML Benchmark Getting Started + +This document provides instructions about how to r

[GitHub] [flink-ml] lindong28 commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

lindong28 commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r840995675 ## File path: flink-ml-benchmark/README.md ## @@ -0,0 +1,172 @@ +# Flink ML Benchmark Getting Started + +This document provides instructions on how to run

[GitHub] [flink-ml] weibozhao commented on a change in pull request #56: [FLINK-25616] Add Transformer for VectorAssembler

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

[GitHub] [flink] SteNicholas commented on pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

SteNicholas commented on pull request #17155: URL: https://github.com/apache/flink/pull/17155#issuecomment-1086509438 > Thanks for your contribution @SteNicholas, Can you continue to finish this work? @lsyldliu, thanks for the reminder. I will update this pull request this week. Sor

[GitHub] [flink] flinkbot edited a comment on pull request #19323: [FLINK-26858][client]When the startup mode in the command line submis…

flinkbot edited a comment on pull request #19323: URL: https://github.com/apache/flink/pull/19323#issuecomment-1085715458 ## CI report: * be9d917e79455bf9a80fa43ff9fb978384f264a5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] lsyldliu commented on pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

lsyldliu commented on pull request #17155: URL: https://github.com/apache/flink/pull/17155#issuecomment-1086498370 Thanks for your contribution @SteNicholas, Can you continue to finish this work? -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on pull request #19333: [FLINK-26190][python] Remove getTableConfig from ExecNodeConfiguration

flinkbot edited a comment on pull request #19333: URL: https://github.com/apache/flink/pull/19333#issuecomment-1086447112 ## CI report: * 84ab13731ec4deaa375549d5d63afb2020ccd476 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] luoyuxia commented on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

luoyuxia commented on pull request #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1086496321 @twalthr Sorry to bother you, but do you have time to review this pr? Then I can continue the new type inference for Hive UDAF. -- This is an automated message from the Apac

[jira] [Created] (FLINK-26997) Add table store links to Community page

Jingsong Lee created FLINK-26997: Summary: Add table store links to Community page Key: FLINK-26997 URL: https://issues.apache.org/jira/browse/FLINK-26997 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #19333: [FLINK-26190][python] Remove getTableConfig from ExecNodeConfiguration

flinkbot edited a comment on pull request #19333: URL: https://github.com/apache/flink/pull/19333#issuecomment-1086447112 ## CI report: * 84ab13731ec4deaa375549d5d63afb2020ccd476 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-22317) Support DROP column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516198#comment-17516198 ] dalongliu commented on FLINK-22317: --- I will take over this issue, cc [~jark]  > Suppo

[GitHub] [flink] flinkbot edited a comment on pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

flinkbot edited a comment on pull request #19329: URL: https://github.com/apache/flink/pull/19329#issuecomment-1085879092 ## CI report: * fae9d6fee2e0bfe4066b185cabab170b91ed4564 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516197#comment-17516197 ] zoucao commented on FLINK-26945: Looking forward to it, It is very useful. > Add DATE_S

[GitHub] [flink] flinkbot edited a comment on pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

flinkbot edited a comment on pull request #19329: URL: https://github.com/apache/flink/pull/19329#issuecomment-1085879092 ## CI report: * fae9d6fee2e0bfe4066b185cabab170b91ed4564 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26986) Remove deprecated string expressions in Python Table API

[ https://issues.apache.org/jira/browse/FLINK-26986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26986: Affects Version/s: (was: 1.15.0) > Remove deprecated string expressions in Python Table API >

  1   2   3   4   5   6   >