Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 7E2BD200B71 for ; Wed, 31 Aug 2016 19:28:21 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 7C9F3160AD3; Wed, 31 Aug 2016 17:28:21 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 9BC14160AA7 for ; Wed, 31 Aug 2016 19:28:20 +0200 (CEST) Received: (qmail 25911 invoked by uid 500); 31 Aug 2016 17:28:19 -0000 Mailing-List: contact commits-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list commits@flink.apache.org Received: (qmail 25899 invoked by uid 99); 31 Aug 2016 17:28:19 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 31 Aug 2016 17:28:19 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id B043AE00D6; Wed, 31 Aug 2016 17:28:19 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: aljoscha@apache.org To: commits@flink.apache.org Date: Wed, 31 Aug 2016 17:28:19 -0000 Message-Id: <269a6aa1f4e74350a6152149f78faed9@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [01/27] flink git commit: [FLINK-4380] Introduce KeyGroupAssigner and Max-Parallelism Parameter archived-at: Wed, 31 Aug 2016 17:28:21 -0000 Repository: flink Updated Branches: refs/heads/master 7cd9bb5f1 -> bdf9f86c5 http://git-wip-us.apache.org/repos/asf/flink/blob/ec975aab/flink-tests/src/test/java/org/apache/flink/test/streaming/api/StreamingOperatorsITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/streaming/api/StreamingOperatorsITCase.java b/flink-tests/src/test/java/org/apache/flink/test/streaming/api/StreamingOperatorsITCase.java index 5d99de4..3b98d33 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/streaming/api/StreamingOperatorsITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/streaming/api/StreamingOperatorsITCase.java @@ -78,16 +78,20 @@ public class StreamingOperatorsITCase extends StreamingMultipleProgramsTestBase final int numKeys = 2; StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); + DataStream> sourceStream = env.addSource(new TupleSource(numElements, numKeys)); SplitStream> splittedResult = sourceStream .keyBy(0) .fold(0, new FoldFunction, Integer>() { + private static final long serialVersionUID = 4875723041825726082L; + @Override public Integer fold(Integer accumulator, Tuple2 value) throws Exception { return accumulator + value.f1; } }).map(new RichMapFunction>() { + private static final long serialVersionUID = 8538355101606319744L; int key = -1; @Override public Tuple2 map(Integer value) throws Exception { @@ -97,6 +101,8 @@ public class StreamingOperatorsITCase extends StreamingMultipleProgramsTestBase return new Tuple2<>(key, value); } }).split(new OutputSelector>() { + private static final long serialVersionUID = -8439325199163362470L; + @Override public Iterable select(Tuple2 value) { List output = new ArrayList<>(); @@ -107,6 +113,8 @@ public class StreamingOperatorsITCase extends StreamingMultipleProgramsTestBase }); splittedResult.select("0").map(new MapFunction, Integer>() { + private static final long serialVersionUID = 2114608668010092995L; + @Override public Integer map(Tuple2 value) throws Exception { return value.f1; @@ -114,6 +122,8 @@ public class StreamingOperatorsITCase extends StreamingMultipleProgramsTestBase }).writeAsText(resultPath1, FileSystem.WriteMode.OVERWRITE); splittedResult.select("1").map(new MapFunction, Integer>() { + private static final long serialVersionUID = 5631104389744681308L; + @Override public Integer map(Tuple2 value) throws Exception { return value.f1; @@ -149,6 +159,7 @@ public class StreamingOperatorsITCase extends StreamingMultipleProgramsTestBase final int numElements = 10; StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); + DataStream> input = env.addSource(new NonSerializableTupleSource(numElements)); input @@ -156,12 +167,16 @@ public class StreamingOperatorsITCase extends StreamingMultipleProgramsTestBase .fold( new NonSerializable(42), new FoldFunction, NonSerializable>() { + private static final long serialVersionUID = 2705497830143608897L; + @Override public NonSerializable fold(NonSerializable accumulator, Tuple2 value) throws Exception { return new NonSerializable(accumulator.value + value.f1.value); } }) .map(new MapFunction() { + private static final long serialVersionUID = 6906984044674568945L; + @Override public Integer map(NonSerializable value) throws Exception { return value.value; @@ -192,6 +207,7 @@ public class StreamingOperatorsITCase extends StreamingMultipleProgramsTestBase } private static class NonSerializableTupleSource implements SourceFunction> { + private static final long serialVersionUID = 3949171986015451520L; private final int numElements; public NonSerializableTupleSource(int numElements) { @@ -212,6 +228,7 @@ public class StreamingOperatorsITCase extends StreamingMultipleProgramsTestBase private static class TupleSource implements SourceFunction> { + private static final long serialVersionUID = -8110466235852024821L; private final int numElements; private final int numKeys; http://git-wip-us.apache.org/repos/asf/flink/blob/ec975aab/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/DataStreamPojoITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/DataStreamPojoITCase.java b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/DataStreamPojoITCase.java index c345b37..cc8b699 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/DataStreamPojoITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/DataStreamPojoITCase.java @@ -59,6 +59,7 @@ public class DataStreamPojoITCase extends StreamingMultipleProgramsTestBase { .sum("sum") .keyBy("aaa", "abc", "wxyz") .flatMap(new FlatMapFunction() { + private static final long serialVersionUID = 788865239171396315L; Data[] first = new Data[3]; @Override public void flatMap(Data value, Collector out) throws Exception { @@ -105,6 +106,7 @@ public class DataStreamPojoITCase extends StreamingMultipleProgramsTestBase { .sum("sum") .keyBy("aaa", "stats.count") .flatMap(new FlatMapFunction() { + private static final long serialVersionUID = -3678267280397950258L; Data[] first = new Data[3]; @Override public void flatMap(Data value, Collector out) throws Exception { http://git-wip-us.apache.org/repos/asf/flink/blob/ec975aab/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/TimestampITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/TimestampITCase.java b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/TimestampITCase.java index d69c140..d693aaa 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/TimestampITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/TimestampITCase.java @@ -46,6 +46,7 @@ import org.apache.flink.streaming.runtime.streamrecord.StreamRecord; import org.apache.flink.test.util.ForkableFlinkMiniCluster; import org.apache.flink.util.TestLogger; +import org.apache.flink.util.TestLogger; import org.junit.AfterClass; import org.junit.Assert; import org.junit.Before; http://git-wip-us.apache.org/repos/asf/flink/blob/ec975aab/flink-tests/src/test/java/org/apache/flink/test/web/WebFrontendITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/web/WebFrontendITCase.java b/flink-tests/src/test/java/org/apache/flink/test/web/WebFrontendITCase.java index 032c8fe..fc90994 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/web/WebFrontendITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/web/WebFrontendITCase.java @@ -36,6 +36,7 @@ import org.apache.flink.runtime.webmonitor.testutils.HttpTestClient; import org.apache.flink.test.util.ForkableFlinkMiniCluster; import org.apache.flink.test.util.TestBaseUtils; +import org.apache.flink.util.TestLogger; import org.junit.BeforeClass; import org.junit.Test; @@ -56,7 +57,7 @@ import static org.junit.Assert.fail; import static org.apache.flink.test.util.TestBaseUtils.getFromHTTP; -public class WebFrontendITCase { +public class WebFrontendITCase extends TestLogger { private static final int NUM_TASK_MANAGERS = 2; private static final int NUM_SLOTS = 4;