arjunkumar_krishnankutty
06/30/2022, 9:12 PMtime=2022-06-30 14:08:08 name=tap_mysql level=CRITICAL message=only INCREMENTAL, LOG_BASED, and FULL TABLE replication methods are supported
Traceback (most recent call last):
meltano_projects/test_meltano/.meltano/extractors/tap-mysql/venv/lib/python3.9/site-packages/tap_mysql/__init__.py", line 354, in sync_non_binlog_streams
raise Exception("only INCREMENTAL, LOG_BASED, and FULL TABLE replication methods are supported")
Exception: only INCREMENTAL, LOG_BASED, and FULL TABLE replication methods are supported
I am testing this on local mysql 5.7.36 container. not able to figure out the issue.
- name: tap-mysql
config:
host: 127.0.0.1
port: 3303
user: *****
database: hr
select:
- hr-jobs.job_id
- hr-jobs.job_title
- hr-jobs.max_salary
- hr-jobs.min_salary
- hr-locations.city
- hr-locations.country_id
- hr-locations.state_province
metadata:
hr-jobs:
replication-method: LOG_BASED
hr-locations:
replication-method: LOG_BASEDjose
06/30/2022, 11:10 PM- name: tap-mysql
config:
metadata.*.test_table*.selected: true
metadata.*.*.selected: true
metadata.myDB-test_table.selected: true
metadata.myDB-test_table.replication-method: LOG_BASED
select:
- test_table.*
metadata:
myDB-test_table:
replication-method: LOG_BASED
Not sure why, but the replication that is inside the metadata tag was not working. Adding the metadata.myDB-test_table.replication-method: LOG_BASED inside the config tab solved the issue.arjunkumar_krishnankutty
07/01/2022, 3:42 AMarjunkumar_krishnankutty
07/01/2022, 4:48 AMmeltano run tap-mysql tap-snowflakejose
07/01/2022, 7:47 AMarjunkumar_krishnankutty
07/01/2022, 9:33 PM2022-07-01T21:23:16.011590Z [info ] time=2022-07-01 14:23:16 name=target_snowflake level=INFO message=Getting catalog objects from table cache... cmd_type=elb consumer=True name=target-snowflake producer=False stdio=stderr string_id=target-snowflake
2022-07-01T21:23:19.403458Z [info ] time=2022-07-01 14:23:19 name=target_snowflake level=INFO message=Table PUBLIC."JOBS" exists cmd_type=elb consumer=True name=target-snowflake producer=False stdio=stderr string_id=target-snowflake
2022-07-01T21:23:21.217703Z [info ] time=2022-07-01 14:23:21 name=target_snowflake level=INFO message=Table PUBLIC."LOCATIONS" exists cmd_type=elb consumer=True name=target-snowflake producer=False stdio=stderr string_id=target-snowflake
2022-07-01T21:23:22.942747Z [info ] time=2022-07-01 14:23:22 name=target_snowflake level=INFO message=Emitting state {"currently_syncing": null, "bookmarks": {"hr-jobs": {"version": 1656650608245, "log_file": "bin.000001", "log_pos": 1011}, "hr-locations": {"version": 1656650608291, "log_file": "bin.000001", "log_pos": 1011}}} cmd_type=elb consumer=True name=target-snowflake producer=False stdio=stderr string_id=target-snowflake
2022-07-01T21:23:22.947892Z [info ] Incremental state has been updated at 2022-07-01 21:23:22.947770.
2022-07-01T21:23:22.948103Z [debug ] Incremental state: {'currently_syncing': None, 'bookmarks': {'hr-jobs': {'version': 1656650608245, 'log_file': 'bin.000001', 'log_pos': 1011}, 'hr-locations': {'version': 1656650608291, 'log_file': 'bin.000001', 'log_pos': 1011}}}
2022-07-01T21:23:22.948225Z [info ] {"currently_syncing": null, "bookmarks": {"hr-jobs": {"version": 1656650608245, "log_file": "bin.000001", "log_pos": 1011}, "hr-locations": {"version": 1656650608291, "log_file": "bin.000001", "log_pos": 1011}}} cmd_type=elb consumer=True name=target-snowflake producer=False stdio=stdout string_id=target-snowflakearjunkumar_krishnankutty
07/05/2022, 9:51 PMjose
07/11/2022, 5:53 PM