Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/18253
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r132593478
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -39,98 +40,114 @@ import org.apache.spark.util.Utils
* has
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r132507914
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -39,98 +40,114 @@ import org.apache.spark.util.Utils
* has
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r132486074
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -39,98 +40,114 @@ import org.apache.spark.util.Utils
* has
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r132474881
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -39,98 +40,114 @@ import org.apache.spark.util.Utils
* has
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130760063
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/bus/ListenerBusQueueImpl.scala
---
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130759258
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -2379,8 +2382,13 @@ class SparkContext(config: SparkConf) extends
Logging {
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130390981
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/bus/ListenerBusQueueImpl.scala
---
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130341740
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -2350,13 +2354,12 @@ class SparkContext(config: SparkConf) extends
Logging {
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130360348
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala ---
@@ -227,6 +169,7 @@ private[spark] class EventLoggingListener(
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130376495
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -39,98 +39,107 @@ import org.apache.spark.util.Utils
* has
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130345159
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -2379,8 +2382,13 @@ class SparkContext(config: SparkConf) extends
Logging {
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130359427
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala ---
@@ -131,94 +132,35 @@ private[spark] class EventLoggingListener(
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130359204
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala ---
@@ -131,94 +132,35 @@ private[spark] class EventLoggingListener(
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130341036
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -532,7 +533,10 @@ class SparkContext(config: SparkConf) extends Logging {
Github user bOOm-X commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r130375161
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala ---
@@ -27,7 +27,12 @@ private[spark] trait SparkListenerBus
Github user abellina commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r129669738
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala ---
@@ -131,94 +132,35 @@ private[spark] class EventLoggingListener(
Github user abellina commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r129889123
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/SparkListenerBus.scala ---
@@ -27,7 +27,12 @@ private[spark] trait SparkListenerBus
Github user abellina commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r129659027
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -2379,8 +2382,13 @@ class SparkContext(config: SparkConf) extends
Logging {
Github user abellina commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r129886931
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -139,30 +148,60 @@ private[spark] class LiveListenerBus(conf:
Github user abellina commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r129879433
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -39,98 +39,107 @@ import org.apache.spark.util.Utils
* has
Github user abellina commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r129659490
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -532,7 +533,10 @@ class SparkContext(config: SparkConf) extends Logging {
Github user abellina commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r129877998
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala ---
@@ -39,98 +39,107 @@ import org.apache.spark.util.Utils
* has
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r127791337
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala ---
@@ -227,6 +169,7 @@ private[spark] class EventLoggingListener(
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r127790190
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -532,7 +533,10 @@ class SparkContext(config: SparkConf) extends Logging {
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r127791655
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala ---
@@ -131,94 +132,35 @@ private[spark] class EventLoggingListener(
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r127792909
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/bus/ListenerBusQueueImpl.scala
---
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r127790654
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -2350,13 +2354,12 @@ class SparkContext(config: SparkConf) extends
Logging {
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18253#discussion_r127791118
--- Diff: core/src/main/scala/org/apache/spark/SparkContext.scala ---
@@ -2379,8 +2382,13 @@ class SparkContext(config: SparkConf) extends
Logging {
29 matches
Mail list logo
