15:04:43.671759 [Info] Indexer started with command line: [/Users/prathibha-mac/Documents/source/cb/install/bin/indexer -log=2 -vbuckets=1024 -cluster=127.0.0.1:9000 -adminPort=9100 -scanPort=9101 -httpPort=9102 -streamInitPort=9103 -streamCatchupPort=9104 -streamMaintPort=9105 -storageDir=/Users/prathibha-mac/Documents/source/cb/ns_server/data/n_0/data/@2i] 15:04:43.672410 [Info] Indexer::NewIndexer Status INIT 15:04:43.676648 [Info] Setting maxcpus = 4 15:04:43.676760 [Info] Setting log level to Info 15:04:43.676840 [Info] Indexer::NewIndexer Starting with Vbuckets 1024 15:04:43.680206 [Info] [Queryport ":9101"] started ... 15:04:44.684712 [Error] ClustMgrAgent::Fail to init ClusterInfoCache : No pool named default 15:04:44.684832 [Error] Indexer::NewIndexer ClusterMgrAgent Init Error%!(EXTRA *indexer.MsgError=&{{35 0 11 0xc208001f50 }}) 15:04:44.684842 [Warn] Indexer Failure to Init &{{35 0 11 0xc208001f50 }} 15:04:44.684845 [Info] Indexer exiting normally 15:04:49.769332 [Info] Indexer started with command line: [/Users/prathibha-mac/Documents/source/cb/install/bin/indexer -log=2 -vbuckets=1024 -cluster=127.0.0.1:9000 -adminPort=9100 -scanPort=9101 -httpPort=9102 -streamInitPort=9103 -streamCatchupPort=9104 -streamMaintPort=9105 -storageDir=/Users/prathibha-mac/Documents/source/cb/ns_server/data/n_0/data/@2i] 15:04:49.769907 [Info] Indexer::NewIndexer Status INIT 15:04:49.771144 [Info] Setting maxcpus = 4 15:04:49.771180 [Info] Setting log level to Info 15:04:49.771258 [Info] Indexer::NewIndexer Starting with Vbuckets 1024 15:04:49.774362 [Info] [Queryport ":9101"] started ... 15:04:50.778955 [Error] ClustMgrAgent::Fail to init ClusterInfoCache : No pool named default 15:04:50.779092 [Error] Indexer::NewIndexer ClusterMgrAgent Init Error%!(EXTRA *indexer.MsgError=&{{35 0 11 0xc208408500 }}) 15:04:50.779102 [Warn] Indexer Failure to Init &{{35 0 11 0xc208408500 }} 15:04:50.779105 [Info] Indexer exiting normally 15:04:55.854545 [Info] Indexer started with command line: [/Users/prathibha-mac/Documents/source/cb/install/bin/indexer -log=2 -vbuckets=1024 -cluster=127.0.0.1:9000 -adminPort=9100 -scanPort=9101 -httpPort=9102 -streamInitPort=9103 -streamCatchupPort=9104 -streamMaintPort=9105 -storageDir=/Users/prathibha-mac/Documents/source/cb/ns_server/data/n_0/data/@2i] 15:04:55.855183 [Info] Indexer::NewIndexer Status INIT 15:04:55.857259 [Info] Setting maxcpus = 4 15:04:55.857292 [Info] Setting log level to Info 15:04:55.857388 [Info] Indexer::NewIndexer Starting with Vbuckets 1024 15:04:55.860493 [Info] [Queryport ":9101"] started ... 15:04:56.866023 [Error] ClustMgrAgent::Fail to init ClusterInfoCache : No pool named default 15:04:56.866196 [Error] Indexer::NewIndexer ClusterMgrAgent Init Error%!(EXTRA *indexer.MsgError=&{{35 0 11 0xc2080984b0 }}) 15:04:56.866206 [Warn] Indexer Failure to Init &{{35 0 11 0xc2080984b0 }} 15:04:56.866234 [Info] Indexer exiting normally 15:05:01.943821 [Info] Indexer started with command line: [/Users/prathibha-mac/Documents/source/cb/install/bin/indexer -log=2 -vbuckets=1024 -cluster=127.0.0.1:9000 -adminPort=9100 -scanPort=9101 -httpPort=9102 -streamInitPort=9103 -streamCatchupPort=9104 -streamMaintPort=9105 -storageDir=/Users/prathibha-mac/Documents/source/cb/ns_server/data/n_0/data/@2i] 15:05:01.944607 [Info] Indexer::NewIndexer Status INIT 15:05:01.946957 [Info] Setting maxcpus = 4 15:05:01.947063 [Info] Setting log level to Info 15:05:01.947137 [Info] Indexer::NewIndexer Starting with Vbuckets 1024 15:05:01.950083 [Info] [Queryport ":9101"] started ... 15:05:01.967015 [Info] Indexer Id 23:17:fd:5f:99:fe:51:13 15:05:01.967139 [Info] KVSender::handleCloseStream Message: MsgStreamUpdate Type: CLOSE_STREAM Stream: MAINT_STREAM BuildTS: [] IndexList: [] RestartTs: 15:05:01.980096 [Fatal] KVSender::sendShutdownTopic Unexpected Error During Shutdown Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13. Err projector.topicMissing 15:05:01.980107 [Error] KVSender::closeMutationStream Error Received projector.topicMissing from 127.0.0.1:10000 15:05:01.980110 [Info] KVSender::closeMutationStream Treating TopicMissing As Success 15:05:01.980171 [Info] KVSender::handleCloseStream Message: MsgStreamUpdate Type: CLOSE_STREAM Stream: INIT_STREAM BuildTS: [] IndexList: [] RestartTs: 15:05:01.992149 [Fatal] KVSender::sendShutdownTopic Unexpected Error During Shutdown Projector 127.0.0.1:10000 Topic INIT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13. Err projector.topicMissing 15:05:01.992158 [Error] KVSender::closeMutationStream Error Received projector.topicMissing from 127.0.0.1:10000 15:05:01.992173 [Info] KVSender::closeMutationStream Treating TopicMissing As Success 15:05:01.992361 [Info] Indexer::NewIndexer Status ACTIVE 15:05:47.877064 [Info] Indexer::handleCreateIndex InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_CREATED Stream: INVALID_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1} 15:05:47.895024 [Info] Indexer::initPartnInstance Initialized Partition: Index: 17892643122270655600 Partition: PartitionId: 1 Endpoints: [:9105] 15:05:47.896283 [Info] Indexer::initPartnInstance Initialized Slice: Index: 17892643122270655600 Slice: SliceId: 0 File: /Users/prathibha-mac/Documents/source/cb/ns_server/data/n_0/data/@2i/beer-sample_i_test1_17892643122270655600_0.index Index: 17892643122270655600 15:05:47.896379 [Info] MutationMgr::handleUpdateIndexInstMap Message: MsgUpdateInstMap InstanceId: 17892643122270655600 Name: i_test1 Bucket: beer-sample State: INDEX_STATE_CREATED Stream: INVALID_STREAM 15:05:47.896396 [Info] MutationMgr::handleUpdateIndexPartnMap Message: MsgUpdatePartnMap InstanceId: 17892643122270655600 PartitionId: 0 Endpoints: [:9105] 15:05:47.897426 [Info] Indexer::handleBuildIndex [17892643122270655600] 15:05:47.951513 [Info] MutationMgr::handleUpdateIndexInstMap Message: MsgUpdateInstMap InstanceId: 17892643122270655600 Name: i_test1 Bucket: beer-sample State: INDEX_STATE_INITIAL Stream: MAINT_STREAM 15:05:47.951589 [Warn] StreamState::setHWTFromRestartTs RestartTs Not Found For Bucket beer-sample StreamId MAINT_STREAM. No Value Set. 15:05:47.951866 [Info] MutationMgr::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:05:47.952011 [Info] DATP[->dataport ":9105"] started ... 15:05:47.952072 [Info] MutationStreamReader::startMutationStreamWorker Stream Worker 0 Started for Stream MAINT_STREAM. 15:05:47.952074 [Info] MutationStreamReader::startMutationStreamWorker Stream Worker 1 Started for Stream MAINT_STREAM. 15:05:47.952089 [Info] MutationStreamReader::startMutationStreamWorker Stream Worker 2 Started for Stream MAINT_STREAM. 15:05:47.952094 [Info] MutationStreamReader::startMutationStreamWorker Stream Worker 4 Started for Stream MAINT_STREAM. 15:05:47.952099 [Info] MutationStreamReader::startMutationStreamWorker Stream Worker 7 Started for Stream MAINT_STREAM. 15:05:47.952090 [Info] MutationStreamReader::startMutationStreamWorker Stream Worker 3 Started for Stream MAINT_STREAM. 15:05:47.952098 [Info] MutationStreamReader::startMutationStreamWorker Stream Worker 5 Started for Stream MAINT_STREAM. 15:05:47.952095 [Info] MutationStreamReader::startMutationStreamWorker Stream Worker 6 Started for Stream MAINT_STREAM. 15:05:47.953601 [Info] PeerPipe.doSend() : Send channel closed. Terminate. 15:05:47.953614 [Info] messageListener.start(): message channel closed. Remove peer 172.16.1.178/24:indexer:MetadataProvider:49:89:2f:9b:46:9b:37:97 as follower. 15:05:47.969469 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:05:48.164500 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50492" +1 15:05:48.191821 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:05:48.191828 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:05:49.246617 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:05:49.246625 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:05:50.432178 [Info] PeerPipe.doSend() : Send channel closed. Terminate. 15:05:50.432188 [Info] messageListener.start(): message channel closed. Remove peer 172.16.1.178/24:indexer:MetadataProvider:85:5:12:4d:8:e8:56:f as follower. 15:05:51.289804 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:05:51.289812 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:05:55.337671 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:05:55.337679 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:05:58.165933 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50492" exit: EOF 15:05:58.165946 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50492" closed 15:05:58.165991 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50492" closed ! 15:06:03.340814 [Error] KVSender::openMutationStream Error Received feed.feeder 15:06:03.340842 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:06:03.362551 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:06:03.558356 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50504" +1 15:06:03.586468 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:03.586474 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:04.632007 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:04.632014 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:06.678765 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:06.678772 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:10.733282 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:10.733289 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:13.558879 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50504" exit: EOF 15:06:13.558896 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50504" closed 15:06:13.558927 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50504" closed ! 15:06:18.736687 [Error] KVSender::openMutationStream Error Received feed.feeder 15:06:18.736708 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:06:18.755785 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:06:18.936189 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50520" +1 15:06:18.967827 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:18.967834 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:20.010738 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:20.010745 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:22.059212 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:22.059219 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:26.109273 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:26.109280 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:28.938189 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50520" exit: EOF 15:06:28.938206 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50520" closed 15:06:28.938242 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50520" closed ! 15:06:34.113643 [Error] KVSender::openMutationStream Error Received feed.feeder 15:06:34.113666 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:06:34.135259 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:06:34.311760 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50527" +1 15:06:34.346350 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:34.346357 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:35.390261 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:35.390268 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:37.437623 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:37.437630 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:41.495337 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:41.495344 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:44.312257 [Error] receiving packet: read tcp 127.0.0.1:50527: i/o timeout 15:06:44.312274 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50527" exit: read tcp 127.0.0.1:50527: i/o timeout 15:06:44.312308 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50527" timeout: read tcp 127.0.0.1:50527: i/o timeout 15:06:44.312349 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50527" closed ! 15:06:49.497207 [Error] KVSender::openMutationStream Error Received feed.feeder 15:06:49.497225 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:06:49.515192 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:06:49.701689 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50536" +1 15:06:49.728943 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:49.728950 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:50.778959 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:50.778966 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:52.824134 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:52.824141 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:56.865238 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:06:56.865245 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:06:59.701913 [Error] receiving packet: read tcp 127.0.0.1:50536: i/o timeout 15:06:59.701931 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50536" exit: read tcp 127.0.0.1:50536: i/o timeout 15:06:59.701949 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50536" timeout: read tcp 127.0.0.1:50536: i/o timeout 15:06:59.701989 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50536" closed ! 15:07:04.868217 [Error] KVSender::openMutationStream Error Received feed.feeder 15:07:04.868239 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:07:04.886777 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:07:05.086484 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50551" +1 15:07:05.113345 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:05.113352 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:06.162606 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:06.162633 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:08.205475 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:08.205482 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:12.264318 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:12.264325 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:15.086799 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50551" exit: EOF 15:07:15.086802 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50551" closed 15:07:15.086832 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50551" closed ! 15:07:20.266720 [Error] KVSender::openMutationStream Error Received feed.feeder 15:07:20.266741 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:07:20.287080 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:07:20.466163 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50569" +1 15:07:20.496978 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:20.496984 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:21.536762 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:21.536769 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:23.589632 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:23.589640 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:27.629943 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:27.629951 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:30.466604 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50569" exit: EOF 15:07:30.466607 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50569" closed 15:07:30.466669 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50569" closed ! 15:07:35.633739 [Error] KVSender::openMutationStream Error Received feed.feeder 15:07:35.633764 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:07:35.652418 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:07:35.832088 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50576" +1 15:07:35.860177 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:35.860183 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:36.904596 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:36.904603 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:38.960950 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:38.960958 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:42.998872 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:42.998879 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:45.832803 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50576" exit: EOF 15:07:45.832804 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50576" closed 15:07:45.832849 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50576" closed ! 15:07:51.000390 [Error] KVSender::openMutationStream Error Received feed.feeder 15:07:51.000407 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:07:51.017373 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:07:51.201046 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50601" +1 15:07:51.226980 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:51.226988 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:52.271350 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:52.271357 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:54.334058 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:54.334064 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:07:58.376495 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:07:58.376502 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:01.201350 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50601" exit: EOF 15:08:01.201354 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50601" closed 15:08:01.201382 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50601" closed ! 15:08:06.376680 [Error] KVSender::openMutationStream Error Received feed.feeder 15:08:06.376698 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:08:06.394471 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:08:06.577915 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50610" +1 15:08:06.605535 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:06.605543 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:07.645841 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:07.645848 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:09.688921 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:09.688928 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:13.751187 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:13.751194 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:16.578174 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50610" exit: EOF 15:08:16.578180 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50610" closed 15:08:16.578212 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50610" closed ! 15:08:21.755334 [Error] KVSender::openMutationStream Error Received feed.feeder 15:08:21.755353 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:08:21.772945 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:08:21.955685 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50629" +1 15:08:21.983012 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:21.983019 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:23.033149 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:23.033157 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:25.082907 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:25.082915 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:29.134981 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:29.134991 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:31.955920 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50629" exit: EOF 15:08:31.955929 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50629" closed 15:08:31.955957 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50629" closed ! 15:08:37.138423 [Error] KVSender::openMutationStream Error Received feed.feeder 15:08:37.138442 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:08:37.156956 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:08:37.358509 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50638" +1 15:08:37.387627 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:37.387634 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:38.440090 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:38.440097 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:40.491948 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:40.491956 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:44.539101 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:44.539108 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:47.358784 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50638" exit: EOF 15:08:47.358787 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50638" closed 15:08:47.358826 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50638" closed ! 15:08:52.541041 [Error] KVSender::openMutationStream Error Received feed.feeder 15:08:52.541061 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:08:52.558711 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:08:52.741491 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50647" +1 15:08:52.769374 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:52.769381 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:53.838565 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:53.838572 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:55.880048 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:55.880055 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:08:59.924959 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:08:59.924966 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:02.741954 [Error] receiving packet: read tcp 127.0.0.1:50647: i/o timeout 15:09:02.741976 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50647" exit: read tcp 127.0.0.1:50647: i/o timeout 15:09:02.741995 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50647" timeout: read tcp 127.0.0.1:50647: i/o timeout 15:09:02.742055 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50647" closed ! 15:09:07.926861 [Error] KVSender::openMutationStream Error Received feed.feeder 15:09:07.926886 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:09:07.945603 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:09:08.125966 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50659" +1 15:09:08.154340 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:08.154347 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:09.204607 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:09.204618 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:11.249133 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:11.249140 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:15.289150 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:15.289159 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:18.126287 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50659" exit: EOF 15:09:18.126296 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50659" closed 15:09:18.126326 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50659" closed ! 15:09:23.292624 [Error] KVSender::openMutationStream Error Received feed.feeder 15:09:23.292649 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:09:23.312157 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:09:23.521131 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50666" +1 15:09:23.550289 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:23.550297 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:24.590220 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:24.590227 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:26.649235 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:26.649251 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:30.693032 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:30.693039 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:33.521406 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50666" exit: EOF 15:09:33.521413 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50666" closed 15:09:33.521440 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50666" closed ! 15:09:38.696223 [Error] KVSender::openMutationStream Error Received feed.feeder 15:09:38.696246 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:09:38.715858 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:09:38.912891 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50677" +1 15:09:38.943289 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:38.943296 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:39.995612 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:39.995619 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:42.068785 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:42.068793 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:46.111155 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:46.111162 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:48.913090 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50677" exit: EOF 15:09:48.913097 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50677" closed 15:09:48.913136 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50677" closed ! 15:09:54.114691 [Error] KVSender::openMutationStream Error Received feed.feeder 15:09:54.114711 [Error] Indexer::sendStreamUpdateForBuildIndex - Error from Projector feed.feeder. Retrying. 15:09:54.136846 [Info] KVSender::handleOpenStream Message: MsgStreamUpdate Type: OPEN_STREAM Stream: MAINT_STREAM BuildTS: [9 8 7 6 8 10 7 6 6 5 5 7 4 6 8 8 6 12 6 6 5 10 9 7 4 4 13 6 4 6 3 7 6 7 12 9 5 8 9 6 6 11 6 11 7 9 9 13 6 10 8 7 9 5 4 8 5 5 5 11 6 12 6 9 6 5 7 9 8 3 3 7 6 7 9 4 5 7 10 8 8 8 6 6 12 5 7 8 7 8 9 6 6 10 7 3 5 8 7 4 8 8 4 12 6 8 8 8 9 10 10 6 13 11 5 3 7 6 1 7 6 6 7 5 6 7 4 7 6 7 6 4 9 7 10 8 9 7 6 10 6 7 5 5 4 4 3 6 8 14 11 11 6 10 8 3 3 5 8 6 8 3 6 7 9 6 15 7 4 6 7 3 7 6 7 8 12 9 7 7 5 6 4 4 9 4 8 8 5 6 3 6 2 7 3 9 5 4 8 8 4 6 11 8 8 7 10 10 4 7 6 8 8 11 11 5 10 6 8 9 9 5 6 6 9 13 8 8 10 8 12 11 7 10 8 6 4 6 9 6 6 9 8 10 8 7 11 7 6 4 10 8 8 7 2 17 6 10 6 5 6 12 7 14 7 8 8 4 5 6 5 10 14 6 10 3 3 12 4 4 8 5 4 5 4 9 5 9 12 13 6 3 8 6 7 8 6 6 9 10 6 9 8 8 10 9 7 3 5 5 9 6 8 4 3 6 5 3 8 9 7 7 9 8 7 5 7 12 6 9 9 9 12 5 11 10 7 7 9 15 13 6 7 8 5 9 7 6 5 4 5 6 9 7 7 11 5 8 12 6 5 5 6 5 4 11 8 4 10 9 6 4 8 6 11 6 6 8 8 5 4 5 3 6 4 4 6 4 7 8 4 9 10 14 5 6 9 6 7 7 7 13 9 6 10 8 7 4 4 7 5 8 9 10 3 6 9 7 9 12 5 4 9 8 7 13 9 11 9 5 9 8 7 9 5 8 8 8 6 9 8 12 13 4 9 2 3 11 5 8 9 7 10 4 7 8 12 10 5 7 6 9 7 12 7 10 9 13 3 7 7 8 7 12 2 7 6 8 7 6 6 10 3 9 7 7 7 10 6 6 9 8 9 8 2 7 7 9 8 7 13 6 4 6 4 4 7 9 13 5 5 8 10 8 9 5 5 4 4 7 6 10 3 4 8 4 8 6 6 4 3 8 4 5 5 4 14 8 8 9 6 3 9 8 5 9 5 6 7 4 11 8 6 6 8 3 9 10 7 5 13 8 10 5 7 3 8 7 11 5 7 7 6 8 8 9 5 6 7 6 5 7 7 9 7 7 7 10 13 10 8 1 7 7 5 3 10 5 5 6 4 12 8 4 9 8 10 2 3 6 10 7 11 6 6 4 8 10 6 1 6 7 7 11 10 8 4 7 3 5 9 8 9 6 9 8 6 5 7 4 5 8 7 6 7 4 4 8 4 5 7 12 9 5 9 7 10 9 8 10 6 4 7 10 8 4 5 8 9 8 6 8 6 4 10 7 13 6 8 6 4 7 8 5 3 7 6 12 6 10 8 9 7 7 5 7 11 4 7 5 5 7 6 7 10 8 6 7 6 6 5 7 10 7 9 6 3 9 6 3 10 6 10 6 4 7 8 3 8 10 8 9 9 4 7 11 5 11 9 7 13 5 7 4 7 4 5 4 7 5 10 4 6 11 8 7 10 9 8 7 3 9 9 8 5 10 8 6 6 5 7 6 2 2 9 6 6 6 12 6 10 2 3 10 6 6 3 6 6 7 5 9 6 2 6 5 13 7 9 16 8 8 7 7 2 10 8 7 3 7 6 3 5 2 7 7 11 9 7 6 6 7 5 4 7 9 8 8 6 7 7 6 5 11 13 7 9 11 5 4 6 9 6 5 10 3 8 2 1 7 6 8 9 8 8 5 13 8 10 7 11 9 7 5 6 1 6 9 7 7 5 7 13 3 5 12 6 4 8 6 13 4 11 12 4 7 7 8 5 4 7 8 5 10 8 13 3 4 7 4 5 9 10 7 9 5 12 6 10 3 11 12 6 10 4 6 4 5 5 6 7 11 10 6 14 8 7 4 6 5 9 5 12 8 8 9 8 10 2 8 11 12 6 5 5 5 4 11 9 10 9 12 15 7 4 9 7 10 6 7 7 1 6 7 4 11 4 8 8 4 5 8 15 6 11 7 4 4 7 5 8 6 4 8 7 3 6 8 7 9 8 9 11 7 3 9 4 9 6 2 5 8 6 8 8 8 6 8 7 3 13 6 7 3 3 12 7 8 6 7 7 6 11 10] IndexList: [ InstId: 17892643122270655600 Defn: DefnId: 17892643122270655600 Name: i_test1 Using: gsi Bucket: beer-sample IsPrimary: false SecExprs: [`city`] PartitionScheme: SINGLE PartitionKey: WhereExpr: State: INDEX_STATE_INITIAL Stream: MAINT_STREAM PartitionContainer: &{map[1:{1 [:9105]}] 1}] RestartTs: 15:09:54.348472 [Info] DATP[->dataport ":9105"] new connection "127.0.0.1:50687" +1 15:09:54.388019 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:54.388029 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:55.443912 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:55.443919 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:09:57.495537 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:09:57.495544 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:10:01.545376 [Fatal] KVSender::sendMutationTopicRequest Projector 127.0.0.1:10000 Topic MAINT_STREAM_TOPIC_23:17:fd:5f:99:fe:51:13 Unexpected Error feed.feeder 15:10:01.545383 [Error] KVSender::openMutationStream Error Received feed.feeder from 127.0.0.1:10000 15:10:04.348782 [Error] DATP[->dataport ":9105"] worker "127.0.0.1:50687" exit: EOF 15:10:04.348794 [Error] DATP[->dataport ":9105"] remote "127.0.0.1:50687" closed 15:10:04.348827 [Info] DATP[->dataport ":9105"] connection "127.0.0.1:50687" closed !