Repository: samza
Updated Branches:
  refs/heads/master 85ecf0a2c -> 964f56e75


SAMZA-897: TaskConfig uses getOrDefault() which is not available in Java 7


Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/964f56e7
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/964f56e7
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/964f56e7

Branch: refs/heads/master
Commit: 964f56e752e0860012dbee4634e21743ef50684c
Parents: 85ecf0a
Author: Jacob Maes <[email protected]>
Authored: Thu Mar 17 14:52:08 2016 -0700
Committer: Navina Ramesh <[email protected]>
Committed: Thu Mar 17 16:55:16 2016 -0700

----------------------------------------------------------------------
 samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/samza/blob/964f56e7/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala 
b/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
index 6ff9aac..08a4deb 100644
--- a/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
+++ b/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
@@ -94,7 +94,7 @@ class TaskConfig(config: Config) extends 
ScalaMapConfig(config) with Logging {
 
   def getCommandClass = getOption(TaskConfig.COMMAND_BUILDER)
 
-  def getCommandClass(defaultValue: String) = 
getOrDefault(TaskConfig.COMMAND_BUILDER, defaultValue)
+  def getCommandClass(defaultValue: String) = 
getOrElse(TaskConfig.COMMAND_BUILDER, defaultValue)
 
   def getCheckpointManagerFactory() = 
getOption(TaskConfig.CHECKPOINT_MANAGER_FACTORY)
 

Reply via email to