How did you build Flink?
I'm not so sure if the master is really broken because I've build it
multiple times today, also our Travis says everything is fine:
https://travis-ci.org/apache/flink/builds
On Tue, Feb 24, 2015 at 5:29 PM, Matthias J. Sax <
mj...@informatik.hu-berlin.de> wrote:
> 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);
> > }
>
>
>
