Hi David,
It happened due to lack of patience. I apologise.
On Sat, Jan 8, 2022 at 3:06 PM David Morávek
wrote:
> I just have to answer to this.
>
> This was again cross posted on stackoverflow [1]. I think you seriously
> need to rethink your behavior here. The cross posting is one thing, but
I just have to answer to this.
This was again cross posted on stackoverflow [1]. I think you seriously
need to rethink your behavior here. The cross posting is one thing, but
creating a second "fake" email, so you can repeat the behavior you've been
discouraged from [2], makes me feel that you don
Hi,
I tried the code below but it throws an error.
val src: DataStream[String] =
env.addSource(consumer).windowAll(TumblingEventTimeWindows.of(Time.seconds(2)))
// reading data and used data distribution strategy
src.process(new JSONParsingProcessFunction()).uid("sink")
Error:
type mismatch;
Can somebody help me with this? I tried several examples where they have
extracted the key from Json and used windowing but as far as I have learnt,
with windowing I will have to use some kind of aggregation but in my use
case there is no aggregation to be performed. I just have to get data for
eve
I have an incoming json data like below:
{"custId": 1,"custFirstName":"Martin",
"custLastName":"owen","edl_created_at":"2022-03-01 00:00:00"}
Now, this record has been pushed successfully via producer to the consumer.
But I am willing to get records of say 2 seconds window but I don't have
any key
