Repository: samza
Updated Branches:
  refs/heads/master ea5887178 -> d16861831


SAMZA-1970: Support for physical names in InMemorySystem

if super is not there, java compiles this to this.withPhysicalName which 
results in StackOverflows

Author: Sanil15 <sanil.jai...@gmail.com>

Reviewers: Jagadish<jagad...@apache.org>

Closes #788 from Sanil15/SAMZA-1970-edit


Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/d1686183
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/d1686183
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/d1686183

Branch: refs/heads/master
Commit: d16861831f3494dfc270664736c612f6be7aeb04
Parents: ea58871
Author: Sanil15 <sanil.jai...@gmail.com>
Authored: Wed Oct 31 12:41:40 2018 -0700
Committer: Jagadish <jvenkatra...@linkedin.com>
Committed: Wed Oct 31 12:41:40 2018 -0700

----------------------------------------------------------------------
 .../test/framework/system/descriptors/InMemoryInputDescriptor.java | 2 +-
 .../framework/system/descriptors/InMemoryOutputDescriptor.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/samza/blob/d1686183/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java
----------------------------------------------------------------------
diff --git 
a/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java
 
b/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java
index f2214de..477c35d 100644
--- 
a/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java
+++ 
b/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java
@@ -41,7 +41,7 @@ public class InMemoryInputDescriptor<StreamMessageType>
   }
 
   public InMemoryInputDescriptor withPhysicalName(String physicalName) {
-    withPhysicalName(physicalName);
+    super.withPhysicalName(physicalName);
     return this;
   }
 }

http://git-wip-us.apache.org/repos/asf/samza/blob/d1686183/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java
----------------------------------------------------------------------
diff --git 
a/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java
 
b/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java
index 7c38aa6..a86e5a1 100644
--- 
a/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java
+++ 
b/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java
@@ -45,7 +45,7 @@ public class InMemoryOutputDescriptor<StreamMessageType>
   }
 
   public InMemoryOutputDescriptor withPhysicalName(String physicalName) {
-    withPhysicalName(physicalName);
+    super.withPhysicalName(physicalName);
     return this;
   }
 }

Reply via email to