2022-06-22 12:52:46 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.part_size: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Standard]
2022-06-22 12:53:03 destination > SLF4J: Class path contains multiple SLF4J bindings.
2022-06-22 12:52:46 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.part_size: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Internal Staging]
2022-06-22 12:52:46 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.access_key_id: object found, string expected, $.secret_access_key: object found, string expected
2022-06-22 12:52:46 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.project_id: is missing but it is required, $.bucket_name: is missing but it is required, $.credentials_json: is missing but it is required, $.part_size: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [GCS Staging]
2022-06-22 12:52:46 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.azure_blob_storage_account_name: is missing but it is required, $.azure_blob_storage_container_name: is missing but it is required, $.azure_blob_storage_sas_token: is missing but it is required, $.part_size: is not defined in the schema and the schema does not allow additional properties, $.access_key_id: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_name: is not defined in the schema and the schema does not allow additional properties, $.s3_bucket_region: is not defined in the schema and the schema does not allow additional properties, $.secret_access_key: is not defined in the schema and the schema does not allow additional properties, $.purge_staging_data: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Azure Blob Staging]
2022-06-22 12:52:46 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/28670/0/logs.log
2022-06-22 12:52:46 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha
2022-06-22 12:52:46 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-check-28670-0-zwasy for airbyte/source-postgres:0.4.16
2022-06-22 12:52:46 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-check-28670-0-zwasy stdoutLocalPort = 9024
2022-06-22 12:52:46 INFO i.a.w.p.KubeProcessFactory(create):106 - source-postgres-check-28670-0-zwasy stderrLocalPort = 9025
2022-06-22 12:52:46 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server...
2022-06-22 12:52:46 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server...
2022-06-22 12:52:46 INFO i.a.w.p.KubePodProcess(<init>):515 - Creating pod source-postgres-check-28670-0-zwasy...
2022-06-22 12:52:46 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-06-22 12:52:46 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(<init>):546 - Copying files...
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/2a216781-207f-4ac3-a119-39e02e674975/source_config.json datalake/source-postgres-check-28670-0-zwasy:/config/source_config.json -c init
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/69dad9da-83c2-491c-a426-7e9d923a5105/FINISHED_UPLOADING datalake/source-postgres-check-28670-0-zwasy:/config/FINISHED_UPLOADING -c init
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:52:48 INFO i.a.w.p.KubePodProcess(<init>):549 - Waiting until pod is ready...
2022-06-22 12:52:49 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout...
2022-06-22 12:52:49 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr...
2022-06-22 12:52:50 INFO i.a.w.p.KubePodProcess(<init>):565 - Reading pod IP...
2022-06-22 12:52:50 INFO i.a.w.p.KubePodProcess(<init>):567 - Pod IP: 172.16.7.94
2022-06-22 12:52:50 INFO i.a.w.p.KubePodProcess(<init>):574 - Using null stdin output stream...
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 INFO i.a.i.s.p.PostgresSource(main):409 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-06-22 12:52:50 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-06-22 12:52:50 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-06-22 12:52:50 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-22 12:52:50 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-22 12:52:50 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 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-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 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-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 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-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-06-22 12:52:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:50 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-06-22 12:52:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:51 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false
2022-06-22 12:52:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:51 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):93 - Attempting to get metadata from the database to see if we can connect.
2022-06-22 12:52:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:51 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-06-22 12:52:51 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:51 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-06-22 12:52:51 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / source-postgres-check-28670-0-zwasy) - Closed all resources for pod
2022-06-22 12:52:51 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-22 12:52:51 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/28670/0/logs.log
2022-06-22 12:52:51 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha
2022-06-22 12:52:51 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-check-28670-0-qdhtr for airbyte/destination-snowflake:0.4.20
2022-06-22 12:52:51 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-check-28670-0-qdhtr stdoutLocalPort = 9036
2022-06-22 12:52:51 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-check-28670-0-qdhtr stderrLocalPort = 9037
2022-06-22 12:52:51 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server...
2022-06-22 12:52:51 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server...
2022-06-22 12:52:51 INFO i.a.w.p.KubePodProcess(<init>):515 - Creating pod destination-snowflake-check-28670-0-qdhtr...
2022-06-22 12:52:51 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-06-22 12:52:51 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(<init>):546 - Copying files...
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/9a7bd596-5eed-4781-a397-aa6b3e64016f/source_config.json datalake/destination-snowflake-check-28670-0-qdhtr:/config/source_config.json -c init
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/d6e1d926-929a-446d-8372-3115145d9841/FINISHED_UPLOADING datalake/destination-snowflake-check-28670-0-qdhtr:/config/FINISHED_UPLOADING -c init
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:52:53 INFO i.a.w.p.KubePodProcess(<init>):549 - Waiting until pod is ready...
2022-06-22 12:52:54 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout...
2022-06-22 12:52:54 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr...
2022-06-22 12:52:55 INFO i.a.w.p.KubePodProcess(<init>):565 - Reading pod IP...
2022-06-22 12:52:55 INFO i.a.w.p.KubePodProcess(<init>):567 - Pod IP: 172.16.7.67
2022-06-22 12:52:55 INFO i.a.w.p.KubePodProcess(<init>):574 - Using null stdin output stream...
2022-06-22 12:52:55 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Class path contains multiple SLF4J bindings.
2022-06-22 12:52:55 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-22 12:52:55 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-22 12:52:55 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-22 12:52:55 ERROR i.a.c.i.LineGobbler(voidCall):82 - SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):343 - Sentry transaction event: be36ca0d274a43328a9f5f9e863f9ab6
2022-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: CHECK
2022-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 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-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 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-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 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-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 INFO i.a.i.d.j.c.SwitchingDestination(check):55 - Using destination type: COPY_S3
2022-06-22 12:52:55 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:55 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):169 - Creating S3 client...
2022-06-22 12:52:58 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-22 12:52:58 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection
2022-06-22 12:53:00 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-check-28670-0-qdhtr) - Closed all resources for pod
2022-06-22 12:53:00 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-22 12:53:00 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/28670/0/logs.log
2022-06-22 12:53:00 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha
2022-06-22 12:53:00 INFO i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 28670 attempt id: 0
2022-06-22 12:53:00 INFO i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {public.offer=incremental - append_dedup}
2022-06-22 12:53:00 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-06-22 12:53:00 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = destination-snowflake-write-28670-0-lenvx for airbyte/destination-snowflake:0.4.20
2022-06-22 12:53:00 INFO i.a.w.p.KubeProcessFactory(create):103 - destination-snowflake-write-28670-0-lenvx stdoutLocalPort = 9002
2022-06-22 12:53:00 INFO i.a.w.p.KubeProcessFactory(create):106 - destination-snowflake-write-28670-0-lenvx stderrLocalPort = 9003
2022-06-22 12:53:00 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server...
2022-06-22 12:53:00 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server...
2022-06-22 12:53:00 INFO i.a.w.p.KubePodProcess(<init>):515 - Creating pod destination-snowflake-write-28670-0-lenvx...
2022-06-22 12:53:00 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-06-22 12:53:00 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-06-22 12:53:01 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-06-22 12:53:01 INFO i.a.w.p.KubePodProcess(<init>):546 - Copying files...
2022-06-22 12:53:01 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json
2022-06-22 12:53:01 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/53f31a57-fecc-4c6f-9dfe-3091dd1471e2/destination_config.json datalake/destination-snowflake-write-28670-0-lenvx:/config/destination_config.json -c init
2022-06-22 12:53:01 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/dae66b1e-0752-4299-805f-b8e2e0761a4b/destination_catalog.json datalake/destination-snowflake-write-28670-0-lenvx:/config/destination_catalog.json -c init
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/da9aca46-13fe-42fc-8923-272f10b627de/FINISHED_UPLOADING datalake/destination-snowflake-write-28670-0-lenvx:/config/FINISHED_UPLOADING -c init
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:02 INFO i.a.w.p.KubePodProcess(<init>):549 - Waiting until pod is ready...
2022-06-22 12:53:03 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout...
2022-06-22 12:53:03 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr...
2022-06-22 12:53:03 INFO i.a.w.p.KubePodProcess(<init>):565 - Reading pod IP...
2022-06-22 12:53:03 INFO i.a.w.p.KubePodProcess(<init>):567 - Pod IP: 172.16.11.181
2022-06-22 12:53:03 INFO i.a.w.p.KubePodProcess(<init>):570 - Creating stdin socket...
2022-06-22 12:53:03 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = source-postgres-read-28670-0-crzsy for airbyte/source-postgres:0.4.16
2022-06-22 12:53:03 INFO i.a.w.p.KubeProcessFactory(create):103 - source-postgres-read-28670-0-crzsy stdoutLocalPort = 9030
2022-06-22 12:53:03 INFO i.a.w.p.KubeProcessFactory(create):106 - source-postgres-read-28670-0-crzsy stderrLocalPort = 9031
2022-06-22 12:53:03 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server...
2022-06-22 12:53:03 INFO i.a.w.p.KubePodProcess(<init>):515 - Creating pod source-postgres-read-28670-0-crzsy...
2022-06-22 12:53:03 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server...
2022-06-22 12:53:04 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-06-22 12:53:04 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(<init>):546 - Copying files...
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: input_state.json
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/657eb17a-25f0-41ed-a09c-dd60fa9be268/input_state.json datalake/source-postgres-read-28670-0-crzsy:/config/input_state.json -c init
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_config.json
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/890aed22-021d-4d72-aa9b-f2e66c3199a3/source_config.json datalake/source-postgres-read-28670-0-crzsy:/config/source_config.json -c init
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: source_catalog.json
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/f65e5f3c-e020-4c5b-944f-489cd45705b3/source_catalog.json datalake/source-postgres-read-28670-0-crzsy:/config/source_catalog.json -c init
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/c71a0061-14a7-4e09-88be-494c67a62b92/FINISHED_UPLOADING datalake/source-postgres-read-28670-0-crzsy:/config/FINISHED_UPLOADING -c init
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:05 INFO i.a.w.p.KubePodProcess(<init>):549 - Waiting until pod is ready...
2022-06-22 12:53:06 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout...
2022-06-22 12:53:06 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr...
2022-06-22 12:53:07 INFO i.a.w.p.KubePodProcess(<init>):565 - Reading pod IP...
2022-06-22 12:53:07 INFO i.a.w.p.KubePodProcess(<init>):567 - Pod IP: 172.16.6.241
2022-06-22 12:53:07 INFO i.a.w.p.KubePodProcess(<init>):574 - Using null stdin output stream...
2022-06-22 12:53:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):395 - Destination output thread started.
2022-06-22 12:53:07 INFO i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-06-22 12:53:07 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-06-22 12:53:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):347 - Source has no more messages, closing connection.
2022-06-22 12:53:09 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / source-postgres-read-28670-0-crzsy) - Closed all resources for pod
2022-06-22 12:53:09 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):355 - Total records read: 19 (16 KB)
2022-06-22 12:53:09 WARN i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$5):358 - Schema validation errors found for stream publicoffer. Error messages: [$.last_stock_transaction_id is of an incorrect type. Expected it to be number, $.lead_time is of an incorrect type. Expected it to be number, $.sellable_errors is of an incorrect type. Expected it to be string, $.expired_at is of an incorrect type. Expected it to be string, $.country_of_origin is of an incorrect type. Expected it to be string, $.replacement_offer_id is of an incorrect type. Expected it to be number, $.location is of an incorrect type. Expected it to be string, $.last_stock_transaction_balance is of an incorrect type. Expected it to be number]
2022-06-22 12:53:09 INFO i.a.w.g.DefaultReplicationWorker(run):174 - One of source or destination thread complete. Waiting on the other.
2022-06-22 12:53:15 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@73cccbbf[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@78ec8b15[stateType=<null>,data={"cdc":false,"streams":[{"stream_name":"offer","stream_namespace":"public","cursor_field":["updated_at"],"cursor":"2022-06-22T12:52:46.993852Z"}]},global=<null>,streams=[],additionalProperties={}],trace=<null>,additionalProperties={}]
2022-06-22 12:53:17 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / destination-snowflake-write-28670-0-lenvx) - Closed all resources for pod
2022-06-22 12:53:17 INFO i.a.w.g.DefaultReplicationWorker(run):176 - Source and destination threads complete.
2022-06-22 12:53:17 INFO i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@7258f23a[status=completed,recordsSynced=18,bytesSynced=16945,startTime=1655902380733,endTime=1655902397450,totalStats=io.airbyte.config.SyncStats@69b1e83f[recordsEmitted=18,bytesEmitted=16945,stateMessagesEmitted=1,recordsCommitted=18],streamStats=[io.airbyte.config.StreamSyncStats@600daf9b[streamName=offer,stats=io.airbyte.config.SyncStats@387fb7e9[recordsEmitted=18,bytesEmitted=16945,stateMessagesEmitted=<null>,recordsCommitted=18]]]]
2022-06-22 12:53:17 INFO i.a.w.g.DefaultReplicationWorker(run):266 - Source output at least one state message
2022-06-22 12:53:17 INFO i.a.w.g.DefaultReplicationWorker(run):272 - State capture: Updated state to: Optional[io.airbyte.config.State@34a7610c[state={"cdc":false,"streams":[{"stream_name":"offer","stream_namespace":"public","cursor_field":["updated_at"],"cursor":"2022-06-22T12:52:46.993852Z"}]}]]
2022-06-22 12:53:17 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-22 12:53:17 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):157 - sync summary: io.airbyte.config.StandardSyncOutput@2ce9a99[standardSyncSummary=io.airbyte.config.StandardSyncSummary@c37e55e[status=completed,recordsSynced=18,bytesSynced=16945,startTime=1655902380733,endTime=1655902397450,totalStats=io.airbyte.config.SyncStats@69b1e83f[recordsEmitted=18,bytesEmitted=16945,stateMessagesEmitted=1,recordsCommitted=18],streamStats=[io.airbyte.config.StreamSyncStats@600daf9b[streamName=offer,stats=io.airbyte.config.SyncStats@387fb7e9[recordsEmitted=18,bytesEmitted=16945,stateMessagesEmitted=<null>,recordsCommitted=18]]]],normalizationSummary=<null>,state=io.airbyte.config.State@34a7610c[state={"cdc":false,"streams":[{"stream_name":"offer","stream_namespace":"public","cursor_field":["updated_at"],"cursor":"2022-06-22T12:52:46.993852Z"}]}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@749f9c45[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2dc11651[stream=io.airbyte.protocol.models.AirbyteStream@5b2d4b22[name=offer,jsonSchema={"type":"object","properties":{"id":{"type":"number"},"mpn":{"type":"string"},"mpq":{"type":"number"},"expiry":{"type":"string"},"checksum":{"type":"string"},"location":{"type":"string"},"quantity":{"type":"number"},"date_code":{"type":"string"},"lead_time":{"type":"number"},"vendor_id":{"type":"number"},"created_at":{"type":"string"},"expired_at":{"type":"string"},"offer_type":{"type":"string"},"updated_at":{"type":"string"},"price_tiers":{"type":"string"},"product_sku":{"type":"string"},"availability":{"type":"string"},"manufacturer":{"type":"string"},"packaging_type":{"type":"string"},"sellable_errors":{"type":"string"},"country_of_origin":{"type":"string"},"packaging_condition":{"type":"string"},"replacement_offer_id":{"type":"number"},"date_code_within_2_years":{"type":"boolean"},"last_stock_transaction_id":{"type":"number"},"last_stock_transaction_balance":{"type":"number"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[updated_at],destinationSyncMode=append_dedup,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-06-22 12:53:17 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating...
2022-06-22 12:53:17 INFO i.a.c.p.ConfigRepository(updateConnectionState):775 - Updating connection 1bb0f19b-ed19-4c86-a600-15bf5fc08fbf state: io.airbyte.config.State@141e94f9[state={"cdc":false,"streams":[{"stream_name":"offer","stream_namespace":"public","cursor_field":["updated_at"],"cursor":"2022-06-22T12:52:46.993852Z"}]}]
2022-06-22 12:53:17 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Cloud storage job log path: /workspace/28670/0/logs.log
2022-06-22 12:53:17 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha
2022-06-22 12:53:17 INFO i.a.w.g.DefaultNormalizationWorker(run):49 - Running normalization.
2022-06-22 12:53:17 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization-snowflake:0.2.1
2022-06-22 12:53:17 INFO i.a.w.p.KubeProcessFactory(create):100 - Attempting to start pod = normalization-snowflake-normalize-28670-0-wyuez for airbyte/normalization-snowflake:0.2.1
2022-06-22 12:53:17 INFO i.a.w.p.KubeProcessFactory(create):103 - normalization-snowflake-normalize-28670-0-wyuez stdoutLocalPort = 9014
2022-06-22 12:53:17 INFO i.a.w.p.KubeProcessFactory(create):106 - normalization-snowflake-normalize-28670-0-wyuez stderrLocalPort = 9015
2022-06-22 12:53:17 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):584 - Creating stdout socket server...
2022-06-22 12:53:17 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):602 - Creating stderr socket server...
2022-06-22 12:53:17 INFO i.a.w.p.KubePodProcess(<init>):515 - Creating pod normalization-snowflake-normalize-28670-0-wyuez...
2022-06-22 12:53:17 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):305 - Waiting for init container to be ready before copying files...
2022-06-22 12:53:17 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):309 - Init container present..
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(waitForInitPodToRun):312 - Init container ready..
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(<init>):546 - Copying files...
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_config.json
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/87673c66-5d78-4acc-88b7-97b1ee98a872/destination_config.json datalake/normalization-snowflake-normalize-28670-0-wyuez:/config/destination_config.json -c init
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: destination_catalog.json
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/a67c614f-86b9-4859-8b37-9aa82dd19fdc/destination_catalog.json datalake/normalization-snowflake-normalize-28670-0-wyuez:/config/destination_catalog.json -c init
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):254 - Uploading file: FINISHED_UPLOADING
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):262 - kubectl cp /tmp/4de26f73-c365-4f10-a870-2954b0e8ca10/FINISHED_UPLOADING datalake/normalization-snowflake-normalize-28670-0-wyuez:/config/FINISHED_UPLOADING -c init
2022-06-22 12:53:19 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):265 - Waiting for kubectl cp to complete
2022-06-22 12:53:20 INFO i.a.w.p.KubePodProcess(copyFilesToKubeConfigVolume):279 - kubectl cp complete, closing process
2022-06-22 12:53:20 INFO i.a.w.p.KubePodProcess(<init>):549 - Waiting until pod is ready...
2022-06-22 12:53:23 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$9):593 - Setting stdout...
2022-06-22 12:53:23 INFO i.a.w.p.KubePodProcess(lambda$setupStdOutAndStdErrListeners$10):605 - Setting stderr...
2022-06-22 12:53:23 INFO i.a.w.p.KubePodProcess(<init>):565 - Reading pod IP...
2022-06-22 12:53:23 INFO i.a.w.p.KubePodProcess(<init>):567 - Pod IP: 172.16.6.212
2022-06-22 12:53:23 INFO i.a.w.p.KubePodProcess(<init>):574 - Using null stdin output stream...
2022-06-22 12:53:03 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-22 12:53:03 destination > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-22 12:53:03 destination > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-22 12:53:03 destination > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-22 12:53:07 source > SLF4J: Class path contains multiple SLF4J bindings.
2022-06-22 12:53:07 source > SLF4J: Found binding in [jar:file:/airbyte/lib/log4j-slf4j-impl-2.17.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-06-22 12:53:07 source > SLF4J: Found binding in [jar:file:/airbyte/lib/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 INFO i.a.i.b.IntegrationRunner(createSentryTransaction):343 - Sentry transaction event: ced05ffa8b774942b275e35487a2d67b
2022-06-22 12:53:07 source > 2022-06-22 12:53:06 INFO i.a.i.s.p.PostgresSource(main):409 - starting source: class io.airbyte.integrations.source.postgres.PostgresSource
2022-06-22 12:53:07 source > SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-06-22 12:53:07 source > SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: READ
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 INFO i.a.i.b.IntegrationRunner(runInternal):121 - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 INFO i.a.i.b.IntegrationRunner(runInternal):122 - Command: WRITE
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 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-06-22 12:53:07 destination > 2022-06-22 12:53:04 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-06-22 12:53:07 destination > 2022-06-22 12:53:04 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-06-22 12:53:07 destination > 2022-06-22 12:53:04 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 INFO i.a.i.d.j.c.SwitchingDestination(getConsumer):65 - Using destination type: COPY_S3
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 INFO i.a.i.d.s.S3DestinationConfig(createS3Client):169 - Creating S3 client...
2022-06-22 12:53:07 destination > 2022-06-22 12:53:04 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):141 - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 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-06-22 12:53:07 source > 2022-06-22 12:53:07 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-06-22 12:53:07 source > 2022-06-22 12:53:07 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-06-22 12:53:07 source > 2022-06-22 12:53:07 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.b.s.SshTunnel(getInstance):170 - Starting connection with method: NO_TUNNEL
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-1 - Starting...
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-1 - Start completed.
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.s.j.AbstractJdbcSource(lambda$getCheckOperations$1):93 - Attempting to get metadata from the database to see if we can connect.
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO c.z.h.HikariDataSource(close):350 - HikariPool-1 - Shutdown initiated...
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO c.z.h.HikariDataSource(close):352 - HikariPool-1 - Shutdown completed.
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.s.r.CdcStateManager(<init>):26 - Initialized CDC state with: null
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.s.r.StateManager(createCursorInfoForStream):108 - Found matching cursor in state. Stream: AirbyteStreamNameNamespacePair{name='offer', namespace='public'}. Cursor Field: updated_at Value: 2022-06-22T12:45:16.595115Z
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO c.z.h.HikariDataSource(<init>):80 - HikariPool-2 - Starting...
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO c.z.h.HikariDataSource(<init>):82 - HikariPool-2 - Start completed.
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.s.p.PostgresSource(discoverInternal):144 - Checking schema: public
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.i.s.j.AbstractJdbcSource(discoverInternal):121 - Internal schemas to exclude: [catalog_history, information_schema, pg_catalog, pg_internal]
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):32 - Set initial fetch size: 10 rows
2022-06-22 12:53:07 source > 2022-06-22 12:53:07 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(accept):42 - Updated fetch size: 100000 rows
2022-06-22 12:53:08 source > 2022-06-22 12:53:07 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column created_by_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column region (type vendor_region_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column country (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column archived_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column platform_id (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column is_sourceability (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column markup (type float8[17]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column hide_scraped_offers (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column all_scraped_offers_date_code_greater_than_2_years (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column vendor_type (type vendor_type_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column partner_status (type vendor_partner_status_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column minimum_order_value (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column image_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column blacklisted_manufacturers (type jsonb[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column date_code_policy_url (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor column lead_time_buffer (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_request column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_request column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_request column failed_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_request column failed_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_request column succeeded_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_request column scrapers (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_request column id (type bigserial[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table migration_versions column version (type varchar[191]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table migration_versions column executed_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table migration_versions column execution_time (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_unique_vendors_roll_up column range_start (type timestamp[22]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_unique_vendors_roll_up column offer_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_unique_vendors_roll_up column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_unique_vendors_roll_up column count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_unique_vendors_roll_up column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_default column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_default column import_session_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_default column value (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_default column data_field (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_default column use_existing_data (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_api_datasheet_request column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_api_datasheet_request column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_api_datasheet_request column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_api_datasheet_request column result (type manufacturer_api_datasheet_request_result_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_group column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_group column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table datasheet_file column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table datasheet_file column checksum (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table datasheet_file column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table datasheet_file column uuid (type uuid[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table datasheet_file column mime_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark column search_mpn (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark column search_manufacturer (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark column result_mpn (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark column result_manufacturer (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark column result_status (type part_match_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark column last_searched_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column created_by_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column file_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column header (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column status (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column created (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column updated (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column client_file_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column status_sort (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column updated_by_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column import_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column publish_chunk_index (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column import_rows_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column imported_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column metadata (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column webhook_target_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column import_rows_processed_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session column import_row_issue_aggregations (type jsonb[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_match column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_match column import_session_match_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_match column import_row_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_match column manufacturer_part_number (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_match column manufacturer_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_match column exact_match (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_match column sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_key (type bigserial[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_time (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_user (type varchar[64]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_txn (type varchar[16]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_tag (type varchar[24]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_oid (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_name (type varchar[64]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_schema (type varchar[64]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table awsdms_ddl_audit column c_ddlqry (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_scraped column id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_scraped column scraped_url (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_scraped column scraped_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_scraped column scraper_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_scraped column scraper_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_scraped column image_urls (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_scraped column live (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_scraped column scraper_request_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_lead column id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_product_offers_whitelist column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_product_offers_whitelist column api_client_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_product_offers_whitelist column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table active_offer column offer_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table active_offer column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table active_offer column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table active_offer column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table active_offer column sellable_errors (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table active_offer column offer_type (type offer_type_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table active_offer column price_tiers (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table active_offer column attributes (type jsonb[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_mapping_replace column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_mapping_replace column import_mapping_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_mapping_replace column original_value (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_mapping_replace column new_value (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column service (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column batch_size (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column current_position (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column number_of_records (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column started_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column completed_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column synced_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table export_job column files (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_market_availability_score_history column id (type bigserial[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_market_availability_score_history column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_market_availability_score_history column score (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_market_availability_score_history column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column url (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column ihs_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column manufacturer_setting_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column custom_manufacturer_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column updated_at_for_indexing (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column indexed_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer column index_task (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark_result column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark_result column match_status_results (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark_result column total_searches (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark_result column positive_changes (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark_result column neutral_changes (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark_result column negative_changes (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark_result column file_path (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_match_benchmark_result column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row_issue column id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row_issue column import_row_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row_issue column import_mapping_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row_issue column level (type import_row_issue_level_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row_issue column code (type import_row_issue_code_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row_issue column message (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row_issue column import_session_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table category_map column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table category_map column ihs_category_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table category_map column source (type part_information_source_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table category_map column source_category (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column import_session_offer_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column expiration_updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column expiration_update_checked_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column needed_existing_data (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column referenced_offer_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column import_row_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column account_platform_id (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_sourced column price_multiplier (type numeric[6]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_live column id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_live column live_offer_platform_id (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_live column vendor_offer_id (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_data_ingestor column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_data_ingestor column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_data_ingestor column last_run_time (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_data_ingestor column source (type part_information_source_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_data_ingestor column updates_last_run (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_data_ingestor column update_identifier (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row column id (type bigserial[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row column import_session_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row column data (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row column index (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row column processed_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row column checksum (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_row column duplicate_of_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column id (type bigserial[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column price_date (type date[13]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column high_price (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column low_price (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column high_average (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column low_average (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column average_element_amount (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table search_request_log column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table search_request_log column api_client_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table search_request_log column manufacturer_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table search_request_log column manufacturer_part_number (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table search_request_log column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information_import_row column part_information_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information_import_row column import_row_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column custom_manufacturer_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column ihs_manufacturer_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column lead_time_buffer (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column markup (type float8[17]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column description (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column industries (type _manufacturer_industry_enum[2147483647]) -> JsonSchemaType({type=array})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column new_product_url (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column website_url (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column aliases (type jsonb[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column display_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column primary_address_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column primary_phone_number_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column parent_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column tree_root (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column image_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column company_size (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column established (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting column request_for_quote (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_definition column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_definition column ihs_parameter_set_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_definition column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_definition column description (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_definition column unit_of_measurement (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_definition column data_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_definition column data_length (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_definition column data_precision (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_mapping column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_mapping column import_session_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_mapping column column_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_mapping column data_field (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column ihs_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column indexed_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column last_ihs_update (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column last_ihs_parameters_update (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column mpn (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column manufacturer_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column ihs_category (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column indexed_updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column ihs_category_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column last_ihs_update_check (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column last_index_checksum (type bpchar[40]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product column hidden_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table audit_log column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table audit_log column action (type audit_log_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table audit_log column target_entity (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table audit_log column target_identifier (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table audit_log column changes (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table audit_log column author_id (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table audit_log column author_email (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table audit_log column timestamp (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column country_code (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column administrative_area (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column locality (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column dependent_locality (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column postal_code (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column sorting_code (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column address_line1 (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column address_line2 (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table address column organization (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper column enabled (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper column tick_multiplier (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column mpn (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column manufacturer (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column vendor_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column date_code (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column quantity (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column lead_time (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column mpq (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column moq (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column price (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column packaging_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column availability (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column packaging_condition (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column date_code_within_2_years (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column country_of_origin (type varchar[2]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column additional_information (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column vendor (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead column expired_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting_whitelisted_vendors column ihs_category_setting_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting_whitelisted_vendors column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column imported_match_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_filename (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_compliance (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_technical_data (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_alternates (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column imported_exact_match_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_url (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_offers (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_scraper_details (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_sku (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_datasheet_url (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_match column export_intelligence_scores (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_type column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_type column ihs_category_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_type column type_parameter_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_type column value (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_type column count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table remote_datasheet column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table remote_datasheet column file_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table remote_datasheet column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table remote_datasheet column url (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_custom_part column id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_custom_part column manufacturer (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column id (type bigserial[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column mpn (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column date_code (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column quantity (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column lead_time (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column mpq (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column packaging_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column manufacturer (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column availability (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column packaging_condition (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column expiry (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column date_code_within_2_years (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column sellable_errors (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column expired_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column offer_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column price_tiers (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column last_stock_transaction_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column last_stock_transaction_balance (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column checksum (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column country_of_origin (type varchar[2]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column location (type varchar[2]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer column replacement_offer_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column lead_time_expiring_soon_notification_sent_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column lead_time_expired_notification_sent_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column stock_expiring_soon_notification_sent_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column stock_expired_notification_sent_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column imported_qualified_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column imported_matched_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column imported_matched_qualified_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column availability_lead_time_expiration (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column availability_stock_expiration (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column availability_lead_time_expires_at (type date[13]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column availability_stock_expires_at (type date[13]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column imported_needed_existing_data_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column imported_used_existing_data_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column price_multiplier (type numeric[6]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer column source (type import_session_offer_source_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer_expiry_update column import_session_offer_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer_expiry_update column offer_sourced_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_offer_expiry_update column processed_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_rating column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_rating column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_rating column erp_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_rating column order_rating (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_rating column quality (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_rating column timeliness (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_rating column total_rating (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_target column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_target column url (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_target column headers (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_manufacturer column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_manufacturer column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_manufacturer column url (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column username (type varchar[180]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column username_canonical (type varchar[180]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column email (type varchar[180]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column email_canonical (type varchar[180]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column enabled (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column salt (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column password (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column last_login (type timestamp[22]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column confirmation_token (type varchar[180]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column password_requested_at (type timestamp[22]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column roles (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table fos_user column timezone (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_contact column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_contact column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_contact column title (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_contact column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_contact column email (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_contact column phone_number (type varchar[35]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column parent_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column tree_root (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column parametric_file_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column tree_left (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column tree_level (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column tree_right (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column type_parameter_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category column ihs_parameter_set_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule column scrape_frequency (type product_scrape_frequency[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule column next_scrape_queued_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule column last_scrape_completed_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule column next_request_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule column frequency_set_by_user (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_group_vendor column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_group_vendor column vendor_group_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_group_vendor column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table vendor_group_vendor column priority (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule_import_row column product_scrape_schedule_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scrape_schedule_import_row column import_row_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_request column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_request column webhook_target_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_request column event_date (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_request column event_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_request column last_attempted_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_request column payload (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_request column send_attempts (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table webhook_request column status (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column ihs_category_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column manufacturer_part_number (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column manufacturer_name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column uuid (type uuid[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column import_session_custom_part_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column description (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column datasheet_url (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column import_row_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column status (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column replaced_deleted_ihs_part_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column image_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table custom_part column datasheet_file_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_part_information column id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_part_information column manufacturer_identifier (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_part_information column source (type part_information_source_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_set column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_set column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_parameter_set column file_prefix (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_requests_roll_up column range_start (type timestamp[22]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_requests_roll_up column scraper (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_requests_roll_up column count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table scraper_requests_roll_up column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stats_roll_up column range_start (type timestamp[22]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stats_roll_up column offer_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stats_roll_up column qualified (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stats_roll_up column ihs_matched (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stats_roll_up column count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stats_roll_up column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column uuid (type uuid[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column permissions_preset (type api_client_permissions_preset_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column token_minimum_issued_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column last_token_created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column daily_rate_limit (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column daily_live_rate_limit (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column markup (type float8[17]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column minutely_rate_limit (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column minutely_live_rate_limit (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column custom_roles (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column accessible_vendor_types (type _vendor_type_enum[2147483647]) -> JsonSchemaType({type=array})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column deleted_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column region (type api_client_region_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column product_subscription_webhook_target_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column product_offers_whitelist_enabled (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column account_platform_id (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column skip_ecom_markup (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column vendor_blacklist_enabled (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column live_api_offer_vendor_sources (type _live_api_offer_vendor_source_enum[2147483647]) -> JsonSchemaType({type=array})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column on_demand_offer_vendor_sources (type _on_demand_offer_vendor_source_enum[2147483647]) -> JsonSchemaType({type=array})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column skip_all_markups (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column api_client_group_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client column disabled_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column ihs_category_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column ihs_category_type_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column created_by_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column updated_by_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column demand (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column custom_markup (type float8[17]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column quantity_reduction (type float8[17]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column additional_lead_time (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column additional_lead_time_percentage (type float8[17]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table ihs_category_setting column vendor_whitelist_enabled (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_stats_snapshot column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_stats_snapshot column total_product_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_stats_snapshot column products_with_valid_offers_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_stats_snapshot column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column source (type part_information_source_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column status (type part_status_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column description (type text[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column ihs_category_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column eu_rohs_compliant (type bool[1]) -> JsonSchemaType({type=boolean})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column remote_datasheet_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column image_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column source_type (type part_information_source_type_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column datasheet_file_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table part_information column specs (type jsonb[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table phone_number column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table phone_number column phone_number (type varchar[35]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column queued_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column price_trends (type jsonb[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column active_offer_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column active_sourced_offer_count (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column last_offer_created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column availability_score (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column supply_chain_score (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column periodic_max_availability_score (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_offer_analytics column product_offer_count_attributes (type jsonb[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table import_session_product_scrape_schedule column id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column offer_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column previous_transaction_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column quantity (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column balance (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column purchase_request_item_platform_id (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column sales_order_item_platform_id (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table offer_stock_transaction column reverted_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_blacklisted_vendors column api_client_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_blacklisted_vendors column vendor_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table image column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table image column uuid (type uuid[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table image column size (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table image column mime_type (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table image column width (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table image column height (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table image column created_at (type timestamp[22]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table image column checksum (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_subscription column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_subscription column api_client_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_subscription column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead_import_row column lead_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table lead_import_row column import_row_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table category_statistics column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table category_statistics column ihs_category_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table category_statistics column top_manufacturers (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column name (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column permissions_preset (type api_client_permissions_preset_enum[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column minutely_rate_limit (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column minutely_live_rate_limit (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column daily_rate_limit (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column daily_live_rate_limit (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column custom_roles (type json[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column accessible_vendor_types (type _vendor_type_enum[2147483647]) -> JsonSchemaType({type=array})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column live_api_offer_vendor_sources (type _live_api_offer_vendor_source_enum[2147483647]) -> JsonSchemaType({type=array})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table api_client_group column on_demand_offer_vendor_sources (type _on_demand_offer_vendor_source_enum[2147483647]) -> JsonSchemaType({type=array})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting_product column manufacturer_setting_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table manufacturer_setting_product column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scraper column id (type serial[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scraper column product_sku (type varchar[255]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scraper column scraper_id (type int4[10]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scraper column scraped_urls (type jsonb[2147483647]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scraper column updated_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_scraper column created_at (type timestamp[29]) -> JsonSchemaType({type=string})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price_to_offer column product_low_high_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$discoverInternal$5):143 - Table product_daily_high_low_price_to_offer column offer_id (type int8[19]) -> JsonSchemaType({type=number})
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.vendor
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.scraper_request
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.migration_versions
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.offer_unique_vendors_roll_up
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_default
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.manufacturer_api_datasheet_request
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.vendor_group
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.datasheet_file
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.part_match_benchmark
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_session
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_match
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.awsdms_ddl_audit
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.offer_scraped
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_session_lead
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.api_client_product_offers_whitelist
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.active_offer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_mapping_replace
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.export_job
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_market_availability_score_history
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.manufacturer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.part_match_benchmark_result
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_row_issue
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.category_map
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.offer_sourced
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.offer_live
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.manufacturer_data_ingestor
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_row
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_daily_high_low_price
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.search_request_log
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.part_information_import_row
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.manufacturer_setting
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.ihs_parameter_definition
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_mapping
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.audit_log
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.address
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.scraper
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.lead
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.ihs_category_setting_whitelisted_vendors
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_session_match
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.ihs_category_type
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.remote_datasheet
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_session_custom_part
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.offer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_session_offer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_session_offer_expiry_update
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.vendor_rating
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.webhook_target
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.custom_manufacturer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.fos_user
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.vendor_contact
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.ihs_category
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_scrape_schedule
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.vendor_group_vendor
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_scrape_schedule_import_row
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.webhook_request
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.custom_part
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_session_part_information
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.ihs_parameter_set
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.scraper_requests_roll_up
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.offer_stats_roll_up
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.api_client
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.ihs_category_setting
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_stats_snapshot
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.part_information
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.phone_number
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_offer_analytics
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.import_session_product_scrape_schedule
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.offer_stock_transaction
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.api_client_blacklisted_vendors
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.image
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_subscription
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.lead_import_row
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.category_statistics
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.api_client_group
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.manufacturer_setting_product
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_scraper
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(discoverInternal):148 - Found table: public.product_daily_high_low_price_to_offer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(isCdc):258 - using CDC: false
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(queryTableIncremental):268 - Queueing query for table: offer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$queryTableIncremental$16):273 - Preparing query for table: offer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.j.AbstractJdbcSource(lambda$queryTableIncremental$16):282 - Executing query for table: offer
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(initialize):32 - Set initial fetch size: 10 rows
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.d.j.s.AdaptiveStreamingQueryConfig(accept):42 - Updated fetch size: 55211 rows
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.r.StateDecoratingIterator(computeNext):60 - State Report: stream name: AirbyteStreamNameNamespacePair{name='offer', namespace='public'}, original cursor field: updated_at, original cursor 2022-06-22T12:45:16.595115Z, cursor field: updated_at, new cursor: 2022-06-22T12:52:46.993852Z
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):130 - Closing database connection pool.
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO c.z.h.HikariDataSource(close):350 - HikariPool-2 - Shutdown initiated...
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO c.z.h.HikariDataSource(close):352 - HikariPool-2 - Shutdown completed.
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.r.AbstractDbSource(lambda$read$2):132 - Closed database connection pool.
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-06-22 12:53:08 source > 2022-06-22 12:53:08 INFO i.a.i.s.p.PostgresSource(main):411 - completed source: class io.airbyte.integrations.source.postgres.PostgresSource
2022-06-22 12:53:09 destination > 2022-06-22 12:53:09 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-06-22 12:53:09 destination > 2022-06-22 12:53:09 INFO i.a.i.d.b.BufferedStreamConsumer(close):217 - executing on success close procedure.
2022-06-22 12:53:09 destination > 2022-06-22 12:53:09 INFO i.a.i.d.b.BufferedStreamConsumer(flushQueueToDestination):181 - Flushing buffer: 92520 bytes
2022-06-22 12:53:09 destination > 2022-06-22 12:53:09 INFO i.a.i.d.b.BufferedStreamConsumer(lambda$flushQueueToDestination$1):185 - Flushing offer: 18 records
2022-06-22 12:53:09 destination > 2022-06-22 12:53:09 INFO i.a.i.d.j.c.s.S3StreamCopier(prepareStagingFile):95 - S3 upload part size: 10 MB
2022-06-22 12:53:09 destination > 2022-06-22 12:53:09 INFO i.a.i.d.s.c.S3CsvWriter(<init>):58 - Full S3 path for stream 'offer': s3://sourcengine-analytics-usw2-staging/snowflake/offer/2022_06_22_1655902384633_a2804237-307a-4e31-84fe-21342b206019.csv
2022-06-22 12:53:09 destination > 2022-06-22 12:53:09 INFO i.a.i.d.s.u.S3StreamTransferManagerHelper(getDefault):55 - PartSize arg is set to 10 MB
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - Initiated multipart upload to sourcengine-analytics-usw2-staging/snowflake/offer/2022_06_22_1655902384633_a2804237-307a-4e31-84fe-21342b206019.csv with full ID 8LdxJ6L07pOBzGF0MSKn9Jpt8erTLAAe4zgZcOMBF5uqovS7u2gl5plchiG8Dlg0guyKYSfzOrLEGH_x4F6XisdJrWF.fsayoy0RfPPmd8SzzLkl5xM4Lz6JLNEjZEEJ
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO i.a.i.d.s.w.BaseS3Writer(close):113 - Uploading remaining data for stream 'offer'.
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO a.m.s.MultiPartOutputStream(close):158 - Called close() on [MultipartOutputStream for parts 1 - 10000]
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 WARN a.m.s.MultiPartOutputStream(close):160 - [MultipartOutputStream for parts 1 - 10000] is already closed
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO a.m.s.StreamTransferManager(complete):367 - [Manager uploading to sourcengine-analytics-usw2-staging/snowflake/offer/2022_06_22_1655902384633_a2804237-307a-4e31-84fe-21342b206019.csv with id 8LdxJ6L07...JLNEjZEEJ]: Uploading leftover stream [Part number 1 containing 0.02 MB]
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO a.m.s.StreamTransferManager(uploadStreamPart):558 - [Manager uploading to sourcengine-analytics-usw2-staging/snowflake/offer/2022_06_22_1655902384633_a2804237-307a-4e31-84fe-21342b206019.csv with id 8LdxJ6L07...JLNEjZEEJ]: Finished uploading [Part number 1 containing 0.02 MB]
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO a.m.s.StreamTransferManager(complete):395 - [Manager uploading to sourcengine-analytics-usw2-staging/snowflake/offer/2022_06_22_1655902384633_a2804237-307a-4e31-84fe-21342b206019.csv with id 8LdxJ6L07...JLNEjZEEJ]: Completed
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO i.a.i.d.s.w.BaseS3Writer(close):115 - Upload completed for stream 'offer'.
2022-06-22 12:53:10 destination > 2022-06-22 12:53:10 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):152 - Creating schema in destination if it doesn't exist: TEST
2022-06-22 12:53:11 destination > 2022-06-22 12:53:11 INFO i.a.d.j.DefaultJdbcDatabase(lambda$query$1):106 - closing connection
2022-06-22 12:53:11 destination > 2022-06-22 12:53:11 INFO i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):158 - Preparing tmp table in destination for stream: offer, schema: TEST, tmp table name: _airbyte_tmp_ulg_offer.
2022-06-22 12:53:12 destination > 2022-06-22 12:53:12 INFO i.a.i.d.s.SnowflakeS3StreamCopier(copyStagingFileToTemporaryTable):83 - Starting parallel copy to tmp table: _airbyte_tmp_ulg_offer in destination for stream: offer, schema: TEST. Chunks count 1
2022-06-22 12:53:13 destination > 2022-06-22 12:53:13 INFO i.a.i.d.s.SnowflakeS3StreamCopier(copyStagingFileToTemporaryTable):87 - Copy to tmp table _airbyte_tmp_ulg_offer in destination for stream offer complete.
2022-06-22 12:53:13 destination > 2022-06-22 12:53:13 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):174 - Preparing table _airbyte_raw_offer in destination.
2022-06-22 12:53:13 destination > 2022-06-22 12:53:13 INFO i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):176 - Table _airbyte_tmp_ulg_offer in destination prepared.
2022-06-22 12:53:13 destination > 2022-06-22 12:53:13 INFO i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):183 - Preparing to merge tmp table _airbyte_tmp_ulg_offer to dest table: _airbyte_raw_offer, schema: TEST, in destination.
2022-06-22 12:53:15 destination > 2022-06-22 12:53:15 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):198 - S3 staging file offer/2022_06_22_1655902384633_a2804237-307a-4e31-84fe-21342b206019.csv cleaned.
2022-06-22 12:53:15 destination > 2022-06-22 12:53:15 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):202 - Begin cleaning _airbyte_tmp_ulg_offer tmp table in destination.
2022-06-22 12:53:15 destination > 2022-06-22 12:53:15 INFO i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):204 - _airbyte_tmp_ulg_offer tmp table in destination cleaned.
2022-06-22 12:53:15 destination > 2022-06-22 12:53:15 INFO i.a.i.b.IntegrationRunner(runInternal):169 - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2022-06-22 12:53:23 normalization > Running: transform-config --config destination_config.json --integration-type snowflake --out /config
2022-06-22 12:53:23 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.SNOWFLAKE: 'snowflake'>, out='/config')
2022-06-22 12:53:23 normalization > transform_snowflake
2022-06-22 12:53:23 normalization > Running: transform-catalog --integration-type snowflake --profile-config-dir /config --catalog destination_catalog.json --out /config/models/generated/ --json-column _airbyte_data
2022-06-22 12:53:24 normalization > Processing destination_catalog.json...
2022-06-22 12:53:24 normalization >   Generating airbyte_ctes/TEST/OFFER_AB1.sql from offer
2022-06-22 12:53:24 normalization >   Generating airbyte_ctes/TEST/OFFER_AB2.sql from offer
2022-06-22 12:53:24 normalization >   Generating airbyte_views/TEST/OFFER_STG.sql from offer
2022-06-22 12:53:24 normalization >   Generating airbyte_incremental/scd/TEST/OFFER_SCD.sql from offer
2022-06-22 12:53:24 normalization >   Generating airbyte_incremental/TEST/OFFER.sql from offer
2022-06-22 12:53:24 normalization > detected no config file for ssh, assuming ssh is off.
2022-06-22 12:53:25 normalization >            [--event-buffer-size EVENT_BUFFER_SIZE]
2022-06-22 12:53:25 normalization >   --event-buffer-size EVENT_BUFFER_SIZE
2022-06-22 12:53:25 normalization > 
2022-06-22 12:53:25 normalization > DBT >=1.0.0 detected; using 10K event buffer size
2022-06-22 12:53:25 normalization > 
2022-06-22 12:53:27 normalization > 12:53:27  Running with dbt=1.0.0
2022-06-22 12:53:27 normalization > 12:53:27  Partial parse save file not found. Starting full parse.
2022-06-22 12:53:29 normalization > 12:53:29  [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-06-22 12:53:29 normalization > There are 1 unused configuration paths:
2022-06-22 12:53:29 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-06-22 12:53:29 normalization > 
2022-06-22 12:53:29 normalization > 12:53:29  Found 5 models, 0 tests, 0 snapshots, 0 analyses, 535 macros, 0 operations, 0 seed files, 1 source, 0 exposures, 0 metrics
2022-06-22 12:53:29 normalization > 12:53:29  
2022-06-22 12:53:30 normalization > 12:53:30  Concurrency: 5 threads (target='prod')
2022-06-22 12:53:30 normalization > 12:53:30  
2022-06-22 12:53:30 normalization > 12:53:30  1 of 3 START view model _AIRBYTE_TEST.OFFER_STG......................................................................... [RUN]
2022-06-22 12:53:31 normalization > 12:53:31  1 of 3 OK created view model _AIRBYTE_TEST.OFFER_STG.................................................................... [SUCCESS 1 in 0.89s]
2022-06-22 12:53:31 normalization > 12:53:31  2 of 3 START incremental model TEST.OFFER_SCD........................................................................... [RUN]
2022-06-22 12:53:48 normalization > 12:53:48  2 of 3 OK created incremental model TEST.OFFER_SCD...................................................................... [SUCCESS 1 in 16.51s]
2022-06-22 12:53:48 normalization > 12:53:48  3 of 3 START incremental model TEST.OFFER............................................................................... [RUN]
2022-06-22 12:54:42 INFO i.a.w.p.KubePodProcess(close):714 - (pod: datalake / normalization-snowflake-normalize-28670-0-wyuez) - Closed all resources for pod
2022-06-22 12:54:42 INFO i.a.w.g.DefaultNormalizationWorker(run):73 - Normalization executed in 1 minute 24 seconds.
2022-06-22 12:54:42 INFO i.a.w.g.DefaultNormalizationWorker(run):79 - Normalization summary: io.airbyte.config.NormalizationSummary@1d9a1c17[startTime=1655902397604,endTime=1655902482070]
2022-06-22 12:54:42 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-06-22 12:54:42 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):236 - Stopping temporal heartbeating...
2022-06-22 12:54:41 normalization > 12:54:41  3 of 3 OK created incremental model TEST.OFFER.......................................................................... [SUCCESS 1 in 53.18s]
2022-06-22 12:54:41 normalization > 12:54:41  
2022-06-22 12:54:41 normalization > 12:54:41  Finished running 1 view model, 2 incremental models in 72.43s.
2022-06-22 12:54:41 normalization > 12:54:41  
2022-06-22 12:54:41 normalization > 12:54:41  Completed successfully
2022-06-22 12:54:41 normalization > 12:54:41  
2022-06-22 12:54:41 normalization > 12:54:41  Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3