[
https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28478:
--
Assignee: Gyula Fora
> Session Cluster will lost if it failed between status recorded and dep
[
https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28478:
---
Affects Version/s: kubernetes-operator-1.1.0
> Session Cluster will lost if it failed between status
[
https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28478:
---
Priority: Critical (was: Major)
> Session Cluster will lost if it failed between status recorded an
imaffe commented on code in PR #19972:
URL: https://github.com/apache/flink/pull/19972#discussion_r917344225
##
docs/content.zh/docs/connectors/datastream/pulsar.md:
##
@@ -429,9 +448,10 @@ Pulsar Source 默认情况下使用流的方式消费数据。除非任务失败
{{< /tab >}}
{{< /tabs >}}
- {{< hint warni
[
https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28478:
---
Description:
When I test case with https://issues.apache.org/jira/browse/FLINK-28187
I hit that the session
[
https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564641#comment-17564641
]
Aitozi commented on FLINK-28478:
cc [~gyfora]
> Session Cluster will lost if it failed
[
https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28478:
---
Description:
When I test case with https://issues.apache.org/jira/browse/FLINK-28187
I hit that the session
[
https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28478:
---
Description:
When I test case with https://issues.apache.org/jira/browse/FLINK-28187
I found that the sessi
Aitozi created FLINK-28478:
--
Summary: Session Cluster will lost if it failed between status
recorded and deploy
Key: FLINK-28478
URL: https://issues.apache.org/jira/browse/FLINK-28478
Project: Flink
1996fanrui commented on PR #20214:
URL: https://github.com/apache/flink/pull/20214#issuecomment-1179649056
@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
1996fanrui commented on PR #20233:
URL: https://github.com/apache/flink/pull/20233#issuecomment-1179643941
@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
1996fanrui commented on PR #19781:
URL: https://github.com/apache/flink/pull/19781#issuecomment-1179643825
@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
1996fanrui commented on PR #20137:
URL: https://github.com/apache/flink/pull/20137#issuecomment-1179643729
@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-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564637#comment-17564637
]
Aitozi commented on FLINK-28187:
[~gyfora] Thanks for your hint, I take a look on it
>
[
https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28477:
---
Description:
In the {{HistoryServerArchiveFetcher}}, we only list the archives specified by
the historyserv
[
https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28477:
---
Description:
In the {{HistoryServerArchiveFetcher}}, we only list the archives specified by
the historyserv
[
https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564636#comment-17564636
]
Aitozi commented on FLINK-28477:
cc [~guoyangze] [~xtsong]
> Support to scan the histor
[
https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28477:
---
Issue Type: Improvement (was: Bug)
> Support to scan the history server dir with max depth
> --
Aitozi created FLINK-28477:
--
Summary: Support to scan the history server dir with max depth
Key: FLINK-28477
URL: https://issues.apache.org/jira/browse/FLINK-28477
Project: Flink
Issue Type: Bug
Aitozi commented on PR #19840:
URL: https://github.com/apache/flink/pull/19840#issuecomment-1179638147
@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
Aitozi commented on PR #19840:
URL: https://github.com/apache/flink/pull/19840#issuecomment-1179638069
The failure task seems caused by the Kafka connector test time out:
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_apis/build/builds/37968/logs/195
--
This is
[
https://issues.apache.org/jira/browse/FLINK-27386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27386:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-27391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27391:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-27942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27942:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-27293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27293:
---
Labels: pull-request-available stale-major (was: pull-request-available)
I am the [Flink Ji
Matyas Orhidi created FLINK-28476:
-
Summary: Add metrics for Kubernetes API server access
Key: FLINK-28476
URL: https://issues.apache.org/jira/browse/FLINK-28476
Project: Flink
Issue Type: Im
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564588#comment-17564588
]
Piotr Nowojski commented on FLINK-28357:
Hi [~Sandys-Lumsdaine]
{quote}
Maybe my
flinkbot commented on PR #20234:
URL: https://github.com/apache/flink/pull/20234#issuecomment-1179558695
## CI report:
* 21bb37c5427fa54708106c4edcf7c7d69c8cc1ca UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28475:
---
Labels: pull-request-available (was: )
> kafka connector won't stop when the stopping offse
leozhangsr opened a new pull request, #20234:
URL: https://github.com/apache/flink/pull/20234
## What is the purpose of the change
Stopping offset can be 0.When we make a zero stopping offset empty,it would
be serialized to NO_STOPPING_OFFSET, which it is not expected.
## Brief cha
1996fanrui commented on PR #19781:
URL: https://github.com/apache/flink/pull/19781#issuecomment-1179556663
@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
flinkbot commented on PR #20233:
URL: https://github.com/apache/flink/pull/20233#issuecomment-1179556655
## CI report:
* 8b440b3ab0b604fe6184075ad704b76d0811a3d8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28474:
---
Labels: pull-request-available (was: )
> ChannelStateWriteResult may not fail after checkpo
1996fanrui opened a new pull request, #20233:
URL: https://github.com/apache/flink/pull/20233
## What is the purpose of the change
Fix the bug ChannelStateWriteResult might not fail after checkpoint abort.
## Brief change log
Call the ChannelStateWriter.abort(checkpointId
[
https://issues.apache.org/jira/browse/FLINK-28474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fanrui updated FLINK-28474:
---
Description:
After Checkpoint abort, ChannelStateWriteResult should fail.
But if _channelStateWriter.start(
Leo zhang created FLINK-28475:
-
Summary: kafka connector won't stop when the stopping offset is
zero
Key: FLINK-28475
URL: https://issues.apache.org/jira/browse/FLINK-28475
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564584#comment-17564584
]
James commented on FLINK-28357:
---
Maybe my example above is actually the same scenario as b
[
https://issues.apache.org/jira/browse/FLINK-28474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fanrui updated FLINK-28474:
---
Description:
After Checkpoint abort, ChannelStateWriteResult should fail.
But if _channelStateWriter.start(
fanrui created FLINK-28474:
--
Summary: ChannelStateWriteResult may not fail after checkpoint
abort
Key: FLINK-28474
URL: https://issues.apache.org/jira/browse/FLINK-28474
Project: Flink
Issue Type:
JackWangCS commented on PR #20206:
URL: https://github.com/apache/flink/pull/20206#issuecomment-1179551312
>
I am trying to follow your way to validate the HBase delegation provider.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
JackWangCS commented on code in PR #20206:
URL: https://github.com/apache/flink/pull/20206#discussion_r917272387
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/token/HBaseDelegationTokenProvider.java:
##
@@ -0,0 +1,159 @@
+/*
+ * Licensed to the Apache Software
JackWangCS commented on code in PR #20206:
URL: https://github.com/apache/flink/pull/20206#discussion_r917272181
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/token/HBaseDelegationTokenProvider.java:
##
@@ -0,0 +1,159 @@
+/*
+ * Licensed to the Apache Software
bgeng777 commented on code in PR #306:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917270036
##
examples/flink-python-example/README.md:
##
@@ -0,0 +1,83 @@
+
+
+# Flink Kubernetes Operator Python Example
+
+## Overview
+
+This is an end-to-end
bgeng777 commented on code in PR #306:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917270023
##
examples/flink-python-example/Dockerfile:
##
@@ -0,0 +1,41 @@
+
+#
[
https://issues.apache.org/jira/browse/FLINK-28447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28447.
--
Resolution: Fixed
merged to main 11cba495e45710dccbc7a7c9c6fb0892d8340550
> Create Kubernetes Operato
gyfora merged PR #305:
URL: https://github.com/apache/flink-kubernetes-operator/pull/305
--
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
mbalassi commented on PR #305:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/305#issuecomment-1179526229
Thanks, @gyfora. Addressed your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
mbalassi commented on code in PR #305:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/305#discussion_r917256157
##
.github/PULL_REQUEST_TEMPLATE.md:
##
@@ -0,0 +1,68 @@
+
+
+## What is the purpose of the change
+
+*(For example: This pull request adds a new featu
mbalassi commented on code in PR #305:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/305#discussion_r917255798
##
.github/PULL_REQUEST_TEMPLATE.md:
##
@@ -0,0 +1,68 @@
+
mbalassi commented on code in PR #306:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917254407
##
examples/flink-python-example/README.md:
##
@@ -0,0 +1,83 @@
+
+
+# Flink Kubernetes Operator Python Example
+
+## Overview
+
+This is an end-to-end
[
https://issues.apache.org/jira/browse/FLINK-28473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564568#comment-17564568
]
Levani Kokhreidze commented on FLINK-28473:
---
Hi [~chesnay]
Sorry for the pin
Levani Kokhreidze created FLINK-28473:
-
Summary: JobManager restart/failover doesn't trigger local
recovery on TaskManagers
Key: FLINK-28473
URL: https://issues.apache.org/jira/browse/FLINK-28473
flinkbot commented on PR #20232:
URL: https://github.com/apache/flink/pull/20232#issuecomment-1179520244
## CI report:
* 071904184f88310bc5a72a7dfda3581cbbd33faa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25371:
---
Labels: pull-request-available (was: )
> Include data port as part of the host info for sub
X-czh opened a new pull request, #20232:
URL: https://github.com/apache/flink/pull/20232
## What is the purpose of the change
Help user locate the container where a task is running on from Web UI by
including port in the host info on Web UI.
## Brief change log
I
flinkbot commented on PR #20231:
URL: https://github.com/apache/flink/pull/20231#issuecomment-1179518946
## CI report:
* babfe69771e60060b73cd4100ea054827b2a6b92 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27056:
---
Labels: pull-request-available (was: )
> "pipeline.time-characteristic" should be deprecate
gyfora commented on code in PR #305:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/305#discussion_r917251282
##
.github/PULL_REQUEST_TEMPLATE.md:
##
@@ -0,0 +1,68 @@
+
+
+## What is the purpose of the change
+
+*(For example: This pull request adds a new feature
X-czh opened a new pull request, #20231:
URL: https://github.com/apache/flink/pull/20231
## What is the purpose of the change
This pull request marks the configuration option
"pipeline.time-characteristic" as deprecated and set its default value to
EVENT_TIME to reflect the c
[
https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28364:
---
Labels: pull-request-available (was: )
> Python Job support for Kubernetes Operator
> -
bgeng777 opened a new pull request, #306:
URL: https://github.com/apache/flink-kubernetes-operator/pull/306
## What is the purpose of the change
Add Python Job example using Kubernetes Operator
## Brief change log
- Add simple Python script/Dockerfile/job yaml for Pyflink j
Myasuka commented on PR #20145:
URL: https://github.com/apache/flink/pull/20145#issuecomment-1179515495
@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.
zhuzhurk commented on code in PR #20153:
URL: https://github.com/apache/flink/pull/20153#discussion_r917245184
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -1449,4 +1491,42 @@ public Void retrievePayload(ResourceID resourceID) {
Gyula Fora created FLINK-28472:
--
Summary: Add JmStatus as a group for JobManagerDeploymentStatus
count metrics
Key: FLINK-28472
URL: https://issues.apache.org/jira/browse/FLINK-28472
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564550#comment-17564550
]
Márton Balassi commented on FLINK-27852:
[~tedchang] and [~jbusche] opened a PR
zhuzhurk commented on code in PR #20153:
URL: https://github.com/apache/flink/pull/20153#discussion_r917219894
##
flink-runtime/src/main/java/org/apache/flink/runtime/blocklist/BlocklistUtils.java:
##
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
[
https://issues.apache.org/jira/browse/FLINK-28471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
eyys updated FLINK-28471:
-
Attachment: [FLINK-28471] Translate hive_read_write.md into Chinese - ASF
JIRA.url
> Translate hive_read_write.
zhuzhurk commented on code in PR #20153:
URL: https://github.com/apache/flink/pull/20153#discussion_r917218919
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolServiceTest.java:
##
@@ -230,14 +228,13 @@ public void testCreateAllocated
yuchengxin commented on PR #20145:
URL: https://github.com/apache/flink/pull/20145#issuecomment-1179497611
@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
yuchengxin commented on PR #20145:
URL: https://github.com/apache/flink/pull/20145#issuecomment-1179494111
> @yuchengxin Thanks for the update! I think this PR looks good. Would you
please update the description as you already introduced another
`PackagedProgramUtilsPipelineTest
70 matches
Mail list logo
