spark-streaming
"java. io. IOException: Classe introuvable" sur une application de streaming longue durée
Je reçois l'exception ci-dessous sur une application de streaming Spark de longue durée. L'exception peut se produire après ... enerator$$anon$1.onReceive(JobGenerator.scala:86)
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:48)
Programmation itérative sur un flux spark ordonné à l'aide de Java dans Spark Streaming?
Existe-t-il de toute façon dans spark streaming pour conserver les données sur plusieurs micro-lots d'un dstream trié, où le ... pas l'ensemble de données entier, mais persistent certains événements qui peuvent être utilisés dans les futurs DSTREAM RDD?
"java.io. IOException: Classe non trovata" sull'applicazione di streaming a lunga esecuzione
Sto ricevendo l'eccezione di seguito su un'applicazione di streaming Spark a lunga esecuzione. L'eccezione potrebbe verifica ... enerator$$anon$1.onReceive(JobGenerator.scala:86)
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:48)
Programmazione iterativa su un flusso spark ordinato utilizzando Java in Spark Streaming?
Esiste comunque in spark streaming per mantenere i dati su più micro-batch di un dstream ordinato, in cui il flusso viene ord ... re calcoli.. non l'intero set di dati, ma persistono determinati eventi che possono essere utilizzati nei futuri RDD DStream?