Thanks Robert, it seems like it does work.
So if it is running via local environment context it will just execute
the local executor?
How much is the difference does the flow in local vs cluster?
- Henry
On Wed, Aug 6, 2014 at 6:41 AM, Robert Metzger wrote:
> The dev setup for developing Flink
Fabian Hueske created FLINK-1042:
Summary: Serialization of RuntimeStatefulSerializerFactory causes
exception
Key: FLINK-1042
URL: https://issues.apache.org/jira/browse/FLINK-1042
Project: Flink
Hi All,
Please vote on releasing the following artifacts as Apache Flink 0.6
incubating. This will be the first release for Flink since entering the
Apache Incubator.
The tag to be voted upon:
https://git-wip-us.apache.org/repos/asf?p=incubator-flink.git;a=commit;h=c8585689
The artifacts to be
Hi Norman,
right now it is only possible to use Primitive Types and Case Classes (of
which tuples are a special case) as Scala Data Types. Your program could
work if you omit the second map function and instead put that code in your
first map function. This way you avoid having that custom JSON Typ
