[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823479#comment-17823479
]
Matthias Pohl commented on FLINK-31472:
---
*
https://github.com/apache/flink/action
[
https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823478#comment-17823478
]
Matthias Pohl commented on FLINK-29114:
---
*
https://github.com/apache/flink/action
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823477#comment-17823477
]
Matthias Pohl commented on FLINK-18476:
---
https://github.com/apache/flink/actions/r
[
https://issues.apache.org/jira/browse/FLINK-34557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823473#comment-17823473
]
Matthias Pohl commented on FLINK-34557:
---
hi [~tltheshy], thanks for sharing your o
[
https://issues.apache.org/jira/browse/FLINK-34576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-34576:
--
Description:
The HA mode of flink-kubernetes-operator is being used. When one of the pods of
flink-ku
chenyuzhi created FLINK-34576:
-
Summary: Flink deployment keep staying at RECONCILING/STABLE status
Key: FLINK-34576
URL: https://issues.apache.org/jira/browse/FLINK-34576
Project: Flink
Issue Ty
libenchao commented on code in PR #24430:
URL: https://github.com/apache/flink/pull/24430#discussion_r1512231078
##
docs/content.zh/docs/connectors/table/formats/maxwell.md:
##
@@ -251,6 +251,13 @@ Format Options
Boolean
Encode all decimals as plain numbers instead
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-34566:
--
Assignee: Fei Feng
> Flink Kubernetes Operator reconciliation parallelism setting not work
>
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823457#comment-17823457
]
Gyula Fora commented on FLINK-34566:
Thanks [~Fei Feng] !
> Flink Kubernetes Operat
lincoln-lil commented on code in PR #721:
URL: https://github.com/apache/flink-web/pull/721#discussion_r1512211263
##
docs/content/posts/2024-03-xx-release-1.19.0.md:
##
@@ -0,0 +1,466 @@
+---
+authors:
+- LincolnLee:
+ name: "Lincoln Lee"
+ twitter: lincoln_86xy
+
+date: "202
[
https://issues.apache.org/jira/browse/FLINK-32497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823451#comment-17823451
]
Han Zhuo commented on FLINK-32497:
--
Thanks, I have closed this issue.
> IF FUNCTION is
[
https://issues.apache.org/jira/browse/FLINK-32497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Han Zhuo resolved FLINK-32497.
--
Fix Version/s: 1.17.2
1.16.3
Resolution: Fixed
> IF FUNCTION is FALSE and th
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823445#comment-17823445
]
Fei Feng commented on FLINK-34566:
--
Of course, yes. Please assign this ticket for me ,
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-34508:
-
Assignee: Muhammet Orazov
> Migrate S3-related ITCases and e2e tests to Minio
> --
[
https://issues.apache.org/jira/browse/FLINK-34427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823444#comment-17823444
]
Matthias Pohl commented on FLINK-34427:
---
https://dev.azure.com/apache-flink/apache
lincoln-lil opened a new pull request, #721:
URL: https://github.com/apache/flink-web/pull/721
Add announcement blog post for Flink 1.19
--
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 specif
[
https://issues.apache.org/jira/browse/FLINK-34186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34186:
--
Assignee: Qingsheng Ren
> Migrate issue management from Github to JIRA
>
[
https://issues.apache.org/jira/browse/FLINK-34180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34180:
---
Fix Version/s: cdc-3.1.0
> Accept Flink CDC project as part of Apache Flink
> --
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823433#comment-17823433
]
Gyula Fora edited comment on FLINK-34566 at 3/5/24 6:02 AM:
[
https://issues.apache.org/jira/browse/FLINK-34187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-34187.
Resolution: Resolved
Resolved in flink cdc (master): f7fa3175809b4b912b19ad91c89599bf1c2b9ea3
> S
[
https://issues.apache.org/jira/browse/FLINK-34187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34187:
---
Component/s: Flink CDC
> Setup CI for Flink CDC project
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-34187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34187:
---
Fix Version/s: cdc-3.1.0
> Setup CI for Flink CDC project
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823433#comment-17823433
]
Gyula Fora commented on FLINK-34566:
Thanks for the detailed explanation, I missed t
flinkbot commented on PR #24434:
URL: https://github.com/apache/flink/pull/24434#issuecomment-1977960778
## CI report:
* 2402077397fe6410c262e673e7c24aa417f37c06 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mynkyu opened a new pull request, #24434:
URL: https://github.com/apache/flink/pull/24434
## What is the purpose of the change
- Comment typo fix PR
## Brief change log
ASIS: `THe parallelism for this operator.`
TOBE: `The parallelism for this operator.`
## Veri
mynkyu closed pull request #24433: [hotfix] [docs] Flink comment typo in
pyflink datastream
URL: https://github.com/apache/flink/pull/24433
--
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 specif
mynkyu opened a new pull request, #24433:
URL: https://github.com/apache/flink/pull/24433
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them on
[
https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823408#comment-17823408
]
Benchao Li commented on FLINK-16627:
[~nilerzhou] Thanks for the PR, I'll try to giv
LadyForest commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1512103738
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/utils/PathUtils.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-34536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823407#comment-17823407
]
Benchao Li edited comment on FLINK-34536 at 3/5/24 3:56 AM:
[
https://issues.apache.org/jira/browse/FLINK-34536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li closed FLINK-34536.
--
Resolution: Not A Problem
I'm closing this due the discussions above, feel free to reopen it if anyone
[
https://issues.apache.org/jira/browse/FLINK-34530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823406#comment-17823406
]
lincoln lee commented on FLINK-34530:
-
The release package check should be updated,
[
https://issues.apache.org/jira/browse/FLINK-34187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34187:
---
Labels: pull-request-available (was: )
> Setup CI for Flink CDC project
> -
LadyForest commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1512083846
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/table/utils/PathUtilsTest.java:
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the A
Zakelly commented on PR #24374:
URL: https://github.com/apache/flink/pull/24374#issuecomment-1977882012
@spoon-lz Sorry for the late reply, seems we come to an agreement in
discussion. To be brief, we agree to deprecate the old class and introduce a
new one. Corresponding APIs will be chang
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823396#comment-17823396
]
Fei Feng edited comment on FLINK-34566 at 3/5/24 2:51 AM:
--
Than
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fei Feng reopened FLINK-34566:
--
> Flink Kubernetes Operator reconciliation parallelism setting not work
>
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823396#comment-17823396
]
Fei Feng commented on FLINK-34566:
--
Thanks [~gyfora] for comment this issue.
Firstly,
LadyForest commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1512043134
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/utils/PathUtils.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apach
RocMarshal closed pull request #24407: [FLINK-34522][core] Changing the Time to
Duration for StateTtlConfig.Builder.cleanupInRocksdbCompactFilter
URL: https://github.com/apache/flink/pull/24407
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
MartijnVisser commented on code in PR #42:
URL:
https://github.com/apache/flink-connector-hbase/pull/42#discussion_r1511745875
##
flink-connector-hbase-e2e-tests/pom.xml:
##
@@ -192,14 +192,6 @@ under the License.
MartijnVisser commented on code in PR #42:
URL:
https://github.com/apache/flink-connector-hbase/pull/42#discussion_r1511744415
##
flink-connector-hbase-e2e-tests/pom.xml:
##
@@ -192,14 +192,6 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-34575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823322#comment-17823322
]
Martijn Visser commented on FLINK-34575:
Thanks for filing the ticket, I've chan
[
https://issues.apache.org/jira/browse/FLINK-34575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34575:
---
Issue Type: Technical Debt (was: Bug)
> Vulnerabilities in commons-compress 1.24.0; upgrade
[
https://issues.apache.org/jira/browse/FLINK-33992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823316#comment-17823316
]
Ahmed Soliman commented on FLINK-33992:
---
[~gyfora]
> For session job submissions
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511610976
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the A
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511611341
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/ObjectContainer.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Softwa
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511610976
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the A
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511610616
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/ObjectContainer.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Softwa
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511584785
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -1516,4 +1517,141 @@ private Stream
[
https://issues.apache.org/jira/browse/FLINK-34532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-34532:
---
Assignee: lincoln lee
> Stage source and binary releases on dist.apache.org
> -
[
https://issues.apache.org/jira/browse/FLINK-34531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-34531:
---
Assignee: lincoln lee
> Build and stage Java and Python artifacts
> ---
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511453416
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the A
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511453416
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the A
XComp commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1511414346
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/utils/PathUtils.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Sof
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511439120
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823242#comment-17823242
]
Lorenzo Affetti commented on FLINK-20392:
-
{quote}I'm not able to follow what yo
LadyForest commented on PR #24390:
URL: https://github.com/apache/flink/pull/24390#issuecomment-1976845985
Hi @XComp, would you mind taking a look when you're available?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Adrian Vasiliu created FLINK-34575:
--
Summary: Vulnerabilities in commons-compress 1.24.0; upgrade to
1.26.0 needed.
Key: FLINK-34575
URL: https://issues.apache.org/jira/browse/FLINK-34575
Project: Fl
mxm commented on code in PR #786:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/786#discussion_r1511334711
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java:
##
@@ -148,8 +149,11 @@ public static ConfigChanges tuneTaskManager
mxm commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1511292849
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/EvaluatedMetrics.java:
##
@@ -30,6 +31,7 @@
@NoArgsConstructor
@AllArgsConstructor
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34566.
--
Resolution: Not A Problem
I am closing this ticket for now, if you feel that this resolution is incorr
mxm commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1511294060
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/topology/JobTopology.java:
##
@@ -97,10 +109,6 @@ public boolean isSource(JobVertexID jobVert
gyfora commented on code in PR #786:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/786#discussion_r1511285884
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java:
##
@@ -148,8 +149,11 @@ public static ConfigChanges tuneTaskMana
echauchot commented on PR #26:
URL:
https://github.com/apache/flink-connector-cassandra/pull/26#issuecomment-1976742586
> @echauchot Sorry to ping you out of the blue, I saw that you were an
active contributor to the Cassandra connector. If you have some time, would you
mind reviewing this
ferenc-csaky commented on PR #42:
URL:
https://github.com/apache/flink-connector-hbase/pull/42#issuecomment-1976709968
@Tan-JiaLiang if you have some time can you PTAL?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
XComp commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1511250389
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SNAP
ferenc-csaky commented on code in PR #22789:
URL: https://github.com/apache/flink/pull/22789#discussion_r1511222835
##
flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/HadoopFreeTests.java:
##
Review Comment:
Use AssertJ's `assertThatThrownBy
[
https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823201#comment-17823201
]
Matthias Pohl commented on FLINK-29114:
---
*
https://github.com/apache/flink/action
gaborgsomogyi opened a new pull request, #789:
URL: https://github.com/apache/flink-kubernetes-operator/pull/789
## What is the purpose of the change
Flink can report slot sharing group information in the vertex information.
This can be used to fine tune the autoscaler algorithm to de
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823193#comment-17823193
]
Matthias Pohl commented on FLINK-20392:
---
The goal is to move away from bash-based
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823188#comment-17823188
]
Lorenzo Affetti commented on FLINK-20392:
-
[~mapohl] [~jark]
In order to bette
libenchao merged PR #24431:
URL: https://github.com/apache/flink/pull/24431
--
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-34574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-34574:
-
Assignee: Gabor Somogyi
> Add CPU and memory size autoscaler quota
> --
Gabor Somogyi created FLINK-34574:
-
Summary: Add CPU and memory size autoscaler quota
Key: FLINK-34574
URL: https://issues.apache.org/jira/browse/FLINK-34574
Project: Flink
Issue Type: New Fe
[
https://issues.apache.org/jira/browse/FLINK-34573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LSZ updated FLINK-34573:
Description:
we havae a flink job , jst one taskmanger;
when use high presure as soure data,it will be stuck. som
[
https://issues.apache.org/jira/browse/FLINK-34573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LSZ updated FLINK-34573:
Attachment: rate.PNG
> the task is stuck on the high presure
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-32497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823172#comment-17823172
]
david radley commented on FLINK-32497:
--
I notice this is a critical issue. But from
mxm merged PR #788:
URL: https://github.com/apache/flink-kubernetes-operator/pull/788
--
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...
LSZ created FLINK-34573:
---
Summary: the task is stuck on the high presure
Key: FLINK-34573
URL: https://issues.apache.org/jira/browse/FLINK-34573
Project: Flink
Issue Type: Bug
Components: Run
[
https://issues.apache.org/jira/browse/FLINK-33992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823169#comment-17823169
]
Gyula Fora commented on FLINK-33992:
It would be great if Flink itself would have a
[
https://issues.apache.org/jira/browse/FLINK-33992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823168#comment-17823168
]
Gyula Fora commented on FLINK-33992:
For session job submissions the jar generally h
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823165#comment-17823165
]
Gyula Fora commented on FLINK-34566:
{noformat}
A ThreadPoolExecutor will automatica
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823166#comment-17823166
]
Gyula Fora commented on FLINK-34566:
>From the java docs:
"A ThreadPoolExecutor wil
[ https://issues.apache.org/jira/browse/FLINK-34566 ]
Gyula Fora deleted comment on FLINK-34566:
was (Author: gyfora):
{noformat}
A ThreadPoolExecutor will automatically adjust the pool size (see getPoolSize)
according to the bounds set by core
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823164#comment-17823164
]
Gyula Fora commented on FLINK-34566:
Even if the core pool size is 10, the maxpoolsi
dawidwys commented on code in PR #24219:
URL: https://github.com/apache/flink/pull/24219#discussion_r1511101924
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java:
##
@@ -0,0 +1,129 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823163#comment-17823163
]
Gyula Fora commented on FLINK-34566:
Looking at this in detail I think it should wor
[
https://issues.apache.org/jira/browse/FLINK-34352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-34352.
--
Fix Version/s: 1.20.0
Resolution: Fixed
merged e168cd4d into master.
> Improve the doc
X-czh commented on PR #23626:
URL: https://github.com/apache/flink/pull/23626#issuecomment-1976492211
@FangYongs Thanks for the PR. The changes LGTM except for a nit on the UT.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
masteryhx closed pull request #24396: [FLINK-34352][doc] Improve the
documentation of allowNonRestoredState
URL: https://github.com/apache/flink/pull/24396
--
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
[
https://issues.apache.org/jira/browse/FLINK-33992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823159#comment-17823159
]
Ahmed Soliman commented on FLINK-33992:
---
Hello [~skala]
I have some thoughts her
X-czh commented on code in PR #23626:
URL: https://github.com/apache/flink/pull/23626#discussion_r1511095895
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/lineage/DefaultLineageGraphTest.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Fo
caicancai commented on code in PR #788:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/788#discussion_r1511081946
##
docs/content/docs/custom-resource/overview.md:
##
@@ -85,7 +85,7 @@ The spec contains all the information the operator need to
deploy and manage
FangYongs commented on PR #23626:
URL: https://github.com/apache/flink/pull/23626#issuecomment-1976458731
@HuangZhenQiu @mobuchowski I have add dataset and facet interfaces in
lineage vertex, please help to review this PR cc @X-czh
--
This is an automated message from the Apache Git Serv
FangYongs commented on PR #23626:
URL: https://github.com/apache/flink/pull/23626#issuecomment-1976455987
Thanks @JingGe , please help to review this PR again
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ferenc-csaky commented on PR #26:
URL:
https://github.com/apache/flink-connector-cassandra/pull/26#issuecomment-1976453914
@echauchot Sorry to ping you out of the blue, I saw that you were an active
contributor to the Cassandra connector. If you have some time, would you mind
reviewing thi
[
https://issues.apache.org/jira/browse/FLINK-34536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823143#comment-17823143
]
yisha zhou commented on FLINK-34536:
[~libenchao] Thanks for your insight, it helps
[
https://issues.apache.org/jira/browse/FLINK-32075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-32075.
--
Fix Version/s: 1.20.0
(was: 1.19.0)
Resolution: Fixed
merged cd9
masteryhx closed pull request #24181: [FLINK-32075][FLIP-306][Checkpoint]
Delete merged files on checkpoint abort or subsumption
URL: https://github.com/apache/flink/pull/24181
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
1 - 100 of 146 matches
Mail list logo
