JunRuiLee commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1805761682
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/forwardgroup/StreamNodeForwardGroup.java:
##
@@ -0,0 +1,177 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36559:
--
Description: (was: Duplicate with 36052.)
> [docs]Add flink cdc elasticsearch pipeline sink to doc
[
https://issues.apache.org/jira/browse/FLINK-36052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890794#comment-17890794
]
JunboWang edited comment on FLINK-36052 at 10/18/24 5:49 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-36541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890800#comment-17890800
]
LvYanquan commented on FLINK-36541:
---
I would like to try to fix it.
> Occasional met
[
https://issues.apache.org/jira/browse/FLINK-36052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890794#comment-17890794
]
JunboWang commented on FLINK-36052:
---
Could we add Component/s as FLINK-CDC?
> add ela
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36559:
--
Description: Duplicate with 36052.
> [docs]Add flink cdc elasticsearch pipeline sink to docs
> ---
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang closed FLINK-36559.
-
Resolution: Duplicate
Duplicate with FLINK-36052.
> [docs]Add flink cdc elasticsearch pipeline sink to
liting liu created FLINK-36567:
--
Summary: Planner module didn't use the setting from flink-conf.yaml
Key: FLINK-36567
URL: https://issues.apache.org/jira/browse/FLINK-36567
Project: Flink
Issue
yuxiqian commented on PR #3651:
URL: https://github.com/apache/flink-cdc/pull/3651#issuecomment-2421296255
Could @melin please take a look?
--
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 spe
[
https://issues.apache.org/jira/browse/FLINK-36565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36565:
---
Labels: pull-request-available (was: )
> Pipeline YAML should allow merging decimal with di
yuxiqian opened a new pull request, #3651:
URL: https://github.com/apache/flink-cdc/pull/3651
This closes FLINK-36565.
Currently, table-merging router does not allow coercing `Decimal` fields
with different precisions from upstream, which means some lossless conversions
are actually
LvYanquan created FLINK-36566:
-
Summary: Code optimization: always identify DataChangeEvent before
SchemaChangeEvent in Operator
Key: FLINK-36566
URL: https://issues.apache.org/jira/browse/FLINK-36566
Pro
Zakelly commented on code in PR #25501:
URL: https://github.com/apache/flink/pull/25501#discussion_r1805798857
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java:
##
@@ -220,7 +220,7 @@ public void initializeState(StreamTaskStat
1996fanrui commented on PR #25218:
URL: https://github.com/apache/flink/pull/25218#issuecomment-2421167238
Hey @XComp @ztison , sorry, I'd like to discuss with you again about this PR.
Could we fix the issue for `DefaultSlotAssigner` and `Application Mode`
first? I prefer to fix it fi
Zakelly commented on PR #25479:
URL: https://github.com/apache/flink/pull/25479#issuecomment-2421167188
Will merge this without CI green
--
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 s
liangyu-1 commented on PR #25516:
URL: https://github.com/apache/flink/pull/25516#issuecomment-2421163090
@dmvk @fapaul
Hi, would you please help me check this issue?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
ruanhang1993 closed pull request #102: [FLINK-35109] Drop support for Flink
1.17 & 1.18 and fix tests for 1.20-SNAPSHOT
URL: https://github.com/apache/flink-connector-kafka/pull/102
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
yuxiqian commented on PR #3636:
URL: https://github.com/apache/flink-cdc/pull/3636#issuecomment-2421159128
Squashed & rebased with `master`. Could @ruanhang1993 please take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/FLINK-36562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890773#comment-17890773
]
LvYanquan commented on FLINK-36562:
---
Closed as this is duplicated with FLINK-36564
>
[
https://issues.apache.org/jira/browse/FLINK-36562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan closed FLINK-36562.
-
Release Note: Duplicated with FLINK-36564.
Resolution: Duplicate
> Running CI in random timezone
[
https://issues.apache.org/jira/browse/FLINK-36563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan closed FLINK-36563.
-
Resolution: Duplicate
> Running CI in random timezone to expose more time related bugs
> -
[
https://issues.apache.org/jira/browse/FLINK-36563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890772#comment-17890772
]
LvYanquan commented on FLINK-36563:
---
Closed as this is duplicated with FLINK-36564.
>
yux created FLINK-36565:
---
Summary: Pipeline YAML should allow merging decimal with different
precisions
Key: FLINK-36565
URL: https://issues.apache.org/jira/browse/FLINK-36565
Project: Flink
Issue Typ
Zakelly commented on code in PR #25509:
URL: https://github.com/apache/flink/pull/25509#discussion_r1805752878
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/CompressibleFSDataInputStream.java:
##
@@ -31,19 +31,21 @@ public class CompressibleFSDataInputStream exte
lvyanquan commented on PR #3650:
URL: https://github.com/apache/flink-cdc/pull/3650#issuecomment-2421138664
@yuxiqian 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.
[
https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36564:
---
Labels: pull-request-available (was: )
> Running CI in random timezone to expose more time
LvYanquan created FLINK-36564:
-
Summary: Running CI in random timezone to expose more time
related bugs
Key: FLINK-36564
URL: https://issues.apache.org/jira/browse/FLINK-36564
Project: Flink
Is
LvYanquan created FLINK-36563:
-
Summary: Running CI in random timezone to expose more time
related bugs
Key: FLINK-36563
URL: https://issues.apache.org/jira/browse/FLINK-36563
Project: Flink
I
LvYanquan created FLINK-36562:
-
Summary: Running CI in random timezone to expose more time
related bugs
Key: FLINK-36562
URL: https://issues.apache.org/jira/browse/FLINK-36562
Project: Flink
I
mateczagany commented on PR #25509:
URL: https://github.com/apache/flink/pull/25509#issuecomment-2420140089
> Are you saying that the exact same state data with default S3 Hadoop
configs is slow uncompressed and fast compressed? That would be better case.
Yes, that's correct, I did no
[
https://issues.apache.org/jira/browse/FLINK-36561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ilya Soin updated FLINK-36561:
--
Language: (was: jav)
> ResultSet.wasNull() does not reflect null values in Flink JDBC Driver
> -
Ilya Soin created FLINK-36561:
-
Summary: ResultSet.wasNull() does not reflect null values in Flink
JDBC Driver
Key: FLINK-36561
URL: https://issues.apache.org/jira/browse/FLINK-36561
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890500#comment-17890500
]
Piotr Nowojski commented on FLINK-36356:
https://dev.azure.com/apache-flink/apac
pnowojski commented on PR #25539:
URL: https://github.com/apache/flink/pull/25539#issuecomment-2419944369
@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 comment.
AHeise merged PR #757:
URL: https://github.com/apache/flink-web/pull/757
--
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.apache
ferenc-csaky commented on PR #25494:
URL: https://github.com/apache/flink/pull/25494#issuecomment-2419808148
@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 comme
ferenc-csaky commented on code in PR #25494:
URL: https://github.com/apache/flink/pull/25494#discussion_r1804959664
##
flink-rpc/flink-rpc-akka/pom.xml:
##
@@ -94,8 +94,8 @@ under the License.
io.netty
-
gaborgsomogyi commented on PR #25509:
URL: https://github.com/apache/flink/pull/25509#issuecomment-2419716967
> Could you reproduce this issue with state compression enabled?
I've slightly touched compressed state and yeah, seen either slowness and/or
huge amount of re-opens.
The
gaborgsomogyi commented on code in PR #25509:
URL: https://github.com/apache/flink/pull/25509#discussion_r1804812888
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/CompressibleFSDataInputStream.java:
##
@@ -31,19 +31,21 @@ public class CompressibleFSDataInputStrea
Zakelly commented on code in PR #25509:
URL: https://github.com/apache/flink/pull/25509#discussion_r1804708194
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/CompressibleFSDataInputStream.java:
##
@@ -31,19 +31,21 @@ public class CompressibleFSDataInputStream exte
lvyanquan commented on PR #3613:
URL: https://github.com/apache/flink-cdc/pull/3613#issuecomment-2419385239
According to feedback from community users, cherrypicking this pr has indeed
solved the problem.
--
This is an automated message from the Apache Git Service.
To respond to the messa
Zakelly commented on code in PR #25515:
URL: https://github.com/apache/flink/pull/25515#discussion_r1804486595
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/AbstractAggregatingState.java:
##
@@ -59,7 +59,7 @@ public AbstractAggregatingState(
}
prot
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36559:
---
Labels: pull-request-available (was: )
> [docs]Add flink cdc elasticsearch pipeline sink to
lvyanquan commented on code in PR #3639:
URL: https://github.com/apache/flink-cdc/pull/3639#discussion_r1804467910
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java:
#
lvyanquan commented on code in PR #3639:
URL: https://github.com/apache/flink-cdc/pull/3639#discussion_r1804454752
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java:
#
Zakelly commented on code in PR #25501:
URL: https://github.com/apache/flink/pull/25501#discussion_r1804441714
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java:
##
@@ -111,6 +112,7 @@ interface Provider extends Serializable
[
https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890390#comment-17890390
]
Yanfei Lei commented on FLINK-35031:
Merged into master via ecb41150dab63c0c12b8dc3c
[
https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-35031.
Assignee: Yanfei Lei
Resolution: Resolved
> Latency marker emitting under async execution mo
lvyanquan commented on PR #3648:
URL: https://github.com/apache/flink-cdc/pull/3648#issuecomment-2419036919
@beryllw @yuxiqian @ruanhang1993 could you please help to review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-36560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36560:
---
Labels: pull-request-available (was: )
> Fix the issue of timestamp_ltz increasing by 8 hou
fredia merged PR #25503:
URL: https://github.com/apache/flink/pull/25503
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-36560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890385#comment-17890385
]
LvYanquan commented on FLINK-36560:
---
I've found the issue in code, and willing to fix
LvYanquan created FLINK-36560:
-
Summary: Fix the issue of timestamp_ltz increasing by 8 hours in
Paimon
Key: FLINK-36560
URL: https://issues.apache.org/jira/browse/FLINK-36560
Project: Flink
Iss
pnowojski commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1804401532
##
flink-metrics/flink-metrics-otel/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
pnowojski commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1804401155
##
flink-metrics/flink-metrics-otel/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
dawidwys merged PR #25536:
URL: https://github.com/apache/flink/pull/25536
--
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.apac
huyuanfeng2018 commented on PR #904:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/904#issuecomment-2418982398
> I'm lacking context for the change so my comments could be missing the
mark but I think that means I represent a lot of people trying to consume the
proposed con
mateczagany commented on PR #25509:
URL: https://github.com/apache/flink/pull/25509#issuecomment-2418969804
I have reproduced this issue easily, but I could not reproduce it if
snapshot compression is turned on.
IIUC when using snapshot compression, `SnappyFramedInputStream#available
davidradl commented on code in PR #25540:
URL: https://github.com/apache/flink/pull/25540#discussion_r1804348228
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Table.java:
##
@@ -161,27 +147,6 @@ TemporalTableFunction createTemporalTableFunction(
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-4602:
---
Parent: (was: FLINK-3957)
Issue Type: Technical Debt (was: Sub-task)
> Move RocksDB back
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-4602:
--
Assignee: Han Yin
> Move RocksDB backend to proper package
> -
SamBarker commented on code in PR #904:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/904#discussion_r1804328631
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -416,21 +416,31 @@ protected static > int scale(
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36559:
--
Summary: [docs]Add flink cdc elasticsearch pipeline sink to docs (was:
[docs]Add elasticsearch sink t
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36559:
--
Component/s: Flink CDC
(was: Documentation)
> [docs]Add elasticsearch sink to doc
JunboWang created FLINK-36559:
-
Summary: [docs]Add elasticsearch sink to docs
Key: FLINK-36559
URL: https://issues.apache.org/jira/browse/FLINK-36559
Project: Flink
Issue Type: Improvement
dawidwys commented on PR #25536:
URL: https://github.com/apache/flink/pull/25536#issuecomment-2418841891
@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 comment.
SamBarker commented on code in PR #25494:
URL: https://github.com/apache/flink/pull/25494#discussion_r1804065549
##
flink-rpc/flink-rpc-akka/pom.xml:
##
@@ -94,8 +94,8 @@ under the License.
io.netty
-
[
https://issues.apache.org/jira/browse/FLINK-36527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36527:
---
Labels: pull-request-available (was: )
> Introduce a parameter to support the autoscaler to
huyuanfeng2018 opened a new pull request, #904:
URL: https://github.com/apache/flink-kubernetes-operator/pull/904
## What is the purpose of the change
Introduce a parameter to support autoscaler adopt a more radical strategy
when source vertex or upstream shuffle is keyBy
#
69 matches
Mail list logo
