Dmitriy Setrakyan created IGNITE-544:
----------------------------------------

             Summary: Errors when executing streaming example.
                 Key: IGNITE-544
                 URL: https://issues.apache.org/jira/browse/IGNITE-544
             Project: Ignite
          Issue Type: Improvement
          Components: cache
            Reporter: Dmitriy Setrakyan
            Assignee: Alexey Goncharuk
            Priority: Blocker
             Fix For: sprint-2


After cache stopped:
{code}
[19:38:42] (err) Failed to notify listener: ArrayListener 
[arr=[o.a.i.i.processors.datastreamer.DataStreamerImpl$Buffer$1@7c77187, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@622e13ad, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@257b603f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7cca31ad, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@40bd2cfa, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@529cfc3b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2c9814cf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1720fa8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@28813980, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1d49758f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@719b2485, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@60857a51, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@416912f8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17daf257, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3f4d4325, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@74d1e16f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d26d3df, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3daece66, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@68aff69d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@130eb87e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@587d29eb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@13eb117c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e70682, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@624c9328, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@534fccfb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@18e4471f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@248b8197, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@22d893fd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@f5dab49, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@35bbd902, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4dc4711b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2b654425, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4900b5e3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@22181608, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4c3ae7f9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4dffd637, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@19cddc6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@635633ab, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@78480517, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4bb53a47, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2ca0ac1a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7e39094e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@46e1db23, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2464a6ba, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@d8d1e50, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b4815d6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@73b8f95f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@72e8d0e4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17f23f77, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6cef7efa, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@58291039, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6c728428, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6afd0756, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d72ac5d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6dcad312, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@15614947, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17a42b0a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f5c6de7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4435735d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5b8121ed, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6dcbbdec, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7164d6e7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1e24fc0d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4c78386d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7c6cd8d3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2b68fa57, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1295afa3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1f2346cc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@513afbb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@69c5470c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@56920520, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@53823c18, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4bf42fa4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@8cafcf1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4eb753cd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@c97c4ff, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@66f443c6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3906069d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4ddb134b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7fd98633, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b77107d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@324ccb60, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2718c729, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@144335e7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17342bea, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4377f5a7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@22b7536f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2fd6a6d3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@190bb3b8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@652db7f3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d19bc12, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@67636d5c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2331947b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2bab2dc1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1be2fd8a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@67176a27, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@482ab8f2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3a9d4113, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@361ff567, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6a85e7d1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@77f53f5b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@27307d6f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6e4d0023, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2b33c954, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@75e2248e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@519de458, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5757ba50, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@629bb087, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b92e0e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@38b8a5a5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@52571dd8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6df7809d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@22710a73, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5f190615, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@354a69f3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@64e8e4af, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4ee048d3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@595ed6b4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3fbd299d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1cd36f59, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@50b91ac0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ffd9d15, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@295aa2b6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2e74a963, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3603c977, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2585ff97, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5936a683, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@52023377, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ae21031, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@709121bd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1cff9392, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5fa582f1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@35ac62ac, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4cc9216d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2c4a4865, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5f0be517, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@9645558, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@ca3cf50, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7254b7c1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7277c7c1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59129242, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4b591f7f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1c64436a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@50e1d6e8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1d2cde34, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1e0d9809, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@20cce7b1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ec423d6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5628f44, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@775d9231, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@30eb1204, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6f6e4d5c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7e67e75a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@65b02ebd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@d237b3d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@10bad368, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5126ab12, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3587a24d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@236bcd53, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@650c7bc5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@116324d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@98b6de8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@74f738df, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7223b7d7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@42176784, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@10a1b603, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5d5d5508, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@32afcc7b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4bfda6ed, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5671103f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6133eaec, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2db33ea5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@bdf3f30, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5571369c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2bebc254, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1f19979a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6d4d1df6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@31d41315, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@44589e19, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17ae644f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@128979e1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3d48c1e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@37c722b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6714e217, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3e0bc965, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@191816c6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7915d2e4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3951938b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59f12525, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@86a6fb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5753c6fd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@62abda57, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@32a3132a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7a7dafb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e8a80dc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@724f8238, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@585ff518, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@61968cea, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7b807c64, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@75d06f6e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5280a3f9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@724949f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f3fbb43, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@96210d5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5e2ae56b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d09125d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7fee5b1c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6613088c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6f9bb898, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5a35c4cc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@570e522d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@29a77728, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1bca55fc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6fade1ed, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4a97490f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@589b7942, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@11b7b218, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@11158b4a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@61ba7756, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@62e8534a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4ee31a7d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@73919730, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@41a34ed3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@617127ae, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3797e90f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@48c0c0da, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@13cedac7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7b6ac347, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@73bd92b4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3db55a09, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@58c8a79a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7515273f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6a22231b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7dd04944, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6039c513, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3c493af4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4788fc9d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@38ed1741, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@16525c12, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@63b94ab6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@63552e48, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@33526a7c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@37e412c8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1e210278, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@54cc489a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@746dd9f5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6308f7e2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@752c0b39, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4312159e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59aade78, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d399548, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@68593c15, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3bb47a65, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@34622a75, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5c06a64, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2458475d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3c2776e1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1933c292, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1fa6189a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7922d69c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7eb52727, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@79154d31, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5658e841, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@39214220, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6efac63c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3d556217, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2cde9f1c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1f5df8e5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@27ae1614, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@317d8d2c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6903c260, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@19699575, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e203efa, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1369ceff, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@648e1e30, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3119fde9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7e81d2de, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@23c2e5c7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@37291011, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@49a155a8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@39466960, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@d1e4f52, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@72c87f78, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3187689c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b000aa5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@449ba648, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7599221c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f5067bb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@44be1fd6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5d8e48ef, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@61bb0880, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1d2ac6b3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@295e2a6f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b8d69b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3f7e21c4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@742a67c6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2cff367e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6c332174, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@228d5d37, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5be0af7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@50a790f8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@256a3319, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6dc6b666, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@185af09b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@74969338, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@109448, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@58bd67aa, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@172c8a0e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@57e3c480, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@53d5a8e0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@60660507, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@13e99fff, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5a679ec6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@248bafc2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7415d869, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2b5cb773, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4dab9d70, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3427ceb8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6eab9ec5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@20024b4c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@31d30221, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b0b58ad, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@9e4a4bf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b0ed6e4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@126509ae, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@734af57f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5fa776f5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@12d32213, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@28c1719e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@c8498f4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6870474f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@633833e8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4056e390, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@68bd8056, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@21df831, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@20983ce9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@57a50109, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@539e949b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3e2f32a9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5f313ef1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2063d157, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7feb38c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@400373a0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@16130be7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2844991b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5ad42d4c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@111dbc5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@f53b433, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3d36883, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@78168bf8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@77d6a8cc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@65366829, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7db9937c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@31bc8e78, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@736ec04b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@254f892f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@145ccc89, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@41c65f34, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@442fb3df, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1df04c84, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6fbae337, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1c763e0b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@25fec711, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3a753b46, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2eec464, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2fc52454, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7cd0b8f2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6fec1325, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1b552758, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1d3457e2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@64da6b9e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b20391b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@597dbcc0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@66497b4a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@51f87a86, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b7a6943, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@f555950, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@226be0db, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3055925a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@580dc562, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d3798ea, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@a7c2af, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1c7c57a3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2aecb79b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6bdd8ae4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@55d19f8a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2b6e1bdc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@64712145, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@63fc0d85, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3a08e3bf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@61e3bfd9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@c75d1a9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@f666587, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@728e7acf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@e6f1e30, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2c356ecd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@10c37c91, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@119a3444, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@67f226d9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@60366fec, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b9aa08f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2be281ac, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5dd0aee7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@ecaf3be, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@30eaa430, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@f3aac60, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@57c59cf6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@e4bc2b3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6be53c6e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3166d4de, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4a3fdc28, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1ab1d186, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@587588f2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5fb26706, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6bd82e44, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ff1ef58, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@b37da4c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4771067b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6df1badf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1d0a0316, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@285a4f41, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6757d6ef, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@710bf98, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4acf1edf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@30156080, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@692c28c3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b42a601, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59c97450, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@42431e89, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4aa14c32, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@34ad89c9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@265400f8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7cb9e5ed, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3cb9f694, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6482c30b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@62575ca3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@51725b89, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@220c0a65, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@50e40fb4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@80ef34f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4b634fd4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@97e2bff, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@79970ccb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@67c0c3d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@57b0eec9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2fe91613, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6e59b671, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@8224263, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@58342308, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3f0aef93, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1c432c3d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@668448c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f3d0b2a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17a30529, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1284f124, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@568c8bdc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@417fae7c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e7a6137, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7bc2a40d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@49a212c2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@751249c4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@687ced88, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6f0ce46, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5f1df858, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@38a6d616, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@37396c27, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@373b0678, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d4e7ff, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@9cc9775, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@75e89a3f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1a0f5a3c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3a44bd9d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@575ef29f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6656a329, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@668cb65, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@19df2660, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@39b5f5ce, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6a29563a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2ada9bf9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4a5654e4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5cdbc3e5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ce3c6c2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2189ff4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7a110a27, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@78d72a6b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1a602665, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5cc1fde2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2e73846f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6f3667b8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@747e3735, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2703fab5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@156152c6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@49b6fc75, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4cf4bde9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@741a3090, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6bf2abb7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@15d9a7e8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7c2b4b4f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59107aea, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2741cd6c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f7fd88b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59a89518, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b563ed, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2a36e45a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2b0cca17, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@36919a3b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1e932d0f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@39a0eb3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e8b20a5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@74f12b0d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@738d8bc9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@20b1ec9d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@37286e26, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4a7c828d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@55308bc8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7a4a50f7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@e6748c6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2021db6d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@719e6a6a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59fb4146, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6d6e03c7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@433a47b4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4175a883, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4287209a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5fea6336, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4efc8898, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@22210074, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59d9675a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@55265c84, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f34b6f0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@55bc3bc2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@474d7598, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2068d389, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7a316242, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e6734ed, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@622a790c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4b81a5b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@75ea4bfc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2ddd9f0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@330e32be, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@77a08c46, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@50329ce5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3c4cdd4a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7e1583bf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@da4e287, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@49b59262, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1349b093, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4113c13e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b09a341, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@eca1ac0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5059fea2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@f9cdfa6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@292976bf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@776b7540, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@685839e1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@150aaa3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@63aea8b8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4f4300f8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@66fdbfc0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@62fc140e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@74818b81, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@23120129, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@281aa934, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2a44845d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@52e1cf17, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@61c9872b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1ce7c12f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@120fd882, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e4a34a3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6317029e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@415b596a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2dfc420b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@328c943b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@69546306, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@72dfe74f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3d7c0f05, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b0779dd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@21017be8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2ce91518, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@71b023a7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@21a965dd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@bdd843b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6f78018d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1fa5bade, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7548b37a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@12d31db4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3d08020a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@f492c3f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3faa8dcf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@351e1933, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@48fb55c8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@e15b03c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@653a80c4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2028cad1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@326f8e09, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@11584c28, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2055c267, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@464deafe, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@81c2bf8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5b760fdf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@553ea82c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7c8db26f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@15a715ed, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ec4e871, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5e9b504d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4f948f3b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@62b1f359, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b6f181e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3ff23e06, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@54f49394, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@39328968, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7aded9b8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@54f2caeb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@246a8bd2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@93e3ffe, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5213478, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@47c603a5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@37822494, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4fbb2c55, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4335432e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3499abc6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@12199f45, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4d6d0d7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6d93df50, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@142d9ebf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4a90d8c8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@78f2f925, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@be8d034, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@73c87f90, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3fd2bfb9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@508652b7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1d2241e3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2d269928, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7a3d442, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@65d22deb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6a7055eb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@73067e54, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6a1eb5b2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1e57706f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@76e0b143, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@36548515, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@29780548, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@c89dc00, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f101e7b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6d7e50a1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4c55a03, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@46eeef47, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3972c227, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@269666f0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@8ad3563, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@390877e6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@16c4e91a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3f0bcd4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@629797e4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@185a6b17, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2967dd3f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2ff7c2db, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@71015876, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3ac89792, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2dd13bd1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3ca1d5aa, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4798f8a0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@399293c6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1db93896, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2f87a20e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2fda12a6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2fba838, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@56d24d79, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@44d7127f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3be77761, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6402a24d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@20ff9231, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5c4738bb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5c1b002d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2d7ac129, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@71c8a0ad, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@14afcccf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@10b1ac1f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6bb944a9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5f405cbb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@35633a28, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@28afb9cf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@9122c7f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@546a0c62, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@78f4debd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2dc061ad, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3529d1be, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@31a4c265, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6ffbe3da, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@41983a81, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3a47b72d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2d67edea, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1db22eaf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1d7e43aa, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1a8761f7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@81dd7f0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4d6570a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b5a3729, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4af36b6c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2c379795, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1a6ffb1e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@20366405, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@714fd364, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@615469e7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@486c9d8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17838301, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1858b666, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5a01efdb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@687b354a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@636b28cf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3edd5942, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b770675, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5a17bf34, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6080d9e9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@34c38bf2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@675467b1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@dd8a70, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@66f44413, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e40df24, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@a6d40b2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@668fd585, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@221fc19b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6a6e9303, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@ae6262c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@125de908, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e12e1c1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@50fa958b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6b960efe, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@167eaf2d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4fbb58ca, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4b69da7b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@10d3cc16, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@73370ee6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@665f6542, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@63e0c1f0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6ddd12e6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@26d66185, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3bbe6568, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5eb4ccae, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5b7bbfbc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e34271f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6698e94, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ec0e34b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@78c03570, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17a3f9a8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5df4d8e6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2457a2a8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5dc568e7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5523b44e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2e6b75e4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3730c063, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@41c40432, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@98d5980, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7cbcc900, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4dbe3d2c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2cba553d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4f984873, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@55767c49, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@691d7c96, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17f0df35, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1aa6c668, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7cd46541, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7eaf4f81, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6fb73e16, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@430e200e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1cafbb43, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@18782c10, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4ee9e687, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7cd5a104, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1dc1687e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4400cf7a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@455cc4a3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@14d0808d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2c488f1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@40fdeccc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@63a741ac, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@736371bd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@55c6fc20, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7af2e1d8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2301750b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4b87164f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@29c2d4e3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@44531c22, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6c52808e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1f94d625, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@204e6cf8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ca0d6df, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@40e7f35, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3d12b46f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6e682699, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@140403a5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@630431c7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4b9d4004, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@646efb00, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@50c3d503, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@120b5cd5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3337a3f0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2012f86d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6e375aa1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@26924e46, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@28b44147, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1fd205ac, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4be4a6a5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7fb031e1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7584e929, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7a747d50, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@14cb2d35, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6a8a2974, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@381548ad, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@61522c02, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2cbd1798, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@17474af2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5852897, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@75c72619, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3182feee, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1c3f32f6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@30d27076, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7c697f9b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5a3a9b76, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3ff7aa45, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1c852c0d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2ba70da1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2548c288, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@27efe1e6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@12bf4452, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@16699a1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@62595787, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3ae17afb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@52142421, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@670a0453, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4fc7825a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7e401ffb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@d06193e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3a19bc51, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@49bf2c1a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@37fe4d11, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@a8c6d39, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d00b30d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4def8f4b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@8bcc522, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@61b084a9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@19d0db49, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@28f49aef, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@468fcf06, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@237f9eb2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3cea0307, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@30c5d597, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@80acb76, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@575f5ecb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3b419d1c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@25b68e8e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7b39a035, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@563d109f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6123ce39, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7070ee6d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@467ed05e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@787989e6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7d4c2d6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@702047c7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@406c85bd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@746e02ef, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@550dbcc6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@27e1c7df, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@384eff3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f9ec16, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3faa8ba3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@165c7cb6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3283e2f9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ad231e3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@11ce5a89, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@64023dca, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@493b9f99, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@228de274, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4174febe, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@346d7737, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@213ff174, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6c6c2965, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@a0bbb58, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5500a1e1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@b6a5e64, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6c0796d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5146c396, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1997ff6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@585998df, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5dd789a8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3a6abbf7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@70c61583, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@64cdf424, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@536abdc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6aec1d8e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2a46775d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2121dae5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@11f9ed56, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1bf3828a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@296e236, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2dcff673, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@73823dc1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@74e216e9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4150cd11, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@137ed726, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@71f08cbd, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@15c19934, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@523ef6d8, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@371cdc5e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@42fc3b64, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5b6d1236, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7e40a7b5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2fef6a0f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@ceb438d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3f240c84, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@44a269da, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@10c9cc53, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@46e802ec, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@59376699, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@e8c28dc, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@50f9c60a, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5600519b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3461f66c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5b44f2f4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4513b600, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@11cbbbb0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2a22fd73, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@560d7991, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@e7676e6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@422c5aa3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7fd8fef0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@42a4c16b, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7fd85e9f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5f01ea85, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6796b0eb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3dd9aeb, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3e4c10a9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6e499027, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3c0a74ed, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@53efab45, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@df830c9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2f9241f9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@40d0f5fa, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6e4bdb26, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2279c05e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1f59c061, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@58619955, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6843eb94, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@454bdf2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@55df3fd1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@120af0e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@76c8fbf5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@575273f3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7bdfff7f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f8377d5, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4e253c83, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@aac035f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@e0c3172, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6a55d2b9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@d733a54, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@672f665e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@8c74c68, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4cc397d3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5876b585, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@44772543, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@76e195a9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@264cf9a9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4bfbba78, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@36dbd379, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4c6d44d6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@dad6d43, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1b132ef4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@73bb76f4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5556d7a1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@33776f3d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@31919329, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@19b54f39, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7abd7871, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@72bbee9c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4f0e2339, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7c716166, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6d1ef069, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@40fc2c58, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ed5c895, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@9d8fc78, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@135fc892, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@32e0a84d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@62214fe4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2c5454e4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@412202a4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7637780d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1e814740, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@107cd300, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@419ad489, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@ca03ba7, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@188fd634, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6e1de2f6, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@79b44d20, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@74442cb2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@121c6a78, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1397309f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4811b280, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1d65368c, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@6cdbc0f2, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@46e2163e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@32229d0, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3747ae6e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@5293424, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@532c8159, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@41524e45, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4becacdf, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7282992, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@30395667, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@63ca0643, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4deed4b1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@b4c1027, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@71bcf547, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@42771d2d, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7987028e, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@1221f8b1, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4a1317f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7ec5dab3, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@3f972497, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@22eeb7a4, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2fc9404f, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7f090747, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@793c27ad, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@2eb8fcb9, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@4b960a19, 
o.a.i.i.processors.datastreamer.DataStreamerImpl$5@7c921f13]]java.lang.NullPointerException
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.load0(DataStreamerImpl.java:574)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.access$900(DataStreamerImpl.java:59)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:620)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:587)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter$ArrayListener.apply(GridFutureAdapter.java:405)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter$ArrayListener.apply(GridFutureAdapter.java:388)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:227)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListeners(GridFutureAdapter.java:215)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:345)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:311)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.onResponse(DataStreamerImpl.java:1242)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$3.onMessage(DataStreamerImpl.java:236)
        at 
