Fix checkstyle failure

chrisbu · Dec 24, 2016 · a47e881 · a47e881
1 parent 965a645
commit a47e881
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/samza-core/src/main/java/org/apache/samza/config/JavaStorageConfig.java b/samza-core/src/main/java/org/apache/samza/config/JavaStorageConfig.java
@@ -61,7 +61,7 @@ public String getChangelogStream(String storeName) {
     String changelogSystem = get(CHANGELOG_SYSTEM, null);
 
     String systemStreamRes;
-    if (systemStream != null  && ! systemStream.contains(".")) {
+    if (systemStream != null  && !systemStream.contains(".")) {
       // contains only stream name
       if (changelogSystem != null) {
         systemStreamRes = changelogSystem + "." + systemStream;
@@ -85,4 +85,4 @@ public String getStorageKeySerde(String storeName) {
   public String getStorageMsgSerde(String storeName) {
     return get(String.format(MSG_SERDE, storeName), null);
   }
-}
+}
diff --git a/samza-core/src/test/java/org/apache/samza/config/TestJavaStorageConfig.java b/samza-core/src/test/java/org/apache/samza/config/TestJavaStorageConfig.java
@@ -58,7 +58,7 @@ public void testIsChangelogSystemSetting() {
     assertEquals("system2.stream2", config.getChangelogStream("store2"));
 
     Map<String, String> configMapErr = new HashMap<>();
-    configMapErr.put("stores.store4.changelog","stream4"); // incorrect
+    configMapErr.put("stores.store4.changelog", "stream4"); // incorrect
     JavaStorageConfig configErr = new JavaStorageConfig(new MapConfig(configMapErr));
 
     try {