1996fanrui merged PR #746:
URL: https://github.com/apache/flink-kubernetes-operator/pull/746
--
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
XComp commented on code in PR #23977:
URL: https://github.com/apache/flink/pull/23977#discussion_r1441442856
##
flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java:
##
@@ -127,6 +129,11 @@ private void runHandleJobsWhenNotEnoughSlots(final
Jo
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17802610#comment-17802610
]
xuyang commented on FLINK-33490:
Hi, [~martijnvisser] and [~fsk119] . Thank you for your
[
https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33009:
--
Description: According to [Flink's API compatibility
constraints|https://nightlies.apache.org/
[
https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-33009:
-
Assignee: Wencong Liu
> tools/release/update_japicmp_configuration.sh should only enabl
eskabetxe commented on code in PR #78:
URL:
https://github.com/apache/flink-connector-jdbc/pull/78#discussion_r1441475081
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java:
##
@@ -0,0 +1,190 @@
+/*
+ * Licensed to the Apache Software F
eskabetxe commented on code in PR #78:
URL:
https://github.com/apache/flink-connector-jdbc/pull/78#discussion_r1441475081
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java:
##
@@ -0,0 +1,190 @@
+/*
+ * Licensed to the Apache Software F
RocMarshal commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1441443240
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software
RocMarshal commented on code in PR #78:
URL:
https://github.com/apache/flink-connector-jdbc/pull/78#discussion_r1441484531
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java:
##
@@ -0,0 +1,190 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17802731#comment-17802731
]
Matthias Pohl commented on FLINK-33009:
---
Go ahead. I assigned the issue to you. As
Yang-LI-CS commented on code in PR #743:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/743#discussion_r1441489844
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetrics.java:
##
@@ -216,15 +216,23 @@ private static double getNumReco
WencongLiu opened a new pull request, #24027:
URL: https://github.com/apache/flink/pull/24027
## What is the purpose of the change
*Disable binary compatibility check in master branch and only enable it in
the release branch.*
## Does this pull request potentially affect one of
[
https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33009:
---
Labels: pull-request-available (was: )
> tools/release/update_japicmp_configuration.sh shou
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1441516846
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/transactions/xa/XaTransaction.java:
##
@@ -0,0 +1,295 @@
+package org.apache.
flinkbot commented on PR #24027:
URL: https://github.com/apache/flink/pull/24027#issuecomment-1876766234
## CI report:
* e634566487438269e995514720d36fbc58ad5a2c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
WencongLiu commented on PR #24027:
URL: https://github.com/apache/flink/pull/24027#issuecomment-1876767318
I've tested the modified `update_japicmp_configuration` and it could work
well.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1441520106
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1441520406
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software F
eskabetxe commented on PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-1876772728
@RocMarshal thanks for the review.. the 3 commits are there to allow to
review each semantic separately (I thing its easy), we could squash all in one
after finishing the review
1996fanrui merged PR #743:
URL: https://github.com/apache/flink-kubernetes-operator/pull/743
--
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-33966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17802829#comment-17802829
]
Rui Fan commented on FLINK-33966:
-
Merged to main(1.8.0) via 456fb6e9a816d7f4bebdceb5fca
[
https://issues.apache.org/jira/browse/FLINK-33966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33966.
-
Fix Version/s: kubernetes-operator-1.8.0
Resolution: Fixed
> Fix the getNumRecordsInPerSecond Uti
RocMarshal created FLINK-33988:
--
Summary: Invalid configuration when using initialized root logger
level on yarn application mode
Key: FLINK-33988
URL: https://issues.apache.org/jira/browse/FLINK-33988
P
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33988:
---
Description: from https://issues.apache.org/jira/browse/FLINK-33166
> Invalid configuration when usi
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33988:
---
Assignee: RocMarshal
> Invalid configuration when using initialized root logger level on yarn
> ap
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33988:
---
Description:
from https://issues.apache.org/jira/browse/FLINK-33166
When I set env. log. level=DE
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33988:
---
Description:
from https://issues.apache.org/jira/browse/FLINK-33166
When I set env. log. level=DEBU
[
https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33166:
Fix Version/s: 1.19.0
> Support setting root logger level by config
>
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33988:
Affects Version/s: 1.19.0
(was: 1.18.0)
(was: 1.17.2)
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33988:
Fix Version/s: 1.19.0
> Invalid configuration when using initialized root logger level on yarn
> applicat
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33988:
Priority: Major (was: Minor)
> Invalid configuration when using initialized root logger level on yarn
>
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33988:
---
Description:
relevant https://issues.apache.org/jira/browse/FLINK-33166
When I set env. log. level=
Myasuka merged PR #83:
URL: https://github.com/apache/flink-benchmarks/pull/83
--
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-33977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33977:
--
Component/s: Autoscaler
> Adaptive scheduler may not minimize the number of TMs during downsca
1996fanrui merged PR #747:
URL: https://github.com/apache/flink-kubernetes-operator/pull/747
--
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
Flaviu Cicio created FLINK-33989:
Summary: Insert Statement With Filter Operation Generates Extra
Tombstone in Kafka
Key: FLINK-33989
URL: https://issues.apache.org/jira/browse/FLINK-33989
Project: Fl
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441676954
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -86,9 +88,10 @@ public class CheckpointStatsTracker {
pri
Dan Zou created FLINK-33990:
---
Summary: Use default classloader in TaskManager when there are no
user jars for job
Key: FLINK-33990
URL: https://issues.apache.org/jira/browse/FLINK-33990
Project: Flink
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441683484
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -155,7 +167,12 @@ public CheckpointStatsSnapshot createSnapshot(
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441707237
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -343,6 +376,62 @@ public void reportIncompleteStats(
}
[
https://issues.apache.org/jira/browse/FLINK-33990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li updated FLINK-33990:
---
Description: TaskManager will create a new class loader for each flink job
even when it has no user
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441710885
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -343,6 +376,62 @@ public void reportIncompleteStats(
}
[
https://issues.apache.org/jira/browse/FLINK-33990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-33990:
--
Assignee: Dan Zou
> Use default classloader in TaskManager when there are no user jars for jo
[
https://issues.apache.org/jira/browse/FLINK-33990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-33990:
--
Assignee: Dan Zou (was: Dan Zou)
> Use default classloader in TaskManager when there are no
rkhachatryan commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441711155
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionGraphFactory.java:
##
@@ -159,6 +160,11 @@ public ExecutionGraph createAndRestore
[
https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803150#comment-17803150
]
Zhongqiang Gong commented on FLINK-33970:
-
[~tison] I also want to add this chec
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441711709
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -730,57 +739,87 @@ void restoreInternal() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803156#comment-17803156
]
Benchao Li commented on FLINK-33611:
[~dsaisharath] Thanks for the explanation, it h
XComp commented on code in PR #22984:
URL: https://github.com/apache/flink/pull/22984#discussion_r1441722684
##
flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java:
##
@@ -72,9 +72,23 @@ public static RestartStrategyConfiguration fixedDela
GOODBOY008 commented on PR #88:
URL:
https://github.com/apache/flink-connector-jdbc/pull/88#issuecomment-1877064388
@MartijnVisser Please take a look, Thank you~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Summary: Insert Statement With Filter Operation Generates Extra Tombstone
using Upsert Kafka Con
[
https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803150#comment-17803150
]
Zhongqiang Gong edited comment on FLINK-33970 at 1/4/24 1:13 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Component/s: Connectors / Kafka
> Insert Statement With Filter Operation Generates Extra Tombsto
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Description:
Given the following Flink SQL tables:
{code:sql}
CREATE TABLE input (
id STRING N
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Description:
Given the following Flink SQL tables:
{code:sql}
CREATE TABLE input (
id STRING N
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Description:
Given the following Flink SQL tables:
{code:sql}
CREATE TABLE input (
id STRING N
[
https://issues.apache.org/jira/browse/FLINK-33072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33072:
--
Component/s: Connectors / Kinesis
> Implement end-to-end tests for AWS Kinesis Connectors
> --
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Description:
Given the following Flink SQL tables:
{code:sql}
CREATE TABLE input (
id STRING N
dannycranmer merged PR #121:
URL: https://github.com/apache/flink-connector-aws/pull/121
--
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
Emre Kartoglu created FLINK-33991:
-
Summary: Custom Error Handling for Kinesis Polling Consumer
Key: FLINK-33991
URL: https://issues.apache.org/jira/browse/FLINK-33991
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-33560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803166#comment-17803166
]
Danny Cranmer commented on FLINK-33560:
---
Merged commit
[{{b7f2e26}}|https://githu
[
https://issues.apache.org/jira/browse/FLINK-33560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-33560.
---
Resolution: Fixed
> Externalize Kinesis Python connector code
>
[
https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803167#comment-17803167
]
Emre Kartoglu commented on FLINK-33260:
---
We can resolve this in favour of
https:/
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emre Kartoglu updated FLINK-33991:
--
Fix Version/s: aws-connector-4.3.0
> Custom Error Handling for Kinesis Polling Consumer
> ---
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emre Kartoglu updated FLINK-33991:
--
Description:
We introduced custom error handling for the Kinesis EFO Consumer as part of
http
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emre Kartoglu updated FLINK-33991:
--
Description:
We introduced custom error handling for the Kinesis EFO Consumer as part of
http
[
https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33260:
--
Summary: Custom Error Handling for Kinesis EFO Consumer (was: Custom Error
Handling for Kines
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-33991:
-
Assignee: Emre Kartoglu
> Custom Error Handling for Kinesis Polling Consumer
> ---
[
https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-33260.
---
Resolution: Fixed
> Custom Error Handling for Kinesis EFO Consumer
> ---
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Description:
Given the following Flink SQL tables:
{code:sql}
CREATE TABLE input (
id STRING N
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Description:
Given the following Flink SQL tables:
{code:sql}
CREATE TABLE input (
id STRING N
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Description:
Given the following Flink SQL tables:
{code:sql}
CREATE TABLE input (
id STRING N
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flaviu Cicio updated FLINK-33989:
-
Description:
Given the following Flink SQL tables:
{code:sql}
CREATE TABLE input (
id STRING N
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441782436
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionGraphFactory.java:
##
@@ -159,6 +160,11 @@ public ExecutionGraph createAndRestoreExe
[
https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803176#comment-17803176
]
Piotr Nowojski commented on FLINK-27756:
https://dev.azure.com/apache-flink/apac
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441683484
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -155,7 +167,12 @@ public CheckpointStatsSnapshot createSnapshot(
pnowojski commented on code in PR #24023:
URL: https://github.com/apache/flink/pull/24023#discussion_r1441789636
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackendParametersImpl.java:
##
@@ -0,0 +1,151 @@
+/*
+ * Licensed to the Apache Software Found
pnowojski commented on PR #24023:
URL: https://github.com/apache/flink/pull/24023#issuecomment-1877155133
Thanks for the review!
> Why only add the download metric? While you are at this, you could have
also simply added metrics for, e.g., merge/clip.
That was the scope of the
[
https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803179#comment-17803179
]
Martijn Visser commented on FLINK-33970:
This shouldn't be fixed per connector,
[
https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803181#comment-17803181
]
Martijn Visser commented on FLINK-33970:
Next to this, I believe this only fixes
[
https://issues.apache.org/jira/browse/FLINK-33897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-33897:
---
Issue Type: New Feature (was: Improvement)
> Allow triggering unaligned checkpoint via CLI
[
https://issues.apache.org/jira/browse/FLINK-33897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803185#comment-17803185
]
Piotr Nowojski commented on FLINK-33897:
I have mixed feelings. Shouldn't the so
Sweta Kalakuntla created FLINK-33992:
Summary: Add option to fetch the jar from private repository in
FlinkSessionJob
Key: FLINK-33992
URL: https://issues.apache.org/jira/browse/FLINK-33992
Projec
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803187#comment-17803187
]
Martijn Visser commented on FLINK-33490:
Sounds good to me, thank you!
> Valid
rkhachatryan commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1441837132
##
docs/content/docs/ops/traces.md:
##
@@ -97,7 +97,7 @@ Flink reports a single span trace for the whole checkpoint
once checkpoint reach
- org
[
https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803196#comment-17803196
]
Zhongqiang Gong commented on FLINK-33970:
-
[~martijnvisser] I had tried to use h
nicusX commented on PR #122:
URL:
https://github.com/apache/flink-connector-aws/pull/122#issuecomment-1877217949
@dannycranmer please review this PR when you have the chance
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
nicusX commented on PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#issuecomment-1877219219
@hlteoh37 @dannycranmer please review this PR when you have the chance, so
we can proceed with the other related tasks
--
This is an automated message from the Apache Git S
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803201#comment-17803201
]
Piotr Nowojski commented on FLINK-33856:
Hi, I second that implementing this as
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803201#comment-17803201
]
Piotr Nowojski edited comment on FLINK-33856 at 1/4/24 3:00 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803203#comment-17803203
]
Zhongqiang Gong commented on FLINK-33970:
-
[~martijnvisser] And I checked my pr
XComp commented on code in PR #22984:
URL: https://github.com/apache/flink/pull/22984#discussion_r1441914909
##
flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java:
##
@@ -72,9 +72,23 @@ public static RestartStrategyConfiguration fixedDela
XComp commented on code in PR #22984:
URL: https://github.com/apache/flink/pull/22984#discussion_r1441915244
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -810,7 +811,8 @@ public RestartStrategies.RestartS
XComp commented on code in PR #22984:
URL: https://github.com/apache/flink/pull/22984#discussion_r1441916069
##
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfig.java:
##
@@ -53,13 +54,14 @@ public class StateTtlConfig implements Serializable {
priva
XComp commented on PR #22984:
URL: https://github.com/apache/flink/pull/22984#issuecomment-1877310802
Thanks for picking this up. We should merge FLINK-32570 soon'ish to not miss
it for 1.19.
I reiterated over the PR once more with the following changes:
* I rebased the branch to m
Maximilian Michels created FLINK-33993:
--
Summary: Ineffective scaling detection events are misleading
Key: FLINK-33993
URL: https://issues.apache.org/jira/browse/FLINK-33993
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-33932:
---
Description:
Rocksdb uploader will throw exception and decline the current checkpoint if
th
[
https://issues.apache.org/jira/browse/FLINK-33993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33993:
---
Labels: pull-request-available (was: )
> Ineffective scaling detection events are misleadin
[
https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803237#comment-17803237
]
Piotr Nowojski commented on FLINK-33932:
Yes, I don't think this should cause a
pnowojski commented on code in PR #23986:
URL: https://github.com/apache/flink/pull/23986#discussion_r1441986930
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateUploader.java:
##
@@ -107,13 +122,43 @@ private
1 - 100 of 164 matches
Mail list logo
