Re: 1.1.4 IntelliJ Problem

ven or java dependency management at > all. > > best Stephan > >> On 03 Jan 2017, at 22:06, Stephan Ewen <se...@apache.org >> <mailto:se...@apache.org>> wrote: >> >> Hi! >> >> It is probably some inconsistent configuration in the IDE

Re: 1.1.4 IntelliJ Problem

bly some inconsistent configuration in the IDE. > > It often helps to do "Maven->Reimport" or use "restart and clear caches". > > > On Tue, Jan 3, 2017 at 9:48 AM, Stephan Epping <stephan.epp...@zweitag.de > <mailto:stephan.epp...@zweitag.de&

Re: 1.1.4 IntelliJ Problem

> It often helps to do "Maven->Reimport" or use "restart and clear caches". > > > On Tue, Jan 3, 2017 at 9:48 AM, Stephan Epping <stephan.epp...@zweitag.de > <mailto:stephan.epp...@zweitag.de>> wrote: > Hey, > > thanks for the reply.

1.1.4 IntelliJ Problem

Hi, I am getting this error running my tests with 1.1.4 inside intellij ide. java.lang.NoSuchMethodError:

Re: Problem with JodaTime

to fix such an issue, you have to implement a custom serializer > for the field that is causing the issues. > > On Thu, Dec 22, 2016 at 3:44 PM, Stephan Epping <stephan.epp...@zweitag.de > <mailto:stephan.epp...@zweitag.de>> wrote: > Hi, > > I notice

Problem with JodaTime

Hi, I noticed the following Problem with a POJO I use to encapsulate Values. java.lang.NullPointerException at org.joda.time.tz.CachedDateTimeZone.getInfo(CachedDateTimeZone.java:143) at org.joda.time.tz.CachedDateTimeZone.getOffset(CachedDateTimeZone.java:103) at

Re: What is the best way to load/add patterns dynamically (at runtime) with Flink?

I also found this really interesting post http://stackoverflow.com/questions/40018199/flink-and-dynamic-templates-recognition

Re: Cassandra Connector

o's, scala case classes) but we >> did not want the user to be aware of it. This has the neat property that we >> can change the underlying classes >> any way we want (like modifying the constructor) without breaking anything. >> >> Regards, >> Chesnay >>

Re: Maintaining watermarks per key, instead of per operator instance

; > DataStream aggregatesPerHour = readings > .timeWindow(Time.hours(1)) > .allowedLateness(Time.hours(2)) > .apply(new ReadingAggregate(), new AggregateReadings(), new > AggregateReadings()); > > > Feedback is very welcome. > > best, Step

Cassandra Connector

Hello, I wondered why the cassandra connector has such an unusual interface: CassandraSink csink = CassandraSink.addSink(readings) while all other sinks seem to look like RMQSink sink = new RMQSink(cfg, "readings_persist_out", new JSONReadingSchema()); readings.addSink(sink); best, Stephan

Docker

Hi, It would be really nice to have an official docker image (e.g. https://github.com/apache/flink/tree/master/flink-contrib/docker-flink ). Or a least to have a regular image/build on docker hub best, Stephan

Re: Maintaining watermarks per key, instead of per operator instance

> checkpointing mechanism for fault-tolerance. >> >> To me, the stateful FlatMapOperator looks like the best approach. There is >> an upcoming feature for registering timers in user-functions, i.e., a >> function is called after the timer exceeds. This could be he

apply with fold- and window function

Hello, I wondered if there is a particular reason for the window function to have explicitly the same input/output type? public SingleOutputStreamOperator apply(R initialValue, FoldFunction foldFunction, WindowFunction function) for example (the following does not work):

Re: Maintaining watermarks per key, instead of per operator instance

n. > > Best, Fabian > > 2016-11-10 11:01 GMT+01:00 Stephan Epping <stephan.epp...@zweitag.de > <mailto:stephan.epp...@zweitag.de>>: > Hello, > > I found this question in the Nabble archive > (http://apache-flink-user-mailing-list-archive.2336050.n4.nabbl