[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-31757:
---
Summary: Support Balanced Tasks Scheduling (was: Optimize Flink
un-balanced tasks scheduling)
>
flinkbot commented on PR #23461:
URL: https://github.com/apache/flink/pull/23461#issuecomment-1734057845
## CI report:
* 71309fb4cba1e09de71b03a2ad190137e76eab2d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23459:
URL: https://github.com/apache/flink/pull/23459#issuecomment-1734054047
## CI report:
* ea9b0a0cff9ae7889e246989b2e5d27779f9eb0e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23460:
URL: https://github.com/apache/flink/pull/23460#issuecomment-1734056213
## CI report:
* 3907cb98c6ec3a08e5c1c6ba86fd8f69e774e08d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on PR #23458:
URL: https://github.com/apache/flink/pull/23458#issuecomment-1733693205
@RyanSkraba thanks for the contribution
looks ok from my side
could you please also provide backports to 1.16.x, 1.17.x, 1.18.x ?
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-33150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-33150:
---
Fix Version/s: (was: 1.15.4)
> add the processing logic for the long type
>
[
https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-33149:
-
Assignee: Ryan Skraba
> Bump snappy-java to 1.1.10.4
>
>
jgagnon1 commented on PR #23453:
URL: https://github.com/apache/flink/pull/23453#issuecomment-1733850068
@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-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768680#comment-17768680
]
Martijn Visser commented on FLINK-28303:
[~tanjialiang] It would be good to double check this in
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768679#comment-17768679
]
Yang Wang commented on FLINK-33155:
---
Thanks for your comments.
> Changing the default behavior
RyanSkraba opened a new pull request, #23459:
URL: https://github.com/apache/flink/pull/23459
## What is the purpose of the change
Backport of https://github.com/apache/flink/pull/23458 to `release-1.16`
Bump the version of snappy to address a vulnerability.
## Brief
RyanSkraba opened a new pull request, #23460:
URL: https://github.com/apache/flink/pull/23460
## What is the purpose of the change
Backport of https://github.com/apache/flink/pull/23458 to `release-1.17`
Bump the version of snappy to address a vulnerability.
## Brief
RyanSkraba opened a new pull request, #23461:
URL: https://github.com/apache/flink/pull/23461
## What is the purpose of the change
Backport of https://github.com/apache/flink/pull/23458 to `release-1.18`
Bump the version of snappy to address a vulnerability.
## Brief
XComp commented on PR #23461:
URL: https://github.com/apache/flink/pull/23461#issuecomment-1734177907
```
16:26:18.071 [ERROR] Failed to execute goal
com.github.eirslett:frontend-maven-plugin:1.11.0:install-node-and-npm (install
node and npm) on project flink-runtime-web: Could not
[
https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768751#comment-17768751
]
Matthias Schwalbe commented on FLINK-26585:
---
Thanks [~masteryhx] ,
... Jira somehow swallowed
[
https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768751#comment-17768751
]
Matthias Schwalbe edited comment on FLINK-26585 at 9/25/23 3:41 PM:
[
https://issues.apache.org/jira/browse/FLINK-32471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32471:
---
Labels: pull-request-available stale-major (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768878#comment-17768878
]
Matthias Pohl commented on FLINK-33149:
---
I think my previous investigation is not enough: It seems
dependabot[bot] opened a new pull request, #98:
URL: https://github.com/apache/flink-connector-aws/pull/98
Bumps [org.xerial.snappy:snappy-java](https://github.com/xerial/snappy-java)
from 1.1.10.1 to 1.1.10.4.
Release notes
Sourced from
dependabot[bot] opened a new pull request, #340:
URL: https://github.com/apache/flink-statefun/pull/340
Bumps [org.xerial.snappy:snappy-java](https://github.com/xerial/snappy-java)
from 1.1.10.1 to 1.1.10.4.
Release notes
Sourced from
yigress commented on code in PR #23425:
URL: https://github.com/apache/flink/pull/23425#discussion_r1336512189
##
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorFailureTest.java:
##
@@ -72,7 +72,7 @@ class CheckpointCoordinatorFailureTest {
yigress commented on code in PR #23425:
URL: https://github.com/apache/flink/pull/23425#discussion_r1336512772
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java:
##
@@ -368,6 +373,34 @@ public void discard() throws Exception {
yigress commented on code in PR #23425:
URL: https://github.com/apache/flink/pull/23425#discussion_r1336512951
##
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:
##
@@ -109,6 +109,20 @@ public class CheckpointingOptions {
yigress commented on code in PR #23425:
URL: https://github.com/apache/flink/pull/23425#discussion_r1336513096
##
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:
##
@@ -109,6 +109,20 @@ public class CheckpointingOptions {
yigress commented on code in PR #23425:
URL: https://github.com/apache/flink/pull/23425#discussion_r1336513394
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java:
##
@@ -368,6 +373,34 @@ public void discard() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768867#comment-17768867
]
Matthias Pohl commented on FLINK-33149:
---
Thanks for looking into it. I did a code investigation to
Sxnan commented on PR #22897:
URL: https://github.com/apache/flink/pull/22897#issuecomment-1734709549
@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.
hackergin opened a new pull request, #23462:
URL: https://github.com/apache/flink/pull/23462
BP https://github.com/apache/flink/pull/23446
--
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
flinkbot commented on PR #23462:
URL: https://github.com/apache/flink/pull/23462#issuecomment-1734714992
## CI report:
* a630fd02f8232d8bbd9f521bdc7990dfd8d79e21 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
swuferhong opened a new pull request, #23463:
URL: https://github.com/apache/flink/pull/23463
## What is the purpose of the change
After testing different sql pattern, found that `FLINK-33064` can cause
serious bugs in views and subquery scenarios. So this pr is aims
minchowang commented on PR #16:
URL:
https://github.com/apache/flink-connector-pulsar/pull/16#issuecomment-1734745307
@syhily Hi, Whether can apply to develop-1.14
[develop-flink-1.14](https://github.com/streamnative/flink/tree/develop) for
this PR.
--
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769014#comment-17769014
]
tanjialiang commented on FLINK-28303:
-
[~martijnvisser] I had already check the latest kafka
Asha Boyapati created FLINK-33156:
-
Summary: Remove flakiness from tests in
OperatorStateBackendTest.java
Key: FLINK-33156
URL: https://issues.apache.org/jira/browse/FLINK-33156
Project: Flink
xbthink commented on PR #23454:
URL: https://github.com/apache/flink/pull/23454#issuecomment-1734723928
@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-33143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng closed FLINK-33143.
-
Resolution: Resolved
> Wrongly throw error while temporary table join with invalidScan lookup
flinkbot commented on PR #23463:
URL: https://github.com/apache/flink/pull/23463#issuecomment-1734753507
## CI report:
* 14e35b26265249609fb92f82c02d598f1c29ce7e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp commented on code in PR #677:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1336571925
##
flink-autoscaler/pom.xml:
##
@@ -45,6 +45,32 @@ under the License.
provided
+
+org.projectlombok
+
swuferhong closed pull request #23457: [FLINK-33143][table-planner] Fix wrongly
throw error while temporary table join with invalidScan lookup source and
selected as view
URL: https://github.com/apache/flink/pull/23457
--
This is an automated message from the Apache Git Service.
To respond
xintongsong commented on code in PR #23456:
URL: https://github.com/apache/flink/pull/23456#discussion_r1336633757
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java:
##
@@ -526,8 +526,14 @@ public DataStream global() {
* in
[
https://issues.apache.org/jira/browse/FLINK-33156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Asha Boyapati updated FLINK-33156:
--
Description:
This issue is similar to:
https://issues.apache.org/jira/browse/FLINK-32963
We
X-czh opened a new pull request, #23465:
URL: https://github.com/apache/flink/pull/23465
## What is the purpose of the change
First step towards [[FLIP-363: Unify the Representation of TaskManager
Location in REST API and Web
[
https://issues.apache.org/jira/browse/FLINK-33129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhaoyang Shao updated FLINK-33129:
--
Priority: Critical (was: Blocker)
> Can't create RowDataToAvroConverter for
victor9309 closed pull request #23451: [FLINK-32108][test] KubernetesExtension
calls assumeThat in @BeforeAll callback which doesn't print the actual failure
message
URL: https://github.com/apache/flink/pull/23451
--
This is an automated message from the Apache Git Service.
To respond to
victor9309 commented on PR #23451:
URL: https://github.com/apache/flink/pull/23451#issuecomment-1734762519
failure
--
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
xiangyuf commented on code in PR #23455:
URL: https://github.com/apache/flink/pull/23455#discussion_r1336585759
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -1050,10 +1052,15 @@ private
1996fanrui commented on code in PR #677:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1336584237
##
flink-autoscaler/pom.xml:
##
@@ -45,6 +45,32 @@ under the License.
provided
+
+org.projectlombok
+
asha-boyapati opened a new pull request, #23464:
URL: https://github.com/apache/flink/pull/23464
## What is the purpose of the change
This PR is similar to the following PR which was accepted:
https://github.com/apache/flink/pull/23298
This PR makes the following tests
[
https://issues.apache.org/jira/browse/FLINK-33129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768959#comment-17768959
]
Zhaoyang Shao commented on FLINK-33129:
---
In DataStructureConverters, there is similar
[
https://issues.apache.org/jira/browse/FLINK-33143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768969#comment-17768969
]
Yunhong Zheng commented on FLINK-33143:
---
This fix way cannot cover all sql pattern, like subQuery,
[
https://issues.apache.org/jira/browse/FLINK-33107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-33107.
--
Fix Version/s: kubernetes-operator-1.7.0
Resolution: Fixed
merged to main
gyfora merged PR #681:
URL: https://github.com/apache/flink-kubernetes-operator/pull/681
--
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:
[
https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-33137:
---
Assignee: Lorenzo Nicora
> FLIP-312: Prometheus Sink Connector
>
Ryan Skraba created FLINK-33149:
---
Summary: Bump snappy-java to 1.1.10.4
Key: FLINK-33149
URL: https://issues.apache.org/jira/browse/FLINK-33149
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-33151:
-
Assignee: Danny Cranmer
> Prometheus Sink Connector - Create Github Repo
>
Lorenzo Nicora created FLINK-33152:
--
Summary: Prometheus Sink Connector - Integration tests
Key: FLINK-33152
URL: https://issues.apache.org/jira/browse/FLINK-33152
Project: Flink
Issue
RyanSkraba opened a new pull request, #23458:
URL: https://github.com/apache/flink/pull/23458
## What is the purpose of the change
Bump the version of snappy to address a vulnerability.
## Brief change log
## Verifying this change
This change is already covered by
[
https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33149:
---
Labels: pull-request-available (was: )
> Bump snappy-java to 1.1.10.4
>
[
https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33137:
--
Component/s: Connectors / Prometheus
> FLIP-312: Prometheus Sink Connector
>
[
https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33137:
--
Fix Version/s: prometheus-connector-1.0.0
> FLIP-312: Prometheus Sink Connector
>
Danny Cranmer created FLINK-33151:
-
Summary: Prometheus Sink Connector - Create Github Repo
Key: FLINK-33151
URL: https://issues.apache.org/jira/browse/FLINK-33151
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorenzo Nicora updated FLINK-33140:
---
Description: End-to-end example application, to be deployed on Amazon
Managed Service for
[
https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorenzo Nicora updated FLINK-33140:
---
Description: End-to-end example application, deployable on Amazon Managed
Service for
[
https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorenzo Nicora updated FLINK-33140:
---
Summary: Prometheus Sink Connector - E2E example on AWS (was: Prometheus
Sink Connector -
[
https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorenzo Nicora updated FLINK-33140:
---
Summary: Prometheus Sink Connector - E2E example (was: Prometheus Sink
Connector - E2E
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-31757:
Description:
This is a umbrella JIRA of
[FLIP-370|https://cwiki.apache.org/confluence/x/U56zDw].
flinkbot commented on PR #23458:
URL: https://github.com/apache/flink/pull/23458#issuecomment-1733193724
## CI report:
* 4debb4036b86485b39be61cb284e7ba6e8daaba7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-33151.
---
Resolution: Done
> Prometheus Sink Connector - Create Github Repo
>
[
https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768596#comment-17768596
]
Danny Cranmer commented on FLINK-33151:
---
https://github.com/apache/flink-connector-prometheus
>
echauchot commented on PR #23443:
URL: https://github.com/apache/flink/pull/23443#issuecomment-1733119379
Hi @rmetzger, I saw you authored parts of this code, can you please do a
review or point me to another reviewer ?
--
This is an automated message from the Apache Git Service.
To
wenhao.yu created FLINK-33150:
-
Summary: add the processing logic for the long type
Key: FLINK-33150
URL: https://issues.apache.org/jira/browse/FLINK-33150
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-31757:
Summary: FLIP-370: Support Balanced Tasks Scheduling (was: Support
Balanced Tasks Scheduling)
>
[
https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33151:
--
Component/s: Connectors / Prometheus
> Prometheus Sink Connector - Create Github Repo
>
[
https://issues.apache.org/jira/browse/FLINK-33152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33152:
--
Fix Version/s: prometheus-connector-1.0.0
> Prometheus Sink Connector - Integration tests
>
[
https://issues.apache.org/jira/browse/FLINK-33139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33139:
--
Fix Version/s: prometheus-connector-1.0.0
> Prometheus Sink Connector - Table API support
>
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-31757:
Description: This is an umbrella JIRA of
[FLIP-370|https://cwiki.apache.org/confluence/x/U56zDw]. (was:
[
https://issues.apache.org/jira/browse/FLINK-33141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33141:
--
Fix Version/s: (was: prometheus-connector-1.0.0)
> Promentheus Sink Connector - Amazon
[
https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33151:
--
Fix Version/s: prometheus-connector-1.0.0
> Prometheus Sink Connector - Create Github Repo
>
[
https://issues.apache.org/jira/browse/FLINK-33141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33141:
--
Fix Version/s: prometheus-connector-1.0.0
> Promentheus Sink Connector - Amazon Managed
[
https://issues.apache.org/jira/browse/FLINK-33139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33139:
--
Component/s: Connectors / Prometheus
> Prometheus Sink Connector - Table API support
>
[
https://issues.apache.org/jira/browse/FLINK-33138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33138:
--
Component/s: Connectors / Prometheus
> Prometheus Connector Sink - DataStream API
[
https://issues.apache.org/jira/browse/FLINK-33138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33138:
--
Fix Version/s: prometheus-connector-1.0.0
> Prometheus Connector Sink - DataStream API
[
https://issues.apache.org/jira/browse/FLINK-33152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33152:
--
Component/s: Connectors / Prometheus
> Prometheus Sink Connector - Integration tests
>
[
https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tanjialiang closed FLINK-33153.
---
Release Note: realte to https://issues.apache.org/jira/browse/FLINK-28303
Resolution:
[
https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tanjialiang updated FLINK-33153:
External issue URL: https://issues.apache.org/jira/browse/FLINK-28303
Release Note:
[
https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tanjialiang updated FLINK-33153:
External issue URL: (was:
https://issues.apache.org/jira/browse/FLINK-28303)
> Kafka using
[
https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768631#comment-17768631
]
tanjialiang commented on FLINK-33153:
-
It relate to
Monody created FLINK-33154:
--
Summary: flink on k8s，An error occurred during consuming rocketmq
Key: FLINK-33154
URL: https://issues.apache.org/jira/browse/FLINK-33154
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768637#comment-17768637
]
tanjialiang commented on FLINK-28303:
-
Maybe this this is the reason?
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-33155:
--
Component/s: Deployment / YARN
> Flink ResourceManager continuously fails to start TM container on
Yang Wang created FLINK-33155:
-
Summary: Flink ResourceManager continuously fails to start TM
container on YARN when Kerberos enabled
Key: FLINK-33155
URL: https://issues.apache.org/jira/browse/FLINK-33155
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-33155:
--
Description:
When Kerberos enabled(with key tab) and after one day(the container token
expired),
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-33155:
--
Description:
When Kerberos enabled(with key tab) and after one day(the container token
expired),
[
https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768604#comment-17768604
]
Matthias Schwalbe commented on FLINK-26585:
---
Hi [~masteryhx] ,
The PR
FangYongs commented on code in PR #23455:
URL: https://github.com/apache/flink/pull/23455#discussion_r1335703134
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -1050,10 +1052,15 @@ private
[
https://issues.apache.org/jira/browse/FLINK-33127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768602#comment-17768602
]
Matthias Schwalbe commented on FLINK-33127:
---
[~masteryhx] : I actually want to finish
[
https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768607#comment-17768607
]
Hangxiang Yu commented on FLINK-26585:
--
[~Matthias Schwalbe] I have taked a second review last
[
https://issues.apache.org/jira/browse/FLINK-33127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768610#comment-17768610
]
Hangxiang Yu commented on FLINK-33127:
--
Actually I have taked a second review last month but not
tanjialiang created FLINK-33153:
---
Summary: Kafka using latest-offset maybe missing data
Key: FLINK-33153
URL: https://issues.apache.org/jira/browse/FLINK-33153
Project: Flink
Issue Type: Bug
FangYongs commented on code in PR #23455:
URL: https://github.com/apache/flink/pull/23455#discussion_r1335701445
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -1050,10 +1052,15 @@ private
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768665#comment-17768665
]
Gabor Somogyi commented on FLINK-33155:
---
Not updating
1 - 100 of 101 matches
Mail list logo
