[GitHub] [flink] Tartarus0zm commented on a diff in pull request #19656: [FLINK-26371][hive] Support variable substitution for sql statement while using Hive dialect

2022-05-08 Thread GitBox
Tartarus0zm commented on code in PR #19656: URL: https://github.com/apache/flink/pull/19656#discussion_r867688723 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java: ## @@ -807,6 +807,29 @@ public void testShowPartition

[GitHub] [flink] alpreu commented on pull request #19660: [FLINK-27185][connectors] Convert connector modules to assertj

2022-05-08 Thread GitBox
alpreu commented on PR #19660: URL: https://github.com/apache/flink/pull/19660#issuecomment-1120715311 @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 specific comment. T

[jira] [Updated] (FLINK-27554) The asf-site does not build on Apple Silicon

2022-05-08 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-27554: - Description: It looks that the ASF website does not build on my laptop with Apple silicon. It e

[jira] [Updated] (FLINK-27554) The asf-site does not build on Apple Silicon

2022-05-08 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-27554: - Description: It looks that the ASF website does not build on my laptop with Apple silicon. It e

[GitHub] [flink] alpreu commented on pull request #19655: [FLINK-27527] Create a file-based upsert sink for testing internal components

2022-05-08 Thread GitBox
alpreu commented on PR #19655: URL: https://github.com/apache/flink/pull/19655#issuecomment-1120713848 @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 specific comment. T

[jira] [Created] (FLINK-27554) The asf-site does not build on Apple Silicon

2022-05-08 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-27554: Summary: The asf-site does not build on Apple Silicon Key: FLINK-27554 URL: https://issues.apache.org/jira/browse/FLINK-27554 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-26812) Flink native k8s integration should support owner reference

2022-05-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533644#comment-17533644 ] Robert Metzger commented on FLINK-26812: This is a related discussion: https://

[jira] [Created] (FLINK-27553) Clarify the semantic of RecordWriter interface.

2022-05-08 Thread Zheng Hu (Jira)
Zheng Hu created FLINK-27553: Summary: Clarify the semantic of RecordWriter interface. Key: FLINK-27553 URL: https://issues.apache.org/jira/browse/FLINK-27553 Project: Flink Issue Type: Sub-task

[GitHub] [flink] wanglijie95 commented on pull request #19676: [hotfix][docs] Mention changes of "RuntimeContext#getMetricGroup" in 1.14 release notes.

2022-05-08 Thread GitBox
wanglijie95 commented on PR #19676: URL: https://github.com/apache/flink/pull/19676#issuecomment-1120709277 @xintongsong Could you help to review this fix? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
yunfengzhou-hub commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867684157 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Soft

[jira] [Updated] (FLINK-27552) Prometheus metrics

2022-05-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-27552: -- Description: I have a Standalone cluster (with jobmanager and taskmanager on same machine) on 1.14.4

[jira] [Created] (FLINK-27552) Prometheus metrics

2022-05-08 Thread Jira
João Boto created FLINK-27552: - Summary: Prometheus metrics Key: FLINK-27552 URL: https://issues.apache.org/jira/browse/FLINK-27552 Project: Flink Issue Type: Bug Components: Runtime /

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
yunfengzhou-hub commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867680909 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
yunfengzhou-hub commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867679164 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink] flinkbot commented on pull request #19676: [hotfix][docs] Mention changes of "RuntimeContext#getMetricGroup" in 1.14 release notes.

2022-05-08 Thread GitBox
flinkbot commented on PR #19676: URL: https://github.com/apache/flink/pull/19676#issuecomment-1120704410 ## CI report: * b1e10a6ab2436322c8d19678aed859e7d6269bca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wanglijie95 opened a new pull request, #19676: [hotfix][docs] Mention changes of "RuntimeContext#getMetricGroup" in 1.14 release notes.

