Created
January 20, 2016 14:43
-
-
Save jriquelme/144816586e3f421d00af to your computer and use it in GitHub Desktop.
random errors in kinesalite using NextShardIterator
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"fmt" | |
"log" | |
"strconv" | |
"sync" | |
"time" | |
"github.com/aws/aws-sdk-go/aws" | |
"github.com/aws/aws-sdk-go/aws/session" | |
"github.com/aws/aws-sdk-go/service/kinesis" | |
"github.com/davecgh/go-spew/spew" | |
) | |
var useKinesalite = true | |
func main() { | |
stream := "teststream" | |
var k *kinesis.Kinesis | |
if useKinesalite { | |
stream = fmt.Sprintf("teststream_%d", time.Now().Unix()) | |
cfg := aws.NewConfig().WithEndpoint("http://127.0.0.1:4567").WithRegion("us-east-1") | |
k = kinesis.New(session.New(), cfg) | |
createStream(stream, 8, k) | |
} else { | |
k = kinesis.New(session.New()) | |
} | |
// put records | |
n := 100 | |
for i := 0; i < n; i++ { | |
input := &kinesis.PutRecordInput{ | |
Data: []byte(fmt.Sprintf("record %d", i)), | |
PartitionKey: aws.String(strconv.Itoa(i)), | |
StreamName: aws.String(stream), | |
} | |
_, putErr := k.PutRecord(input) | |
if putErr != nil { | |
panic(putErr) | |
} | |
} | |
log.Print("frames sent") | |
// check | |
desc, descErr := k.DescribeStream(&kinesis.DescribeStreamInput{ | |
StreamName: aws.String(stream), | |
}) | |
if descErr != nil { | |
panic(descErr) | |
} | |
if *desc.StreamDescription.StreamStatus != "ACTIVE" { | |
spew.Dump(desc.StreamDescription) | |
panic("invalid stream status") | |
} | |
// read from each shard | |
msgs := make(chan []byte, n) | |
var wg sync.WaitGroup | |
for _, shard := range desc.StreamDescription.Shards { | |
wg.Add(1) | |
// one go routine per shard | |
go func(shardID *string) { | |
defer wg.Done() | |
log.Printf("reading from shard %s", *shardID) | |
itOut, itErr := k.GetShardIterator(&kinesis.GetShardIteratorInput{ | |
ShardId: shardID, | |
ShardIteratorType: aws.String("TRIM_HORIZON"), | |
StreamName: aws.String(stream), | |
}) | |
if itErr != nil { | |
panic(itErr) | |
} | |
// get records... | |
shardIt := itOut.ShardIterator | |
for { | |
getOut, getErr := k.GetRecords(&kinesis.GetRecordsInput{ | |
Limit: aws.Int64(10), | |
ShardIterator: shardIt, | |
}) | |
if getErr != nil { | |
panic(getErr) | |
} | |
log.Printf("%d records read from shard %s with iterator %s (MillisBehindLatest=%d)", len(getOut.Records), *shardID, *shardIt, *getOut.MillisBehindLatest) | |
for _, r := range getOut.Records { | |
msgs <- r.Data | |
} | |
// stop if we got nothing and MillisBehindLatest is zero... | |
if len(getOut.Records) == 0 && *getOut.MillisBehindLatest == 0 { | |
log.Printf("done with shard %s", *shardID) | |
return | |
} | |
shardIt = getOut.NextShardIterator | |
// or if the shard was closed | |
if shardIt == nil { | |
log.Printf("done with shard %s, closed", *shardID) | |
return | |
} | |
} | |
}(shard.ShardId) | |
} | |
wg.Wait() | |
close(msgs) | |
log.Print("records fetched") | |
// print and count messages | |
c := 0 | |
for msg := range msgs { | |
fmt.Sprintf("<- %s", msg) | |
c++ | |
} | |
log.Printf("%d messages", c) | |
} | |
func createStream(name string, shards int64, k *kinesis.Kinesis) { | |
log.Printf("creating stream %s", name) | |
_, err := k.CreateStream(&kinesis.CreateStreamInput{ | |
ShardCount: aws.Int64(shards), | |
StreamName: aws.String(name), | |
}) | |
if err != nil { | |
panic(err) | |
} | |
statusloop: | |
for { | |
output, err := k.DescribeStream(&kinesis.DescribeStreamInput{ | |
StreamName: aws.String(name), | |
}) | |
if err != nil { | |
panic(err) | |
} | |
status := *(output.StreamDescription.StreamStatus) | |
switch status { | |
case "CREATING": | |
case "ACTIVE": | |
break statusloop | |
default: | |
panic(fmt.Sprintf("invalid status %s", status)) | |
} | |
} | |
log.Printf("stream %s created", name) | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2016/01/20 11:25:35 creating stream teststream_1453299935 | |
2016/01/20 11:25:36 stream teststream_1453299935 created | |
2016/01/20 11:25:36 frames sent | |
2016/01/20 11:25:36 reading from shard shardId-000000000007 | |
2016/01/20 11:25:36 reading from shard shardId-000000000003 | |
2016/01/20 11:25:36 reading from shard shardId-000000000001 | |
2016/01/20 11:25:36 reading from shard shardId-000000000005 | |
2016/01/20 11:25:36 reading from shard shardId-000000000006 | |
2016/01/20 11:25:36 reading from shard shardId-000000000000 | |
2016/01/20 11:25:36 reading from shard shardId-000000000002 | |
2016/01/20 11:25:36 reading from shard shardId-000000000004 | |
2016/01/20 11:25:36 5 records read from shard shardId-000000000002 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdAp4vqvDPdhdfCOQO9tv23ocqtxsPB/qO7BlgjsSx+IHkbyzVTgAT81SPS6H4GALMbDwABc4I+8gnK6waK48MYpXRsxLzhJ8VwgALmm/YQW+CnKZer3VY9uL+xle+g1zf5NgTM8vgQwrA8FaL18L0k9Z (MillisBehindLatest=0) | |
2016/01/20 11:25:36 0 records read from shard shardId-000000000002 with iterator AAAAAAAAAAEFnRepSIIy7CmtuBJxgJ9sacV1NKlC/7njtoXJ1crOM0Y1xGvx2x4EvEzKYuqsFVo3cM6xwywpuUtMN0LCTLCP2vImoWFwrTtI7FiGOprEBVRWarRIRl2GfaJ/FedxF1fZNDum0jdWpc0F0yDoxCIXKOc1yFydO7ksJaqws34pNt8i4X7V2ae2YX7AF8tGOIjvGJBj6ZxflEyJ42FK8sVH (MillisBehindLatest=0) | |
2016/01/20 11:25:36 done with shard shardId-000000000002 | |
2016/01/20 11:25:36 10 records read from shard shardId-000000000003 with iterator AAAAAAAAAAHRAu2VrJTmHaa46zTaq7zHqC+oC7X5+Yd/iGpBQcEDWTe35B02buUNwqNBixxbwjQe3CcxqSRTC3JMB2tFvSc6OcBKC5U08x+Xe+woq9nhUDvyCCbyDpj7cjq0TU4tP5sxD+FFQMJdS+iVIvT7dF+VZDqceQRz7ZTUdQvr5HeEfmg17SYFam/ER5FTrUtEnuZfvB6TB9OJOWCMT2RipDLH (MillisBehindLatest=0) | |
2016/01/20 11:25:36 10 records read from shard shardId-000000000005 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdAoc3Yh1p6B02Hpy+NpZMQqZk3RO3UPzI6/agokI2ghL3uVtg/c2tlx+5DKDF+bMYRoB4gyMxv3W0H+ZVW0PC/Ush1dyQSb8vJb0Bg/7vsQhP0x/XIjLsNV0BXrlOc0NGFYuSH0/N8krTE+VM4KwYvAd (MillisBehindLatest=0) | |
2016/01/20 11:25:36 10 records read from shard shardId-000000000007 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdAqdOkunoisyMwd9wkleRuRBLNDuTD+4te8cOs+yb2nmpS2JMGlio81FJbuS1L7loAofBF+Hd6ofSGoJBQ+xJ1KDwntKh18eFT4+aE6QJRXpV142s+zUfM7kxK6V3zZ9sh2/I9WZ9VjqlbF+GiCnIqfs (MillisBehindLatest=0) | |
2016/01/20 11:25:36 10 records read from shard shardId-000000000001 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdApKcsw6+QKb6RoJfJCZkWXtaMuvUL4PX0RfFJd4fK9NGdWwmWFG+zatoiLu00tqR/h5de8AjnSuMSvttBd2jfrpa8X6Sxi4u2RXDZBsw7oDNigppmNO3Dev4WuHUnatM1/ymfBddeL0Y3CEO/XuWpq9 (MillisBehindLatest=0) | |
2016/01/20 11:25:36 10 records read from shard shardId-000000000006 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdApKFJjcXX8eEEJaGFTRn1V+9Yyy+DxcCO+hzEXWq/70IdHqM/Ix2iMatggYL1TQ+H66LQgG6Yh1+84/N5Atc3FQyAEndmwBvE3lfbSx9MSC7MMlXGsqv8UZntUoQC5JKj1dhyIPN/yiZuFQJq63OAiI (MillisBehindLatest=0) | |
2016/01/20 11:25:36 10 records read from shard shardId-000000000000 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdArSdpATBn6KpYERaVzRNZHu8muBn2t69UVfglsboJMr9XZHx6+BjmLjlbCi1mvQevXvevSrEaGUtBb5j0BD2j48jA+VAjcNDmCJY0AGlrMY7agKBjSUqy8e+QYzL6i0DRfHz5TIvB2vFhpUiJ8tDWJG (MillisBehindLatest=0) | |
2016/01/20 11:25:36 10 records read from shard shardId-000000000004 with iterator AAAAAAAAAAEAXWyvODL1agawune1OTCTK7Pk/wFfNwn6TAgmzFItFUhZS/zc/0XY4DhfNQBRdAohbOHNhAB+/XIGgFGTKjEPr5ipBoPVsFns7UIVPnlZxwAKUKFXCQLhFS17TMgkQPbWPQo2XFx/IdF77s+koeNOUO+Gc7w4SvzKrJi8CN9ryzDMNAOndWbSjGjuy0DHS3LSBZhOdeURnojZTZd3ecmz (MillisBehindLatest=0) | |
2016/01/20 11:25:36 1 records read from shard shardId-000000000005 with iterator AAAAAAAAAAHNpnN3rz+7nkQHJL3DRJVDYRtp4wuNKGlwgQrdN+lB4GuzgUHDC4wwYLBVpBbm54uKHgyjYBn3ekZUcVeFftIOgID+YwWpJyWbWOQbHkiALo0XXFtFX0bEe0+S1V43n3d5cJSDv7xpAQNpUnDSg4V9Y7Q75tDZiatZUfJe7yau2uQdSR3mEABh8cDOHKjaSSCownU+mvDAl3wxotIUm7Le (MillisBehindLatest=0) | |
2016/01/20 11:25:36 2 records read from shard shardId-000000000000 with iterator AAAAAAAAAAHmNu/M6jRPf929Ab4YwbaxUdXCErCqp4rJITq6Zf7Uz1bBxAzLVVoQkVNBHjT+fClmtpHWZMhzRHM30f8c5dalPrSi72S5XR/aDIPfP97w8yrrPGLc6WkK7eZCmdyXOacDVoaM2LCnDn2S1M/ws2O5V6HV6JguLrxpm/S4lA/ajmB4hTNca/citTJJ6WggwDI5KCYyeIMXQyTelR/jP9EV (MillisBehindLatest=0) | |
panic: InvalidArgumentException: Invalid ShardIterator. | |
status code: 400, request id: ac2e4cb0-bf81-11e5-813b-3d874e374272 | |
goroutine 25 [running]: | |
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc820135270) | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:82 +0x39d | |
created by main.main | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7 | |
goroutine 1 [semacquire]: | |
sync.runtime_Semacquire(0xc8201357bc) | |
/usr/local/go/src/runtime/sema.go:43 +0x26 | |
sync.(*WaitGroup).Wait(0xc8201357b0) | |
/usr/local/go/src/sync/waitgroup.go:126 +0xb4 | |
main.main() | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:103 +0xafa | |
goroutine 17 [syscall, locked to thread]: | |
runtime.goexit() | |
/usr/local/go/src/runtime/asm_amd64.s:1721 +0x1 | |
goroutine 20 [select]: | |
net/http.(*persistConn).roundTrip(0xc820172000, 0xc82044e140, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1164 +0xb0d | |
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82021b5e0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:235 +0x530 | |
net/http.send(0xc82021b5e0, 0x7f6967af74d8, 0xc820086090, 0xc820445140, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:220 +0x52c | |
net/http.(*Client).send(0x9f94c0, 0xc82021b5e0, 0x16, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:143 +0x15a | |
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82021b5e0, 0x8be950, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:380 +0xbc0 | |
net/http.(*Client).Do(0x9f94c0, 0xc82021b5e0, 0x14, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:178 +0x188 | |
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820343600) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55 | |
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820343730, 0xc820343600) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f | |
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820343600, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c | |
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc820444d80, 0xc820421488, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f | |
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc8201347d0) | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350 | |
created by main.main | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7 | |
goroutine 18 [IO wait]: | |
net.runtime_pollWait(0x7f6967af89f8, 0x72, 0xc82000a200) | |
/usr/local/go/src/runtime/netpoll.go:157 +0x60 | |
net.(*pollDesc).Wait(0xc820061cd0, 0x72, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a | |
net.(*pollDesc).WaitRead(0xc820061cd0, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 | |
net.(*netFD).Read(0xc820061c70, 0xc8200d0000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200) | |
/usr/local/go/src/net/fd_unix.go:232 +0x23a | |
net.(*conn).Read(0xc8200ca000, 0xc8200d0000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/net.go:172 +0xe4 | |
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc8200ca000, 0xc8200c4058, 0xc8200d0000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1370 +0x67 | |
net/http.(*noteEOFReader).Read(0xc8200c6040, 0xc8200d0000, 0x1000, 0x1000, 0xc82021c310, 0x0, 0x0) | |
<autogenerated>:126 +0xd0 | |
bufio.(*Reader).fill(0xc8200ce000) | |
/usr/local/go/src/bufio/bufio.go:97 +0x1e9 | |
bufio.(*Reader).Peek(0xc8200ce000, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/bufio/bufio.go:132 +0xcc | |
net/http.(*persistConn).readLoop(0xc8200c4000) | |
/usr/local/go/src/net/http/transport.go:876 +0xf7 | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:685 +0xc78 | |
goroutine 19 [select]: | |
net/http.(*persistConn).writeLoop(0xc8200c4000) | |
/usr/local/go/src/net/http/transport.go:1009 +0x40c | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:686 +0xc9d | |
goroutine 21 [runnable]: | |
net/http.(*persistConn).roundTrip(0xc820394000, 0xc8204320f0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1164 +0xb0d | |
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82021b260, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:235 +0x530 | |
net/http.send(0xc82021b260, 0x7f6967af74d8, 0xc820086090, 0xc8201bde80, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:220 +0x52c | |
net/http.(*Client).send(0x9f94c0, 0xc82021b260, 0x16, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:143 +0x15a | |
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82021b260, 0x8be950, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:380 +0xbc0 | |
net/http.(*Client).Do(0x9f94c0, 0xc82021b260, 0x14, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:178 +0x188 | |
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820343080) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55 | |
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc8203431b0, 0xc820343080) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f | |
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820343080, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c | |
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc8201bdac0, 0xc820420948, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f | |
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc8201349f0) | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350 | |
created by main.main | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7 | |
goroutine 23 [select]: | |
net/http.(*persistConn).roundTrip(0xc8200c4000, 0xc8201d4520, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1164 +0xb0d | |
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82036c460, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:235 +0x530 | |
net/http.send(0xc82036c460, 0x7f6967af74d8, 0xc820086090, 0xc820353a00, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:220 +0x52c | |
net/http.(*Client).send(0x9f94c0, 0xc82036c460, 0x16, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:143 +0x15a | |
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82036c460, 0x8be950, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:380 +0xbc0 | |
net/http.(*Client).Do(0x9f94c0, 0xc82036c460, 0x14, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:178 +0x188 | |
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820370840) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55 | |
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820370970, 0xc820370840) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f | |
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820370840, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c | |
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc820353640, 0xc820358f48, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f | |
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc820134e30) | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350 | |
created by main.main | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7 | |
goroutine 24 [select]: | |
net/http.(*persistConn).roundTrip(0xc8203920b0, 0xc820433790, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1164 +0xb0d | |
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82021b420, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:235 +0x530 | |
net/http.send(0xc82021b420, 0x7f6967af74d8, 0xc820086090, 0xc820444a60, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:220 +0x52c | |
net/http.(*Client).send(0x9f94c0, 0xc82021b420, 0x16, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:143 +0x15a | |
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82021b420, 0x8be950, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:380 +0xbc0 | |
net/http.(*Client).Do(0x9f94c0, 0xc82021b420, 0x14, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:178 +0x188 | |
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820343340) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55 | |
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820343470, 0xc820343340) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f | |
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820343340, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c | |
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc8204446a0, 0xc820421108, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f | |
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc820135050) | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350 | |
created by main.main | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7 | |
goroutine 26 [select]: | |
net/http.(*persistConn).roundTrip(0xc820152000, 0xc8201d5bc0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1164 +0xb0d | |
net/http.(*Transport).RoundTrip(0xc820086090, 0xc82036c620, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:235 +0x530 | |
net/http.send(0xc82036c620, 0x7f6967af74d8, 0xc820086090, 0xc8204345e0, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:220 +0x52c | |
net/http.(*Client).send(0x9f94c0, 0xc82036c620, 0x16, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:143 +0x15a | |
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc82036c620, 0x8be950, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:380 +0xbc0 | |
net/http.(*Client).Do(0x9f94c0, 0xc82036c620, 0x14, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:178 +0x188 | |
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820370b00) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55 | |
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820370c30, 0xc820370b00) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f | |
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820370b00, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c | |
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc820434220, 0xc820359708, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f | |
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc820135490) | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350 | |
created by main.main | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7 | |
goroutine 27 [select]: | |
net/http.(*persistConn).roundTrip(0xc8200c40b0, 0xc8201c9950, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1164 +0xb0d | |
net/http.(*Transport).RoundTrip(0xc820086090, 0xc8203788c0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:235 +0x530 | |
net/http.send(0xc8203788c0, 0x7f6967af74d8, 0xc820086090, 0xc8204287e0, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:220 +0x52c | |
net/http.(*Client).send(0x9f94c0, 0xc8203788c0, 0x16, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:143 +0x15a | |
net/http.(*Client).doFollowingRedirects(0x9f94c0, 0xc8203788c0, 0x8be950, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:380 +0xbc0 | |
net/http.(*Client).Do(0x9f94c0, 0xc8203788c0, 0x14, 0x0, 0x0) | |
/usr/local/go/src/net/http/client.go:178 +0x188 | |
github.com/aws/aws-sdk-go/aws/corehandlers.glob.func2(0xc820388dc0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/corehandlers/handlers.go:65 +0x55 | |
github.com/aws/aws-sdk-go/aws/request.(*HandlerList).Run(0xc820388ef0, 0xc820388dc0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/handlers.go:115 +0x9f | |
github.com/aws/aws-sdk-go/aws/request.(*Request).Send(0xc820388dc0, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/aws/request/request.go:225 +0x57c | |
github.com/aws/aws-sdk-go/service/kinesis.(*Kinesis).GetRecords(0xc8200340a0, 0xc820428420, 0xc8203677c8, 0x0, 0x0) | |
/home/jriquelme/mt/vendor/src/github.com/aws/aws-sdk-go/service/kinesis/api.go:318 +0x4f | |
main.main.func1(0xc8201357b0, 0xc820034078, 0xc82000b7c0, 0xc82011db00, 0xc8201356b0) | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:80 +0x350 | |
created by main.main | |
/home/jriquelme/mt/src/bitbucket.org/larixsource/kstest.go:101 +0xac7 | |
goroutine 35 [IO wait]: | |
net.runtime_pollWait(0x7f6967af8938, 0x72, 0xc82000a200) | |
/usr/local/go/src/runtime/netpoll.go:157 +0x60 | |
net.(*pollDesc).Wait(0xc820376220, 0x72, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a | |
net.(*pollDesc).WaitRead(0xc820376220, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 | |
net.(*netFD).Read(0xc8203761c0, 0xc82015c000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200) | |
/usr/local/go/src/net/fd_unix.go:232 +0x23a | |
net.(*conn).Read(0xc820034020, 0xc82015c000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/net.go:172 +0xe4 | |
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc820034020, 0xc820392058, 0xc82015c000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1370 +0x67 | |
net/http.(*noteEOFReader).Read(0xc820352460, 0xc82015c000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0) | |
<autogenerated>:126 +0xd0 | |
bufio.(*Reader).fill(0xc82037a7e0) | |
/usr/local/go/src/bufio/bufio.go:97 +0x1e9 | |
bufio.(*Reader).Peek(0xc82037a7e0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/bufio/bufio.go:132 +0xcc | |
net/http.(*persistConn).readLoop(0xc820392000) | |
/usr/local/go/src/net/http/transport.go:876 +0xf7 | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:685 +0xc78 | |
goroutine 29 [IO wait]: | |
net.runtime_pollWait(0x7f6967af8878, 0x72, 0xc82000a200) | |
/usr/local/go/src/runtime/netpoll.go:157 +0x60 | |
net.(*pollDesc).Wait(0xc820101640, 0x72, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a | |
net.(*pollDesc).WaitRead(0xc820101640, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 | |
net.(*netFD).Read(0xc8201015e0, 0xc82015e000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200) | |
/usr/local/go/src/net/fd_unix.go:232 +0x23a | |
net.(*conn).Read(0xc82021c2c8, 0xc82015e000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/net.go:172 +0xe4 | |
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc82021c2c8, 0xc8200c4108, 0xc82015e000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1370 +0x67 | |
net/http.(*noteEOFReader).Read(0xc82012d200, 0xc82015e000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0) | |
<autogenerated>:126 +0xd0 | |
bufio.(*Reader).fill(0xc82037c3c0) | |
/usr/local/go/src/bufio/bufio.go:97 +0x1e9 | |
bufio.(*Reader).Peek(0xc82037c3c0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/bufio/bufio.go:132 +0xcc | |
net/http.(*persistConn).readLoop(0xc8200c40b0) | |
/usr/local/go/src/net/http/transport.go:876 +0xf7 | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:685 +0xc78 | |
goroutine 36 [select]: | |
net/http.(*persistConn).writeLoop(0xc820392000) | |
/usr/local/go/src/net/http/transport.go:1009 +0x40c | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:686 +0xc9d | |
goroutine 67 [IO wait]: | |
net.runtime_pollWait(0x7f6967af86f8, 0x72, 0xc82000a200) | |
/usr/local/go/src/runtime/netpoll.go:157 +0x60 | |
net.(*pollDesc).Wait(0xc82038c220, 0x72, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a | |
net.(*pollDesc).WaitRead(0xc82038c220, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 | |
net.(*netFD).Read(0xc82038c1c0, 0xc82016e000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200) | |
/usr/local/go/src/net/fd_unix.go:232 +0x23a | |
net.(*conn).Read(0xc82014e008, 0xc82016e000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/net.go:172 +0xe4 | |
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc82014e008, 0xc820152058, 0xc82016e000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1370 +0x67 | |
net/http.(*noteEOFReader).Read(0xc820364460, 0xc82016e000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0) | |
<autogenerated>:126 +0xd0 | |
bufio.(*Reader).fill(0xc82038e7e0) | |
/usr/local/go/src/bufio/bufio.go:97 +0x1e9 | |
bufio.(*Reader).Peek(0xc82038e7e0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/bufio/bufio.go:132 +0xcc | |
net/http.(*persistConn).readLoop(0xc820152000) | |
/usr/local/go/src/net/http/transport.go:876 +0xf7 | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:685 +0xc78 | |
goroutine 68 [select]: | |
net/http.(*persistConn).writeLoop(0xc820152000) | |
/usr/local/go/src/net/http/transport.go:1009 +0x40c | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:686 +0xc9d | |
goroutine 30 [select]: | |
net/http.(*persistConn).writeLoop(0xc8200c40b0) | |
/usr/local/go/src/net/http/transport.go:1009 +0x40c | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:686 +0xc9d | |
goroutine 82 [select]: | |
net/http.(*persistConn).readLoop(0xc820394000) | |
/usr/local/go/src/net/http/transport.go:976 +0xac7 | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:685 +0xc78 | |
goroutine 83 [select]: | |
net/http.(*persistConn).writeLoop(0xc820394000) | |
/usr/local/go/src/net/http/transport.go:1009 +0x40c | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:686 +0xc9d | |
goroutine 98 [IO wait]: | |
net.runtime_pollWait(0x7f6967af8638, 0x72, 0xc82000a200) | |
/usr/local/go/src/runtime/netpoll.go:157 +0x60 | |
net.(*pollDesc).Wait(0xc820201f00, 0x72, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a | |
net.(*pollDesc).WaitRead(0xc820201f00, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 | |
net.(*netFD).Read(0xc820201ea0, 0xc82019e000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200) | |
/usr/local/go/src/net/fd_unix.go:232 +0x23a | |
net.(*conn).Read(0xc82032e2e0, 0xc82019e000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/net.go:172 +0xe4 | |
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc82032e2e0, 0xc820172058, 0xc82019e000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1370 +0x67 | |
net/http.(*noteEOFReader).Read(0xc82012af00, 0xc82019e000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0) | |
<autogenerated>:126 +0xd0 | |
bufio.(*Reader).fill(0xc82015a1e0) | |
/usr/local/go/src/bufio/bufio.go:97 +0x1e9 | |
bufio.(*Reader).Peek(0xc82015a1e0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/bufio/bufio.go:132 +0xcc | |
net/http.(*persistConn).readLoop(0xc820172000) | |
/usr/local/go/src/net/http/transport.go:876 +0xf7 | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:685 +0xc78 | |
goroutine 99 [select]: | |
net/http.(*persistConn).writeLoop(0xc820172000) | |
/usr/local/go/src/net/http/transport.go:1009 +0x40c | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:686 +0xc9d | |
goroutine 52 [IO wait]: | |
net.runtime_pollWait(0x7f6967af8578, 0x72, 0xc82000a200) | |
/usr/local/go/src/runtime/netpoll.go:157 +0x60 | |
net.(*pollDesc).Wait(0xc8204d46f0, 0x72, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a | |
net.(*pollDesc).WaitRead(0xc8204d46f0, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 | |
net.(*netFD).Read(0xc8204d4690, 0xc8201a0000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200) | |
/usr/local/go/src/net/fd_unix.go:232 +0x23a | |
net.(*conn).Read(0xc8200ca028, 0xc8201a0000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/net.go:172 +0xe4 | |
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc8200ca028, 0xc820394108, 0xc8201a0000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1370 +0x67 | |
net/http.(*noteEOFReader).Read(0xc82000f960, 0xc8201a0000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
<autogenerated>:126 +0xd0 | |
bufio.(*Reader).fill(0xc8200cf800) | |
/usr/local/go/src/bufio/bufio.go:97 +0x1e9 | |
bufio.(*Reader).Peek(0xc8200cf800, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/bufio/bufio.go:132 +0xcc | |
net/http.(*persistConn).readLoop(0xc8203940b0) | |
/usr/local/go/src/net/http/transport.go:876 +0xf7 | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:685 +0xc78 | |
goroutine 53 [select]: | |
net/http.(*persistConn).writeLoop(0xc8203940b0) | |
/usr/local/go/src/net/http/transport.go:1009 +0x40c | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:686 +0xc9d | |
goroutine 38 [IO wait]: | |
net.runtime_pollWait(0x7f6967af84b8, 0x72, 0xc82000a200) | |
/usr/local/go/src/runtime/netpoll.go:157 +0x60 | |
net.(*pollDesc).Wait(0xc8203764c0, 0x72, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:73 +0x3a | |
net.(*pollDesc).WaitRead(0xc8203764c0, 0x0, 0x0) | |
/usr/local/go/src/net/fd_poll_runtime.go:78 +0x36 | |
net.(*netFD).Read(0xc820376460, 0xc8201aa000, 0x1000, 0x1000, 0x0, 0x7f6967af3050, 0xc82000a200) | |
/usr/local/go/src/net/fd_unix.go:232 +0x23a | |
net.(*conn).Read(0xc820034030, 0xc8201aa000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/net.go:172 +0xe4 | |
net/http.noteEOFReader.Read(0x7f6965ca7000, 0xc820034030, 0xc820392108, 0xc8201aa000, 0x1000, 0x1000, 0x0, 0x0, 0x0) | |
/usr/local/go/src/net/http/transport.go:1370 +0x67 | |
net/http.(*noteEOFReader).Read(0xc820352940, 0xc8201aa000, 0x1000, 0x1000, 0xc820345030, 0x0, 0x0) | |
<autogenerated>:126 +0xd0 | |
bufio.(*Reader).fill(0xc82037b140) | |
/usr/local/go/src/bufio/bufio.go:97 +0x1e9 | |
bufio.(*Reader).Peek(0xc82037b140, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0) | |
/usr/local/go/src/bufio/bufio.go:132 +0xcc | |
net/http.(*persistConn).readLoop(0xc8203920b0) | |
/usr/local/go/src/net/http/transport.go:876 +0xf7 | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:685 +0xc78 | |
goroutine 39 [select]: | |
net/http.(*persistConn).writeLoop(0xc8203920b0) | |
/usr/local/go/src/net/http/transport.go:1009 +0x40c | |
created by net/http.(*Transport).dialConn | |
/usr/local/go/src/net/http/transport.go:686 +0xc9d | |
exit status 2 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2016/01/20 11:25:23 creating stream teststream_1453299923 | |
2016/01/20 11:25:23 stream teststream_1453299923 created | |
2016/01/20 11:25:23 frames sent | |
2016/01/20 11:25:23 reading from shard shardId-000000000007 | |
2016/01/20 11:25:23 reading from shard shardId-000000000000 | |
2016/01/20 11:25:23 reading from shard shardId-000000000003 | |
2016/01/20 11:25:23 reading from shard shardId-000000000005 | |
2016/01/20 11:25:23 reading from shard shardId-000000000004 | |
2016/01/20 11:25:23 reading from shard shardId-000000000001 | |
2016/01/20 11:25:23 reading from shard shardId-000000000006 | |
2016/01/20 11:25:23 reading from shard shardId-000000000002 | |
2016/01/20 11:25:23 5 records read from shard shardId-000000000002 with iterator AAAAAAAAAAGVTG2xIRBLGw4zEybQRl9TpIuQJJ6QeW6HKVn0OKJzJDdvErSEYlV6LKTFVQKLJtAn6zCe8fZPO6ZgAZU4h+hwfQKG7NZ0N1i8ry7RMcZHZ3nxs14cofZ1n4ghaZMOhZ/3SbmXM5NXARWQzQsVWjxZ3gcPB91Iu2SCzIQFAV2IzWfHcJUhRGk82UM2VUrw8ysNuINQROkVaR0mUblhvvBX (MillisBehindLatest=0) | |
2016/01/20 11:25:23 10 records read from shard shardId-000000000007 with iterator AAAAAAAAAAHMOFsPspRjUZzPbOpfdX11kGdYqq7Brcm0w7z9syu797Wfotj6PiZQ8FrtGsvkj5dMofEFiBGmehDC68nfx88i1L9TPBTPAspz684XMqcTuM3H6zDcbbwH7MIaOLZvl5EX/Ok9aWL1DM60U0yibCMOmtq1pQFApWTt+5lNPNOfoRhN/XbiereDFkLdBglEJlvBE5kmA4+AG383Yo68jswz (MillisBehindLatest=0) | |
2016/01/20 11:25:23 0 records read from shard shardId-000000000002 with iterator AAAAAAAAAAGZcW2mz2zp9WyY0y9sCnNmQwqXKSoyRQGJehD1Ld3SDNYPtJ2i9gORY1eRiRbfg5u/0B5Cc/Dhs578ySebSikw4RjH2ali4CYbdS5AzCS1wvDz4ilhBstyBXyuPC92rRJiGqWeisUrghOP8t8177HC00zVRrAyIID6W6VWROrpxOggY3jWbOUKCzFcA65hdfHYYCaQudjL74E03yK27WUt (MillisBehindLatest=0) | |
2016/01/20 11:25:23 done with shard shardId-000000000002 | |
2016/01/20 11:25:23 10 records read from shard shardId-000000000000 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkwi3jm+piEPASU+5FNf+oTI7B7URk929NYBKfYz0KT3Qb7Dzs8Q32j17JvhUFBkLwECSPyB1+bW6lAydpwhKndavQsDagq4cIGkvAXedknozT7J8rrr+3/7RuxSw+VR3kQmLVsI9XQtY5lY+yvUXGGM (MillisBehindLatest=0) | |
2016/01/20 11:25:23 10 records read from shard shardId-000000000003 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkxvIzkpEVo6lQScuxACQ2FKh2qIIegy/VQZ3Da785IGdE4Ex+uw0f5ISdkWRv0j9mdDvFY2qccl8u8kAQiNIDu1uFG86LWvkYeE3vHv9g0ZgqYBZwM1uD74Thbu8VKVgu5yAe6MQb93p3eYA6YEkK0v (MillisBehindLatest=0) | |
2016/01/20 11:25:23 10 records read from shard shardId-000000000005 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkx5zO0ehOdE9KXOohP3seQhUWGWaqoOk49sh0dBJuZlnGujHIUpN+ANTlG5mAy8Vlyw6715MdvsMk9rcY8h0O3NFVd5ZW6Xg98KaVkZqIr6+wU9GOzzy1oBFpd4C8JroiJcUO4Wit5JcoBJmk2XmLSZ (MillisBehindLatest=0) | |
2016/01/20 11:25:23 10 records read from shard shardId-000000000004 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkxSWEkZZ0Y/KRtEZwZF6QJioxof/BP8pWVPs+/l/w+RFTE0O6etRhwS/bkFblzb7+49zVdGl9Xbc2IZftOV1SKcudm4Ox0AzCMhwCLE6tvgZ28YFcGsG5QRxq1yQnwOzPdzNVPIGwvaHFTVlnBoR5zR (MillisBehindLatest=0) | |
2016/01/20 11:25:23 10 records read from shard shardId-000000000001 with iterator AAAAAAAAAAFwCHhWqfTUNikGLIP4x/hADn6az0AbEVBZenwOUJ0GyDV6qW9PM4ujfCNQCEiBwkxgT6kFeQzCDiCdMjMLl0wfD/AiA+9HmGi1UuxQ4qFHeuAipI5rsej3bAVNSQE3j7GzS74JRukmVdhViJxeV9y5tkOrrWxPw4Rk1Qs8DGhgEJTPDPvMKTtr/Pyu4DzzI/X8J0m/41alOE+NGEb2ZXww (MillisBehindLatest=0) | |
2016/01/20 11:25:23 10 records read from shard shardId-000000000006 with iterator AAAAAAAAAAGVTG2xIRBLGw4zEybQRl9TpIuQJJ6QeW6HKVn0OKJzJDdvErSEYlV6LKTFVQKLJtDNrrwZVjpERbAG0oAbr+kUOnE4dj+Bq78r9fhmfXa3HMMeBBqj8Rhamdv5qVdY9ALpKNcZNxDTKvzO6lxryGe7MCF58RZiLsyP6iB1wFlFqu1wzzYqO5rDbkg9/R/Kk8SAIJXwD0xKWopXHtIGMyNq (MillisBehindLatest=0) | |
2016/01/20 11:25:23 1 records read from shard shardId-000000000005 with iterator AAAAAAAAAAFn/W2pnwIeJ/93+8q5Ltep3GxXEq7hiM5WNW0XZDAtTL/VM+crpijK+R/h8zREDCyo73Nnim+tAdKwqLeP6uLJBVmOe9i/OQ/9tiupd+mu3CAWAeorDmLKAJfvg6ozljk/n8v2/6OI0v6glbZu98uxluHNZibyLVD2WCBM7U7QzrThJ9Qt1UwVwwjs99HCgktnXO+mWRpSgNnjhy6wG7Gf (MillisBehindLatest=0) | |
2016/01/20 11:25:23 2 records read from shard shardId-000000000000 with iterator AAAAAAAAAAFn/W2pnwIeJ/93+8q5Ltep3GxXEq7hiM5WNW0XZDAtTL/VM+crpijK+R/h8zREDCyVlDKE05/qz3F40TlmM+eIdWQ7OPDCLgj5c6dKhnKaT1cNN9WC3RnfO4VoLoVX+YGrvL9OPO631I6VJ3AFT11PmujX5CQl9KVbyMw0asGGOhA9ltCWAmZAVNuEFBNbd1eLnUNmRkLFUW/6lDuE5aJr (MillisBehindLatest=0) | |
2016/01/20 11:25:23 2 records read from shard shardId-000000000004 with iterator AAAAAAAAAAGZeJxXEj0SP1jSBLqWalUrTkFs6xi3RlyS9FcAJw+ve52LTvEMTvpazF86TIYia/yuljfAk+1gfH+aD7lfbkgoRHKt/9Z3JedAI++1TnIxAvIibMo3dNtl10crgU2Pffi8SECeceO1z0BYNbtEWMrMlOsmJqITc952Afh/Fr9E8DjyFO7TpzRo0ZzRr9WERE6ehc+sHhN4Bgu+BEOcPH2D (MillisBehindLatest=0) | |
2016/01/20 11:25:23 4 records read from shard shardId-000000000007 with iterator AAAAAAAAAAH5rzwEmfRnE9l3Kawhl9nYFLtSL/nOBTubf+8ZqmW7cXLs4y6FJ4Y8VLEuLujTrtddicPjpYzJbbh1bZ5xmH6cIUZyIQ4jVbdP8m1i+asA5gvmsk6l9p25sDSYFlzI83RxwTc5WuQdT5wPDvvcHFyHAVG+HoYRX+5X2QIPRWWKHKlT9FF5WKwXBMw1sryPR+JDkVrdO4MFE3sHT1jojfEo (MillisBehindLatest=0) | |
2016/01/20 11:25:23 3 records read from shard shardId-000000000001 with iterator AAAAAAAAAAGZeJxXEj0SP1jSBLqWalUrTkFs6xi3RlyS9FcAJw+ve52LTvEMTvpazF86TIYia/x2YMTs5CRhrTRzL1ly5qIyR+z1hMJQ4X6c6T3G1ANf5aSWjk/DPqnXhpVINmW9aqnotyEhVGp3BR0bhuJa81UVwixEiaUyEXWDO6TRwLg2Kzz789+XBQNKDlYKc2eJC13uyyZDfrHvYssiYhrJoLBF (MillisBehindLatest=0) | |
2016/01/20 11:25:23 0 records read from shard shardId-000000000005 with iterator AAAAAAAAAAELKq8DX0LHP1eCT44zbZo0zM4ohs2hF+gVMMpFah5wwDhU2381Y/TJgN4yUrZmQh3sTsO0ILdMuVgINalG7RRfERslYLwVK0Btgvl+LWDYcpMmgPMupst7orNhpXY+dv7H1l0ErU2vvLm6eWyEInUTTfvWq/gnkuZdE7/etlCG9Dmk17ggefbDUHklTc+I20BAI2lhhkC9p0LRDYS8HGzg (MillisBehindLatest=0) | |
2016/01/20 11:25:23 done with shard shardId-000000000005 | |
2016/01/20 11:25:23 0 records read from shard shardId-000000000000 with iterator AAAAAAAAAAGpwoI+zW7PYpxNMX23C8lR0WOTLGwsq1lForPyb09+4x3XvNRQ1L9hSsPy3AaCccLeXQ+8rZ5e9YfZEwABcnRZyX6GRFLqml8Nhqt4yTrdzGGR+0XeDfF8rkusgyGaKIzwrBNlmjLNQ6ddvrnPNuXjwDQuuZ2nINwuBBmQxw21xpXQcFmXWiHXOPj6SjyLNAI1x1MT9KAY4dlczPfaqQvQ (MillisBehindLatest=0) | |
2016/01/20 11:25:23 done with shard shardId-000000000000 | |
2016/01/20 11:25:23 5 records read from shard shardId-000000000003 with iterator AAAAAAAAAAFn/W2pnwIeJ/93+8q5Ltep3GxXEq7hiM5WNW0XZDAtTL/VM+crpijK+R/h8zREDCx3CQ8xkKcod0HY/JasJ/EqS22MG47OzIKyXQpg5+okiux1xUPW7NYEvpBODPLKWUS9MIUIOVffoGX6vwe9yvVHA+UCnlkSX5YEX3WBKwLJWRFeOcfpEs8l5DP6UMJ0K+LVUgbYAq9v2l+ShY9dDsar (MillisBehindLatest=0) | |
2016/01/20 11:25:23 0 records read from shard shardId-000000000004 with iterator AAAAAAAAAAGpwoI+zW7PYpxNMX23C8lR0WOTLGwsq1lForPyb09+4x3XvNRQ1L9hSsPy3AaCccIRPfqNpgqnLZ19qDfjRbgYK8GymNMAiG24Kn0maPrw3XIGGuhMNbJ1xBoqjG3V8OnkaAfvKlmL/75bgfuqB6wX7CxyAjz3qODKCBevP5GPWM46/5LthCHo8n3Auh+2XE3dctNIjRcEMzWoho3f6l0o (MillisBehindLatest=0) | |
2016/01/20 11:25:23 done with shard shardId-000000000004 | |
2016/01/20 11:25:23 0 records read from shard shardId-000000000007 with iterator AAAAAAAAAAHtPv/Qc1e+JUA9yzoaCneS7oGDEBT31aKoUwADduqbIqDDGI+M2EVGzqr4hXbGlmIzwPMjBmn6Gcszpvzhz0wSFJeTLsumh27HojaMvcn41T7s2i8bhvNppQ1ktBfu49Tm0y+/tt0f13U0y2HHAUPyjQ6fKtf+7SrMEJZ21yy/TJSdCRA8VmVcX9rExVX71k5DcIt7QpPQmXQNqSsPyUIe (MillisBehindLatest=0) | |
2016/01/20 11:25:23 done with shard shardId-000000000007 | |
2016/01/20 11:25:23 0 records read from shard shardId-000000000001 with iterator AAAAAAAAAAHtPv/Qc1e+JUA9yzoaCneS7oGDEBT31aKoUwADduqbIqDDGI+M2EVGzqr4hXbGlmKrUhVsPkgTh7qcTiS30r32Wbi84fCKqV343JJpzwWEZecpHgFTNv8IrYfhOZ6cLWxZlmHRmngFIhRyCye6V0cGe5PS1W8Z4mxxLNFqVyQInLZIKGvvI5rh4y5PbGnYrKsXsH/ThiDJot/eutZtg5SO (MillisBehindLatest=0) | |
2016/01/20 11:25:23 done with shard shardId-000000000001 | |
2016/01/20 11:25:23 0 records read from shard shardId-000000000003 with iterator AAAAAAAAAAEg22ja29F+6r15vv64Xxg26Q5g7OqbLVB7V/GOHLG0PHvIB28AfEuoy1j+YZDGrUeROcKEAJ32aIwfDhmfZ0MA770R+VOc9B22aI9mdlTL90IehCxk2n9uysPGvIyUrOoK7jzgCp28rBmJQ3YB1nju1+Tgbf7U1XzNW+YV/jwJP4Tk5QmUq+ci6IG3qtYQ8NY2iDAhpX9xa+SM6cgMsguP (MillisBehindLatest=0) | |
2016/01/20 11:25:23 done with shard shardId-000000000003 | |
2016/01/20 11:25:23 8 records read from shard shardId-000000000006 with iterator AAAAAAAAAAGZeJxXEj0SP1jSBLqWalUrTkFs6xi3RlyS9FcAJw+ve52LTvEMTvpazF86TIYia/z+6e4TuXPmMT8tHtTjTkTtxDx9+Iwc3ya8cML2WcsTeQ2j0wsrDu3H4VStT6ZuYGSGiojOd8WapnjFmksAgHAvw/q8gJBHL+mQOcyO0RF+Y46OvmfAKGdCTUxjAJCqJszU0/Wy88tN2FLI9ABLmG3l (MillisBehindLatest=0) | |
2016/01/20 11:25:23 0 records read from shard shardId-000000000006 with iterator AAAAAAAAAAFDmvx8h9iNi3QtPOHrTQE7KG6yin9WLD5mt3o3IBAz9aSgw5EtdHmyeH5e8HrbEd8XM6NAkBOHQnty99dqUdvtjyS2e1oZthYeyS/qFXfNPanMBZvBQ20n4spR8bNrdwphHWjf6Is6nVTtRl9GGg70CUujbknNRQNdPlA6kl6I5RqTVvXiXUcEQJqIpsKIxBrVlKLCrbQrp2psYvuZoAk8 (MillisBehindLatest=0) | |
2016/01/20 11:25:23 done with shard shardId-000000000006 | |
2016/01/20 11:25:23 records fetched | |
2016/01/20 11:25:23 100 messages |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment