2023-05-02 14:39:33 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):179 - Attempt 0 to get state
2023-05-02 14:39:33 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):179 - Attempt 0 to set attempt sync config
2023-05-02 14:39:33 INFO i.a.c.t.s.DefaultTaskQueueMapper(getTaskQueue):31 - Called DefaultTaskQueueMapper getTaskQueue for geography auto
2023-05-02 14:39:34 INFO i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/36/0/logs.log
2023-05-02 14:39:34 INFO i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.44.2
2023-05-02 14:39:34 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):179 - Attempt 0 to save workflow id for cancellation
2023-05-02 14:39:34 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):179 - Attempt 0 to get the source for heartbeat
2023-05-02 14:39:34 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):179 - Attempt 0 to get the source definition
2023-05-02 14:39:34 INFO i.a.w.g.ReplicationWorkerFactory(create):95 - Setting up source...
2023-05-02 14:39:34 INFO i.a.w.g.ReplicationWorkerFactory(create):99 - Setting up destination...
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable METRIC_CLIENT: ''
2023-05-02 14:39:34 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2023-05-02 14:39:34 INFO i.a.w.g.ReplicationWorkerFactory(create):108 - Setting up replication worker...
2023-05-02 14:39:34 INFO i.a.w.g.DefaultReplicationWorker(run):161 - start sync worker. job id: 36 attempt id: 0
2023-05-02 14:39:34 INFO i.a.w.g.DefaultReplicationWorker(run):163 - Committing states from replication activity
2023-05-02 14:39:34 INFO i.a.w.g.DefaultReplicationWorker(run):166 - Committing stats from replication activity
2023-05-02 14:39:34 INFO i.a.c.i.LineGobbler(voidCall):149 - 
2023-05-02 14:39:34 INFO i.a.c.i.LineGobbler(voidCall):149 - ----- START REPLICATION -----
2023-05-02 14:39:34 INFO i.a.c.i.LineGobbler(voidCall):149 - 
2023-05-02 14:39:34 INFO i.a.w.g.DefaultReplicationWorker(run):182 - configured sync modes: {public.instances=incremental - append_dedup}
2023-05-02 14:39:34 INFO i.a.w.i.DefaultAirbyteDestination(start):92 - Running destination...
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SIDECAR_KUBE_CPU_LIMIT: '2.0'
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SOCAT_KUBE_CPU_LIMIT: '2.0'
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SIDECAR_KUBE_CPU_REQUEST: '0.1'
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SOCAT_KUBE_CPU_REQUEST: '0.1'
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable LAUNCHDARKLY_KEY: ''
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable FEATURE_FLAG_CLIENT: ''
2023-05-02 14:39:34 INFO i.a.c.i.LineGobbler(voidCall):149 - Checking if airbyte/destination-convex:0.1.0 exists...
2023-05-02 14:39:34 INFO i.a.c.i.LineGobbler(voidCall):149 - airbyte/destination-convex:0.1.0 was found locally.
2023-05-02 14:39:34 INFO i.a.w.p.DockerProcessFactory(create):133 - Creating docker container = destination-convex-write-36-0-gouxp with resources io.airbyte.config.ResourceRequirements@43361b67[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=,additionalProperties={}] and allowedHosts null
2023-05-02 14:39:34 INFO i.a.w.p.DockerProcessFactory(create):184 - Preparing command: docker run --rm --init -i -w /data/36/0 --log-driver none --name destination-convex-write-36-0-gouxp --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_CONNECTOR_IMAGE=airbyte/destination-convex:0.1.0 -e AUTO_DETECT_SCHEMA=true -e LAUNCHDARKLY_KEY= -e SOCAT_KUBE_CPU_REQUEST=0.1 -e SOCAT_KUBE_CPU_LIMIT=2.0 -e USE_STREAM_CAPABLE_STATE=true -e FIELD_SELECTION_WORKSPACES= -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e APPLY_FIELD_SELECTION=false -e WORKER_JOB_ATTEMPT=0 -e OTEL_COLLECTOR_ENDPOINT=http://host.docker.internal:4317 -e FEATURE_FLAG_CLIENT= -e AIRBYTE_VERSION=0.44.2 -e WORKER_JOB_ID=36 airbyte/destination-convex:0.1.0 write --config destination_config.json --catalog destination_catalog.json
2023-05-02 14:39:34 INFO i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):41 - Writing messages to protocol version 0.2.0
2023-05-02 14:39:34 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):181 - Reading messages from protocol version 0.2.0
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SIDECAR_KUBE_CPU_LIMIT: '2.0'
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SOCAT_KUBE_CPU_LIMIT: '2.0'
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SIDECAR_KUBE_CPU_REQUEST: '0.1'
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable SOCAT_KUBE_CPU_REQUEST: '0.1'
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable LAUNCHDARKLY_KEY: ''
2023-05-02 14:39:34 INFO i.a.c.EnvConfigs(getEnvOrDefault):1222 - Using default value for environment variable FEATURE_FLAG_CLIENT: ''
2023-05-02 14:39:34 INFO i.a.c.i.LineGobbler(voidCall):149 - Checking if airbyte/source-postgres:2.0.28 exists...
2023-05-02 14:39:34 INFO i.a.c.i.LineGobbler(voidCall):149 - airbyte/source-postgres:2.0.28 was found locally.
2023-05-02 14:39:34 INFO i.a.w.p.DockerProcessFactory(create):133 - Creating docker container = source-postgres-read-36-0-gbruw with resources io.airbyte.config.ResourceRequirements@19fc9254[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=,additionalProperties={}] and allowedHosts null
2023-05-02 14:39:34 INFO i.a.w.p.DockerProcessFactory(create):184 - Preparing command: docker run --rm --init -i -w /data/36/0 --log-driver none --name source-postgres-read-36-0-gbruw --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e WORKER_CONNECTOR_IMAGE=airbyte/source-postgres:2.0.28 -e AUTO_DETECT_SCHEMA=true -e LAUNCHDARKLY_KEY= -e SOCAT_KUBE_CPU_REQUEST=0.1 -e SOCAT_KUBE_CPU_LIMIT=2.0 -e USE_STREAM_CAPABLE_STATE=true -e FIELD_SELECTION_WORKSPACES= -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e APPLY_FIELD_SELECTION=false -e WORKER_JOB_ATTEMPT=0 -e OTEL_COLLECTOR_ENDPOINT=http://host.docker.internal:4317 -e FEATURE_FLAG_CLIENT= -e AIRBYTE_VERSION=0.44.2 -e WORKER_JOB_ID=36 airbyte/source-postgres:2.0.28 read --config source_config.json --catalog source_catalog.json --state input_state.json
2023-05-02 14:39:34 INFO i.a.w.i.VersionedAirbyteStreamFactory(create):181 - Reading messages from protocol version 0.2.0
2023-05-02 14:39:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):310 - Destination output thread started.
2023-05-02 14:39:34 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$8):376 - Replication thread started.
2023-05-02 14:39:34 INFO i.a.w.i.HeartbeatTimeoutChaperone(runWithHeartbeatThread):94 - Starting source heartbeat check. Will check every 1 minutes.
2023-05-02 14:39:34 source > INFO i.a.i.s.p.PostgresSource(main):485 starting source: class io.airbyte.integrations.source.postgres.PostgresSource
2023-05-02 14:39:34 source > INFO i.a.i.b.IntegrationCliParser(parseOptions):126 integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2023-05-02 14:39:34 source > INFO i.a.i.b.IntegrationRunner(runInternal):108 Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2023-05-02 14:39:34 source > INFO i.a.i.b.IntegrationRunner(runInternal):109 Command: READ
2023-05-02 14:39:34 source > INFO i.a.i.b.IntegrationRunner(runInternal):110 Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2023-05-02 14:39:34 destination > Begin writing to the destination...
2023-05-02 14:39:34 source > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword groups - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-02 14:39:34 source > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-02 14:39:34 source > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword group - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-02 14:39:34 source > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-02 14:39:34 source > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword always_show - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-02 14:39:34 source > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword min - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-02 14:39:34 source > WARN c.n.s.JsonMetaSchema(newValidator):278 Unknown keyword max - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-05-02 14:39:34 source > INFO i.a.i.b.s.SshTunnel(getInstance):204 Starting connection with method: NO_TUNNEL
2023-05-02 14:39:34 source > INFO i.a.i.s.p.PostgresUtils(isCdc):53 using CDC: true
2023-05-02 14:39:34 source > INFO i.a.i.s.r.s.StateManagerFactory(createStateManager):51 Global state manager selected to manage state object with type LEGACY.
2023-05-02 14:39:34 source > INFO i.a.i.s.r.s.StateManagerFactory(generateGlobalState):84 Legacy state converted to global state.
2023-05-02 14:39:34 source > INFO i.a.i.s.r.s.CursorManager(createCursorInfoForStream):181 No cursor field set in catalog but not present in state. Stream: public_instances, New Cursor Field: null. Resetting cursor value
2023-05-02 14:39:34 source > INFO i.a.i.s.r.CdcStateManager(<init>):29 Initialized CDC state with: null
2023-05-02 14:39:34 source > INFO c.z.h.HikariDataSource(<init>):80 HikariPool-1 - Starting...
2023-05-02 14:39:35 source > INFO c.z.h.HikariDataSource(<init>):82 HikariPool-1 - Start completed.
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresUtils(isCdc):53 using CDC: true
2023-05-02 14:39:35 source > INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):31 Set initial fetch size: 10 rows
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresCdcCatalogHelper(getPublicizedTables):118 For CDC, only tables in publication airbyte_publication will be included in the sync: [public.instances]
2023-05-02 14:39:35 source > INFO i.a.i.s.j.AbstractJdbcSource(logPreSyncDebugData):444 Data source product recognized as PostgreSQL:14.6 (Homebrew)
2023-05-02 14:39:35 source > INFO i.a.i.s.j.AbstractJdbcSource(logPreSyncDebugData):456 Discovering indexes for schema "public", table "instances"
2023-05-02 14:39:35 source > INFO i.a.i.s.j.AbstractJdbcSource(logPreSyncDebugData):458 Index name: instances_pkey1, Column: name, Unique: true
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresQueryUtils(logXminStatus):76 Xmin Status : {Number of wraparounds: 0, Xmin Transaction Value: 111798525, Xmin Raw Value: 111798525
2023-05-02 14:39:35 source > INFO i.a.i.s.j.AbstractJdbcSource(discoverInternal):164 Internal schemas to exclude: [catalog_history, information_schema, pg_catalog, pg_internal]
2023-05-02 14:39:35 source > INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):31 Set initial fetch size: 10 rows
2023-05-02 14:39:35 source > INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(accept):40 Set new fetch size: 1213630 rows
2023-05-02 14:39:35 source > INFO i.a.d.j.s.TwoStageSizeEstimator(getTargetBufferByteSize):71 Max memory limit: 9412018176, JDBC buffer size: 5647210906
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresUtils(isCdc):53 using CDC: true
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresUtils(getFirstRecordWaitTime):111 First record waiting time: 300 seconds
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresSource(getIncrementalIterators):347 First record waiting time: 300 seconds
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresUtils(shouldFlushAfterSync):61 Should flush after sync: true
2023-05-02 14:39:35 source > INFO o.a.k.c.c.AbstractConfig(logAll):376 StandaloneConfig values: 
	access.control.allow.methods = 
	access.control.allow.origin = 
	admin.listeners = null
	auto.include.jmx.reporter = true
	bootstrap.servers = [localhost:9092]
	client.dns.lookup = use_all_dns_ips
	config.providers = []
	connector.client.config.override.policy = All
	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	listeners = [http://:8083]
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	offset.flush.interval.ms = 1000
	offset.flush.timeout.ms = 5000
	offset.storage.file.filename = /tmp/cdc-state-offset8256572382554346783/offset.dat
	plugin.path = null
	response.http.headers.config = 
	rest.advertised.host.name = null
	rest.advertised.listener = null
	rest.advertised.port = null
	rest.extension.classes = []
	ssl.cipher.suites = null
	ssl.client.auth = none
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	task.shutdown.graceful.timeout.ms = 5000
	topic.creation.enable = true
	topic.tracking.allow.reset = true
	topic.tracking.enable = true
	value.converter = class org.apache.kafka.connect.json.JsonConverter

2023-05-02 14:39:35 source > WARN o.a.k.c.r.WorkerConfig(logPluginPathConfigProviderWarning):379 Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results.
2023-05-02 14:39:35 source > INFO o.a.k.c.s.FileOffsetBackingStore(start):58 Starting FileOffsetBackingStore with file /tmp/cdc-state-offset8256572382554346783/offset.dat
2023-05-02 14:39:35 source > INFO o.a.k.c.c.AbstractConfig(logAll):376 JsonConverterConfig values: 
	converter.type = key
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2023-05-02 14:39:35 source > INFO o.a.k.c.c.AbstractConfig(logAll):376 JsonConverterConfig values: 
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2023-05-02 14:39:35 source > INFO i.a.i.d.i.p.PostgresDebeziumStateUtil(extractLsn):206 No previous offsets found
2023-05-02 14:39:35 source > INFO i.a.i.d.i.p.PostgresDebeziumStateUtil(parseSavedOffset):181 Closing offsetStorageReader and fileOffsetBackingStore
2023-05-02 14:39:35 source > INFO o.a.k.c.s.FileOffsetBackingStore(stop):66 Stopped FileOffsetBackingStore
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresSource(lambda$getReplicationSlot$4):274 Attempting to find the named replication slot using the query: HikariProxyPreparedStatement@1410456976 wrapping SELECT * FROM pg_replication_slots WHERE slot_name = 'airbyte_slot' AND plugin = 'pgoutput' AND database = 'convex'
2023-05-02 14:39:35 source > INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):31 Set initial fetch size: 10 rows
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresUtils(shouldFlushAfterSync):61 Should flush after sync: true
2023-05-02 14:39:35 source > INFO i.a.i.d.i.p.PostgresCdcTargetPosition(targetPosition):49 identified target lsn: PgLsn{lsn=25777118048}
2023-05-02 14:39:35 source > INFO i.a.i.s.p.PostgresUtils(shouldFlushAfterSync):61 Should flush after sync: true
2023-05-02 14:39:35 source > INFO i.a.i.d.AirbyteDebeziumHandler(getIncrementalIterators):95 Using CDC: true
2023-05-02 14:39:35 source > INFO o.a.k.c.c.AbstractConfig(logAll):376 JsonConverterConfig values: 
	converter.type = key
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2023-05-02 14:39:35 source > INFO o.a.k.c.c.AbstractConfig(logAll):376 JsonConverterConfig values: 
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2023-05-02 14:39:35 source > INFO o.a.k.c.c.AbstractConfig(logAll):376 EmbeddedConfig values: 
	access.control.allow.methods = 
	access.control.allow.origin = 
	admin.listeners = null
	auto.include.jmx.reporter = true
	bootstrap.servers = [localhost:9092]
	client.dns.lookup = use_all_dns_ips
	config.providers = []
	connector.client.config.override.policy = All
	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
	key.converter = class org.apache.kafka.connect.json.JsonConverter
	listeners = [http://:8083]
	metric.reporters = []
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	offset.flush.interval.ms = 1000
	offset.flush.timeout.ms = 5000
	offset.storage.file.filename = /tmp/cdc-state-offset13445654593951644455/offset.dat
	offset.storage.partitions = null
	offset.storage.replication.factor = null
	offset.storage.topic = 
	plugin.path = null
	response.http.headers.config = 
	rest.advertised.host.name = null
	rest.advertised.listener = null
	rest.advertised.port = null
	rest.extension.classes = []
	ssl.cipher.suites = null
	ssl.client.auth = none
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	task.shutdown.graceful.timeout.ms = 5000
	topic.creation.enable = true
	topic.tracking.allow.reset = true
	topic.tracking.enable = true
	value.converter = class org.apache.kafka.connect.json.JsonConverter

2023-05-02 14:39:35 source > WARN o.a.k.c.r.WorkerConfig(logPluginPathConfigProviderWarning):379 Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results.
2023-05-02 14:39:35 source > INFO o.a.k.c.c.AbstractConfig(logAll):376 JsonConverterConfig values: 
	converter.type = key
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2023-05-02 14:39:35 source > INFO o.a.k.c.c.AbstractConfig(logAll):376 JsonConverterConfig values: 
	converter.type = value
	decimal.format = BASE64
	schemas.cache.size = 1000
	schemas.enable = false

2023-05-02 14:39:35 source > WARN i.d.c.p.PostgresConnectorConfig(validateFlushLsnSource):1070 Property 'flush.lsn.source' is set to 'false', the LSN will not be flushed to the database source and WAL logs will not be cleared. User is expected to handle this outside Debezium.
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresConnector(testConnection):154 Successfully tested connection for jdbc:postgresql://host.docker.internal:5432/convex with user 'emmaling'
2023-05-02 14:39:35 source > INFO i.d.j.JdbcConnection(lambda$doClose$4):947 Connection gracefully closed
2023-05-02 14:39:35 source > INFO o.a.k.c.s.FileOffsetBackingStore(start):58 Starting FileOffsetBackingStore with file /tmp/cdc-state-offset13445654593951644455/offset.dat
2023-05-02 14:39:35 source > WARN i.d.c.p.PostgresConnectorConfig(validateFlushLsnSource):1070 Property 'flush.lsn.source' is set to 'false', the LSN will not be flushed to the database source and WAL logs will not be cleared. User is expected to handle this outside Debezium.
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(start):124 Starting PostgresConnectorTask with configuration:
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    connector.class = io.debezium.connector.postgresql.PostgresConnector
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    max.queue.size = 8192
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    slot.name = airbyte_slot
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    publication.name = airbyte_publication
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    topic.prefix = convex
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    offset.storage.file.filename = /tmp/cdc-state-offset13445654593951644455/offset.dat
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    decimal.handling.mode = string
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    flush.lsn.source = false
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    converters = datetime
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    errors.retry.delay.initial.ms = 299
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    datetime.type = io.airbyte.integrations.debezium.internals.postgres.PostgresConverter
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    value.converter = org.apache.kafka.connect.json.JsonConverter
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    key.converter = org.apache.kafka.connect.json.JsonConverter
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    publication.autocreate.mode = disabled
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    database.user = emmaling
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    database.dbname = convex
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    errors.retry.delay.max.ms = 300
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    offset.flush.timeout.ms = 5000
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    heartbeat.interval.ms = 10000
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    column.include.list = \Qpublic.instances\E\.(\Qdb_cluster\E|\Qname\E|\Q_ab_cdc_updated_at\E|\Q_ab_cdc_deleted_at\E|\Q_ab_cdc_lsn\E|\Qmodification_ts\E|\Qstate\E|\Qversion\E|\Qdb_password\E|\Qinstance_secret\E)
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    plugin.name = pgoutput
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    database.port = 5432
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    offset.flush.interval.ms = 1000
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    key.converter.schemas.enable = false
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    include.unknown.datatypes = true
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    errors.max.retries = 10
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    database.hostname = host.docker.internal
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    database.password = ********
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    value.converter.schemas.enable = false
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    name = convex
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    max.batch.size = 2048
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    table.include.list = \Qpublic.instances\E
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(lambda$start$0):126    snapshot.mode = initial
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(startIfNeededAndPossible):243 Attempting to start task
2023-05-02 14:39:35 source > INFO i.d.c.CommonConnectorConfig(getTopicNamingStrategy):849 Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy
2023-05-02 14:39:35 source > INFO i.d.j.JdbcConnection(lambda$doClose$4):947 Connection gracefully closed
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(getPreviousOffsets):375 No previous offsets found
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresConnectorTask(start):113 user 'emmaling' connected to database 'convex' on PostgreSQL 14.6 (Homebrew) on aarch64-apple-darwin22.1.0, compiled by Apple clang version 14.0.0 (clang-1400.0.29.202), 64-bit with roles:
	role 'impolite_fish_831' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'peaceful_horse_578' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_knowing_partridge_253' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_formal_llama_678' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_outgoing_chimpanzee_418' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'fleet_eagle_631' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_brave_cormorant_724' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'adventurous_heron_271' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_little_dunlin_209' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'secret_hare_976' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'judicious_lapwing_404' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'clear_kookabura_918' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_coordinated_goose_728' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'third_sheep_819' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'merry_tiger_926' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_fine_flamingo_545' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'optimistic_quelea_685' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'lazy_lobster_517' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'enchanted_pony_474' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'tough_mouse_480' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
	role 'kindred_leopard_137' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_zany_monkey_512' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'helpful_dunlin_171' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'late_louse_209' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_jaded_caribou_306' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'lovable_hawk_746' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'agile_quail_902' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'false_gazelle_324' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_nautical_antelope_43' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'marvelous_reindeer_171' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_imperfect_cassowary_499' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_flippant_capybara_855' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'innocent_worm_737' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'uncommon_crow_369' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'wandering_bee_475' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'fiery_kangaroo_814' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'superb_spider_100' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_colorless_finch_234' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_woozy_snail_615' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_giddy_crow_472' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'fortunate_elk_646' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'standing_echidna_736' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_brave_beaver_478' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_cagey_turtle_651' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'dapper_grasshopper_973' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'fortunate_curlew_905' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'jovial_shrew_827' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'hushed_mandrill_786' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_dashing_antelope_221' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'formal_kookabura_682' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'bizarre_coyote_440' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'judicious_llama_288' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'beloved_porcupine_444' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'outgoing_leopard_800' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_avid_nightingale_29' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_canny_cobra_785' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_keen_gnu_542' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'glad_pig_33' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_third_wolverine_683' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'uncommon_elephant_829' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'abundant_hedgehog_159' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'standing_capybara_955' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'famous_scorpion_641' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_next_guanaco_86' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_tangible_kingfisher_906' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_tangible_dunlin_929' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'rosy_zebra_28' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_rapid_lobster_434' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'obsolete_gnu_171' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'charming_porpoise_845' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'trustworthy_chicken_266' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'standing_frog_145' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'pg_read_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
	role 'test_shocking_bat_673' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_avid_raven_375' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'mild_leopard_957' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_resolute_mouse_303' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'bleak_dragonfly_28' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'vivid_sandpiper_368' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_kindly_crab_276' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_tricky_gnat_993' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_quick_dotterel_122' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'whimsical_otter_157' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'rightful_chough_822' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'dynamic_hamster_90' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'charming_sheep_976' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'knowing_capybara_249' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_descriptive_coyote_8' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'lovable_mouse_933' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'nautical_meerkat_841' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'bright_chinchilla_839' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_admired_shark_340' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'intent_tarsier_75' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_naive_porcupine_95' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_robust_chinchilla_208' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_childlike_wolverine_269_dev' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'uncommon_herring_177' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'quiet_seahorse_147' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'doubtful_goshawk_423' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'silent_mallard_368' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'compassionate_albatross_711' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_vibrant_anteater_455' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'brainy_boar_354' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'pastel_woodpecker_988' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'canny_dragonfly_581' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'superb_albatross_558' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'reminiscent_lobster_88' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_disagreeable_stingray_78' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_confused_quail_841' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_naive_rat_268' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_different_chicken_55_dev' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_opulent_giraffe_226' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'dusty_meerkat_32' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_shiny_chough_534' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	role 'test_woozy_eagle_243' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
	r…
2023-05-02 14:39:35 source > INFO i.d.c.p.c.PostgresConnection(readReplicationSlotInfo):264 Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{5/FF979310}, catalogXmin=111789349]
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresConnectorTask(start):122 No previous offset found
2023-05-02 14:39:35 source > INFO i.d.u.Threads(threadFactory):270 Requested thread factory for connector PostgresConnector, id = convex named = change-event-source-coordinator
2023-05-02 14:39:35 source > INFO i.d.u.Threads$3(newThread):287 Creating thread debezium-postgresconnector-convex-change-event-source-coordinator
2023-05-02 14:39:35 source > INFO i.d.c.c.BaseSourceTask(startIfNeededAndPossible):245 Successfully started task
2023-05-02 14:39:35 source > INFO i.d.p.ChangeEventSourceCoordinator(lambda$start$0):103 Metrics registered
2023-05-02 14:39:35 source > INFO i.d.p.ChangeEventSourceCoordinator(lambda$start$0):106 Context created
2023-05-02 14:39:35 source > INFO i.d.c.p.s.InitialSnapshotter(shouldSnapshot):34 Taking initial snapshot for new datasource
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresSnapshotChangeEventSource(getSnapshottingTask):65 According to the connector configuration data will be snapshotted
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doExecute):110 Snapshot step 1 - Preparing
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doExecute):119 Snapshot step 2 - Determining captured tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.promotions to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.promotion_entitlements to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public._sqlx_migrations to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.entitlement_grants to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.deprecated_beta_keys to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.team_usage_call_count_per_function to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.members to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.entitlements_snapshot to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.team_usage_per_team to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.teams to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.plan_subscription_log to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.plans to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.deployments to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.promotion_redemptions to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.team_usage_document_count_per_table to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.team_usage_deleted_deployments to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.plan_entitlements to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.old_instances to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.invitations to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.prewarmed_instances to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.team_member to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.authorized_devices to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.projects to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.team_usage_per_deployment to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.current_backend_version_journal to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.instances to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(determineCapturedTables):267 Adding table public.db_clusters to the list of capture schema tables
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doExecute):126 Snapshot step 3 - Locking captured tables [public.instances]
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doExecute):132 Snapshot step 4 - Determining snapshot offset
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresOffsetContext(initialContext):233 Creating initial offset context
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresOffsetContext(initialContext):236 Read xlogStart at 'LSN{6/6F9B60}' from transaction '111798525'
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresSnapshotChangeEventSource(updateOffsetForSnapshot):147 Read xlogStart at 'LSN{6/6F9B60}' from transaction '111798525'
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doExecute):135 Snapshot step 5 - Reading structure of captured tables
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresSnapshotChangeEventSource(readTableStructure):193 Reading structure of schema 'public' of catalog 'convex'
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doExecute):139 Snapshot step 5.a - Creating connection pool
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(createConnectionPool):213 Created connection pool with 1 threads
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doExecute):144 Snapshot step 6 - Persisting schema history
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doExecute):156 Snapshot step 7 - Snapshotting data
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(createDataEvents):390 Creating snapshot worker pool with 1 worker thread(s)
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(createDataEvents):399 For table 'public.instances' using select statement: 'SELECT "name", "db_password", "instance_secret", "version", "db_cluster", "state", "modification_ts" FROM "public"."instances"'
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doCreateDataEventsForTable):513 Exporting data from table 'public.instances' (1 of 1 tables)
2023-05-02 14:39:35 source > INFO i.d.r.RelationalSnapshotChangeEventSource(doCreateDataEventsForTable):559 	 Finished exporting 7 records for table 'public.instances' (1 of 1 tables); total duration '00:00:00.02'
2023-05-02 14:39:35 source > INFO i.d.p.s.AbstractSnapshotChangeEventSource(execute):88 Snapshot - Final stage
2023-05-02 14:39:35 source > INFO i.d.p.s.AbstractSnapshotChangeEventSource(execute):92 Snapshot completed
2023-05-02 14:39:35 source > INFO i.d.p.ChangeEventSourceCoordinator(doSnapshot):156 Snapshot ended with SnapshotResult [status=COMPLETED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='convex'db='convex', lsn=LSN{6/6F9B60}, txId=111798525, timestamp=2023-05-02T14:39:35.518769Z, snapshot=FALSE, schema=public, table=instances], lastSnapshotRecord=true, lastCompletelyProcessedLsn=null, lastCommitLsn=null, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]]
2023-05-02 14:39:35 source > INFO i.d.p.ChangeEventSourceCoordinator(streamingConnected):240 Connected metrics set to 'true'
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresSchema(printReplicaIdentityInfo):100 REPLICA IDENTITY for 'public.instances' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns
2023-05-02 14:39:35 source > INFO i.d.p.ChangeEventSourceCoordinator(streamEvents):173 Starting streaming
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresStreamingChangeEventSource(execute):136 Retrieved latest position from stored offset 'LSN{6/6F9B60}'
2023-05-02 14:39:35 source > INFO i.d.c.p.c.WalPositionLocator(<init>):48 Looking for WAL restart position for last commit LSN 'null' and last change LSN 'LSN{6/6F9B60}'
2023-05-02 14:39:35 source > INFO i.d.c.p.c.PostgresReplicationConnection(initPublication):147 Initializing PgOutput logical decoder publication
2023-05-02 14:39:35 source > INFO i.d.c.p.c.PostgresConnection(readReplicationSlotInfo):264 Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{5/FF979310}, catalogXmin=111789349]
2023-05-02 14:39:35 source > INFO i.d.j.JdbcConnection(lambda$doClose$4):947 Connection gracefully closed
2023-05-02 14:39:35 source > INFO i.d.u.Threads(threadFactory):270 Requested thread factory for connector PostgresConnector, id = convex named = keep-alive
2023-05-02 14:39:35 source > INFO i.d.u.Threads$3(newThread):287 Creating thread debezium-postgresconnector-convex-keep-alive
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresSchema(printReplicaIdentityInfo):100 REPLICA IDENTITY for 'public.instances' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns
2023-05-02 14:39:35 source > INFO i.d.c.p.PostgresStreamingChangeEventSource(searchWalPosition):327 Searching for WAL resume position
2023-05-02 14:39:36 source > INFO i.a.i.d.i.p.PostgresCdcTargetPosition(reachedTargetPosition):61 Signalling close because Snapshot is complete
2023-05-02 14:39:36 source > INFO i.a.i.d.i.DebeziumRecordIterator(requestClose):208 Closing: Change event reached target position
2023-05-02 14:39:36 source > INFO i.d.e.EmbeddedEngine(stop):1146 Stopping the embedded engine
2023-05-02 14:39:36 source > INFO i.d.e.EmbeddedEngine(stop):1153 Waiting for PT5M for connector to stop
2023-05-02 14:39:36 source > INFO i.d.e.EmbeddedEngine(run):944 Stopping the task and engine
2023-05-02 14:39:36 source > INFO i.d.c.c.BaseSourceTask(stop):278 Stopping down connector
2023-05-02 14:39:36 source > INFO i.d.c.p.PostgresStreamingChangeEventSource(searchWalPosition):348 WAL resume position 'null' discovered
2023-05-02 14:39:36 source > INFO i.d.j.JdbcConnection(lambda$doClose$4):947 Connection gracefully closed
2023-05-02 14:39:36 source > INFO i.d.j.JdbcConnection(lambda$doClose$4):947 Connection gracefully closed
2023-05-02 14:39:36 source > INFO i.d.c.p.c.PostgresReplicationConnection(initPublication):147 Initializing PgOutput logical decoder publication
2023-05-02 14:39:36 source > INFO i.d.u.Threads(threadFactory):270 Requested thread factory for connector PostgresConnector, id = convex named = keep-alive
2023-05-02 14:39:36 source > INFO i.d.u.Threads$3(newThread):287 Creating thread debezium-postgresconnector-convex-keep-alive
2023-05-02 14:39:36 source > INFO i.d.c.p.PostgresStreamingChangeEventSource(processMessages):211 Processing messages
2023-05-02 14:39:36 source > INFO i.d.j.JdbcConnection(lambda$doClose$4):947 Connection gracefully closed
2023-05-02 14:39:36 source > INFO i.d.j.JdbcConnection(lambda$doClose$4):947 Connection gracefully closed
2023-05-02 14:39:36 source > INFO i.d.p.ChangeEventSourceCoordinator(streamEvents):175 Finished streaming
2023-05-02 14:39:36 source > INFO i.d.p.ChangeEventSourceCoordinator(streamingConnected):240 Connected metrics set to 'false'
2023-05-02 14:39:36 source > INFO o.a.k.c.s.FileOffsetBackingStore(stop):66 Stopped FileOffsetBackingStore
2023-05-02 14:39:36 source > INFO i.a.i.d.i.DebeziumRecordPublisher(lambda$start$1):73 Debezium engine shutdown.
2023-05-02 14:39:36 source > INFO i.a.i.d.i.DebeziumRecordPublisher(lambda$start$1):74 Connector 'io.debezium.connector.postgresql.PostgresConnector' completed normally.
2023-05-02 14:39:46 source > INFO i.a.i.s.p.PostgresCdcStateHandler(saveState):37 debezium state: {"[\"convex\",{\"server\":\"convex\"}]":"{\"transaction_id\":null,\"lsn\":25777118048,\"txId\":111798525,\"ts_usec\":1683038375518769}"}
2023-05-02 14:39:46 source > INFO i.a.i.s.r.AbstractDbSource(lambda$read$1):173 Closing database connection pool.
2023-05-02 14:39:46 source > INFO c.z.h.HikariDataSource(close):350 HikariPool-1 - Shutdown initiated...
2023-05-02 14:39:46 source > INFO c.z.h.HikariDataSource(close):352 HikariPool-1 - Shutdown completed.
2023-05-02 14:39:46 source > INFO i.a.i.s.r.AbstractDbSource(lambda$read$1):175 Closed database connection pool.
2023-05-02 14:39:46 source > INFO i.a.i.b.IntegrationRunner(runInternal):186 Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2023-05-02 14:39:46 source > INFO i.a.i.s.p.PostgresSource(main):487 completed source: class io.airbyte.integrations.source.postgres.PostgresSource
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$8):438 - Source has no more messages, closing connection.
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$8):447 - Total records read: 8 (2 KB)
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$8):456 - Schema validation was performed to a max of 10 records with errors per stream.
2023-05-02 14:39:46 WARN i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):458 - Schema validation errors found for stream public_instances. Error messages: [$.modification_ts: 2023-04-27T21:39:50.929779 is an invalid date-time, $.modification_ts: 2023-04-27T21:39:51.283246 is an invalid date-time, $._ab_cdc_deleted_at: null found, string expected, $.modification_ts: 2023-04-27T20:26:11.595993 is an invalid date-time, $.modification_ts: 2023-04-27T20:27:00.968949 is an invalid date-time, $.modification_ts: 2023-04-26T18:50:36.867480 is an invalid date-time, $.modification_ts: 2023-04-26T18:50:35.310486 is an invalid date-time, $.modification_ts: 2023-04-27T20:26:10.969919 is an invalid date-time]
2023-05-02 14:39:46 INFO i.a.w.i.HeartbeatTimeoutChaperone(runWithHeartbeatThread):111 - thread status... heartbeat thread: false , replication thread: true
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(replicate):266 - Waiting for source and destination threads to complete.
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(replicate):271 - One of source or destination thread complete. Waiting on the other.
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):321 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@4a8c3b8e[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@444bdcaf[type=GLOBAL,stream=<null>,global=<null>,data={"cdc":true,"cdc_state":{"state":{"[\"convex\",{\"server\":\"convex\"}]":"{\"transaction_id\":null,\"lsn\":25777118048,\"txId\":111798525,\"ts_usec\":1683038375518769}"}},"streams":[{"stream_name":"instances","stream_namespace":"public","cursor_field":[]}]},additionalProperties={global_={shared_state={state={["convex",{"server":"convex"}]={"transaction_id":null,"lsn":25777118048,"txId":111798525,"ts_usec":1683038375518769}}}, stream_states=[{stream_descriptor={name=instances, namespace=public}, stream_state={stream_name=instances, cursor_field=[], stream_namespace=public}}]}}],trace=<null>,control=<null>,additionalProperties={}]
2023-05-02 14:39:46 WARN i.a.w.i.b.DefaultSyncStatsTracker(updateDestinationStateStats):195 - The message tracker encountered an issue that prevents committed record counts from being reliably computed. This only impacts metadata and does not indicate a problem with actual sync data.
io.airbyte.workers.internal.book_keeping.StateDeltaTracker$StateDeltaTrackerException: Delta was not stored for state hash 1727035794
	at io.airbyte.workers.internal.book_keeping.StateDeltaTracker.commitStateHash(StateDeltaTracker.java:128) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.book_keeping.DefaultSyncStatsTracker.updateDestinationStateStats(DefaultSyncStatsTracker.java:192) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.sync_persistence.SyncPersistenceImpl.updateDestinationStateStats(SyncPersistenceImpl.java:426) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.handleDestinationEmittedState(AirbyteMessageTracker.java:137) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.acceptFromDestination(AirbyteMessageTracker.java:103) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:323) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-05-02 14:39:46 WARN i.a.w.i.b.DefaultSyncStatsTracker(updateDestinationStateStats):205 - The state message tracker was unable to match the destination state message to a corresponding source state message.This only impacts metrics and does not indicate a problem with actual sync data.
