h12567 commented on PR #24750:
URL: https://github.com/apache/flink/pull/24750#issuecomment-2087873976
May I ask how to find the list of issues/requests I can contribute to?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-35217:
---
Fix Version/s: 1.18.2
1.19.1
> Missing fsync in
StefanRRichter merged PR #24752:
URL: https://github.com/apache/flink/pull/24752
--
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:
StefanRRichter merged PR #24751:
URL: https://github.com/apache/flink/pull/24751
--
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:
borislitvak commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1585425522
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeDialectFactory.java:
##
@@ -0,0 +1,37 @@
+/*
borislitvak commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1585423831
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeRowConverter.java:
##
@@ -0,0 +1,45 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-35279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alan Zhang updated FLINK-35279:
---
Description:
The "last-state" upgrade mode is only supported for Flink application mode
today[1],
Alan Zhang created FLINK-35279:
--
Summary: Support "last-state" upgrade mode for FlinkSessionJob
Key: FLINK-35279
URL: https://issues.apache.org/jira/browse/FLINK-35279
Project: Flink
Issue
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585113359
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
[
https://issues.apache.org/jira/browse/FLINK-34645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842430#comment-17842430
]
Ryan Skraba commented on FLINK-34645:
-
1.18 Java 11 / Test (module: misc)
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585036601
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
gyfora commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1585008279
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584990017
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584990017
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584990017
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
trystanj commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1584990017
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15
vinlee19 commented on PR #3286:
URL: https://github.com/apache/flink-cdc/pull/3286#issuecomment-2085539643
@ruanhang1993 @gong PTAL
--
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
Márton Balassi created FLINK-35278:
--
Summary: Occasional NPE on k8s operator status replacement
Key: FLINK-35278
URL: https://issues.apache.org/jira/browse/FLINK-35278
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-35277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35277:
---
Labels: pull-request-available (was: )
> Fix the error in the `asncdcaddremove.sql` script
[
https://issues.apache.org/jira/browse/FLINK-35277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wenli xiao updated FLINK-35277:
---
Description:
1. background
When attempting to use Flink CDC 3.1 in the Flink connector to load
[
https://issues.apache.org/jira/browse/FLINK-35277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wenli xiao updated FLINK-35277:
---
Environment:
Flink 1.18.0
Flink CDC 3.1-pre
DB2 11.5.x
was:
Flink 1.18.0
DB2 11.5.x
[
https://issues.apache.org/jira/browse/FLINK-35277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842404#comment-17842404
]
wenli xiao commented on FLINK-35277:
asncdcaddremove.sql:
[
https://issues.apache.org/jira/browse/FLINK-35277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wenli xiao updated FLINK-35277:
---
Description:
1. background
When attempting to use Flink CDC 3.1 in the Flink connector to load
wenli xiao created FLINK-35277:
--
Summary: Fix the error in the `asncdcaddremove.sql` script for the
DB2 test container.
Key: FLINK-35277
URL: https://issues.apache.org/jira/browse/FLINK-35277
Project:
[
https://issues.apache.org/jira/browse/FLINK-35275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842395#comment-17842395
]
PengFei Li commented on FLINK-35275:
[~twalthr] Could you help confirm if this is a bug? If so, I'd
[
https://issues.apache.org/jira/browse/FLINK-35276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated FLINK-35276:
Attachment: job-logs.txt
> SortCodeGeneratorTest.testMultiKeys fails on negative zero
>
Ryan Skraba created FLINK-35276:
---
Summary: SortCodeGeneratorTest.testMultiKeys fails on negative zero
Key: FLINK-35276
URL: https://issues.apache.org/jira/browse/FLINK-35276
Project: Flink
kottmann commented on PR #22789:
URL: https://github.com/apache/flink/pull/22789#issuecomment-2085392466
@ferenc-csaky Thank you for reviewing my PR and for your helpful feedback! I
really appreciate your support in improving it.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-35275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengFei Li updated FLINK-35275:
---
Description:
In ArrayContainsFunction, elementGetter is used to get elements of an array,
but
PengFei Li created FLINK-35275:
--
Summary: ArrayContainsFunction uses wrong DataType to create
element getter
Key: FLINK-35275
URL: https://issues.apache.org/jira/browse/FLINK-35275
Project: Flink
mbalassi commented on code in PR #819:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/819#discussion_r1584812594
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkDeploymentMetrics.java:
##
@@ -94,6 +101,22 @@ public
flinkbot commented on PR #24752:
URL: https://github.com/apache/flink/pull/24752#issuecomment-2085320637
## CI report:
* 0670f3aec8b7aaa6db1192a8cdead22d9c6b925b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24751:
URL: https://github.com/apache/flink/pull/24751#issuecomment-2085320237
## CI report:
* e5d3c1296ac763d40175720c8fff58716ab1a3b1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mbalassi commented on code in PR #819:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/819#discussion_r1584810870
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkDeploymentMetrics.java:
##
@@ -165,13 +194,21 @@ private
StefanRRichter opened a new pull request, #24751:
URL: https://github.com/apache/flink/pull/24751
Backport of FLINK-35217 for 1.19
(cherry picked from commit 80af4d502318348ba15a8f75a2a622ce9dbdc968)
--
This is an automated message from the Apache Git Service.
To respond to
gaborgsomogyi commented on code in PR #819:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/819#discussion_r1584790463
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkDeploymentMetrics.java:
##
@@ -165,13 +194,21 @@
ThisisWilli commented on PR #2494:
URL: https://github.com/apache/flink-cdc/pull/2494#issuecomment-2085275760
> Hi @ThisisWilli, thanks for your great contribution! Could you please
rebase this PR with latest `master` branch? You may need to rename some
packages like from
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842366#comment-17842366
]
chenyuzhi commented on FLINK-35192:
---
It's probably not that the images aren't broken, but that they're
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842312#comment-17842312
]
chenyuzhi edited comment on FLINK-35192 at 4/30/24 12:44 PM:
-
The op
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842363#comment-17842363
]
Roman Khachatryan commented on FLINK-35217:
---
[~srichter] would you mind backporting the fix to
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584710588
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeRowConverter.java:
##
@@ -0,0 +1,45 @@
+/*
+ *
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584685732
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeDialectFactory.java:
##
@@ -0,0 +1,37 @@
+/*
+
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584710588
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeRowConverter.java:
##
@@ -0,0 +1,45 @@
+/*
+ *
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584685732
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeDialectFactory.java:
##
@@ -0,0 +1,37 @@
+/*
+
davidradl commented on code in PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#discussion_r1584685732
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/snowflake/dialect/SnowflakeDialectFactory.java:
##
@@ -0,0 +1,37 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-35217.
--
Resolution: Fixed
Merged to master in
StefanRRichter merged PR #24722:
URL: https://github.com/apache/flink/pull/24722
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-35217:
---
Fix Version/s: 1.20.0
> Missing fsync in FileSystemCheckpointStorage
>
gong commented on PR #3284:
URL: https://github.com/apache/flink-cdc/pull/3284#issuecomment-2085022086
@PatrickRen PTAL
--
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
gong commented on PR #3283:
URL: https://github.com/apache/flink-cdc/pull/3283#issuecomment-2085021893
@PatrickRen PTAL
--
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
eskabetxe commented on code in PR #116:
URL:
https://github.com/apache/flink-connector-jdbc/pull/116#discussion_r1584601921
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java:
##
@@ -88,32 +92,49 @@ public abstract class
[
https://issues.apache.org/jira/browse/FLINK-35272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35272:
---
Labels: pull-request-available (was: )
> Pipeline Transform job supports omitting /
yuxiqian opened a new pull request, #3285:
URL: https://github.com/apache/flink-cdc/pull/3285
This closes [FLINK-35272](https://issues.apache.org/jira/browse/FLINK-35272).
Currently, pipeline jobs with transform (including projection and filtering)
are constructed with the following
[
https://issues.apache.org/jira/browse/FLINK-35274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35274:
---
Labels: pull-request-available (was: )
> Occasional failure issue with Flink CDC Db2 UT
>
[
https://issues.apache.org/jira/browse/FLINK-35274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Gong updated FLINK-35274:
-
Fix Version/s: 3.1.0
> Occasional failure issue with Flink CDC Db2 UT
>
Xin Gong created FLINK-35274:
Summary: Occasional failure issue with Flink CDC Db2 UT
Key: FLINK-35274
URL: https://issues.apache.org/jira/browse/FLINK-35274
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-33761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33761:
---
Labels: pull-request-available (was: )
> Snowflake as JDBC source
>
boring-cyborg[bot] commented on PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#issuecomment-2084941773
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
[
https://issues.apache.org/jira/browse/FLINK-35273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-35273:
--
Description:
The issue is from
https://apache-flink.slack.com/archives/C065944F9M2/p1714134880878399
fredia commented on code in PR #24698:
URL: https://github.com/apache/flink/pull/24698#discussion_r1584530942
##
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/StateFuture.java:
##
@@ -49,7 +49,7 @@ public interface StateFuture {
* @param action the
[
https://issues.apache.org/jira/browse/FLINK-35273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-35273:
--
Component/s: API / Python
> PyFlink's LocalZonedTimestampType should respect timezone set by
>
Biao Geng created FLINK-35273:
-
Summary: PyFlink's LocalZonedTimestampType should respect timezone
set by set_local_timezone
Key: FLINK-35273
URL: https://issues.apache.org/jira/browse/FLINK-35273
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842322#comment-17842322
]
Biao Geng commented on FLINK-35192:
---
[~stupid_pig], it looks like that pictures of the pmap is broken.
fredia commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r1584477969
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to
jectpro7 commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1584465123
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -74,15 +76,20 @@
kottmann commented on PR #22789:
URL: https://github.com/apache/flink/pull/22789#issuecomment-2084837876
This is fixed now as well, see new commit.
--
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
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584453635
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584453151
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584451630
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584445284
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
ljz2051 commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r158208
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStValueState.java:
##
@@ -95,4 +100,32 @@ public V
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1584443822
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842312#comment-17842312
]
chenyuzhi edited comment on FLINK-35192 at 4/30/24 9:26 AM:
The op image
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842312#comment-17842312
]
chenyuzhi edited comment on FLINK-35192 at 4/30/24 9:24 AM:
The op image
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842312#comment-17842312
]
chenyuzhi edited comment on FLINK-35192 at 4/30/24 9:19 AM:
The op image
ljz2051 commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r1584431128
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842312#comment-17842312
]
chenyuzhi edited comment on FLINK-35192 at 4/30/24 9:17 AM:
The op image
ljz2051 commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r1584427802
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java:
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842312#comment-17842312
]
chenyuzhi commented on FLINK-35192:
---
The op image we use is to modify the basic image of the
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-35192:
--
Attachment: image-2024-04-30-17-11-24-974.png
> operator oom
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-34902.
Resolution: Fixed
Fixed in master: 8a75f8f22b8e08e45f1a6453b87718eab6db115a
> INSERT INTO column
twalthr merged PR #24724:
URL: https://github.com/apache/flink/pull/24724
--
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:
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584382431
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-35192:
--
Attachment: image-2024-04-30-16-47-07-289.png
> operator oom
>
>
> Key:
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584375937
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842294#comment-17842294
]
Biao Geng commented on FLINK-35192:
---
Sure, created a
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584364578
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java:
##
@@ -830,6 +832,8 @@ public CompletableFuture submitTask(
[
https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842295#comment-17842295
]
Wei Yuan commented on FLINK-35212:
--
Hi Biao Geng, as you say, maybe the exception which I submitted
flinkbot commented on PR #24750:
URL: https://github.com/apache/flink/pull/24750#issuecomment-2084709081
## CI report:
* 9970141f26ce36804d528727728eb23648a1201f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1584361582
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -575,8 +576,51 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-35195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35195:
---
Labels: pull-request-available (was: )
> Support the execution of create materialized
lsyldliu opened a new pull request, #24750:
URL: https://github.com/apache/flink/pull/24750
## What is the purpose of the change
*Support the execution of create materialized table in continuous refresh
mode*
## Brief change log
- *Support the execution of create
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842292#comment-17842292
]
Ryan Skraba commented on FLINK-35041:
-
1.20 test_ci_core
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35192:
---
Labels: pull-request-available (was: )
> operator oom
>
>
>
bgeng777 opened a new pull request, #822:
URL: https://github.com/apache/flink-kubernetes-operator/pull/822
## What is the purpose of the change
According to
[FLINK-35192](https://issues.apache.org/jira/browse/FLINK-35192), the usage of
file.deleteOnExit() will register a
[
https://issues.apache.org/jira/browse/FLINK-34071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842275#comment-17842275
]
Aleksandr Pilipenko commented on FLINK-34071:
-
[~chalixar] for exception classification I
1 - 100 of 108 matches
Mail list logo
