Github user jackylk commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2861#discussion_r229285477 --- Diff: integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonRDD.scala --- @@ -37,6 +37,11 @@ abstract class CarbonRDD[T: ClassTag]( @transient private val ss: SparkSession, @transient private var deps: Seq[Dependency[_]]) extends RDD[T](ss.sparkContext, deps) { + @transient val sparkAppName: String = ss.sparkContext.appName + CarbonProperties.getInstance() + .addProperty(CarbonCommonConstants.CARBON_WRITTEN_BY_APPNAME, + sparkAppName) --- End diff -- move to previous line
---