問題タブ [notserializableexception]

Cassandra からデータを取得するスタンドアロンの Spark プログラムを作成しています。例に従い、newAPIHadoopRDD() および ColumnFamilyInputFormat クラスを介して RDD を作成しました。RDD が作成されますが、RDD の .groupByKey() メソッドを呼び出すと、NotSerializableException が発生します。

例外：

java.io.NotSerializableException: java.nio.HeapByteBuffer の java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1164) の java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1518) の java.io.ObjectOutputStream.writeSerialData( ObjectOutputStream.java:1483) で java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1400) で java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1158) で java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:330) で) org.apache.spark.serializer.JavaSerializationStream.writeObject(JavaSerializer.scala:42) で org.apache.spark.storage.DiskBlockObjectWriter.write(BlockObjectWriter.scala:179) で org.apache.spark.scheduler.ShuffleMapTask$ org.apache.spark.scheduler の $anonfun$runTask$1.apply(ShuffleMapTask.scala:161)。ShuffleMapTask$$anonfun$runTask$1.apply(ShuffleMapTask.scala:158) で scala.collection.Iterator$class.foreach(Ite​​rator.scala:727) org.apache.spark.InterruptibleIterator.foreach(InterruptibleIterator.scala:28) でorg.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:158) で org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99) で org.apache.spark.scheduler.Task.run (Task.scala:51) org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:187) で java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) で java. java.lang.Thread.run(Thread.java:662) の util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)InterruptibleIterator.foreach(InterruptibleIterator.scala:28) org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:158) org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99) org .apache.spark.scheduler.Task.run(Task.scala:51) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:187) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask (ThreadPoolExecutor.java:895) で java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) で java.lang.Thread.run(Thread.java:662) でInterruptibleIterator.foreach(InterruptibleIterator.scala:28) org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:158) org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99) org .apache.spark.scheduler.Task.run(Task.scala:51) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:187) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask (ThreadPoolExecutor.java:895) で java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) で java.lang.Thread.run(Thread.java:662) でjava.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) の executor.Executor$TaskRunner.run(Executor.scala:187) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java: 918) java.lang.Thread.run(Thread.java:662) でjava.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) の executor.Executor$TaskRunner.run(Executor.scala:187) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java: 918) java.lang.Thread.run(Thread.java:662) で

私がやろうとしているのは、すべての行キー列を単一のエントリにマージすることです。次のように reduceByKey() メソッドを使用しようとすると、同じ例外が発生します。

私は使っている：

• spark-1.0.0-bin-hadoop1
• カサンドラ 1.2.12
• Java 1.6

誰が問題が何であるか知っていますか？シリアル化に失敗するのは何ですか？

ありがとう、
シャイ

インスタンスを作成し、コンテナに入れて送信したい。

このエラーが発生します

java.io.NotSerializableException コンテナーにインスタンス o を追加しなければ、問題なく送信できます。

私は少し検索して答えを見つけることができませんでした... クラスを作成し、クラスの ArrayList をファイルに正常に保存しましたが、このファイルを読み込もうとすると、次のようになります。

E/Reading file(14768): java.io.WriteAbortedException: 例外を読み取ります。java.io.NotSerializableException: il.co.hyperactive.callmaagansmallgate.Gate

ここに私のクラスがあります:

私はかなり奇妙な問題を抱えています。ロードしたデータの一部を、シリアル化されたオブジェクトとして保存したいと考えています。以前にこれを行ったことがありますが、何らかの理由で機能させることができません。

奇妙な部分は、オブジェクトの SERIALIZING で例外がスローされないことです。これにより、問題は Serializable オブジェクトにあるとは思えません。シリアル化されたオブジェクトの読み取り (読み込み) でのみ、例外がスローされます...

スタック トレースを見ると、最初の行は、シリアル化できないクラス OfflineDataHelpers を参照しています。私はそれを知っていますが、私はそれを望んでいません。クラス User だけであるべきなので、なぜそう言っているのかわかりません。

ユーザー クラス (シリアライズ可能なオブジェクト)

OfflineDataHelpers クラス ((逆) シリアル化を実行するクラス

関数 saveUser および loadUser は、有効な User オブジェクト (null 以外) を使用してアクティビティで呼び出されます。「loadUser」呼び出しを削除すると、例外はスローされず、「ユーザー .... が保存されました」と表示されます。

しかし、関数 loadUser を追加すると、スタックトレースに次のように表示されます。

これは、OfflineDataHelpers をシリアル化しようとしていることを示唆していますが、そうは思いません。誰でもアイデアはありますか？

私のコードが「java.io.WriteAbortedException: 書き込みが中止されました; java.io.NotSerializableException: core.FlightOrder$FlightTicket」例外をスローしている理由を理解しようとしていました。

私は次のように宣言されたクラスを持っています：

FlightTickets のプライベート セットが含まれています。

そして、次のように宣言された内部クラス:

私が読んだ解決策は、内部クラス「FlightTicket」を静的クラスにすることでしたが、コードを適切に機能させるために何をすべきかわかりません。誰かがこの問題にアプローチする正しい方法を理解するのを手伝ってもらえますか?

JPanelオブジェクトをサーバー¹に送信しようとしています。そうしている間、エラーが発生します-

これは私が書いたコードです。

このエラーを修正するにはどうすればよいですか?

1. リモート PC 内のファイルをツリー形式で指定し、パネルに追加してネットワーク経由で送信しています。ただし、送信しているかどうかにJFrame関係JPanelなく、同じエラーが発生しています。FileSystemViewJTree

RMI を使用してサーバー アプリケーションに接続する GUI を作成しました。GUI はオンライン ユーザーを表示する必要があるため、スレッドは「Online-User-List」を含む JLabel を更新します。実行時にこの例外が発生することがあります。

...

例外は次の場所に表示されます。

この方法では：

この Methode を Timer-inner-class で使用します。

これは Timer-inner-class を持つクラスです (それらのほとんどは GUI です):

クラスをシリアライズ可能にしようとしています。私のクラスはすべてそうですが、使用法が見つからない他のクラス (com.sun.java.swing.plaf.windows.XPStyle、WClipboard など) に対して NotSerializableException がスローされます。

これらのクラスをシリアライズするとき、またはシリアライズ可能にするときにどうすればよいですか?

解決した

問題は、JFrames と JDialogs で使用した LookAndFeel にありました (問題XPStyle)。2 つ目 ( WClipboard)、ここから取得したサードパーティ クラスで使用されました。このクラスはクリップボードを使用します。

Clipboard フィールドtransientと LookAndFeel を削除するだけで管理できなくなりました。

に D&D を実装していJTreeます。カスタムTransferHandlerを作成し、新しいTransferableクラスを作成しました。このクラスはとても簡単です:

「オンドロップ」の場合、私は電話します

を取得しjava.io.NotSerializableExceptionます。次の方法でデータオブジェクトのクラスを変更するTreePathTransferableとObject:

すべて正常に動作します。転送されたデータは同じなので、これは私には意味がありません - TreePath[]。違いはなぜですか？

スタックトレース

注: シリアル化できないクラスを XXX に置き換えました。これは、DefaultMutableTreeNode のサブクラスのプロパティです。このサブクラスはシリアル化できないため、例外は意味がありますが、なぜ 2 番目のケースに表示されないのでしょうか?

TransferHandler