Hi Lorenzo,
Could you provide some code example to reproduce your question? As I
understand, IterativeStream#keyBy is supported since it is a subclass
of DataStream.
Moreover, we have implemented an unified iteration module for Flink
[1] in Flink ML [2], which relies on Flink 1.15.2. Probably
The Apache Flink community is excited to announce the release of Flink ML
2.1.0!
This release focuses on improving Flink ML's infrastructure, such as Python
SDK, memory management, and benchmark framework, to facilitate the
development of performant, memory-safe, and easy-to-use algorithm
The Apache Flink community is excited to announce the release of Flink ML
2.1.0!
This release focuses on improving Flink ML's infrastructure, such as Python
SDK, memory management, and benchmark framework, to facilitate the
development of performant, memory-safe, and easy-to-use algorithm
Hi Natia,
As I understand, the processing order of onlineKmeans is the same the input
data.
Are you running OnlineKmeans with using one data point with random initial
KmeansModel? Could you use a fixed initial model following [1] and try out?
[1]
Hi Saravanan,
One solution could be using a streamOperator to implement `BoundedOneInput`
interface.
An example code could be found here [1].
[1]
Hi thekingofcity,
Thanks for your interest! Unfortunately we don't have an example for online
learning for now.
We are working on an online machine learning example. Hopefully it will be
added here [1] in the next three weeks.
[1] https://github.com/apache/flink-ml
thekingofcity
> On Tue, 4 Jan 2022 at 02:57, Zhipeng Zhang
> wrote:
>
>> Hi everyone,
>>
>> Thanks for starting the discussion :)
>>
>> We (Alink team [1]) are actually using part of the Gelly library to
>> support graph algorithms (connected component, single source shor
Hi everyone,
Thanks for starting the discussion :)
We (Alink team [1]) are actually using part of the Gelly library to support
graph algorithms (connected component, single source shortest path, etc.)
for users in Alibaba Inc.
As DataSet API is going to be dropped, shall we also provide a new
Hi Yuval,
It seems that scala code is not included in
`flink-table-api-scala-bridge_2.12-1.14.2-sources.jar` for now.
You can find all the compiled code in the compiled jar
(flink-table-api-scala-bridge_2.12-1.14.2.jar) for debugging.
If we need to also include scala code in the sources.jar, we
Hi Dan,
Could you provide the code snippet such that we can reproduce the bug here?
Dan Hill 于2021年12月20日周一 07:18写道：
> Hi.
>
> I was curious if anyone else has hit this exception. I'm using the
> IntervalJoinOperator to two streams of protos. I registered the protos
> with a kryo serializer.
--
best,
Zhipeng
11 matches
Mail list logo
