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; } }