org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:664)
        at 
org.apache.ignite.internal.managers.communication.GridIoManager.access$1500(GridIoManager.java:57)
        at 
org.apache.ignite.internal.managers.communication.GridIoManager$5.run(GridIoManager.java:627)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
Exception in thread "ignite-#13%pub-null%" java.lang.NullPointerException
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.load0(DataStreamerImpl.java:574)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.access$900(DataStreamerImpl.java:59)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:620)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:587)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter$ArrayListener.apply(GridFutureAdapter.java:405)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter$ArrayListener.apply(GridFutureAdapter.java:388)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:227)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListeners(GridFutureAdapter.java:215)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:345)
        at 
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:311)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.onResponse(DataStreamerImpl.java:1242)
        at 
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$3.onMessage(DataStreamerImpl.java:236)
        at 
org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:664)
        at 
org.apache.ignite.internal.managers.communication.GridIoManager.access$1500(GridIoManager.java:57)
        at 
org.apache.ignite.internal.managers.communication.GridIoManager$5.run(GridIoManager.java:627)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
{code}

And when node stopped (no load yet):
{code}
[19:32:39,302][ERROR][grid-timeout-worker-#33%null%][GridTimeoutProcessor] 
Error when executing timeout callback: 
o.a.i.i.processors.cache.GridCachePartitionExchangeManager$ResendTimeoutObject@663870b3
java.lang.AssertionError: Invalid node2part [node2part: null, 
locNodeId=b536c509-466a-411f-9f8c-1dbdff66171e, locName=null]
        at 
org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionTopologyImpl.partitionMap(GridDhtPartitionTopologyImpl.java:731)
        at 
org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager.sendAllPartitions(GridCachePartitionExchangeManager.java:554)
        at 
org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager.refreshPartitions(GridCachePartitionExchangeManager.java:505)
        at 
org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ResendTimeoutObject.onTimeout(GridCachePartitionExchangeManager.java:1022)
        at 
org.apache.ignite.internal.processors.timeout.GridTimeoutProcessor$TimeoutWorker.body(GridTimeoutProcessor.java:133)
        at 
org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:107)
        at java.lang.Thread.run(Thread.java:745)
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to