You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by pm...@apache.org on 2018/10/12 19:17:52 UTC
samza git commit: Fix broken tests on master.
Repository: samza
Updated Branches:
refs/heads/master 17113e163 -> 954fb25e7
Fix broken tests on master.
Author: Prateek Maheshwari <pm...@apache.org>
Reviewers: Prateek Maheshwari <pm...@apache.org>
Closes #722 from prateekm/test-fixes
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/954fb25e
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/954fb25e
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/954fb25e
Branch: refs/heads/master
Commit: 954fb25e72b392f4ec4baeeba0d7f8e638ca0d06
Parents: 17113e1
Author: Prateek Maheshwari <pm...@apache.org>
Authored: Fri Oct 12 12:17:48 2018 -0700
Committer: Prateek Maheshwari <pm...@apache.org>
Committed: Fri Oct 12 12:17:48 2018 -0700
----------------------------------------------------------------------
.../samza/test/framework/StreamApplicationIntegrationTest.java | 2 +-
.../org/apache/samza/test/framework/StreamTaskIntegrationTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/954fb25e/samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTest.java
----------------------------------------------------------------------
diff --git a/samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTest.java b/samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTest.java
index 1dda302..6188381 100644
--- a/samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTest.java
+++ b/samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTest.java
@@ -66,7 +66,7 @@ public class StreamApplicationIntegrationTest {
InMemoryInputDescriptor<TestTableData.Profile> profileStreamDesc = isd
.getInputDescriptor("Profile", new NoOpSerde<TestTableData.Profile>())
- .withBootstrap(true);
+ .shouldBootstrap();
InMemoryOutputDescriptor<TestTableData.EnrichedPageView> outputStreamDesc = isd
.getOutputDescriptor("EnrichedPageView", new NoOpSerde<>());
http://git-wip-us.apache.org/repos/asf/samza/blob/954fb25e/samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.java
----------------------------------------------------------------------
diff --git a/samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.java b/samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.java
index f778704..003b200 100644
--- a/samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.java
+++ b/samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.java
@@ -73,7 +73,7 @@ public class StreamTaskIntegrationTest {
InMemoryInputDescriptor<TestTableData.Profile> profileStreamDesc = isd
.getInputDescriptor("Profile", new NoOpSerde<TestTableData.Profile>())
- .withBootstrap(true);
+ .shouldBootstrap();
InMemoryOutputDescriptor<TestTableData.EnrichedPageView> outputStreamDesc = isd
.getOutputDescriptor("EnrichedPageView", new NoOpSerde<>());