flinkbot commented on PR #23921:
URL: https://github.com/apache/flink/pull/23921#issuecomment-1853773306
## CI report:
* 073a0461b43cc665ecf9c3874273054d59cc2257 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jiabao-Sun commented on code in PR #23914:
URL: https://github.com/apache/flink/pull/23914#discussion_r1425242859
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/utils/StreamAbstractTestBase.java:
##
@@ -22,10 +22,14 @@
import
1996fanrui commented on code in PR #726:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/726#discussion_r1425233692
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/RestApiMetricsCollector.java:
##
@@ -78,19 +99,89 @@ protected Map
[
https://issues.apache.org/jira/browse/FLINK-33687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33687:
---
Labels: pull-request-available (was: )
> Reuse RestClusterClient in
Jiabao-Sun commented on PR #23914:
URL: https://github.com/apache/flink/pull/23914#issuecomment-1853767448
Hi @snuyanzin, I think the `SnapshotDirectory.cleanup` may not be the root
cause.
I debugged it locally, and the directory structure cleared by
SnapshotDirectory is start with
xiangyuf opened a new pull request, #23921:
URL: https://github.com/apache/flink/pull/23921
## What is the purpose of the change
Reuse RestClusterClient in StandaloneClusterDescriptor to avoid frequent
thread create/destroy.
## Brief change log
- Reuse
1996fanrui commented on code in PR #726:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/726#discussion_r1425233692
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/RestApiMetricsCollector.java:
##
@@ -78,19 +99,89 @@ protected Map
[
https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796167#comment-17796167
]
David Artiga commented on FLINK-6755:
-
This is awesome :D
> Allow triggering Checkpoints through
MartijnVisser commented on PR #23489:
URL: https://github.com/apache/flink/pull/23489#issuecomment-1853706439
@singhravidutt Can I get your thoughts on
https://github.com/apache/flink/pull/23920 as an alternative solution?
--
This is an automated message from the Apache Git Service.
To
MartijnVisser commented on code in PR #23489:
URL: https://github.com/apache/flink/pull/23489#discussion_r1425195367
##
flink-filesystems/flink-gs-fs-hadoop/pom.xml:
##
@@ -204,20 +251,13 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-33312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796133#comment-17796133
]
Sergey Nuyanzin commented on FLINK-33312:
-
No more new occurrences for almost 2 months
For that
[
https://issues.apache.org/jira/browse/FLINK-33312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33312.
---
Resolution: Cannot Reproduce
>
leonardBang opened a new pull request, #703:
URL: https://github.com/apache/flink-web/pull/703
Add Pulsar connector v4.1.0 release
--
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-33804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796131#comment-17796131
]
Martijn Visser commented on FLINK-33804:
[~qqibrow] What is your proposal for the long term
1996fanrui commented on code in PR #731:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/731#discussion_r1425174343
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/DateTimeUtils.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software
singhravidutt commented on code in PR #23489:
URL: https://github.com/apache/flink/pull/23489#discussion_r1425171966
##
flink-filesystems/flink-gs-fs-hadoop/pom.xml:
##
@@ -188,6 +212,29 @@ under the License.
shade
gyfora commented on code in PR #730:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/730#discussion_r1425170026
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -375,9 +376,24 @@ private int
mxm commented on code in PR #731:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/731#discussion_r1425158303
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/DateTimeUtils.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software
mxm commented on code in PR #730:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/730#discussion_r1425156114
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -375,9 +376,24 @@ private int
mxm commented on code in PR #730:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/730#discussion_r1425156114
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -375,9 +376,24 @@ private int
Matthias Pohl created FLINK-33816:
-
Summary:
SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain failed due async
checkpoint triggering not being completed
Key: FLINK-33816
URL:
[
https://issues.apache.org/jira/browse/FLINK-33815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33815:
---
Labels: pull-request-available (was: )
> Add tests against jdk17 for pulsar connector
>
snuyanzin opened a new pull request, #71:
URL: https://github.com/apache/flink-connector-pulsar/pull/71
## Purpose of the change
1.18.x supports
## Brief change log
gha
## Verifying this change
This change is a trivial rework
##
Sergey Nuyanzin created FLINK-33815:
---
Summary: Add tests against jdk17 for pulsar connector
Key: FLINK-33815
URL: https://issues.apache.org/jira/browse/FLINK-33815
Project: Flink
Issue
flinkbot commented on PR #23920:
URL: https://github.com/apache/flink/pull/23920#issuecomment-1853622776
## CI report:
* 2ebe7f6e090690486c1954099a2b57283c578192 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
MartijnVisser opened a new pull request, #23920:
URL: https://github.com/apache/flink/pull/23920
## What is the purpose of the change
* Resolve FLINK-33793 `java.lang.NoSuchMethodError when checkpointing in
Google Cloud Storage`
## Brief change log
* Make sure that
snuyanzin commented on PR #23914:
URL: https://github.com/apache/flink/pull/23914#issuecomment-1853578934
> That would mean that we should wait for the snapshot cleanup to finish
before calling @AfterEach-annotated methods, wouldn't it?
ideally yes
--
This is an automated message
gyfora commented on PR #726:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/726#issuecomment-1853576202
> I worry a bit about the implications of enabling this feature by default
(also see [#726
Jiabao-Sun commented on PR #23914:
URL: https://github.com/apache/flink/pull/23914#issuecomment-1853575930
Thanks @snuyanzin @XComp, I'll try to fix it.
--
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
XComp commented on PR #23914:
URL: https://github.com/apache/flink/pull/23914#issuecomment-1853573483
Thanks for this finding, @snuyanzin . That would mean that we should wait
for the snapshot cleanup to finish before calling `@AfterEach`-annotated
methods, wouldn't it?
--
This is an
gyfora commented on code in PR #726:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/726#discussion_r1425082293
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetric.java:
##
@@ -65,15 +69,35 @@ public enum ScalingMetric {
JingGe commented on PR #23915:
URL: https://github.com/apache/flink/pull/23915#issuecomment-1853555679
Thanks @zhutong6688 for driving it. Could you squash the commits?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
snuyanzin commented on PR #23914:
URL: https://github.com/apache/flink/pull/23914#issuecomment-1853554316
@Jiabao-Sun , @XComp
it seems I found the reason
junit5.10.1 makes it always failing and it is becoming a bit more clear
there are 2 threads
1. junit5 trying to
JingGe merged PR #23859:
URL: https://github.com/apache/flink/pull/23859
--
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:
JingGe commented on PR #23859:
URL: https://github.com/apache/flink/pull/23859#issuecomment-1853547424
Thanks @PatrickRen for the review!
--
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
XComp commented on PR #23914:
URL: https://github.com/apache/flink/pull/23914#issuecomment-1853544386
> The var tempFolder: Path = _ defines in scala is an object field already,
for each @Test method, it is different.
Thanks for clarification. My lack of Scala knowledge made me mix
schulzp commented on PR #83:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/83#issuecomment-1853540370
@reswqa, there are two things that need to be fixed:
1. use `MetricsGroupTestUtils#mockWriterMetricGroup()` instead of
`InternalSinkWriterMetricGroup.mock()`,
[
https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-31752:
-
Fix Version/s: 1.17.1
> SourceOperatorStreamTask increments numRecordsOut twice
>
[
https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-31752:
-
Fix Version/s: 1.18.0
> SourceOperatorStreamTask increments numRecordsOut twice
>
[
https://issues.apache.org/jira/browse/FLINK-33801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796082#comment-17796082
]
Gyula Fora commented on FLINK-33801:
This is basically similar to the rollback feature in the
[
https://issues.apache.org/jira/browse/FLINK-33508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796058#comment-17796058
]
Anika Kelhanka commented on FLINK-33508:
Approach to update Flink's History Server logic to
boring-cyborg[bot] commented on PR #74:
URL:
https://github.com/apache/flink-connector-kafka/pull/74#issuecomment-1853442445
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
Rui Fan created FLINK-33814:
---
Summary: Autoscaler Standalone control loop supports multiple
thread
Key: FLINK-33814
URL: https://issues.apache.org/jira/browse/FLINK-33814
Project: Flink
Issue
101 - 143 of 143 matches
Mail list logo
