Segui totalmente o conteúdo da aula "04 - Client do Twitter" e no meu caso não funcionaram, nem fazendo no meu PC mesmo ou utilizando a Máquina Virtual
Executando o client_twitter.py da seguinte forma:
PS D:\Estudos\ProjetosPython\Spark_Streaming> python3 client_twitter.py
Ocorrem os erros abaixo:
Setting default log level to "WARN". To adjust logging level use sc.setLogLevel(newLevel). For SparkR, use se 23/05/04 20:20:23 WARN NativeCodeLoader: Unable to load native-hadoop li 23/05/04 20:20:26 WARN TextSocketSourceProvider: The socket source shoul 23/05/04 20:20:29 WARN ResolveWriteToStream: Temporary checkpoint locatipData\Local\Temp\temporary-e4468f41-2b90-47cb-99a9-7e1fc02f79cc. If it'sceDeleteTempCheckpointLocation to true. Important to know deleting temp 23/05/04 20:20:29 WARN ResolveWriteToStream: spark.sql.adaptive.enabled Traceback (most recent call last): File "C:\Python\Spark_Streaming\client_twitter.py", line 17, in <modul .start() File "C:\Python\Spark_Streaming\SparkStreaming\lib\site-packages\pyspa return self.sq(self.jwrite.start()) File "C:\Python\Spark_Streaming\SparkStreaming\lib\site-packages\py4jAggregate [word#3], [word#3, count(1) AS count#7L] +- Project [word#3] +- Generate explode(split(value#0, , -1)), false, [word#3] +- StreamingRelationV2 org.apache.spark.sql.execution.streaming.sources.TextSocketSourceProvider@6c180d47, socket, org.apache.spark.sql.execution.streaming.sources.TextSocketTable@70b5591f, [host=localhost, port=9009], [value#0]
(SparkStreaming) PS C:\Python\Spark_Streaming> ÊXITO: o processo com PID 14432 (processo filho de PID 15040) foi finalizado. ÊXITO: o processo com PID 15040 (processo filho de PID 16508) foi finalizado. ÊXITO: o processo com PID 16508 (processo filho de PID 2308) foi finalizado.
Por favor, Como posso resolver isso?