--
best,
Zhipeng
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.
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 c
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 gr
t; Martijn
>
> 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, sin
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 于2022年1月26日周三
Hi Saravanan,
One solution could be using a streamOperator to implement `BoundedOneInput`
interface.
An example code could be found here [1].
[1]
https://github.com/apache/flink-ml/blob/56b441d85c3356c0ffedeef9c27969aee5b3ecfc/flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/Data
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]
https://github.com/apache/flink-ml/blob/239788f2b
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
librari
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 you
10 matches
Mail list logo
