experience.
Thanks!
Dong
On Wed, Jan 19, 2022 at 4:32 PM Bonino Dario
wrote:
Hi Dong,
Thank you for the reply. Since we are actually experimenting with
the Flink ML libraries, If you think it's worth, we may contribute
some documentation, e.g., tutorial based on what we learn wh
wrote:
I am adding a couple of people who worked on it. Hopefully, they
will be able to answer you.
On 17/01/2022 13:39, Bonino Dario wrote:
Dear List,
We are in the process of evaluating Flink ML version 2.0 in the
context of some ML task mainly concerned with clas
Dear List,
We are in the process of evaluating Flink ML version 2.0 in the context
of some ML task mainly concerned with classification and clustering.
While algorithms for this 2 domains are already present, although in a
limited form (perhaps) in the latest release of Flink ML, we did not
, Igal Shilman wrote:
Do you have the statefun-sdk-java as a dependency, if you are not
using it can you remove it?
On Tue, May 25, 2021 at 11:28 AM Bonino Dario <mailto:dario.bon...@gmail.com>> wrote:
Dear Igal,
we are actually analyzing the issue. Our imported package is
path
then, make sure that you are not using accidentally the shaded version
of a TypedValue (check the package name)
Let me know if that helped, and we'll try to debug this together
otherwise.
Cheers,
Igal.
On Mon, May 24, 2021 at 6:46 PM Bonino Dario <mailto:dario.bon...@gmai
Hello list,
we are manually building TypedValue instances to be sent to a python
remote function (with a reqreply function builder). We create the typed
value as follows (in Kotlin):
override fun map(value: Tuple2): TypedValue {
return TypedValue.newBuilder()
.setValue(get
e bit improved, I will file a JIRA issue
for that!
A side question is there a particular reason that you chose to use the
DataStream SDK v.s the other deployment options?
Thanks,
Igal.
On Tue, Apr 27, 2021 at 5:31 PM Bonino Dario <mailto:dario.bon...@gmail.com>> wrote:
Dear
Dear List,
I am trying to call a sample stateful function defined in Python, using
the Stateful Function Python SDK, from a Flink pipeline. I am building
upon the examples provided for the SDK for Flink DataStream Integration
but I am currently stuck on a type cast issue that I am not able to
Dear list,
I need to use a Table Source to extract data from a PostgreSQL table
that includes a column of type uuid. Data in the column is converted to
java.util.UUID by the postgresql jdbc driver (I guess) however I was not
able to find a way to define a Table schema for correctly reading tha
