gtk96 commented on PR #3554:
URL: https://github.com/apache/flink-cdc/pull/3554#issuecomment-2295789623
@leonardBang @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
[
https://issues.apache.org/jira/browse/FLINK-29991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874793#comment-17874793
]
Martijn Visser commented on FLINK-29991:
[~chalixar] Sure thing
> KinesisFireho
[
https://issues.apache.org/jira/browse/FLINK-29991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29991.
--
Resolution: Cannot Reproduce
> KinesisFirehoseSinkTest#firehoseSinkFailsWhenUnableToConnectToR
[
https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29031.
--
Fix Version/s: (was: 2.0.0)
Resolution: Cannot Reproduce
> FlinkKinesisConsumerTest
Thorne-coder commented on PR #3478:
URL: https://github.com/apache/flink-cdc/pull/3478#issuecomment-2295770281
@leonardBang 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 comme
flinkbot commented on PR #25215:
URL: https://github.com/apache/flink/pull/25215#issuecomment-2295734528
## CI report:
* 91a0968b0e7d74df2a503ee772c37bd386b5e649 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36090:
---
Labels: pull-request-available (was: )
> Bug with IngestDB restore operation for priority q
max-509 opened a new pull request, #25215:
URL: https://github.com/apache/flink/pull/25215
## What is the purpose of the change
This pull request fix IngestDB restore operation correctness with priority
queue states.
## Brief change log
- `equals()` and `hashCode`
[
https://issues.apache.org/jira/browse/FLINK-36090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maxim Vershinin updated FLINK-36090:
Priority: Major (was: Minor)
> Bug with IngestDB restore operation for priority queue sta
lajith created FLINK-36091:
--
Summary: Config passed in via the environment variable
FLINK_PROPERTIES which has space not getting processed
Key: FLINK-36091
URL: https://issues.apache.org/jira/browse/FLINK-36091
[
https://issues.apache.org/jira/browse/FLINK-36090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874777#comment-17874777
]
Maxim Vershinin commented on FLINK-36090:
-
Please assign this task to me
> Bug
Maxim Vershinin created FLINK-36090:
---
Summary: Bug with IngestDB restore operation for priority queue
state in backend
Key: FLINK-36090
URL: https://issues.apache.org/jira/browse/FLINK-36090
Project
yuxiqian commented on PR #3521:
URL: https://github.com/apache/flink-cdc/pull/3521#issuecomment-2295634405
Thanks for Leonard's review, I've made the following changes:
* Marked new API with `@PublicEvolving` and `@Internal` annotations
* Reverted `ColumnSchemaChangeEvent` and `Tabl
[
https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-36088:
--
Priority: Blocker (was: Critical)
> Fix NopointException in PaimonDataSink.
> ---
[
https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-36082:
--
Priority: Blocker (was: Major)
> Fix NotSerializableException for KafkaDataSink
> ---
leonardBang commented on code in PR #3521:
URL: https://github.com/apache/flink-cdc/pull/3521#discussion_r1721184717
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DropTableEvent.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (A
leonardBang merged PR #3551:
URL: https://github.com/apache/flink-cdc/pull/3551
--
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-36084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-36084.
Resolution: Fixed
close via: adb8368985ad20e1872a50939c43488516d18b55
> Optimze parquet binary ge
[
https://issues.apache.org/jira/browse/FLINK-36084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-36084:
Assignee: xy
> Optimze parquet binary getBytes with getBytesUnsafe to avoid copy cost
> -
JingsongLi merged PR #25213:
URL: https://github.com/apache/flink/pull/25213
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-36089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau closed FLINK-36089.
-
Resolution: Fixed
> clean codegen print function
>
>
> Key:
Jacky Lau created FLINK-36089:
-
Summary: clean codegen print function
Key: FLINK-36089
URL: https://issues.apache.org/jira/browse/FLINK-36089
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36088:
--
Description: Fix NoPointException in BucketAssignOperator when job
restarted. (was: Fix NopointExcept
lvyanquan opened a new pull request, #3553:
URL: https://github.com/apache/flink-cdc/pull/3553
Try to get latestSchema from SchemaRegistry when job restarted.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
[
https://issues.apache.org/jira/browse/FLINK-36087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan closed FLINK-36087.
-
Resolution: Fixed
> Fix
> ---
>
> Key: FLINK-36087
> URL: https://issues
LvYanquan created FLINK-36088:
-
Summary: Fix NopointException in PaimonDataSink.
Key: FLINK-36088
URL: https://issues.apache.org/jira/browse/FLINK-36088
Project: Flink
Issue Type: Bug
C
LvYanquan created FLINK-36087:
-
Summary: Fix
Key: FLINK-36087
URL: https://issues.apache.org/jira/browse/FLINK-36087
Project: Flink
Issue Type: Bug
Reporter: LvYanquan
--
This m
lvyanquan commented on PR #3549:
URL: https://github.com/apache/flink-cdc/pull/3549#issuecomment-2295531608
@PatrickRen @yuxiqian CC as you may interested.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-36044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874751#comment-17874751
]
zhanghuaibei commented on FLINK-36044:
--
Why hasn't anyone answered
> In flink-conn
[
https://issues.apache.org/jira/browse/FLINK-36086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36086:
---
Labels: pull-request-available (was: )
> SQL Server source connector skips changes if resta
Sergei Morozov created FLINK-36086:
--
Summary: SQL Server source connector skips changes if restarted
mid transaction
Key: FLINK-36086
URL: https://issues.apache.org/jira/browse/FLINK-36086
Project: F
flinkbot commented on PR #25214:
URL: https://github.com/apache/flink/pull/25214#issuecomment-2295387359
## CI report:
* 0efa9a276fe17970772afc229d5611fe7fe2fee2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Al-Moatasem opened a new pull request, #25214:
URL: https://github.com/apache/flink/pull/25214
## What is the purpose of the change
While using PyFlink 1.19, the JDBC sink raises this error message
```
Traceback (most recent call last):
File "d:\pyflink_s/sink_02_jdbc.py", line
[
https://issues.apache.org/jira/browse/FLINK-36085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36085:
Summary: Refactor SHOW operations with LIKE/ILIKE (was: Refactor SHOW
operation with LIKE
[
https://issues.apache.org/jira/browse/FLINK-36085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36085:
Component/s: Table SQL / Planner
> Refactor SHOW operations with LIKE/ILIKE
>
[
https://issues.apache.org/jira/browse/FLINK-36085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36085:
Summary: Refactor SHOW operation with LIKE/ILIKE (was: Refeactor operation
with LIKE/ILIK
[
https://issues.apache.org/jira/browse/FLINK-36085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36085:
Description:
Current implementation has several issues
1. every operation implements its o
[
https://issues.apache.org/jira/browse/FLINK-36085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36085:
Description:
Current implementation has several issues
1. every operation implements its o
Sergey Nuyanzin created FLINK-36085:
---
Summary: Refeactor operation with LIKE/ILIKE
Key: FLINK-36085
URL: https://issues.apache.org/jira/browse/FLINK-36085
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-36050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36050:
Parent: FLINK-31256
Issue Type: Sub-task (was: New Feature)
> Support enhanced `s
gyfora commented on code in PR #860:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/860#discussion_r1721033240
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -219,64 +240,205 @@ private void
vahmed-hamdy commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1720826288
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/constants/AWSGlueConfigConstants.java:
##
@@ -0,0 +1,48 @@
+
Samrat002 commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-2295338861
@foxus thank you for adding the change. 👍🏻
please review again i have added tests and tried to address to your
suggested change.
--
This is an automated message from
FSLiber commented on PR #25210:
URL: https://github.com/apache/flink/pull/25210#issuecomment-2295312301
> The style of the PR title can be referred this:
https://flink.apache.org/how-to-contribute/code-style-and-quality-pull-requests/
thanks for advice, I have corrected it.
--
This
flinkbot commented on PR #25213:
URL: https://github.com/apache/flink/pull/25213#issuecomment-2295281210
## CI report:
* 898fb9eb74111d37ce03a8d5830c120f0c9ad426 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36084:
---
Labels: pull-request-available (was: )
> Optimze parquet binary getBytes with getBytesUnsaf
xuzifu666 opened a new pull request, #25213:
URL: https://github.com/apache/flink/pull/25213
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
xy created FLINK-36084:
--
Summary: Optimze parquet binary getBytes with getBytesUnsafe to
avoid copy cost
Key: FLINK-36084
URL: https://issues.apache.org/jira/browse/FLINK-36084
Project: Flink
Issue Typ
GOODBOY008 opened a new pull request, #3551:
URL: https://github.com/apache/flink-cdc/pull/3551
### Summary
I noticed that some Flink CDC documentation pages load slowly due to
uncompressed images. To address this, I’ve optimized the images to improve page
load speed.
https://gith
GOODBOY008 opened a new pull request, #113:
URL: https://github.com/apache/flink-connector-kafka/pull/113
(no comment)
--
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
[
https://issues.apache.org/jira/browse/FLINK-36083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36083:
---
Labels: doc pull-request-available (was: doc)
> Fix kafka table api doc's Connector Options
GOODBOY008 opened a new pull request, #112:
URL: https://github.com/apache/flink-connector-kafka/pull/112
(no comment)
--
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
[
https://issues.apache.org/jira/browse/FLINK-36083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong updated FLINK-36083:
Attachment: (was: image-2024-08-18-15-23-32-615.png)
> Fix kafka table api doc's Conne
[
https://issues.apache.org/jira/browse/FLINK-36083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong updated FLINK-36083:
Labels: doc (was: )
> Fix kafka table api doc's Connector Options table broken
>
Zhongqiang Gong created FLINK-36083:
---
Summary: Fix kafka table api doc's Connector Options table broken
Key: FLINK-36083
URL: https://issues.apache.org/jira/browse/FLINK-36083
Project: Flink
55 matches
Mail list logo
