gaborgsomogyi commented on code in PR #369:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/369#discussion_r973867967
##
docs/content/docs/concepts/architecture.md:
##
@@ -63,3 +63,18 @@ The Operator manages the lifecycle of Flink resources. The
following chart
[
https://issues.apache.org/jira/browse/FLINK-29329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606413#comment-17606413
]
Yun Tang commented on FLINK-29329:
--
Do you mean once we incurred OOM, then no checkpoints would be
[
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606408#comment-17606408
]
Yun Tang commented on FLINK-29328:
--
[~Jason_H] Please use English to update this ticket.
>
[
https://issues.apache.org/jira/browse/FLINK-29280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-29280:
---
Fix Version/s: 1.16.0
1.17.0
> Join hint are not propagated in subquery
>
[
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606407#comment-17606407
]
Yanfei Lei commented on FLINK-29328:
>From your attachments, this issue is caused by state
[
https://issues.apache.org/jira/browse/FLINK-29280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-29280.
--
Resolution: Fixed
Fixed in master: 22cb554008320e6684280b5205f93d7a6f685c6c
in 1.16.0:
[
https://issues.apache.org/jira/browse/FLINK-29280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-29280:
--
Assignee: xuyang
> Join hint are not propagated in subquery
>
godfreyhe closed pull request #20823: [FLINK-29280][table-planner] fix join
hints could not be propagated in subquery
URL: https://github.com/apache/flink/pull/20823
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-29329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-29329:
--
Attachment: job-exceptions-1.txt
> Checkpoint can not be triggered if encountering OOM
>
lincoln-lil commented on PR #20800:
URL: https://github.com/apache/flink/pull/20800#issuecomment-1250520693
> @flinkbot run azure
failed by a known case: https://issues.apache.org/jira/browse/FLINK-29315
[
https://issues.apache.org/jira/browse/FLINK-29329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-29329:
--
Attachment: (was: job-exceptions.txt)
> Checkpoint can not be triggered if encountering OOM
>
[
https://issues.apache.org/jira/browse/FLINK-29329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-29329:
--
Description:
When writing a checkpoint, an OOM error is thrown. But the JM is not failed and
is
[
https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-27603:
-
Fix Version/s: (was: 1.16.0)
1.17.0
> Hive dialect supports "reload
[
https://issues.apache.org/jira/browse/FLINK-28131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-28131.
Resolution: Done
> FLIP-168: Speculative Execution for Batch Job
>
[
https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-13910:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Many serializable classes have no
Yuxin Tan created FLINK-29329:
-
Summary: Checkpoint can not be triggered if encountering OOM
Key: FLINK-29329
URL: https://issues.apache.org/jira/browse/FLINK-29329
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-21375:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Refactor HybridMemorySegment
>
[
https://issues.apache.org/jira/browse/FLINK-18986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-18986:
-
Fix Version/s: (was: 1.16.0)
1.17.0
> KubernetesSessionCli creates
[
https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-25444:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> ClosureCleaner rejects
[
https://issues.apache.org/jira/browse/FLINK-21556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-21556.
Resolution: Fixed
> StreamingKafkaITCase hangs on azure
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-27391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-27391:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Support Hive bucket table
>
[
https://issues.apache.org/jira/browse/FLINK-27242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-27242:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Support RENAME PARTITION statement
[
https://issues.apache.org/jira/browse/FLINK-27243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-27243:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Support SHOW PARTITIONS statement
[
https://issues.apache.org/jira/browse/FLINK-27241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-27241:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Support DROP PARTITION statement
[
https://issues.apache.org/jira/browse/FLINK-27240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-27240:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Support ADD PARTITION statement
[
https://issues.apache.org/jira/browse/FLINK-26968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-26968:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Bump CopyOnWriteStateMap entry
[
https://issues.apache.org/jira/browse/FLINK-26967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-26967:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Fix race condition in
[
https://issues.apache.org/jira/browse/FLINK-26965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-26965:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Allow reuse of
[
https://issues.apache.org/jira/browse/FLINK-26964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-26964:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Notify CheckpointStrategy about
[
https://issues.apache.org/jira/browse/FLINK-26963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-26963:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Allow HeapBackend creation
[
https://issues.apache.org/jira/browse/FLINK-22956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-22956:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Stream Over TTL should use
[
https://issues.apache.org/jira/browse/FLINK-23815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-23815:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Separate the concerns of
[
https://issues.apache.org/jira/browse/FLINK-16388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-16388:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Bump orc-core to 1.4.5
>
[
https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-18229:
-
Fix Version/s: (was: 1.16.0)
1.17.0
> Pending worker requests should be
[
https://issues.apache.org/jira/browse/FLINK-21784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-21784:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Allow HeapBackend RestoreOperation
[
https://issues.apache.org/jira/browse/FLINK-21783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-21783:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Allow HeapBackend snapshotting
[
https://issues.apache.org/jira/browse/FLINK-21649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-21649:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Allow extension of CopyOnWrite
[
https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-16952:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Parquet file system format
[
https://issues.apache.org/jira/browse/FLINK-28738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28738.
--
Resolution: Fixed
Fixed in master: a02b2c232ea2fb1b22bd0e5c290e4c6f0217549b
in 1.16.0:
godfreyhe closed pull request #20679: [FLINK-28738][table-planner] Adds a user
doc about the determinism in streaming
URL: https://github.com/apache/flink/pull/20679
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Jason created FLINK-29328:
-
Summary: 【flink在使用状态过期设置时出现问题】
Key: FLINK-29328
URL: https://issues.apache.org/jira/browse/FLINK-29328
Project: Flink
Issue Type: Bug
Components: API /
[
https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606392#comment-17606392
]
Xingbo Huang commented on FLINK-27916:
--
LadyForest commented on PR #20652:
URL: https://github.com/apache/flink/pull/20652#issuecomment-1250479200
Hi @lsyldliu, do you have time to take a look?
--
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
lincoln-lil commented on PR #20679:
URL: https://github.com/apache/flink/pull/20679#issuecomment-1250475895
@godfreyhe multiple runs always failed in irrelevant connector cases, the
last one is https://issues.apache.org/jira/browse/FLINK-29315
--
This is an automated message from the
HuangXingBo commented on code in PR #569:
URL: https://github.com/apache/flink-web/pull/569#discussion_r973821044
##
_posts/2022-09-08-release-1.14.6.md:
##
@@ -0,0 +1,105 @@
+---
+layout: post
+title: "Apache Flink 1.14.6 Release Announcement"
+date: 2022-09-08T00:00:00.000Z
xuyangzhong commented on PR #20823:
URL: https://github.com/apache/flink/pull/20823#issuecomment-1250466188
The failed case is caused by
https://issues.apache.org/jira/browse/FLINK-29315
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606387#comment-17606387
]
xuyang commented on FLINK-29315:
yunfengzhou-hub commented on code in PR #155:
URL: https://github.com/apache/flink-ml/pull/155#discussion_r973815348
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/PolynomialExpansionTest.java:
##
@@ -20,7 +20,7 @@
Review Comment:
Let's add back the
lincoln-lil commented on PR #20800:
URL: https://github.com/apache/flink/pull/20800#issuecomment-1250441016
@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
lincoln-lil commented on PR #20800:
URL: https://github.com/apache/flink/pull/20800#issuecomment-1250440721
Succeed in pipeline:
https://dev.azure.com/lincoln86xy/lincoln86xy/_build/results?buildId=304=results
--
This is an automated message from the Apache Git Service.
To
yunfengzhou-hub commented on PR #155:
URL: https://github.com/apache/flink-ml/pull/155#issuecomment-1250437078
Hi @weibozhao , could you please refine the description of this PR, as what
we have done in other algorithms' PRs?
--
This is an automated message from the Apache Git Service.
yunfengzhou-hub commented on PR #156:
URL: https://github.com/apache/flink-ml/pull/156#issuecomment-1250436451
Hi @weibozhao , could you please refine the description and JavaDocs of this
PR, illustrating why do we need to add the `size` parameter to VectorAssembler?
What additional
bzhaoopenstack commented on PR #20668:
URL: https://github.com/apache/flink/pull/20668#issuecomment-1250434206
@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
[
https://issues.apache.org/jira/browse/FLINK-29244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606379#comment-17606379
]
Feifan Wang commented on FLINK-29244:
-
Hi [~yuanmei] , how do you think about this ?
> Add metric
fransking opened a new pull request, #317:
URL: https://github.com/apache/flink-statefun/pull/317
Avoiding reserialisation unless the state object has actually changed and
maintaining a deserialised backing property to avoid multiple deserialisations
within a batch
--
This is an
fransking closed pull request #315: FLINK-27934 - Inefficient
deserialization/serialization of state variables within a batch
URL: https://github.com/apache/flink-statefun/pull/315
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
gauravmiglanid11 commented on PR #360:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/360#issuecomment-1250380177
Hi @morhidi , changes done, please review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
gauravmiglanid11 commented on code in PR #360:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/360#discussion_r973770361
##
examples/kubernetes-client-examples/src/main/java/org/apache/flink/examples/Basic.java:
##
@@ -0,0 +1,80 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-29261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606342#comment-17606342
]
Gyula Fora commented on FLINK-29261:
I think this would be a reasonable improvement as the correct
[
https://issues.apache.org/jira/browse/FLINK-29199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606341#comment-17606341
]
Gyula Fora commented on FLINK-29199:
This is something that could be built on top of the current
[
https://issues.apache.org/jira/browse/FLINK-29199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606340#comment-17606340
]
Gyula Fora commented on FLINK-29199:
Also this will be quite tricky to implement with the current
gyfora commented on PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#issuecomment-1250366042
> Re: [CI
failure](https://github.com/apache/flink-kubernetes-operator/actions/runs/3069970323/jobs/4972514311),
it looks like the Maven step completed successfully
gyfora commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r973760343
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java:
gyfora commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r973754287
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java:
##
@@ -180,10 +180,6 @@ private
sap1ens commented on PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#issuecomment-1250355459
Re: [CI
failure](https://github.com/apache/flink-kubernetes-operator/actions/runs/3069970323/jobs/4972514311),
it looks like the Maven step completed successfully
sap1ens commented on PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#issuecomment-1250355101
> If I understand it correctly this would in theory also solve
https://issues.apache.org/jira/browse/FLINK-29144 as a side effect :)
In a way yes, you can place
sap1ens commented on PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#issuecomment-1250354948
> Also this does not address the SessionJobs as we discussed in the Slack
thread with @jeesmon.
Yes, but aside from providing the "no-op" jar, which I thought is
sap1ens commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r973753540
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java:
gyfora commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r973734058
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java:
gyfora commented on PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#issuecomment-1250325337
If I understand it correctly this would in theory also solve
https://issues.apache.org/jira/browse/FLINK-29144 as a side effect :)
--
This is an automated message from
ganlute commented on PR #20542:
URL: https://github.com/apache/flink/pull/20542#issuecomment-1250315262
The failure of CI seems to have nothing to do with 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
ganlute closed pull request #20851: [WIP][FLINK-28910][Connectors/hbase]Fix
potential data deletion while updating HBase rows
URL: https://github.com/apache/flink/pull/20851
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
lincoln-lil commented on PR #20679:
URL: https://github.com/apache/flink/pull/20679#issuecomment-1250290239
@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
[
https://issues.apache.org/jira/browse/FLINK-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-16332.
---
Resolution: Fixed
> Support un-ordered mode for async lookup join
>
[
https://issues.apache.org/jira/browse/FLINK-18871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-18871.
---
Fix Version/s: 1.16.0
Resolution: Fixed
The non-deterministic function exists in changelog
[
https://issues.apache.org/jira/browse/FLINK-24412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-24412.
---
Fix Version/s: 1.16.0
Resolution: Fixed
> retract stream join on topN error
>
lincoln-lil commented on PR #20679:
URL: https://github.com/apache/flink/pull/20679#issuecomment-1250244597
@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
[
https://issues.apache.org/jira/browse/FLINK-29283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29283.
--
Resolution: Won't Fix
> Remove hardcoded apiVersion from operator unit test
>
gyfora closed pull request #367: [FLINK-29283] Remove hardcoded apiVersion from
operator unit test
URL: https://github.com/apache/flink-kubernetes-operator/pull/367
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
gyfora commented on PR #367:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/367#issuecomment-1250236032
I am closing 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 above to go to the
tisonkun commented on code in PR #20584:
URL: https://github.com/apache/flink/pull/20584#discussion_r973693195
##
flink-end-to-end-tests/flink-end-to-end-tests-pulsar/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java:
##
@@ -19,21 +19,26 @@
godfreyhe commented on PR #20679:
URL: https://github.com/apache/flink/pull/20679#issuecomment-1250228642
@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
gaborgsomogyi commented on code in PR #369:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/369#discussion_r973666366
##
docs/content/docs/concepts/architecture.md:
##
@@ -63,3 +63,18 @@ The Operator manages the lifecycle of Flink resources. The
following chart
83 matches
Mail list logo
