Skip to content

Commit

Permalink
get address from blockmanager
Browse files Browse the repository at this point in the history
allwefantasy committed Sep 9, 2020
1 parent f6952a1 commit b344bc0
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion streamingpro-mlsql/src/main/java/tech/mlsql/ets/Ray.scala
Original file line number Diff line number Diff line change
@@ -128,7 +128,7 @@ class Ray(override val uid: String) extends SQLAlg with VersionCompatibility wit

tempdf.rdd.mapPartitions { iter =>

val host: String = if (SparkEnv.get == null || MLSQLSparkUtils.rpcEnv().address == null) {
val host: String = if (SparkEnv.get == null || MLSQLSparkUtils.blockManager == null || MLSQLSparkUtils.blockManager.blockManagerId == null) {
WriteLog.write(List("Ray: Cannot get MLSQLSparkUtils.rpcEnv().address, using NetTool.localHostName()").iterator,
Map("PY_EXECUTE_USER" -> owner))
NetTool.localHostName()

0 comments on commit b344bc0

Please sign in to comment.