che.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
>> a TumblingEventTimeWi
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 Illegal
really feel good.
2017-03-15 11:44 GMT+01:00 Vladislav Pernin (JIRA) :
> Vladislav Pernin created FLINK-6061:
> ---
>
> Summary: NPE on TypeSerializer.serialize with a
> RocksDBStateBackend calling state.entries in the
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
>
>
> 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-6001
> > NPE on TumblingEventTimeWind
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!
>
> I think (10) is
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
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
Moreover, that would reduce the build duration.
Le 7 juil. 2016 11:25, "Ufuk Celebi" a écrit :
> Hey Alan,
>
> as Marton said your contribution is more than welcome. :-)
>
> The discussion around moving some contributions outside of the main
> repository did never come to a final conclusion. Ther
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. Beligianni wrote:
> Hi,
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
11 matches
Mail list logo
