Repository: samza Updated Branches: refs/heads/master e6049b7dd -> 5f81b8d13
TestExecutionPlanner compilation error Author: Boris S <[email protected]> Author: Boris Shkolnik <[email protected]> Reviewers: Xinyu Liu <[email protected]> Closes #337 from sborya/TestExecutionPlannerCompilationError Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/5f81b8d1 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/5f81b8d1 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/5f81b8d1 Branch: refs/heads/master Commit: 5f81b8d13aa9650ea64e340aedae797ea6f200fa Parents: e6049b7 Author: Boris S <[email protected]> Authored: Tue Oct 24 18:43:51 2017 -0700 Committer: Boris S <[email protected]> Committed: Tue Oct 24 18:43:51 2017 -0700 ---------------------------------------------------------------------- build.gradle | 1 + .../org/apache/samza/execution/TestExecutionPlanner.java | 8 ++++---- 2 files changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/5f81b8d1/build.gradle ---------------------------------------------------------------------- diff --git a/build.gradle b/build.gradle index 7ff75ec..3a6f9b6 100644 --- a/build.gradle +++ b/build.gradle @@ -89,6 +89,7 @@ rat { 'samza-hdfs/src/main/resources/**', 'samza-hdfs/src/test/resources/**', 'out/**', + 'hs_err_pid*.log', 'state/**' ] } http://git-wip-us.apache.org/repos/asf/samza/blob/5f81b8d1/samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java ---------------------------------------------------------------------- diff --git a/samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java b/samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java index d98cc72..ab20bba 100644 --- a/samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java +++ b/samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java @@ -177,12 +177,12 @@ public class TestExecutionPlanner { OutputStream<KV<Object, Object>> output2 = streamGraph.getOutputStream("output2"); messageStream1.map(m -> m) - .filter(m->true) - .window(Windows.keyedTumblingWindow(m -> m, Duration.ofMillis(8), mock(Serde.class), mock(Serde.class))); + .filter(m -> true) + .window(Windows.<KV<Object, Object>, Object>keyedTumblingWindow(m -> m, Duration.ofMillis(8), mock(Serde.class), mock(Serde.class))); messageStream2.map(m -> m) - .filter(m->true) - .window(Windows.keyedTumblingWindow(m -> m, Duration.ofMillis(16), mock(Serde.class), mock(Serde.class))); + .filter(m -> true) + .window(Windows.<KV<Object, Object>, Object>keyedTumblingWindow(m -> m, Duration.ofMillis(16), mock(Serde.class), mock(Serde.class))); messageStream1 .join(messageStream2, mock(JoinFunction.class),
