Saya menggunakan storm untuk memproses masalah online, tetapi saya tidak mengerti mengapa storm memutar ulang Tuple dari spout . Mencoba ulang apa yang crash mungkin lebih efektif daripada memutar ulang dari root bukan? Adakah yang bisa membantu...

Setelah menerapkan topologi apache storm yang sangat sederhana di java saya menemukan NPE yang menyebabkan kebingungan. Ini pada dasarnya adalah metode utama saya: TologyBuilder builder = new TopologyBuilder(); builder.setSpout("spout", new...

Saya mengalami sedikit masalah saat masuk ke file menggunakan log4j di storm. Sebelum mengirimkan topologi saya, yaitu dalam metode utama saya, saya menulis beberapa pernyataan log dan mengkonfigurasi logger menggunakan:...

semuanya. Saya ingin melakukan pekerjaan itu—— satu semburan mengeluarkan angka ke blotA, dan BlotA mengeluarkan angka ganjil ke Blot_odd, BlotA mengeluarkan angka genap ke Blot_even. Saya memilih satu cara untuk menggunakan emit(streamId,tuple) ,...