Skip to content

Commit

Permalink
[SPARK-27215][CORE] Correct the kryo configurations
Browse files Browse the repository at this point in the history
## What changes were proposed in this pull request?

```scala
val KRYO_USE_UNSAFE = ConfigBuilder("spark.kyro.unsafe")
    .booleanConf
    .createWithDefault(false)

  val KRYO_USE_POOL = ConfigBuilder("spark.kyro.pool")
    .booleanConf
    .createWithDefault(true)
```
**kyro should be kryo**

## How was this patch tested?

no need

Closes apache#24156 from LantaoJin/SPARK-27215.

Authored-by: Lantao Jin <[email protected]>
Signed-off-by: Marcelo Vanzin <[email protected]>
  • Loading branch information
LantaoJin authored and Marcelo Vanzin committed Mar 20, 2019
1 parent ec5e342 commit 93c6d2a
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -34,11 +34,11 @@ private[spark] object Kryo {
.toSequence
.createWithDefault(Nil)

val KRYO_USE_UNSAFE = ConfigBuilder("spark.kyro.unsafe")
val KRYO_USE_UNSAFE = ConfigBuilder("spark.kryo.unsafe")
.booleanConf
.createWithDefault(false)

val KRYO_USE_POOL = ConfigBuilder("spark.kyro.pool")
val KRYO_USE_POOL = ConfigBuilder("spark.kryo.pool")
.booleanConf
.createWithDefault(true)

Expand Down

0 comments on commit 93c6d2a

Please sign in to comment.