[
https://issues.apache.org/jira/browse/FLINK-31188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kelu Tao closed FLINK-31188.
Resolution: Duplicate
> Expose kubernetes scheduler configOption when running flink on kubernetes
>
[
https://issues.apache.org/jira/browse/FLINK-31188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692458#comment-17692458
]
Kelu Tao commented on FLINK-31188:
--
thanks [~wangyang0918] . Close this for duplication.
> Expose
legendtkl commented on PR #20467:
URL: https://github.com/apache/flink/pull/20467#issuecomment-1441155698
Hi, @bzhaoopenstack , what is the status of this PR? Are you still working
on it?
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-31188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692454#comment-17692454
]
Yang Wang commented on FLINK-31188:
---
This might be a duplicate of FLINK-28825.
> Expose kubernetes
[
https://issues.apache.org/jira/browse/FLINK-31182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31182:
--
Description:
This issue is reported from the [user mail
flinkbot commented on PR #22001:
URL: https://github.com/apache/flink/pull/22001#issuecomment-1441151888
## CI report:
* ddfc500d1d2ce5afda09308ebc511676788fcc90 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-31120:
Release Note: (was: master: fa6a2aed6136ae59ed14cd01819e8f94867840b7
release-1.17:
[
https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692453#comment-17692453
]
Caizhi Weng commented on FLINK-31120:
-
master: fa6a2aed6136ae59ed14cd01819e8f94867840b7
[
https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30242:
---
Labels: pull-request-available (was: )
> Push localHashAggregate pass the union node
>
[
https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-31120:
Fix Version/s: 1.17.0
1.16.2
1.18.0
>
Aitozi opened a new pull request, #22001:
URL: https://github.com/apache/flink/pull/22001
…void extra rescale shuffle
## What is the purpose of the change
This PR is meant to add new rule to reduce the extra rescale shuffle. The
basic logic is to transpose the local agg
[
https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-31120.
---
Release Note:
master: fa6a2aed6136ae59ed14cd01819e8f94867840b7
release-1.17:
Kelu Tao created FLINK-31188:
Summary: Expose kubernetes scheduler configOption when running
flink on kubernetes
Key: FLINK-31188
URL: https://issues.apache.org/jira/browse/FLINK-31188
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kelu Tao updated FLINK-31188:
-
Description:
Now when we deploy Flink job on kubernetes, the scheduler is kubernetes
scheduler by
tsreaper merged PR #21961:
URL: https://github.com/apache/flink/pull/21961
--
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-31182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692450#comment-17692450
]
Jane Chan commented on FLINK-31182:
---
[~Sergey Nuyanzin] Yes, the check on the output type inference
[
https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692447#comment-17692447
]
xingyuan cheng edited comment on FLINK-27815 at 2/23/23 2:15 AM:
-
Hello
[
https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692447#comment-17692447
]
xingyuan cheng edited comment on FLINK-27815 at 2/23/23 2:15 AM:
-
Hello
[
https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692447#comment-17692447
]
xingyuan cheng edited comment on FLINK-27815 at 2/23/23 2:12 AM:
-
Hello
[
https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692447#comment-17692447
]
xingyuan cheng commented on FLINK-27815:
Hello [~godfreyhe] , I have two questions about
[
https://issues.apache.org/jira/browse/FLINK-31186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692435#comment-17692435
]
luoyuxia commented on FLINK-31186:
--
cc [~renqs]
> Removing topic from kafka source does nothing
>
hlteoh37 commented on code in PR #22000:
URL: https://github.com/apache/flink/pull/22000#discussion_r1115002217
##
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java:
##
@@
flinkbot commented on PR #22000:
URL: https://github.com/apache/flink/pull/22000#issuecomment-1440840955
## CI report:
* f9cf80bef0d417df2cede4fb4fc741db3b4b6d7e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31183:
---
Labels: pull-request-available (was: )
> Flink Kinesis EFO Consumer can fail to stop
dannycranmer opened a new pull request, #22000:
URL: https://github.com/apache/flink/pull/22000
…to stop gracefully during stop-with-savepoint
## What is the purpose of the change
Update Kinesis EFO consumer to exit gracefully during stop-with-savepoint.
There is an edgecase
[
https://issues.apache.org/jira/browse/FLINK-28655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692362#comment-17692362
]
Alexey Leonov-Vendrovskiy commented on FLINK-28655:
---
a full link of the PR for simpler
[
https://issues.apache.org/jira/browse/FLINK-28361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692360#comment-17692360
]
Alexey Leonov-Vendrovskiy commented on FLINK-28361:
---
What are the PRs that can be
[
https://issues.apache.org/jira/browse/FLINK-31187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31187:
---
Labels: pull-request-available (was: )
> Standalone HA mode does not work if dynamic
mateczagany opened a new pull request, #534:
URL: https://github.com/apache/flink-kubernetes-operator/pull/534
## What is the purpose of the change
Standalone mode with HA enabled will call the JobManager entrypoint with a
`--host` argument, but in case there are any dynamic
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1114915489
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,201 @@
[
https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge closed FLINK-30025.
---
Resolution: Fixed
> Unified the max display column width for SqlClient and Table APi in both
> Streaming
[
https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692350#comment-17692350
]
Jing Ge commented on FLINK-30025:
-
[~Sergey Nuyanzin] Thanks for the hint.
merged into master:
[
https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692346#comment-17692346
]
Sergey Nuyanzin edited comment on FLINK-30025 at 2/22/23 8:00 PM:
--
it
[
https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692346#comment-17692346
]
Sergey Nuyanzin commented on FLINK-30025:
-
it looks like the PR is merged.
Shouldn't be the
[
https://issues.apache.org/jira/browse/FLINK-31182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692344#comment-17692344
]
Sergey Nuyanzin commented on FLINK-31182:
-
it looks this code is present for a long time...
Samrat002 commented on code in PR #21770:
URL: https://github.com/apache/flink/pull/21770#discussion_r1114849025
##
flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java:
##
@@ -324,18 +325,25 @@ private static void addToPythonPath(PythonEnvironment
Samrat002 commented on code in PR #21770:
URL: https://github.com/apache/flink/pull/21770#discussion_r1114841299
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -6,7 +6,7 @@ info:
license:
name: Apache 2.0
url:
Samrat002 commented on code in PR #21770:
URL: https://github.com/apache/flink/pull/21770#discussion_r1114841299
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -6,7 +6,7 @@ info:
license:
name: Apache 2.0
url:
[
https://issues.apache.org/jira/browse/FLINK-31187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-31187:
--
Assignee: Mate Czagany
> Standalone HA mode does not work if dynamic properties are supplied
venkata91 commented on PR #21985:
URL: https://github.com/apache/flink/pull/21985#issuecomment-1440566165
> > The issue here is different and is only specific to `1.16`
>
> So this issue only occurs in 1.16 and not in 1.17 and later? Then we're
good yes :)
There is some what a
Mate Czagany created FLINK-31187:
Summary: Standalone HA mode does not work if dynamic properties
are supplied
Key: FLINK-31187
URL: https://issues.apache.org/jira/browse/FLINK-31187
Project: Flink
akalash commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114678942
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
[
https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692286#comment-17692286
]
Julien Tournay commented on FLINK-31144:
{quote}IMO, It's too hard to decide the threshold for
[
https://issues.apache.org/jira/browse/FLINK-30947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-30947.
---
Fix Version/s: aws-connector-4.1.0
Resolution: Done
> Sync
[
https://issues.apache.org/jira/browse/FLINK-30947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-30947:
-
Assignee: Hong Liang Teoh
> Sync flink-avro-glue-schema-registry and
[
https://issues.apache.org/jira/browse/FLINK-30947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692275#comment-17692275
]
Danny Cranmer commented on FLINK-30947:
---
Merged commit
[
https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692274#comment-17692274
]
Weijie Guo commented on FLINK-31143:
Sure, I will contact [~TsReaper] offline to confirm this.
>
dannycranmer merged PR #54:
URL: https://github.com/apache/flink-connector-aws/pull/54
--
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-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692269#comment-17692269
]
Weijie Guo edited comment on FLINK-31143 at 2/22/23 4:36 PM:
-
[~mapohl]
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692272#comment-17692272
]
Matthias Pohl commented on FLINK-31168:
---
What is odd, though, is the location of the inital cause
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114607304
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
[
https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692271#comment-17692271
]
Matthias Pohl commented on FLINK-31143:
---
I see, can you help me find someone who can verify it?
[
https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692269#comment-17692269
]
Weijie Guo edited comment on FLINK-31143 at 2/22/23 4:32 PM:
-
[~mapohl]
[
https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692269#comment-17692269
]
Weijie Guo commented on FLINK-31143:
[~mapohl] Sorry, what I said before is not very clear. We
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114607304
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692266#comment-17692266
]
Matthias Pohl commented on FLINK-31168:
---
My previous conclusion doesn't hold because the
RocMarshal commented on PR #21999:
URL: https://github.com/apache/flink/pull/21999#issuecomment-1440348971
> The pr title and commit message isn't general. `ProcessWindowFunction` is
just a special case here.
>
> How about this? `Fix the bug that SteamTask skip handle exception
akalash commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114577578
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114510855
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
[
https://issues.apache.org/jira/browse/FLINK-31167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692253#comment-17692253
]
Matthias Pohl edited comment on FLINK-31167 at 2/22/23 3:44 PM:
[
https://issues.apache.org/jira/browse/FLINK-31167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692253#comment-17692253
]
Matthias Pohl commented on FLINK-31167:
---
[~SleePy] thanks for your explanation and the link to
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114532431
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692250#comment-17692250
]
Rui Fan commented on FLINK-29816:
-
Hi [~Weijie Guo] , thanks for your reminder. I have requested them,
Mulavar commented on PR #21545:
URL: https://github.com/apache/flink/pull/21545#issuecomment-1440268275
@lincoln-lil @godfreyhe hello, thanks for u suggestions!
I've added sql cases for this pr, do u have any time to take a look again?
--
This is an automated message from the Apache
hadoopkandy commented on PR #21983:
URL: https://github.com/apache/flink/pull/21983#issuecomment-1440264891
@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
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114503782
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -689,6 +695,7 @@ void restoreInternal() throws Exception {
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114510855
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114508117
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
1996fanrui commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1114505785
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -256,19 +259,27 @@
private final
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114503782
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -689,6 +695,7 @@ void restoreInternal() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-31091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692243#comment-17692243
]
Matthias Pohl commented on FLINK-31091:
---
Yes, if you have to create a backport for release-1.16,
[
https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692241#comment-17692241
]
Matthias Pohl commented on FLINK-31143:
---
Thanks for looking into it, [~Weijie Guo]. I'm not sure I
[
https://issues.apache.org/jira/browse/FLINK-31091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692240#comment-17692240
]
Sergey Nuyanzin commented on FLINK-31091:
-
Thanks for explanation, I think I got your point.
To
1996fanrui commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114484862
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -689,6 +695,7 @@ void restoreInternal() throws Exception {
reswqa commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114482598
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
[
https://issues.apache.org/jira/browse/FLINK-31091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692234#comment-17692234
]
Matthias Pohl commented on FLINK-31091:
---
Thanks for resolving this issue. FYI in terms of
reswqa commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114477282
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -261,6 +261,12 @@
*/
private volatile boolean
[
https://issues.apache.org/jira/browse/FLINK-31091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31091:
--
Fix Version/s: (was: 1.18.0)
> SQL interval related queries stop working via SQL client
>
reswqa commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114467955
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -689,6 +695,7 @@ void restoreInternal() throws Exception {
akalash commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1114460469
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -689,6 +695,7 @@ void restoreInternal() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692232#comment-17692232
]
Lijie Wang commented on FLINK-29859:
[~mapohl] I 'll have a look.
> TPC-DS end-to-end test with
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692227#comment-17692227
]
Weijie Guo edited comment on FLINK-29816 at 2/22/23 2:57 PM:
-
[~fanrui] If
[
https://issues.apache.org/jira/browse/FLINK-30879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692228#comment-17692228
]
Matthias Pohl commented on FLINK-30879:
---
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692227#comment-17692227
]
Weijie Guo commented on FLINK-29816:
[~fanrui] If we prefer to fix it in the first way (that is,
akalash commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1114433452
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -256,19 +259,27 @@
private final
[
https://issues.apache.org/jira/browse/FLINK-31091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-31091.
-
Resolution: Fixed
> SQL interval related queries stop working via SQL client
>
[
https://issues.apache.org/jira/browse/FLINK-31091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31091:
Fix Version/s: 1.17.0
1.18.0
> SQL interval related queries stop
akalash commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1114428581
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -256,19 +259,27 @@
private final
[
https://issues.apache.org/jira/browse/FLINK-31091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1769#comment-1769
]
Sergey Nuyanzin commented on FLINK-31091:
-
Merged into release-1.17 branch:
[
https://issues.apache.org/jira/browse/FLINK-31132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31132.
--
Resolution: Fixed
> compact without setting parallelism does not follow the configured sink
>
1996fanrui commented on PR #21999:
URL: https://github.com/apache/flink/pull/21999#issuecomment-1440165179
Hi @akalash , thanks for your quick feedback.
> how urgent is this PR ?
I think it isn't very urgent.
> Can we wait for merging #21923?(I think it helps you avoid
[
https://issues.apache.org/jira/browse/FLINK-31132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692099#comment-17692099
]
Weijie Guo edited comment on FLINK-31132 at 2/22/23 2:44 PM:
-
master(1.18)
snuyanzin merged PR #21991:
URL: https://github.com/apache/flink/pull/21991
--
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:
gauravmiglanid11 commented on code in PR #533:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/533#discussion_r1114423285
##
flink-kubernetes-operator-autoscaler/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricEvaluatorTest.java:
##
@@
gauravmiglanid11 commented on code in PR #533:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/533#discussion_r1114422824
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@
gauravmiglanid11 commented on code in PR #533:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/533#discussion_r1114422334
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricEvaluator.java:
##
@@
reswqa merged PR #21992:
URL: https://github.com/apache/flink/pull/21992
--
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:
akalash commented on PR #21999:
URL: https://github.com/apache/flink/pull/21999#issuecomment-1440106317
@1996fanrui, how urgent is this PR ? Can we wait for merging #21923?(I think
it helps you avoid a new flag)
--
This is an automated message from the Apache Git Service.
To respond to
1996fanrui commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1114369247
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -256,19 +259,27 @@
private final
mxm commented on code in PR #533:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/533#discussion_r1114357150
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -153,4 +154,12
101 - 200 of 323 matches
Mail list logo
