[
https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong updated FLINK-26081:
Description:
Update document,becasue of add maven wapper.
Related files: building.md.
flinkbot commented on PR #25212:
URL: https://github.com/apache/flink/pull/25212#issuecomment-2295141501
## CI report:
* 16a0fa640b86ab5b9e6e9693e10950fbd7efda64 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26081:
---
Labels: pull-request-available (was: )
> Update document,becasue of add maven wrapper.
> --
GOODBOY008 commented on PR #25212:
URL: https://github.com/apache/flink/pull/25212#issuecomment-2295140732
@Jiabao-Sun 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 specific commen
GOODBOY008 opened a new pull request, #25212:
URL: https://github.com/apache/flink/pull/25212
Changes:
- Update flink build doc with maven wrapper.
--
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
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36081:
--
Assignee: Mingya Wang
> Flink CDC MySQL source connector missing some columns data of newly a
[
https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36082:
---
Labels: pull-request-available (was: )
> Fix NotSerializableException for KafkaDataSink
> -
lvyanquan opened a new pull request, #3549:
URL: https://github.com/apache/flink-cdc/pull/3549
Avoiding using lambda class.
--
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-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36082:
--
Assignee: LvYanquan
> Fix NotSerializableException for KafkaDataSink
> --
[
https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874607#comment-17874607
]
Leonard Xu commented on FLINK-36082:
Thanks [~kunni] , assigned to you
> Fix NotSer
[
https://issues.apache.org/jira/browse/FLINK-35638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong resolved FLINK-35638.
-
Fix Version/s: cdc-3.3.0
Resolution: Resolved
Merged to master via : cbb33bb8708d
[
https://issues.apache.org/jira/browse/FLINK-35638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong reassigned FLINK-35638:
---
Assignee: He Wang
> Modify OceanBase Docker container to make the test cases runnab
GOODBOY008 merged PR #3439:
URL: https://github.com/apache/flink-cdc/pull/3439
--
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-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874601#comment-17874601
]
LvYanquan commented on FLINK-36082:
---
I've found that it may related to lambda class in
LvYanquan created FLINK-36082:
-
Summary: Fix NotSerializableException for KafkaDataSink
Key: FLINK-36082
URL: https://issues.apache.org/jira/browse/FLINK-36082
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874600#comment-17874600
]
Mingya Wang commented on FLINK-36081:
-
ok, my pleasure, I have submitted a PR to fix
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingya Wang updated FLINK-36081:
Labels: mysql-cdc-connector pull-request-available (was:
pull-request-available)
> Flink CDC MyS
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36081:
---
Labels: pull-request-available (was: )
> Flink CDC MySQL source connector missing some colu
kevinwangcs opened a new pull request, #3548:
URL: https://github.com/apache/flink-cdc/pull/3548
**Problem Description:**
When adding a new table, the Flink CDC MySQL source connector experiences
missing data for some columns of the newly added table.
**Reproduction Scenario:**
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874599#comment-17874599
]
Leonard Xu commented on FLINK-36081:
Thanks for reporting this issue, [~kevinwang] ,
Mingya Wang created FLINK-36081:
---
Summary: Flink CDC MySQL source connector missing some columns
data of newly added tables
Key: FLINK-36081
URL: https://issues.apache.org/jira/browse/FLINK-36081
Projec
foxus commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-2295043353
@Samrat002, thanks for agreeing to collaborate, I've resolved some of the
comments but left it as a separate commit to allow you to review and squash if
you're happy whilst you're
foxus commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1720860598
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/TypeMapper.java:
##
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the Apach
foxus commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1720844609
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/operator/GlueFunctionOperator.java:
##
@@ -0,0 +1,272 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-29991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874478#comment-17874478
]
Ahmed Hamdy commented on FLINK-29991:
-
Since we externalised aws connectors and the
[
https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874477#comment-17874477
]
Ahmed Hamdy commented on FLINK-29031:
-
Given the connectors are now externalized and
[
https://issues.apache.org/jira/browse/FLINK-26058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874476#comment-17874476
]
Ahmed Hamdy commented on FLINK-26058:
-
This is not a bug
> KinesisDynamicTableFacto
[
https://issues.apache.org/jira/browse/FLINK-26058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Hamdy closed FLINK-26058.
---
Resolution: Not A Problem
> KinesisDynamicTableFactory implements DynamicSourceFactory but uses sink
vahmed-hamdy commented on PR #155:
URL:
https://github.com/apache/flink-connector-aws/pull/155#issuecomment-2294817367
@hlteoh37 Since you reviewed the datastream connector, could you please take
a look?
--
This is an automated message from the Apache Git Service.
To respond to the messa
Ahmed Hamdy created FLINK-36080:
---
Summary: Add SQL Connector for SQS
Key: FLINK-36080
URL: https://issues.apache.org/jira/browse/FLINK-36080
Project: Flink
Issue Type: Sub-task
Repo
Ahmed Hamdy created FLINK-36079:
---
Summary: Add Documentation for SQS Table API connector
Key: FLINK-36079
URL: https://issues.apache.org/jira/browse/FLINK-36079
Project: Flink
Issue Type: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-35401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35401:
---
Labels: pull-request-available (was: )
> Add SQS Table API support
> --
vahmed-hamdy opened a new pull request, #155:
URL: https://github.com/apache/flink-connector-aws/pull/155
## Purpose of the change
Implements the Table API for the Sqs Sink Connector.
## Verifying this change
- Added unit tests
- Manually verified by running th
[
https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874458#comment-17874458
]
Piotr Nowojski commented on FLINK-35886:
Merged to master as 308f05a911d..5f6200
pnowojski merged PR #25167:
URL: https://github.com/apache/flink/pull/25167
--
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
gaoyan1998 opened a new pull request, #3547:
URL: https://github.com/apache/flink-cdc/pull/3547
This PR Support speed rate,
Prevent too much data in the initial stage from causing pressure downstream
usageļ¼
```yaml
source:
type: mysql
sink:
36 matches
Mail list logo
