You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ni...@apache.org on 2016/12/24 00:13:22 UTC
samza git commit: Fix checkstyle failure
Repository: samza
Updated Branches:
refs/heads/master 965a645d8 -> a47e8819f
Fix checkstyle failure
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/a47e8819
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/a47e8819
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/a47e8819
Branch: refs/heads/master
Commit: a47e8819f2a17d3481bbb3e3230019d6a9cbaa4d
Parents: 965a645
Author: Yi Pan (Data Infrastructure) <ni...@gmail.com>
Authored: Fri Dec 23 16:13:00 2016 -0800
Committer: Yi Pan (Data Infrastructure) <ni...@gmail.com>
Committed: Fri Dec 23 16:13:00 2016 -0800
----------------------------------------------------------------------
.../src/main/java/org/apache/samza/config/JavaStorageConfig.java | 4 ++--
.../test/java/org/apache/samza/config/TestJavaStorageConfig.java | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/a47e8819/samza-core/src/main/java/org/apache/samza/config/JavaStorageConfig.java
----------------------------------------------------------------------
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
index 7480c93..5db94a6 100644
--- 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 class JavaStorageConfig extends MapConfig {
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 class JavaStorageConfig extends MapConfig {
public String getStorageMsgSerde(String storeName) {
return get(String.format(MSG_SERDE, storeName), null);
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/samza/blob/a47e8819/samza-core/src/test/java/org/apache/samza/config/TestJavaStorageConfig.java
----------------------------------------------------------------------
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
index 1f4d74c..cc80430 100644
--- 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 class TestJavaStorageConfig {
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 {