GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/364
Port FLINK-1391 and FLINK-1392 to "release-0.8" branch.
These commits port the fixes for the two issues (Avro and Protobuf support)
to the release-0.8 branch.
They also contain a hotfix regarding the closure cleaner by @aljoscha.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink kryo081
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/364.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #364
----
commit 38ebc09ff5782005c5aa1f60b458cae250b8c26e
Author: Robert Metzger <[email protected]>
Date: 2015-01-12T20:11:09Z
[FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo
Conflicts:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
Conflicts:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
commit cbe633537567cc39a9877125e79cd7da49ee7f3b
Author: Robert Metzger <[email protected]>
Date: 2015-01-13T09:21:29Z
[FLINK-1392] Add Kryo serializer for Protobuf
Conflicts:
flink-java/pom.xml
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
Conflicts:
flink-shaded/pom.xml
pom.xml
commit 63472baff1fca18b83666831effe2204606cf355
Author: Aljoscha Krettek <[email protected]>
Date: 2015-01-15T10:46:53Z
[hotfix] Also use java closure cleaner on grouped operations
commit 9043582a4a1f4fd25e960217a99f3f32d4ba18a9
Author: Robert Metzger <[email protected]>
Date: 2015-02-05T13:07:48Z
[backports] Cleanup and port changes to 0.8 branch.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
