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

flinkbot edited a comment on pull request #19177: URL: https://github.com/apache/flink/pull/19177#issuecomment-1073539671 ## CI report: * 1012ead6db20e77f4fa95ebcc92fd3f23e59cc11 Azure:

[GitHub] [flink] syhily commented on a change in pull request #18816: [FLINK-26027][pulsar] add sink metrics to pulsar sink

syhily commented on a change in pull request #18816: URL: https://github.com/apache/flink/pull/18816#discussion_r840254164 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/groups/UnregisteredMetricsGroup.java ## @@ -178,4 +182,35 @@ public

[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_r840253077 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/BenchmarkUtils.java ## @@ -0,0 +1,151 @@ +/* + * Licensed to the

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

flinkbot edited a comment on pull request #19177: URL: https://github.com/apache/flink/pull/19177#issuecomment-1073539671 ## CI report: * 1012ead6db20e77f4fa95ebcc92fd3f23e59cc11 Azure:

[jira] [Created] (FLINK-26972) Support spot instance in Flink Kubernetes operator

Yang Wang created FLINK-26972: - Summary: Support spot instance in Flink Kubernetes operator Key: FLINK-26972 URL: https://issues.apache.org/jira/browse/FLINK-26972 Project: Flink Issue Type: New

[jira] [Comment Edited] (FLINK-11388) Add an OSS RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513235#comment-17513235 ] Jingsong Lee edited comment on FLINK-11388 at 4/1/22 5:21 AM: -- master:

[GitHub] [flink] JingsongLi merged pull request #19292: [FLINK-11388][docs][oss]Update docs for OSS Recoverable writer

JingsongLi merged pull request #19292: URL: https://github.com/apache/flink/pull/19292 -- 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] imaffe commented on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

imaffe commented on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1085410874 @MartijnVisser The pipeline has succeeded ~ Thank you ~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-26971) UniversalCompaction should pick by size ratio after picking by file num

