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
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
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`
[
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
>
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
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`
[
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
> ---
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
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
[
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:
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
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
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
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
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-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
[
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
[
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-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 ]
Hanyu Zheng deleted comment on FLINK-32720:
-
was (Author: JIRAUSER300701):
GENERATE_SERIES Function
Description
Constructs an array of values between {{start}} and {{{}end{}}}, inclusive.
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:
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
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`
[
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
>
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
[
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
[
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
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-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)
>
[
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
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
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
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`
[
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
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
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-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
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=17749218#comment-17749218
]
Matthias Pohl commented on FLINK-32681:
---
The test failure is reproducible locally (with a Linux
lincoln-lil commented on code in PR #23051:
URL: https://github.com/apache/flink/pull/23051#discussion_r1276305812
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/SqlWindowTableFunction.java:
##
@@ -62,25 +58,7 @@
*
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749203#comment-17749203
]
Stefan Richter commented on FLINK-32681:
[~mapohl] I was trying to reproduce this locally
flinkbot commented on PR #23105:
URL: https://github.com/apache/flink/pull/23105#issuecomment-1658303732
## CI report:
* ba703284d3eb7e93a6f16f0c58ed720ac1e8b77c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
afedulov opened a new pull request, #23105:
URL: https://github.com/apache/flink/pull/23105
This is a trivial change that marks non-private methods that reference
SourceFunction as @Deprecated.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-32713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-32713:
-
Assignee: Alexander Fedulov
> Cascade deprecation to non-private methods that
[
https://issues.apache.org/jira/browse/FLINK-32715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32715:
-
Assignee: Matthias Pohl
> ProcessFailureCancelingITCase.testCancelingOnProcessFailure
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32678:
--
Description:
-We decided to do another round of testing for the LeaderElection refactoring
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32678:
--
Summary: Stress-Test to cover multiple low-level changes in Flink (was:
Test FLIP-285
flinkbot commented on PR #23104:
URL: https://github.com/apache/flink/pull/23104#issuecomment-1658084855
## CI report:
* 95159c7b1c5e86433e3b421cb440215ceb597d20 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yunfengzhou-hub commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1279088716
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/VertexEndOfDataListener.java:
##
@@ -51,6 +51,12 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-32715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32715:
---
Labels: pull-request-available test-stability (was: test-stability)
>
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-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
[
https://issues.apache.org/jira/browse/FLINK-32715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749119#comment-17749119
]
Matthias Pohl commented on FLINK-32715:
---
I'm lowering the priority again: It looks like a testing
[
https://issues.apache.org/jira/browse/FLINK-32715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32715:
--
Priority: Critical (was: Blocker)
>
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(
lindong28 commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1279012662
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -426,6 +456,39 @@ public boolean isShutdown() {
return
[
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
>
[
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
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(
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-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
[
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-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:
--
Affects Version/s: 1.16.1
(was: kubernetes-operator-1.3.1)
>
[
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:
--
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:
--
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:
--
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
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-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
[
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:
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-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
[
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
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-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
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(
[
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
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
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
[
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:
---
[
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-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-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749070#comment-17749070
]
Matthias Pohl commented on FLINK-32663:
---
[
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:
---
[
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-32515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-32515.
--
Resolution: Fixed
> FLIP-303: Support REPLACE TABLE AS SELECT statement
>
1 - 100 of 115 matches
Mail list logo