2022-05-08 Thread GitBox
wanglijie95 opened a new pull request, #19676: URL: https://github.com/apache/flink/pull/19676 ## What is the purpose of the change Mention changes of "RuntimeContext#getMetricGroup" in 1.14 release notes. ## Verifying this change This change is a doc fix without any test coverag

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867674748 ## flink-ml-lib/src/test/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluatorTest.java: ## @@ -0,0 +1,210 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [flink] zuston commented on pull request #19675: [FLINK-27550] Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread GitBox
zuston commented on PR #19675: URL: https://github.com/apache/flink/pull/19675#issuecomment-1120691530 @wangyang0918 @KarmaGYZ If u have time, could u help review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[jira] [Commented] (FLINK-27551) Consider implementing our own status update logic

2022-05-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533633#comment-17533633 ] Gyula Fora commented on FLINK-27551: cc [~morhidi] [~wangyang0918]  > Consider impl

[jira] [Created] (FLINK-27551) Consider implementing our own status update logic

2022-05-08 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27551: -- Summary: Consider implementing our own status update logic Key: FLINK-27551 URL: https://issues.apache.org/jira/browse/FLINK-27551 Project: Flink Issue Type: Imp

[GitHub] [flink] flinkbot commented on pull request #19675: [FLINK-27550] Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread GitBox
flinkbot commented on PR #19675: URL: https://github.com/apache/flink/pull/19675#issuecomment-1120688808 ## CI report: * acba16cf050aa0e3aca29076da1bbdafb5cd4e73 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-27495) Observer should update last savepoint information directly from cluster too

2022-05-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533631#comment-17533631 ] Gyula Fora commented on FLINK-27495: [~wangyang0918] [~t...@apache.org]  I am think

[GitHub] [flink] zuston opened a new pull request, #19675: [FLINK-27550] Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread GitBox
zuston opened a new pull request, #19675: URL: https://github.com/apache/flink/pull/19675 ## What is the purpose of the change *Remove checking yarn queues before submitting job to Yarn* ## Brief change log When invoking the method of `checkYarnQueues` in `Yar

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27550: --- Labels: pull-request-available (was: ) > Remove checking yarn queues before submitting job

[jira] [Closed] (FLINK-27545) Update examples in PyFlink shell

2022-05-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27545. --- Fix Version/s: 1.16.0 1.14.5 1.15.1 Resolution: Fixed Fixed in:

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867661821 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-27550: - Description: When invoking the method of {{checkYarnQueues}} in YarnClusterDescriptor, it will

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-27550: - Description: When invoking the method of {{checkYarnQueues}} in YarnClusterDescriptor, it will

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-27550: - Description: When invoking the method of checkYarnQueues in YarnClusterDescriptor, it will chec

[jira] [Created] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-27550: Summary: Remove checking yarn queues before submitting job to Yarn Key: FLINK-27550 URL: https://issues.apache.org/jira/browse/FLINK-27550 Project: Flink Iss

[GitHub] [flink] dianfu closed pull request #19673: [FLINK-27545][python][examples] Update the example in PyFlink shell

2022-05-08 Thread GitBox
dianfu closed pull request #19673: [FLINK-27545][python][examples] Update the example in PyFlink shell URL: https://github.com/apache/flink/pull/19673 -- 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

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867656982 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867650416 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Description: Current flink project build with jdk1.8 is ok. when enable jdk11, it has some scenarios. 1. U

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Attachment: screenshot-2.png > Inconsistent bytecode version when enable jdk11 or higher version > ---

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Attachment: screenshot-1.png > Inconsistent bytecode version when enable jdk11 or higher version > ---

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Description: Current flink project build with jdk1.8 is ok. when enable jdk11, it has some scenarios. 1. U

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Description: Current flink project build with jdk1.8 is ok. when enable jdk11, it has some scenarios. 1. U

[jira] [Updated] (FLINK-27547) Hardcode of pom aboout java11 & java17 target java version may cause hidden error

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27547: Description: Current flink parent pom property 1.8 by default. And many modules inherit this property. B

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Description: Current flink project build with jdk1.8 is ok. when enable jdk11, it has some scenarios. 1. U

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Description: Current flink project build with jdk1.8 is ok. when enable jdk11, it has some scenarios. 1. U

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Description: Current flink project build with jdk1.8 is ok. when enable jdk11, it has some scenarios. 1. U