[ https://issues.apache.org/jira/browse/FLINK-26971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26971: --- Labels: pull-request-available (was: ) > UniversalCompaction should pick by size ratio

[GitHub] [flink-table-store] JingsongLi opened a new pull request #70: [FLINK-26971] UniversalCompaction should pick by size ratio after picking by file num

JingsongLi opened a new pull request #70: URL: https://github.com/apache/flink-table-store/pull/70 This way we can avoid the problem of oversized first files -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Created] (FLINK-26971) UniversalCompaction should pick by size ratio after picking by file num

Jingsong Lee created FLINK-26971: Summary: UniversalCompaction should pick by size ratio after picking by file num Key: FLINK-26971 URL: https://issues.apache.org/jira/browse/FLINK-26971 Project:

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

zhipeng93 commented on pull request #73: URL: https://github.com/apache/flink-ml/pull/73#issuecomment-1085405076 @lindong28 Thanks for the review. I have adressed your comments in the latest commit. -- This is an automated message from the Apache Git Service. To respond to the message,

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * b2fea27bfc4b620fb65360be604bc56ce5a27be5 Azure:

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * b2fea27bfc4b620fb65360be604bc56ce5a27be5 Azure:

[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_r840215290 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -32,9 +32,31 @@ public static double asum(DenseVector x) { }

[GitHub] [flink] flinkbot edited a comment on pull request #19316: [FLINK-25238][table-runtime] Allow customized types for ArrayDataSerializer#copy

flinkbot edited a comment on pull request #19316: URL: https://github.com/apache/flink/pull/19316#issuecomment-1085391584 ## CI report: * cd534d2b00c7f1c116eeca4fc9982290970a1f68 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19298: [hive] support insert timestamp to decimal

flinkbot edited a comment on pull request #19298: URL: https://github.com/apache/flink/pull/19298#issuecomment-1084376509 ## CI report: * cd0f9e9ea3bfff7dceabebaa423be2228e5ec291 Azure:

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * b2fea27bfc4b620fb65360be604bc56ce5a27be5 Azure:

[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_r840212185 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScaler.java ## @@ -0,0 +1,288 @@ +/* + * Licensed to the

[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_r840212185 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScaler.java ## @@ -0,0 +1,288 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #19316: [FLINK-25238][table-runtime] Allow customized types for ArrayDataSerializer#copy

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

[GitHub] [flink] flinkbot edited a comment on pull request #19315: [hive] support distinct from

flinkbot edited a comment on pull request #19315: URL: https://github.com/apache/flink/pull/19315#issuecomment-1085386734 ## CI report: * 5c2e924a5bf679bf9b54cd00b1ec1d1e5116048e UNKNOWN * a1f4dbd7a4131b977e2efe1a6d3fce52c2b3bad7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19298: [hive] support insert timestamp to decimal

flinkbot edited a comment on pull request #19298: URL: https://github.com/apache/flink/pull/19298#issuecomment-1084376509 ## CI report: * cd0f9e9ea3bfff7dceabebaa423be2228e5ec291 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * b2fea27bfc4b620fb65360be604bc56ce5a27be5 Azure:

[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_r840212185 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScaler.java ## @@ -0,0 +1,288 @@ +/* + * Licensed to the

[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_r840212010 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScaler.java ## @@ -0,0 +1,288 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #19315: [hive] support distinct from

flinkbot edited a comment on pull request #19315: URL: https://github.com/apache/flink/pull/19315#issuecomment-1085386734 ## CI report: * 5c2e924a5bf679bf9b54cd00b1ec1d1e5116048e UNKNOWN * a1f4dbd7a4131b977e2efe1a6d3fce52c2b3bad7 UNKNOWN Bot commands The

[jira] [Updated] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25238: --- Labels: pull-request-available (was: ) > flink iceberg source reading array types fail

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19219: [FLINK-26835][serialization] Fix concurrent modification exception

flinkbot edited a comment on pull request #19219: URL: https://github.com/apache/flink/pull/19219#issuecomment-1077334179 ## CI report: * e862f4777de3fa54ea129ab1b5ac0015b692750c Azure:

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * b2fea27bfc4b620fb65360be604bc56ce5a27be5 Azure:

[GitHub] [flink] yittg opened a new pull request #19316: [FLINK-25238][table-runtime] Allow customized types for ArrayDataSerializer#copy

yittg opened a new pull request #19316: URL: https://github.com/apache/flink/pull/19316 ## What is the purpose of the change Allow customized types for ArrayDataSerializer#copy, instead of throwing a cast exception. ## Brief change log ## Verifying

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

[GitHub] [flink] flinkbot commented on pull request #19315: [hive] support distinct from

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

[GitHub] [flink] flinkbot edited a comment on pull request #19219: [FLINK-26835][serialization] Fix concurrent modification exception

flinkbot edited a comment on pull request #19219: URL: https://github.com/apache/flink/pull/19219#issuecomment-1077334179 ## CI report: * e862f4777de3fa54ea129ab1b5ac0015b692750c Azure:

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * b2fea27bfc4b620fb65360be604bc56ce5a27be5 Azure:

[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_r840207227 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowDatabases.java ## @@ -49,8 +70,44 @@ public

[GitHub] [flink] luoyuxia opened a new pull request #19315: [hive] support distinct from

luoyuxia opened a new pull request #19315: URL: https://github.com/apache/flink/pull/19315 ## 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

[GitHub] [flink] ZhangChaoming commented on pull request #19219: [FLINK-26835][serialization] Fix concurrent modification exception

ZhangChaoming commented on pull request #19219: URL: https://github.com/apache/flink/pull/19219#issuecomment-1085384720 @dawidwys @pnowojski Since I have no idear about the performance impact of `ConcurrentHashMap`, I aggree to @dawidwys' suggestion that alway duplicate a new serializer:

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * b2fea27bfc4b620fb65360be604bc56ce5a27be5 Azure:

[jira] [Commented] (FLINK-26728) Support min max min_by max_by operation in KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-26728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515687#comment-17515687 ] CaoYu commented on FLINK-26728: --- Hi [~dianfu]  I have already summit a PR in GitHub.   Would you have

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 746c20dcbaa8a541975f0b3d6bddb041008db2e2 Azure:

[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_r840204804 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -89,4 +111,56 @@ public static void gemv( y.values,

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #19177: [FLINK-23399][state] Add a benchmark for rescaling

Myasuka commented on a change in pull request #19177: URL: https://github.com/apache/flink/pull/19177#discussion_r840197342 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/benchmark/RescalingBenchmark.java

[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_r840198302 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/clustering/kmeans/KMeansInputsGenerator.java ## @@ -0,0 +1,66 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 746c20dcbaa8a541975f0b3d6bddb041008db2e2 Azure:

[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_r840197583 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/generator/GeneratorUtils.java ## @@ -0,0 +1,129 @@ +/* + * Licensed to

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

ZhangChaoming commented on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1085368113 @slinkydeveloper IMO, this enhanced syntax can NOT be applied easily to all the ShowOperations. - The identifier in preposition is different - This syntax is not

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 746c20dcbaa8a541975f0b3d6bddb041008db2e2 Azure:

[jira] [Comment Edited] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515682#comment-17515682 ] Yi Tang edited comment on FLINK-25238 at 4/1/22 3:06 AM: - [~sjwiesman] Shall we

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515682#comment-17515682 ] Yi Tang commented on FLINK-25238: - [~sjwiesman] Shall we reopen this issue. The similar issue for

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

[jira] [Updated] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

[ https://issues.apache.org/jira/browse/FLINK-26460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26460: --- Fix Version/s: 1.16.0 > Fix Unsupported type when convertTypeToSpec: MAP >

[jira] [Updated] (FLINK-26970) Fix comment style error

[ https://issues.apache.org/jira/browse/FLINK-26970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26970: --- Labels: pull-request-available (was: ) > Fix comment style error > ---

[GitHub] [flink] flinkbot edited a comment on pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

flinkbot edited a comment on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085355130 ## CI report: * c718701d04dde31a32925135833390ec58843530 Azure:

[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_r840189932 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/generator/GeneratorUtils.java ## @@ -0,0 +1,129 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-26970) Fix comment style error

[ https://issues.apache.org/jira/browse/FLINK-26970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yingjie.wang updated FLINK-26970: - External issue URL: (was: https://github.com/apache/flink/pull/19314) > Fix comment style

[jira] [Created] (FLINK-26970) Fix comment style error

yingjie.wang created FLINK-26970: Summary: Fix comment style error Key: FLINK-26970 URL: https://issues.apache.org/jira/browse/FLINK-26970 Project: Flink Issue Type: Improvement

[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_r840189898 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScalerModel.java ## @@ -0,0 +1,185 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #19314: [FLINK-26962][Runtime/Task] Fix comment style error

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

[jira] [Commented] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515679#comment-17515679 ] Yun Tang commented on FLINK-14998: -- [~jay li], you can refer to

[jira] [Updated] (FLINK-26962) Fix comment style error

[ https://issues.apache.org/jira/browse/FLINK-26962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26962: --- Labels: pull-request-available (was: ) > Fix comment style error > ---

[GitHub] [flink] CodingCaproni opened a new pull request #19314: [FLINK-26962][Runtime/Task] Fix comment style error

CodingCaproni opened a new pull request #19314: URL: https://github.com/apache/flink/pull/19314 **What is the purpose of the change** Fix comment style error. **Verifying this change** This change is a trivial rework without any test coverage. **Does this pull request

[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_r840186693 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/clustering/kmeans/KMeansInputsGenerator.java ## @@ -0,0 +1,66 @@ +/* +

[jira] [Closed] (FLINK-26792) BufferedMutator failed when insert and update with a flush in Hbase Sink

[ https://issues.apache.org/jira/browse/FLINK-26792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lothar closed FLINK-26792. -- Resolution: Not A Bug > BufferedMutator failed when insert and update with a flush in Hbase Sink >

[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_r840185834 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/clustering/kmeans/KMeansModelDataGenerator.java ## @@ -0,0 +1,64 @@

[jira] [Comment Edited] (FLINK-26858) When submitting a task, an error is reported and the description is inaccurate, which will lead to misleading

[ https://issues.apache.org/jira/browse/FLINK-26858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515676#comment-17515676 ] 丛鹏 edited comment on FLINK-26858 at 4/1/22 2:33 AM: [~martijnvisser] Thank you for

[jira] [Commented] (FLINK-26858) When submitting a task, an error is reported and the description is inaccurate, which will lead to misleading

[ https://issues.apache.org/jira/browse/FLINK-26858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515676#comment-17515676 ] 丛鹏 commented on FLINK-26858: What can I do, such as turning off the issue? > When submitting a task, an

[jira] [Commented] (FLINK-26884) Move Elasticsearch connector to external connector repository

[ https://issues.apache.org/jira/browse/FLINK-26884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515674#comment-17515674 ] zhisheng commented on FLINK-26884: -- [~martijnvisser] thanks your quickly reply, I get it. > Move

[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_r840183375 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/Benchmark.java ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache

[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_r840180676 ## File path: flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java ## @@ -0,0 +1,163 @@ +/* + * Licensed to the Apache

[jira] [Comment Edited] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515379#comment-17515379 ] jay li edited comment on FLINK-14998 at 4/1/22 2:11 AM: Hi [~yunta]  thanks i

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * 99092a0711958b858b23f10ea0056167c3b4f7f7 Azure:

[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_r840168951 ## File path: flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/BenchmarkResult.java ## @@ -0,0 +1,61 @@ +/* + * Licensed to the

[GitHub] [flink] hackergin commented on a change in pull request #19302: [FLINK-26810][connectors/elasticsearch] Use local timezone for TIMESTAMP_WITH_LOCAL_TIMEZONE fields in dynamic index

hackergin commented on a change in pull request #19302: URL: https://github.com/apache/flink/pull/19302#discussion_r840165388 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java

[jira] [Commented] (FLINK-25794) Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager

[ https://issues.apache.org/jira/browse/FLINK-25794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515657#comment-17515657 ] Yangze Guo commented on FLINK-25794: [~zjureel] Is this issue still valid? Shall we close it? >

[jira] [Updated] (FLINK-26969) Write operation examples of tumbling window, sliding window, session window and count window based on pyflink

[ https://issues.apache.org/jira/browse/FLINK-26969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26969: Issue Type: Improvement (was: New Feature) > Write operation examples of tumbling window, sliding

[jira] [Assigned] (FLINK-26969) Write operation examples of tumbling window, sliding window, session window and count window based on pyflink

[ https://issues.apache.org/jira/browse/FLINK-26969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-26969: --- Assignee: zhangjingcun > Write operation examples of tumbling window, sliding window, session

[jira] [Updated] (FLINK-26969) Write operation examples of tumbling window, sliding window, session window and count window based on pyflink

[ https://issues.apache.org/jira/browse/FLINK-26969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26969: Affects Version/s: (was: 1.14.4) > Write operation examples of tumbling window, sliding window,

[jira] [Updated] (FLINK-26969) Write operation examples of tumbling window, sliding window, session window and count window based on pyflink

[ https://issues.apache.org/jira/browse/FLINK-26969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26969: Component/s: API / Python > Write operation examples of tumbling window, sliding window, session window

[jira] [Updated] (FLINK-26969) Write operation examples of tumbling window, sliding window, session window and count window based on pyflink

[ https://issues.apache.org/jira/browse/FLINK-26969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjingcun updated FLINK-26969: - Description: Write operation examples of tumbling window, sliding window, session window and

[jira] [Updated] (FLINK-26969) Write operation examples of tumbling window, sliding window, session window and count window based on pyflink

[ https://issues.apache.org/jira/browse/FLINK-26969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjingcun updated FLINK-26969: - Summary: Write operation examples of tumbling window, sliding window, session window and count

[jira] [Created] (FLINK-26969) Write operation examples of tumbling window, sliding window, session window and time window based on pyflink

zhangjingcun created FLINK-26969: Summary: Write operation examples of tumbling window, sliding window, session window and time window based on pyflink Key: FLINK-26969 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * Unknown: [CANCELED](TBD) * 99092a0711958b858b23f10ea0056167c3b4f7f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * Unknown: [CANCELED](TBD) * 99092a0711958b858b23f10ea0056167c3b4f7f7 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * Unknown: [CANCELED](TBD) * 99092a0711958b858b23f10ea0056167c3b4f7f7 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * Unknown: [CANCELED](TBD) * 99092a0711958b858b23f10ea0056167c3b4f7f7 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] snuyanzin commented on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

snuyanzin commented on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1085224069 @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] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * b2d8f3d7657f62c44cfaeab31ccf7c5166ea184b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * b2d8f3d7657f62c44cfaeab31ccf7c5166ea184b Azure:

  1   2   3   4   5   6   >