Hi Dongwoo,
Thanks for your proposal!
I think the idea about OperationValidator is similar to the plan advice[1],
which can give advice if the statement has problems. I wonder if it would
be more beneficial to develop the concept within the existing
infrastructure, rather than introducing a new c
Hi everyone,
I'm delighted to announce that FLIP-460 [1] has been accepted.
There were 13 votes in favor:
- Yong Fang (binding)
- Robert Metzger (binding)
- Leonard Xu (binding)
- Becket Qin (binding)
- Ahmed Hamdy (non-binding)
- Aleksandr Pilipenko (non-binding)
- Xintong Song (binding)
- Rui F
heiya07 created FLINK-35867:
---
Summary: 99% state lost after task auto restart due to "rocksdb
block checksum mismatch" exception
Key: FLINK-35867
URL: https://issues.apache.org/jira/browse/FLINK-35867
Proje
sucb created FLINK-35866:
Summary: unsupported type Short for numeric minus
Key: FLINK-35866
URL: https://issues.apache.org/jira/browse/FLINK-35866
Project: Flink
Issue Type: Bug
Components
Hi David,
The FLIP is updated.
Cheers, Martijn
On Tue, Jul 16, 2024 at 6:33 PM David Radley
wrote:
> Hello all,
>
>
>
> I have prototyped the new design and confirmed it works. I have documented
> the design in google doc
> https://docs.google.com/document/d/1J1E-cE-X2H3-kw4rNjLn71OGPQk_Yl1iG
Hi Darin,
Your comment "I think our use case is rather unique and I'm not sure who
else would benefit" makes me think then why we should actually support it
in Flink, given that you're mentioning the use case is rather unique?
Especially since the SourceFunction has many flaws, and has been long
o
Hi Martijn,
Thanks for the guidance on making a FLIP.
Before proceeding, I’d like to gather some initial thoughts from the
community to see if we agree on the usefulness of this feature.
Could anyone share their opinions on the custom query operation validator
for Flink SQL Gateway?
Thanks in adv
Hi Kevin,
That sounds good, unfortunately the image did not come through in the email for
me,kind regards, David
From: Kevin Lam
Date: Wednesday, 10 July 2024 at 19:20
To: dev@flink.apache.org
Subject: [EXTERNAL] Re: Potential Kafka Connector FLIP: Large Message Handling
Hey David, Yes my p
Hi Dongwoo,
I think this should first have been a FLIP [1], given that it proposes to
make something pluggable with custom interfaces.
Best regards,
Martijn
[1]
https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals
On Thu, Jul 18, 2024 at 2:50 PM Dongwoo Kim wrote:
>
Hi devs,
A month ago, I created a jira issue and pr for a custom query operation
validator in Flink SQL Gateway to block unsafe queries.
Since there has been no feedback yet, I would appreciate it if someone
could review it or provide some feedback.
I'm curious if this feature can be added and if
Zhongqiang Gong created FLINK-35865:
---
Summary: When Sync SqlServer table with smallint type as pk
Key: FLINK-35865
URL: https://issues.apache.org/jira/browse/FLINK-35865
Project: Flink
Issu
Dylan He created FLINK-35864:
Summary: Add CONV function
Key: FLINK-35864
URL: https://issues.apache.org/jira/browse/FLINK-35864
Project: Flink
Issue Type: Sub-task
Components: Table SQ
Hi devs,
Junrui Lee, Lei Yang, and I would like to initiate a discussion about
FLIP-470: Support Adaptive Broadcast Join[1].
In general, Broadcast Hash Join is currently the most efficient join
strategy available in Flink. However, its prerequisite is that the input
data on one side must be suffi
+1(binding)
- Reviewed the flink-web PR (Left some comments)
- Checked Github release tag
- Verified signatures
- Verified sha512 (hashsums)
- The source archives don't contain any binaries
- Build the source with Maven 3 and java8 (Checked the license as well)
- Start the cluster locally with jdk
Thanks, Mathias, for your opinions.
I see two scenarios where different values for starting and rescaling would
be appropriate:
1) Flink serverless providers may prefer the fastest possible job startup
time, which can also be achieved by setting a smaller value for the
stabilization timeout, such
15 matches
Mail list logo
