hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832538357
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833153362
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -40,10 +40,40 @@ Dependencies
The Kinesis connector is not part of the binary distribution.
See ho
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833156129
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -123,6 +158,430 @@ WITH (
Connector Options
-
+
+
+
+Option
+
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833159382
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -123,6 +158,430 @@ WITH (
Connector Options
-
+
+
+
+Option
+
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833154045
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -57,16 +87,21 @@ CREATE TABLE KinesisTable (
PARTITIONED BY (user_id, item_id)
WITH (
'connecto
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833157483
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -123,6 +158,430 @@ WITH (
Connector Options
-
+
+
+
+Option
+
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833158725
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -123,6 +158,430 @@ WITH (
Connector Options
-
+
+
+
+Option
+
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833158015
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -123,6 +158,430 @@ WITH (
Connector Options
-
+
+
+
+Option
+
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833163366
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -57,16 +87,21 @@ CREATE TABLE KinesisTable (
PARTITIONED BY (user_id, item_id)
WITH (
'connecto
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833158443
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -123,6 +158,430 @@ WITH (
Connector Options
-
+
+
+
+Option
+
[
https://issues.apache.org/jira/browse/FLINK-36592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-36592.
Assignee: Yanfei Lei
Resolution: Resolved
Merged into master via 2ceb62da55575a852dfc2481609
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832519329
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832536416
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832527875
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832537388
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
[
https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896388#comment-17896388
]
Lorenzo Affetti commented on FLINK-31762:
-
[~arvid] wrote to you on Slack as wel
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832523859
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833155289
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -123,6 +158,430 @@ WITH (
Connector Options
-
+
+
+
+Option
+
[
https://issues.apache.org/jira/browse/FLINK-36417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896462#comment-17896462
]
Sergey Nuyanzin commented on FLINK-36417:
-
[~xuyangzhong]
I created 2 PRs
1.19:
snuyanzin opened a new pull request, #25623:
URL: https://github.com/apache/flink/pull/25623
This is a cherry-pick of
https://github.com/apache/flink/commit/4101316ef37d3a7082bff57cb732f4e9e0349d09
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
flinkbot commented on PR #25623:
URL: https://github.com/apache/flink/pull/25623#issuecomment-2463118913
## CI report:
* fb4ed527c0c31f58b7022d083449245d1936f0c8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lvyanquan opened a new pull request, #3697:
URL: https://github.com/apache/flink-cdc/pull/3697
cherry picked from commit f24399cf5a32f4c79bbb6a86e3a3399f17bfbbe0
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
nicusX commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833225006
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -123,6 +158,430 @@ WITH (
Connector Options
-
+
+
+
+Option
+
snuyanzin opened a new pull request, #25621:
URL: https://github.com/apache/flink/pull/25621
This is a cherr0pick of
https://github.com/apache/flink/commit/4101316ef37d3a7082bff57cb732f4e9e0349d09
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
snuyanzin closed pull request #25621: [BP-1.19][FLINK-36417][table] Add support
for hints in WatermarkAssigner
URL: https://github.com/apache/flink/pull/25621
--
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
snuyanzin opened a new pull request, #25622:
URL: https://github.com/apache/flink/pull/25622
This is a cherry-pick of
https://github.com/apache/flink/commit/4101316ef37d3a7082bff57cb732f4e9e0349d09
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
flinkbot commented on PR #25622:
URL: https://github.com/apache/flink/pull/25622#issuecomment-2463111350
## CI report:
* a80b23046e5f37b007b5bdd13b8dabcbfac02eae UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
GOODBOY008 commented on PR #3694:
URL: https://github.com/apache/flink-cdc/pull/3694#issuecomment-2462185587
@yuxiqian Can you help fix
https://github.com/apache/flink-cdc/actions/runs/11719299368/job/32655114796?pr=3694#step:4:399
?
--
This is an automated message from the Apache Git Se
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832543911
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
nicusX commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1833085942
##
docs/content/docs/connectors/table/kinesis.md:
##
@@ -57,16 +87,21 @@ CREATE TABLE KinesisTable (
PARTITIONED BY (user_id, item_id)
WITH (
'connector'
sap1ens commented on PR #871:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/871#issuecomment-2463446748
@gyfora FYI, I think I found a regression:
https://issues.apache.org/jira/browse/FLINK-36673
--
This is an automated message from the Apache Git Service.
To respond to
github-actions[bot] closed pull request #3366: [FLINK-35360] Submit Flink CDC
pipeline job yarn Application mode
URL: https://github.com/apache/flink-cdc/pull/3366
--
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
github-actions[bot] commented on PR #3460:
URL: https://github.com/apache/flink-cdc/pull/3460#issuecomment-2463458749
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
github-actions[bot] commented on PR #3366:
URL: https://github.com/apache/flink-cdc/pull/3366#issuecomment-2463458855
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
Yaroslav Tkachenko created FLINK-36673:
--
Summary: Operator is not properly handling failed deployments
without savepoints
Key: FLINK-36673
URL: https://issues.apache.org/jira/browse/FLINK-36673
P
leonardBang merged PR #3537:
URL: https://github.com/apache/flink-cdc/pull/3537
--
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
leonardBang merged PR #3592:
URL: https://github.com/apache/flink-cdc/pull/3592
--
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
[
https://issues.apache.org/jira/browse/FLINK-35982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35982:
---
Affects Version/s: cdc-3.2.0
> Transform metadata config doesn't work if no projection block was pro
[
https://issues.apache.org/jira/browse/FLINK-35982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35982:
---
Fix Version/s: cdc-3.3.0
> Transform metadata config doesn't work if no projection block was provide
[
https://issues.apache.org/jira/browse/FLINK-35982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896231#comment-17896231
]
Leonard Xu commented on FLINK-35982:
master: d620c5805e264f4e9c3cc540d1ae7005bfb4580
[
https://issues.apache.org/jira/browse/FLINK-35982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35982:
--
Assignee: yux
> Transform metadata config doesn't work if no projection block was provided
>
[
https://issues.apache.org/jira/browse/FLINK-35985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35985:
---
Affects Version/s: cdc-3.2.0
> SUBSTRING function not available in transform rules
> ---
[
https://issues.apache.org/jira/browse/FLINK-35985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35985:
---
Fix Version/s: cdc-3.3.0
cdc-3.2.1
> SUBSTRING function not available in transfor
[
https://issues.apache.org/jira/browse/FLINK-35985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896238#comment-17896238
]
Leonard Xu commented on FLINK-35985:
master: 1d2cfd789e582c7e864b2b5b4e00c160b2a2386
yuxiqian commented on PR #3509:
URL: https://github.com/apache/flink-cdc/pull/3509#issuecomment-2461825412
Closed by #3592.
--
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.
yuxiqian closed pull request #3509: [FLINK-35980][tests] Add transform-related
test cases
URL: https://github.com/apache/flink-cdc/pull/3509
--
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 speci
leonardBang commented on PR #3572:
URL: https://github.com/apache/flink-cdc/pull/3572#issuecomment-2461825121
@MOBIN-F Could you help rebase this PR?
--
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
hlteoh37 commented on PR #25615:
URL: https://github.com/apache/flink/pull/25615#issuecomment-2461727622
@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
dannycranmer commented on code in PR #760:
URL: https://github.com/apache/flink-web/pull/760#discussion_r1832431016
##
docs/data/release_archive.yml:
##
@@ -641,6 +641,11 @@ release_archive:
version: 3.3.0
release_date: "2024-10-17"
filename: "kafka"
+-
Sud0x67 commented on PR #25559:
URL: https://github.com/apache/flink/pull/25559#issuecomment-2462556454
@fsk119 Thanks for your comments, I have updated this pr.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-36671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-36671:
Description:
h2. What
The old Kinesis Table API source `kinesis-legacy` supports defining
Hong Liang Teoh created FLINK-36671:
---
Summary: Kinesis Table API for new KDS source does not support
metadata.
Key: FLINK-36671
URL: https://issues.apache.org/jira/browse/FLINK-36671
Project: Flink
fredia merged PR #25561:
URL: https://github.com/apache/flink/pull/25561
--
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
eemario commented on PR #25596:
URL: https://github.com/apache/flink/pull/25596#issuecomment-2461971637
@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.
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832494228
##
docs/content/docs/connectors/datastream/dynamodb.md:
##
@@ -23,16 +23,143 @@ KIND, either express or implied. See the License for the
specific language
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832495432
##
docs/content/docs/connectors/datastream/dynamodb.md:
##
@@ -141,7 +268,7 @@ annotations see
[here](https://docs.aws.amazon.com/sdk-for-java/latest/devel
[
https://issues.apache.org/jira/browse/FLINK-36266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896270#comment-17896270
]
Sergey Nuyanzin commented on FLINK-36266:
-
Merged as
[4edfc01f62a88686abf6733da
[
https://issues.apache.org/jira/browse/FLINK-36266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-36266.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Insert into as select * behaves incorrec
snuyanzin merged PR #25316:
URL: https://github.com/apache/flink/pull/25316
--
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
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832515617
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832514730
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832527361
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832527875
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
nicusX commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1831490695
##
docs/content/docs/connectors/datastream/dynamodb.md:
##
@@ -141,7 +268,7 @@ annotations see
[here](https://docs.aws.amazon.com/sdk-for-java/latest/develop
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832520124
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832521188
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
Sud0x67 closed pull request #25559: [FLINK-36502] [TABLE-SQL] Remove deprecated
methods in FactoryUtil.
URL: https://github.com/apache/flink/pull/25559
--
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 t
yuxiqian opened a new pull request, #3696:
URL: https://github.com/apache/flink-cdc/pull/3696
PR #3537 and #3592 has some implicit conflicts that will cause CI failure.
#3537 changes `SUBSTR` function to 1-based index and corresponding test
cases in #3592 didn't get updated yet.
--
[
https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896359#comment-17896359
]
Piotr Nowojski commented on FLINK-34919:
Same issue happened in an internal buil
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832529448
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832525097
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
Sud0x67 commented on PR #25559:
URL: https://github.com/apache/flink/pull/25559#issuecomment-2462559190
@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.
[
https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36647:
---
Labels: pull-request-available (was: )
> Support TimestampDiff function in cdc pipeline tra
flinkbot commented on PR #25620:
URL: https://github.com/apache/flink/pull/25620#issuecomment-2461687110
## CI report:
* de798b7f22ccf9fc8731debfdf9f86d3856f3f25 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang reopened FLINK-36397:
---
> Using the offset obtained after a query transaction as a high watermark
> cannot ensure exactly-once
ruanhang1993 merged PR #3564:
URL: https://github.com/apache/flink-cdc/pull/3564
--
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...@flin
[
https://issues.apache.org/jira/browse/FLINK-36105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-36105.
---
Resolution: Fixed
master(3.3-SNAPSHOT): 5d58769fe8058242123614cd9729d6660f8f4d81
> CDC pipeline job
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832571255
##
docs/content/docs/connectors/datastream/dynamodb.md:
##
@@ -23,16 +23,143 @@ KIND, either express or implied. See the License for the
specific language
Hong Liang Teoh created FLINK-36672:
---
Summary: Kinesis Table API for new KDS source should infer region
from streamARN
Key: FLINK-36672
URL: https://issues.apache.org/jira/browse/FLINK-36672
Project
[
https://issues.apache.org/jira/browse/FLINK-36630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896253#comment-17896253
]
Alberto Lago commented on FLINK-36630:
--
Hello,
got a branch ready to create a PR:
[
https://issues.apache.org/jira/browse/FLINK-36662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-36662.
---
Resolution: Fixed
Fixed in master: 10692791c9ed1ebc039ebcd12667c04f95abc440
> Incorrect constant pu
MOBIN-F commented on PR #3572:
URL: https://github.com/apache/flink-cdc/pull/3572#issuecomment-2461897844
> @MOBIN-F Could you help rebase this PR?
@leonardBang done~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
lincoln-lil merged PR #25612:
URL: https://github.com/apache/flink/pull/25612
--
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 commented on PR #25612:
URL: https://github.com/apache/flink/pull/25612#issuecomment-2461879314
> LGTM thanks for addressing feedback
@snuyanzin Thank you! Merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
pnowojski commented on PR #25580:
URL: https://github.com/apache/flink/pull/25580#issuecomment-2461841052
Thanks for fixing the issue! Merged
--
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
pnowojski merged PR #25580:
URL: https://github.com/apache/flink/pull/25580
--
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
ruanhang1993 commented on code in PR #3625:
URL: https://github.com/apache/flink-cdc/pull/3625#discussion_r1832419660
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlTypeUtils.java:
[
https://issues.apache.org/jira/browse/FLINK-36408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36408:
---
Labels: pull-request-available (was: )
> MySQL pipeline connector could not work with FLOAT
[
https://issues.apache.org/jira/browse/FLINK-36512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-36512:
-
Assignee: Prashant Bhardwaj
> Make rescale trigger based on failed checkpoints depend o
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832475173
##
docs/content/docs/connectors/datastream/dynamodb.md:
##
@@ -23,16 +23,143 @@ KIND, either express or implied. See the License for the
specific language
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832476673
##
docs/content/docs/connectors/datastream/dynamodb.md:
##
@@ -23,16 +23,143 @@ KIND, either express or implied. See the License for the
specific language
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832475620
##
docs/content/docs/connectors/datastream/dynamodb.md:
##
@@ -23,16 +23,143 @@ KIND, either express or implied. See the License for the
specific language
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832477326
##
docs/content/docs/connectors/datastream/dynamodb.md:
##
@@ -23,16 +23,143 @@ KIND, either express or implied. See the License for the
specific language
yuxiqian commented on PR #3694:
URL: https://github.com/apache/flink-cdc/pull/3694#issuecomment-2462272056
Sure, done.
--
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 un
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832515104
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on code in PR #179:
URL:
https://github.com/apache/flink-connector-aws/pull/179#discussion_r1832518101
##
docs/content/docs/connectors/datastream/kinesis.md:
##
@@ -27,644 +27,348 @@ under the License.
# Amazon Kinesis Data Streams Connector
-The Kinesis
hlteoh37 commented on PR #25128:
URL: https://github.com/apache/flink/pull/25128#issuecomment-2462653401
Looks good. Could we squash the commits to have a single commit with name
`[FLINK-35628][docs] Provide a Chinese translation of datagen.md`?
--
This is an automated message from the Ap
lvyanquan commented on PR #3652:
URL: https://github.com/apache/flink-cdc/pull/3652#issuecomment-2461562530
Thanks for @lvyanquan's advise, simplify my code using
InitContext.getRestoredCheckpointId() to avoid using state.
--
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-36221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang reassigned FLINK-36221:
-
Assignee: yux
> Add specification about CAST ... AS ... built-in functions
> --
[
https://issues.apache.org/jira/browse/FLINK-36221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36221:
--
Component/s: Flink CDC
> Add specification about CAST ... AS ... built-in functions
>
1 - 100 of 191 matches
Mail list logo
