Flow@32924[S]:οΏ½[32msuccessfully built Flow from a yaml configοΏ½[0m
dispatcher@32933[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
dispatcher@32933[I]:οΏ½[37mpost initiating, this may take some time takes 0.000 secsοΏ½[0m
dispatcher@32933[S]:οΏ½[32msuccessfully built BaseExecutor from a yaml configοΏ½[0m
dispatcher@32933[I]:οΏ½[37msetting up sockets...οΏ½[0m
dispatcher@32933[I]:οΏ½[37minput οΏ½[33mtcp://0.0.0.0:53089οΏ½[0m (PULL_BIND) output οΏ½[33mtcp://0.0.0.0:54667οΏ½[0m (PUB_BIND) control over οΏ½[33mtcp://0.0.0.0:52269οΏ½[0m (PAIR_BIND)οΏ½[0m
dispatcher@32933[S]:οΏ½[32mready and listeningοΏ½[0m
splittor@32936[W]:οΏ½[40mοΏ½[33mthe min_sent_len (=2) should be smaller or equal to the max_sent_len (=64)οΏ½[0m
splittor@32936[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
splittor@32936[I]:οΏ½[37mpost initiating, this may take some time takes 0.000 secsοΏ½[0m
splittor@32936[S]:οΏ½[32msuccessfully built Sentencizer from a yaml configοΏ½[0m
splittor@32936[I]:οΏ½[37msetting up sockets...οΏ½[0m
splittor@32936[I]:οΏ½[37minput οΏ½[33mtcp://0.0.0.0:54667οΏ½[0m (SUB_CONNECT) output οΏ½[33mtcp://0.0.0.0:47697οΏ½[0m (PUSH_CONNECT) control over οΏ½[33mtcp://0.0.0.0:54221οΏ½[0m (PAIR_BIND)οΏ½[0m
splittor@32936[S]:οΏ½[32mready and listeningοΏ½[0m
encoder@32939[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
encoder@32939[I]:οΏ½[37mpost initiating, this may take some time takes 1.769 secsοΏ½[0m
encoder@32939[S]:οΏ½[32msuccessfully built TransformerTorchEncoder from a yaml configοΏ½[0m
encoder@32939[I]:οΏ½[37msetting up sockets...οΏ½[0m
encoder@32939[I]:οΏ½[37minput οΏ½[33mtcp://0.0.0.0:47697οΏ½[0m (PULL_BIND) output οΏ½[33mtcp://0.0.0.0:41123οΏ½[0m (PUSH_CONNECT) control over οΏ½[33mtcp://0.0.0.0:43255οΏ½[0m (PAIR_BIND)οΏ½[0m
encoder@32939[S]:οΏ½[32mready and listeningοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mpost initiating, this may take some time takes 0.000 secsοΏ½[0m
chunk_indexer@32942[S]:οΏ½[32msuccessfully built NumpyIndexer from a yaml configοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mpost initiating, this may take some time takes 0.000 secsοΏ½[0m
chunk_indexer@32942[S]:οΏ½[32msuccessfully built BasePbIndexer from a yaml configοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mpost initiating, this may take some time takes 0.000 secsοΏ½[0m
chunk_indexer@32942[S]:οΏ½[32msuccessfully built ChunkIndexer from a yaml configοΏ½[0m
chunk_indexer@32942[W]:οΏ½[40mοΏ½[33myou can not query from <jina.executors.indexers.vector.numpy.NumpyIndexer object at 0x7f9e657a65b0> as its "query_handler" is not set. If you are indexing data from scratch then it is fine. If you are querying data then the index file must be empty or broken.οΏ½[0m
chunk_indexer@32942[I]:οΏ½[37msetting up sockets...οΏ½[0m
chunk_indexer@32942[I]:οΏ½[37minput οΏ½[33mtcp://0.0.0.0:41123οΏ½[0m (PULL_BIND) output οΏ½[33mtcp://0.0.0.0:53169οΏ½[0m (PUSH_CONNECT) control over οΏ½[33mtcp://0.0.0.0:34031οΏ½[0m (PAIR_BIND)οΏ½[0m
chunk_indexer@32942[S]:οΏ½[32mready and listeningοΏ½[0m
doc_indexer@32945[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
doc_indexer@32945[I]:οΏ½[37mpost initiating, this may take some time takes 0.000 secsοΏ½[0m
doc_indexer@32945[S]:οΏ½[32msuccessfully built DocPbIndexer from a yaml configοΏ½[0m
doc_indexer@32945[I]:οΏ½[37msetting up sockets...οΏ½[0m
doc_indexer@32945[I]:οΏ½[37minput οΏ½[33mtcp://0.0.0.0:54667οΏ½[0m (SUB_CONNECT) output οΏ½[33mtcp://0.0.0.0:53169οΏ½[0m (PUSH_CONNECT) control over οΏ½[33mtcp://0.0.0.0:57293οΏ½[0m (PAIR_BIND)οΏ½[0m
doc_indexer@32945[S]:οΏ½[32mready and listeningοΏ½[0m
join_all@32948[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
join_all@32948[I]:οΏ½[37mpost initiating, this may take some time takes 0.000 secsοΏ½[0m
join_all@32948[S]:οΏ½[32msuccessfully built BaseExecutor from a yaml configοΏ½[0m
join_all@32948[I]:οΏ½[37msetting up sockets...οΏ½[0m
join_all@32948[I]:οΏ½[37minput οΏ½[33mtcp://0.0.0.0:53169οΏ½[0m (PULL_BIND) output οΏ½[33mtcp://0.0.0.0:34151οΏ½[0m (PUSH_BIND) control over οΏ½[33mtcp://0.0.0.0:42943οΏ½[0m (PAIR_BIND)οΏ½[0m
join_all@32948[S]:οΏ½[32mready and listeningοΏ½[0m
join_all@32924[I]:οΏ½[37mpost initiating, this may take some time...οΏ½[0m
join_all@32924[I]:οΏ½[37mpost initiating, this may take some time takes 0.001 secsοΏ½[0m
join_all@32924[S]:οΏ½[32mgateway is listening at: 0.0.0.0:55767οΏ½[0m
Flow@32924[I]:οΏ½[37m7 Pods (i.e. 7 Peas) are running in this FlowοΏ½[0m
Flow@32924[S]:οΏ½[32mflow is now ready for use, current build_level is GRAPHοΏ½[0m
JINA@32924[W]:οΏ½[40mοΏ½[33m"raw_bytes" is deprecated in "index()" and will be removed in the next version; please use "input_fn" insteadοΏ½[0m
join_all@32924[S]:οΏ½[32mconnected to the gateway at 0.0.0.0:55767!οΏ½[0m
οΏ½[36mindexοΏ½[0m [οΏ½[32m=οΏ½[0m ] π 0 β±οΈ 0.0s π 0.0/s 0 batchindex ... file not found: /tmp/jina/southpark/character-lines.csv
οΏ½[32m [0.001 secs]οΏ½[0m
οΏ½[32mβ
done in β± 0.0s π 0.0/sοΏ½[0m
join_all@32924[I]:οΏ½[37msetting up sockets...οΏ½[0m
join_all@32924[I]:οΏ½[37minput οΏ½[33mtcp://0.0.0.0:34151οΏ½[0m (PULL_CONNECT) output οΏ½[33mtcp://0.0.0.0:53089οΏ½[0m (PUSH_CONNECT) control over οΏ½[33mipc:///tmp/tmpzl6dj5e7οΏ½[0m (PAIR_BIND)οΏ½[0m
join_all@32924[I]:οΏ½[37mprefetching 50 requests...οΏ½[0m
join_all@32924[W]:οΏ½[40mοΏ½[33mif this takes too long, you may want to take smaller "--prefetch" or ask client to reduce "--batch-size"οΏ½[0m
join_all@32924[I]:οΏ½[37mprefetching 50 requests takes 0.000 secsοΏ½[0m
join_all@32924[I]:οΏ½[37m#sent: 0 #recv: 0 sent_size: 0 Bytes recv_size: 0 BytesοΏ½[0m
join_all@32924[S]:οΏ½[32mterminatedοΏ½[0m
join_all@32924[S]:οΏ½[32mterminatedοΏ½[0m
join_all@32948[I]:οΏ½[37mreceived "control" from ctlοΏ½[32mβΈοΏ½[0mβοΏ½[0m
join_all@32948[I]:οΏ½[37mbreak from the event loopοΏ½[0m
join_all@32948[I]:οΏ½[37m#sent: 0 #recv: 1 sent_size: 0 Bytes recv_size: 249 BytesοΏ½[0m
join_all@32948[I]:οΏ½[37m#sent: 1 #recv: 1 sent_size: 289 Bytes recv_size: 249 BytesοΏ½[0m
join_all@32948[S]:οΏ½[32mterminatedοΏ½[0m
doc_indexer@32945[I]:οΏ½[37mreceived "control" from ctlοΏ½[32mβΈοΏ½[0mβοΏ½[0m
doc_indexer@32945[I]:οΏ½[37mbreak from the event loopοΏ½[0m
doc_indexer@32945[I]:οΏ½[37mno update since 2020-05-17 14:29:50, will not save. If you really want to save it, call "touch()" before "save()" to force savingοΏ½[0m
doc_indexer@32945[I]:οΏ½[37mexecutor says there is nothing to saveοΏ½[0m
doc_indexer@32945[I]:οΏ½[37m#sent: 0 #recv: 1 sent_size: 0 Bytes recv_size: 249 BytesοΏ½[0m
doc_indexer@32945[I]:οΏ½[37m#sent: 1 #recv: 1 sent_size: 292 Bytes recv_size: 249 BytesοΏ½[0m
doc_indexer@32945[S]:οΏ½[32mterminatedοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mreceived "control" from ctlοΏ½[32mβΈοΏ½[0mβοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mbreak from the event loopοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mno update since 2020-05-17 14:29:50, will not save. If you really want to save it, call "touch()" before "save()" to force savingοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mno update since 2020-05-17 14:29:50, will not save. If you really want to save it, call "touch()" before "save()" to force savingοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mno update since 2020-05-17 14:29:50, will not save. If you really want to save it, call "touch()" before "save()" to force savingοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37mdumped changes to the executor, 0s since last the saveοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37m#sent: 0 #recv: 1 sent_size: 0 Bytes recv_size: 249 BytesοΏ½[0m
chunk_indexer@32942[I]:οΏ½[37m#sent: 1 #recv: 1 sent_size: 294 Bytes recv_size: 249 BytesοΏ½[0m
chunk_indexer@32942[S]:οΏ½[32mterminatedοΏ½[0m
encoder@32939[I]:οΏ½[37mreceived "control" from ctlοΏ½[32mβΈοΏ½[0mβοΏ½[0m
encoder@32939[I]:οΏ½[37mbreak from the event loopοΏ½[0m
encoder@32939[I]:οΏ½[37m#sent: 0 #recv: 1 sent_size: 0 Bytes recv_size: 249 BytesοΏ½[0m
encoder@32939[I]:οΏ½[37m#sent: 1 #recv: 1 sent_size: 288 Bytes recv_size: 249 BytesοΏ½[0m
encoder@32939[S]:οΏ½[32mterminatedοΏ½[0m
splittor@32936[I]:οΏ½[37mreceived "control" from ctlοΏ½[32mβΈοΏ½[0mβοΏ½[0m
splittor@32936[I]:οΏ½[37mbreak from the event loopοΏ½[0m
splittor@32936[I]:οΏ½[37m#sent: 0 #recv: 1 sent_size: 0 Bytes recv_size: 249 BytesοΏ½[0m
splittor@32936[I]:οΏ½[37m#sent: 1 #recv: 1 sent_size: 289 Bytes recv_size: 249 BytesοΏ½[0m
splittor@32936[S]:οΏ½[32mterminatedοΏ½[0m
dispatcher@32933[I]:οΏ½[37mreceived "control" from ctlοΏ½[32mβΈοΏ½[0mβοΏ½[0m
dispatcher@32933[I]:οΏ½[37mbreak from the event loopοΏ½[0m
dispatcher@32933[I]:οΏ½[37m#sent: 0 #recv: 1 sent_size: 0 Bytes recv_size: 249 BytesοΏ½[0m
dispatcher@32933[I]:οΏ½[37m#sent: 1 #recv: 1 sent_size: 291 Bytes recv_size: 249 BytesοΏ½[0m
dispatcher@32933[S]:οΏ½[32mterminatedοΏ½[0m
Flow@32924[S]:οΏ½[32mflow is closed and all resources should be released already, current build level is EMPTYοΏ½[0m
Traceback (most recent call last):
File "/home/alexcg/.local/lib/python3.8/site-packages/jina/clients/python/grpc.py", line 71, in start
self.call(*args, **kwargs)
File "/home/alexcg/.local/lib/python3.8/site-packages/jina/clients/python/__init__.py", line 121, in call
for resp in self._stub.Call(req_iter):
File "/home/alexcg/.local/lib/python3.8/site-packages/grpc/_channel.py", line 416, in __next__
return self._next()
File "/home/alexcg/.local/lib/python3.8/site-packages/grpc/_channel.py", line 689, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.UNKNOWN
details = "Exception iterating requests!"
debug_error_string = "None"
>
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "app.py", line 82, in <module>
main()
File "/home/alexcg/.local/lib/python3.8/site-packages/click/core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "/home/alexcg/.local/lib/python3.8/site-packages/click/core.py", line 782, in main
rv = self.invoke(ctx)
File "/home/alexcg/.local/lib/python3.8/site-packages/click/core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/home/alexcg/.local/lib/python3.8/site-packages/click/core.py", line 610, in invoke
return callback(*args, **kwargs)
File "app.py", line 65, in main
fl.index(raw_bytes=read_data(data_path, num_docs), batch_size=8)
File "/home/alexcg/.local/lib/python3.8/site-packages/jina/helper.py", line 31, in wrapper
return f(*args, **kwargs)
File "/home/alexcg/.local/lib/python3.8/site-packages/jina/flow/__init__.py", line 606, in index
self._get_client(**kwargs).index(input_fn, output_fn)
File "/home/alexcg/.local/lib/python3.8/site-packages/jina/clients/python/__init__.py", line 184, in index
self.start(output_fn, **kwargs)
File "/home/alexcg/.local/lib/python3.8/site-packages/jina/clients/python/grpc.py", line 82, in start
raise BadClient('%s error in grpc: %s '
jina.excepts.BadClient: StatusCode.UNKNOWN error in grpc: Exception iterating requests! often the case is that you define/send a bad input iterator to jina, please double check your input iterator