Hi.
I have create the jira https://issues.apache.org/jira/browse/FLINK-14108 for
improve confluent schema registry integration. I have the code but would
like to have some feedback if the community would like the contribution.
Lasse Nedergaard
is to skip watermark and create a keyed processed function and
handle the time for each key my self.
Med venlig hilsen / Best regards
Lasse Nedergaard
> Den 23. sep. 2019 kl. 06.16 skrev 廖嘉逸 :
>
> Hi all,
> Currently Watermark can only be supported on task’s level(or partit
Lasse Nedergaard created FLINK-14108:
-
Summary: Support for Confluent Kafka schema registry for Avro
serialisation
Key: FLINK-14108
URL: https://issues.apache.org/jira/browse/FLINK-14108
Hi.
I have encountered the same problem when you input epoch time to window table
function and then use window.start and window.end the out doesn’t output in
epoch but local time and I located the problem to the same internal function as
you.
Med venlig hilsen / Best regards
Lasse
Lasse Nedergaard created FLINK-9800:
Summary: Return the relation between a running job and the
original jar in REST API
Key: FLINK-9800
URL: https://issues.apache.org/jira/browse/FLINK-9800
