Skip to content

Commit

Permalink
change query condition from user into host and remove local username
Browse files Browse the repository at this point in the history
  • Loading branch information
naive-zhang committed Dec 21, 2024
1 parent c1775ee commit 21973e1
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ class YarnLogQuerySuite extends SparkYarnConnectorWithYarn {
spark.sql("USE yarn")
val rows = spark.sql(
"select * from yarn.default.app_logs where line_num = 10" +
" and user='zhangxinsen'" +
" and host='localhost'" +
" limit 10").collect()
val host = rows.head.getString(2)
assert(host == "localhost")
Expand Down

0 comments on commit 21973e1

Please sign in to comment.