twalthr commented on code in PR #25207:
URL: https://github.com/apache/flink/pull/25207#discussion_r1719432608
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortLimit.java:
##
@@ -38,21 +40,47 @@
import org.apache
twalthr commented on PR #25207:
URL: https://github.com/apache/flink/pull/25207#issuecomment-2292953228
@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.
twalthr commented on code in PR #25206:
URL: https://github.com/apache/flink/pull/25206#discussion_r1719447587
##
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
FSLiber opened a new pull request, #25210:
URL: https://github.com/apache/flink/pull/25210
Fix ambiguous word
--
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
flinkbot commented on PR #25210:
URL: https://github.com/apache/flink/pull/25210#issuecomment-2293039206
## CI report:
* 3e92557f44ba59c83df9f05fd56e2ed6d652ceba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
GOODBOY008 commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719513579
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,25 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.18-SNAPSHOT ]
-
GOODBOY008 commented on code in PR #41:
URL:
https://github.com/apache/flink-connector-mongodb/pull/41#discussion_r1719513579
##
.github/workflows/push_pr.yml:
##
@@ -28,14 +28,25 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [ 1.18-SNAPSHOT ]
-
Jiabao-Sun merged PR #41:
URL: https://github.com/apache/flink-connector-mongodb/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 above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-33039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874152#comment-17874152
]
Nicolas Ferrario commented on FLINK-33039:
--
Same here. It also happens when rea
[
https://issues.apache.org/jira/browse/FLINK-36053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-36053.
Resolution: Implemented
implemented by main:
97ec9b4314cdae92d050c112cef2112aed421e4e
4b8f5f93c2c1
Jiabao-Sun merged PR #40:
URL: https://github.com/apache/flink-connector-mongodb/pull/40
--
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
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1719542058
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalog.java:
##
@@ -0,0 +1,1115 @@
+/*
+ * Licensed to the
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1719542058
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalog.java:
##
@@ -0,0 +1,1115 @@
+/*
+ * Licensed to the
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1719546294
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/util/GlueUtils.java:
##
@@ -0,0 +1,384 @@
+/*
+ * Licensed to t
rkhachatryan commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1719565014
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/PausableRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache
pnowojski commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1719583700
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/PausableRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache Sof
pnowojski commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1719583700
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/PausableRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache Sof
twalthr commented on PR #25207:
URL: https://github.com/apache/flink/pull/25207#issuecomment-2293165758
@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.
Hongshun Wang created FLINK-36076:
-
Summary: Hotfix: Set isSchemaChangeApplying as
isSchemaChangeApplying for thread safe.
Key: FLINK-36076
URL: https://issues.apache.org/jira/browse/FLINK-36076
Proje
[
https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874174#comment-17874174
]
Hongshun Wang commented on FLINK-36076:
---
I'd like to do it.
> Hotfix: Set isSchem
[
https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-36076:
--
Summary: Hotfix: Set isSchemaChangeApplying as volatile for thread safe.
(was: Hotfix: Set is
yuxiqian commented on PR #3521:
URL: https://github.com/apache/flink-cdc/pull/3521#issuecomment-2293183939
Rebased & improved test coverage.
--
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 sp
Ahmed Hamdy created FLINK-36077:
---
Summary: Implement Table API support for PubSubSink V2
Key: FLINK-36077
URL: https://issues.apache.org/jira/browse/FLINK-36077
Project: Flink
Issue Type: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-36077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Hamdy updated FLINK-36077:
Description: Duplicate of https://issues.apache.org/jira/browse/FLINK-24299
specific to Sink imple
vahmed-hamdy opened a new pull request, #30:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/30
## Description
- Add Table Api support for PubSubSinkV2 [FLINK-36077]
- Added credential providers options for Json Credentials and Access token
credentials
## Testing
-
[
https://issues.apache.org/jira/browse/FLINK-36077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36077:
---
Labels: pull-request-available (was: )
> Implement Table API support for PubSubSink V2
> --
vahmed-hamdy commented on PR #30:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/30#issuecomment-2293294073
@snuyanzin Could you 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
rkhachatryan commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1719692957
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/PausableRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-36077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874190#comment-17874190
]
Ahmed Hamdy commented on FLINK-36077:
-
[~snuyanzin] Could you plz take a look when p
GOODBOY008 merged PR #42:
URL: https://github.com/apache/flink-connector-mongodb/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-unsubscr
lincoln-lil merged PR #25182:
URL: https://github.com/apache/flink/pull/25182
--
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-35997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-35997.
---
Assignee: Dylan He
Resolution: Fixed
Fixed in master: 500d274265d100e4fe091e27fa1d96cebd812c2d
[
https://issues.apache.org/jira/browse/FLINK-34928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-34928:
Assignee: Ferenc Csaky
> FLIP-439: Externalize Kudu Connector from Bahir
> --
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874301#comment-17874301
]
Hong Liang Teoh commented on FLINK-34023:
-
Hey [~atchesonaws] , your solution se
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874302#comment-17874302
]
Hong Liang Teoh commented on FLINK-34023:
-
Re: the testing fails, can you check
xccui merged PR #25208:
URL: https://github.com/apache/flink/pull/25208
--
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.
xccui merged PR #25209:
URL: https://github.com/apache/flink/pull/25209
--
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-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874102#comment-17874102
]
Xingcan Cui edited comment on FLINK-36004 at 8/16/24 4:30 PM:
snuyanzin commented on PR #25207:
URL: https://github.com/apache/flink/pull/25207#issuecomment-2293883982
Thanks for your contribution @jnh5y
--
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
snuyanzin merged PR #25207:
URL: https://github.com/apache/flink/pull/25207
--
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-36049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36049:
Component/s: Table SQL / Planner
> Add CompiledPlan annotations to BatchExecSortLimit
> --
[
https://issues.apache.org/jira/browse/FLINK-36049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874332#comment-17874332
]
Sergey Nuyanzin commented on FLINK-36049:
-
Merged as
[99bf496b41cc30c5b633927a2
[
https://issues.apache.org/jira/browse/FLINK-36049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-36049.
-
Resolution: Fixed
> Add CompiledPlan annotations to BatchExecSortLimit
> ---
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874371#comment-17874371
]
Brad Atcheson edited comment on FLINK-34023 at 8/16/24 7:09 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874371#comment-17874371
]
Brad Atcheson commented on FLINK-34023:
---
Ah, thank you! Unit tests pass under Java
Ahmed Hamdy created FLINK-36078:
---
Summary: Add Documentation for PubSubSink Table API connector
Key: FLINK-36078
URL: https://issues.apache.org/jira/browse/FLINK-36078
Project: Flink
Issue Type
lihaosky opened a new pull request, #25211:
URL: https://github.com/apache/flink/pull/25211
[## What is the purpose of the change
Catalog changes to support model resource
## Brief change log
* Add `CatalogModel` related resource
* Add model CRUD operations in `Cat
flinkbot commented on PR #25211:
URL: https://github.com/apache/flink/pull/25211#issuecomment-2294376013
## CI report:
* 7d28f8478ea6823a7d176315ae7207791f95b96c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874427#comment-17874427
]
Mingliang Liu commented on FLINK-34369:
---
Can we close this now?
> Elasticsearch c
[ https://issues.apache.org/jira/browse/FLINK-34369 ]
Mingliang Liu deleted comment on FLINK-34369:
---
was (Author: liuml07):
Can we close this now?
> Elasticsearch connector supports SSL context
>
>
liuml07 commented on PR #105:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/105#issuecomment-2294601880
Thank you @snuyanzin for taking another look.
I see a lot of errors like this, and not sure if this is causing the compile
& test to timeout
> Warning: Coul
51 matches
Mail list logo
