whhe commented on code in PR #3439:
URL: https://github.com/apache/flink-cdc/pull/3439#discussion_r1718046695
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/testutils/UniqueDatabase.java:
##
Darren_Han created FLINK-36062:
--
Summary: Only the first one in the delayed data will trigger,and
it will only be restored when the transition is made to the current day window
Key: FLINK-36062
URL: https://issues.ap
[
https://issues.apache.org/jira/browse/FLINK-36062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Darren_Han updated FLINK-36062:
---
External issue ID: (was: FLINK-35069)
> Only the first one in the delayed data will trigger,and it
[
https://issues.apache.org/jira/browse/FLINK-36057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-36057:
--
Fix Version/s: aws-connector-4.4.0
(was: 1.20.0)
> Allow specifying ARN
Junrui Li created FLINK-36063:
-
Summary: Migrate StreamGraph and its related classes to
flink-runtime
Key: FLINK-36063
URL: https://issues.apache.org/jira/browse/FLINK-36063
Project: Flink
Issue
Junrui Li created FLINK-36064:
-
Summary: Refactor CollectResultIterator to eliminate dependency on
OperatorID
Key: FLINK-36064
URL: https://issues.apache.org/jira/browse/FLINK-36064
Project: Flink
Junrui Li created FLINK-36065:
-
Summary: Support for submitting StreamGraph
Key: FLINK-36065
URL: https://issues.apache.org/jira/browse/FLINK-36065
Project: Flink
Issue Type: Sub-task
C
Junrui Li created FLINK-36066:
-
Summary: Introducing the AdaptiveGraphGenerator component
Key: FLINK-36066
URL: https://issues.apache.org/jira/browse/FLINK-36066
Project: Flink
Issue Type: Sub-ta
Junrui Li created FLINK-36067:
-
Summary: Introducing the StreamGraphOptimizer component
Key: FLINK-36067
URL: https://issues.apache.org/jira/browse/FLINK-36067
Project: Flink
Issue Type: Sub-task
Junrui Li created FLINK-36068:
-
Summary: Support for adaptive job scheduling based on StreamGraph
Key: FLINK-36068
URL: https://issues.apache.org/jira/browse/FLINK-36068
Project: Flink
Issue Type
Junrui Li created FLINK-36069:
-
Summary: Extending job detail rest API to adapt to Incremental
JobGraph Generation
Key: FLINK-36069
URL: https://issues.apache.org/jira/browse/FLINK-36069
Project: Flink
Rui Fan created FLINK-36071:
---
Summary: Using System.nanoTime to measure the elapsed time instead
of System.currentTimeMillis
Key: FLINK-36071
URL: https://issues.apache.org/jira/browse/FLINK-36071
Project:
Junrui Li created FLINK-36070:
-
Summary: Modifying web UI to adapt to Incremental JobGraph
Generation
Key: FLINK-36070
URL: https://issues.apache.org/jira/browse/FLINK-36070
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-36071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36071:
Description:
A series of flink metrics are using the System.currentTimeMillis[1] to measure
the elapsed t
Junrui Li created FLINK-36072:
-
Summary: Optimizing the Overhead of the Network Layer in Adaptive
Execution Scenarios
Key: FLINK-36072
URL: https://issues.apache.org/jira/browse/FLINK-36072
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36071:
Description:
A series of flink metrics are using the System.currentTimeMillis[1] to measure
the elapsed t
[
https://issues.apache.org/jira/browse/FLINK-36062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873839#comment-17873839
]
Darren_Han commented on FLINK-36062:
[~lijinzhong] Do you have time to check this is
Samrat002 commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-2290924791
Fixed the missing comment.
it might have slipped unintentionally
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-36071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36071:
Description:
A series of flink metrics are using the System.currentTimeMillis[1] to measure
the elapsed t
beibei-li01 closed pull request #25203: [hotfix] [API/DataStream]: Ensure the
proper triggering functionality of ContinuousProcessingTimeTrigger
URL: https://github.com/apache/flink/pull/25203
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
beibei-li01 opened a new pull request, #25203:
URL: https://github.com/apache/flink/pull/25203
###** What is the purpose of the change**
This pull request fixes an issue in ContinuousProcessingTimeTrigger that
triggered logic failure when processingtime lasted longer than the maximum
flinkbot commented on PR #25203:
URL: https://github.com/apache/flink/pull/25203#issuecomment-2290995529
## CI report:
* f7537fd653e07ff438dcf2ca12acda7f5ed237d1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
beibei-li01 closed pull request #25203: [hotfix] [API/DataStream]: Ensure the
proper triggering functionality of ContinuousProcessingTimeTrigger
URL: https://github.com/apache/flink/pull/25203
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
beibei-li01 opened a new pull request, #25204:
URL: https://github.com/apache/flink/pull/25204
### **What is the purpose of the change**
This pull request fixes an issue in ContinuousProcessingTimeTrigger that
triggered logic failure when processingtime lasted longer than the maximum
flinkbot commented on PR #25204:
URL: https://github.com/apache/flink/pull/25204#issuecomment-2291049967
## CI report:
* c72f43f81811d7ece569cfc0655d882254dc63e2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lincoln-lil merged PR #25201:
URL: https://github.com/apache/flink/pull/25201
--
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.a
lincoln-lil merged PR #25202:
URL: https://github.com/apache/flink/pull/25202
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873763#comment-17873763
]
lincoln lee edited comment on FLINK-35935 at 8/15/24 11:24 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-35935.
---
Resolution: Fixed
> CREATE TABLE AS doesn't work with LIMIT
> --
GOODBOY008 commented on code in PR #3439:
URL: https://github.com/apache/flink-cdc/pull/3439#discussion_r1718351691
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/testutils/UniqueDatabase.java:
#
whhe commented on code in PR #3439:
URL: https://github.com/apache/flink-cdc/pull/3439#discussion_r1718375231
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/testutils/UniqueDatabase.java:
##
whhe commented on code in PR #3439:
URL: https://github.com/apache/flink-cdc/pull/3439#discussion_r1718375231
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/testutils/UniqueDatabase.java:
##
beibei-li01 opened a new pull request, #25205:
URL: https://github.com/apache/flink/pull/25205
### **What is the purpose of the change**
This pull request fixes an issue in ContinuousProcessingTimeTrigger that
triggered logic failure when processingtime lasted longer than the maximum
beibei-li01 closed pull request #25204: [hotfix] [API/DataStream]: Ensure the
proper triggering functionality of ContinuousProcessingTimeTrigger
URL: https://github.com/apache/flink/pull/25204
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
flinkbot commented on PR #25205:
URL: https://github.com/apache/flink/pull/25205#issuecomment-2291286783
## CI report:
* 39fe9fd7cc625b6cc6e808b3bbe95b5d79bae50b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
vahmed-hamdy commented on PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#issuecomment-2291347709
@rjbaucells Hello, It is pending approval from @MartijnVisser
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
lincoln-lil merged PR #25133:
URL: https://github.com/apache/flink/pull/25133
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-35920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-35920.
---
Resolution: Fixed
Fixed in master: a91085ebdbcaf7784f9af78f6f4f40079f310399
> Add PRINTF function
>
lincoln-lil commented on PR #25182:
URL: https://github.com/apache/flink/pull/25182#issuecomment-2291470530
> @dylanhz thanks for this improvement! +1 for merging. Could you rebase the
latest branch?
You can do the rebase after #25176 been merged.
--
This is an automated message fr
Robert Metzger created FLINK-36073:
--
Summary: ApplicationMode with the K8s operator does not support
downloading jars via filesystem plugins
Key: FLINK-36073
URL: https://issues.apache.org/jira/browse/FLINK-36073
[
https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873991#comment-17873991
]
Robert Metzger commented on FLINK-28915:
Okay, thanks for confirming this is an
ferenc-csaky commented on PR #25139:
URL: https://github.com/apache/flink/pull/25139#issuecomment-2292061587
Thank you @gaborgsomogyi! If no objections until then, will merge this on
Monday.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874045#comment-17874045
]
Ferenc Csaky commented on FLINK-28915:
--
Thanks for filing the follow-up ticket with
ferenc-csaky commented on PR #22789:
URL: https://github.com/apache/flink/pull/22789#issuecomment-2292116465
@kottmann I was not a committer back then, but if you will have some time
and desire to resolve the current conflicts, I still believe this would be a
nice improvement and will add i
[
https://issues.apache.org/jira/browse/FLINK-35280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-35280:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> Migrate HBase Sink connector to use the ASy
[
https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-35136:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> Release flink-connector-hbase v4.0.0 for Fl
[
https://issues.apache.org/jira/browse/FLINK-33557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-33557:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> Externalize Cassandra Python connector code
[
https://issues.apache.org/jira/browse/FLINK-35350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-35350:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> Add documentation for Kudu
> --
[
https://issues.apache.org/jira/browse/FLINK-28372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-28372:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> Investigate Akka Artery
> -
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-25343:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> HBaseConnectorITCase.testTableSourceSinkWit
[
https://issues.apache.org/jira/browse/FLINK-32562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-32562:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> FileSink Compactor Service should not use F
[
https://issues.apache.org/jira/browse/FLINK-34931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-34931:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> Update Kudu DataStream connector to use Sin
[
https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-33558:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> Externalize Elasticsearch Python connector
[
https://issues.apache.org/jira/browse/FLINK-35114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-35114:
Assignee: Ferenc Csaky (was: Ferenc Csaky)
> Remove old Table API implementations
>
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky closed FLINK-25343.
Resolution: Won't Fix
Closing this, as the HBase connector is not part of the core repository
any
[
https://issues.apache.org/jira/browse/FLINK-36073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-36073:
Assignee: Ferenc Csaky
> ApplicationMode with the K8s operator does not support downloadi
[
https://issues.apache.org/jira/browse/FLINK-36073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874056#comment-17874056
]
Ferenc Csaky commented on FLINK-36073:
--
I will be able to spend some time on this i
jnh5y opened a new pull request, #25206:
URL: https://github.com/apache/flink/pull/25206
## What is the purpose of the change
* Adds Compiled Plan annotations to BatchExecRank.
* Tests the new annotations with the existing TestPrograms.
## Verifying this change
This ch
jnh5y opened a new pull request, #25207:
URL: https://github.com/apache/flink/pull/25207
## What is the purpose of the change
* Adds Compiled Plan annotations to BatchExecSortLimit.
* Tests the new annotations with the existing TestPrograms.
## Verifying this change
Th
[
https://issues.apache.org/jira/browse/FLINK-36048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36048:
---
Labels: pull-request-available (was: )
> Add CompiledPlan annotations to BatchExecRank
> --
[
https://issues.apache.org/jira/browse/FLINK-36049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36049:
---
Labels: pull-request-available (was: )
> Add CompiledPlan annotations to BatchExecSortLimit
flinkbot commented on PR #25206:
URL: https://github.com/apache/flink/pull/25206#issuecomment-2292285471
## CI report:
* c82d7a7b541e88cf32a00b67b0066da681df86b2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25207:
URL: https://github.com/apache/flink/pull/25207#issuecomment-2292285769
## CI report:
* 56aa0a7c832030ee49b2737582841704b303b21e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850841#comment-17850841
]
Brad Atcheson edited comment on FLINK-34023 at 8/15/24 11:16 PM:
-
SamBarker commented on code in PR #863:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/863#discussion_r1719115879
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesClientMetrics.java:
##
@@ -118,32 +139,91 @@ public
jnh5y commented on code in PR #25206:
URL: https://github.com/apache/flink/pull/25206#discussion_r1719174902
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/batch/RankBatchRestoreTest.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to t
lincoln-lil merged PR #25176:
URL: https://github.com/apache/flink/pull/25176
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-35993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-35993:
Fix Version/s: 2.0.0
> Add UNHEX function
> --
>
> Key: FLINK-3599
[
https://issues.apache.org/jira/browse/FLINK-35993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-35993.
---
Resolution: Fixed
Fixed in master: 215ad96248c989405177704a8eb63c6ff3215792
> Add UNHEX function
>
Jiabao-Sun commented on PR #22789:
URL: https://github.com/apache/flink/pull/22789#issuecomment-2292582386
Thanks @kottmann for this contribution and @ferenc-csaky for the review,
Sorry for missing the message earlier.
Could you rebase master and resolve the conflicts?
--
This
RocMarshal commented on code in PR #865:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1719192530
##
flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java:
##
@@ -104,6 +134,43 @@ public
Jiabao-Sun commented on PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#issuecomment-2292619117
Hi @yuxiqian, could you help review this when you have time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
Jiabao-Sun commented on PR #40:
URL:
https://github.com/apache/flink-connector-mongodb/pull/40#issuecomment-2292632369
Hi @GOODBOY008, 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 s
Jiabao-Sun commented on PR #42:
URL:
https://github.com/apache/flink-connector-mongodb/pull/42#issuecomment-2292632048
Hi @GOODBOY008, 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 s
RocMarshal commented on code in PR #865:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1719192530
##
flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java:
##
@@ -104,6 +134,43 @@ public
xccui merged PR #25196:
URL: https://github.com/apache/flink/pull/25196
--
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.
Jiabao Sun created FLINK-36074:
--
Summary: Supprt insert overwrite semantics for mongodb table sink.
Key: FLINK-36074
URL: https://issues.apache.org/jira/browse/FLINK-36074
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874102#comment-17874102
]
Xingcan Cui commented on FLINK-36004:
-
Fixed in master: b460d3d6fe00a18342783113635d
[
https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui resolved FLINK-36004.
-
Resolution: Fixed
> Flink SQL returns wrong results for Paimon tables with complex schemas
> ---
[
https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-36074:
---
Summary: Support insert overwrite semantics for mongodb table sink. (was:
Supprt insert overwrite s
[
https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-36074:
---
Description: Support insert overwrite semantics for mongodb table sink.
(was: Supprt insert overwri
Jiabao-Sun opened a new pull request, #43:
URL: https://github.com/apache/flink-connector-mongodb/pull/43
Support `insert overwrite` semantics for mongodb table sink
--
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-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36074:
---
Labels: pull-request-available (was: )
> Support insert overwrite semantics for mongodb tab
Jiabao-Sun commented on PR #139:
URL:
https://github.com/apache/flink-connector-jdbc/pull/139#issuecomment-2292669294
Thanks @whhe for the review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
Jiabao-Sun merged PR #139:
URL: https://github.com/apache/flink-connector-jdbc/pull/139
--
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.
xuyangzhong opened a new pull request, #25208:
URL: https://github.com/apache/flink/pull/25208
## What is the purpose of the change
BP for https://github.com/apache/flink/pull/25196 in 1.20
*The method `copy` in Flink’s `ArrayDataSerializer` does not return the
expected copied
flinkbot commented on PR #25208:
URL: https://github.com/apache/flink/pull/25208#issuecomment-2292709579
## CI report:
* 57a8d4871a03983c9240589f2502c8879806ea0a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xuyangzhong opened a new pull request, #25209:
URL: https://github.com/apache/flink/pull/25209
## What is the purpose of the change
BP for https://github.com/apache/flink/pull/25196 in 1.19
*The method `copy` in Flink’s `ArrayDataSerializer` does not return the
expected copied
xuyangzhong commented on PR #25196:
URL: https://github.com/apache/flink/pull/25196#issuecomment-2292724340
Hi, @xccui I have bp this fix to 1.20 and 1.19. You can take a look if you
have time.
1.20: https://github.com/apache/flink/pull/25208
1.19: https://github.com/apache/flink/pull
flinkbot commented on PR #25209:
URL: https://github.com/apache/flink/pull/25209#issuecomment-2292736975
## CI report:
* 72587fb0a66959422eb23b091c95375d269a801f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jiabao-Sun commented on PR #43:
URL:
https://github.com/apache/flink-connector-mongodb/pull/43#issuecomment-2292753782
Hi @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 spe
yuxiqian commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719350260
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,15 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.18-SNAPSHOT ]
-
yuxiqian commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719355383
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/testutils/MongoTestUtil.java:
##
@@ -62,7 +62,7 @@ private MongoTestUtil() {}
yuxiqian commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719355383
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/testutils/MongoTestUtil.java:
##
@@ -62,7 +62,7 @@ private MongoTestUtil() {}
yuxiqian commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719355383
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/testutils/MongoTestUtil.java:
##
@@ -62,7 +62,7 @@ private MongoTestUtil() {}
yuxiqian commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719355383
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/testutils/MongoTestUtil.java:
##
@@ -62,7 +62,7 @@ private MongoTestUtil() {}
yuxiqian commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719359318
##
pom.xml:
##
@@ -399,6 +404,37 @@ under the License.
true
+
+
+
Jiabao-Sun commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719375910
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/testutils/MongoTestUtil.java:
##
@@ -62,7 +62,7 @@ private MongoTestUtil() {
Jiabao-Sun commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719376795
##
pom.xml:
##
@@ -399,6 +404,37 @@ under the License.
true
+
+
[
https://issues.apache.org/jira/browse/FLINK-36066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li updated FLINK-36066:
--
Description:
To support the incremental generation of JobGraph and update the StreamGraph
based on ru
1 - 100 of 112 matches
Mail list logo
