C:\Credion\pgsync\pgsync-2.1.1\venv\Scripts\python.exe "C:\Program Files\JetBrains\PyCharm Community Edition 2021.2\plugins\python-ce\helpers\pydev\pydevd.py" --multiproc --qt-support=auto --client 127.0.0.1 --port 60850 --file C:/Credion/pgsync/pgsync-2.1.1/bin/pgsync --config C:\Credion\pgsync\schema.json --daemon Connected to pydev debugger (build 212.4746.96) C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\elasticsearch\connection\base.py:208: ElasticsearchWarning: Elasticsearch built-in security features are not enabled. Without authentication, your cluster could be accessible to anyone. See https://www.elastic.co/guide/en/elasticsearch/reference/7.13/security-minimal-setup.html to enable security. warnings.warn(message, category=ElasticsearchWarning) - Book - Author 0:00:03.603893 (3.60 sec) 2021-08-18 22:26:05.559:ERROR:pgsync.sync: Exception: (psycopg2.errors.UndefinedFunction) operator does not exist: text = integer LINE 5: WHERE "Book_1".isbn = 8 ^ HINT: No operator matches the given name and argument types. You might need to add explicit type casts. [SQL: SELECT count(*) AS count_1 FROM public."Book" AS "Book_1" LEFT OUTER JOIN (SELECT JSON_AGG(CAST(anon_2._keys AS JSONB) || CAST(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_1)s, JSON_BUILD_ARRAY(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_2)s, JSON_BUILD_ARRAY("BookAuthor_1".id)))) AS JSONB)) AS _keys, JSON_AGG(anon_2.anon) AS "Author", "BookAuthor_1".book_isbn AS book_isbn FROM public."BookAuthor" AS "BookAuthor_1" LEFT OUTER JOIN (SELECT CAST(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_3)s, JSON_BUILD_ARRAY(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_4)s, JSON_BUILD_ARRAY("Author_1".id)))) AS JSONB) AS _keys, JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_5)s, "Author_1".name) AS anon, "Author_1".id AS id FROM public."Author" AS "Author_1") AS anon_2 ON anon_2.id = "BookAuthor_1".author_id GROUP BY "BookAuthor_1".book_isbn) AS anon_1 ON anon_1.book_isbn = "Book_1".isbn WHERE "Book_1".isbn = %(isbn_1)s] [parameters: {'JSON_BUILD_OBJECT_1': 'BookAuthor', 'JSON_BUILD_OBJECT_2': 'id', 'JSON_BUILD_OBJECT_3': 'Author', 'JSON_BUILD_OBJECT_4': 'id', 'JSON_BUILD_OBJECT_5': 'name', 'isbn_1': 8}] (Background on this error at: http://sqlalche.me/e/14/f405) Traceback (most recent call last): File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1770, in _execute_context self.dialect.do_execute( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\default.py", line 717, in do_execute cursor.execute(statement, parameters) psycopg2.errors.UndefinedFunction: operator does not exist: text = integer LINE 5: WHERE "Book_1".isbn = 8 ^ HINT: No operator matches the given name and argument types. You might need to add explicit type casts. The above exception was the direct cause of the following exception: Traceback (most recent call last): File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\sync.py", line 832, in sync_payloads self.es.bulk(self.index, itertools.chain(*docs)) File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\elastichelper.py", line 83, in bulk for _ in parallel_bulk( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\elasticsearch\helpers\actions.py", line 472, in parallel_bulk for result in pool.imap( File "C:\Users\Administrator\AppData\Local\Programs\Python\Python39\lib\multiprocessing\pool.py", line 870, in next raise value File "C:\Users\Administrator\AppData\Local\Programs\Python\Python39\lib\multiprocessing\pool.py", line 125, in worker result = (True, func(*args, **kwds)) File "C:\Users\Administrator\AppData\Local\Programs\Python\Python39\lib\multiprocessing\pool.py", line 144, in _helper_reraises_exception raise ex File "C:\Users\Administrator\AppData\Local\Programs\Python\Python39\lib\multiprocessing\pool.py", line 388, in _guarded_task_generation for i, x in enumerate(iterable): File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\elasticsearch\helpers\actions.py", line 155, in _chunk_actions for action, data in actions: File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\sync.py", line 760, in _sync length=self.fetchcount(node._subquery), File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\base.py", line 869, in fetchcount return conn.execute( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1262, in execute return meth(self, multiparams, params, _EMPTY_EXECUTION_OPTS) File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\sql\elements.py", line 323, in _execute_on_connection return connection._execute_clauseelement( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1451, in _execute_clauseelement ret = self._execute_context( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1813, in _execute_context self._handle_dbapi_exception( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1994, in _handle_dbapi_exception util.raise_( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\util\compat.py", line 207, in raise_ raise exception File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1770, in _execute_context self.dialect.do_execute( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\default.py", line 717, in do_execute cursor.execute(statement, parameters) sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedFunction) operator does not exist: text = integer LINE 5: WHERE "Book_1".isbn = 8 ^ HINT: No operator matches the given name and argument types. You might need to add explicit type casts. [SQL: SELECT count(*) AS count_1 FROM public."Book" AS "Book_1" LEFT OUTER JOIN (SELECT JSON_AGG(CAST(anon_2._keys AS JSONB) || CAST(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_1)s, JSON_BUILD_ARRAY(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_2)s, JSON_BUILD_ARRAY("BookAuthor_1".id)))) AS JSONB)) AS _keys, JSON_AGG(anon_2.anon) AS "Author", "BookAuthor_1".book_isbn AS book_isbn FROM public."BookAuthor" AS "BookAuthor_1" LEFT OUTER JOIN (SELECT CAST(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_3)s, JSON_BUILD_ARRAY(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_4)s, JSON_BUILD_ARRAY("Author_1".id)))) AS JSONB) AS _keys, JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_5)s, "Author_1".name) AS anon, "Author_1".id AS id FROM public."Author" AS "Author_1") AS anon_2 ON anon_2.id = "BookAuthor_1".author_id GROUP BY "BookAuthor_1".book_isbn) AS anon_1 ON anon_1.book_isbn = "Book_1".isbn WHERE "Book_1".isbn = %(isbn_1)s] [parameters: {'JSON_BUILD_OBJECT_1': 'BookAuthor', 'JSON_BUILD_OBJECT_2': 'id', 'JSON_BUILD_OBJECT_3': 'Author', 'JSON_BUILD_OBJECT_4': 'id', 'JSON_BUILD_OBJECT_5': 'name', 'isbn_1': 8}] (Background on this error at: http://sqlalche.me/e/14/f405) Traceback (most recent call last): File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1770, in _execute_context self.dialect.do_execute( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\default.py", line 717, in do_execute cursor.execute(statement, parameters) psycopg2.errors.UndefinedFunction: operator does not exist: text = integer LINE 5: WHERE "Book_1".isbn = 8 ^ HINT: No operator matches the given name and argument types. You might need to add explicit type casts. The above exception was the direct cause of the following exception: Traceback (most recent call last): File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\click\core.py", line 1062, in main rv = self.invoke(ctx) File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\click\core.py", line 1404, in invoke return ctx.invoke(self.callback, **ctx.params) File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\click\core.py", line 763, in invoke return __callback(*args, **kwargs) File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\sync.py", line 1093, in main sync.pull() File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\sync.py", line 961, in pull self.logical_slot_changes(txmin=txmin, txmax=txmax) File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\sync.py", line 292, in logical_slot_changes self.sync_payloads(payloads) File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\sync.py", line 832, in sync_payloads self.es.bulk(self.index, itertools.chain(*docs)) File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\elastichelper.py", line 83, in bulk for _ in parallel_bulk( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\elasticsearch\helpers\actions.py", line 472, in parallel_bulk for result in pool.imap( File "C:\Users\Administrator\AppData\Local\Programs\Python\Python39\lib\multiprocessing\pool.py", line 870, in next raise value File "C:\Users\Administrator\AppData\Local\Programs\Python\Python39\lib\multiprocessing\pool.py", line 125, in worker result = (True, func(*args, **kwds)) File "C:\Users\Administrator\AppData\Local\Programs\Python\Python39\lib\multiprocessing\pool.py", line 144, in _helper_reraises_exception raise ex File "C:\Users\Administrator\AppData\Local\Programs\Python\Python39\lib\multiprocessing\pool.py", line 388, in _guarded_task_generation for i, x in enumerate(iterable): File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\elasticsearch\helpers\actions.py", line 155, in _chunk_actions for action, data in actions: File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\sync.py", line 760, in _sync length=self.fetchcount(node._subquery), File "C:\Credion\pgsync\pgsync-2.1.1\pgsync\base.py", line 869, in fetchcount return conn.execute( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1262, in execute return meth(self, multiparams, params, _EMPTY_EXECUTION_OPTS) File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\sql\elements.py", line 323, in _execute_on_connection return connection._execute_clauseelement( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1451, in _execute_clauseelement ret = self._execute_context( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1813, in _execute_context self._handle_dbapi_exception( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1994, in _handle_dbapi_exception util.raise_( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\util\compat.py", line 207, in raise_ raise exception File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\base.py", line 1770, in _execute_context self.dialect.do_execute( File "C:\Credion\pgsync\pgsync-2.1.1\venv\lib\site-packages\sqlalchemy\engine\default.py", line 717, in do_execute cursor.execute(statement, parameters) sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedFunction) operator does not exist: text = integer LINE 5: WHERE "Book_1".isbn = 8 ^ HINT: No operator matches the given name and argument types. You might need to add explicit type casts. [SQL: SELECT count(*) AS count_1 FROM public."Book" AS "Book_1" LEFT OUTER JOIN (SELECT JSON_AGG(CAST(anon_2._keys AS JSONB) || CAST(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_1)s, JSON_BUILD_ARRAY(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_2)s, JSON_BUILD_ARRAY("BookAuthor_1".id)))) AS JSONB)) AS _keys, JSON_AGG(anon_2.anon) AS "Author", "BookAuthor_1".book_isbn AS book_isbn FROM public."BookAuthor" AS "BookAuthor_1" LEFT OUTER JOIN (SELECT CAST(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_3)s, JSON_BUILD_ARRAY(JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_4)s, JSON_BUILD_ARRAY("Author_1".id)))) AS JSONB) AS _keys, JSON_BUILD_OBJECT(%(JSON_BUILD_OBJECT_5)s, "Author_1".name) AS anon, "Author_1".id AS id FROM public."Author" AS "Author_1") AS anon_2 ON anon_2.id = "BookAuthor_1".author_id GROUP BY "BookAuthor_1".book_isbn) AS anon_1 ON anon_1.book_isbn = "Book_1".isbn WHERE "Book_1".isbn = %(isbn_1)s] [parameters: {'JSON_BUILD_OBJECT_1': 'BookAuthor', 'JSON_BUILD_OBJECT_2': 'id', 'JSON_BUILD_OBJECT_3': 'Author', 'JSON_BUILD_OBJECT_4': 'id', 'JSON_BUILD_OBJECT_5': 'name', 'isbn_1': 8}] (Background on this error at: http://sqlalche.me/e/14/f405) Process finished with exit code 1