Repository: samza Updated Branches: refs/heads/master d5bded34e -> eed44d52e
SAMZA-1040: Revert the ClassLoaderHelper change in SamzaContainer Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/eed44d52 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/eed44d52 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/eed44d52 Branch: refs/heads/master Commit: eed44d52e19883c2bbdbafa2278681121b11a71a Parents: d5bded3 Author: Xinyu Liu <[email protected]> Authored: Wed Oct 19 11:27:50 2016 -0700 Committer: Xinyu Liu <[email protected]> Committed: Wed Oct 19 11:27:50 2016 -0700 ---------------------------------------------------------------------- .../main/scala/org/apache/samza/container/SamzaContainer.scala | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/eed44d52/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala index 05a996c..4ab4bce 100644 --- a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala +++ b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala @@ -74,7 +74,6 @@ import org.apache.samza.task.AsyncStreamTask import org.apache.samza.task.AsyncStreamTaskAdapter import org.apache.samza.task.StreamTask import org.apache.samza.task.TaskInstanceCollector -import org.apache.samza.util.ClassLoaderHelper import org.apache.samza.util.ExponentialSleepStrategy import org.apache.samza.util.Logging import org.apache.samza.util.ThrottlingExecutor @@ -442,11 +441,11 @@ object SamzaContainer extends Logging { val taskName = taskModel.getTaskName - val taskObj = ClassLoaderHelper.fromClassName[StreamTask](taskClassName) + val taskObj = Class.forName(taskClassName).newInstance val task = if (!singleThreadMode && !isAsyncTask) // Wrap the StreamTask into a AsyncStreamTask with the build-in thread pool - new AsyncStreamTaskAdapter(taskObj, taskThreadPool) + new AsyncStreamTaskAdapter(taskObj.asInstanceOf[StreamTask], taskThreadPool) else taskObj
