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/23 15:43:42 UTC
samza git commit: Fix samza-test checkstyle errors.
Repository: samza
Updated Branches:
refs/heads/master 738410392 -> 91e54568b
Fix samza-test checkstyle errors.
Author: Shanthoosh Venkataraman <sv...@linkedin.com>
Reviewers: Yi Pan <ni...@gmail.com>
Closes #757 from shanthoosh/master
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/91e54568
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/91e54568
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/91e54568
Branch: refs/heads/master
Commit: 91e54568b5be9f4dbc93245e0d7e40b99aae4aaa
Parents: 7384103
Author: Shanthoosh Venkataraman <sv...@linkedin.com>
Authored: Tue Oct 23 08:43:37 2018 -0700
Committer: Prateek Maheshwari <pm...@apache.org>
Committed: Tue Oct 23 08:43:37 2018 -0700
----------------------------------------------------------------------
.../test/integration/TestStandaloneIntegrationApplication.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/91e54568/samza-test/src/main/java/org/apache/samza/test/integration/TestStandaloneIntegrationApplication.java
----------------------------------------------------------------------
diff --git a/samza-test/src/main/java/org/apache/samza/test/integration/TestStandaloneIntegrationApplication.java b/samza-test/src/main/java/org/apache/samza/test/integration/TestStandaloneIntegrationApplication.java
index fba3b52..56618a1 100644
--- a/samza-test/src/main/java/org/apache/samza/test/integration/TestStandaloneIntegrationApplication.java
+++ b/samza-test/src/main/java/org/apache/samza/test/integration/TestStandaloneIntegrationApplication.java
@@ -40,8 +40,8 @@ public class TestStandaloneIntegrationApplication implements StreamApplication {
public void describe(StreamApplicationDescriptor appDescriptor) {
String systemName = "testSystemName";
String inputStreamName = appDescriptor.getConfig().get("input.stream.name");
- String outputStreamName = "standaloneIntegrationTestKafkaOutputTopic";
- LOGGER.info("Publishing message from: {} to: {}.", inputStreamName, outputStreamName);
+ String outputStreamName = "standaloneIntegrationTestKafkaOutputTopic";
+ LOGGER.info("Publishing message from: {} to: {}.", inputStreamName, outputStreamName);
KafkaSystemDescriptor kafkaSystemDescriptor = new KafkaSystemDescriptor(systemName);
KVSerde<Object, Object> noOpSerde = KVSerde.of(new NoOpSerde<>(), new NoOpSerde<>());