[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27549: Description: Current flink project build with jdk1.8 is ok. when enable jdk11, it has some scenarios. 1. U

[jira] [Created] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version

2022-05-08 Thread Ran Tao (Jira)
Ran Tao created FLINK-27549: --- Summary: Inconsistent bytecode version when enable jdk11 or higher version Key: FLINK-27549 URL: https://issues.apache.org/jira/browse/FLINK-27549 Project: Flink Issu

[jira] [Created] (FLINK-27548) Improve quick-start of table store

2022-05-08 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27548: Summary: Improve quick-start of table store Key: FLINK-27548 URL: https://issues.apache.org/jira/browse/FLINK-27548 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-27547) Hardcode of pom aboout java11 & java17 target java version may cause hidden error

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27547: Description: Current flink parent pom property 1.8 by default. And many modules inherit this property. B

[jira] [Updated] (FLINK-27547) Hardcode of pom aboout java11 & java17 target java version may cause hidden error

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27547: Description: Current flink parent pom property 1.8 by default. And many modules inherit this property. B

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #196: [FLINK-27500] Validation errors should not block reconciliation

2022-05-08 Thread GitBox
gyfora commented on code in PR #196: URL: https://github.com/apache/flink-kubernetes-operator/pull/196#discussion_r867636056 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java: ## @@ -305,4 +307,46 @@ public stati

[jira] [Updated] (FLINK-27547) Hardcode of pom aboout java11 & java17 target java version may cause hidden error

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27547: Description: Current flink parent pom property 1.8 by default. And many modules inherit this property. B

[jira] [Updated] (FLINK-27547) Hardcode of pom aboout java11 & java17 target java version may cause hidden error

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27547: Description: Current flink parent pom property 1.8 by default. And many modules inherit this property. B

[jira] [Created] (FLINK-27547) Hardcode of pom aboout java11 & java17 target java version may cause hidden error

2022-05-08 Thread Ran Tao (Jira)
Ran Tao created FLINK-27547: --- Summary: Hardcode of pom aboout java11 & java17 target java version may cause hidden error Key: FLINK-27547 URL: https://issues.apache.org/jira/browse/FLINK-27547 Project: Flin

[jira] [Comment Edited] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend

2022-05-08 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533607#comment-17533607 ] Alexis Sarda-Espinosa edited comment on FLINK-27504 at 5/9/22 4:57 AM: ---

[jira] [Commented] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend

2022-05-08 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533607#comment-17533607 ] Alexis Sarda-Espinosa commented on FLINK-27504: --- Hi Yun, thanks for the in

[GitHub] [flink] imaffe commented on pull request #19433: [BK-1.14][FLINK-26645][Connector/pulsar] Support subscribe only one topic partition/

2022-05-08 Thread GitBox
imaffe commented on PR #19433: URL: https://github.com/apache/flink/pull/19433#issuecomment-1120614941 @MartijnVisser seems this backport PR is ready ? -- 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

[GitHub] [flink] Tartarus0zm commented on pull request #19608: [FLINK-27450][hive] Upgrade default hive version to fix Hive SessionState initialization issue with jdk11

2022-05-08 Thread GitBox
Tartarus0zm commented on PR #19608: URL: https://github.com/apache/flink/pull/19608#issuecomment-1120613738 > @Tartarus0zm LGTM. But could you please update the pr titile like "[[FLINK-27450](https://issues.apache.org/jira/browse/FLINK-27450)][hive] Upgrade default hive-exec version to fix

[jira] [Assigned] (FLINK-27546) Add append only writer which implements the RecordWriter interface.

2022-05-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27546: Assignee: Zheng Hu > Add append only writer which implements the RecordWriter interface.

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-08 Thread GitBox
ChengkaiYang2022 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1120610051 > > > @flinkbot run azure > > > > > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=35475&view=results > > @fsk119 hi,not sure why this

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-08 Thread GitBox
ChengkaiYang2022 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1120609343 > > @flinkbot run azure > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=35475&view=results @fsk119 hi,not sure why this failed?Is this bec

[jira] [Updated] (FLINK-27418) Flink SQL TopN result is wrong

2022-05-08 Thread zhangbin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangbin updated FLINK-27418: - Description: Flink SQL TopN is executed multiple times with different results, sometimes with correct r

[jira] [Updated] (FLINK-27546) Add append only writer which implements the RecordWriter interface.

2022-05-08 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng Hu updated FLINK-27546: - Fix Version/s: table-store-0.2.0 > Add append only writer which implements the RecordWriter interface. >

[jira] [Created] (FLINK-27546) Add append only writer which implements the RecordWriter interface.

2022-05-08 Thread Zheng Hu (Jira)
Zheng Hu created FLINK-27546: Summary: Add append only writer which implements the RecordWriter interface. Key: FLINK-27546 URL: https://issues.apache.org/jira/browse/FLINK-27546 Project: Flink

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-08 Thread GitBox
ChengkaiYang2022 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1120607570 > @flinkbot run azure https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=35475&view=results -- This is an automated message from the Apache Git Servi

[GitHub] [flink] luoyuxia commented on pull request #19608: [FLINK-27450][hive][JDK11]SessionState can't be initialized due to classloader

2022-05-08 Thread GitBox
luoyuxia commented on PR #19608: URL: https://github.com/apache/flink/pull/19608#issuecomment-1120605580 @Tartarus0zm LGTM. But could you please update the pr titile like "[FLINK-27450][hive] Upgrade default hive-exec version to fix Hive SessionState initialization issue in jdk11" -- Th

[GitHub] [flink-web] JingsongLi commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
JingsongLi commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867605695 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,110 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle: "

[GitHub] [flink-web] JingsongLi commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
JingsongLi commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867605296 ## downloads.md: ## @@ -162,6 +162,27 @@ This version is compatible with Apache Flink version {{ flink_kubernetes_operato {% endfor %} +Apache Flink® Table Stor

[GitHub] [flink-web] JingsongLi commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
JingsongLi commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867604787 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,110 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle: "

[GitHub] [flink-web] JingsongLi commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
JingsongLi commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867604541 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,110 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle: "

[GitHub] [flink-web] JingsongLi commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
JingsongLi commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867603603 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,110 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle: "

[jira] [Commented] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend

2022-05-08 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533593#comment-17533593 ] Yun Tang commented on FLINK-27504: -- First of all, the compaction frequecny of RocksDB i

[GitHub] [flink] flinkbot commented on pull request #19674: [FLINK-27401] CEP supports accumulator in IterativeCondition

2022-05-08 Thread GitBox
flinkbot commented on PR #19674: URL: https://github.com/apache/flink/pull/19674#issuecomment-1120591431 ## CI report: * e59dc9d027984f4a38dd400b0d6017a83f7c590a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] fsk119 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-08 Thread GitBox
fsk119 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1120589931 @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 specific comment. T

[jira] [Updated] (FLINK-27401) CEP supports AggregateFunction in IterativeCondition

2022-05-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27401: --- Labels: pull-request-available (was: ) > CEP supports AggregateFunction in IterativeConditi

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27529: Description: Currently HybridSourceSplitEnumerator check readerSourceIndex using Integer type but == oper

[GitHub] [flink] mayuehappy opened a new pull request, #19674: [FLINK-27401] CEP supports accumulator in IterativeCondition

2022-05-08 Thread GitBox
mayuehappy opened a new pull request, #19674: URL: https://github.com/apache/flink/pull/19674 ## 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

[jira] [Commented] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533590#comment-17533590 ] Ran Tao commented on FLINK-27529: - [~thw] Thanks for reviewing, I have add some context

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-08 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27529: Description: Currently HybridSourceSplitEnumerator check readerSourceIndex using Integer type but == oper

[GitHub] [flink-playgrounds] dianfu merged pull request #28: Build pyflint image with compatible python version

2022-05-08 Thread GitBox
dianfu merged PR #28: URL: https://github.com/apache/flink-playgrounds/pull/28 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867595652 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867595098 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink] flinkbot commented on pull request #19673: [FLINK-27545][python][examples] Update the example in PyFlink shell

2022-05-08 Thread GitBox
flinkbot commented on PR #19673: URL: https://github.com/apache/flink/pull/19673#issuecomment-1120577371 ## CI report: * d28ef4c4f9dacbd60a1147e654cbc64f7f48ae55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Tartarus0zm commented on pull request #19608: [FLINK-27450][hive][JDK11]SessionState can't be initialized due to classloader

2022-05-08 Thread GitBox
Tartarus0zm commented on PR #19608: URL: https://github.com/apache/flink/pull/19608#issuecomment-1120577173 @MartijnVisser @luoyuxia CI has passed, please take a look, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink-web] openinx commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
openinx commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867594000 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,110 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle: "Uni

[jira] [Updated] (FLINK-27545) Update examples in PyFlink shell

2022-05-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27545: --- Labels: pull-request-available (was: ) > Update examples in PyFlink shell > ---

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867593318 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink] dianfu opened a new pull request, #19673: [FLINK-27545][python][examples] Update the example in PyFlink shell

