You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by sam mohel <sa...@gmail.com> on 2017/07/24 23:08:30 UTC
problem with the size of the result after submitting
i submitted a topology using apache-storm -0.10.2 with localhost 127.0.0.1
and got results with size 50 KB only. Each time i submit the topology ,i
got same size. It suppose to get more than it . I checked the log files and
here is the worker.log
[INFO] Activating spout spout0:(57)
2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive thread
2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
connecting to lenovo:6703, bufferSize: 5242880
2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down receiving-thread:
[top-1-1500931668, 6703]
2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
Netty-Client-lenovo/192.168.x.x:6703 <http://192.168.1.5:6703/>
2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms to
send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
<http://192.168.1.5:6703/>
2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
receiving-thread:[top-1-1500931668, 6703] to die
2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
[top-1-1500931668, 6703]
2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging context
2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor b-6:[8
8]
2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor b-6:[8 8]
2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
b-9:[47 47]
2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
i hope i can find help , Thanks
Re: problem with the size of the result after submitting
Posted by sam mohel <sa...@gmail.com>.
up .. will appreciate any help
On Tue, Jul 25, 2017 at 2:23 PM, sam mohel <sa...@gmail.com> wrote:
> Can someone help , please?
>
> On Tuesday, July 25, 2017, sam mohel <sa...@gmail.com> wrote:
> > i attached log files for worker and supervisor files , Can someone help
> ?
> > On Tue, Jul 25, 2017 at 7:57 AM, sam mohel <sa...@gmail.com> wrote:
> >>
> >> in supervisor.log got
> >> 2017-07-25 07:35:20.137 b.s.d.supervisor [INFO] Worker Process
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810 exited with code: 20
> >> 2017-07-25 07:35:21.988 b.s.d.supervisor [INFO] Worker Process
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810 has died!
> >> 2017-07-25 07:35:21.994 b.s.d.supervisor [INFO] Shutting down and
> clearing state for id 42c31e1a-d6d9-45e7-99ce-ef2cb6293810. Current
> supervisor time: 1500960921. State: :timed-out, Heartbeat: {:time-secs
> 1500960919, :storm-id "top-1-1500960906", :executors [[8 8] [47 47] [12 12]
> [54 54] [2 2] [32 32] [41 41] [7 7] [51 51] [22 22] [42 42] [3 3] [56 56]
> [33 33] [24 24] [1 1] [39 39] [53 53] [40 40] [35 35] [43 43] [18 18] [6 6]
> [28 28] [38 38] [20 20] [9 9] [57 57] [48 48] [30 30] [23 23] [50 50] [11
> 11] [31 31] [-1 -1] [44 44] [16 16] [55 55] [13 13] [19 19] [52 52] [21 21]
> [5 5] [27 27] [29 29] [26 26] [45 45] [10 10] [37 37] [46 46] [14 14] [4 4]
> [36 36] [15 15] [34 34] [25 25] [49 49] [17 17]], :port 6703}
> >> 2017-07-25 07:35:21.995 b.s.d.supervisor [INFO] Shutting down
> 94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> >> 2017-07-25 07:35:21.996 b.s.config [INFO] GET worker-user
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> >> 2017-07-25 07:35:22.005 b.s.util [INFO] Error when trying to kill 4984.
> Process is probably already dead.
> >> 2017-07-25 07:35:22.005 b.s.d.supervisor [INFO] Sleep 1 seconds for
> execution of cleanup threads on worker.
> >> 2017-07-25 07:35:23.007 b.s.util [INFO] Error when trying to kill 4984.
> Process is probably already dead.
> >> 2017-07-25 07:35:23.009 b.s.config [INFO] REMOVE worker-user
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> >> 2017-07-25 07:35:23.009 b.s.d.supervisor [INFO] Shut down
> 94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> >> On Tue, Jul 25, 2017 at 1:08 AM, sam mohel <sa...@gmail.com> wrote:
> >>>
> >>> i submitted a topology using apache-storm -0.10.2 with localhost
> 127.0.0.1
> >>> and got results with size 50 KB only. Each time i submit the topology
> ,i got same size. It suppose to get more than it . I checked the log files
> and here is the worker.log
> >>> [INFO] Activating spout spout0:(57)
> >>> 2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
> >>> 2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry
> [INFO] The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries
> [5]
> >>> 2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry
> [INFO] The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries
> [5]
> >>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
> top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
> >>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive
> thread
> >>> 2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
> connecting to lenovo:6703, bufferSize: 5242880
> >>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down
> receiving-thread: [top-1-1500931668, 6703]
> >>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
> Netty-Client-lenovo/192.168.x.x:6703
> >>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms
> to send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
> >>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
> receiving-thread:[top-1-1500931668, 6703] to die
> >>> 2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
> [top-1-1500931668, 6703]
> >>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
> >>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging
> context
> >>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
> >>> 2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor
> b-6:[8 8]
> >>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
> >>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
> >>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor
> b-6:[8 8]
> >>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
> b-9:[47 47]
> >>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
> >>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
> >>>
> >>> i hope i can find help , Thanks
> >
> >
>
Re: problem with the size of the result after submitting
Posted by sam mohel <sa...@gmail.com>.
up .. will appreciate any help
On Tue, Jul 25, 2017 at 2:23 PM, sam mohel <sa...@gmail.com> wrote:
> Can someone help , please?
>
> On Tuesday, July 25, 2017, sam mohel <sa...@gmail.com> wrote:
> > i attached log files for worker and supervisor files , Can someone help
> ?
> > On Tue, Jul 25, 2017 at 7:57 AM, sam mohel <sa...@gmail.com> wrote:
> >>
> >> in supervisor.log got
> >> 2017-07-25 07:35:20.137 b.s.d.supervisor [INFO] Worker Process
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810 exited with code: 20
> >> 2017-07-25 07:35:21.988 b.s.d.supervisor [INFO] Worker Process
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810 has died!
> >> 2017-07-25 07:35:21.994 b.s.d.supervisor [INFO] Shutting down and
> clearing state for id 42c31e1a-d6d9-45e7-99ce-ef2cb6293810. Current
> supervisor time: 1500960921. State: :timed-out, Heartbeat: {:time-secs
> 1500960919, :storm-id "top-1-1500960906", :executors [[8 8] [47 47] [12 12]
> [54 54] [2 2] [32 32] [41 41] [7 7] [51 51] [22 22] [42 42] [3 3] [56 56]
> [33 33] [24 24] [1 1] [39 39] [53 53] [40 40] [35 35] [43 43] [18 18] [6 6]
> [28 28] [38 38] [20 20] [9 9] [57 57] [48 48] [30 30] [23 23] [50 50] [11
> 11] [31 31] [-1 -1] [44 44] [16 16] [55 55] [13 13] [19 19] [52 52] [21 21]
> [5 5] [27 27] [29 29] [26 26] [45 45] [10 10] [37 37] [46 46] [14 14] [4 4]
> [36 36] [15 15] [34 34] [25 25] [49 49] [17 17]], :port 6703}
> >> 2017-07-25 07:35:21.995 b.s.d.supervisor [INFO] Shutting down
> 94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> >> 2017-07-25 07:35:21.996 b.s.config [INFO] GET worker-user
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> >> 2017-07-25 07:35:22.005 b.s.util [INFO] Error when trying to kill 4984.
> Process is probably already dead.
> >> 2017-07-25 07:35:22.005 b.s.d.supervisor [INFO] Sleep 1 seconds for
> execution of cleanup threads on worker.
> >> 2017-07-25 07:35:23.007 b.s.util [INFO] Error when trying to kill 4984.
> Process is probably already dead.
> >> 2017-07-25 07:35:23.009 b.s.config [INFO] REMOVE worker-user
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> >> 2017-07-25 07:35:23.009 b.s.d.supervisor [INFO] Shut down
> 94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> >> On Tue, Jul 25, 2017 at 1:08 AM, sam mohel <sa...@gmail.com> wrote:
> >>>
> >>> i submitted a topology using apache-storm -0.10.2 with localhost
> 127.0.0.1
> >>> and got results with size 50 KB only. Each time i submit the topology
> ,i got same size. It suppose to get more than it . I checked the log files
> and here is the worker.log
> >>> [INFO] Activating spout spout0:(57)
> >>> 2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
> >>> 2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry
> [INFO] The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries
> [5]
> >>> 2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry
> [INFO] The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries
> [5]
> >>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
> top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
> >>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive
> thread
> >>> 2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
> connecting to lenovo:6703, bufferSize: 5242880
> >>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down
> receiving-thread: [top-1-1500931668, 6703]
> >>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
> Netty-Client-lenovo/192.168.x.x:6703
> >>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms
> to send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
> >>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
> receiving-thread:[top-1-1500931668, 6703] to die
> >>> 2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
> [top-1-1500931668, 6703]
> >>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
> >>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging
> context
> >>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
> >>> 2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor
> b-6:[8 8]
> >>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
> >>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
> >>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor
> b-6:[8 8]
> >>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
> b-9:[47 47]
> >>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
> >>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
> >>>
> >>> i hope i can find help , Thanks
> >
> >
>
Re: problem with the size of the result after submitting
Posted by sam mohel <sa...@gmail.com>.
Can someone help , please?
On Tuesday, July 25, 2017, sam mohel <sa...@gmail.com> wrote:
> i attached log files for worker and supervisor files , Can someone help ?
> On Tue, Jul 25, 2017 at 7:57 AM, sam mohel <sa...@gmail.com> wrote:
>>
>> in supervisor.log got
>> 2017-07-25 07:35:20.137 b.s.d.supervisor [INFO] Worker Process
42c31e1a-d6d9-45e7-99ce-ef2cb6293810 exited with code: 20
>> 2017-07-25 07:35:21.988 b.s.d.supervisor [INFO] Worker Process
42c31e1a-d6d9-45e7-99ce-ef2cb6293810 has died!
>> 2017-07-25 07:35:21.994 b.s.d.supervisor [INFO] Shutting down and
clearing state for id 42c31e1a-d6d9-45e7-99ce-ef2cb6293810. Current
supervisor time: 1500960921. State: :timed-out, Heartbeat: {:time-secs
1500960919, :storm-id "top-1-1500960906", :executors [[8 8] [47 47] [12 12]
[54 54] [2 2] [32 32] [41 41] [7 7] [51 51] [22 22] [42 42] [3 3] [56 56]
[33 33] [24 24] [1 1] [39 39] [53 53] [40 40] [35 35] [43 43] [18 18] [6 6]
[28 28] [38 38] [20 20] [9 9] [57 57] [48 48] [30 30] [23 23] [50 50] [11
11] [31 31] [-1 -1] [44 44] [16 16] [55 55] [13 13] [19 19] [52 52] [21 21]
[5 5] [27 27] [29 29] [26 26] [45 45] [10 10] [37 37] [46 46] [14 14] [4 4]
[36 36] [15 15] [34 34] [25 25] [49 49] [17 17]], :port 6703}
>> 2017-07-25 07:35:21.995 b.s.d.supervisor [INFO] Shutting down
94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>> 2017-07-25 07:35:21.996 b.s.config [INFO] GET worker-user
42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>> 2017-07-25 07:35:22.005 b.s.util [INFO] Error when trying to kill 4984.
Process is probably already dead.
>> 2017-07-25 07:35:22.005 b.s.d.supervisor [INFO] Sleep 1 seconds for
execution of cleanup threads on worker.
>> 2017-07-25 07:35:23.007 b.s.util [INFO] Error when trying to kill 4984.
Process is probably already dead.
>> 2017-07-25 07:35:23.009 b.s.config [INFO] REMOVE worker-user
42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>> 2017-07-25 07:35:23.009 b.s.d.supervisor [INFO] Shut down
94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>> On Tue, Jul 25, 2017 at 1:08 AM, sam mohel <sa...@gmail.com> wrote:
>>>
>>> i submitted a topology using apache-storm -0.10.2 with localhost
127.0.0.1
>>> and got results with size 50 KB only. Each time i submit the topology
,i got same size. It suppose to get more than it . I checked the log files
and here is the worker.log
>>> [INFO] Activating spout spout0:(57)
>>> 2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
>>> 2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry
[INFO] The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries
[5]
>>> 2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry
[INFO] The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries
[5]
>>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
>>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive thread
>>> 2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
connecting to lenovo:6703, bufferSize: 5242880
>>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down
receiving-thread: [top-1-1500931668, 6703]
>>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
Netty-Client-lenovo/192.168.x.x:6703
>>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms
to send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
>>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
receiving-thread:[top-1-1500931668, 6703] to die
>>> 2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
[top-1-1500931668, 6703]
>>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
>>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging
context
>>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
>>> 2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor
b-6:[8 8]
>>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
>>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
>>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor b-6:[8
8]
>>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
b-9:[47 47]
>>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>>>
>>> i hope i can find help , Thanks
>
>
Re: problem with the size of the result after submitting
Posted by sam mohel <sa...@gmail.com>.
Can someone help , please?
On Tuesday, July 25, 2017, sam mohel <sa...@gmail.com> wrote:
> i attached log files for worker and supervisor files , Can someone help ?
> On Tue, Jul 25, 2017 at 7:57 AM, sam mohel <sa...@gmail.com> wrote:
>>
>> in supervisor.log got
>> 2017-07-25 07:35:20.137 b.s.d.supervisor [INFO] Worker Process
42c31e1a-d6d9-45e7-99ce-ef2cb6293810 exited with code: 20
>> 2017-07-25 07:35:21.988 b.s.d.supervisor [INFO] Worker Process
42c31e1a-d6d9-45e7-99ce-ef2cb6293810 has died!
>> 2017-07-25 07:35:21.994 b.s.d.supervisor [INFO] Shutting down and
clearing state for id 42c31e1a-d6d9-45e7-99ce-ef2cb6293810. Current
supervisor time: 1500960921. State: :timed-out, Heartbeat: {:time-secs
1500960919, :storm-id "top-1-1500960906", :executors [[8 8] [47 47] [12 12]
[54 54] [2 2] [32 32] [41 41] [7 7] [51 51] [22 22] [42 42] [3 3] [56 56]
[33 33] [24 24] [1 1] [39 39] [53 53] [40 40] [35 35] [43 43] [18 18] [6 6]
[28 28] [38 38] [20 20] [9 9] [57 57] [48 48] [30 30] [23 23] [50 50] [11
11] [31 31] [-1 -1] [44 44] [16 16] [55 55] [13 13] [19 19] [52 52] [21 21]
[5 5] [27 27] [29 29] [26 26] [45 45] [10 10] [37 37] [46 46] [14 14] [4 4]
[36 36] [15 15] [34 34] [25 25] [49 49] [17 17]], :port 6703}
>> 2017-07-25 07:35:21.995 b.s.d.supervisor [INFO] Shutting down
94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>> 2017-07-25 07:35:21.996 b.s.config [INFO] GET worker-user
42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>> 2017-07-25 07:35:22.005 b.s.util [INFO] Error when trying to kill 4984.
Process is probably already dead.
>> 2017-07-25 07:35:22.005 b.s.d.supervisor [INFO] Sleep 1 seconds for
execution of cleanup threads on worker.
>> 2017-07-25 07:35:23.007 b.s.util [INFO] Error when trying to kill 4984.
Process is probably already dead.
>> 2017-07-25 07:35:23.009 b.s.config [INFO] REMOVE worker-user
42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>> 2017-07-25 07:35:23.009 b.s.d.supervisor [INFO] Shut down
94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>> On Tue, Jul 25, 2017 at 1:08 AM, sam mohel <sa...@gmail.com> wrote:
>>>
>>> i submitted a topology using apache-storm -0.10.2 with localhost
127.0.0.1
>>> and got results with size 50 KB only. Each time i submit the topology
,i got same size. It suppose to get more than it . I checked the log files
and here is the worker.log
>>> [INFO] Activating spout spout0:(57)
>>> 2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
>>> 2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry
[INFO] The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries
[5]
>>> 2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry
[INFO] The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries
[5]
>>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
>>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive thread
>>> 2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
connecting to lenovo:6703, bufferSize: 5242880
>>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down
receiving-thread: [top-1-1500931668, 6703]
>>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
Netty-Client-lenovo/192.168.x.x:6703
>>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms
to send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
>>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
receiving-thread:[top-1-1500931668, 6703] to die
>>> 2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
[top-1-1500931668, 6703]
>>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
>>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging
context
>>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
>>> 2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor
b-6:[8 8]
>>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
>>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
>>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor b-6:[8
8]
>>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
b-9:[47 47]
>>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>>>
>>> i hope i can find help , Thanks
>
>
Re: problem with the size of the result after submitting
Posted by sam mohel <sa...@gmail.com>.
i attached log files for worker and supervisor files , Can someone help ?
On Tue, Jul 25, 2017 at 7:57 AM, sam mohel <sa...@gmail.com> wrote:
> in supervisor.log got
> 2017-07-25 07:35:20.137 b.s.d.supervisor [INFO] Worker Process
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810 exited with code: 20
> 2017-07-25 07:35:21.988 b.s.d.supervisor [INFO] Worker Process
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810 has died!
> 2017-07-25 07:35:21.994 b.s.d.supervisor [INFO] Shutting down and clearing
> state for id 42c31e1a-d6d9-45e7-99ce-ef2cb6293810. Current supervisor
> time: 1500960921. State: :timed-out, Heartbeat: {:time-secs 1500960919,
> :storm-id "top-1-1500960906", :executors [[8 8] [47 47] [12 12] [54 54] [2
> 2] [32 32] [41 41] [7 7] [51 51] [22 22] [42 42] [3 3] [56 56] [33 33] [24
> 24] [1 1] [39 39] [53 53] [40 40] [35 35] [43 43] [18 18] [6 6] [28 28] [38
> 38] [20 20] [9 9] [57 57] [48 48] [30 30] [23 23] [50 50] [11 11] [31 31]
> [-1 -1] [44 44] [16 16] [55 55] [13 13] [19 19] [52 52] [21 21] [5 5] [27
> 27] [29 29] [26 26] [45 45] [10 10] [37 37] [46 46] [14 14] [4 4] [36 36]
> [15 15] [34 34] [25 25] [49 49] [17 17]], :port 6703}
> 2017-07-25 07:35:21.995 b.s.d.supervisor [INFO] Shutting down
> 94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> 2017-07-25 07:35:21.996 b.s.config [INFO] GET worker-user
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> 2017-07-25 07:35:22.005 b.s.util [INFO] Error when trying to kill 4984.
> Process is probably already dead.
> 2017-07-25 07:35:22.005 b.s.d.supervisor [INFO] Sleep 1 seconds for
> execution of cleanup threads on worker.
> 2017-07-25 07:35:23.007 b.s.util [INFO] Error when trying to kill 4984.
> Process is probably already dead.
> 2017-07-25 07:35:23.009 b.s.config [INFO] REMOVE worker-user
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> 2017-07-25 07:35:23.009 b.s.d.supervisor [INFO] Shut down
> 94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>
> On Tue, Jul 25, 2017 at 1:08 AM, sam mohel <sa...@gmail.com> wrote:
>
>> i submitted a topology using apache-storm -0.10.2 with localhost 127.0.0.1
>> and got results with size 50 KB only. Each time i submit the topology ,i
>> got same size. It suppose to get more than it . I checked the log files and
>> here is the worker.log
>>
>> [INFO] Activating spout spout0:(57)
>> 2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
>> 2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
>> The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
>> 2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
>> The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
>> top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive thread
>> 2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
>> connecting to lenovo:6703, bufferSize: 5242880
>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down
>> receiving-thread: [top-1-1500931668, 6703]
>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
>> Netty-Client-lenovo/192.168.x.x:6703 <http://192.168.1.5:6703/>
>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms to
>> send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
>> <http://192.168.1.5:6703/>
>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
>> receiving-thread:[top-1-1500931668, 6703] to die
>> 2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
>> [top-1-1500931668, 6703]
>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging context
>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
>> 2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor
>> b-6:[8 8]
>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor b-6:[8 8]
>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
>> b-9:[47 47]
>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>>
>>
>> i hope i can find help , Thanks
>>
>
>
Re: problem with the size of the result after submitting
Posted by sam mohel <sa...@gmail.com>.
i attached log files for worker and supervisor files , Can someone help ?
On Tue, Jul 25, 2017 at 7:57 AM, sam mohel <sa...@gmail.com> wrote:
> in supervisor.log got
> 2017-07-25 07:35:20.137 b.s.d.supervisor [INFO] Worker Process
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810 exited with code: 20
> 2017-07-25 07:35:21.988 b.s.d.supervisor [INFO] Worker Process
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810 has died!
> 2017-07-25 07:35:21.994 b.s.d.supervisor [INFO] Shutting down and clearing
> state for id 42c31e1a-d6d9-45e7-99ce-ef2cb6293810. Current supervisor
> time: 1500960921. State: :timed-out, Heartbeat: {:time-secs 1500960919,
> :storm-id "top-1-1500960906", :executors [[8 8] [47 47] [12 12] [54 54] [2
> 2] [32 32] [41 41] [7 7] [51 51] [22 22] [42 42] [3 3] [56 56] [33 33] [24
> 24] [1 1] [39 39] [53 53] [40 40] [35 35] [43 43] [18 18] [6 6] [28 28] [38
> 38] [20 20] [9 9] [57 57] [48 48] [30 30] [23 23] [50 50] [11 11] [31 31]
> [-1 -1] [44 44] [16 16] [55 55] [13 13] [19 19] [52 52] [21 21] [5 5] [27
> 27] [29 29] [26 26] [45 45] [10 10] [37 37] [46 46] [14 14] [4 4] [36 36]
> [15 15] [34 34] [25 25] [49 49] [17 17]], :port 6703}
> 2017-07-25 07:35:21.995 b.s.d.supervisor [INFO] Shutting down
> 94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> 2017-07-25 07:35:21.996 b.s.config [INFO] GET worker-user
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> 2017-07-25 07:35:22.005 b.s.util [INFO] Error when trying to kill 4984.
> Process is probably already dead.
> 2017-07-25 07:35:22.005 b.s.d.supervisor [INFO] Sleep 1 seconds for
> execution of cleanup threads on worker.
> 2017-07-25 07:35:23.007 b.s.util [INFO] Error when trying to kill 4984.
> Process is probably already dead.
> 2017-07-25 07:35:23.009 b.s.config [INFO] REMOVE worker-user
> 42c31e1a-d6d9-45e7-99ce-ef2cb6293810
> 2017-07-25 07:35:23.009 b.s.d.supervisor [INFO] Shut down
> 94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
>
> On Tue, Jul 25, 2017 at 1:08 AM, sam mohel <sa...@gmail.com> wrote:
>
>> i submitted a topology using apache-storm -0.10.2 with localhost 127.0.0.1
>> and got results with size 50 KB only. Each time i submit the topology ,i
>> got same size. It suppose to get more than it . I checked the log files and
>> here is the worker.log
>>
>> [INFO] Activating spout spout0:(57)
>> 2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
>> 2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
>> The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
>> 2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
>> The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
>> top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
>> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive thread
>> 2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
>> connecting to lenovo:6703, bufferSize: 5242880
>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down
>> receiving-thread: [top-1-1500931668, 6703]
>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
>> Netty-Client-lenovo/192.168.x.x:6703 <http://192.168.1.5:6703/>
>> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms to
>> send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
>> <http://192.168.1.5:6703/>
>> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
>> receiving-thread:[top-1-1500931668, 6703] to die
>> 2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
>> [top-1-1500931668, 6703]
>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging context
>> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
>> 2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor
>> b-6:[8 8]
>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
>> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor b-6:[8 8]
>> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
>> b-9:[47 47]
>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>>
>>
>> i hope i can find help , Thanks
>>
>
>
Re: problem with the size of the result after submitting
Posted by sam mohel <sa...@gmail.com>.
in supervisor.log got
2017-07-25 07:35:20.137 b.s.d.supervisor [INFO] Worker Process
42c31e1a-d6d9-45e7-99ce-ef2cb6293810 exited with code: 20
2017-07-25 07:35:21.988 b.s.d.supervisor [INFO] Worker Process
42c31e1a-d6d9-45e7-99ce-ef2cb6293810 has died!
2017-07-25 07:35:21.994 b.s.d.supervisor [INFO] Shutting down and clearing
state for id 42c31e1a-d6d9-45e7-99ce-ef2cb6293810. Current supervisor time:
1500960921. State: :timed-out, Heartbeat: {:time-secs 1500960919, :storm-id
"top-1-1500960906", :executors [[8 8] [47 47] [12 12] [54 54] [2 2] [32 32]
[41 41] [7 7] [51 51] [22 22] [42 42] [3 3] [56 56] [33 33] [24 24] [1 1]
[39 39] [53 53] [40 40] [35 35] [43 43] [18 18] [6 6] [28 28] [38 38] [20
20] [9 9] [57 57] [48 48] [30 30] [23 23] [50 50] [11 11] [31 31] [-1 -1]
[44 44] [16 16] [55 55] [13 13] [19 19] [52 52] [21 21] [5 5] [27 27] [29
29] [26 26] [45 45] [10 10] [37 37] [46 46] [14 14] [4 4] [36 36] [15 15]
[34 34] [25 25] [49 49] [17 17]], :port 6703}
2017-07-25 07:35:21.995 b.s.d.supervisor [INFO] Shutting down
94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
2017-07-25 07:35:21.996 b.s.config [INFO] GET worker-user
42c31e1a-d6d9-45e7-99ce-ef2cb6293810
2017-07-25 07:35:22.005 b.s.util [INFO] Error when trying to kill 4984.
Process is probably already dead.
2017-07-25 07:35:22.005 b.s.d.supervisor [INFO] Sleep 1 seconds for
execution of cleanup threads on worker.
2017-07-25 07:35:23.007 b.s.util [INFO] Error when trying to kill 4984.
Process is probably already dead.
2017-07-25 07:35:23.009 b.s.config [INFO] REMOVE worker-user
42c31e1a-d6d9-45e7-99ce-ef2cb6293810
2017-07-25 07:35:23.009 b.s.d.supervisor [INFO] Shut down
94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
On Tue, Jul 25, 2017 at 1:08 AM, sam mohel <sa...@gmail.com> wrote:
> i submitted a topology using apache-storm -0.10.2 with localhost 127.0.0.1
> and got results with size 50 KB only. Each time i submit the topology ,i
> got same size. It suppose to get more than it . I checked the log files and
> here is the worker.log
>
> [INFO] Activating spout spout0:(57)
> 2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
> 2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
> The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
> 2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
> The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
> top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive thread
> 2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
> connecting to lenovo:6703, bufferSize: 5242880
> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down
> receiving-thread: [top-1-1500931668, 6703]
> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
> Netty-Client-lenovo/192.168.x.x:6703 <http://192.168.1.5:6703/>
> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms to
> send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
> <http://192.168.1.5:6703/>
> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
> receiving-thread:[top-1-1500931668, 6703] to die
> 2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
> [top-1-1500931668, 6703]
> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging context
> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
> 2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor
> b-6:[8 8]
> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor b-6:[8 8]
> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
> b-9:[47 47]
> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>
>
> i hope i can find help , Thanks
>
Re: problem with the size of the result after submitting
Posted by sam mohel <sa...@gmail.com>.
in supervisor.log got
2017-07-25 07:35:20.137 b.s.d.supervisor [INFO] Worker Process
42c31e1a-d6d9-45e7-99ce-ef2cb6293810 exited with code: 20
2017-07-25 07:35:21.988 b.s.d.supervisor [INFO] Worker Process
42c31e1a-d6d9-45e7-99ce-ef2cb6293810 has died!
2017-07-25 07:35:21.994 b.s.d.supervisor [INFO] Shutting down and clearing
state for id 42c31e1a-d6d9-45e7-99ce-ef2cb6293810. Current supervisor time:
1500960921. State: :timed-out, Heartbeat: {:time-secs 1500960919, :storm-id
"top-1-1500960906", :executors [[8 8] [47 47] [12 12] [54 54] [2 2] [32 32]
[41 41] [7 7] [51 51] [22 22] [42 42] [3 3] [56 56] [33 33] [24 24] [1 1]
[39 39] [53 53] [40 40] [35 35] [43 43] [18 18] [6 6] [28 28] [38 38] [20
20] [9 9] [57 57] [48 48] [30 30] [23 23] [50 50] [11 11] [31 31] [-1 -1]
[44 44] [16 16] [55 55] [13 13] [19 19] [52 52] [21 21] [5 5] [27 27] [29
29] [26 26] [45 45] [10 10] [37 37] [46 46] [14 14] [4 4] [36 36] [15 15]
[34 34] [25 25] [49 49] [17 17]], :port 6703}
2017-07-25 07:35:21.995 b.s.d.supervisor [INFO] Shutting down
94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
2017-07-25 07:35:21.996 b.s.config [INFO] GET worker-user
42c31e1a-d6d9-45e7-99ce-ef2cb6293810
2017-07-25 07:35:22.005 b.s.util [INFO] Error when trying to kill 4984.
Process is probably already dead.
2017-07-25 07:35:22.005 b.s.d.supervisor [INFO] Sleep 1 seconds for
execution of cleanup threads on worker.
2017-07-25 07:35:23.007 b.s.util [INFO] Error when trying to kill 4984.
Process is probably already dead.
2017-07-25 07:35:23.009 b.s.config [INFO] REMOVE worker-user
42c31e1a-d6d9-45e7-99ce-ef2cb6293810
2017-07-25 07:35:23.009 b.s.d.supervisor [INFO] Shut down
94209043-2d37-47a0-b8b9-c37edfae8ccd:42c31e1a-d6d9-45e7-99ce-ef2cb6293810
On Tue, Jul 25, 2017 at 1:08 AM, sam mohel <sa...@gmail.com> wrote:
> i submitted a topology using apache-storm -0.10.2 with localhost 127.0.0.1
> and got results with size 50 KB only. Each time i submit the topology ,i
> got same size. It suppose to get more than it . I checked the log files and
> here is the worker.log
>
> [INFO] Activating spout spout0:(57)
> 2017-07-24 23:27:55.167 b.s.d.executor [INFO] Prepared bolt b-6:(10)
> 2017-07-24 23:27:55.141 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
> The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
> 2017-07-24 23:27:55.390 b.s.u.StormBoundedExponentialBackoffRetry [INFO]
> The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]
> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down worker
> top-1-1500931668 10dd0bf8-daf1-496e-8ea7-142810464250 6703
> 2017-07-24 23:28:00.342 b.s.d.worker [INFO] Shutting down receive thread
> 2017-07-24 23:28:00.378 b.s.m.n.Client [INFO] creating Netty Client,
> connecting to lenovo:6703, bufferSize: 5242880
> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Shutting down
> receiving-thread: [top-1-1500931668, 6703]
> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] closing Netty Client
> Netty-Client-lenovo/192.168.x.x:6703 <http://192.168.1.5:6703/>
> 2017-07-24 23:28:00.383 b.s.m.n.Client [INFO] waiting up to 600000 ms to
> send 0 pending messages to Netty-Client-lenovo/192.168.x.x:6703
> <http://192.168.1.5:6703/>
> 2017-07-24 23:28:00.383 b.s.m.loader [INFO] Waiting for
> receiving-thread:[top-1-1500931668, 6703] to die
> 2017-07-24 23:28:00.384 b.s.m.loader [INFO] Shutdown receiving-thread:
> [top-1-1500931668, 6703]
> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shut down receive thread
> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Terminating messaging context
> 2017-07-24 23:28:00.385 b.s.d.worker [INFO] Shutting down executors
> 2017-07-24 23:28:00.386 b.s.d.executor [INFO] Shutting down executor
> b-6:[8 8]
> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
> 2017-07-24 23:28:00.387 b.s.util [INFO] Async loop interrupted!
> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shut down executor b-6:[8 8]
> 2017-07-24 23:28:00.388 b.s.d.executor [INFO] Shutting down executor
> b-9:[47 47]
> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
> 2017-07-24 23:28:00.389 b.s.util [INFO] Async loop interrupted!
>
>
> i hope i can find help , Thanks
>