You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by xi...@apache.org on 2016/10/19 18:38:13 UTC
samza git commit: SAMZA-1040: Revert the ClassLoaderHelper change in
SamzaContainer
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 <xi...@apache.org>
Authored: Wed Oct 19 11:27:50 2016 -0700
Committer: Xinyu Liu <xi...@apache.org>
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