объявляю класс with Serializable, но при использовании его в foreachPartition он все равно орет, что org.apache.spark.SparkException: Task not serializable
abstract class ClickHouseStreamCallbackSer extends ClickHouseStreamCallback with java.io.Serializable {}
хотя в тырнетах пишут, что типа норм тема весь класс сериализовывать.
А в каком скоцпк класс определен
Что-то что оно использует - является не сериализуемым.
это понятно, для этого и написана сериализуемая обёртка.
Сделай внешним классом , он обджект в котором определен класс пытается сериализовать
что не сериализуется то?
Обсуждают сегодня