You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@griffin.apache.org by gu...@apache.org on 2019/07/27 00:57:05 UTC
[griffin] branch master updated: Fix some spelling error
This is an automated email from the ASF dual-hosted git repository.
guoyp pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/griffin.git
The following commit(s) were added to refs/heads/master by this push:
new c189a2e Fix some spelling error
c189a2e is described below
commit c189a2eef8a0c85778769ab3d5c61e7fda048e67
Author: wankunde <wa...@163.com>
AuthorDate: Sat Jul 27 08:56:43 2019 +0800
Fix some spelling error
Minor changes，fix some spelling error.
Author: wankunde <wa...@163.com>
Closes #516 from wankunde/master.
---
.../main/scala/org/apache/griffin/measure/launch/batch/BatchDQApp.scala | 2 +-
.../org/apache/griffin/measure/launch/streaming/StreamingDQApp.scala | 2 +-
.../scala/org/apache/griffin/measure/step/transform/TransformStep.scala | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/measure/src/main/scala/org/apache/griffin/measure/launch/batch/BatchDQApp.scala b/measure/src/main/scala/org/apache/griffin/measure/launch/batch/BatchDQApp.scala
index fe03508..4c8e7b9 100644
--- a/measure/src/main/scala/org/apache/griffin/measure/launch/batch/BatchDQApp.scala
+++ b/measure/src/main/scala/org/apache/griffin/measure/launch/batch/BatchDQApp.scala
@@ -57,7 +57,7 @@ case class BatchDQApp(allParam: GriffinConfig) extends DQApp {
conf.setAll(sparkParam.getConfig)
conf.set("spark.sql.crossJoin.enabled", "true")
sparkSession = SparkSession.builder().config(conf).enableHiveSupport().getOrCreate()
- var logLevel = getGriffinLogLevel()
+ val logLevel = getGriffinLogLevel()
sparkSession.sparkContext.setLogLevel(sparkParam.getLogLevel)
griffinLogger.setLevel(logLevel)
sqlContext = sparkSession.sqlContext
diff --git a/measure/src/main/scala/org/apache/griffin/measure/launch/streaming/StreamingDQApp.scala b/measure/src/main/scala/org/apache/griffin/measure/launch/streaming/StreamingDQApp.scala
index 502f8cb..e80ac61 100644
--- a/measure/src/main/scala/org/apache/griffin/measure/launch/streaming/StreamingDQApp.scala
+++ b/measure/src/main/scala/org/apache/griffin/measure/launch/streaming/StreamingDQApp.scala
@@ -63,7 +63,7 @@ case class StreamingDQApp(allParam: GriffinConfig) extends DQApp {
conf.setAll(sparkParam.getConfig)
conf.set("spark.sql.crossJoin.enabled", "true")
sparkSession = SparkSession.builder().config(conf).enableHiveSupport().getOrCreate()
- var logLevel = getGriffinLogLevel()
+ val logLevel = getGriffinLogLevel()
sparkSession.sparkContext.setLogLevel(sparkParam.getLogLevel)
griffinLogger.setLevel(logLevel)
sqlContext = sparkSession.sqlContext
diff --git a/measure/src/main/scala/org/apache/griffin/measure/step/transform/TransformStep.scala b/measure/src/main/scala/org/apache/griffin/measure/step/transform/TransformStep.scala
index 8c094b2..b3318ba 100644
--- a/measure/src/main/scala/org/apache/griffin/measure/step/transform/TransformStep.scala
+++ b/measure/src/main/scala/org/apache/griffin/measure/step/transform/TransformStep.scala
@@ -44,7 +44,7 @@ trait TransformStep extends DQStep {
def execute(context: DQContext): Boolean = {
val threadName = Thread.currentThread().getName
- info(threadName + " bigin transform step : \n" + debugString())
+ info(threadName + " begin transform step : \n" + debugString())
// Submit parents Steps
val parentStepFutures = parentSteps.filter(checkAndUpdateStatus).map { parentStep =>
Future {