[jira] [Created] (FLINK-3307) RMQSourceTest failure

Márton Balassi created FLINK-3307: - Summary: RMQSourceTest failure Key: FLINK-3307 URL: https://issues.apache.org/jira/browse/FLINK-3307 Project: Flink Issue Type: Bug Components: S

[jira] [Created] (FLINK-3306) Auto type registration at Kryo is buggy

Stephan Ewen created FLINK-3306: --- Summary: Auto type registration at Kryo is buggy Key: FLINK-3306 URL: https://issues.apache.org/jira/browse/FLINK-3306 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3305) Remove JavaKaffee serializer util

Stephan Ewen created FLINK-3305: --- Summary: Remove JavaKaffee serializer util Key: FLINK-3305 URL: https://issues.apache.org/jira/browse/FLINK-3305 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode

Sebastian Klemke created FLINK-3304: --- Summary: AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode Key: FLINK-3304 URL: https://issues.apache.org/jira/browse/FLINK-3304 Project: Flink

[jira] [Created] (FLINK-3303) Move all non-batch specific classes in flink-java to flink-core

Stephan Ewen created FLINK-3303: --- Summary: Move all non-batch specific classes in flink-java to flink-core Key: FLINK-3303 URL: https://issues.apache.org/jira/browse/FLINK-3303 Project: Flink

[jira] [Created] (FLINK-3302) Save Taskmanager Metrics per Job

Pieter Hameete created FLINK-3302: - Summary: Save Taskmanager Metrics per Job Key: FLINK-3302 URL: https://issues.apache.org/jira/browse/FLINK-3302 Project: Flink Issue Type: Wish C

Re: How it is used internally Akka framework in Flink?

Hi! This wiki page describes roughly how Flink uses Akka for coordination between JobManager and TaskManager https://cwiki.apache.org/confluence/display/FLINK/Akka+and+Actors Stephan On Fri, Jan 29, 2016 at 9:25 AM, Lorena Reis wrote: > Hi all, > > I'd like to know how it is used internally

How it is used internally Akka framework in Flink?

Hi all, I'd like to know how it is used internally Akka framework in Flink. I just found this https://flink.apache.org/news/2015/06/24/announcing-apache-flink-0.9.0-release.html where it mentions: "Flink’s RPC system has been replaced by the widely adopted Akka framework. Akka...