snuyanzin merged PR #33:
URL: https://github.com/apache/flink-connector-mongodb/pull/33
--
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.
snuyanzin commented on PR #33:
URL:
https://github.com/apache/flink-connector-mongodb/pull/33#issuecomment-2055706896
Thanks for taking 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
flinkbot commented on PR #24664:
URL: https://github.com/apache/flink/pull/24664#issuecomment-2055692417
## CI report:
* 8b00ef071cfe932d5b868a496090711345e6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
swathic95 opened a new pull request, #24664:
URL: https://github.com/apache/flink/pull/24664
## What is the purpose of the change
Currently, whenever we have flink failures, we need to manually do the
triaging by looking into the flink logs even for the initial analysis. It wo
snuyanzin opened a new pull request, #33:
URL: https://github.com/apache/flink-connector-mongodb/pull/33
The PR will allow to differentiate between MongoDB connector statistics and
others with name ci
--
This is an automated message from the Apache Git Service.
To respond to t
snuyanzin opened a new pull request, #43:
URL: https://github.com/apache/flink-connector-opensearch/pull/43
The PR will allow to differentiate between Opensearch connector statistics
and others with name ci
--
This is an automated message from the Apache Git Service.
To respond to the
snuyanzin commented on PR #41:
URL:
https://github.com/apache/flink-connector-opensearch/pull/41#issuecomment-2055588592
Closing since it is already 1.26.1 in `pom.xml`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dependabot[bot] commented on PR #41:
URL:
https://github.com/apache/flink-connector-opensearch/pull/41#issuecomment-2055588739
OK, I won't notify you again about this release, but will get in touch when
a new version is available. If you'd rather skip all updates until the next
major or mi
snuyanzin closed pull request #41: Bump org.apache.commons:commons-compress
from 1.23.0 to 1.26.0
URL: https://github.com/apache/flink-connector-opensearch/pull/41
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
[
https://issues.apache.org/jira/browse/FLINK-34158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837086#comment-17837086
]
Sergey Nuyanzin commented on FLINK-34158:
-
Merged as
[f74dc57561a058696bd2bd42
[
https://issues.apache.org/jira/browse/FLINK-34158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-34158.
-
Fix Version/s: 1.20.0
Resolution: Fixed
> Migrate WindowAggregateReduceFunctionsR
[
https://issues.apache.org/jira/browse/FLINK-34158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-34158.
---
> Migrate WindowAggregateReduceFunctionsRule
> --
>
>
snuyanzin merged PR #24140:
URL: https://github.com/apache/flink/pull/24140
--
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-32440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-32440.
Resolution: Resolved
> Introduce file merging configuration
>
[
https://issues.apache.org/jira/browse/FLINK-32440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837085#comment-17837085
]
Yanfei Lei commented on FLINK-32440:
Merged c601c70 into master.
> Introduce file m
fredia merged PR #22973:
URL: https://github.com/apache/flink/pull/22973
--
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
melin commented on PR #2938:
URL: https://github.com/apache/flink-cdc/pull/2938#issuecomment-2055529063
Add key and value to kafka header, example: region = hangzhou
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-35024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837083#comment-17837083
]
Yanfei Lei commented on FLINK-35024:
Merged 6d139a1 into master
> Implement record
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1565225216
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
Exception
[
https://issues.apache.org/jira/browse/FLINK-35024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-35024.
Resolution: Resolved
> Implement record order preservation and buffering of AsyncExecutionControll
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1565180422
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
Exception>
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1565216681
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractInput.java:
##
@@ -35,7 +38,8 @@
* AbstractStreamOperatorV2}.
*/
@Experimenta
lvyanquan commented on code in PR #3215:
URL: https://github.com/apache/flink-cdc/pull/3215#discussion_r1565217554
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java
yuxiqian commented on code in PR #3215:
URL: https://github.com/apache/flink-cdc/pull/3215#discussion_r1565211096
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java:
[
https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837080#comment-17837080
]
Yufan Sheng commented on FLINK-34962:
-
[~Tison] This issue should be marked resolved
fredia merged PR #24633:
URL: https://github.com/apache/flink/pull/24633
--
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-34414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837079#comment-17837079
]
Yufan Sheng commented on FLINK-34414:
-
I don't think this is a issue from my side. F
yuxiqian commented on code in PR #3215:
URL: https://github.com/apache/flink-cdc/pull/3215#discussion_r1565211096
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java:
yuxiqian commented on code in PR #3215:
URL: https://github.com/apache/flink-cdc/pull/3215#discussion_r1565211096
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java:
[
https://issues.apache.org/jira/browse/FLINK-33884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen resolved FLINK-33884.
---
Fix Version/s: pulsar-4.2.0
Resolution: Fixed
Master via
https://github.com/apache/flink-con
tisonkun merged PR #72:
URL: https://github.com/apache/flink-connector-pulsar/pull/72
--
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...
[
https://issues.apache.org/jira/browse/FLINK-34629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen resolved FLINK-34629.
---
Fix Version/s: pulsar-4.2.0
Resolution: Fixed
Master via
https://github.com/apache/flink-con
[
https://issues.apache.org/jira/browse/FLINK-34436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837073#comment-17837073
]
Yufan Sheng commented on FLINK-34436:
-
I think this is not a issue. It's just a desi
boring-cyborg[bot] commented on PR #85:
URL:
https://github.com/apache/flink-connector-pulsar/pull/85#issuecomment-2055403591
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
tisonkun merged PR #85:
URL: https://github.com/apache/flink-connector-pulsar/pull/85
--
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...
Jiabao-Sun commented on code in PR #24612:
URL: https://github.com/apache/flink/pull/24612#discussion_r1565204190
##
flink-core/src/test/java/org/apache/flink/configuration/ConfigurationConversionsTest.java:
##
@@ -52,7 +51,9 @@ public class ConfigurationConversionsTest {
[
https://issues.apache.org/jira/browse/FLINK-35064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837068#comment-17837068
]
Yufan Sheng commented on FLINK-35064:
-
I have made a comment in the related PR. I ju
syhily commented on PR #88:
URL:
https://github.com/apache/flink-connector-pulsar/pull/88#issuecomment-2055283881
The root cause is from pulsar client side with the Jackson shading issues.
Shade a jackson causes a lot of issues. I think we should ask pulsar client not
to shade the jackson.
syhily commented on PR #84:
URL:
https://github.com/apache/flink-connector-pulsar/pull/84#issuecomment-2055266431
I'm in favor of the
https://github.com/apache/flink-connector-pulsar/pull/85, maybe we can continue
the review progress on that PR and close this PR instead. WDT @minchowang ?
syhily commented on PR #72:
URL:
https://github.com/apache/flink-connector-pulsar/pull/72#issuecomment-2055251321
Thanks, there are no issues from my side. @tisonkun Can you help me double
check this PR?
--
This is an automated message from the Apache Git Service.
To respond to the messa
syhily commented on PR #88:
URL:
https://github.com/apache/flink-connector-pulsar/pull/88#issuecomment-2055227659
Sorry, I don't think this PR is accepted, indeed. IIUC, the
`pulsar-client-all` bundle a Jackson internally with a package named
`org.apache.pulsar.shade.com.fasterxml`. The no
hzjhjjyy closed pull request #23254: Allow specifying the ServerSocket port for
the collect function when accessing the TaskManager from the client.
URL: https://github.com/apache/flink/pull/23254
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
lvyanquan commented on code in PR #3215:
URL: https://github.com/apache/flink-cdc/pull/3215#discussion_r1565182494
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java
fredia commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565164680
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
Zakelly commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565167042
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java:
##
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
Zakelly commented on code in PR #24644:
URL: https://github.com/apache/flink/pull/24644#discussion_r1565161944
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -459,13 +470,28 @@ public void notifyCheckpoin
masteryhx commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565160755
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java:
##
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
Zakelly commented on code in PR #24663:
URL: https://github.com/apache/flink/pull/24663#discussion_r1565158902
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java:
##
@@ -104,6 +104,25 @@ default String getName() {
CheckpointableKeyedStateBacken
Zakelly commented on code in PR #22973:
URL: https://github.com/apache/flink/pull/22973#discussion_r1565156390
##
docs/layouts/shortcodes/generated/checkpointing_configuration.html:
##
@@ -44,6 +44,42 @@
String
The default directory used for storing the
1996fanrui commented on code in PR #24612:
URL: https://github.com/apache/flink/pull/24612#discussion_r1565149231
##
flink-core/src/test/java/org/apache/flink/configuration/FilesystemSchemeConfigTest.java:
##
@@ -21,83 +21,79 @@
import org.apache.flink.core.fs.FileSystem;
impo
[
https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34987:
---
Labels: pull-request-available (was: )
> Introduce Internal State Interface for Async State
Zakelly commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565148947
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalKeyedState.java:
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
elon-X commented on PR #88:
URL:
https://github.com/apache/flink-connector-pulsar/pull/88#issuecomment-2054774574
@MartijnVisser @syhily Could you please help approve this PR when you have
some free time? Thank you very much.
--
This is an automated message from the Apache Git Service.
T
yuxiqian commented on PR #3224:
URL: https://github.com/apache/flink-cdc/pull/3224#issuecomment-2054696577
cc @PatrickRen @lvyanquan
--
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 c
[
https://issues.apache.org/jira/browse/FLINK-35102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35102:
---
Labels: pull-request-available (was: )
> Incorret Type mapping for Flink CDC Doris connecto
chenyu-opensource commented on PR #24662:
URL: https://github.com/apache/flink/pull/24662#issuecomment-2054684404
> Thanks for the quick fix, looks good to me.
>
> I just think a hotfix commit should be good enough, would you mind
renaming this to `[hotfix][runtime]x`?
That
Xiqian YU created FLINK-35102:
-
Summary: Incorret Type mapping for Flink CDC Doris connector
Key: FLINK-35102
URL: https://issues.apache.org/jira/browse/FLINK-35102
Project: Flink
Issue Type: Bug
leonardBang merged PR #3208:
URL: https://github.com/apache/flink-cdc/pull/3208
--
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
xleoken commented on PR #3223:
URL: https://github.com/apache/flink-cdc/pull/3223#issuecomment-2054589844
cc @GOODBOY008
--
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
xleoken opened a new pull request, #3223:
URL: https://github.com/apache/flink-cdc/pull/3223
https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/docs/get-started/quickstar
flinkbot commented on PR #24663:
URL: https://github.com/apache/flink/pull/24663#issuecomment-2054586620
## CI report:
* b551d919ce3a63501e9ebc6f8769bd56f0c74d0c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24662:
URL: https://github.com/apache/flink/pull/24662#issuecomment-2054585372
## CI report:
* 0260e42af4748141a97fc036dc42b87623829b36 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837041#comment-17837041
]
Rui Fan commented on FLINK-35040:
-
Thanks [~slfan1989] and [~rmetzger] for the comment!
[
https://issues.apache.org/jira/browse/FLINK-35046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu reassigned FLINK-35046:
Assignee: Hangxiang Yu
> Introduce New KeyedStateBackend related Async interfaces
> -
[
https://issues.apache.org/jira/browse/FLINK-35046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35046:
---
Labels: pull-request-available (was: )
> Introduce New KeyedStateBackend related Async inte
masteryhx opened a new pull request, #24663:
URL: https://github.com/apache/flink/pull/24663
## What is the purpose of the change
Introduce AsyncKeyedStateBackend which supports to create StateExecutor
## Brief change log
- Introduce a new interface called AsyncKe
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837040#comment-17837040
]
chenyu commented on FLINK-35101:
[~Weijie Guo] Thank you so much for your review.
> Mis
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35101:
---
Labels: pull-request-available (was: )
> Missing method parameter annotation for ResourceMa
chenyu-opensource opened a new pull request, #24662:
URL: https://github.com/apache/flink/pull/24662
## What is the purpose of the change
This pull request fixs the problem of missing methed parameter annotation.
## Brief change log
Add the parameter annot
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-35093:
--
Assignee: Hongshun Wang
> Postgres source connector support SPECIFIC_OFFSETS start up mode fr
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837038#comment-17837038
]
Weijie Guo commented on FLINK-35101:
Just feel free to open a hotfix PR.
> Missing
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyu updated FLINK-35101:
---
Component/s: Table SQL / Runtime
> Missing method parameter annotation for ResourceManagerGateway.sendSlotRe
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyu updated FLINK-35101:
---
Fix Version/s: (was: 1.18.0)
> Missing method parameter annotation for ResourceManagerGateway.sendSlotRe
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837036#comment-17837036
]
chenyu commented on FLINK-35101:
Please, assign this issue to me. I can fix it.
> Missi
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyu updated FLINK-35101:
---
Affects Version/s: 1.19.0
1.18.0
> Missing method parameter annotation for ResourceMa
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35101:
---
Affects Version/s: 1.20.0
> Missing method parameter annotation for ResourceManagerGateway.sendSlotR
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-35101.
--
Resolution: Fixed
> Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
> --
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35101:
---
Component/s: Runtime / Coordination
(was: Table SQL / Runtime)
> Missing method
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35101:
---
Fix Version/s: 1.20.0
(was: 1.19.0)
> Missing method parameter annotation for
[
https://issues.apache.org/jira/browse/FLINK-35101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837037#comment-17837037
]
Weijie Guo commented on FLINK-35101:
Yeap, this should be aligned. A hot-fix is good
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837034#comment-17837034
]
Weijie Guo commented on FLINK-34273:
https://dev.azure.com/apache-flink/apache-flink
chenyu created FLINK-35101:
--
Summary: Missing method parameter annotation for
ResourceManagerGateway.sendSlotReport
Key: FLINK-35101
URL: https://issues.apache.org/jira/browse/FLINK-35101
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837035#comment-17837035
]
Weijie Guo commented on FLINK-18476:
1.20 jdk17
https://dev.azure.com/apache-flink/
[
https://issues.apache.org/jira/browse/FLINK-35100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35100:
---
Description:
{code:java}
java.lang.IllegalStateException: Trying to open gateway for unseen checkpo
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837034#comment-17837034
]
Weijie Guo edited comment on FLINK-34273 at 4/15/24 2:15 AM:
-
Weijie Guo created FLINK-35100:
--
Summary: Quickstarts Java nightly end-to-end test failed on Azure
Key: FLINK-35100
URL: https://issues.apache.org/jira/browse/FLINK-35100
Project: Flink
Issue Ty
kumar-mallikarjuna commented on PR #24661:
URL: https://github.com/apache/flink/pull/24661#issuecomment-2054358863
@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
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35093:
--
Description:
Current, Postgres source connector only support INITIAL and LATEST mode.
Howeve
lvyanquan commented on PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#issuecomment-2054304285
Thanks @yuxiqian for those comments, I've addressed it and resubmitted.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
lvyanquan commented on code in PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#discussion_r1565075579
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonCommitter.java:
##
lvyanquan commented on code in PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#discussion_r1565069967
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java:
lvyanquan commented on code in PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#discussion_r1565072387
##
docs/content/pipelines/paimon-pipeline(ZH).md:
##
@@ -0,0 +1,209 @@
+# Paimon Pipeline 连接器
+
+Paimon Pipeline 连接器可以用作 Pipeline 的 *Data
Sink*，将数据写入[Paimon](https
skymilong commented on code in PR #3194:
URL: https://github.com/apache/flink-cdc/pull/3194#discussion_r1565044902
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/MemorySize.java:
##
@@ -0,0 +1,421 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
melin created FLINK-35099:
-
Summary: Support for multiple datasources
Key: FLINK-35099
URL: https://issues.apache.org/jira/browse/FLINK-35099
Project: Flink
Issue Type: New Feature
Componen
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837027#comment-17837027
]
dongwoo.kim edited comment on FLINK-34470 at 4/15/24 1:15 AM:
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837027#comment-17837027
]
dongwoo.kim commented on FLINK-34470:
-
Hello [~m.orazow],
I'm glad that you're int
yuxiqian commented on code in PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#discussion_r1565028345
##
docs/content/pipelines/paimon-pipeline(ZH).md:
##
@@ -0,0 +1,209 @@
+# Paimon Pipeline 连接器
+
+Paimon Pipeline 连接器可以用作 Pipeline 的 *Data
Sink*，将数据写入[Paimon](https:
snuyanzin commented on PR #24658:
URL: https://github.com/apache/flink/pull/24658#issuecomment-2054184159
Yep, you're right probably i was not aware of the context
I was judging only by timestamps
I'm really sorry in case I offended in any way
I would suggest in case you are int
snuyanzin merged PR #42:
URL: https://github.com/apache/flink-connector-opensearch/pull/42
--
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-unsubs
snuyanzin commented on PR #42:
URL:
https://github.com/apache/flink-connector-opensearch/pull/42#issuecomment-2054124759
Thanks for taking 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
1 - 100 of 124 matches
Mail list logo
