yunfengzhou-hub commented on code in PR #23944:
URL: https://github.com/apache/flink/pull/23944#discussion_r1429620891
##
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslationUtil.java:
##
@@ -40,8 +43,16 @@ public static JobGraph getJobGraph(
czchen commented on PR #23935:
URL: https://github.com/apache/flink/pull/23935#issuecomment-1859660606
Shall be https://github.com/apache/flink/pull/23837
--
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
Yangze Guo created FLINK-33870:
--
Summary: Split the HighAvailabilityServices into LeaderServices
and PersistentServices
Key: FLINK-33870
URL: https://issues.apache.org/jira/browse/FLINK-33870
Project:
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-32667:
---
Description:
In OLAP scenarios, we only require the leader election services for the
Dispatcher /
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798026#comment-17798026
]
Dong Lin commented on FLINK-25509:
--
[~ruanhang1993] I think we need to update flink-kafka-connector's
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-32667:
---
Summary: Enable users to independently adjust the high availability
strategies related to jobs
JunRuiLee commented on code in PR #23944:
URL: https://github.com/apache/flink/pull/23944#discussion_r1429569157
##
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslationUtil.java:
##
@@ -40,8 +43,16 @@ public static JobGraph getJobGraph(
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798025#comment-17798025
]
Tongtong Zhu edited comment on FLINK-33588 at 12/18/23 6:52 AM:
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798025#comment-17798025
]
Tongtong Zhu commented on FLINK-33588:
--
[~jingge] I have made the necessary modifications as per
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-32667:
---
Parent: FLINK-33852
Issue Type: Sub-task (was: Improvement)
> Use standalone store and
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-32667:
---
Parent: (was: FLINK-25318)
Issue Type: Improvement (was: Sub-task)
> Use standalone
X-czh commented on code in PR #23447:
URL: https://github.com/apache/flink/pull/23447#discussion_r1429559942
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java:
##
@@ -126,9 +140,14 @@ public synchronized void
yunfengzhou-hub commented on PR #23944:
URL: https://github.com/apache/flink/pull/23944#issuecomment-1859639546
Thanks for the comments @reswqa. I have updated the PR according to the
comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
yunfengzhou-hub commented on PR #23944:
URL: https://github.com/apache/flink/pull/23944#issuecomment-1859639249
@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
yunfengzhou-hub commented on code in PR #23944:
URL: https://github.com/apache/flink/pull/23944#discussion_r1429556103
##
flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java:
##
@@ -153,6 +154,8 @@ public class JobGraphGenerator
liming30 commented on code in PR #23922:
URL: https://github.com/apache/flink/pull/23922#discussion_r1429554092
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java:
##
@@ -359,6 +361,50 @@
reswqa commented on code in PR #23944:
URL: https://github.com/apache/flink/pull/23944#discussion_r1429533482
##
flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java:
##
@@ -153,6 +154,8 @@ public class JobGraphGenerator implements
[
https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798019#comment-17798019
]
zhilinli commented on FLINK-32346:
--
Hi Community gods Can I support this feature? If this feature is
flinkbot commented on PR #23944:
URL: https://github.com/apache/flink/pull/23944#issuecomment-1859594720
## CI report:
* baad6c06ef71afca753ef0c5f8fb2af0a3e8c2ce UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33534:
---
Labels: pull-request-available (was: )
> PipelineOptions.PARALLELISM_OVERRIDES is not
yunfengzhou-hub opened a new pull request, #23944:
URL: https://github.com/apache/flink/pull/23944
## What is the purpose of the change
This pull request supports configuring the PARALLELISM_OVERRIDES
configuration during the job submission process. Before this PR, Flink has
wanglijie95 commented on code in PR #23447:
URL: https://github.com/apache/flink/pull/23447#discussion_r1429465647
##
flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobDetails.java:
##
@@ -355,16 +356,21 @@ public String toString() {
/**
*
JunRuiLee commented on code in PR #23447:
URL: https://github.com/apache/flink/pull/23447#discussion_r1429512642
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java:
##
@@ -126,9 +140,14 @@ public synchronized void
[
https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798003#comment-17798003
]
Rui Fan edited comment on FLINK-33565 at 12/18/23 4:21 AM:
---
Hi [~mapohl], I
[
https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798003#comment-17798003
]
Rui Fan commented on FLINK-33565:
-
Hi [~mapohl], I have finished the POC, and wanna to check whether my
[
https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33565:
Attachment: screenshot-1.png
> The concurrentExceptions doesn't work
>
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798000#comment-17798000
]
Hang Ruan commented on FLINK-25509:
---
Hi, [~martijnvisser] & [~lindong] .
The Flink 1.18 has been
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1429453681
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/AutoScalerUtils.java:
##
@@ -94,4 +99,106 @@ public static boolean
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1429452589
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/AutoScalerUtils.java:
##
@@ -94,4 +99,108 @@ public static boolean
X-czh commented on PR #23447:
URL: https://github.com/apache/flink/pull/23447#issuecomment-1859486000
@wanglijie95 Kindly remind~ Could you help take a look when you have time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Jufang He created FLINK-33868:
-
Summary: Add checkpoint metrics: the latency to write the file
Key: FLINK-33868
URL: https://issues.apache.org/jira/browse/FLINK-33868
Project: Flink
Issue Type:
Jufang He created FLINK-33869:
-
Summary: Add checkpoint metrics: the latency to close the file
Key: FLINK-33869
URL: https://issues.apache.org/jira/browse/FLINK-33869
Project: Flink
Issue Type:
Jufang He created FLINK-33867:
-
Summary: Add checkpoint metrics: the rate of file write
Key: FLINK-33867
URL: https://issues.apache.org/jira/browse/FLINK-33867
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jufang He updated FLINK-33856:
--
Description:
When Flink makes a checkpoint, the interaction performance with the external
file
bs352 commented on code in PR #77:
URL:
https://github.com/apache/flink-connector-jdbc/pull/77#discussion_r1429434411
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcOutputFormat.java:
##
@@ -153,6 +153,16 @@ public void open(int taskNumber,
Myasuka commented on code in PR #83:
URL: https://github.com/apache/flink-benchmarks/pull/83#discussion_r1429398494
##
src/main/java/org/apache/flink/state/benchmark/ttl/TtlListStateBenchmark.java:
##
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
liyubin117 commented on code in PR #23678:
URL: https://github.com/apache/flink/pull/23678#discussion_r1429393701
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenTableSourceFactory.java:
##
@@ -141,15 +143,15 @@ private
flinkbot commented on PR #23943:
URL: https://github.com/apache/flink/pull/23943#issuecomment-1859429375
## CI report:
* ffc32e900cfb448b602f9134d6ea3e247564d722 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuyongvs opened a new pull request, #23943:
URL: https://github.com/apache/flink/pull/23943
## What is the purpose of the change
*Support CharType for the MaxAggFunction.**
## Brief change log
* Support CharType for the MaxAggFunction like MinAggFunction*
[
https://issues.apache.org/jira/browse/FLINK-33719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797988#comment-17797988
]
Jane Chan commented on FLINK-33719:
---
[~jackylau] assigned to you.
> Cleanup the usage of deprecated
[
https://issues.apache.org/jira/browse/FLINK-33719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-33719:
-
Assignee: Jacky Lau
> Cleanup the usage of deprecated StreamTableEnvironment#toRetractStream
>
[
https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797987#comment-17797987
]
Jacky Lau commented on FLINK-32721:
---
hi [~lsy] sorry for late response, i will modify it
> agg
LadyForest commented on code in PR #23678:
URL: https://github.com/apache/flink/pull/23678#discussion_r1429375718
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenTableSourceFactory.java:
##
@@ -141,15 +143,15 @@ private
xuyangzhong commented on code in PR #23827:
URL: https://github.com/apache/flink/pull/23827#discussion_r1429367900
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/JsonObjectAggFunction.java:
##
@@ -128,6 +137,15 @@ public void
Kurt Ostfeld created FLINK-33866:
Summary: KafkaSinkBuilder in flink-connector-kafka references
DeliveryGuarantee in flink-connector-base
Key: FLINK-33866
URL: https://issues.apache.org/jira/browse/FLINK-33866
[
https://issues.apache.org/jira/browse/FLINK-33764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-33764.
--
Resolution: Fixed
merged to main f6adb400e1c87f06faec948379c264eebba71166
> Incorporate GC / Heap
gyfora merged PR #726:
URL: https://github.com/apache/flink-kubernetes-operator/pull/726
--
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:
Zakelly commented on code in PR #83:
URL: https://github.com/apache/flink-benchmarks/pull/83#discussion_r1429208690
##
src/main/java/org/apache/flink/state/benchmark/ttl/TtlListStateBenchmark.java:
##
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Zakelly commented on code in PR #83:
URL: https://github.com/apache/flink-benchmarks/pull/83#discussion_r1429207983
##
src/main/java/org/apache/flink/state/benchmark/ttl/TtlStateBenchmarkBase.java:
##
@@ -0,0 +1,48 @@
+package org.apache.flink.state.benchmark.ttl;
+
+import
reta commented on PR #38:
URL:
https://github.com/apache/flink-connector-opensearch/pull/38#issuecomment-1859212485
> this is what I tried to do and this is how it looks like with this PR
Yep. it looks reasonable
--
This is an automated message from the Apache Git Service.
To
Myasuka commented on code in PR #83:
URL: https://github.com/apache/flink-benchmarks/pull/83#discussion_r1429199281
##
src/main/java/org/apache/flink/state/benchmark/ttl/TtlListStateBenchmark.java:
##
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Myasuka commented on code in PR #23820:
URL: https://github.com/apache/flink/pull/23820#discussion_r1429195464
##
flink-runtime/src/test/java/org/apache/flink/runtime/util/profiler/ProfilingServiceTest.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache Software
Myasuka commented on code in PR #23820:
URL: https://github.com/apache/flink/pull/23820#discussion_r1429195243
##
flink-runtime/src/test/java/org/apache/flink/runtime/util/profiler/ProfilingServiceTest.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33865:
Description:
exponential-delay.attempts-before-reset-backoff doesn't work when it's set in
Job
flinkbot commented on PR #23942:
URL: https://github.com/apache/flink/pull/23942#issuecomment-1859194965
## CI report:
* fce08fa4150978ab8c7ea743ac17cacc6d565d26 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33865:
---
Labels: pull-request-available (was: )
> exponential-delay.attempts-before-reset-backoff
1996fanrui opened a new pull request, #23942:
URL: https://github.com/apache/flink/pull/23942
Draft PR
--
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,
snuyanzin commented on PR #38:
URL:
https://github.com/apache/flink-connector-opensearch/pull/38#issuecomment-1859140916
at least we could build/test with what it is allowed
this is what I tried to do and this is how it looks like with this PR
| Opensearch| jdk8 | jdk11 | jdk17
[
https://issues.apache.org/jira/browse/FLINK-33862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797908#comment-17797908
]
Martijn Visser commented on FLINK-33862:
This isn't a command that you would use to build Flink
Rui Fan created FLINK-33865:
---
Summary: exponential-delay.attempts-before-reset-backoff doesn't
work when it's set in Job Configuration
Key: FLINK-33865
URL: https://issues.apache.org/jira/browse/FLINK-33865
flinkbot commented on PR #23941:
URL: https://github.com/apache/flink/pull/23941#issuecomment-1859082438
## CI report:
* 797c7d77b1b08af37e5e8ac3609cfee16f61cf2a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
shalk opened a new pull request, #23941:
URL: https://github.com/apache/flink/pull/23941
translate content.zh/docs/dev/table/overview.md
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than
62 matches
Mail list logo
