[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

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

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

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

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

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

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

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

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

[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

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

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

[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

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

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

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

[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=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=17533607#comment-17533607 ] Alexis Sarda-Espinosa commented on FLINK-27504: --- Hi Yun, thanks for the info, I will try

[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

[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=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=results @fsk119 hi,not sure why this failed?Is this because

[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

[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=results -- This is an automated message from the Apache Git Service.

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

[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

[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=17533593#comment-17533593 ] Yun Tang commented on FLINK-27504: -- First of all, the compaction frequecny of RocksDB is not related to

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

[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

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

[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

[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=17533590#comment-17533590 ] Ran Tao commented on FLINK-27529: - [~thw] Thanks for reviewing, I have add some context for this issue

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

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

[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

[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

[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

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

[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

[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

[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

[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

[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=17533584#comment-17533584 ] Chengkai Yang commented on FLINK-27544: --- cc [~gaoyunhaii] would you mind to take a look at this?

[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

[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

[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

[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

[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

[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

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

[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

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

[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

[jira] [Comment Edited] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-08 Thread Fuyao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533572#comment-17533572 ] Fuyao Li edited comment on FLINK-27483 at 5/9/22 2:09 AM: -- Hello Aitozi, I

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-08 Thread Fuyao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533572#comment-17533572 ] Fuyao Li commented on FLINK-27483: -- Hello Aitozi, I would suggest to allow session job specific

[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

[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

[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

[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 '' > Example code in 'Structure of Table API and SQL

[jira] [Created] (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)
Chengkai Yang created FLINK-27544: - Summary: Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run Key: FLINK-27544 URL: https://issues.apache.org/jira/browse/FLINK-27544

[GitHub] [flink] Myracle commented on pull request #19651: [FLINK-26909][Client/Job Submission] Support AdaptiveBatch when parallelism is -1 from Cli

2022-05-08 Thread GitBox
Myracle commented on PR #19651: URL: https://github.com/apache/flink/pull/19651#issuecomment-1120545073 @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.

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-08 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r867573941 ## flink-ml-lib/src/test/java/org/apache/flink/ml/classification/OnlineLogisticRegressionTest.java: ## @@ -0,0 +1,444 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-27506) update playgrounds for Flink 1.14

2022-05-08 Thread Shubham Bansal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533544#comment-17533544 ] Shubham Bansal commented on FLINK-27506: I would like to look into this. Right now I am looking

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

2022-05-08 Thread GitBox
tweise closed pull request #19654: [FLINK-27529][connector/common] Replace HybridSourceSplitEnumerator readerSourceIndex to safely Integer check URL: https://github.com/apache/flink/pull/19654 -- This is an automated message from the Apache Git Service. To respond to the message, please log

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

2022-05-08 Thread GitBox
tweise commented on PR #19654: URL: https://github.com/apache/flink/pull/19654#issuecomment-1120499967 @chucheng92 what's the actual problem that this is supposed to solve? Can you share a stack trace or other context? -- This is an automated message from the Apache Git Service. To

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

2022-05-08 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533540#comment-17533540 ] Thomas Weise commented on FLINK-27529: -- [~lemonjing] can you please add information what actual

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

2022-05-08 Thread GitBox
tweise commented on code in PR #19654: URL: https://github.com/apache/flink/pull/19654#discussion_r867550647 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java: ## @@ -355,7 +355,8 @@ public Map

[jira] [Commented] (FLINK-26114) DefaultScheduler fails fatally in case of an error when shutting down the checkpoint-related resources

2022-05-08 Thread Atri Sharma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533520#comment-17533520 ] Atri Sharma commented on FLINK-26114: - Hello, can I help with this issue? > DefaultScheduler fails

[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=17533505#comment-17533505 ] Alexis Sarda-Espinosa commented on FLINK-27504: --- I configured universal compaction style

[jira] [Updated] (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:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-27504: -- Attachment: duration_trend_67c76bb.png size_growth_67c76bb.png

[jira] [Updated] (FLINK-21352) FLIP-158: Generalized incremental checkpoints

2022-05-08 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21352: - Description: Umbrella ticket for [FLIP-158: Generalized incremental

[GitHub] [flink-web] curcur merged pull request #536: Add myself

2022-05-08 Thread GitBox
curcur merged PR #536: URL: https://github.com/apache/flink-web/pull/536 -- 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-web] curcur commented on pull request #536: Add myself

2022-05-08 Thread GitBox
curcur commented on PR #536: URL: https://github.com/apache/flink-web/pull/536#issuecomment-1120440780 did a full rebuild before merging by ./docker-build.sh -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-web] curcur opened a new pull request, #536: Add myself

2022-05-08 Thread GitBox
curcur opened a new pull request, #536: URL: https://github.com/apache/flink-web/pull/536 Add myself to the Flink community page. -- 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

[jira] [Updated] (FLINK-21352) FLIP-158: Generalized incremental checkpoints

2022-05-08 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21352: - Description: Umbrella ticket for [FLIP-158: Generalized incremental

[GitHub] [flink] wuchong merged pull request #19665: [hotfix][doc] Fix the mismatch result in Window Join example

2022-05-08 Thread GitBox
wuchong merged PR #19665: URL: https://github.com/apache/flink/pull/19665 -- 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:

[jira] [Closed] (FLINK-27517) Introduce rolling file writer to write one record each time for append-only table.

2022-05-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27517. Resolution: Fixed master: 1fedb6586ba292bedf00bb1b6922d5110a2f7fa8 > Introduce rolling file

[GitHub] [flink-table-store] JingsongLi merged pull request #110: [FLINK-27517] Introduce rolling file writer to write one record each time for append-only table.

2022-05-08 Thread GitBox
JingsongLi merged PR #110: URL: https://github.com/apache/flink-table-store/pull/110 -- 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-table-store] JingsongLi commented on a diff in pull request #110: [FLINK-27517] Introduce rolling file writer to write one record each time for append-only table.

2022-05-08 Thread GitBox
JingsongLi commented on code in PR #110: URL: https://github.com/apache/flink-table-store/pull/110#discussion_r867479945 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/DataFileWriter.java: ## @@ -91,176 +94,149 @@ public DataFilePathFactory

[jira] [Created] (FLINK-27543) Introduce StatsProducer to refactor code in DataFileWriter

2022-05-08 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27543: Summary: Introduce StatsProducer to refactor code in DataFileWriter Key: FLINK-27543 URL: https://issues.apache.org/jira/browse/FLINK-27543 Project: Flink

[jira] [Assigned] (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:all-tabpanel ] Gyula Fora reassigned FLINK-27495: -- Assignee: Gyula Fora > Observer should update last savepoint information directly from

[jira] [Closed] (FLINK-27500) Validation error handling inside controller blocks reconciliation

2022-05-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27500. -- Resolution: Fixed merged to main 52447287b17e8864066e65a0f1bbacf2184dbf2b > Validation error

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #196: [FLINK-27500] Validation errors should not block reconciliation

2022-05-08 Thread GitBox
gyfora merged PR #196: URL: https://github.com/apache/flink-kubernetes-operator/pull/196 -- 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] liuzhuang2017 commented on a diff in pull request #19493: [FLINK-27205][docs-zh] Translate "Concepts -> Glossary" page into Chinese.

2022-05-08 Thread GitBox
liuzhuang2017 commented on code in PR #19493: URL: https://github.com/apache/flink/pull/19493#discussion_r867472022 ## docs/content.zh/docs/concepts/glossary.md: ## @@ -27,15 +27,13 @@ under the License. Flink Application Cluster Review Comment: @RocMarshal , Thank

  1   2   >