Re: [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time)

Aljoscha, thanks for starting this discussion. I think this will be very important to get right. Can you explain a bit more why the results are "wrong"? I understand that window panes are built on event timestamps (as intended), but fired at regular intervals instead of watermarks. Why is this

Re: [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time)

Hi Aljoscha, I'm in favor of option 2: Keep the setStreamTimeCharacteristic to set the default time behavior. Then add a method to the operators to set a custom time behavior. The problem explanatory in SlidingTimeWindows: @Override public Trigger

Re: No job recovery after job manager failure

As an update: I’m investigating this. Ali sent me the log files. > On 16 Dec 2015, at 18:15, Ufuk Celebi wrote: > > Hey Ali, > > can you send me the complete logs? > > I don’t think it’s possible via the mailing list. Just send it to my private > email u...@apache.org. > >

[jira] [Created] (FLINK-3181) The vertex-centric SSSP example and library method send unnecessary messages during the first superstep

Vasia Kalavri created FLINK-3181: Summary: The vertex-centric SSSP example and library method send unnecessary messages during the first superstep Key: FLINK-3181 URL:

Re: Flink shell in Jupyter

I think Till has done some advanced Pythin / Flink / Zeppelin integration (to use Python plotting libs) for a talk at some point. @Till: Do you still have the code? Could you share it with Gyula? On Wed, Dec 16, 2015 at 4:22 PM, Gyula Fóra wrote: > Hey Guys, > > Has anyone

Re: Flink shell in Jupyter

That would be awesome, I think it would be fine to go for Scala 2.11 first in the notebook, if Python is more trouble. Gyula Stephan Ewen ezt írta (időpont: 2015. dec. 17., Cs, 14:17): > I think Till has done some advanced Pythin / Flink / Zeppelin integration > (to use

[jira] [Created] (FLINK-3183) Display direct memory stats in web frontend

Ufuk Celebi created FLINK-3183: -- Summary: Display direct memory stats in web frontend Key: FLINK-3183 URL: https://issues.apache.org/jira/browse/FLINK-3183 Project: Flink Issue Type:

[jira] [Created] (FLINK-3182) TaskManagersHandler can block web frontend

Ufuk Celebi created FLINK-3182: -- Summary: TaskManagersHandler can block web frontend Key: FLINK-3182 URL: https://issues.apache.org/jira/browse/FLINK-3182 Project: Flink Issue Type: Bug

Re: Flink shell in Jupyter

@Gyula if you want to delegate something small this interests me too. Best, Tanya On Thu, Dec 17, 2015 at 9:04 AM, Till Rohrmann wrote: > The only thing I did was to use the Py4J bridge to ship data between the > Scala and the Python process. That way, I could visualize

[jira] [Created] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

Till Rohrmann created FLINK-3184: Summary: Decrease Akka timeouts on cluster side to make system more responsive Key: FLINK-3184 URL: https://issues.apache.org/jira/browse/FLINK-3184 Project: Flink

[jira] [Created] (FLINK-3180) MemoryLogger does not log direct memory

Ufuk Celebi created FLINK-3180: -- Summary: MemoryLogger does not log direct memory Key: FLINK-3180 URL: https://issues.apache.org/jira/browse/FLINK-3180 Project: Flink Issue Type: Bug