Jiabao Sun created FLINK-36075:
--
Summary: Add paginate partition strategy for mongodb connector
Key: FLINK-36075
URL: https://issues.apache.org/jira/browse/FLINK-36075
Project: Flink
Issue Type:
[
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:
Support insert overwrite s
Jiabao-Sun commented on PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#issuecomment-2292922637
Thanks @yuxiqian for the review.
Could you help take a look again?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
Jiabao-Sun commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719410167
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,25 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.18-SNAPSHOT ]
-
dylanhz closed pull request #25146: [FLINK-35963][table] Add REGEXP_SUBSTR
function
URL: https://github.com/apache/flink/pull/25146
--
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
dylanhz closed pull request #25142: [FLINK-35932][table] Add REGEXP_COUNT
function
URL: https://github.com/apache/flink/pull/25142
--
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 commen
dylanhz closed pull request #25144: [FLINK-35962][table] Add REGEXP_INSTR
function
URL: https://github.com/apache/flink/pull/25144
--
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 commen
Jiabao-Sun commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719404820
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,25 @@ 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_r1719383582
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,25 @@ 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_r1719383582
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,25 @@ 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_r1719383582
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,25 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.18-SNAPSHOT ]
-
[
https://issues.apache.org/jira/browse/FLINK-36066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874117#comment-17874117
]
Lei Yang commented on FLINK-36066:
--
I would like to work on this task.
> Introducing
[
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
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
+
+
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() {
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
+
+
+
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_r1719350260
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,15 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.18-SNAPSHOT ]
-
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
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`
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
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
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, #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
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.
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
[
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 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
]
Jiabao Sun updated FLINK-36074:
---
Description: Support insert overwrite semantics for mongodb table sink.
(was: Supprt insert overwri
[
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-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-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874102#comment-17874102
]
Xingcan Cui commented on FLINK-36004:
-
Fixed in master: b460d3d6fe00a18342783113635d
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
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.
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 #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
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 #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
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 #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
[
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
>
[
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
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
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
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
[
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:
-
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`
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`
[
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
[
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
> --
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
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
[
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
[
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-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-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-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-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-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-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-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-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-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-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
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-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 #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=17873991#comment-17873991
]
Robert Metzger commented on FLINK-28915:
Okay, thanks for confirming this is an
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
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
[
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 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
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
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`
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
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
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:
##
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:
#
[
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
> --
[
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:
---
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
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
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`
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
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
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 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
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
[
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
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-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
[
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
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
1 - 100 of 112 matches
Mail list logo
