add user's resource request config
refactor code
Merge branch 'master' into scheduler

Conflicts:
	core/src/main/scala/org/apache/gearpump/cluster/AppManager.scala
	core/src/main/scala/org/apache/gearpump/scheduler/PriorityScheduler.scala
	core/src/main/scala/org/apache/gearpump/scheduler/Resource.scala
	core/src/main/scala/org/apache/gearpump/scheduler/Scheduler.scala
	core/src/main/scala/org/apache/gearpump/util/Configs.scala
	src/main/scala/org/apache/gearpump/cluster/scheduler/PriorityScheduler.scala
	src/main/scala/org/apache/gearpump/cluster/scheduler/Resource.scala
	src/main/scala/org/apache/gearpump/cluster/scheduler/Scheduler.scala
	src/main/scala/org/apache/gearpump/scheduler/PriorityScheduler.scala
	src/main/scala/org/apache/gearpump/scheduler/Resource.scala
	src/main/scala/org/apache/gearpump/scheduler/Scheduler.scala
Merge pull request #74 from intel-hadoop/master

sync with master
Merge pull request #75 from clockfly/master

task recovery
Merge pull request #77 from clockfly/master

fix recovery bug
load kafka configuration only once
Merge branch 'master' into scheduler

Conflicts:
	core/src/main/scala/org/apache/gearpump/cluster/Worker.scala
	core/src/main/scala/org/apache/gearpump/cluster/scheduler/PriorityScheduler.scala
	core/src/main/scala/org/apache/gearpump/cluster/scheduler/Scheduler.scala
	core/src/main/scala/org/apache/gearpump/util/Configs.scala
	core/src/main/scala/org/apache/gearpump/util/Constants.scala
	streaming/src/main/scala/org/apache/gearpump/streaming/AppMaster.scala
	streaming/src/main/scala/org/apache/gearpump/streaming/ClusterMessage.scala
add Grouper, KafkaConsumer and fix configuration bugs
add license header
Merge pull request #80 from manuzhang/at_least_once

add multi-topic support to KafkaSpout
revert WorkerInfo changes
Merge branch 'master' into scheduler

Conflicts:
	streaming/src/main/scala/org/apache/gearpump/streaming/AppMaster.scala
	streaming/src/main/scala/org/apache/gearpump/streaming/ClusterMessage.scala
	streaming/src/main/scala/org/apache/gearpump/streaming/Executor.scala
refactor AppMaster
periodically checkpoint messages and timestamp to Kafka
Merge pull request #81 from manuzhang/at_least_once

periodically checkpoint messages and timestamp to Kafka
start consuming from checkpoints
Merge branch 'at_least_once' of https://github.com/manuzhang/gearpump into at_least_once
move throughput metrics to KafkaBolt
fix resource never return back