Re: TumblingEventTimeWindows with negative offset / Wrong documentation

ssue for it: https://issues.apache.org/jira/browse/FLINK-6214 > > I think it will be solved soon. > > Regards, > Timo > > > Am 29/03/17 um 16:57 schrieb Vladislav Pernin: > > Hi, >> >> The documentation mentions the possibility to use a negative offset with >&g

TumblingEventTimeWindows with negative offset / Wrong documentation

Hi, The documentation mentions the possibility to use a negative offset with a TumblingEventTimeWindows : // daily tumbling event-time windows offset by -8 hours.input .keyBy() .window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8))) .(); But the code will throw an

Re: [jira] [Created] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling state.entries in the open() function

not really feel good. 2017-03-15 11:44 GMT+01:00 Vladislav Pernin (JIRA) <j...@apache.org>: > Vladislav Pernin created FLINK-6061: > --- > > Summary: NPE on TypeSerializer.serialize with a > RocksDBStateBackend calling state.entries i

[jira] [Created] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling state.entries in the open() function

Vladislav Pernin created FLINK-6061: --- Summary: NPE on TypeSerializer.serialize with a RocksDBStateBackend calling state.entries in the open() function Key: FLINK-6061 URL: https://issues.apache.org/jira/browse

Re: [DISCUSS] Release Flink 1.1.5 / Flink 1.2.1

d > > allowedLateness > > > On Tue, Mar 14, 2017, at 18:20, Vladislav Pernin wrote: > > Hi, > > > > I would also include the following (not yet resolved) issue in the 1.2.1 > > scope : > > > > https://issues.apache.org/jira/browse/FLINK-

Re: [DISCUSS] Release Flink 1.1.5 / Flink 1.2.1

Hi, I would also include the following (not yet resolved) issue in the 1.2.1 scope : https://issues.apache.org/jira/browse/FLINK-6001 NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness 2017-03-14 17:34 GMT+01:00 Ufuk Celebi : > Big +1 Gordon! >

Wrong argument used in StreamTask when user-defined backend is used

https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L716 This should be : LOG.info("Using user-defined state backend: {}.", fromJob); Regards, Vladislav

[jira] [Created] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness

Vladislav Pernin created FLINK-6001: --- Summary: NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness Key: FLINK-6001 URL: https://issues.apache.org/jira/browse/FLINK-6001

Re: Failure in flink-storm when building Flink

Could you tell us about the commit which fix it ? I'm trying to have a stable build against an almost up to date master before submitting a PR. Thanks. Le 30 juin 2016 15:41, "Aljoscha Krettek" a écrit : Yes, that's the one I fixed. :-) On Thu, 30 Jun 2016 at 15:40 F.

[jira] [Created] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

Vladislav Pernin created FLINK-4034: --- Summary: Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo Key: FLINK-4034 URL: https://issues.apache.org/jira/browse/FLINK-4034