Re: Thread 'SortMerger spilling thread' terminated due to an exception: No space left on device

2016-12-04 Thread Fabian Hueske
Hi Miguel, have you found a solution to your problem? I'm not a docker expert but this forum thread looks like could be related to your problem [1]. Best, Fabian [1] https://forums.docker.com/t/no-space-left-on-device-error/10894 2016-12-02 17:43 GMT+01:00 Miguel Coimbra : > Hello Fabian, > >

Flink CEP dynamic patterns

2016-12-04 Thread Abdallah Ghdiri
As suggested by Matthias i am going to post my inquiry to the main thread. Can you please take a look at my question over at stack overflow and see if you have an answer its a quite important aspect of an ongoing project http://stackoverflow.com/questions/40935714/is-it-possible-to-add-new-patterns

Re: microsecond resolution

2016-12-04 Thread jeff jacobson
Wow. Really? Is there a way to do micros? A hack? A Jira story? Most (all?) U.S. equity and European futures, options, and stock markets timestamp in microseconds. This makes Flink unusable for a massive industry vertical. To the extent lower-frequency time-series data is being used (e.g. end of da

Update avro to 1.7.7 or later for flink 1.1.4

2016-12-04 Thread Torok, David
I spent close to two days and tracked down the solution to a major issue with Avro / GenericRecord and Flink. In short, there is a field marked 'transient' in Avro 1.7.6 and earlier which interferes with correct Kryo serialization. This was fixed in Avro 1.7.7, but Flink is dependent on Avro 1

Re: microsecond resolution

2016-12-04 Thread Abdallah Ghdiri
Help Matthias Can you please take a look at my question over at stack overflow and see if you have an answer http://stackoverflow.com/questions/40935714/is-it-possible-to-add-new-patterns-in-flink-cep-after-calling-execute Abdallah. On Dec 4, 2016 11:27 PM, "Matthias J. Sax" wrote: > -BEGIN

Re: microsecond resolution

2016-12-04 Thread Matthias J. Sax
-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Oh. My bad... Did not read your question carefully enough. Than the answer is no, it does not support microseconds (only milliseconds). - -Matthias On 12/4/16 2:22 PM, jeff jacobson wrote: > Sorry if I'm missing something. That link mentions mill

Re: microsecond resolution

2016-12-04 Thread jeff jacobson
Sorry if I'm missing something. That link mentions milliseconds, no? My question is whether or not I can specify microseconds where 1000microseconds = 1millisecond. Thanks! On Sun, Dec 4, 2016 at 5:05 PM, Matthias J. Sax wrote: > Yes. It does. > > See: > https://ci.apache.org/projects/flink/flin

Re: microsecond resolution

2016-12-04 Thread Matthias J. Sax
Yes. It does. See: https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/event_timestamps_watermarks.html#assigning-timestamps "Both timestamps and watermarks are specified as millliseconds since the Java epoch of 1970-01-01T00:00:00Z." -Matthias On 12/04/2016 10:57 AM,

microsecond resolution

2016-12-04 Thread jeff jacobson
I've sourced stackoverflow, the docs, and the web but I can't figure out: does flink support microsecond timestamp resolution? Thanks!