The exception is very clear that the SourceFunction should be serializable.
Password is not serializable. You can try to set the kafka consumer properties
such as this:
props.put(SaslConfigs.SASL_JAAS_CONFIG, "LoginModule required subject=\"test\"
secret=\"test\";");
The String value will be p
Hi Jiayi,
As far as I know, there is no plan to support this feature. But I think it may
be a very useful feature as it can eliminate the redundant network transmission
compared to multiple operators to support multiple patterns. You can create an
issue and we can discuss further about it on th
Hi Florin,
Are you using processing time or event time? The JIRA FLINK-7384 allows to emit
timed-out patterns without having to wait for the next element ONLY in
processing time. For event time, it still needs the watermark to trigger the
emitting of matched or timed-out patterns. Besides, the
