[carbondata] 03/33: [CARBONDATA-3493] Initialize Profiler in CarbonEnv

[ravipesala]

This is an automated email from the ASF dual-hosted git repository.

ravipesala pushed a commit to branch branch-1.6
in repository https://gitbox.apache.org/repos/asf/carbondata.git

commit 90b6c648d3b20e563e685b9aa8c8bafcefbcf3ad
Author: akashrn5 <akashnilu...@gmail.com>
AuthorDate: Wed Jul 31 18:54:41 2019 +0530

    [CARBONDATA-3493] Initialize Profiler in CarbonEnv
    
    Problem: After enabling "enable.query.statistics", exception is
    thrown while querying because profiler is not initialized before
    setting up the rpc end point connection.
    
    Solution: Initialized Profiler in CarbonEnv before setting up the
    rpc end point connection.
    
    This closes #3342
    
    Co-authored-by: shivamasn <shivamas...@gmail.com>
---
 integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala  | 2 ++
 .../spark2/src/main/scala/org/apache/spark/sql/CarbonSession.scala      | 2 --
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala 
b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala
index c13e7b9..1cbd156 100644
--- a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala
+++ b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonEnv.scala
@@ -28,6 +28,7 @@ import org.apache.spark.sql.execution.command.mv._
 import org.apache.spark.sql.execution.command.preaaggregate._
 import org.apache.spark.sql.execution.command.timeseries.TimeSeriesFunction
 import org.apache.spark.sql.hive._
+import org.apache.spark.sql.profiler.Profiler
 
 import org.apache.carbondata.common.logging.LogServiceFactory
 import org.apache.carbondata.core.constants.CarbonCommonConstants
@@ -121,6 +122,7 @@ class CarbonEnv {
         initialized = true
       }
     }
+    Profiler.initialize(sparkSession.sparkContext)
     LOGGER.info("Initialize CarbonEnv completed...")
   }
 }
diff --git 
a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSession.scala 
b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSession.scala
index 7b1bf4c..deefcd1 100644
--- a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSession.scala
+++ b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSession.scala
@@ -259,8 +259,6 @@ object CarbonSession {
         }
         options.foreach { case (k, v) => 
session.sessionState.conf.setConfString(k, v) }
         SparkSession.setDefaultSession(session)
-        // Setup monitor end point and register CarbonMonitorListener
-        Profiler.initialize(sparkContext)
         // Register a successfully instantiated context to the singleton. This 
should be at the
         // end of the class definition so that the singleton is updated only 
if there is no
         // exception in the construction of the instance.