Spark Streaming之Receiver和Direct区别

Receiver(过时了) receiver运行在executor中,是一个常驻内存的进程。 默认存储级别:MEMORY_AND_DISK_SER_2。 由于使用的high level的API,offset都存在zookeeper中,用户不用关心offset。 当receiver接收到数据,此时若driver端挂了,相应的executor也会挂掉,此时,也会造成数据的丢失。为了避免数据丢失,引入了
相关文章
相关标签/搜索