[
https://issues.apache.org/jira/browse/FLINK-25691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526768#comment-17526768
]
macdoor615 edited comment on FLINK-25691 at 4/23/22 5:25 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526768#comment-17526768
]
macdoor615 commented on FLINK-25691:
[~alexanderpreuss] [~martijnvisser]
We are fac
[
https://issues.apache.org/jira/browse/FLINK-27359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526760#comment-17526760
]
Yang Wang commented on FLINK-27359:
---
Duplicated due to bad network.
> Kubernetes oper
[
https://issues.apache.org/jira/browse/FLINK-27359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang closed FLINK-27359.
-
Resolution: Duplicate
> Kubernetes operator throws NPE when testing with Flink 1.15
> --
Yang Wang created FLINK-27359:
-
Summary: Kubernetes operator throws NPE when testing with Flink
1.15
Key: FLINK-27359
URL: https://issues.apache.org/jira/browse/FLINK-27359
Project: Flink
Issue
Yang Wang created FLINK-27358:
-
Summary: Kubernetes operator throws NPE when testing with Flink
1.15
Key: FLINK-27358
URL: https://issues.apache.org/jira/browse/FLINK-27358
Project: Flink
Issue
hehuiyuan commented on PR #19297:
URL: https://github.com/apache/flink/pull/19297#issuecomment-1107312527
hi @fapaul @JingsongLi , have a look this pr.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Summary: In Flink HA Service on K8S, Web UI External Service should point
to elected Job Man
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Summary: In Flink HA Service on K8S, Web UI External Service should update
with new elected
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
[
https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesus H Christ updated FLINK-27357:
---
Description:
Flink on Kubernetes has High Availability services which build an external
ser
Jesus H Christ created FLINK-27357:
--
Summary: In Flink HA Service, Web UI External Service should
update with new elected Job Manager leader's IP
Key: FLINK-27357
URL: https://issues.apache.org/jira/browse/FLINK-
[
https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26177:
---
Labels: auto-deprioritized-critical pull-request-available stale-blocker
test-stability (
[
https://issues.apache.org/jira/browse/FLINK-26238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26238:
---
Labels: stale-major test-stability (was: test-stability)
I am the [Flink Jira Bot|https://g
[
https://issues.apache.org/jira/browse/FLINK-26595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26595:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-25451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25451:
---
Labels: stale-major test-stability (was: test-stability)
I am the [Flink Jira Bot|https://g
[
https://issues.apache.org/jira/browse/FLINK-25747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25747:
---
Labels: auto-deprioritized-critical auto-deprioritized-major
test-stability (was: auto-de
chinmayms commented on PR #19514:
URL: https://github.com/apache/flink/pull/19514#issuecomment-1106842571
Thanks @MartijnVisser !
--
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 co
tweise commented on PR #19514:
URL: https://github.com/apache/flink/pull/19514#issuecomment-1106834064
@MartijnVisser thanks for fixing the test. LGTM. From what I see it is the
case, but would like to confirm nevertheless: All shaded dependencies are
covered by the NOTICE changes?
--
T
MartijnVisser commented on PR #19514:
URL: https://github.com/apache/flink/pull/19514#issuecomment-1106821488
@tweise The S3 tests have passed, see
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=35010&view=results
- Can you review the PR? CC @chinmayms
--
This is
Austin Cawley-Edwards created FLINK-27356:
-
Summary: Incorrect Number of Methods Listed for SplitReader
Key: FLINK-27356
URL: https://issues.apache.org/jira/browse/FLINK-27356
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526503#comment-17526503
]
Ling Jin commented on FLINK-15123:
--
It seems the issue has no progress for a long time,
[
https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526494#comment-17526494
]
Feifan Wang commented on FLINK-27155:
-
I think task in RUNNING state not mean we can
[
https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526488#comment-17526488
]
Matthias Schwalbe commented on FLINK-26586:
---
[~akalashnikov] , I just managed
SteNicholas commented on PR #178:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/178#issuecomment-1106611797
@wangyang0918, thanks for your review. I have addressed above comments and
verified the configuration html manually. PTAL.
cc @gyfora .
--
This is an automated m
snuyanzin commented on code in PR #19552:
URL: https://github.com/apache/flink/pull/19552#discussion_r856240226
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java:
##
@@ -100,7 +93,7 @@ privat
[
https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-26052:
Assignee: Feifan Wang
> Update chinese documentation regarding FLIP-203
> ---
[
https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526480#comment-17526480
]
Dawid Wysakowicz commented on FLINK-26052:
--
Sure, I've assigned it to you. Than
[
https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-27187.
---
Resolution: Fixed
Thanks for adding this metric [~Feifan Wang],
merged as cb68ccf1b
[
https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526478#comment-17526478
]
Feifan Wang commented on FLINK-26052:
-
Hi [~pnowojski] and [~dwysakowicz] , I'm a Ch
[
https://issues.apache.org/jira/browse/FLINK-27343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pengyusong updated FLINK-27343:
---
Priority: Minor (was: Critical)
> flink jdbc sink will lead to unordered result, because the sink b
rkhachatryan merged PR #19441:
URL: https://github.com/apache/flink/pull/19441
--
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.
[
https://issues.apache.org/jira/browse/FLINK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-27218.
---
Fix Version/s: 1.16.0
1.15.1
Resolution: Fixed
Merged into
[
https://issues.apache.org/jira/browse/FLINK-22984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-22984.
---
Fix Version/s: 1.16.0
1.13.7
1.14.5
1.15.1
SteNicholas commented on code in PR #178:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/178#discussion_r856126535
##
Dockerfile:
##
@@ -23,21 +23,23 @@ WORKDIR /app
ENV SHADED_DIR=flink-kubernetes-shaded
ENV OPERATOR_DIR=flink-kubernetes-operator
ENV WEBHOOK_
dianfu closed pull request #19551: [FLINK-22984][python] Disable
PushWatermarkIntoTableSourceScanAcrossCalcRule when having Python UDF
URL: https://github.com/apache/flink/pull/19551
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
SteNicholas commented on code in PR #178:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/178#discussion_r856126535
##
Dockerfile:
##
@@ -23,21 +23,23 @@ WORKDIR /app
ENV SHADED_DIR=flink-kubernetes-shaded
ENV OPERATOR_DIR=flink-kubernetes-operator
ENV WEBHOOK_
rkhachatryan commented on PR #19508:
URL: https://github.com/apache/flink/pull/19508#issuecomment-1106582214
Thanks @mayuehappy.
Merged the PR.
--
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
rkhachatryan merged PR #19508:
URL: https://github.com/apache/flink/pull/19508
--
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.
rkhachatryan commented on code in PR #18539:
URL: https://github.com/apache/flink/pull/18539#discussion_r856290060
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Checkpoints.java:
##
@@ -369,4 +373,37 @@ public static CheckpointStorage loadCheckpointStorage(
[
https://issues.apache.org/jira/browse/FLINK-27352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526450#comment-17526450
]
EMing Zhou commented on FLINK-27352:
Hi, Can you assigne to me?Thank you.
> [JUnit5
gyfora commented on PR #177:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/177#issuecomment-1106522084
Reworked the watcher logic and added some more tests
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
dawidwys commented on code in PR #18539:
URL: https://github.com/apache/flink/pull/18539#discussion_r856213164
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Checkpoints.java:
##
@@ -369,4 +373,37 @@ public static CheckpointStorage loadCheckpointStorage(
dawidwys commented on code in PR #18539:
URL: https://github.com/apache/flink/pull/18539#discussion_r856213164
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Checkpoints.java:
##
@@ -369,4 +373,37 @@ public static CheckpointStorage loadCheckpointStorage(
[ https://issues.apache.org/jira/browse/FLINK-27340 ]
EMing Zhou deleted comment on FLINK-27340:
was (Author: zsigner):
Hi [~Sergey Nuyanzin]
Can I get the ticket?
> [JUnit5 Migration] Module: flink-python
> ---
rkhachatryan commented on code in PR #18539:
URL: https://github.com/apache/flink/pull/18539#discussion_r856196969
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Checkpoints.java:
##
@@ -369,4 +373,37 @@ public static CheckpointStorage loadCheckpointStorage(
JulioPerezGitHub commented on PR #17020:
URL: https://github.com/apache/flink/pull/17020#issuecomment-1106481367
https://discord.gg/ccZe2WMd
--
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 sp
flinkbot commented on PR #19557:
URL: https://github.com/apache/flink/pull/19557#issuecomment-1106473407
## CI report:
* 1940799765d3b35c3e93f7bc6f78138f1e33fbbb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #19556:
URL: https://github.com/apache/flink/pull/19556#issuecomment-1106473307
## CI report:
* 4d99ef8a1ea72740067fb5838d9c854a622be5d5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin opened a new pull request, #19557:
URL: https://github.com/apache/flink/pull/19557
## What is the purpose of the change
Trivial misprint fix class name for `ExecutionEnvironment` class in
docs/content.zh/docs/connectors/datastream/formats/hadoop.md
docs/content
[
https://issues.apache.org/jira/browse/FLINK-26413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26413:
---
Labels: pull-request-available (was: )
> Hive dialect support "LOAD DATA INPATH"
> ---
luoyuxia opened a new pull request, #19556:
URL: https://github.com/apache/flink/pull/19556
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them o
JingsongLi commented on PR #99:
URL: https://github.com/apache/flink-table-store/pull/99#issuecomment-1106466192
> The different manifests design for both two kinds of tables.
Can you clarify which parts of the design are different?
> What's the read API abstraction for those tw
JingsongLi commented on code in PR #99:
URL: https://github.com/apache/flink-table-store/pull/99#discussion_r856178226
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/WriteMode.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation
JingsongLi commented on PR #99:
URL: https://github.com/apache/flink-table-store/pull/99#issuecomment-1106461636
Can we set the append-only write file to an empty key? This allows for a
good integration of these two modes.
Actually, `SstFileMeta` can be renamed to `DataFileMeta`.
--
Th
zoltar9264 commented on PR #19441:
URL: https://github.com/apache/flink/pull/19441#issuecomment-1106451265
@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
[
https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526356#comment-17526356
]
Zhengqi Zhang edited comment on FLINK-27174 at 4/22/22 11:57 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526356#comment-17526356
]
Zhengqi Zhang commented on FLINK-27174:
---
In the current code, if the user does not
rkhachatryan commented on code in PR #19441:
URL: https://github.com/apache/flink/pull/19441#discussion_r856152839
##
flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/ChangelogStorageMetricsTest.java:
##
@@ -295,6 +346,55 @@ public void close() {
}
gyfora commented on code in PR #176:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/176#discussion_r856146587
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/ReconciliationStatus.java:
##
@@ -54,19 +49,20 @@ public class
fapaul commented on code in PR #19405:
URL: https://github.com/apache/flink/pull/19405#discussion_r856141131
##
flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/pom.xml:
##
@@ -30,10 +30,14 @@ under the License.
..
- flink-elasticsear
gyfora commented on code in PR #176:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/176#discussion_r856144200
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconcileTarget.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to
gyfora commented on code in PR #176:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/176#discussion_r856142721
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconcileTarget.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to
snuyanzin commented on PR #18109:
URL: https://github.com/apache/flink/pull/18109#issuecomment-1106425611
@JingsongLi sorry for the poke
Since you are one of the committers dealing with datagen, could you please
have a look here, once you have time?
--
This is an automated message from
NicoK commented on code in PR #526:
URL: https://github.com/apache/flink-web/pull/526#discussion_r856088102
##
_posts/2022-04-11-1.15-announcement.md:
##
@@ -0,0 +1,431 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.15"
+subtitle: ""
+date: 2022-04-11T0
Matthias Pohl created FLINK-27355:
-
Summary: JobManagerRunnerRegistry.localCleanupAsync does not call
the JobManagerRunner.close method repeatedly
Key: FLINK-27355
URL: https://issues.apache.org/jira/browse/FLINK-
SteNicholas commented on code in PR #178:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/178#discussion_r856126535
##
Dockerfile:
##
@@ -23,21 +23,23 @@ WORKDIR /app
ENV SHADED_DIR=flink-kubernetes-shaded
ENV OPERATOR_DIR=flink-kubernetes-operator
ENV WEBHOOK_
[
https://issues.apache.org/jira/browse/FLINK-26114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-26114:
-
Assignee: (was: Niklas Semmler)
> DefaultScheduler fails fatally in case of an erro
[
https://issues.apache.org/jira/browse/FLINK-26114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26114:
--
Description:
In contrast to the {{AdaptiveScheduler}}, the {{DefaultScheduler}} fails
fatally
[
https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526331#comment-17526331
]
Fabian Paul commented on FLINK-27174:
-
I think that is a valid point. We introduced
gyfora commented on PR #176:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/176#issuecomment-1106387142
Thank you, I will check this later today :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
afedulov commented on PR #19405:
URL: https://github.com/apache/flink/pull/19405#issuecomment-1106341694
@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 comme
Aitozi commented on PR #176:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/176#issuecomment-1106331702
Due to the java type erasure, I can't not completly eliminate the
`FlinkDeploymentReconciliationStatus` and `FlinkSessionJobReconciliationStatus`
because I can't get the c
[
https://issues.apache.org/jira/browse/FLINK-27174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526313#comment-17526313
]
Zhengqi Zhang commented on FLINK-27174:
---
[~fpaul] , please take a look
> Non-null
Matthias Pohl created FLINK-27354:
-
Summary: JobMaster still processes requests while terminating
Key: FLINK-27354
URL: https://issues.apache.org/jira/browse/FLINK-27354
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-27348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmet Gürbüz closed FLINK-27348.
Resolution: Done
> Flink KafkaSource doesn't set groupId
> -
>
[
https://issues.apache.org/jira/browse/FLINK-27348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526291#comment-17526291
]
Ahmet Gürbüz edited comment on FLINK-27348 at 4/22/22 9:49 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526298#comment-17526298
]
Roman Khachatryan commented on FLINK-27155:
---
I think Yun Tang means waiting fo
[
https://issues.apache.org/jira/browse/FLINK-27353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27353:
---
Labels: pull-request-available (was: )
> Update training exercises to use Flink 1.15
>
NicoK opened a new pull request, #48:
URL: https://github.com/apache/flink-training/pull/48
This PR will only go through CI once 1.15.0 is released. Until then, you can
apply the following change to `build.gradle` to see it in action:
```
flinkVersion = '1.15-SNAPSHOT'
```
--
Thi
Nico Kruber created FLINK-27353:
---
Summary: Update training exercises to use Flink 1.15
Key: FLINK-27353
URL: https://issues.apache.org/jira/browse/FLINK-27353
Project: Flink
Issue Type: New Fea
[
https://issues.apache.org/jira/browse/FLINK-11694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11694.
Resolution: Fixed
Should be covered by spotless.
> Enforce space before left curly brace
[
https://issues.apache.org/jira/browse/FLINK-27348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526291#comment-17526291
]
Ahmet Gürbüz commented on FLINK-27348:
--
How will i do that with KafkaSource? [~Jian
[
https://issues.apache.org/jira/browse/FLINK-26268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-26268:
Assignee: Huang Xingbo
> Add classfication algorithm support for LogisticRegression, KNN
[
https://issues.apache.org/jira/browse/FLINK-26268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-26268.
Resolution: Done
Merged into master via aedf66335ff3475e449ebeee795d43372c9fa703
> Add classficat
[
https://issues.apache.org/jira/browse/FLINK-26268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26268:
---
Labels: pull-request-available (was: )
> Add classfication algorithm support for LogisticRe
HuangXingBo closed pull request #88: [FLINK-26268][ml][python] Add
classfication algorithm support for LogisticRegression, KNN and NaiveBayes in
ML Python API
URL: https://github.com/apache/flink-ml/pull/88
--
This is an automated message from the Apache Git Service.
To respond to the messag
[
https://issues.apache.org/jira/browse/FLINK-24144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-24144:
---
Assignee: (was: Nico Kruber)
> Improve DataGenerator to prevent excessive creation of n
[
https://issues.apache.org/jira/browse/FLINK-24144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-24144:
Priority: Not a Priority (was: Major)
> Improve DataGenerator to prevent excessive creation of ne
[
https://issues.apache.org/jira/browse/FLINK-26382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-26382.
-
Fix Version/s: 1.15.0
1.14.5
(was: 1.14.3)
Ass
[
https://issues.apache.org/jira/browse/FLINK-27215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526283#comment-17526283
]
tim yu commented on FLINK-27215:
Hi [~fsk119], I have seen some classes that like
Flink
1 - 100 of 136 matches
Mail list logo
