Hi Kanwarpal, please don't hijack other discussion threads on our mailinglist. I saw your message to the mailing list and I'm sure you'll get an answer to your question.
Robert On Tue, Feb 24, 2015 at 6:56 PM, Kanwarpal Singh <kanwarpal...@gmail.com> wrote: > Hi i am new to Flink,can anyone help me how i can work for this community > > On Tue, Feb 24, 2015 at 11:06 PM, Fabian Hueske <fhue...@gmail.com> wrote: > > > The master builds for me as well. > > Can you try to clone a new copy and do a "mvn -DskipTests clean install"? > > > > 2015-02-24 18:26 GMT+01:00 Matthias J. Sax < > mj...@informatik.hu-berlin.de > > >: > > > > > Hi, > > > > > > I build on command line: > > > > > > mjsax@T420s-dbis-mjsax:~/workspace_flink/flink$ git pull flink master > > > From https://github.com/apache/flink > > > * branch master -> FETCH_HEAD > > > Already up-to-date. > > > > > > The problem is in TEST: > > > > > > > > > flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java > > > > > > I fixed the bug and git diff gives me: > > > > mjsax@T420s-dbis-mjsax:~/workspace_flink/flink$ git diff > > > > > > flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java > > > > diff --git > > > > > > a/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java > > > > > > b/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java > > > > index 155010e..d68afd6 100644 > > > > --- > > > > > > a/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java > > > > +++ > > > > > > b/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoWithCustomSerializersTest.java > > > > @@ -16,7 +16,7 @@ > > > > * limitations under the License. > > > > */ > > > > > > > > -package org.apache.flink.api.java.typeutils.runtime; > > > > +package org.apache.flink.api.java.typeutils.runtime.kryo; > > > > > > > > import java.util.Collection; > > > > import java.util.HashSet; > > > > @@ -25,6 +25,7 @@ import org.apache.flink.api.common.ExecutionConfig; > > > > import org.apache.flink.api.common.typeinfo.TypeInformation; > > > > import org.apache.flink.api.common.typeutils.TypeSerializer; > > > > import org.apache.flink.api.java.typeutils.GenericTypeInfo; > > > > > > > > > > > > As you can see, the class is in .../runtim/kryo/ but the package > > > statement omits the ".kryo" > > > > > > > > > -Matthias > > > > > > > > > > > > > > > On 02/24/2015 05:47 PM, Robert Metzger wrote: > > > > 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); > > > >>> } > > > >> > > > >> > > > >> > > > > > > > > > > > > >
