Re: Temporal join on rolling aggregate

Hi everyone, Before digging into what it would it take to implement a general solution, I narrowed down the scope to write a fix which makes the query mentioned in the thread work. Here are some findings: - For the temporal join logic, it's not the watermark that matters but having a

Re: Scala : ClassCastException with Kafka Connector and ObjectNode

Hi Till, That solved my issue ! Many many thanks for the solution and for the useful StackOverflow link ! ☺️ Cheers, Sébastien > Le 30 mars 2021 à 18:16, Till Rohrmann a écrit : > > Hi Sebastien, > > I think the Scala compiler infers the most specific type for d

Scala : ClassCastException with Kafka Connector and ObjectNode

thing even if it’s a really basic use-case and code, I’m beginner in Scala. Thanks in advance for your help ! Sebastien

Re: Process stream multiple time with different KeyBy

question was answered in quote some detail : >> https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html >> Best regardsTheo >> Ursprüngliche Nachricht >> Von: Eduardo Winpenny Tejedor >> Datum: Mo., 17. Feb. 2020, 21:07 >> An: Lehuede sebastien

Process stream multiple time with different KeyBy

Hi all, I'm currently working on a Flink Application where I match events against a set of rules. At the beginning I wanted to dynamically create streams following the category of events (Event are JSON formatted and I've a field like "category":"foo" in each event) but I'm stuck by the

Re: [Kerberos] JAAS module content not generated? javax.security.auth.callback.UnsupportedCallbackException: Could not login: the client is being asked for a password, but the Kafka client code does n

/flink/blob/release-1.5.3/flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/JaasModule.java#L74 With `sasl.mechanism=GSSAPI` the connection to Kafka with kerberos authentication succeeds. Regards, Sebastien > On September 11, 2018 at 8:08 AM Sebastien Pereira >

[Kerberos] JAAS module content not generated? javax.security.auth.callback.UnsupportedCallbackException: Could not login: the client is being asked for a password, but the Kafka client code does not c

ile? - We strongly suspect the UnsupportedCallbackException is caused by missing content in the generated JAAS file. Thanks, Sebastien Pereira

Re: Grok and Flink

logs/events in CEF Format, you can just use 'split' in the flatmap function for example. Hope will help. Regards, Sebastien.

Re: Kafka to Flink Avro Deserializer

uot; generated file : *import com.nybble.alpha.AvroDeserializationSchema;* *import com.nybble.alpha.toKafka;* Do i miss something ? Regards, Sebastien. 2018-04-25 11:32 GMT+02:00 Timo Walther <twal...@apache.org>: > Hi Sebastien, > > for me this seems more an Avro issue than a Flink issue. You can i

Kafka to Flink Avro Deserializer

with Avro Deserialization ? I can't find much information about " avro.shaded.com.google.common.util.concurrent.UncheckedExecutionException" Regards, Sebastien.

KafkaJsonTableSource purpose

ities. But when i was looking for a solution to obtain my final result, i came across KafkaJsonTableSource. Does anyone think this can be a good solution for my use case ? I think i will be able to store JSON from Kafka, process data then modify the table and send data to another Kafka, is it correct ? Regards, Sebastien

Flink Kafka connector not exist

afka-0.11_${scala.binary.version}* *${flink.version}* ** And here is the import line in my java file : *import** org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011; * Can anyone could help me with this issue ? Regards, Sebastien

Flink - Kafka Connector

/connectors/kafka.html Can you confirm i will not be able to use latest version of Kafka (1.1.0), Flink 1.4 and this connector to do my test ? The connector is compatible with Kafka 0.11 and under only ? Regards, Sebastien.