Repository: samza Updated Branches: refs/heads/master 738410392 -> 91e54568b
Fix samza-test checkstyle errors. Author: Shanthoosh Venkataraman <[email protected]> Reviewers: Yi Pan <[email protected]> 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 <[email protected]> Authored: Tue Oct 23 08:43:37 2018 -0700 Committer: Prateek Maheshwari <[email protected]> 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<>());
