Я пытаюсь получить данные из Twitter, чтобы выполнить анализ настроений в режиме реального времени с помощью Storm. Поскольку я очень новичок в Storm, в качестве первого шага к его пониманию я попытался следовать этому руководству , чтобы получать данные из Twitter и сохранять их в файле .csv
. Топология инициализирована правильно, и, кажется, все работает нормально, но программа не подключается к Twitter. Я получаю «ошибку»:
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - Waiting for 250 milliseconds
[Twitter Stream consumer-1[Waiting for 250 milliseconds]] INFO twitter4j.TwitterStreamImpl - Establishing connection.
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - https://userstream.twitter.com/1.1/user.json
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - Waiting for 500 milliseconds
[Twitter Stream consumer-1[Waiting for 500 milliseconds]] INFO twitter4j.TwitterStreamImpl - Establishing connection.
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - https://userstream.twitter.com/1.1/user.json
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - Waiting for 1000 milliseconds
[Twitter Stream consumer-1[Waiting for 1000 milliseconds]] INFO twitter4j.TwitterStreamImpl - Establishing connection.
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - https://userstream.twitter.com/1.1/user.json
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - Waiting for 2000 milliseconds
[Twitter Stream consumer-1[Waiting for 2000 milliseconds]] INFO twitter4j.TwitterStreamImpl - Establishing connection.
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - https://userstream.twitter.com/1.1/user.json
[Twitter Stream consumer-1[Establishing connection]] INFO twitter4j.TwitterStreamImpl - Waiting for 4000 milliseconds
и это продолжается и продолжается, удваивая время до достижения 16000 миллисекунд, затем просто продолжает ждать 16000 мс для каждой попытки.
Что может вызвать эту проблему? Как я могу это исправить?