Hey, Jeyhun
Thanks for kicking off this discussion. I have two questions about streaming
sources:
(1)The FLIP motivation section says Kafka broker is already partitioned w.r.t.
some key[s] , Is this the main use case in Kafka world? Partitioning by key
fields is not the default partitioner o
Hao Li created FLINK-34993:
--
Summary: Support Model CRUD in parser
Key: FLINK-34993
URL: https://issues.apache.org/jira/browse/FLINK-34993
Project: Flink
Issue Type: Sub-task
Reporter: H
Hao Li created FLINK-34992:
--
Summary: FLIP-437: Support ML Models in Flink SQL
Key: FLINK-34992
URL: https://issues.apache.org/jira/browse/FLINK-34992
Project: Flink
Issue Type: New Feature
Hi, dev
After offline discussion with Becket Qin, Lincoln Lee and Jark Wu, we have
improved some parts of the FLIP.
1. Add Full Refresh Mode section to clarify the semantics of full refresh
mode.
2. Add Future Improvement section explaining why query statement does not
support references to temp
+1 (non-binding)
Looking forward to this future.
Thanks,
Yu Chen
> 2024年4月3日 10:23，Jark Wu 写道：
>
> +1 (binding)
>
> Best,
> Jark
>
> On Tue, 2 Apr 2024 at 15:12, Timo Walther wrote:
>
>> +1 (binding)
>>
>> Thanks,
>> Timo
>>
>> On 29.03.24 17:30, Hao Li wrote:
>>> Hi devs,
>>>
>>> I'd
+1 (binding)
Best,
Jark
On Tue, 2 Apr 2024 at 15:12, Timo Walther wrote:
> +1 (binding)
>
> Thanks,
> Timo
>
> On 29.03.24 17:30, Hao Li wrote:
> > Hi devs,
> >
> > I'd like to start a vote on the FLIP-437: Support ML Models in Flink
> > SQL [1]. The discussion thread is here [2].
> >
> > The v
Hi Lincoln,
Thanks a lot for your comments. Please find my answers below.
1. Is this flip targeted only at batch scenarios or does it include
> streaming?
> (The flip and the discussion did not explicitly mention this, but in the
> draft pr, I only
> saw the implementation for batch scenarios
>
+1 to this as well, as we were talking about this on the other generic
thread about supporting headers at the serdes layer.
Couple of tiny points:
> passHeadersToSerDe option
If the interface can be made backwards compatible, is there a need for this
option anymore? For example adding default fun
Ryan van Huuksloot created FLINK-34991:
--
Summary: Flink Operator ClassPath Race Condition Bug
Key: FLINK-34991
URL: https://issues.apache.org/jira/browse/FLINK-34991
Project: Flink
Issue
Hi Jeyhun,
Thank you for driving this, it would be very useful optimization!
Sorry for joining the discussion now(I originally planned to reply earlier,
but
happened to be during my vacation). I have two questions:
1. Is this flip targeted only at batch scenarios or does it include
streaming?
(T
Xin Gong created FLINK-34990:
Summary: [feature][cdc-connector][oracle] Oracle cdc support newly
add table
Key: FLINK-34990
URL: https://issues.apache.org/jira/browse/FLINK-34990
Project: Flink
Matthias Pohl created FLINK-34989:
-
Summary: Apache Infra requests to reduce the runner usage for a
project
Key: FLINK-34989
URL: https://issues.apache.org/jira/browse/FLINK-34989
Project: Flink
Matthias Pohl created FLINK-34988:
-
Summary: Class loading issues in JDK17 and JDK21
Key: FLINK-34988
URL: https://issues.apache.org/jira/browse/FLINK-34988
Project: Flink
Issue Type: Bug
Hangxiang Yu created FLINK-34987:
Summary: Introduce Internal State Interface for Async API
Key: FLINK-34987
URL: https://issues.apache.org/jira/browse/FLINK-34987
Project: Flink
Issue Type:
+1 (binding)
Thanks,
Timo
On 29.03.24 17:30, Hao Li wrote:
Hi devs,
I'd like to start a vote on the FLIP-437: Support ML Models in Flink
SQL [1]. The discussion thread is here [2].
The vote will be open for at least 72 hours unless there is an objection or
insufficient votes.
[1]
https://cwi
15 matches
Mail list logo
