I removed that line from the code and it seems to have solved the problem.
Thank you very much! :)
All the best,
Laszlo
On Tue, Aug 17, 2021 at 9:54 AM László Ciople
wrote:
> Ok, thank you for the tips. I will modify it and get back to you :)
>
> On Tue, Aug 17, 2021 at 9:42 AM Davi
er
> problem in the snippet you've sent.
>
> Best,
> D.
>
> On Tue, Aug 17, 2021 at 8:33 AM László Ciople
> wrote:
>
>> I modified the code to use a sha256 hash instead of the hashCode when the
>> id is not present in the object. The same behavio
Hello,
I am trying to write a Flink application which receives data from Kafka,
does processing on keyed windowed streams and sends results on a
different topic.
Shortly after the job is started it fails with a NullPointerException in
StateTable.put(). I am really confused by this error, because I
Hello,
While trying to use the Pyflink DataStream API in Flink 1.13, I have
encountered an error regarding list types. I am trying to read data from a
Kafka topic that contains events in a json format. For example:
{
"timestamp": 1614259940,
"harvesterID": "aws-harvester",
"clientID": "
Hello,
I am experimenting with the Python DataStream API in Flink 1.13, in order
to confirm that it is a viable fit for our needs, basically trying to prove
that what can be done in the Java DataStream API also works in Python.
During testing of a processing pipeline, I encountered a problem at the
rrect.
>
>
> [1] https://issues.apache.org/jira/browse/FLINK-19675
>
> Best,
> Xingbo
>
> László Ciople 于2020年12月8日周二 下午5:21写道：
>
>> Hello,
>> I am trying to use Flink v1.11.2 with Python and the Table API to read
>> and write back messages to kafka topics
Hello,
I am trying to use Flink v1.11.2 with Python and the Table API to read and
write back messages to kafka topics. I am trying to filter messages based
on the output of a udf which returns a boolean. It seems that Flink ignores
the WHERE clause in my queries and every input message is received
