Hello,
Mongo connector work when I had mongdb 3.2 and elasticsearch 5.0, but now it is not and I get the following error. Does mongo-connector still work, if not then what will be an alternate to it?
Exception in thread Thread-2:
Traceback (most recent call last):
File "/opt/rh/rh-python34/root/usr/lib64/python3.4/threading.py", line 921, in _bootstrap_inner
self.run()
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/mongo_connector/util.py", line 90, in wrapped
func(*args, **kwargs)
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/mongo_connector/oplog_manager.py", line 199, in run
cursor, cursor_empty = self.init_cursor()
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/mongo_connector/oplog_manager.py", line 702, in init_cursor
self.checkpoint = self.rollback()
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/mongo_connector/oplog_manager.py", line 826, in rollback
for doc in dm.search(start_ts, end_ts):
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/mongo_connector/doc_managers/elastic2_doc_manager.py", line 263, in _stream_search
scroll='10m', **kwargs):
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/elasticsearch/helpers/init.py", line 277, in scan
resp = client.search(body=query, scroll=scroll, size=size, **kwargs)
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/elasticsearch/client/utils.py", line 69, in _wrapped
return func(*args, params=params, **kwargs)
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/elasticsearch/client/init.py", line 539, in search
doc_type, '_search'), params=params, body=body)
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/elasticsearch/transport.py", line 327, in perform_request
status, headers, data = connection.perform_request(method, url, params, body, ignore=ignore, timeout=timeout)
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/elasticsearch/connection/http_urllib3.py", line 109, in perform_request
self._raise_error(response.status, raw_data)
File "/opt/rh/rh-python34/root/usr/lib/python3.4/site-packages/elasticsearch/connection/base.py", line 113, in _raise_error
raise HTTP_EXCEPTIONS.get(status_code, TransportError)(status_code, error_message, additional_info)
elasticsearch.exceptions.RequestError: TransportError(400, 'parsing_exception', 'no [query] registered for [filtered]')