2022-05-08 Thread GitBox
dianfu opened a new pull request, #19673: URL: https://github.com/apache/flink/pull/19673 ## What is the purpose of the change *The example in PyFlink shell is outdated. This pull request updates it.* ## Verifying this change This change is a trivial rework withou

[GitHub] [flink] chucheng92 commented on pull request #19654: [FLINK-27529][connector/common] Replace HybridSourceSplitEnumerator readerSourceIndex to safely Integer check

2022-05-08 Thread GitBox
chucheng92 commented on PR #19654: URL: https://github.com/apache/flink/pull/19654#issuecomment-1120574881 > Thanks for reviewing. And sorry i haven’t illustrate details. Question-1: actual problem is == with Integer for readerIndex comparison. ``` Integer i1 = 128;

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867592350 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867592164 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[jira] [Commented] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run

2022-05-08 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533584#comment-17533584 ] Chengkai Yang commented on FLINK-27544: --- cc [~gaoyunhaii] would you mind to take a

[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run

2022-05-08 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27544: -- Description: The example code in [Structure of Table API and SQL Programs|https://nightlies.a

[jira] [Created] (FLINK-27545) Update examples in PyFlink shell

2022-05-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-27545: --- Summary: Update examples in PyFlink shell Key: FLINK-27545 URL: https://issues.apache.org/jira/browse/FLINK-27545 Project: Flink Issue Type: Bug Components:

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #86: [FLINK-27294] Add Transformer for BinaryClassificationEvaluator

2022-05-08 Thread GitBox
weibozhao commented on code in PR #86: URL: https://github.com/apache/flink-ml/pull/86#discussion_r867591071 ## flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluator.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the Apache Software F

[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run

2022-05-08 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27544: -- Description: The example code in [Structure of Table API and SQL Programs|https://nightlies.a

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #196: [FLINK-27500] Validation errors should not block reconciliation

2022-05-08 Thread GitBox
Aitozi commented on code in PR #196: URL: https://github.com/apache/flink-kubernetes-operator/pull/196#discussion_r867590389 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java: ## @@ -305,4 +307,46 @@ public stati

[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run

2022-05-08 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27544: -- Description: The example code in [Structure of Table API and SQL Programs|https://nightlies.a

[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run

2022-05-08 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27544: -- Description: The example code in [Structure of Table API and SQL Programs|https://nightlies.a

[GitHub] [flink-web] openinx commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
openinx commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867587627 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,110 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle: "Uni

[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run

2022-05-08 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27544: -- Description: The example code in [Structure of Table API and SQL Programs|https://nightlies.a

[GitHub] [flink-web] JingsongLi commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
JingsongLi commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867585779 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,110 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle: "

[GitHub] [flink-web] JingsongLi commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-08 Thread GitBox
JingsongLi commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r867585636 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,110 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle: "

  1   2   >