Hi Keith,
Thanks for the feedback and questions
> 1. Can you elaborate what are the possible configuration key and their
> examples for CloudWatchSinkProperties?
In addition to standard AsyncSink configuration key, i.e “sink.batch.max-size“,
the other possible configuration keys for TableAPI a
Thanks for the FLIP, it helps a lot for us to develop features like
VECTOR_SEARCH. But I have some questions about the FLIP:
1. Timing of Option Consumption for SEARCH_KEY Parameters
For the FOR SYSTEM_TIME AS OF syntax, the planner leverages hints and
catalog tables to load the table scan during
Hi, Leonard.
Thanks for your reply. I will recompile it and raise a RC2 later.
Best,
Hang
On Mon, Apr 14, 2025 at 8:57 PM Leonard Xu wrote:
>
> -1 (binding)
>
> - Checked the jar was built incorrectly by JDK 1.8 (Bytecode version is
> 52.0)， should be JDK 11 and supported by JDK17 as well
>
>
+1 (binding) from myself
- verified signatures and hashsums
- checked release tag
- checked release notes
- compiled from source.
Best regards,
Weijie
Leonard Xu 于2025年4月14日周一 21:12写道：
> +1 (binding)
>
>
> - verified signatures
> - verified hashsums
> - checked Github release tag
> - checked
Hi everyone,
Please review and vote on release candidate #2 for
flink-connector-jdbc v4.0.0, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [
The Apache Flink community is very happy to announce the release of Apache
flink-connector-elasticsearch 3.1.0.
Apache Flink® is an open-source stream processing framework for distributed,
high-performing, always-available, and accurate data streaming applications.
The release is available for do
Hi everyone,
I'm happy to announce that we have unanimously approved this release.
There are 7 approving votes, 3 of which are binding:
- Zakelly Lan (binding)
- Yanquan Lv (non-binding)
- Xiqian Yu (non-binding)
- Ferenc Csaky (non-binding)
- Honghun Wang (non-binding)
- Leonard Xu (bind
Yanquan Lv created FLINK-37673:
--
Summary: The transformation of table metadata should only be
effective for the first matching rule
Key: FLINK-37673
URL: https://issues.apache.org/jira/browse/FLINK-37673
Hello Daren,
Thank you for the FLIP. Questions below:
1. Can you elaborate what are the possible configuration key and their
examples for CloudWatchSinkProperties?
2. I see that MetricWriteRequest's unit field is of String type. Is there a
motivation of using String type as opposed to StandardUn
Hi everyone,
Please review and vote on release candidate #1 for
flink-connector-jdbc v4.0.0, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [
+1(binding)
- verified signatures
- verified hashsums
- checked Github release tag
- checked release notes
- checked compiled Java version was 55.0 (Java SE 11)
- reviewed the web PR, left two minor comments
Best,
Leonard
> 2025 4月 12 19:59，Xiqian YU 写道：
>
> +1 (non-binding)
>
> I’ve done t
Siddharth R created FLINK-37672:
---
Summary: Bump protobuf-maven-plugin from 0.5.1 to 0.6.1
Key: FLINK-37672
URL: https://issues.apache.org/jira/browse/FLINK-37672
Project: Flink
Issue Type: Impr
Hi Tom,
Can you check this on one of the approved releases too, given that this
checkstyle issue is 10 years old and listed as a won't fix?
Thanks,
Martijn
On Mon, Apr 14, 2025 at 3:35 PM Tom Cooper wrote:
> -1 (non-binding)
>
> I have tested the RC3, however I have found an issue with the so
The Apache Flink community is very happy to announce the release of Apache
flink-connector-kudu 2.0.0.
Apache Flink® is an open-source stream processing framework for distributed,
high-performing, always-available, and accurate data streaming applications.
The release is available for download at
Thanks Hang for driving this, +1 from my side.
Best,
Leonard
+1 (binding)
- verified signatures
- verified hashsums
- checked Github release tag
- checked release notes
- checked compiled Java version is 55.0 (Java SE 11)
- reviewed the web PR
Best,
Leonard
> 2025 4月 11 19:00，Xiqian YU 写道：
>
> +1 (non-binding)
>
> Checklist:
>
> - Tarball sha512 che
Hi Martin,
The source code build also fails on the 3.4 but not on the 3.3 or 3.2 releases
(I didn't go further back). It also does not fail on the last two main Flink
releases. So it seems that something changed in the process for last two Kafka
connector releases?
It looks like Arvid Heise wa
Piotr Nowojski created FLINK-37670:
--
Summary: Watermark alignment can deadlock job if there are no more
splits to be assigned
Key: FLINK-37670
URL: https://issues.apache.org/jira/browse/FLINK-37670
P
Timo Walther created FLINK-37671:
Summary: ChangelogMode.toString returns invalid string for partial
deletes
Key: FLINK-37671
URL: https://issues.apache.org/jira/browse/FLINK-37671
Project: Flink
Yi Chen created FLINK-37669:
---
Summary: [HELM] Add Helm chart unit tests to flink kubernetes
operator
Key: FLINK-37669
URL: https://issues.apache.org/jira/browse/FLINK-37669
Project: Flink
Issue Ty
-1 (non-binding)
I have tested the RC3, however I have found an issue with the source code
release. It seems that the checkstyle plugin is failing the build (on my Fedora
40 Linux box with Maven 3.8.6 and Java 11/17) due to the following error:
[ERROR] Failed to execute goal
org.apache.maven.p
Thanks for all the replies. I'll kick off a release for jdbc connector
v4.0.0 today.
Best,
Hang
-1 (binding)
- Checked the jar was built incorrectly by JDK 1.8 (Bytecode version is 52.0)，
should be JDK 17
- verified signatures
- verified hashsums
- checked Github release tag
- checked release notes
- reviewed the web PR
Best,
Leonard
> 2025 4月 14 16:24，Hang Ruan 写道：
>
> Hi everyone,
>
Hi devs,
I’d like to start a discussion around FLIP-521: Integrating Variant
Type into Flink: Enabling Efficient Semi-Structured Data
Processing[1]. Working with semi-structured data has long been a
foundational scenario of the Lakehouse. While JSON has traditionally
served as the primary storage
Hi All,
I've read through the FLIP and partially the discussion which is quite
exhausting. The intention looks interesting, the idea is +1.
If the FLIP goes forward then I've some questions which are touching the
fundamentals.
Without super deep consideration I've the feeling that we can realisti
+1 for the flip, the snapshot, changelog related ptfs are nice addition
to flink sql!
I have a question about the naming of the SEARCH_KEY, considering
that it is a simplified alternative to lookup join, and the word 'search'
may be more likely to remind users of keyword searching which is a bit
d
-1 (binding)
- Checked the jar was built incorrectly by JDK 1.8 (Bytecode version is 52.0)，
should be JDK 11 and supported by JDK17 as well
Best,
Leonard
> 2025 4月 14 20:26，Leonard Xu 写道：
>
> -1 (binding)
>
> - Checked the jar was built incorrectly by JDK 1.8 (Bytecode version is
> 52.0)， s
Weijie Guo created FLINK-37675:
--
Summary: Update elastic.yml for 3.1.0 release
Key: FLINK-37675
URL: https://issues.apache.org/jira/browse/FLINK-37675
Project: Flink
Issue Type: Improvement
Gabor Somogyi created FLINK-37674:
-
Summary: Add generalized type information to SQL state connector
Key: FLINK-37674
URL: https://issues.apache.org/jira/browse/FLINK-37674
Project: Flink
Iss
Hi All,
I'd like to start a discussion of FLIP-522: Add generalized type
information to SQL state connector [1].
Feel free to add your thoughts to make this feature better.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-522%3A+Add+generalized+type+information+to+SQL+state+connector
B
30 matches
Mail list logo
