Repository: samza Updated Branches: refs/heads/1.0.0 cfd29c369 -> cebf93c70
Fix samza-test checkstyle errors. Author: Shanthoosh Venkataraman <[email protected]> Reviewers: Yi Pan <[email protected]> Closes #757 from shanthoosh/master (cherry picked from commit 91e54568b5be9f4dbc93245e0d7e40b99aae4aaa) Signed-off-by: Prateek Maheshwari <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/cebf93c7 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/cebf93c7 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/cebf93c7 Branch: refs/heads/1.0.0 Commit: cebf93c70b807d9a0cdbc26e9c8f13dfb74013eb Parents: cfd29c3 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:48 2018 -0700 ---------------------------------------------------------------------- .../test/integration/TestStandaloneIntegrationApplication.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/cebf93c7/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<>());
