2023-02-22 04:46:19 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/0/logs.log
2023-02-22 04:46:19 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 04:46:19 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 04:46:19 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:19 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 04:46:19 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:19 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-confluence:0.1.1 exists...
2023-02-22 04:46:20 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-confluence:0.1.1 was found locally.
2023-02-22 04:46:20 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = source-confluence-check-5-0-biimk with resources io.airbyte.config.ResourceRequirements@12464890[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:46:20 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/0 --log-driver none --name source-confluence-check-5-0-biimk --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/source-confluence:0.1.1 -e WORKER_JOB_ATTEMPT=0 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/source-confluence:0.1.1 check --config source_config.json
2023-02-22 04:46:20 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:46:20 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):114 - WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2023-02-22 04:46:28 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Check succeeded
2023-02-22 04:46:28 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@5532ad[status=succeeded,message=<null>]
2023-02-22 04:46:28 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 04:46:28 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:28 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 04:46:28 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:28 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/0/logs.log
2023-02-22 04:46:28 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 04:46:28 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 04:46:28 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:28 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 04:46:28 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:28 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 04:46:29 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 04:46:29 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-check-5-0-xkdrl with resources io.airbyte.config.ResourceRequirements@12464890[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:46:29 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/0 --log-driver none --name destination-postgres-check-5-0-xkdrl --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=0 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 check --config source_config.json
2023-02-22 04:46:29 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:46:30 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 04:46:31 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-22 04:46:31 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 04:46:31 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-22 04:46:31 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-22 04:46:31 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:46:31 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:46:32 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting connection with method: NO_TUNNEL
2023-02-22 04:46:32 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Starting...
2023-02-22 04:46:32 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Start completed.
2023-02-22 04:46:34 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown initiated...
2023-02-22 04:46:34 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown completed.
2023-02-22 04:46:39 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 04:46:40 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 04:46:41 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@4f235316[status=succeeded,message=<null>]
2023-02-22 04:46:41 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 04:46:41 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:41 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 04:46:41 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:42 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/0/logs.log
2023-02-22 04:46:42 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 04:46:42 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 04:46:42 [32mINFO[m i.a.c.EnvConfigs(getEnvOrDefault):1177 - Using default value for environment variable METRIC_CLIENT: ''
2023-02-22 04:46:42 [33mWARN[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2023-02-22 04:46:42 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):278 - Unknown keyword example - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:46:42 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):278 - Unknown keyword existingJavaType - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:46:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):152 - start sync worker. job id: 5 attempt id: 0
2023-02-22 04:46:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2023-02-22 04:46:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:46:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):167 - configured sync modes: {null.pages=full_refresh - overwrite}
2023-02-22 04:46:42 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):84 - Running destination...
2023-02-22 04:46:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 04:46:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 04:46:42 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-write-5-0-hrdjn with resources io.airbyte.config.ResourceRequirements@347d7367[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:46:42 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/0 --log-driver none --name destination-postgres-write-5-0-hrdjn --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=0 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 write --config destination_config.json --catalog destination_catalog.json
2023-02-22 04:46:42 [32mINFO[m i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):38 - Writing messages to protocol version 0.2.0, messages will be downgraded from protocol version 1.0.0
2023-02-22 04:46:42 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:46:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-confluence:0.1.1 exists...
2023-02-22 04:46:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-confluence:0.1.1 was found locally.
2023-02-22 04:46:42 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = source-confluence-read-5-0-xospr with resources io.airbyte.config.ResourceRequirements@7dec52a0[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:46:42 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/0 --log-driver none --name source-confluence-read-5-0-xospr --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/source-confluence:0.1.1 -e WORKER_JOB_ATTEMPT=0 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/source-confluence:0.1.1 read --config source_config.json --catalog source_catalog.json
2023-02-22 04:46:42 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:46:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):275 - Destination output thread started.
2023-02-22 04:46:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):247 - Waiting for source and destination threads to complete.
2023-02-22 04:46:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):337 - Replication thread started.
2023-02-22 04:46:42 [44msource[0m > WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2023-02-22 04:53:17 [44msource[0m > Starting syncing SourceConfluence
2023-02-22 04:55:02 [44msource[0m > Syncing stream: pages 
2023-02-22 04:55:25 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):278 - Unknown keyword user - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:55:41 [43mdestination[0m > starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 04:55:55 [43mdestination[0m > integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2023-02-22 04:55:56 [43mdestination[0m > Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 04:55:56 [43mdestination[0m > Command: WRITE
2023-02-22 04:55:57 [43mdestination[0m > Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2023-02-22 04:56:02 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-22 04:56:03 [32mINFO[m i.a.w.g.DefaultReplicationWorker(cancel):723 - Cancelling replication worker...
2023-02-22 04:56:04 [43mdestination[0m > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:56:04 [43mdestination[0m > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:56:13 [32mINFO[m i.a.w.g.DefaultReplicationWorker(cancel):732 - Cancelling destination...
2023-02-22 04:56:13 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(cancel):144 - Attempting to cancel destination process...
2023-02-22 04:56:13 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(cancel):149 - Destination process exists, cancelling...
2023-02-22 04:56:13 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(cancel):151 - Cancelled destination process!
2023-02-22 04:56:13 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):252 - One of source or destination thread complete. Waiting on the other.
2023-02-22 04:56:13 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):254 - Source and destination threads complete.
2023-02-22 04:56:13 [32mINFO[m i.a.w.g.DefaultReplicationWorker(cancel):740 - Cancelling source...
2023-02-22 04:56:14 [32mINFO[m i.a.w.i.DefaultAirbyteSource(cancel):169 - Attempting to cancel source process...
2023-02-22 04:56:14 [32mINFO[m i.a.w.i.DefaultAirbyteSource(cancel):174 - Source process exists, cancelling...
2023-02-22 04:56:14 [33mWARN[m i.a.c.i.LineGobbler(voidCall):119 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job.
2023-02-22 04:56:14 [32mINFO[m i.a.w.i.DefaultAirbyteSource(cancel):176 - Cancelled source process!
2023-02-22 04:56:14 [1;31mERROR[m i.a.w.g.DefaultReplicationWorker(replicate):259 - Sync worker failed.
io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:162) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:256) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:175) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:91) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
	Suppressed: java.io.IOException: Stream closed
		at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?]
		at java.io.OutputStream.write(OutputStream.java:164) ~[?:?]
		at java.io.BufferedOutputStream.implWrite(BufferedOutputStream.java:216) ~[?:?]
		at java.io.BufferedOutputStream.write(BufferedOutputStream.java:205) ~[?:?]
		at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:313) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:409) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:414) ~[?:?]
		at sun.nio.cs.StreamEncoder.lockedFlush(StreamEncoder.java:218) ~[?:?]
		at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:205) ~[?:?]
		at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:263) ~[?:?]
		at java.io.BufferedWriter.implFlush(BufferedWriter.java:372) ~[?:?]
		at java.io.BufferedWriter.flush(BufferedWriter.java:359) ~[?:?]
		at io.airbyte.workers.internal.DefaultAirbyteMessageBufferedWriter.flush(DefaultAirbyteMessageBufferedWriter.java:28) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.notifyEndOfInput(DefaultAirbyteDestination.java:115) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:129) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:196) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:175) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:91) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-22 04:56:14 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-22 04:56:14 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-22 04:56:14 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-22 04:56:14 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 04:56:14 [32mINFO[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2023-02-22 04:56:14 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-22 04:56:14 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=a343a9bd-b48a-3670-a1ea-2df13b74b40c, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.commons.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:281) ~[io.airbyte-airbyte-commons-temporal-0.40.32.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:165) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
	at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?]
	at io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:64) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:43) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:95) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:92) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:241) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	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) ~[?:?]
Caused by: java.util.concurrent.CancellationException
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.32.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	... 3 more
2023-02-22 04:56:14 [32mINFO[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):563 - Source did not output any state messages
2023-02-22 04:56:14 [33mWARN[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):574 - State capture: No state retained.
2023-02-22 04:56:14 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):494 - sync summary: {
  "status" : "cancelled",
  "recordsSynced" : 91,
  "bytesSynced" : 436093,
  "startTime" : 1677041202525,
  "endTime" : 1677041774232,
  "totalStats" : {
    "bytesEmitted" : 436093,
    "destinationStateMessagesEmitted" : 0,
    "destinationWriteEndTime" : 1677041773929,
    "destinationWriteStartTime" : 1677041202798,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "recordsEmitted" : 91,
    "recordsCommitted" : 0,
    "replicationEndTime" : 1677041774178,
    "replicationStartTime" : 1677041202525,
    "sourceReadEndTime" : 0,
    "sourceReadStartTime" : 1677041202732,
    "sourceStateMessagesEmitted" : 0
  },
  "streamStats" : [ {
    "streamName" : "pages",
    "stats" : {
      "bytesEmitted" : 436093,
      "recordsEmitted" : 91
    }
  } ]
}
2023-02-22 04:56:14 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):495 - failures: [ ]
2023-02-22 04:56:14 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = a343a9bd-b48a-3670-a1ea-2df13b74b40c, ActivityType = Replicate, WorkflowId=sync_5, WorkflowType=SyncWorkflow, RunId=14ff8cc4-f97c-4b9e-8bbe-ed5f11a17625
io.grpc.StatusRuntimeException: NOT_FOUND: workflow execution already completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	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-02-22 04:56:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:56:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2023-02-22 04:56:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:56:15 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/1/logs.log
2023-02-22 04:56:15 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 04:56:15 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 04:56:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:56:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 04:56:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:56:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-confluence:0.1.1 exists...
2023-02-22 04:56:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-confluence:0.1.1 was found locally.
2023-02-22 04:56:15 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = source-confluence-check-5-1-bvjat with resources io.airbyte.config.ResourceRequirements@12464890[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:56:15 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/1 --log-driver none --name source-confluence-check-5-1-bvjat --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/source-confluence:0.1.1 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/source-confluence:0.1.1 check --config source_config.json
2023-02-22 04:56:15 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:56:15 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):114 - WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2023-02-22 04:56:22 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Check succeeded
2023-02-22 04:56:22 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@7e6a88d7[status=succeeded,message=<null>]
2023-02-22 04:56:22 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:56:22 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 04:56:22 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:56:22 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 04:56:22 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/1/logs.log
2023-02-22 04:56:22 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 04:56:22 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 04:56:22 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:56:22 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 04:56:22 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:56:22 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 04:56:22 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 04:56:22 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-check-5-1-zrqtz with resources io.airbyte.config.ResourceRequirements@12464890[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:56:22 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/1 --log-driver none --name destination-postgres-check-5-1-zrqtz --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 check --config source_config.json
2023-02-22 04:56:22 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:56:24 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 04:56:24 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-22 04:56:24 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 04:56:24 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-22 04:56:24 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-22 04:56:24 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:56:24 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:56:26 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting connection with method: NO_TUNNEL
2023-02-22 04:56:26 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Starting...
2023-02-22 04:56:26 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Start completed.
2023-02-22 04:56:44 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown initiated...
2023-02-22 04:56:54 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown completed.
2023-02-22 04:57:17 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 04:57:17 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 04:57:18 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@606bffdf[status=succeeded,message=<null>]
2023-02-22 04:57:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 04:57:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:57:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 04:57:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-22 04:57:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-22 04:57:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-22 04:57:18 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-22 04:57:18 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = 1531bcd5-ed59-33a2-a18f-0f3a465b5363, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_b25bee2d-b987-4471-9ddf-1b291b53b2a4, WorkflowType=ConnectionManagerWorkflow, RunId=8f18442c-e889-429d-88ad-15997ec9db79
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:3840) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:303) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:298) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	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-02-22 04:57:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:57:48 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/1/logs.log
2023-02-22 04:57:48 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 04:57:48 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 04:57:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:57:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 04:57:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:57:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 04:57:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 04:57:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-check-5-1-werqw with resources io.airbyte.config.ResourceRequirements@12464890[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:57:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/1 --log-driver none --name destination-postgres-check-5-1-werqw --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 check --config source_config.json
2023-02-22 04:57:48 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:57:51 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 04:57:52 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-22 04:57:52 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 04:57:52 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-22 04:57:54 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-22 04:58:00 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:58:00 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 04:58:40 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting connection with method: NO_TUNNEL
2023-02-22 04:58:54 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Starting...
2023-02-22 04:58:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Start completed.
2023-02-22 04:59:28 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown initiated...
2023-02-22 04:59:33 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown completed.
2023-02-22 04:59:44 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 04:59:44 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 04:59:44 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@50e13fe5[status=succeeded,message=<null>]
2023-02-22 04:59:44 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 04:59:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:59:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 04:59:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:59:48 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/1/logs.log
2023-02-22 04:59:48 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 04:59:48 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 04:59:48 [32mINFO[m i.a.c.EnvConfigs(getEnvOrDefault):1177 - Using default value for environment variable METRIC_CLIENT: ''
2023-02-22 04:59:48 [33mWARN[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2023-02-22 04:59:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):152 - start sync worker. job id: 5 attempt id: 1
2023-02-22 04:59:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):167 - configured sync modes: {null.pages=full_refresh - overwrite}
2023-02-22 04:59:48 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):84 - Running destination...
2023-02-22 04:59:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:59:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2023-02-22 04:59:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 04:59:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 04:59:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 04:59:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-write-5-1-racdz with resources io.airbyte.config.ResourceRequirements@459a61ba[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:59:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/1 --log-driver none --name destination-postgres-write-5-1-racdz --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 write --config destination_config.json --catalog destination_catalog.json
2023-02-22 04:59:48 [32mINFO[m i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):38 - Writing messages to protocol version 0.2.0, messages will be downgraded from protocol version 1.0.0
2023-02-22 04:59:48 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:59:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-confluence:0.1.1 exists...
2023-02-22 04:59:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-confluence:0.1.1 was found locally.
2023-02-22 04:59:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = source-confluence-read-5-1-nzqhc with resources io.airbyte.config.ResourceRequirements@4f284d75[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 04:59:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/1 --log-driver none --name source-confluence-read-5-1-nzqhc --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/source-confluence:0.1.1 -e WORKER_JOB_ATTEMPT=1 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/source-confluence:0.1.1 read --config source_config.json --catalog source_catalog.json
2023-02-22 04:59:48 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 04:59:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):275 - Destination output thread started.
2023-02-22 04:59:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):247 - Waiting for source and destination threads to complete.
2023-02-22 04:59:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):337 - Replication thread started.
2023-02-22 04:59:48 [44msource[0m > WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2023-02-22 05:05:09 [44msource[0m > Starting syncing SourceConfluence
2023-02-22 05:07:29 [33mWARN[m 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-02-22 05:07:29 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/2/logs.log
2023-02-22 05:07:29 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 05:07:29 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 05:07:30 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:07:30 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 05:07:30 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:07:30 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-confluence:0.1.1 exists...
2023-02-22 05:07:30 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-confluence:0.1.1 was found locally.
2023-02-22 05:07:30 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = source-confluence-check-5-2-qtxln with resources io.airbyte.config.ResourceRequirements@10bc58a6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 05:07:30 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/2 --log-driver none --name source-confluence-check-5-2-qtxln --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/source-confluence:0.1.1 -e WORKER_JOB_ATTEMPT=2 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/source-confluence:0.1.1 check --config source_config.json
2023-02-22 05:07:30 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 05:07:30 [1;31mERROR[m i.a.c.i.LineGobbler(voidCall):114 - WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2023-02-22 05:07:37 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Check succeeded
2023-02-22 05:07:37 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@61e4fbc3[status=succeeded,message=<null>]
2023-02-22 05:07:37 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 05:07:37 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:07:37 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 05:07:37 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:07:37 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/2/logs.log
2023-02-22 05:07:37 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 05:07:37 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 05:07:37 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:07:37 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 05:07:37 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:07:37 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 05:07:37 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 05:07:37 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-check-5-2-onvtj with resources io.airbyte.config.ResourceRequirements@10bc58a6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 05:07:37 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/2 --log-driver none --name destination-postgres-check-5-2-onvtj --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=2 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 check --config source_config.json
2023-02-22 05:07:37 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 05:07:46 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:09:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-22 05:10:43 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:11:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-22 05:11:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-22 05:11:16 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:11:16 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:11:17 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):231 - Running sync worker cancellation...
2023-02-22 05:11:18 [33mWARN[m i.a.w.g.DefaultCheckConnectionWorker(run):107 - Check connection job subprocess finished with exit code 143
2023-02-22 05:11:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):235 - Interrupting worker thread...
2023-02-22 05:11:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$6):238 - Cancelling completable future...
2023-02-22 05:11:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 05:11:18 [33mWARN[m i.a.c.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-02-22 05:11:18 [1;31mERROR[m i.a.w.g.DefaultCheckConnectionWorker(run):124 - Unexpected error while checking connection: 
java.io.IOException: Stream closed
	at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:172) ~[?:?]
	at java.io.BufferedInputStream.implRead(BufferedInputStream.java:373) ~[?:?]
	at java.io.BufferedInputStream.read(BufferedInputStream.java:367) ~[?:?]
	at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:333) ~[?:?]
	at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:376) ~[?:?]
	at sun.nio.cs.StreamDecoder.lockedRead(StreamDecoder.java:219) ~[?:?]
	at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:173) ~[?:?]
	at java.io.InputStreamReader.read(InputStreamReader.java:189) ~[?:?]
	at java.io.BufferedReader.fill(BufferedReader.java:161) ~[?:?]
	at java.io.BufferedReader.implReadLine(BufferedReader.java:371) ~[?:?]
	at java.io.BufferedReader.readLine(BufferedReader.java:348) ~[?:?]
	at java.io.BufferedReader.readLine(BufferedReader.java:437) ~[?:?]
	at io.airbyte.workers.WorkerUtils.getStdErrFromErrorStream(WorkerUtils.java:187) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.WorkerUtils.throwWorkerException(WorkerUtils.java:196) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:117) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
2023-02-22 05:11:18 [33mWARN[m i.t.i.a.ActivityTaskExecutors$BaseActivityTaskExecutor(execute):114 - Activity failure. ActivityId=2e062885-52d1-3713-9955-c935aeae5023, activityType=RunWithJobOutput, attempt=1
java.util.concurrent.CancellationException: null
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$6(TemporalAttemptExecution.java:241) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
	at io.airbyte.commons.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-commons-temporal-0.40.32.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$7(TemporalAttemptExecution.java:244) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:358) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	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-02-22 05:11:18 [32mINFO[m i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$5):198 - Completing future exceptionally...
io.airbyte.workers.exception.WorkerException: Unexpected error while getting checking connection.
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:126) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:41) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.32.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: java.io.IOException: Stream closed
	at java.io.BufferedInputStream.getBufIfOpen(BufferedInputStream.java:172) ~[?:?]
	at java.io.BufferedInputStream.implRead(BufferedInputStream.java:373) ~[?:?]
	at java.io.BufferedInputStream.read(BufferedInputStream.java:367) ~[?:?]
	at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:333) ~[?:?]
	at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:376) ~[?:?]
	at sun.nio.cs.StreamDecoder.lockedRead(StreamDecoder.java:219) ~[?:?]
	at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:173) ~[?:?]
	at java.io.InputStreamReader.read(InputStreamReader.java:189) ~[?:?]
	at java.io.BufferedReader.fill(BufferedReader.java:161) ~[?:?]
	at java.io.BufferedReader.implReadLine(BufferedReader.java:371) ~[?:?]
	at java.io.BufferedReader.readLine(BufferedReader.java:348) ~[?:?]
	at java.io.BufferedReader.readLine(BufferedReader.java:437) ~[?:?]
	at io.airbyte.workers.WorkerUtils.getStdErrFromErrorStream(WorkerUtils.java:187) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.WorkerUtils.throwWorkerException(WorkerUtils.java:196) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	at io.airbyte.workers.general.DefaultCheckConnectionWorker.run(DefaultCheckConnectionWorker.java:117) ~[io.airbyte-airbyte-commons-worker-0.40.32.jar:?]
	... 3 more
2023-02-22 05:11:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:11:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 05:11:18 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:11:18 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = 2e062885-52d1-3713-9955-c935aeae5023, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_b25bee2d-b987-4471-9ddf-1b291b53b2a4, WorkflowType=ConnectionManagerWorkflow, RunId=7a227bdb-5a4a-4764-bc36-0104f0ea6b61
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskFailed(WorkflowServiceGrpc.java:3866) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$1(ActivityWorker.java:320) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:315) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	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-02-22 05:11:45 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/2/logs.log
2023-02-22 05:11:45 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 05:11:45 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 05:11:45 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:11:45 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 05:11:45 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:11:45 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 05:11:45 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 05:11:45 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-check-5-2-twbxw with resources io.airbyte.config.ResourceRequirements@10bc58a6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 05:11:45 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/2 --log-driver none --name destination-postgres-check-5-2-twbxw --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=2 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 check --config source_config.json
2023-02-22 05:11:45 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 05:14:02 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:22:16 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-22 05:22:18 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:22:18 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-22 05:22:18 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-22 05:22:22 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:22:22 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:22:25 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting connection with method: NO_TUNNEL
2023-02-22 05:22:25 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Starting...
2023-02-22 05:22:25 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Start completed.
2023-02-22 05:22:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown initiated...
2023-02-22 05:22:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown completed.
2023-02-22 05:22:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:22:27 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:22:27 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@55938c44[status=succeeded,message=<null>]
2023-02-22 05:22:27 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 05:22:27 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:22:27 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 05:22:27 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:22:48 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = 2e062885-52d1-3713-9955-c935aeae5023, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_b25bee2d-b987-4471-9ddf-1b291b53b2a4, WorkflowType=ConnectionManagerWorkflow, RunId=7a227bdb-5a4a-4764-bc36-0104f0ea6b61
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:3840) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:303) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:298) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	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-02-22 05:23:20 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/2/logs.log
2023-02-22 05:23:20 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 05:23:20 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 05:23:21 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:23:21 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 05:23:21 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:23:21 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 05:23:21 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 05:23:21 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-check-5-2-cphcj with resources io.airbyte.config.ResourceRequirements@10bc58a6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 05:23:21 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/2 --log-driver none --name destination-postgres-check-5-2-cphcj --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=2 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 check --config source_config.json
2023-02-22 05:23:21 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 05:23:38 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:24:03 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-22 05:24:03 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:24:03 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-22 05:24:03 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-22 05:24:18 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:24:18 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:24:38 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting connection with method: NO_TUNNEL
2023-02-22 05:25:07 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Starting...
2023-02-22 05:25:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Start completed.
2023-02-22 05:27:00 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown initiated...
2023-02-22 05:27:00 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown completed.
2023-02-22 05:27:00 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:27:00 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:27:00 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@3f1c47c[status=failed,message=Message: HikariPool-1 - Connection is not available, request timed out after 63036ms.]
2023-02-22 05:27:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 05:27:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:27:01 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 05:27:01 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:28:02 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = 2e062885-52d1-3713-9955-c935aeae5023, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_b25bee2d-b987-4471-9ddf-1b291b53b2a4, WorkflowType=ConnectionManagerWorkflow, RunId=7a227bdb-5a4a-4764-bc36-0104f0ea6b61
io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 9.999555666s. [closed=[], open=[[remote_addr=airbyte-temporal/172.24.0.3:7233]]]
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:3840) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:303) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:298) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	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-02-22 05:29:08 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/2/logs.log
2023-02-22 05:29:08 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 05:29:08 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 05:29:08 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:29:08 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 05:29:08 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:29:08 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 05:29:08 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 05:29:08 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-check-5-2-zsegr with resources io.airbyte.config.ResourceRequirements@10bc58a6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 05:29:09 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/2 --log-driver none --name destination-postgres-check-5-2-zsegr --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=2 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 check --config source_config.json
2023-02-22 05:29:09 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 05:30:34 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:30:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-22 05:30:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:30:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-22 05:31:03 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-22 05:31:34 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:31:36 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:31:37 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting connection with method: NO_TUNNEL
2023-02-22 05:31:38 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Starting...
2023-02-22 05:31:38 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Start completed.
2023-02-22 05:31:43 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown initiated...
2023-02-22 05:31:43 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown completed.
2023-02-22 05:31:44 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:31:44 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:31:44 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@5bd120b7[status=succeeded,message=<null>]
2023-02-22 05:31:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:31:44 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 05:31:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 05:31:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:31:54 [33mWARN[m i.t.i.w.ActivityWorker$TaskHandlerImpl(logExceptionDuringResultReporting):365 - Failure during reporting of activity result to the server. ActivityId = 2e062885-52d1-3713-9955-c935aeae5023, ActivityType = RunWithJobOutput, WorkflowId=connection_manager_b25bee2d-b987-4471-9ddf-1b291b53b2a4, WorkflowType=ConnectionManagerWorkflow, RunId=7a227bdb-5a4a-4764-bc36-0104f0ea6b61
io.grpc.StatusRuntimeException: NOT_FOUND: invalid activityID or activity already timed out or invoking workflow is completed
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:271) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:252) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:165) ~[grpc-stub-1.51.1.jar:1.51.1]
	at io.temporal.api.workflowservice.v1.WorkflowServiceGrpc$WorkflowServiceBlockingStub.respondActivityTaskCompleted(WorkflowServiceGrpc.java:3840) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.lambda$sendReply$0(ActivityWorker.java:303) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.lambda$retry$0(GrpcRetryer.java:52) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcSyncRetryer.retry(GrpcSyncRetryer.java:67) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retryWithResult(GrpcRetryer.java:60) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.retryer.GrpcRetryer.retry(GrpcRetryer.java:50) ~[temporal-serviceclient-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.sendReply(ActivityWorker.java:298) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:252) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:206) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:179) ~[temporal-sdk-1.17.0.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.17.0.jar:?]
	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-02-22 05:35:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/2/logs.log
2023-02-22 05:35:40 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 05:35:40 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 05:35:41 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:35:41 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-02-22 05:35:41 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:35:41 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 05:35:41 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 05:35:41 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-check-5-2-kmmnj with resources io.airbyte.config.ResourceRequirements@10bc58a6[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 05:35:41 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/2 --log-driver none --name destination-postgres-check-5-2-kmmnj --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=2 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 check --config source_config.json
2023-02-22 05:35:41 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 05:35:43 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:35:43 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - integration args: {check=null, config=source_config.json}
2023-02-22 05:35:43 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:35:43 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Command: CHECK
2023-02-22 05:35:43 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2023-02-22 05:35:43 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:35:44 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):164 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:35:45 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Starting connection with method: NO_TUNNEL
2023-02-22 05:35:46 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Starting...
2023-02-22 05:35:46 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Start completed.
2023-02-22 05:35:49 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown initiated...
2023-02-22 05:35:50 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - HikariPool-1 - Shutdown completed.
2023-02-22 05:35:50 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:35:50 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):167 - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:35:50 [32mINFO[m i.a.w.g.DefaultCheckConnectionWorker(run):114 - Check connection job received output: io.airbyte.config.StandardCheckConnectionOutput@6f7513b5[status=succeeded,message=<null>]
2023-02-22 05:35:50 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2023-02-22 05:35:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:35:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-02-22 05:35:50 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:35:52 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/5/2/logs.log
2023-02-22 05:35:52 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.32
2023-02-22 05:35:52 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2023-02-22 05:35:52 [32mINFO[m i.a.c.EnvConfigs(getEnvOrDefault):1177 - Using default value for environment variable METRIC_CLIENT: ''
2023-02-22 05:35:52 [33mWARN[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2023-02-22 05:35:52 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):278 - Unknown keyword example - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:35:52 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):278 - Unknown keyword existingJavaType - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:35:52 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):152 - start sync worker. job id: 5 attempt id: 2
2023-02-22 05:35:52 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:35:52 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):167 - configured sync modes: {null.pages=full_refresh - overwrite}
2023-02-22 05:35:52 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2023-02-22 05:35:52 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2023-02-22 05:35:52 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):84 - Running destination...
2023-02-22 05:35:52 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-postgres:0.3.26 exists...
2023-02-22 05:35:52 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-postgres:0.3.26 was found locally.
2023-02-22 05:35:52 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = destination-postgres-write-5-2-ixkng with resources io.airbyte.config.ResourceRequirements@5cb40987[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 05:35:52 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/2 --log-driver none --name destination-postgres-write-5-2-ixkng --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/destination-postgres:0.3.26 -e WORKER_JOB_ATTEMPT=2 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/destination-postgres:0.3.26 write --config destination_config.json --catalog destination_catalog.json
2023-02-22 05:35:52 [32mINFO[m i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):38 - Writing messages to protocol version 0.2.0, messages will be downgraded from protocol version 1.0.0
2023-02-22 05:35:52 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 05:35:52 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-confluence:0.1.1 exists...
2023-02-22 05:35:53 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-confluence:0.1.1 was found locally.
2023-02-22 05:35:53 [32mINFO[m i.a.w.p.DockerProcessFactory(create):125 - Creating docker container = source-confluence-read-5-2-uvscm with resources io.airbyte.config.ResourceRequirements@4d6c96b0[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=] and allowedHosts null
2023-02-22 05:35:53 [32mINFO[m i.a.w.p.DockerProcessFactory(create):170 - Preparing command: docker run --rm --init -i -w /data/5/2 --log-driver none --name source-confluence-read-5-2-uvscm --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e FIELD_SELECTION_WORKSPACES= -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e APPLY_FIELD_SELECTION=false -e WORKER_CONNECTOR_IMAGE=airbyte/source-confluence:0.1.1 -e WORKER_JOB_ATTEMPT=2 -e AUTO_DETECT_SCHEMA=true -e AIRBYTE_VERSION=0.40.32 -e WORKER_JOB_ID=5 airbyte/source-confluence:0.1.1 read --config source_config.json --catalog source_catalog.json
2023-02-22 05:35:53 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):107 - Reading messages from protocol version 0.2.0, messages will be upgraded to protocol version 1.0.0
2023-02-22 05:35:53 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):275 - Destination output thread started.
2023-02-22 05:35:53 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):247 - Waiting for source and destination threads to complete.
2023-02-22 05:35:53 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$7):337 - Replication thread started.
2023-02-22 05:35:53 [44msource[0m > WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2023-02-22 05:35:59 [43mdestination[0m > starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2023-02-22 05:37:28 [44msource[0m > Starting syncing SourceConfluence
2023-02-22 05:37:28 [44msource[0m > Syncing stream: pages 
2023-02-22 05:38:24 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):278 - Unknown keyword user - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:38:47 [43mdestination[0m > integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2023-02-22 05:38:48 [43mdestination[0m > Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2023-02-22 05:38:49 [43mdestination[0m > Command: WRITE
2023-02-22 05:39:04 [43mdestination[0m > Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2023-02-22 05:41:54 [43mdestination[0m > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:41:56 [43mdestination[0m > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2023-02-22 05:51:44 [43mdestination[0m > Starting connection with method: NO_TUNNEL
2023-02-22 05:54:02 [43mdestination[0m > HikariPool-1 - Starting...
2023-02-22 05:54:03 [43mdestination[0m > HikariPool-1 - Start completed.
2023-02-22 05:54:04 [43mdestination[0m > Write config: WriteConfig{streamName=pages, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_jyl_pages, outputTableName=_airbyte_raw_pages, syncMode=overwrite}
2023-02-22 05:54:05 [43mdestination[0m > class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2023-02-22 05:54:05 [43mdestination[0m > Preparing tmp tables in destination started for 1 streams
2023-02-22 05:54:05 [43mdestination[0m > Preparing tmp table in destination started for stream pages. schema: public, tmp table name: _airbyte_tmp_jyl_pages
2023-02-22 05:54:08 [43mdestination[0m > Preparing tables in destination completed.
2023-02-22 06:07:10 [43mdestination[0m > HikariPool-1 - Thread starvation or clock leap detected (housekeeper delta=1m18s254ms252µs371ns).