[jira] [Commented] (FLINK-25381) JdbcExactlyOnceSinkE2eTest.testInsert fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515740#comment-17515740 ] Yun Gao commented on FLINK-25381: - 1.15 that it blocked on azure: https://dev.azure.com

[GitHub] [flink] MartijnVisser closed pull request #19299: [FLINK-26858][client]Add error reporting information and correct the …

MartijnVisser closed pull request #19299: URL: https://github.com/apache/flink/pull/19299 -- 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-u

[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&focusedCommentId=17515735#comment-17515735 ] Martijn Visser commented on FLINK-26858: [~congpeng0...@gmail.com] Looking at yo

[jira] [Created] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

Yun Gao created FLINK-26974: --- Summary: Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure Key: FLINK-26974 URL: https://issues.apache.org/jira/browse/FLINK-26974 Project: Flink

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

MartijnVisser commented on pull request #19314: URL: https://github.com/apache/flink/pull/19314#issuecomment-1085496913 @CodingCaproni Thank you for opening this PR. I do think that this change is of too little value (just a space removal) compared to the effort for the community. Therefor

[GitHub] [flink] MartijnVisser closed pull request #19314: [FLINK-26970][Runtime/Task] Fix comment style error

MartijnVisser closed pull request #19314: URL: https://github.com/apache/flink/pull/19314 -- 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-u

[jira] [Created] (FLINK-26973) Emit events on state transitions for FlinkDeployment

Matyas Orhidi created FLINK-26973: - Summary: Emit events on state transitions for FlinkDeployment Key: FLINK-26973 URL: https://issues.apache.org/jira/browse/FLINK-26973 Project: Flink Issue

[jira] [Closed] (FLINK-25440) Apache Pulsar Connector Document description error about 'Starting Position'.

[ https://issues.apache.org/jira/browse/FLINK-25440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25440. -- Resolution: Fixed > Apache Pulsar Connector Document description error about 'Starting Positio

[jira] [Commented] (FLINK-25440) Apache Pulsar Connector Document description error about 'Starting Position'.

[ https://issues.apache.org/jira/browse/FLINK-25440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515734#comment-17515734 ] Martijn Visser commented on FLINK-25440: Fixed in release-1.14: e1de0e0181d2ac39

[jira] [Updated] (FLINK-25440) Apache Pulsar Connector Document description error about 'Starting Position'.

[ https://issues.apache.org/jira/browse/FLINK-25440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25440: --- Fix Version/s: 1.14.5 > Apache Pulsar Connector Document description error about 'Starting P

[GitHub] [flink] MartijnVisser merged pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

MartijnVisser merged pull request #19289: URL: https://github.com/apache/flink/pull/19289 -- 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-u

[GitHub] [flink] XComp edited a comment on pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

XComp edited a comment on pull request #19275: URL: https://github.com/apache/flink/pull/19275#issuecomment-1085493232 That's a good point. Thanks for the detailed explanation. I was thinking about it: Essentially, the question is whether we consider the `HistoryServer` archiving being par

[GitHub] [flink] XComp commented on pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

XComp commented on pull request #19275: URL: https://github.com/apache/flink/pull/19275#issuecomment-1085493232 That's a good point. Thanks for the detailed explanation. I was thinking about it: Essentially, the question is whether we consider the `HistoryServer` archiving being part of th

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #70: [FLINK-26971] UniversalCompaction should pick by size ratio after picking by file num

tsreaper commented on a change in pull request #70: URL: https://github.com/apache/flink-table-store/pull/70#discussion_r840271261 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/UniversalCompaction.java ## @@ -63,7 +63,8

[jira] [Closed] (FLINK-26878) get previous window values in udf

[ https://issues.apache.org/jira/browse/FLINK-26878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthik closed FLINK-26878. --- Fix Version/s: 1.13.6 Resolution: Fixed > get previous window values in udf > ---

[jira] [Commented] (FLINK-26878) get previous window values in udf

[ https://issues.apache.org/jira/browse/FLINK-26878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515727#comment-17515727 ] Karthik commented on FLINK-26878: - yeah that worked i tried that one > get previous win

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

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

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

[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&focusedCommentId=17513235#comment-17513235 ] Jingsong Lee edited comment on FLINK-11388 at 4/1/22 5:21 AM:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[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: [PENDING](https://dev.azure.com/apache-f

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[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&focusedCommentId=17515687#comment-17515687 ] CaoYu commented on FLINK-26728: --- Hi [~dianfu]  I have already summit a PR in GitHub.  

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

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

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

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

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

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

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

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #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 s

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

[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&focusedCommentId=17515682#comment-17515682 ] Yi Tang edited comment on FLINK-25238 at 4/1/22 3:06 AM: - [~sjwi

[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&focusedCommentId=17515682#comment-17515682 ] Yi Tang commented on FLINK-25238: - [~sjwiesman] Shall we reopen this issue. The similar

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #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 erro

[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 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_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&focusedCommentId=17515679#comment-17515679 ] Yun Tang commented on FLINK-14998: -- [~jay li], you can refer to https://flink.apache.o

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

[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&focusedCommentId=17515676#comment-17515676 ] 丛鹏 edited comment on FLINK-26858 at 4/1/22 2:33 AM: [~martijnvisser]

[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&focusedCommentId=17515676#comment-17515676 ] 丛鹏 commented on FLINK-26858: What can I do, such as turning off the issue? > When submittin

[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&focusedCommentId=17515674#comment-17515674 ] zhisheng commented on FLINK-26884: -- [~martijnvisser] thanks your quickly reply, I get i

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

[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&focusedCommentId=17515379#comment-17515379 ] jay li edited comment on FLINK-14998 at 4/1/22 2:11 AM: Hi [~yun

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #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 Apache

[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&focusedCommentId=17515657#comment-17515657 ] Yangze Guo commented on FLINK-25794: [~zjureel] Is this issue still valid? Shall we

  1   2   3   4   5   >