Update src/csharp/Microsoft.Spark/Broadcast.cs

Niharikadutta · imback82 · web-flow · commit d414755a12e6 · 2020-11-11T16:26:07.000-08:00
Co-authored-by: Terry Kim &lt;yuminkim@gmail.com&gt;
diff --git a/src/csharp/Microsoft.Spark/Broadcast.cs b/src/csharp/Microsoft.Spark/Broadcast.cs
@@ -173,7 +173,7 @@ private JvmObjectReference CreateBroadcast_V2_3_2_AndAbove(
                 sc.GetConf().Get("spark.io.encryption.enabled", "false"));
             JvmObjectReference _pythonBroadcast;
 
-            // Databricks has changed the signature of setupBroadcast in its Spark
+            // Spark in Databricks is different from OSS Spark and requires to pass the SparkContext object to setupBroadcast.
             if (ConfigurationService.IsDatabricks)
             {
                 _pythonBroadcast = (JvmObjectReference)javaSparkContext.Jvm.CallStaticJavaMethod(

Original file line number	Diff line number	Diff line change
`@@ -173,7 +173,7 @@ private JvmObjectReference CreateBroadcast_V2_3_2_AndAbove(`
`173`	`173`	`sc.GetConf().Get("spark.io.encryption.enabled", "false"));`
`174`	`174`	`JvmObjectReference _pythonBroadcast;`
`175`	`175`
`176`		`- // Databricks has changed the signature of setupBroadcast in its Spark`
	`176`	`+ // Spark in Databricks is different from OSS Spark and requires to pass the SparkContext object to setupBroadcast.`
`177`	`177`	`if (ConfigurationService.IsDatabricks)`
`178`	`178`	`{`
`179`	`179`	`_pythonBroadcast = (JvmObjectReference)javaSparkContext.Jvm.CallStaticJavaMethod(`