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
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
[
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
[
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
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
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
[
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://
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
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
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
[
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
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 /
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
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
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`
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
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
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
[
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
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
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`
[
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
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
[
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
[
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:
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
[
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
[
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
[
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
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
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
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
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
[
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
[
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
> ---
[
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
> ---
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
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
[
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
[
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
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
[
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
[
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
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
[
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:
---
[
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
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
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
[
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.
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
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
[
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
[
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.
>
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
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
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
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: "
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
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: "
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: "
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: "
[
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
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`
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
[
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
[
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
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
[
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
[
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
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.
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
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
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`
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
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
[
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
> ---
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
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
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;
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
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
[
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
[
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
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:
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
[
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
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
[
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
[
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
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
[
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
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: "
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 - 100 of 141 matches
Mail list logo