Hi, I just pulled the latest version "flink master" and I got a compilation error. I tracked the bug down. It seems that the following commit moved a class without changing the package statement...
Cheers,
Matthias
commit 354efec0f9da0fa03ea9b337b02a1a2a03a9ac16
Author: Robert Metzger <rmetz...@apache.org> 2015-01-26 17:54:25
Committer: Robert Metzger <rmetz...@apache.org> 2015-02-18 15:52:08
Parent: 7407076d3990752eb5fa4072cd036efd2f656cbc ([FLINK-1369] [types]
Add support for Subclasses, Interfaces, Abstract Classes.)
Branches: master, flink/master
[FLINK-1417] Automatically register types with Kryo
> diff --git
> a/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/KryoWithCustomSerializersTest.java
>
> b/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java
> similarity index 96%
> rename from
> flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/KryoWithCustomSerializersTest.java
> rename to
> flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java
> index 7020d80..155010e 100644
> ---
> a/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/KryoWithCustomSerializersTest.java
> +++
> b/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java
> @@ -50,7 +50,7 @@
> @Override
> protected <T> TypeSerializer<T> createSerializer(Class<T> type) {
> ExecutionConfig conf = new ExecutionConfig();
> - conf.registerKryoSerializer(LocalDate.class,
> LocalDateSerializer.class);
> + conf.registerTypeWithKryoSerializer(LocalDate.class,
> LocalDateSerializer.class);
> TypeInformation<T> typeInfo = new GenericTypeInfo<T>(type);
> return typeInfo.createSerializer(conf);
> }
signature.asc
Description: OpenPGP digital signature
