ljw-hit commented on code in PR #23162:
URL: https://github.com/apache/flink/pull/23162#discussion_r1390343343
##
flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/BigPbRowToProtoTest.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Fo
Gyula Fora created FLINK-33526:
--
Summary: Improve default autoscaler configs
Key: FLINK-33526
URL: https://issues.apache.org/jira/browse/FLINK-33526
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-33527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33527:
Summary: Clear all physical states after autoscaler is disabled (was:
Clear all pysical states after auto
Rui Fan created FLINK-33527:
---
Summary: Clear all pysical states after autoscaler is disabled
Key: FLINK-33527
URL: https://issues.apache.org/jira/browse/FLINK-33527
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-33527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33527:
Description:
Currently, we just clear ParallelismOverrides after autoscaler is disabled.
We should clear
1996fanrui opened a new pull request, #707:
URL: https://github.com/apache/flink-kubernetes-operator/pull/707
## What is the purpose of the change
Currently, we just clear ParallelismOverrides after autoscaler is disabled.
We should clear CollectedMetrics and ScalingHistory as
[
https://issues.apache.org/jira/browse/FLINK-33527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33527:
---
Labels: pull-request-available (was: )
> Clear all physical states after autoscaler is disa
snuyanzin commented on PR #23664:
URL: https://github.com/apache/flink/pull/23664#issuecomment-1807143508
Thanks for taking a look
--
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 com
snuyanzin merged PR #23664:
URL: https://github.com/apache/flink/pull/23664
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apa
[
https://issues.apache.org/jira/browse/FLINK-33526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33526:
---
Labels: pull-request-available (was: )
> Improve default autoscaler configs
> -
gyfora opened a new pull request, #708:
URL: https://github.com/apache/flink-kubernetes-operator/pull/708
## What is the purpose of the change
There are a few config defaults that should be improved based on prod usage:
- Metric window : 10 -> 15m
- Catch up duration: 15 -> 30m
1996fanrui commented on code in PR #708:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/708#discussion_r1390425243
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -190,7 +189,8 @@ void registerSessionJobCo
Márton Balassi created FLINK-33528:
--
Summary: Externalize Python connector code
Key: FLINK-33528
URL: https://issues.apache.org/jira/browse/FLINK-33528
Project: Flink
Issue Type: Technical D
mbalassi merged PR #23555:
URL: https://github.com/apache/flink/pull/23555
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-25857.
--
Fix Version/s: 1.19.0
Resolution: Implemented
[{{c3a07f9}}|https://github.com/apache/fl
snuyanzin merged PR #23516:
URL: https://github.com/apache/flink/pull/23516
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apa
[
https://issues.apache.org/jira/browse/FLINK-33213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33213.
---
Resolution: Fixed
> Flink SQL MinMax aggregations without retract messages when `where` cond
[
https://issues.apache.org/jira/browse/FLINK-33213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785297#comment-17785297
]
Sergey Nuyanzin edited comment on FLINK-33213 at 11/12/23 5:08 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-33213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785297#comment-17785297
]
Sergey Nuyanzin commented on FLINK-33213:
-
Merged as
[29e49482a82e8c1cd404e42c3
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785298#comment-17785298
]
Sergey Nuyanzin commented on FLINK-1:
-
Merged to flink main repo as
[c488ad
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-1:
Fix Version/s: 1.19.0
> Upgrade netty to 4.1.93+
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-1.
-
Resolution: Fixed
> Upgrade netty to 4.1.93+
>
>
>
gyfora commented on code in PR #708:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/708#discussion_r1390449190
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java:
##
@@ -190,7 +189,8 @@ void registerSessionJobContro
Prabhu Joseph created FLINK-33529:
-
Summary: PyFlink fails with "No module named 'cloudpickle"
Key: FLINK-33529
URL: https://issues.apache.org/jira/browse/FLINK-33529
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-33529:
--
Description:
PyFlink fails with "No module named 'cloudpickle" on Flink 1.18. The same
progra
[
https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-33529:
--
Attachment: flink1.17-get_site_packages.py
flink1.18-get_site_packages.py
> Py
[
https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-33529:
--
Attachment: batch_wc.py
> PyFlink fails with "No module named 'cloudpickle"
>
gyfora commented on code in PR #707:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/707#discussion_r1390470139
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java:
##
@@ -115,10 +123,39 @@ public void cleanup(KEY jobKey) {
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785321#comment-17785321
]
Sergey Nuyanzin commented on FLINK-33365:
-
looks like the issue is incomplete im
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785321#comment-17785321
]
Sergey Nuyanzin edited comment on FLINK-33365 at 11/12/23 9:36 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785321#comment-17785321
]
Sergey Nuyanzin edited comment on FLINK-33365 at 11/12/23 9:49 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785321#comment-17785321
]
Sergey Nuyanzin edited comment on FLINK-33365 at 11/12/23 9:57 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785321#comment-17785321
]
Sergey Nuyanzin edited comment on FLINK-33365 at 11/12/23 10:18 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785321#comment-17785321
]
Sergey Nuyanzin edited comment on FLINK-33365 at 11/12/23 10:20 PM:
--
snuyanzin commented on PR #68:
URL:
https://github.com/apache/flink-connector-kafka/pull/68#issuecomment-1807265659
@MartijnVisser do you happen to know what should be done to make title
validation passing?
it seems it satisfies the regexp now, however it didn't with the first
commit of
Talat Uyarer created FLINK-33530:
Summary: Add entropy to Google Cloud Storage path for better
scalability
Key: FLINK-33530
URL: https://issues.apache.org/jira/browse/FLINK-33530
Project: Flink
waywtdcc commented on PR #74:
URL:
https://github.com/apache/flink-connector-jdbc/pull/74#issuecomment-1807313296
> > Because sometimes you need to use ?characterEncoding=utf8 similar url
parameters to connect to jdbc
>
> But why not just pass these in to the base URL?
The rea
waywtdcc commented on PR #74:
URL:
https://github.com/apache/flink-connector-jdbc/pull/74#issuecomment-1807313452
> > Because sometimes you need to use ?characterEncoding=utf8 similar url
parameters to connect to jdbc
>
> But why not just pass these in to the base URL?
The rea
waywtdcc closed pull request #74: [FLINK-33069]Mysql and Postgres catalog
support url extra parameters
URL: https://github.com/apache/flink-connector-jdbc/pull/74
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
waywtdcc opened a new pull request, #74:
URL: https://github.com/apache/flink-connector-jdbc/pull/74
Mysql and Postgres catalog support url extra parameters
CREATE CATALOG mymysql WITH(
'type' = 'jdbc',
'default-database' = 'test',
'username' = 'root',
'password' = 'xxx',
Sergey Nuyanzin created FLINK-33531:
---
Summary: Nightly Python fails with NPE at metadataHandlerProvider
on AZP
Key: FLINK-33531
URL: https://issues.apache.org/jira/browse/FLINK-33531
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33531:
Description:
It seems starting 02.11.2023 every master nightly fails with this (that's why
snuyanzin commented on PR #126:
URL: https://github.com/apache/flink-shaded/pull/126#issuecomment-1807326279
resolved conflicts
--
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 commen
snuyanzin merged PR #126:
URL: https://github.com/apache/flink-shaded/pull/126
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.
[
https://issues.apache.org/jira/browse/FLINK-33340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33340:
Fix Version/s: shaded-18.0
> Bump Jackson to 2.15.3
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-33340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785346#comment-17785346
]
Sergey Nuyanzin commented on FLINK-33340:
-
Merged to flink-shaded master as
[/9
[
https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785347#comment-17785347
]
CaoZhen commented on FLINK-33397:
-
hi [~qingyue], [~xuyangzhong], can I participate in t
ngannt1710 commented on PR #49:
URL:
https://github.com/apache/flink-connector-kafka/pull/49#issuecomment-1807353419
I use FlinkKafkaConsumer with two consumer(2 nodes) and two partitions. But
the two consumers receive the same message regardless of which partitions it is
pushed to.
--
[
https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuyang updated FLINK-32380:
---
Attachment: image-2023-11-13-10-19-06-035.png
> Support Java records
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785353#comment-17785353
]
xuyang commented on FLINK-32380:
Hi, [~gyfora] Sorry for this noise. When I rebased mast
[
https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785353#comment-17785353
]
xuyang edited comment on FLINK-32380 at 11/13/23 2:21 AM:
--
Hi,
Yangze Guo created FLINK-33532:
--
Summary: Move the serialization of ShuffleDescriptorGroup out of
the RPC main thread
Key: FLINK-33532
URL: https://issues.apache.org/jira/browse/FLINK-33532
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-33532:
---
Description: Currently, the serilization of ShuffleDescriptorGroup would
happen in the RPC main thre
[
https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-33532:
--
Assignee: dizhou cao (was: Yangze Guo)
> Move the serialization of ShuffleDescriptorGroup ou
[
https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-33532:
---
Description: Currently, the serilization of ShuffleDescriptorGroup would
happen in the RPC main thre
xuyangzhong commented on code in PR #23620:
URL: https://github.com/apache/flink/pull/23620#discussion_r1390569239
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/alias/ClearJoinHintsWithInvalidPropagationShuttle.java:
##
@@ -48,19 +49,10 @@
* T
ljw-hit commented on code in PR #23162:
URL: https://github.com/apache/flink/pull/23162#discussion_r1390343616
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbConstant.java:
##
@@ -27,4 +27,10 @@ public class PbConstant {
public static fina
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785355#comment-17785355
]
Benchao Li commented on FLINK-33365:
[~Sergey Nuyanzin] Thanks for the digging. It's
1996fanrui commented on code in PR #707:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/707#discussion_r1390585356
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java:
##
@@ -115,10 +123,39 @@ public void cleanup(KEY jobKey) {
1996fanrui commented on code in PR #707:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/707#discussion_r1390586714
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java:
##
@@ -115,10 +123,39 @@ public void cleanup(KEY jobKey) {
1996fanrui merged PR #708:
URL: https://github.com/apache/flink-kubernetes-operator/pull/708
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsu
[
https://issues.apache.org/jira/browse/FLINK-33526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785357#comment-17785357
]
Rui Fan commented on FLINK-33526:
-
Merged to master<1.7.0> via : cbcc6b67c98ddfad8bd6141
[
https://issues.apache.org/jira/browse/FLINK-33526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33526.
-
Resolution: Fixed
> Improve default autoscaler configs
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-33526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33526:
Fix Version/s: kubernetes-operator-1.7.0
> Improve default autoscaler configs
> --
WencongLiu commented on code in PR #23666:
URL: https://github.com/apache/flink/pull/23666#discussion_r1390574350
##
docs/content.zh/docs/dev/datastream/dataset_migration.md:
##
@@ -134,10 +131,9 @@ DataStreamSource<> source =
StreamExecutionEnvironment.createInput(inputFormat)
ljw-hit commented on PR #23162:
URL: https://github.com/apache/flink/pull/23162#issuecomment-1807421613
@libenchao Thank you very much for your code review. I learned a lot from
this review and I have solved all the comments. Please review again in your
free time.
--
This is an automate
leoyy0316 commented on PR #23656:
URL: https://github.com/apache/flink/pull/23656#issuecomment-1807423595
> > I have a question, why we always follow hive and spark? if we thinks is
a feature need to support, we can implement it firstly. i think having rich
functions is better
>
> Be
gyfora commented on code in PR #707:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/707#discussion_r1390598097
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java:
##
@@ -115,10 +123,39 @@ public void cleanup(KEY jobKey) {
gyfora merged PR #707:
URL: https://github.com/apache/flink-kubernetes-operator/pull/707
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-33527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-33527.
--
Resolution: Fixed
merged to main bf5bb94bc87295e5ecb8ace8f579a22dca440e2d
> Clear all physical states
libenchao commented on code in PR #23162:
URL: https://github.com/apache/flink/pull/23162#discussion_r1390600656
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize/RowToProtoConverter.java:
##
@@ -84,11 +85,18 @@ public RowToProtoConverter(
Benchao Li created FLINK-33533:
--
Summary: Add documentation about performance for huge ProtoBuf
definations
Key: FLINK-33533
URL: https://issues.apache.org/jira/browse/FLINK-33533
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785361#comment-17785361
]
Gyula Fora commented on FLINK-32380:
Technically speaking we exclude these using the
ljw-hit commented on PR #23162:
URL: https://github.com/apache/flink/pull/23162#issuecomment-1807478539
@libenchao Thank you for your detailed review work. I have solved these
comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
[
https://issues.apache.org/jira/browse/FLINK-33533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li updated FLINK-33533:
---
Description:
This is brought up in the discussion of FLINK-32650. For huge ProtoBuf
definations, th
[
https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785365#comment-17785365
]
Benchao Li commented on FLINK-32650:
I've created another ticket to add the document
[
https://issues.apache.org/jira/browse/FLINK-33533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li updated FLINK-33533:
---
Issue Type: Improvement (was: Bug)
> Add documentation about performance for huge ProtoBuf definati
Gyula Fora created FLINK-33534:
--
Summary: PipelineOptions.PARALLELISM_OVERRIDES is not picked up
from jar submission request
Key: FLINK-33534
URL: https://issues.apache.org/jira/browse/FLINK-33534
Projec
[
https://issues.apache.org/jira/browse/FLINK-33534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-33534:
---
Issue Type: Bug (was: Improvement)
> PipelineOptions.PARALLELISM_OVERRIDES is not picked up from ja
[
https://issues.apache.org/jira/browse/FLINK-33534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785367#comment-17785367
]
Gyula Fora commented on FLINK-33534:
cc [~mxm] [~fanrui]
> PipelineOptions.PARALLE
X-czh commented on PR #23698:
URL: https://github.com/apache/flink/pull/23698#issuecomment-1807522914
@huwh Could you help take a review when you are free? Many thanks~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
liyubin117 commented on code in PR #23666:
URL: https://github.com/apache/flink/pull/23666#discussion_r1390667818
##
docs/content.zh/docs/dev/datastream/dataset_migration.md:
##
@@ -62,44 +58,45 @@ The first step of migrating an application from DataSet API
to DataStream API is
KarmaGYZ commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1390593913
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/SlotSharingGroup.java:
##
@@ -76,6 +76,6 @@ public ResourceProfile getResourceProfile() {
Myasuka opened a new pull request, #696:
URL: https://github.com/apache/flink-web/pull/696
Add the content of release 1.17.2 .
--
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
liyubin117 commented on code in PR #23666:
URL: https://github.com/apache/flink/pull/23666#discussion_r1390673821
##
docs/content.zh/docs/dev/datastream/dataset_migration.md:
##
@@ -134,10 +131,9 @@ DataStreamSource<> source =
StreamExecutionEnvironment.createInput(inputFormat)
liyubin117 commented on code in PR #23666:
URL: https://github.com/apache/flink/pull/23666#discussion_r1390674299
##
docs/content.zh/docs/dev/datastream/dataset_migration.md:
##
@@ -679,19 +673,19 @@ dataStream3.join(dataStream4)
-### Category 4
+### 第四类
-The behavio
reswqa opened a new pull request, #697:
URL: https://github.com/apache/flink-web/pull/697
(no comment)
--
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-mai
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1390238967
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerConfiguration.java:
##
@@ -295,6 +294,19 @@ public static SlotManagerC
1996fanrui commented on PR #23635:
URL: https://github.com/apache/flink/pull/23635#issuecomment-1807589290
Hi @KarmaGYZ , thanks for your hard review!
> I think this PR contains two components. First would be a supplement of
[FLINK-33448](https://issues.apache.org/jira/browse/FLINK-33
[
https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785394#comment-17785394
]
Yuan Mei commented on FLINK-26490:
--
Sorry to respond late. Just saw this ticket recentl
[
https://issues.apache.org/jira/browse/FLINK-32380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785396#comment-17785396
]
xuyang commented on FLINK-32380:
[~gyfora] Thanks for your quick reply! I'll try it.
>
91 matches
Mail list logo
