kryo

0熱

1答えて

Kryo ClassNotFoundException突然投げた

多くの投稿を読んだ後、私はkryoで私の問題の答えを見つけられませんでした。 私たちは、2台のサーバ間で非常に大量のメッセージをシリアライズ/デシリアライズするKryo（v4.0.0）を実装しようとしています。 私たちの問題は、シリアライズ/デシリアライゼーションのは、数分の間に正常に動作し（これ以上千以上のメッセージ）と、突然、次の例外を除いて動作するように停止することができるということです。

classnotfoundexception kryo 2016-11-09

---

2熱

1答えて

スパークストリーミング：com.esotericsoftware.kryo.KryoException：java.lang.IllegalArgumentException：クラスが登録されていません：scala.Tuple2 $ mcJZ $ sp

スパークストリーミングでKryoシリアライザを使用しようとしています。私はそのSpark tuning docsで読む - あなたのカスタムクラスを登録しない場合 最後に、Kryoはまだ 動作しますが、それは無駄である 、各オブジェクトとの完全なクラス名を保存する必要があります。 私はすべてのクラスを登録しようとしています。 trait Message extends java.io.Serial

scala serialization apache-spark spark-streaming kryo 2016-12-30

---

10熱

1答えて

KryoクラッシュEnvironmentFailureException

私はカスタムクラスの一部のオブジェクトをシリアル化しようとしていると私は次の例外だ：私はArrayListを持って com.esotericsoftware.kryo.KryoException: com.sleepycat.je.EnvironmentFailureException: (JE 5.0.73) IdentityHashMap.entrySet() should not be us

java exception kryo 2016-11-28

---

1熱

1答えて

Spark 2.0にアップグレードする際のKryo登録の問題

Spark 1.6.2からSpark 2.0.2にアプリケーションをアップグレードしています。この問題は厳密にはスパーク関連ではありません。スパーク1.6.2にはKryo 2.21が含まれています。 Spark 2.0.2にはKryo 3.0.3が含まれています。 このアプリケーションは、HDS上にKryoでシリアル化されたいくつかのデータを保存します。スペースを節約するために、Kryo登録が強制

serialization apache-spark kryo 2016-11-29

---

1熱

2答えて

kryo serialization over storm

（リモートクラスタにデプロイされた）apache stormに対する複雑なオブジェクト（opencv：Mat）をシリアル化する必要があります。誰も私に良いチュートリアルカスタムkryoシリアル化を提案するか、これを行う方法の解決策を提案できますか？ ありがとうございます！

apache-storm kryo 2017-01-22

---

1熱

1答えて

カスタムシリアライザを使用してavroから読み込んだとき、RDDの実行時タイプが正しくありません

avryファイルからKryoを使用してRDDにデータを読み込もうとしています。私のコードはうまくコンパイルされますが、実行時にはClassCastExceptionが得られます。ここに私のコードが何をするかです： MyKryoRegistratorは MyCustomClassのためのシリアライザを登録 SparkConf conf = new SparkConf()... conf.set("

java apache-spark avro kryo 2017-01-24

---

1熱

1答えて

IMapのインデックスはKryoのシリアル化で動作しますか？

私はHazelcast IMapを作成し、値のインデックスフィールドを定義しました。インデックスはKryoのシリアル化に対応していますか？以前のバージョンのHazelcastインデックスでは、メモリ内フォーマットがOBJECTだった場合にのみ動作することを覚えていました。

hazelcast kryo 2017-01-31

---

1熱

1答えて

spark kryo serialization registerデータ型[]

sparkが強制的にkryoシリアル化を使用するには、次のオプションをspark.kryo.registrationRequiredに設定できます。 org.apache.spark.sql.types.DataType[]の登録方法を教えてください。 Class is not registered: org.apache.spark.sql.types.DataType[] 例外をスローしま

serialization apache-spark kryo 2016-12-15

---

1熱

1答えて

Registring Kryoクラスは、私は次のコードを持っている

が動作していませんか？

scala apache-spark kryo 2016-10-29

---

2熱

1答えて

Kryoライブラリには、maven shade-packageフェーズで "overlapping classes"警告があります

影付きのjarファイルを作成しようとしていますが、shadeプラグインが警告を表示しています。 私はそれらを修正する方法がわかりません。ここで は私のpom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.o

maven maven-shade-plugin kryo uberjar 2016-11-03

---