ord). If you want to generate watermark
> according to some column from the data, you need to define it explicitly.
>
> Regards,
> Dian
>
> 2021年8月4日 上午2:10，Ignacio Taranto 写道：
>
> I assumed that the event time and watermarks were already handled by the
> Kafka connector.
&g
.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/event-time/generating_watermarks/
>
> On Tue, Aug 3, 2021 at 2:34 PM Ignacio Taranto <
> ignacio.tara...@eclypsium.com> wrote:
>
>> I'm trying to so a simple word count example, here's the main function:
hould not affect the Kafka consumer.
> Did you judge this as there is no output for the job? If so, I’m guessing
> that it’s because the window wasn’t triggered in case of event-time.
>
> Could you share more code snippet?
>
> Regards,
> Dian
>
> 2021年8月2日 下午11:40，Ignacio
I'm trying to use *FlinkKafkaConsumer* and a custom Trigger like explained
here:
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/python/datastream/operators/windows/#fire-and-purge
This my *window assigner* implementation:
class TumblingEventWindowAssigner(WindowAssigner[str
