afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1279737381
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconcilerTest.java:
##
@@ -409,24
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1279737169
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -124,14 +159,78 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32706:
Description:
SPLIT Function
Description
Splits a string into an array of substrings, based on a
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov closed FLINK-32693.
-
Release Note: Subsumed by FLINK-32670
Resolution: Duplicate
> Cascade deprecation
hisea closed pull request #18: Add support for setting attributes in sink.
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/18
--
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
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--
Parent: (was: FLINK-28045)
Issue Type: Technical Debt (was: Sub-task)
>
XComp commented on PR #23103:
URL: https://github.com/apache/flink/pull/23103#issuecomment-1659201219
Test run without the fix:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51842=logs=413780be-9d4b-55ad-e383-85bf33d2f47f
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32706:
---
Labels: pull-request-available (was: )
> Add SPLIT(STRING) support in SQL & Table API
>
[
https://issues.apache.org/jira/browse/FLINK-32711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32711:
---
Labels: pull-request-available (was: )
> Type mismatch when proctime function used as
flinkbot commented on PR #23107:
URL: https://github.com/apache/flink/pull/23107#issuecomment-1658771426
## CI report:
* 1d399c7dd4cddfdb075aec4e2abe46a2936d9682 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
He-Pin commented on PR #22996:
URL: https://github.com/apache/flink/pull/22996#issuecomment-1658995663
Hi team, I want to upgrade the current classic transport from netty 3 to
netty 4 ,do you think that's ok?
I just asked on maillist
[
https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32706:
Description:
SPLIT Function
Description
Splits a string into an array of substrings, based on a
hanyuzheng7 opened a new pull request, #23108:
URL: https://github.com/apache/flink/pull/23108
## What is the purpose of the change
This is an implementation of SPLIT
## Brief change log
Splits a string into an array of substrings based on a delimiter. If the
delimiter is
Aitozi opened a new pull request, #23107:
URL: https://github.com/apache/flink/pull/23107
…parameter
## What is the purpose of the change
Fix the bug of type mismatch when `proctime()` is used as parameter of
function with `ANY` type.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32706:
Description:
SPLIT Function
Description
Splits a string into an array of substrings, based on a
[
https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32706:
Description:
SPLIT Function
Description
Splits a string into an array of substrings, based on a
flinkbot commented on PR #23108:
URL: https://github.com/apache/flink/pull/23108#issuecomment-1659125903
## CI report:
* 0f6c18558aa89b3691698b5814fd24627849f7ee UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Alexander Fedulov created FLINK-32719:
-
Summary: Block upgrades during checkpoints when LATEST_STATE
recovery is configured
Key: FLINK-32719
URL: https://issues.apache.org/jira/browse/FLINK-32719
[
https://issues.apache.org/jira/browse/FLINK-32720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749375#comment-17749375
]
Hanyu Zheng commented on FLINK-32720:
-
[~martijnvisser] can you please assign this ticket to
[
https://issues.apache.org/jira/browse/FLINK-32720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32720:
Description:
GENERATE_SERIES Function
Description
Constructs an array of values between
hackergin opened a new pull request, #23109:
URL: https://github.com/apache/flink/pull/23109
## What is the purpose of the change
*Add doc for time travel*
## Brief change log
* add doc for time travel
## Verifying this change
This change is a
flinkbot commented on PR #23109:
URL: https://github.com/apache/flink/pull/23109#issuecomment-1659568110
## CI report:
* ac9510ab936c57b6c57fcf21f6429afad3b3f9d8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hackergin opened a new pull request, #23110:
URL: https://github.com/apache/flink/pull/23110
## What is the purpose of the change
*Add doc for catalog store*
## Brief change log
* Add doc for catalog store*
## Verifying this change
This
[
https://issues.apache.org/jira/browse/FLINK-32653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32653:
---
Labels: pull-request-available (was: )
> Add doc for catalog store
>
[ https://issues.apache.org/jira/browse/FLINK-32720 ]
Hanyu Zheng deleted comment on FLINK-32720:
-
was (Author: JIRAUSER300701):
GENERATE_SERIES Function
Description
Constructs an array of values between {{start}} and {{{}end{}}}, inclusive.
[
https://issues.apache.org/jira/browse/FLINK-32720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749373#comment-17749373
]
Hanyu Zheng commented on FLINK-32720:
-
GENERATE_SERIES Function
Description
Constructs an array of
[
https://issues.apache.org/jira/browse/FLINK-32720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32720:
Description:
GENERATE_SERIES Function
Description
Constructs an array of values between
[
https://issues.apache.org/jira/browse/FLINK-32711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749412#comment-17749412
]
Aitozi commented on FLINK-32711:
I pushed a fix for this, anyone can help review ?
> Type mismatch when
flinkbot commented on PR #23110:
URL: https://github.com/apache/flink/pull/23110#issuecomment-1659592898
## CI report:
* 506f6a776447d4313025ade982c75e2988744296 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp commented on PR #23103:
URL: https://github.com/apache/flink/pull/23103#issuecomment-1659593040
Test run with the fix:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51848=results
--
This is an automated message from the Apache Git Service.
To respond to the
reswqa commented on code in PR #23013:
URL: https://github.com/apache/flink/pull/23013#discussion_r1280046993
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/StreamingSink.java:
##
@@ -173,7 +173,7 @@ public static
WencongLiu commented on PR #23100:
URL: https://github.com/apache/flink/pull/23100#issuecomment-1659552472
@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
Hanyu Zheng created FLINK-32720:
---
Summary: Add GENERATE_SERIES support in SQL & Table API
Key: FLINK-32720
URL: https://issues.apache.org/jira/browse/FLINK-32720
Project: Flink
Issue Type:
reswqa commented on code in PR #23013:
URL: https://github.com/apache/flink/pull/23013#discussion_r1280041872
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/v2/DiscardingSink.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software
XComp commented on PR #23103:
URL: https://github.com/apache/flink/pull/23103#issuecomment-1659598515
I rebased the branch and removed the debug commits (see [CI run w/o
[
https://issues.apache.org/jira/browse/FLINK-32659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749428#comment-17749428
]
Aitozi commented on FLINK-32659:
Can someone help review the fix:
1996fanrui commented on PR #22854:
URL: https://github.com/apache/flink/pull/22854#issuecomment-1659454826
> The CI job appears to have failed -
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51797=results
But I don't understand how to see the exact cause of it
[
https://issues.apache.org/jira/browse/FLINK-32475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32475:
---
Labels: pull-request-available (was: )
> Add doc for time travel
> ---
reswqa commented on code in PR #23013:
URL: https://github.com/apache/flink/pull/23013#discussion_r1280043303
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java:
##
@@ -315,6 +315,13 @@ private R
1996fanrui commented on PR #23094:
URL: https://github.com/apache/flink/pull/23094#issuecomment-1659459081
I will merge this PR tomorrow if no any other comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Jacky Lau created FLINK-32721:
-
Summary: agg supports char type
Key: FLINK-32721
URL: https://issues.apache.org/jira/browse/FLINK-32721
Project: Flink
Issue Type: Improvement
lindong28 commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1278817765
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -180,8 +186,25 @@ public class CheckpointCoordinator {
/**
[
https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-32548:
Release Note: The watermark alignment is ready for production since
Flink-1.18, which fixed a series of
[
https://issues.apache.org/jira/browse/FLINK-24304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-24304.
-
Resolution: Cannot Reproduce
Closing that one because it never reappeared and we're lacking
luoyuxia merged PR #23060:
URL: https://github.com/apache/flink/pull/23060
--
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-32144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749064#comment-17749064
]
Matthias Pohl commented on FLINK-32144:
---
[
https://issues.apache.org/jira/browse/FLINK-32519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-32519.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master: fd0d2db378d42534273c166e6fb664a04ed282b8
>
[
https://issues.apache.org/jira/browse/FLINK-32515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-32515.
--
Resolution: Fixed
> FLIP-303: Support REPLACE TABLE AS SELECT statement
>
[
https://issues.apache.org/jira/browse/FLINK-32144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749064#comment-17749064
]
Matthias Pohl edited comment on FLINK-32144 at 7/31/23 7:35 AM:
2x in
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749070#comment-17749070
]
Matthias Pohl commented on FLINK-32663:
---
yunfengzhou-hub commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1278941839
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -328,6 +337,7 @@ public void executionAttemptFailed(
flinkbot commented on PR #23103:
URL: https://github.com/apache/flink/pull/23103#issuecomment-1657903792
## CI report:
* 67fdad1dcc1da0776fa5e4469e8e2427454b1e28 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-32223.
-
> Add Hive delegation token support
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-32223.
---
Fix Version/s: 1.18.0
Assignee: qingbo jiao
Resolution: Fixed
70e6359 on
XComp merged PR #22987:
URL: https://github.com/apache/flink/pull/22987
--
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:
Matthias Pohl created FLINK-32715:
-
Summary:
ProcessFailureCancelingITCase.testCancelingOnProcessFailure
Key: FLINK-32715
URL: https://issues.apache.org/jira/browse/FLINK-32715
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749071#comment-17749071
]
Matthias Pohl commented on FLINK-31168:
---
jdk17 again:
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749072#comment-17749072
]
Matthias Pohl commented on FLINK-32662:
---
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749073#comment-17749073
]
Matthias Pohl commented on FLINK-32663:
---
lindong28 commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1278993694
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -183,6 +189,15 @@ public class CheckpointCoordinator {
/**
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Description:
I am having trouble understanding why adding a 'UNION ALL' with a 'GROUP BY'
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Description:
I am having trouble understanding why adding a 'UNION ALL' with a 'GROUP BY'
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Attachment: Screenshot 2023-07-31 at 10.37.11 AM.png
Screenshot 2023-07-31 at
[
https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-32548:
Release Note: The watermark alignment is ready for production since
Flink-1.18, which completed a series
[
https://issues.apache.org/jira/browse/FLINK-32712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749059#comment-17749059
]
dalongliu commented on FLINK-32712:
---
[~yuanoOo] It looks like this optimization makes sense, can you
[
https://issues.apache.org/jira/browse/FLINK-32583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32583.
---
Fix Version/s: 1.18.0
1.16.3
1.17.2
Assignee:
[
https://issues.apache.org/jira/browse/FLINK-32583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32583:
--
Release Note: Fixes a race condition in the RestClient that could happen
when submitting a
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31168:
---
Labels: pull-request-available test-stability (was: test-stability)
>
XComp opened a new pull request, #23103:
URL: https://github.com/apache/flink/pull/23103
## What is the purpose of the change
tba
## Brief change log
tba
## Verifying this change
tba
## Does this pull request potentially affect one of the following
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31168:
--
Priority: Critical (was: Blocker)
> JobManagerHAProcessFailureRecoveryITCase failed due to
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Description:
I am having trouble understanding why adding a 'UNION ALL' with a 'GROUP BY'
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Environment: Apache Flink 1.16.1 (was: Apache Flink Kubernetes Operator
1.3.1
Kubernetes
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Priority: Major (was: Blocker)
> 'UNION ALL' with a 'GROUP BY' condition in Flink is
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749096#comment-17749096
]
Yang Wang commented on FLINK-32678:
---
I believe it is reasonable. I would also keep an eye on the netty
mxm commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1279030450
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconcilerTest.java:
##
@@ -409,24
mxm commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1279029826
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -124,14 +159,78 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-32715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749061#comment-17749061
]
Matthias Pohl commented on FLINK-32715:
---
I'm linking an old issue where the same test was failing
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749062#comment-17749062
]
Matthias Pohl commented on FLINK-32662:
---
[
https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749063#comment-17749063
]
Matthias Pohl commented on FLINK-32523:
---
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32663:
-
Assignee: Yanfei Lei (was: Matthias Pohl)
>
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749069#comment-17749069
]
Matthias Pohl commented on FLINK-32663:
---
[~Yanfei Lei] but do you continue looking into that
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749068#comment-17749068
]
Matthias Pohl commented on FLINK-32662:
---
Kwangin (Dennis) Jung created FLINK-32716:
-
Summary: Give 'None' option for 'scheduler-mode'
Key: FLINK-32716
URL: https://issues.apache.org/jira/browse/FLINK-32716
Project: Flink
Kwangin (Dennis) Jung created FLINK-32717:
-
Summary: Change of topic list from KafkaSource
Key: FLINK-32717
URL: https://issues.apache.org/jira/browse/FLINK-32717
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kwangin (Dennis) Jung updated FLINK-32717:
--
Summary: Change of topic list from KafkaSource not works (was: Change of
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749085#comment-17749085
]
Matthias Pohl commented on FLINK-31168:
---
I'm lowering the priority of this issue again. We should
Neha Aggarwal created FLINK-32718:
-
Summary: 'UNION ALL' with a 'GROUP BY' condition in Flink is
causing the checkpoint to become unbounded
Key: FLINK-32718
URL: https://issues.apache.org/jira/browse/FLINK-32718
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Labels: (was: pull-request-available)
> 'UNION ALL' with a 'GROUP BY' condition in Flink
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Component/s: Table SQL / API
Table SQL / Planner
(was:
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Aggarwal updated FLINK-32718:
--
Affects Version/s: 1.16.1
(was: kubernetes-operator-1.3.1)
>
flinkbot commented on PR #23106:
URL: https://github.com/apache/flink/pull/23106#issuecomment-1658605999
## CI report:
* 0531c754a7be10cf9b6101ddec00af90856daa8d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749247#comment-17749247
]
Stefan Richter commented on FLINK-32681:
I'm running on Mac, but with a sleep I already managed
gaborgsomogyi commented on code in PR #21788:
URL: https://github.com/apache/flink/pull/21788#discussion_r1279022122
##
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java:
##
@@ -388,13 +388,20 @@ private Path copyToRemoteApplicationDir(
[
https://issues.apache.org/jira/browse/FLINK-32717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749108#comment-17749108
]
Martijn Visser commented on FLINK-32717:
If you're restarting from a checkpoint/savepoint, that
[
https://issues.apache.org/jira/browse/FLINK-32717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32717.
--
Resolution: Information Provided
> Change of topic list from KafkaSource not works
>
mateczagany commented on code in PR #21788:
URL: https://github.com/apache/flink/pull/21788#discussion_r1279057765
##
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java:
##
@@ -388,13 +388,20 @@ private Path copyToRemoteApplicationDir(
[
https://issues.apache.org/jira/browse/FLINK-32715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749119#comment-17749119
]
Matthias Pohl edited comment on FLINK-32715 at 7/31/23 9:59 AM:
I'm
[
https://issues.apache.org/jira/browse/FLINK-32715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749119#comment-17749119
]
Matthias Pohl edited comment on FLINK-32715 at 7/31/23 9:59 AM:
I'm
XComp opened a new pull request, #23104:
URL: https://github.com/apache/flink/pull/23104
## What is the purpose of the change
We introduced a Precondition checking whether the contenders deregistered
themselves before closing the HA backend of the service.
[
https://issues.apache.org/jira/browse/FLINK-15358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749106#comment-17749106
]
Vladislav Keda commented on FLINK-15358:
[~autophagy] [~huwh] hi! This bug is a blocker for our
1 - 100 of 115 matches
Mail list logo
