Re: [DISCUSS] Drop Scala 2.11

2.4 because that is the last > version > > with scala 2.11 support. > > > > What are people's thoughts on dropping Scala 2.11? How many are still > using > > it in production? > > > > Seth > > > > -- Matthieu Bonneviot Senior R&D Eng

flink runtime incompatibility with java 9 or above due to akka version

esolveCache.scala:61) This error is due to a code optimization done in akka which is not working anymore from java 9. I have open an issue for more details: https://issues.apache.org/jira/browse/FLINK-11431 Are you facing the same issue? Regards Matthieu Bonneviot -- Matthieu Bonneviot Senior

[jira] [Created] (FLINK-11431) Akka dependency not compatible with java 9 or above

Matthieu Bonneviot created FLINK-11431: -- Summary: Akka dependency not compatible with java 9 or above Key: FLINK-11431 URL: https://issues.apache.org/jira/browse/FLINK-11431 Project: Flink

Re: issue in the MetricReporterRegistry

ira/browse/FLINK-11413 Project: Flink Issue Type: Bug Components: Configuration Affects Versions: 1.7.1 I will have time to fix it and submit a PR. Regards Matthieu Bonneviot Le mer. 23 janv. 2019 à 10:41, Chesnay Schepler a écrit : > nvm, it does

Re: Applying for Flink contributor permission

Thanks a lot Le mer. 23 janv. 2019 à 10:06, Robert Metzger a écrit : > Hey Matthieu, > > welcome to the Flink community! > I've added you as a contributor to our JIRA! Happy coding :) > > > > On Wed, Jan 23, 2019 at 9:39 AM Matthieu Bonneviot < > matthieu.bon

[jira] [Created] (FLINK-11413) MetricReporter: "metrics.reporters" configuration has to be provided for reporters to be taken into account

Matthieu Bonneviot created FLINK-11413: -- Summary: MetricReporter: "metrics.reporters" configuration has to be provided for reporters to be taken into account Key: FLINK-11413 URL: https://issues.

Applying for Flink contributor permission

Hi Please provide me contribution permission. email: matthieu.bonnev...@datadome.co apache-username: mbonneviot Thank you

issue in the MetricReporterRegistry

t includedReporters = reporterListPattern.splitAsStream(includedReportersString).*filter(s -> !s.isEmpty())*.collect(Collectors.toSet()); Regards Matthieu Bonneviot -- Matthieu Bonneviot Senior Engineer, DataDome M +33 7 68 29 79 34 <+33+7+68+29+79+34> E matthieu.bonnev...@datadome.co W www.dat

Re: Enrich testing doc with more unit test examples using AbstractStreamOperator

as push to kafka. The interface does not describe the behavior and so the test mocking a SinkFunction generating an exception. The new code for the decorator and the test are much more complicated as it is not using interface but several class extension. Regards Matthieu Bonneviot Le lun. 8 oct. 2018