Skip to content

Instantly share code, notes, and snippets.

@mimani
mimani / host1
Created December 9, 2018 17:39
Logs-1 After fix Provided from PR: 2923
worker-6701.log:2018-12-09T22:47:14.866+05:30 KafkaSpout [INFO] No offsets to commit. KafkaSpout{offsetManagers ={myTopic-6=OffsetManager{topic-partition=myTopic-6, committedOffset=1682098, emittedOffsets=[1682098, 1682099, 1682100, 1682101, 1682102, 1682103, 1682104, 1682105, 1682106], ackedMsgs=[{topic-partition=myTopic-6, offset=1682099, numFails=0, emitted=true}, {topic-partition=myTopic-6, offset=1682100, numFails=0, emitted=true}, {topic-partition=myTopic-6, offset=1682101, numFails=0, emitted=true}, {topic-partition=myTopic-6, offset=1682102, numFails=0, emitted=true}, {topic-partition=myTopic-6, offset=1682105, numFails=0, emitted=true}], latestEmittedOffset=1682106}}, emitted=[{topic-partition=myTopic-6, offset=1682103, numFails=0, emitted=true}, {topic-partition=myTopic-6, offset=1682104, numFails=0, emitted=true}, {topic-partition=myTopic-6, offset=1682106, numFails=0, emitted=true}]}
worker-6701.log:2018-12-09T22:47:17.655+05:30 KafkaSpout [INFO] No offsets to commit. KafkaSpout{offsetManagers ={m
/var/log/storm/worker-6701.log:2018-12-08T09:29:17.263+05:30 KafkaSpout [INFO] No offsets to commit. KafkaSpout{offsetManagers ={myTopic-1=OffsetManager{topic-partition=myTopic-1, committedOffset=1647756, emittedOffsets=[1647756, 1647757, 1647758, 1647759, 1647760, 1647761, 1647762, 1647763, 1647764, 1647765, 1647766, 1647767, 1647768, 1647769, 1647770, 1647771, 1647772, 1647773, 1647774, 1647775, 1647776, 1647777, 1647778, 1647779, 1647780, 1647781], ackedMsgs=[{topic-partition=myTopic-1, offset=1647757, numFails=0, emitted=true}, {topic-partition=myTopic-1, offset=1647758, numFails=0, emitted=true}, {topic-partition=myTopic-1, offset=1647759, numFails=0, emitted=true}, {topic-partition=myTopic-1, offset=1647760, numFails=0, emitted=true}, {topic-partition=myTopic-1, offset=1647761, numFails=0, emitted=true}, {topic-partition=myTopic-1, offset=1647762, numFails=0, emitted=true}, {topic-partition=myTopic-1, offset=1647763, numFails=0, emitted=true}, {topic-partition=myTopic-1, offset=1647764, numFails=0, emit
/usr/bin/strace: [ Process PID=23482 runs in x32 mode. ]
/usr/bin/strace: [ Process PID=23481 runs in x32 mode. ]
/usr/bin/strace: [ Process PID=23480 runs in x32 mode. ]
[pid 24251] read(26, "PK\3\4\24\0\10\10\10\0kv\345L\0\0\0\0\0\0\0\0\0\0\0\0Y\0\0\0", 30) = 30
[pid 24251] read(26, "\265V]O\23A\24=\3\225\305\322j\5AQ\324\202(\245\5\212(\"\264V\371\266\6P,b"..., 851) = 851
[pid 23479] rt_sigprocmask(SIG_SETMASK, [QUIT], NULL, 8) = 0
[pid 23479] +++ exited with 0 +++
/usr/bin/strace: [ Process PID=23482 runs in 64 bit mode. ]
[pid 24436] recvfrom(290, "HTTP/1.1 200 OK\r\nContent-Type: a"..., 8192, 0, NULL, NULL) = 683
[pid 24435] recvfrom(291, "HTTP/1.1 200 OK\r\nContent-Type: a"..., 8192, 0, NULL, NULL) = 544
/usr/bin/strace: [ Process PID=23482 runs in x32 mode. ]
/usr/bin/strace: [ Process PID=23481 runs in x32 mode. ]
/usr/bin/strace: [ Process PID=23480 runs in x32 mode. ]
[pid 24251] read(26, "PK\3\4\24\0\10\10\10\0kv\345L\0\0\0\0\0\0\0\0\0\0\0\0Y\0\0\0", 30) = 30
[pid 24251] read(26, "\265V]O\23A\24=\3\225\305\322j\5AQ\324\202(\245\5\212(\"\264V\371\266\6P,b"..., 851) = 851
[pid 23479] rt_sigprocmask(SIG_SETMASK, [QUIT], NULL, 8) = 0
[pid 23479] +++ exited with 0 +++
/usr/bin/strace: [ Process PID=23482 runs in 64 bit mode. ]
[pid 24436] recvfrom(290, "HTTP/1.1 200 OK\r\nContent-Type: a"..., 8192, 0, NULL, NULL) = 683
[pid 24435] recvfrom(291, "HTTP/1.1 200 OK\r\nContent-Type: a"..., 8192, 0, NULL, NULL) = 544
[pid 23549] read(13, "PK\3\4\24\0\10\10\10\0000{PL\0\0\0\0\0\0\0\0\0\0\0\0004\0\0\0", 30) = 30
[pid 23549] read(13, "\225TmS\323@\20~\256\5BC\24\254\274\210\n\224W\333\202\255Ey-\"\25Z\5Z@\312"..., 790) = 790
[pid 23549] read(13, "PK\3\4\24\0\10\10\10\0000{PL\0\0\0\0\0\0\0\0\0\0\0\0006\0\0\0", 30) = 30
[pid 23549] read(13, "\225S[O\23A\24\376\246\205\266\f\265`\271\265r\261B\305R\240\333\372\200 \304\204 ML\352"..., 584) = 584
[pid 23549] read(13, "PK\3\4\24\0\10\10\10\0000{PL\0\0\0\0\0\0\0\0\0\0\0\0B\0\0\0", 30) = 30
[pid 23549] read(13, "\255TkO\323P\30~\316\270\254\224*0\221\233\202\343*\f\2661\256\23\246\210\243Ct0\262M"..., 777) = 777
[pid 23549] read(13, "PK\3\4\24\0\10\10\10\0000{PL\0\0\0\0\0\0\0\0\0\0\0\0@\0\0\0", 30) = 30
[pid 23549] read(13, "\245VmS\32W\24~./\202\353F\23\242Imk4\211ID\5\212\212Q\264m\f\202\222\360"..., 1180) = 1180
[pid 23549] read(13, "PK\3\4\24\0\10\10\10\0000{PL\0\0\0\0\0\0\0\0\0\0\0\0<\0\0\0", 30) = 30
[pid 23549] read(13, "}Smo\322P\24~.o\335j\225\211sn\352\34\272\351\200\31\0
[pid 31344] write(28, "rt:481, task_end:481), ExecutorI"..., 8192) = 8192
[pid 31344] write(28, "o(task_start:897, task_end:897),"..., 8192) = 8192
[pid 31344] write(28, "nd:423), ExecutorInfo(task_start"..., 8192) = 8192
[pid 31344] sendto(32, "<172>1 2018-05-19T14:39:08.504+0"..., 27211, 0, {sa_family=AF_INET6, sin6_port=htons(514), inet_pton(AF_INET6, "::ffff:127.0.0.1", &sin6_addr), sin6_flowinfo=0, sin6_scope_id=0}, 28) = 27211
[pid 31344] sendto(32, "<174>1 2018-05-19T14:39:08.507+0"..., 185, 0, {sa_family=AF_INET6, sin6_port=htons(514), inet_pton(AF_INET6, "::ffff:127.0.0.1", &sin6_addr), sin6_flowinfo=0, sin6_scope_id=0}, 28) = 185
[pid 31344] open("/home/saurabh/storm-run/workers/a7ac773f-24fe-43d7-b995-115c28486e77/pids", O_RDONLY|O_NONBLOCK|O_DIRECTORY|O_CLOEXEC) = 34
[pid 31344] getdents(34, /* 3 entries */, 32768) = 72
[pid 31344] getdents(34, /* 0 entries */, 32768) = 0
[pid 31344] close(34) = 0
[pid 31344] pipe([34, 53]) = 0

Effective Engineer - Notes

What's an Effective Engineer?

  • They are the people who get things done. Effective Engineers produce results.

Adopt the Right Mindsets