kryo

1熱

1答えて

ProtoBufフィールドのコレクションでのKryoシリアル化の問題

Kryoシリアライザを使用するMy Spark（v1.6.1）アプリケーションのKafkaからprotobufオブジェクトを受信して​​います。 org.apache.spark.SparkException: Job aborted due to stage failure: Task 1 in stage 18.0 failed 4 times, most recent failure: Lo

apache-spark protocol-buffers kryo 2017-10-17

---

1熱

2答えて

なぜkryo登録がSparkSessionで機能しないのですか？

は、ここに私のコードです： public static SparkSession getTestSparkSession(String name) { SparkConf conf = new SparkConf() .set("spark.master", "local") .set("spark.ui.port", "8040") .set(

apache-spark serialization kryo 2017-12-11

---

1熱

1答えて

警告：[Kryo]クラスxをKryoのClassLoaderで読み込めません。

警告：[kryo]クラスslade.core.ChildをkryoのClassLoaderで読み込めません。現在...クラスを見つけることができません と再試行：slade.core.Child シリアルトレース： 子（slade.core.Parent） 私は問題を持っていますKryoは、ルートオブジェクト型に含まれるカスタムオブジェクト型を逆シリアル化しようとすると、上記のエラーをスローします

java serialization osgi kryo 2017-09-09

---

1熱

1答えて

Kryo

null以外のデフォルトの使用にオブジェクトの過渡メンバーをデシリアライズ public class MyObj implements Serializable { private transient Map<String, Object> myHash = new HashMap<String, Object>(); ... } 私はこの質問 Deserialize a

java serialization kryo 2017-12-18

---

0熱

1答えて

Kryoの逆シリアル化中にクラス例外をロードできません。

私はKryoをシリアル化/逆シリアル化に使用していますが、事前にクラスを登録していません。つまり、逆シリアル化時に例外が発生します。 クラスshell.api.model.BatteryStatuoをkryoのClassLoaderで読み込めません。現時点での再試行 私のクラス名は実際にはshell.api.model.BatteryStatusなので、シリアル化中に何が起こったのか分かりません。

java serialization deserialization kryo 2017-11-05

---

0熱

1答えて

kryo.KryoExceptionを使用してkryo.KryoExceptionを設定するには、spark.serializerを設定します。org.hibernate.LazyInitializationException

Daoメソッドを使用して（エンティティリターン後、セッションが閉じられた）hibernate3を使用してdbからいくつかのエンティティを取得し、 。 spark.serializerをorg.apache.spark.serializer.KryoSerializerに設定した後、例外がスローされました：KryoException org.hibernate.LazyInitializationE

hibernate session apache-spark exception kryo 2017-11-09

---

1熱

1答えて

java.lang.IllegalArgumentException：クラスが登録されていません：scala.reflect.ClassTag $$ anon $ 1

私はSpark、GraphX 2.0.2およびIntelliJを使用しています。 は、私はエラーを得た： kryo.register(classOf[GraphImpl[Object,Object]]) を、私はこのエラーを得た： Class is not registered: org.apache.spark.graphx.impl.GraphImpl だから私は、追加 java.la

apache-spark spark-graphx kryo 2017-12-28

---

0熱

1答えて

com.esotericsoftware.kryo.Kryo.KryoException：クラスを作成できません（引数なしコンストラクタがありません）：scala.Tuple2

私はスカラー上のKryoを使ったシリアライゼーションの最も簡単な例を調べることはできません。 これには特定のシリアライザを登録する必要がありますか？次のようなものを追加する おかげ val kryo = new Kryo() kryo.setRegistrationRequired(false) kryo.register(classOf[scala.Tuple2[Any, A

scala serialization kryo 2017-08-10

---

1熱

1答えて

Alpakka - S3からKryoシリアル化されたオブジェクトを読み取る

私はKryoシリアル化されたバイナリデータをS3（数千のシリアル化オブジェクト）に保存しています。 アルパッカは、data: Source[ByteString, NotUsed]と内容を読み取ることができます。しかし、Kryoフォーマットはデリミタを使用しないので、シリアル化された各オブジェクトをdata.via(Framing.delimiter(...))を使用して別のByteStringに

scala amazon-s3 akka kryo alpakka 2017-11-22

---