You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2018/10/31 22:01:57 UTC
[4/4] samza git commit: SAMZA-1970: Support for physical names in
InMemorySystem
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 <sa...@gmail.com>
Reviewers: Jagadish<ja...@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/ed8d1da8
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/ed8d1da8
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/ed8d1da8
Branch: refs/heads/1.0.0
Commit: ed8d1da8bdf3dfd9fc2ce49907561105d6429a08
Parents: 5ddbd30
Author: Sanil15 <sa...@gmail.com>
Authored: Wed Oct 31 12:41:40 2018 -0700
Committer: Jagadish <jv...@linkedin.com>
Committed: Wed Oct 31 14:30:39 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/ed8d1da8/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/ed8d1da8/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;
}
}