io.airbyte.workers.internal.book_keeping.StateMetricsTracker$StateMetricsTrackerNoStateMatchException: Destination state message cannot be matched to corresponding Source state message.
	at io.airbyte.workers.internal.book_keeping.StateMetricsTracker.findStartingTimeStampAndRemoveOlderEntries(StateMetricsTracker.java:169) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.book_keeping.StateMetricsTracker.updateStates(StateMetricsTracker.java:104) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.book_keeping.DefaultSyncStatsTracker.updateDestinationStateStats(DefaultSyncStatsTracker.java:202) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.sync_persistence.SyncPersistenceImpl.updateDestinationStateStats(SyncPersistenceImpl.java:426) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.handleDestinationEmittedState(AirbyteMessageTracker.java:137) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.internal.book_keeping.AirbyteMessageTracker.acceptFromDestination(AirbyteMessageTracker.java:103) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:323) ~[io.airbyte-airbyte-commons-worker-0.44.2.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-05-02 14:39:46 INFO i.a.w.i.s.SyncPersistenceImpl(startBackgroundFlushStateTask):168 - starting state flush thread for connectionId c7171460-8a76-469a-9d63-13c576493ca8
2023-05-02 14:39:46 destination > Writing complete.
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(replicate):273 - Source and destination threads complete.
2023-05-02 14:39:46 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):179 - Attempt 0 to Flush States from SyncPersistenceImpl
2023-05-02 14:39:46 INFO i.a.a.c.AirbyteApiClient(retryWithJitter):179 - Attempt 0 to Flush Stats from SyncPersistenceImpl
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):561 - sync summary: {
  "status" : "completed",
  "recordsSynced" : 7,
  "bytesSynced" : 2885,
  "startTime" : 1683038374014,
  "endTime" : 1683038386354,
  "totalStats" : {
    "bytesCommitted" : 2885,
    "bytesEmitted" : 2885,
    "destinationStateMessagesEmitted" : 1,
    "destinationWriteEndTime" : 1683038386347,
    "destinationWriteStartTime" : 1683038374084,
    "meanSecondsBeforeSourceStateMessageEmitted" : 10,
    "maxSecondsBeforeSourceStateMessageEmitted" : 10,
    "recordsEmitted" : 7,
    "recordsCommitted" : 7,
    "replicationEndTime" : 1683038386354,
    "replicationStartTime" : 1683038374014,
    "sourceReadEndTime" : 1683038386178,
    "sourceReadStartTime" : 1683038374048,
    "sourceStateMessagesEmitted" : 1
  },
  "streamStats" : [ {
    "streamName" : "instances",
    "stats" : {
      "bytesCommitted" : 2885,
      "bytesEmitted" : 2885,
      "recordsEmitted" : 7,
      "recordsCommitted" : 7
    }
  } ]
}
2023-05-02 14:39:46 INFO i.a.w.g.DefaultReplicationWorker(getReplicationOutput):562 - failures: [ ]
2023-05-02 14:39:46 INFO i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-05-02 14:39:46 INFO i.a.c.i.LineGobbler(voidCall):149 - 
2023-05-02 14:39:46 INFO i.a.c.i.LineGobbler(voidCall):149 - ----- END REPLICATION -----
2023-05-02 14:39:46 INFO i.a.c.i.LineGobbler(voidCall):149 - 
2023-05-02 14:39:46 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@3933382b[standardSyncSummary=io.airbyte.config.StandardSyncSummary@68e3c0aa[status=completed,recordsSynced=7,bytesSynced=2885,startTime=1683038374014,endTime=1683038386354,totalStats=io.airbyte.config.SyncStats@322953d0[bytesCommitted=2885,bytesEmitted=2885,destinationStateMessagesEmitted=1,destinationWriteEndTime=1683038386347,destinationWriteStartTime=1683038374084,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=10,maxSecondsBeforeSourceStateMessageEmitted=10,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=7,recordsCommitted=7,replicationEndTime=1683038386354,replicationStartTime=1683038374014,sourceReadEndTime=1683038386178,sourceReadStartTime=1683038374048,sourceStateMessagesEmitted=1,additionalProperties={}],streamStats=[io.airbyte.config.StreamSyncStats@b483fdb[streamName=instances,streamNamespace=<null>,stats=io.airbyte.config.SyncStats@2b1abcf9[bytesCommitted=2885,bytesEmitted=2885,destinationStateMessagesEmitted=<null>,destinationWriteEndTime=<null>,destinationWriteStartTime=<null>,estimatedBytes=<null>,estimatedRecords=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,recordsEmitted=7,recordsCommitted=7,replicationEndTime=<null>,replicationStartTime=<null>,sourceReadEndTime=<null>,sourceReadStartTime=<null>,sourceStateMessagesEmitted=<null>,additionalProperties={}],additionalProperties={}]],additionalProperties={}],normalizationSummary=<null>,webhookOperationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@5d0acfa0[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2545b002[stream=io.airbyte.protocol.models.AirbyteStream@6f39e596[name=instances,jsonSchema={"type":"object","properties":{"db_cluster":{"type":"string"},"name":{"type":"string"},"_ab_cdc_updated_at":{"type":"string"},"_ab_cdc_deleted_at":{"type":"string"},"_ab_cdc_lsn":{"type":"number"},"modification_ts":{"format":"date-time","airbyte_type":"timestamp_without_timezone","type":"string"},"state":{"type":"string"},"version":{"type":"string"},"db_password":{"type":"string"},"instance_secret":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[[name]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append_dedup,primaryKey=[[name]],additionalProperties={}]],additionalProperties={}],failures=[],commitStateAsap=true,additionalProperties={}]
2023-05-02 14:39:46 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):162 - Sync summary length: 2761
2023-05-02 14:39:46 INFO i.a.c.t.TemporalUtils(withBackgroundHeartbeat):307 - Stopping temporal heartbeating...
2023-05-02 14:39:46 INFO i.a.v.j.JsonSchemaValidator(test):121 - JSON schema validation failed. 
errors: $.method: must be a constant value Standard
2023-05-02 14:39:46 INFO i.a.c.t.StreamResetRecordsHelper(deleteStreamResetRecordsForJob):50 - deleteStreamResetRecordsForJob was called for job 36 with config type sync. Returning, as config type is not resetConnection.