Skip to content

Commit 3d93afe

Browse files
authored
Merge pull request apache#184 from zhangbushi5/3xspark
KE-18856 revert acclerate clean block
2 parents cdff1f8 + 61fffa0 commit 3d93afe

File tree

36 files changed

+37
-43
lines changed

36 files changed

+37
-43
lines changed

assembly/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>org.apache.spark</groupId>
2323
<artifactId>spark-parent_2.11</artifactId>
24-
<version>2.2.1-kylin-r18</version>
24+
<version>2.2.1-kylin-r19</version>
2525
<relativePath>../pom.xml</relativePath>
2626
</parent>
2727

common/network-common/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
<parent>
2323
<groupId>org.apache.spark</groupId>
2424
<artifactId>spark-parent_2.11</artifactId>
25-
<version>2.2.1-kylin-r18</version>
25+
<version>2.2.1-kylin-r19</version>
2626
<relativePath>../../pom.xml</relativePath>
2727
</parent>
2828

common/network-shuffle/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
<parent>
2323
<groupId>org.apache.spark</groupId>
2424
<artifactId>spark-parent_2.11</artifactId>
25-
<version>2.2.1-kylin-r18</version>
25+
<version>2.2.1-kylin-r19</version>
2626
<relativePath>../../pom.xml</relativePath>
2727
</parent>
2828

common/network-yarn/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
<parent>
2323
<groupId>org.apache.spark</groupId>
2424
<artifactId>spark-parent_2.11</artifactId>
25-
<version>2.2.1-kylin-r18</version>
25+
<version>2.2.1-kylin-r19</version>
2626
<relativePath>../../pom.xml</relativePath>
2727
</parent>
2828

common/sketch/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
<parent>
2323
<groupId>org.apache.spark</groupId>
2424
<artifactId>spark-parent_2.11</artifactId>
25-
<version>2.2.1-kylin-r18</version>
25+
<version>2.2.1-kylin-r19</version>
2626
<relativePath>../../pom.xml</relativePath>
2727
</parent>
2828

common/tags/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
<parent>
2323
<groupId>org.apache.spark</groupId>
2424
<artifactId>spark-parent_2.11</artifactId>
25-
<version>2.2.1-kylin-r18</version>
25+
<version>2.2.1-kylin-r19</version>
2626
<relativePath>../../pom.xml</relativePath>
2727
</parent>
2828

common/unsafe/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
<parent>
2323
<groupId>org.apache.spark</groupId>
2424
<artifactId>spark-parent_2.11</artifactId>
25-
<version>2.2.1-kylin-r18</version>
25+
<version>2.2.1-kylin-r19</version>
2626
<relativePath>../../pom.xml</relativePath>
2727
</parent>
2828

core/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>org.apache.spark</groupId>
2323
<artifactId>spark-parent_2.11</artifactId>
24-
<version>2.2.1-kylin-r18</version>
24+
<version>2.2.1-kylin-r19</version>
2525
<relativePath>../pom.xml</relativePath>
2626
</parent>
2727

core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -141,14 +141,8 @@ class BlockManagerMaster(
141141

142142
/** Remove all blocks belonging to the given broadcast. */
143143
def removeBroadcast(broadcastId: Long, removeFromMaster: Boolean, blocking: Boolean) {
144-
var future: Future[Seq[Int]] = null
145-
if (blocking) {
146-
future = driverEndpoint.askSync[Future[Seq[Int]]](
147-
RemoveBroadcast(broadcastId, removeFromMaster))
148-
} else {
149-
future = driverEndpoint.ask[Seq[Int]](
150-
RemoveBroadcast(broadcastId, removeFromMaster))
151-
}
144+
val future = driverEndpoint.askSync[Future[Seq[Int]]](
145+
RemoveBroadcast(broadcastId, removeFromMaster))
152146
future.onFailure {
153147
case e: Exception =>
154148
logWarning(s"Failed to remove broadcast $broadcastId" +

examples/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<parent>
2222
<groupId>org.apache.spark</groupId>
2323
<artifactId>spark-parent_2.11</artifactId>
24-
<version>2.2.1-kylin-r18</version>
24+
<version>2.2.1-kylin-r19</version>
2525
<relativePath>../pom.xml</relativePath>
2626
</parent>
2727

0 commit comments

Comments
 (0)