2022-04-22 15:38:19 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-22 15:38:20 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/53/0/logs.log
2022-04-22 15:38:20 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-04-22 15:38:20 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 53 attempt id: 0
2022-04-22 15:38:20 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {PUBLIC._AIRBYTE_RAW_CONDITIONS=full_refresh - append}
2022-04-22 15:38:20 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-04-22 15:38:20 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-kafka:0.1.6 exists...
2022-04-22 15:38:20 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-kafka:0.1.6 was found locally.
2022-04-22 15:38:20 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 53
2022-04-22 15:38:20 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/53/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.6 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=53 airbyte/destination-kafka:0.1.6 write --config destination_config.json --catalog destination_catalog.json
2022-04-22 15:38:20 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-snowflake:0.1.10 exists...
2022-04-22 15:38:20 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-snowflake:0.1.10 was found locally.
2022-04-22 15:38:20 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 53
2022-04-22 15:38:20 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/53/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/source-snowflake:0.1.10 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=53 airbyte/source-snowflake:0.1.10 read --config source_config.json --catalog source_catalog.json
2022-04-22 15:38:20 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-04-22 15:38:20 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-04-22 15:38:20 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-04-22 15:38:22 source > 2022-04-22 15:38:22 INFO i.a.i.s.s.SnowflakeSource(main):29 - starting source: class io.airbyte.integrations.source.snowflake.SnowflakeSource
2022-04-22 15:38:22 destination > 2022-04-22 15:38:22 INFO i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-04-22 15:38:22 source > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, config=source_config.json}
2022-04-22 15:38:22 source > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationRunner(run):88 - Sentry transaction event: b3b4552c485f4776be9d0b59db80394f
2022-04-22 15:38:22 source > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Running integration: io.airbyte.integrations.source.snowflake.SnowflakeSource
2022-04-22 15:38:22 source > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Command: READ
2022-04-22 15:38:22 source > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationRunner(runInternal):108 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='null'}
2022-04-22 15:38:22 destination > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-04-22 15:38:22 destination > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-04-22 15:38:22 destination > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Command: WRITE
2022-04-22 15:38:22 destination > 2022-04-22 15:38:22 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-04-22 15:38:23 source > 2022-04-22 15:38:23 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 15:38:23 source > 2022-04-22 15:38:23 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 15:38:23 source > 2022-04-22 15:38:23 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 15:38:23 source > 2022-04-22 15:38:23 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-04-22 15:38:23 source > 2022-04-22 15:38:23 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):118 - No cursor field set in catalog but not present in state. Stream: AirbyteStreamNameNamespacePair{name='_AIRBYTE_RAW_CONDITIONS', namespace='PUBLIC'}, New Cursor Field: null. Resetting cursor value
2022-04-22 15:38:23 source > 2022-04-22 15:38:23 INFO i.a.i.s.s.SnowflakeSource(toDatabaseConfig):56 - jdbc:snowflake://ca18110.us-central1.gcp.snowflakecomputing.com/?role=ACCOUNTADMIN&warehouse=COMPUTE_WH&database=FHIR&schema=PUBLIC&JDBC_QUERY_RESULT_FORMAT=JSON&CLIENT_SESSION_KEEP_ALIVE=true
2022-04-22 15:38:23 destination > 2022-04-22 15:38:23 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 15:38:23 destination > 2022-04-22 15:38:23 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-04-22 15:38:23 destination > 2022-04-22 15:38:23 INFO i.a.i.d.k.KafkaDestinationConfig(propertiesByProtocol):81 - Kafka protocol config: {"security_protocol":"PLAINTEXT"}
2022-04-22 15:38:23 destination > 2022-04-22 15:38:23 WARN o.a.k.c.ClientUtils(parseAndValidateAddresses):75 - Couldn't resolve server testany7-kafka-strimzi-kafka-bootstrap:9092 from bootstrap.servers as DNS resolution failed for testany7-kafka-strimzi-kafka-bootstrap
2022-04-22 15:38:28 source > 2022-04-22 15:38:28 INFO i.a.i.s.s.SnowflakeSource(toDatabaseConfig):56 - jdbc:snowflake://ca18110.us-central1.gcp.snowflakecomputing.com/?role=ACCOUNTADMIN&warehouse=COMPUTE_WH&database=FHIR&schema=PUBLIC&JDBC_QUERY_RESULT_FORMAT=JSON&CLIENT_SESSION_KEEP_ALIVE=true
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column STATUS1 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column STATUS2 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column STATUSP (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column PATIENTID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS1 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS2 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS3 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS4 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS5 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS6 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS7 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS8 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column PROVIDERID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column SERVICEDATE (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DEPARTMENTID (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column OUTSTANDING1 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column OUTSTANDING2 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column OUTSTANDINGP (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column APPOINTMENTID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column LASTBILLEDDATE1 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column LASTBILLEDDATE2 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column LASTBILLEDDATEP (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column CURRENTILLNESSDATE (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column PATIENTDEPARTMENTID (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column REFERRINGPROVIDERID (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column SUPERVISINGPROVIDERID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column HEALTHCARECLAIMTYPEID1 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column HEALTHCARECLAIMTYPEID2 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column PRIMARYPATIENTINSURANCEID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column SECONDARYPATIENTINSURANCEID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column _AIRBYTE_NORMALIZED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column _AIRBYTE_CLAIMS_HASHID (type VARCHAR[32]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_EIQ_CLAIMS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_EIQ_CLAIMS column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_EIQ_CLAIMS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CONDITIONS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CONDITIONS column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CONDITIONS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_ALLERGIES column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_ALLERGIES column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_ALLERGIES column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column STATUS1 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column STATUS2 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column STATUSP (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column PATIENTID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS1 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS2 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS3 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS4 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS5 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS6 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS7 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DIAGNOSIS8 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column PROVIDERID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column SERVICEDATE (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column DEPARTMENTID (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column OUTSTANDING1 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column OUTSTANDING2 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column OUTSTANDINGP (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column APPOINTMENTID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column LASTBILLEDDATE1 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column LASTBILLEDDATE2 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column LASTBILLEDDATEP (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column CURRENTILLNESSDATE (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column PATIENTDEPARTMENTID (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column REFERRINGPROVIDERID (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column SUPERVISINGPROVIDERID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column HEALTHCARECLAIMTYPEID1 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column HEALTHCARECLAIMTYPEID2 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column PRIMARYPATIENTINSURANCEID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column SECONDARYPATIENTINSURANCEID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column _AIRBYTE_NORMALIZED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CLAIMS column _AIRBYTE_CLAIMS_HASHID (type VARCHAR[32]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column CODE (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column STOP (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column TYPE (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column START (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column SYSTEM (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column PATIENT (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column CATEGORY (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column ENCOUNTER (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column REACTION1 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column REACTION2 (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column SEVERITY1 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column SEVERITY2 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column DESCRIPTION (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column DESCRIPTION1 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column DESCRIPTION2 (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column _AIRBYTE_NORMALIZED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table ALLERGIES column _AIRBYTE_ALLERGIES_HASHID (type VARCHAR[32]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_GCSDS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_GCSDS column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_GCSDS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CLAIMS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CLAIMS column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CLAIMS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column ZIP (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column CITY (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column NAME (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column PHONE (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column ADDRESS (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column REVENUE (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column QOLS_AVG (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column MEMBER_MONTHS (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column AMOUNT_COVERED (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column AMOUNT_UNCOVERED (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column UNIQUE_CUSTOMERS (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column COVERED_ENCOUNTERS (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column COVERED_PROCEDURES (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column COVERED_MEDICATIONS (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column STATE_HEADQUARTERED (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column UNCOVERED_ENCOUNTERS (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column UNCOVERED_PROCEDURES (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column COVERED_IMMUNIZATIONS (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column UNCOVERED_MEDICATIONS (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column UNCOVERED_IMMUNIZATIONS (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column _AIRBYTE_NORMALIZED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table GCSDS column _AIRBYTE_GCSDS_HASHID (type VARCHAR[32]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CLAIMS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CLAIMS column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CLAIMS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_MLO_CLAIMS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_MLO_CLAIMS column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_MLO_CLAIMS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_EBY_CLAIMS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_EBY_CLAIMS column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_TMP_EBY_CLAIMS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CAREPLANS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CAREPLANS column _AIRBYTE_DATA (type VARIANT[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table _AIRBYTE_RAW_CAREPLANS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column CODE (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column STOP (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column START (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column PATIENT (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column ENCOUNTER (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column REASONCODE (type DOUBLE[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@42aae04d
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column DESCRIPTION (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column REASONDESCRIPTION (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column _AIRBYTE_AB_ID (type VARCHAR[16777216]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column _AIRBYTE_EMITTED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column _AIRBYTE_NORMALIZED_AT (type TIMESTAMPTZ[0]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):136 - Table CAREPLANS column _AIRBYTE_CAREPLANS_HASHID (type VARCHAR[32]) -> Json type io.airbyte.protocol.models.JsonSchemaType@56b859a6
2022-04-22 15:38:29 source > 2022-04-22 15:38:29 INFO i.a.i.s.r.AbstractRelationalDbSource(queryTableFullRefresh):35 - Queueing query for table: _AIRBYTE_RAW_CONDITIONS
2022-04-22 15:39:24 WARN i.a.c.i.LineGobbler(voidCall):86 - airbyte-source gobbler IOException: Stream closed. Typically happens when cancelling a job.
2022-04-22 15:39:24 ERROR i.a.w.DefaultReplicationWorker(run):169 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:162) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: java.io.IOException: Stream closed
		at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?]
		at java.io.OutputStream.write(OutputStream.java:162) ~[?:?]
		at java.io.BufferedOutputStream.write(BufferedOutputStream.java:123) ~[?:?]
		at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:313) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:318) ~[?:?]
		at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?]
		at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?]
		at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?]
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.notifyEndOfStream(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:126) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:57) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:155) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354) ~[io.airbyte-airbyte-workers-0.35.65-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-04-22 15:39:24 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@5a9853e5[status=failed,recordsSynced=33,bytesSynced=12627,startTime=1650641900112,endTime=1650641964918,totalStats=io.airbyte.config.SyncStats@5d6cd090[recordsEmitted=33,bytesEmitted=12627,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@1921e180[streamName=_AIRBYTE_RAW_CONDITIONS,stats=io.airbyte.config.SyncStats@be9cb7c[recordsEmitted=33,bytesEmitted=12627,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]]
2022-04-22 15:39:24 INFO i.a.w.DefaultReplicationWorker(run):250 - Source did not output any state messages
2022-04-22 15:39:24 WARN i.a.w.DefaultReplicationWorker(run):261 - State capture: No state retained.
2022-04-22 15:39:24 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-04-22 15:39:24 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@6e5f59c3[standardSyncSummary=io.airbyte.config.StandardSyncSummary@243e381f[status=failed,recordsSynced=33,bytesSynced=12627,startTime=1650641900112,endTime=1650641964918,totalStats=io.airbyte.config.SyncStats@5d6cd090[recordsEmitted=33,bytesEmitted=12627,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[io.airbyte.config.StreamSyncStats@1921e180[streamName=_AIRBYTE_RAW_CONDITIONS,stats=io.airbyte.config.SyncStats@be9cb7c[recordsEmitted=33,bytesEmitted=12627,stateMessagesEmitted=<null>,recordsCommitted=<null>]]]],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@6f633f3b[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@615e9c45[stream=io.airbyte.protocol.models.AirbyteStream@755b50ec[name=_AIRBYTE_RAW_CONDITIONS,jsonSchema={"type":"object","properties":{"_AIRBYTE_DATA":{"type":"string"},"_AIRBYTE_AB_ID":{"type":"string"},"_AIRBYTE_EMITTED_AT":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[_AIRBYTE_AB_ID]],namespace=PUBLIC,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[_AIRBYTE_AB_ID]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@20706098[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@569c094a[additionalProperties={attemptNumber=0, jobId=53}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process message delivery failed
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:296)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: java.io.IOException: Stream closed
	at java.base/java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445)
	at java.base/java.io.OutputStream.write(OutputStream.java:162)
	at java.base/java.io.BufferedOutputStream.write(BufferedOutputStream.java:123)
	at java.base/sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:234)
	at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:304)
	at java.base/sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:282)
	at java.base/sun.nio.cs.StreamEncoder.write(StreamEncoder.java:132)
	at java.base/java.io.OutputStreamWriter.write(OutputStreamWriter.java:205)
	at java.base/java.io.BufferedWriter.flushBuffer(BufferedWriter.java:120)
	at java.base/java.io.BufferedWriter.write(BufferedWriter.java:233)
	at java.base/java.io.Writer.write(Writer.java:249)
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination.accept(DefaultAirbyteDestination.java:90)
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getReplicationRunnable$5(DefaultReplicationWorker.java:294)
	... 4 more
,retryable=<null>,timestamp=1650641913348], io.airbyte.config.FailureReason@43351b68[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@6c46efd2[additionalProperties={attemptNumber=0, jobId=53}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.airbyte.workers.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.DefaultReplicationWorker.lambda$getDestinationOutputRunnable$6(DefaultReplicationWorker.java:354)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1650641904869]]]
2022-04-22 15:39:24 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...