You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/09/20 22:53:00 UTC
[jira] [Created] (SAMZA-1894) Too many redundant definition of
system configuration variables
Yi Pan (Data Infrastructure) created SAMZA-1894:
---------------------------------------------------
Summary: Too many redundant definition of system configuration variables
Key: SAMZA-1894
URL: https://issues.apache.org/jira/browse/SAMZA-1894
Project: Samza
Issue Type: Improvement
Reporter: Yi Pan (Data Infrastructure)
Quick git grep yields the following:
{quote}
yipan-mn1:samza_master yipan$ git grep 'systems\.%s\.samza.factory'
samza-api/src/main/java/org/apache/samza/operators/descriptors/base/system/SystemDescriptor.java: private static final String FACTORY_CONFIG_KEY = "systems.%s.samza.factory";
samza-aws/src/test/java/org/apache/samza/system/kinesis/TestKinesisSystemFactory.java: private static final String SYSTEM_FACTORY_REGEX = "systems.%s.samza.factory";
samza-test/src/main/java/org/apache/samza/test/framework/system/CollectionStreamSystemSpec.java: * <li>"systems.%s.samza.factory" = {@link InMemorySystemFactory}</li>
samza-test/src/main/java/org/apache/samza/test/framework/system/CollectionStreamSystemSpec.java: * <li>"jobs.job-name-and-id.systems.%s.samza.factory" = {@link InMemorySystemFactory}</li>
samza-test/src/main/java/org/apache/samza/test/framework/system/CollectionStreamSystemSpec.java: private static final String SYSTEM_FACTORY = "systems.%s.samza.factory";
samza-test/src/test/java/org/apache/samza/test/StandaloneTestUtils.java: private static final String SYSTEM_FACTORY_FORMAT_STRING = "systems.%s.samza.factory";
samza-test/src/test/java/org/apache/samza/test/processor/TestZkLocalApplicationRunner.java: .put(String.format("systems.%s.samza.factory", systemName), TEST_SYSTEM_FACTORY)
samza-tools/src/main/java/org/apache/samza/tools/benchmark/AbstractSamzaBench.java: protected static final String CFG_SYSTEM_FACTORY = "systems.%s.samza.factory";
{quote}
Most of the configure prefix and keys are already defined in JavaSystemConfig or SystemConfig. We should keep all those configure prefix and key definitions in a single class.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)