New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[SPARK-4381][Streaming]Add warning log when user set spark.master to local in Spark Streaming and there's no job executed #3244
Conversation
Test build #23309 has started for PR 3244 at commit
|
@@ -121,6 +121,11 @@ class StreamingContext private[streaming] ( | |||
} | |||
} | |||
|
|||
if (sc.conf.get("spark.master") == "local") { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Check for the case of local[1]
too I suppose?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the note , I will add it.
Test build #23310 has started for PR 3244 at commit
|
Test build #23309 timed out for PR 3244 at commit |
Test FAILed. |
Test build #23310 has finished for PR 3244 at commit
|
Test PASSed. |
@@ -121,6 +121,11 @@ class StreamingContext private[streaming] ( | |||
} | |||
} | |||
|
|||
if (sc.conf.get("spark.master") == "local" || sc.conf.get("spark.master") == "local[1]") { | |||
logWarning("spark.master should be set as local[n], n > 1 in local mode if you have receivers" + | |||
" to get data, otherwise the job cannot get enough resource to execute.") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
"otherwise Spark jobs will not get resources to process the received data."
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks TD, I will modify it :)
LGTM, one small point. |
Jenkins, test this please. |
Test build #23649 has started for PR 3244 at commit
|
Test build #23649 has finished for PR 3244 at commit
|
Test PASSed. |
Since no unit tests cover this change, I tested it manually. It works as expected merging this to both master and 1.2 |
…local in Spark Streaming and there's no job executed Author: jerryshao <saisai.shao@intel.com> Closes #3244 from jerryshao/SPARK-4381 and squashes the following commits: d2486c7 [jerryshao] Improve the warning log d726e85 [jerryshao] Add local[1] to the filter condition eca428b [jerryshao] Add warning log (cherry picked from commit fef27b2) Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
No description provided.