[samza] branch master updated (fb7f1b3 -> 4ba15fe)

[ca...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cameronlee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.


    from fb7f1b3  Renaming AbstractContainerAllocator to ContainerAllocator (#1169)
     add 4ba15fe  SAMZA-2335: Remove classloader argument from ReflectionUtil (#1174)

No new revisions were added by this update.

Summary of changes:
 .../samza/coordinator/AzureJobCoordinator.java     |  5 +-
 .../clustermanager/ClusterBasedJobCoordinator.java | 13 ++--
 .../samza/clustermanager/ContainerAllocator.java   | 10 +--
 .../clustermanager/ContainerProcessManager.java    | 20 +++---
 .../apache/samza/config/JobCoordinatorConfig.java  |  4 +-
 .../java/org/apache/samza/config/TaskConfig.java   |  4 +-
 .../container/grouper/stream/SSPGrouperProxy.java  |  8 +--
 .../samza/coordinator/MetadataResourceUtil.java    |  4 +-
 .../apache/samza/execution/LocalJobPlanner.java    |  5 +-
 .../apache/samza/execution/RemoteJobPlanner.java   |  2 +-
 .../org/apache/samza/execution/StreamManager.java  |  5 +-
 .../apache/samza/processor/StreamProcessor.java    |  4 +-
 .../apache/samza/runtime/ContainerLaunchUtil.java  |  1 -
 .../samza/runtime/LocalApplicationRunner.java      | 19 +++---
 .../standalone/PassthroughJobCoordinator.java      |  8 +--
 .../org/apache/samza/storage/StorageRecovery.java  | 12 ++--
 .../java/org/apache/samza/table/TableManager.java  |  8 +--
 .../apache/samza/util/MetricsReporterLoader.java   |  5 +-
 .../java/org/apache/samza/util/ReflectionUtil.java | 34 +++-------
 .../java/org/apache/samza/zk/ZkJobCoordinator.java | 12 ++--
 .../apache/samza/checkpoint/CheckpointTool.scala   |  5 +-
 .../apache/samza/container/SamzaContainer.scala    | 23 +++----
 .../apache/samza/coordinator/JobModelManager.scala | 27 ++++----
 .../apache/samza/job/local/ProcessJobFactory.scala |  7 +--
 .../apache/samza/job/local/ThreadJobFactory.scala  |  8 +--
 .../samza/storage/ContainerStorageManager.java     | 15 ++---
 .../main/scala/org/apache/samza/util/Util.scala    |  8 +--
 .../MockContainerAllocatorWithHostAffinity.java    |  3 +-
 .../MockContainerAllocatorWithoutHostAffinity.java |  2 +-
 .../TestClusterBasedJobCoordinator.java            |  3 +-
 .../TestContainerAllocatorWithHostAffinity.java    | 16 ++---
 .../TestContainerAllocatorWithoutHostAffinity.java |  7 +--
 .../TestContainerProcessManager.java               | 11 ++--
 .../org/apache/samza/config/TestTaskConfig.java    |  6 +-
 .../grouper/stream/TestGroupByPartition.java       |  2 +-
 .../stream/TestGroupBySystemStreamPartition.java   |  3 +-
 .../samza/coordinator/JobModelManagerTestUtil.java |  5 +-
 .../samza/coordinator/TestJobModelManager.java     |  4 +-
 .../coordinator/TestMetadataResourceUtil.java      |  4 +-
 .../samza/execution/TestLocalJobPlanner.java       |  4 +-
 .../samza/execution/TestRemoteJobPlanner.java      |  2 +-
 .../apache/samza/execution/TestStreamManager.java  |  2 +-
 .../samza/runtime/TestLocalApplicationRunner.java  | 12 ++--
 .../org/apache/samza/table/TestTableManager.java   |  4 +-
 .../org/apache/samza/util/TestReflectionUtil.java  | 72 ++++++----------------
 .../org/apache/samza/zk/TestZkJobCoordinator.java  |  3 +-
 .../samza/coordinator/TestJobCoordinator.scala     |  5 +-
 .../samza/storage/TestContainerStorageManager.java |  3 +-
 .../samza/storage/TestTaskStorageManager.scala     |  3 +-
 .../elasticsearch/ElasticsearchSystemFactory.java  |  8 +--
 .../kafka/TestKafkaCheckpointManager.scala         |  2 +-
 .../samza/storage/kv/RocksDbKeyValueReader.java    | 10 ++-
 .../apache/samza/logging/log4j/StreamAppender.java |  6 +-
 .../samza/logging/log4j2/StreamAppender.java       |  6 +-
 .../org/apache/samza/monitor/MonitorLoader.java    |  4 +-
 .../apache/samza/monitor/SamzaMonitorService.java  |  3 +-
 .../apache/samza/rest/SamzaRestApplication.java    |  3 +-
 .../org/apache/samza/rest/SamzaRestService.java    |  4 +-
 .../samza/rest/proxy/job/AbstractJobProxy.java     |  4 +-
 .../samza/rest/proxy/job/SimpleYarnJobProxy.java   |  2 +-
 .../rest/proxy/job/SimpleYarnJobProxyFactory.java  |  2 +-
 .../samza/rest/proxy/task/SamzaTaskProxy.java      |  3 +-
 .../rest/proxy/task/SamzaTaskProxyFactory.java     |  3 +-
 .../apache/samza/rest/resources/JobsResource.java  |  2 +-
 .../apache/samza/rest/resources/TasksResource.java |  3 +-
 .../apache/samza/monitor/TestMonitorService.java   |  2 +-
 .../samza/sql/data/SamzaSqlExecutionContext.java   |  2 +-
 .../sql/runner/SamzaSqlApplicationConfig.java      |  2 +-
 .../test/performance/TestKeyValuePerformance.scala |  2 +-
 .../samza/processor/TestZkStreamProcessorBase.java |  6 +-
 .../processor/TestZkLocalApplicationRunner.java    |  3 +-
 .../test/integration/StreamTaskTestUtil.scala      |  4 +-
 .../samza/tools/benchmark/AbstractSamzaBench.java  |  2 +-
 .../samza/job/yarn/YarnClusterResourceManager.java |  2 +-
 .../samza/validation/YarnJobValidationTool.java    |  2 +-
 .../samza/job/yarn/SamzaAppMasterMetrics.scala     |  6 +-
 .../webapp/TestApplicationMasterRestClient.java    |  3 +-
 .../job/yarn/TestSamzaYarnAppMasterService.scala   |  2 +-
 78 files changed, 210 insertions(+), 345 deletions(-)