1
Это сборщик мусора по умолчанию в Storm и почему?Сбор мусора в Apache Storm
Может кто-нибудь объяснить, что происходит с кортежами в памяти после того, как они признаны Болтом?
A
ответ
0
Поскольку Apache Storm - это проект на основе JVM, тогда, когда дело доходит до сбора мусора, будет использоваться политика сбора мусора, используемая процессом Storm JVM.
Возможно, я ошибаюсь, но мне кажется, что вы смешиваете две вещи здесь: процесс JVM GC и Storm Acknowledge.
Вот как признают в Apache Буря была создана:
Apache Грозовые носики держать сообщения (события) в своих выходных очередях, пока они не подтверждается. Подтверждение происходит только после успешной обработки сообщения (события) топологией. Если для сообщения (события) в течение разумного промежутка времени приходит подтверждение, то носители очищают сообщение от очереди вывода. Если подтверждение не наступило в течение предопределенного периода (по умолчанию 30 секунд), то носик снова воспроизводит сообщение через топологию.
Следует читать: Guaranteeing Message Processing.
Смежные вопросы
- 1. android (apache harmony) сбор мусора
- 2. Сбор мусора
- 3. Сбор мусора
- 4. Сбор мусора в ThreadPool?
- 5. Сбор мусора в C++
- 6. Сбор мусора в Perl
- 7. Сбор мусора в C#
- 8. Сбор мусора в git
- 9. Сбор мусора в vfp9
- 10. Сбор мусора в R
- 11. Сбор мусора в bash
- 12. Сбор мусора в GCL
- 13. сбор мусора в python
- 14. сбор мусора в Javascript
- 15. сбор мусора в vb.net
- 16. Сбор урожая мусора Vs Сбор мусора в .NET
- 17. Сбор мусора и нитки
- 18. Сбор мусора YGCT и сбор мусора Время продолжает расти
- 19. Erlang сбор мусора
- 20. Сбор мусора рабочей среды?
- 21. asp.net Сбор мусора Уведомления
- 22. Unity3D: оптимизировать сбор мусора
- 23. Почему это сбор мусора
- 24. DoctrineCommonCache сбор мусора?
- 25. Когда сбор мусора
- 26. Java - сбор мусора
- 27. Фрагменты Сбор мусора
- 28. Эффективного Сбор мусора
- 29. сбор мусора вспышка
- 30. Сбор мусора .Net
Извините, я немного смущен вашим ответом. Я думаю, что буря не хранит полные сообщения в памяти. В принципе, реализация носика отвечает за повторное излучение, когда кортеж не завершился. Поэтому шторм не нужно сохранять значения кортежа. Он только сохраняет идентификатор сообщения и данные, используемые для идентификации задачи носика, не так ли? – fhussonnois
Эй спасибо за это. Но ваш ответ поднял мне больше вопросов. Позвольте мне рассказать о моей работе - Я запускаю кластер штормов и отслеживаю метрики jvm каждого рабочего. Я заметил, что каждый раз, когда количество сборщиков мусора достигает определенного значения, оно занимает так много времени процессора, что рабочий не может послать пульс. Таким образом, нимб думает, что рабочий мертв и перебалансирует топологию. Когда я сменил GC на ParNewGC с CMS по умолчанию, который используется в шторме, эта проблема исчезла. Это связано с GC в шторме? Как я могу это исправить? – paalaak