Snowflake source #74064
Description
Connector Name
source-snowflake
Connector Version
1.0.8
What step the error happened?
During the sync
Relevant information
Sync job completes but with 0 records processed. Logs show error below.
2026-02-26 11:15:20 error WARNING: Unknown module: org.apache.arrow.memory.core specified to --add-opens
Appears to be a missing dependency at first glance.
Relevant log output
>> ATTEMPT 1/1
2026-02-26 11:14:35 info APPLY Stage: BUILD — (workloadId=80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check)
2026-02-26 11:14:35 info APPLY Stage: CLAIM — (workloadId=80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check)
2026-02-26 11:14:35 info Claimed: true for workload 80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check via API in dataplane AUTO (9292ab8f-9724-424d-a4fc-8909b30be3c3)
2026-02-26 11:14:35 info APPLY Stage: LOAD_SHED — (workloadId=80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check)
2026-02-26 11:14:35 info APPLY Stage: CHECK_STATUS — (workloadId=80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check)
2026-02-26 11:14:35 info No pod found running for workload 80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check
2026-02-26 11:14:35 info APPLY Stage: MUTEX — (workloadId=80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check)
2026-02-26 11:14:35 info No mutex key specified for workload: 80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check. Continuing...
2026-02-26 11:14:35 info APPLY Stage: ARCHITECTURE — (workloadId=80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check)
2026-02-26 11:14:35 info APPLY Stage: LAUNCH — (workloadId=80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check)
2026-02-26 11:14:35 info [initContainer] image: airbyte/workload-init-container:2.0.1 resources: ResourceRequirements(claims=[], limits={}, requests={}, additionalProperties={})
2026-02-26 11:14:40 info Attempting to update workload: 80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check to LAUNCHED.
2026-02-26 11:14:40 info Pipeline completed for workload: 80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check.
2026-02-26 11:14:41 info
2026-02-26 11:14:41 info Transitioning workload to running state
2026-02-26 11:14:41 info ----- START CHECK -----
2026-02-26 11:14:41 info
2026-02-26 11:14:41 info Workload successfully transitioned to running state
2026-02-26 11:14:47 info Connector exited, processing output
2026-02-26 11:14:47 info Output file jobOutput.json found
2026-02-26 11:14:47 info Connector exited with exit code 0
2026-02-26 11:14:47 info Reading messages from protocol version 0.2.0
2026-02-26 11:14:47 info INFO main i.m.c.e.DefaultEnvironment(<init>):168 Established active environments: [k8s, cloud, cli, source, connector]
2026-02-26 11:14:47 info INFO main i.a.c.AirbyteConnectorRunnable(run):35 Executing class io.airbyte.cdk.check.CheckOperation operation.
2026-02-26 11:14:47 info INFO main i.a.c.c.CheckOperation(execute):33 Parsing connector configuration JSON object.
2026-02-26 11:14:47 info INFO main i.a.c.c.CheckOperation(execute):35 Building internal connector configuration object.
2026-02-26 11:14:47 info INFO main i.a.c.c.CheckOperation(execute):37 Connecting for config check.
2026-02-26 11:14:47 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$Companion$Factory(session):321 Snowflake source metadata session.
2026-02-26 11:14:47 info INFO main i.a.c.j.JdbcConnectionFactory(get):44 Creating new connection for 'jdbc:snowflake://ajbell-dev_account.snowflakecomputing.com'.
2026-02-26 11:14:47 info INFO main i.a.c.c.CheckOperation(connectionCheck):63 Querying all stream names and namespaces.
2026-02-26 11:14:47 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedTableNames$2(invoke):231 Querying table names for Snowflake source.
2026-02-26 11:14:47 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedTableNames$2(invoke):252 Discovered 24 tables and views.
2026-02-26 11:14:47 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedColumnMetadata$2(invoke):62 Querying column names for catalog discovery.
2026-02-26 11:14:47 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedColumnMetadata$2(invoke):79 Discovered 505 column(s).
2026-02-26 11:14:47 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier(queryColumnMetadata):169 Querying SELECT "INVESTORID", "FIRSTNAME", "SURNAME", "TITLE", "ADDRESS1", "ADDRESS2", "TOWNCITY", "COUNTRY", "POST_CODE", "NINO", "EMAIL_ADDRESS", "TELEPHONENO", "MOBILE_NUMBER", "CREATE_TIME", "UPDATE_TIME", "NATIONALITY1", "NATIONALITY2", "COUNTRY_OF_BIRTH", "ISEXITED", "IFAFIRM", "ISAUTOWITHDRAWALOPTEDOUT", "TAXRESIDENCY1", "TAXRESIDENCY2", "INVESTOR_UUID", "DATEOFBIRTH", "PVC", "CITIZENSHIP1", "CITIZENSHIP2", "NATIONALITY3", "EXITEDON" FROM "AIRBYTE_TOUCH_PII"."FS_TOUCH_CLIENT" LIMIT 0 for catalog discovery.
2026-02-26 11:14:47 info INFO main i.a.c.c.CheckOperation(connectionCheck):77 Query successful on stream 'FS_TOUCH_CLIENT' in 'AIRBYTE_TOUCH_PII'.
2026-02-26 11:14:47 info INFO main i.a.c.d.JdbcMetadataQuerier(extraChecks):327 Connected to database: Snowflake version 10.6.2
2026-02-26 11:14:47 info INFO main i.a.c.c.JdbcCheckQueries(executeAll):40 Executing 1 check queries.
2026-02-26 11:14:47 info INFO main i.a.c.c.JdbcCheckQueries(executeAll):43 Executing check query 1 / 1: 'SELECT 1 WHERE 1 = 0;'.
2026-02-26 11:14:47 info INFO main i.a.c.c.JdbcCheckQueries(executeAll):49 Check query 1 / 1 succeeded.
2026-02-26 11:14:47 info INFO main i.a.c.d.JdbcMetadataQuerier(close):337 Closing JDBC connection.
2026-02-26 11:14:47 info INFO main i.a.c.c.CheckOperation(execute):51 Config check completed successfully.
2026-02-26 11:14:47 info INFO main i.a.c.AirbyteConnectorRunnable(run):47 Flushing output consumer prior to shutdown.
2026-02-26 11:14:47 info INFO main i.a.c.AirbyteConnectorRunnable(run):49 Completed integration: airbyte/source-snowflake.
2026-02-26 11:14:47 info Checking for optional control message...
2026-02-26 11:14:47 info Writing output of 80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check to the doc store
2026-02-26 11:14:47 info Marking workload 80dc9d82-3cd2-49da-a79d-4510426e76c9_8188_0_check as successful
2026-02-26 11:14:47 info Deliberately exiting process with code 0.
2026-02-26 11:14:47 info
2026-02-26 11:14:47 info ----- END CHECK -----
2026-02-26 11:14:47 info
2026-02-26 11:14:49 info APPLY Stage: BUILD — (workloadId=68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check)
2026-02-26 11:14:49 info APPLY Stage: CLAIM — (workloadId=68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check)
2026-02-26 11:14:49 info Claimed: true for workload 68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check via API in dataplane AUTO (9292ab8f-9724-424d-a4fc-8909b30be3c3)
2026-02-26 11:14:49 info APPLY Stage: LOAD_SHED — (workloadId=68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check)
2026-02-26 11:14:49 info APPLY Stage: CHECK_STATUS — (workloadId=68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check)
2026-02-26 11:14:49 info No pod found running for workload 68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check
2026-02-26 11:14:49 info APPLY Stage: MUTEX — (workloadId=68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check)
2026-02-26 11:14:49 info No mutex key specified for workload: 68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check. Continuing...
2026-02-26 11:14:49 info APPLY Stage: ARCHITECTURE — (workloadId=68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check)
2026-02-26 11:14:49 info APPLY Stage: LAUNCH — (workloadId=68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check)
2026-02-26 11:14:49 info [initContainer] image: airbyte/workload-init-container:2.0.1 resources: ResourceRequirements(claims=[], limits={}, requests={}, additionalProperties={})
2026-02-26 11:14:53 info Attempting to update workload: 68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check to LAUNCHED.
2026-02-26 11:14:53 info Pipeline completed for workload: 68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check.
2026-02-26 11:14:54 info
2026-02-26 11:14:54 info Connector exited, processing output
2026-02-26 11:14:54 info Transitioning workload to running state
2026-02-26 11:14:54 info Output file jobOutput.json found
2026-02-26 11:14:54 info ----- START CHECK -----
2026-02-26 11:14:54 info
2026-02-26 11:14:54 info Connector exited with exit code 0
2026-02-26 11:14:54 info Reading messages from protocol version 0.2.0
2026-02-26 11:14:54 info INFO main i.m.c.e.DefaultEnvironment(<init>):168 Established active environments: [k8s, cloud, cli, destination, connector]
2026-02-26 11:14:54 info INFO main i.a.c.AirbyteConnectorRunnable(run):35 Executing class io.airbyte.cdk.load.check.CheckOperation operation.
2026-02-26 11:14:54 info INFO main c.z.h.HikariDataSource(getConnection):109 HikariPool-1 - Starting...
2026-02-26 11:14:54 info INFO main c.z.h.HikariDataSource(getConnection):122 HikariPool-1 - Start completed.
2026-02-26 11:14:54 info INFO main i.a.c.AirbyteConnectorRunnable(run):47 Flushing output consumer prior to shutdown.
2026-02-26 11:14:54 info INFO main i.a.c.AirbyteConnectorRunnable(run):49 Completed integration: airbyte/destination-mssql.
2026-02-26 11:14:54 info Checking for optional control message...
2026-02-26 11:14:54 info Writing output of 68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check to the doc store
2026-02-26 11:14:54 info Workload successfully transitioned to running state
2026-02-26 11:14:54 info Marking workload 68752b51-980c-4e70-8059-40fcf5e32216_8188_0_check as successful
2026-02-26 11:14:54 info Deliberately exiting process with code 0.
2026-02-26 11:14:54 info
2026-02-26 11:14:54 info ----- END CHECK -----
2026-02-26 11:14:54 info
2026-02-26 11:14:59 info APPLY Stage: BUILD — (workloadId=8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync)
2026-02-26 11:14:59 info APPLY Stage: CLAIM — (workloadId=8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync)
2026-02-26 11:14:59 info Claimed: true for workload 8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync via API in dataplane AUTO (9292ab8f-9724-424d-a4fc-8909b30be3c3)
2026-02-26 11:14:59 info APPLY Stage: LOAD_SHED — (workloadId=8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync)
2026-02-26 11:14:59 info APPLY Stage: CHECK_STATUS — (workloadId=8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync)
2026-02-26 11:14:59 info No pod found running for workload 8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync
2026-02-26 11:14:59 info APPLY Stage: MUTEX — (workloadId=8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync)
2026-02-26 11:14:59 info Mutex key: 8726d5cc-e39a-415b-913d-d2bb4ea98edc specified for workload: 8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync. Attempting to delete existing pods...
2026-02-26 11:14:59 info Existing pods for mutex key: 8726d5cc-e39a-415b-913d-d2bb4ea98edc deleted.
2026-02-26 11:14:59 info APPLY Stage: ARCHITECTURE — (workloadId=8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync)
2026-02-26 11:14:59 info APPLY Stage: LAUNCH — (workloadId=8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync)
2026-02-26 11:14:59 info [initContainer] image: airbyte/workload-init-container:2.0.1 resources: ResourceRequirements(claims=[], limits={memory=2Gi, cpu=1}, requests={memory=2Gi, cpu=1}, additionalProperties={})
2026-02-26 11:14:59 info Launching replication pod: replication-job-8188-attempt-0 (selectors = {}) with containers:
2026-02-26 11:14:59 info [source] image: airbyte/source-snowflake:1.0.8 resources: ResourceRequirements(claims=[], limits={memory=2Gi, cpu=1}, requests={memory=1Gi, cpu=0.5}, additionalProperties={})
2026-02-26 11:14:59 info [destination] image: airbyte/destination-mssql:2.2.15 resources: ResourceRequirements(claims=[], limits={memory=2Gi, cpu=1}, requests={memory=1Gi, cpu=0.5}, additionalProperties={})
2026-02-26 11:14:59 info [orchestrator] image: airbyte/container-orchestrator:2.0.1 resources: ResourceRequirements(claims=[], limits={memory=2Gi, cpu=1}, requests={memory=2Gi, cpu=1}, additionalProperties={})
2026-02-26 11:15:10 info Attempting to update workload: 8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync to LAUNCHED.
2026-02-26 11:15:10 info Pipeline completed for workload: 8726d5cc-e39a-415b-913d-d2bb4ea98edc_8188_0_sync.
2026-02-26 11:15:20 info Running replication worker...
2026-02-26 11:15:20 info Starting replication worker. job id: 8188 attempt: 0
2026-02-26 11:15:20 info
2026-02-26 11:15:20 info ----- START REPLICATION -----
2026-02-26 11:15:20 info
2026-02-26 11:15:20 info Running destination...
2026-02-26 11:15:20 info Writing messages to protocol version 0.2.0
2026-02-26 11:15:20 error WARNING: Unknown module: org.apache.arrow.memory.core specified to --add-opens
2026-02-26 11:15:20 info Reading messages from protocol version 0.2.0
2026-02-26 11:15:20 info Reading messages from protocol version 0.2.0
2026-02-26 11:15:20 info MessageProcessor started.
2026-02-26 11:15:20 info SourceReader started.
2026-02-26 11:15:20 info Starting workload heartbeat (interval=10s; timeout=600s)
2026-02-26 11:15:20 info Transitioning workload to running state
2026-02-26 11:15:20 info DestinationWriter started.
2026-02-26 11:15:20 info DestinationReader started.
2026-02-26 11:15:20 info INFO main i.m.c.e.DefaultEnvironment(<init>):168 Established active environments: [k8s, cloud, cli, destination, connector]
2026-02-26 11:15:20 info INFO main i.m.c.e.DefaultEnvironment(<init>):168 Established active environments: [k8s, cloud, cli, source, connector]
2026-02-26 11:15:20 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper(expectAnyFormat):725 Not able to generate jsonSchema-info for type: [simple type, class com.fasterxml.jackson.databind.JsonNode] - probably using custom serializer which does not override acceptJsonFormatVisitor
2026-02-26 11:15:20 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper(expectAnyFormat):725 Not able to generate jsonSchema-info for type: [simple type, class com.fasterxml.jackson.databind.JsonNode] - probably using custom serializer which does not override acceptJsonFormatVisitor
2026-02-26 11:15:20 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper(expectAnyFormat):725 Not able to generate jsonSchema-info for type: [simple type, class com.fasterxml.jackson.databind.JsonNode] - probably using custom serializer which does not override acceptJsonFormatVisitor
2026-02-26 11:15:20 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper(expectAnyFormat):725 Not able to generate jsonSchema-info for type: [simple type, class com.fasterxml.jackson.databind.JsonNode] - probably using custom serializer which does not override acceptJsonFormatVisitor
2026-02-26 11:15:20 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper(expectAnyFormat):725 Not able to generate jsonSchema-info for type: [simple type, class com.fasterxml.jackson.databind.JsonNode] - probably using custom serializer which does not override acceptJsonFormatVisitor
2026-02-26 11:15:20 info INFO main i.a.c.AirbyteConnectorRunnable(run):35 Executing class io.airbyte.cdk.read.ReadOperation operation.
2026-02-26 11:15:20 info INFO main i.a.c.l.c.DataChannelBeanFactory(dataChannelMedium):60 Using data channel medium STDIO
2026-02-26 11:15:20 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$Companion$Factory(session):321 Snowflake source metadata session.
2026-02-26 11:15:20 info INFO main i.a.c.l.c.DataChannelBeanFactory(namespaceMapper):308 Going to use the given source value: SOURCE for namespace
2026-02-26 11:15:20 info INFO main i.a.c.j.JdbcConnectionFactory(get):44 Creating new connection for 'jdbc:snowflake://ajbell-dev_account.snowflakecomputing.com'.
2026-02-26 11:15:20 info INFO main i.a.c.l.c.DestinationCatalog(<init>):49 Destination catalog initialized: [DestinationStream(unmappedNamespace=null, unmappedName=ASSET_APPROVAL_INVESTOR, importType=Append, schema=ObjectType(properties={PLATFORM=FieldType(type=StringType, nullable=true), TAX_FORM=FieldType(type=StringType, nullable=true), SCC_NUMBER=FieldType(type=StringType, nullable=true), INVESTOR_ID=FieldType(type=IntegerType, nullable=true), ACCOUNT_TYPE=FieldType(type=StringType, nullable=true), SCA_REFERENCE=FieldType(type=StringType, nullable=true), TAX_FORM_CODE=FieldType(type=StringType, nullable=true), LAST_REFRESHED=FieldType(type=TimestampTypeWithoutTimezone, nullable=true), MIFID_CATEGORY=FieldType(type=StringType, nullable=true), INVESTOR_REFERENCE=FieldType(type=StringType, nullable=true), INVESTOR_ACCOUNT_ID=FieldType(type=IntegerType, nullable=true), INVESTOR_ACCOUNT_REFERENCE=FieldType(type=StringType, nullable=true)}, additionalProperties=true, required=[]), generationId=4, minimumGenerationId=4, syncId=8188, isFileBased=false, includeFiles=false, destinationObjectName=null, matchingKey=null, namespaceMapper=io.airbyte.cdk.load.command.NamespaceMapper@5ee9d2b8), DestinationStream(unmappedNamespace=null, unmappedName=ASSET_APPROVAL, importType=Append, schema=ObjectType(properties={ISIN=FieldType(type=StringType, nullable=true), SEDOL=FieldType(type=StringType, nullable=true), BLKNET=FieldType(type=StringType, nullable=true), MPS_MODEL=FieldType(type=StringType, nullable=true), ASSET_NAME=FieldType(type=StringType, nullable=true), ASSET_TYPE=FieldType(type=StringType, nullable=true), IS_DELISTED=FieldType(type=BooleanType, nullable=true), PART_OF_MPS=FieldType(type=BooleanType, nullable=true), COUNTERPARTY=FieldType(type=StringType, nullable=true), ISA_ELIGIBLE=FieldType(type=StringType, nullable=true), QUANTITY_HELD=FieldType(type=NumberType, nullable=true), SIPP_ELIGIBLE=FieldType(type=StringType, nullable=true), CURRENTLY_HELD=FieldType(type=BooleanType, nullable=true), DECIMAL_PLACES=FieldType(type=IntegerType, nullable=true), LAST_REFRESHED=FieldType(type=TimestampTypeWithoutTimezone, nullable=true), AJB_MANAGED_MPS=FieldType(type=BooleanType, nullable=true), DFM_MANAGED_MPS=FieldType(type=BooleanType, nullable=true), ACCOUNTS_HOLDING=FieldType(type=IntegerType, nullable=true), ASSET_RESTRICTIONS=FieldType(type=StringType, nullable=true), COMPLEX_INSTRUMENT=FieldType(type=BooleanType, nullable=true), SEDOL_POPULARITY_RANK=FieldType(type=IntegerType, nullable=true), COUNTRY_OF_REGISTRATION=FieldType(type=StringType, nullable=true), REGULAR_INVESTMENT_LIMITS=FieldType(type=StringType, nullable=true), REGULAR_INVESTMENT_ELIGIBLE=FieldType(type=BooleanType, nullable=true)}, additionalProperties=true, required=[]), generationId=4, minimumGenerationId=4, syncId=8188, isFileBased=false, includeFiles=false, destinationObjectName=null, matchingKey=null, namespaceMapper=io.airbyte.cdk.load.command.NamespaceMapper@5ee9d2b8)]
2026-02-26 11:15:20 error Feb 26, 2026 11:15:20 AM net.snowflake.client.core.SFSession open
2026-02-26 11:15:20 error INFO: Opening session with server: https://ajbell-dev-account.snowflakecomputing.com:443/, account: ajbell-dev_account, user: AIRBYTE, password is not provided, role: ROLE_DEV_AIRBYTE, database: DEV_RAW, schema: null, warehouse: AJBELL_DEV_WH_AIRBYTE, validate default parameters: null, authenticator: null, ocsp mode: FAIL_OPEN, passcode in password: null, passcode is not provided, private key is not provided, disable socks proxy: null, application: null, app id: JDBC, app version: 3.23.1, login timeout: null, retry timeout: null, network timeout: null, query timeout: null, connection timeout: null, socket timeout: null, tracing: null, private key file: rsa_key.p8, private key pwd is not provided, enable_diagnostics: not provided, diagnostics_allowlist_path: null, session parameters: client store temporary credential: null, gzip disabled: null, browser response timeout: null
2026-02-26 11:15:20 info INFO main i.a.c.l.c.DataChannelBeanFactory(logPerNRecords):137 Logging every 100000 records
2026-02-26 11:15:20 error Feb 26, 2026 11:15:20 AM net.snowflake.client.core.SFSession open
2026-02-26 11:15:20 error INFO: Connecting to GLOBAL Snowflake domain
2026-02-26 11:15:20 info INFO main i.a.c.l.c.DataChannelBeanFactory(dataChannelSocketPaths):69 Using socket paths []
2026-02-26 11:15:20 error Feb 26, 2026 11:15:20 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2026-02-26 11:15:20 error WARNING: Cache file creation: File /home/airbyte/.cache/snowflake/ocsp_response_cache.json is accessible by others to:
2026-02-26 11:15:20 info INFO main i.a.c.l.s.PipelineEventBookkeepingRouter(<init>):80 Creating bookkeeping router for 1 data channels
2026-02-26 11:15:20 info INFO main i.a.c.l.c.DataChannelBeanFactory(dataChannelFormat):79 Using data channel format JSONL
2026-02-26 11:15:20 info Workload successfully transitioned to running state
2026-02-26 11:15:20 info INFO main i.a.c.AirbyteConnectorRunnable(run):35 Executing class io.airbyte.cdk.load.write.WriteOperation operation.
2026-02-26 11:15:20 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):158 Starting input consumer task
2026-02-26 11:15:20 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):163 Starting startup task
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.internal.InputConsumerTask@31f72a10)
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.implementor.SetupTask@2e505d83)
2026-02-26 11:15:20 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):167 Launching open stream task 0
2026-02-26 11:15:20 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):171 Setting up load pipeline
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.implementor.OpenStreamTask@1498d333)
2026-02-26 11:15:20 info INFO main i.a.c.l.p.DirectLoadPipelineStep(taskForPartition):40 Creating DirectLoad pipeline step task for partition 0
2026-02-26 11:15:20 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):173 Launching update batch task
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(DirectLoadRecordAccumulator, part=0))
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.i.InputConsumerTask(execute):78 Starting consuming messages from the input flow
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.i.ReservingDeserializingInputFlow(collect):32 Reserved 593mb memory for input processing
2026-02-26 11:15:20 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):176 Launching heartbeat task
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.internal.UpdateBatchStateTask@4376e4e7)
2026-02-26 11:15:20 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):185 Starting checkpoint update task
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-6 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.internal.UpdateCheckpointsTask@2a5c4edf)
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-6 i.a.c.l.t.i.UpdateCheckpointsTask(execute):34 Starting to consume checkpoint messages (state) for updating
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.internal.HeartbeatTask@30f23d43)
2026-02-26 11:15:20 error Feb 26, 2026 11:15:20 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2026-02-26 11:15:20 error WARNING: Read cache: File /home/airbyte/.cache/snowflake/ocsp_response_cache.json is accessible by others to:
2026-02-26 11:15:20 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.SetupTask@2e505d83) completed
2026-02-26 11:15:20 error Feb 26, 2026 11:15:20 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2026-02-26 11:15:20 error WARNING: Extract private key from file: File rsa_key.p8 is accessible by others to: read
2026-02-26 11:15:21 error Feb 26, 2026 11:15:21 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2026-02-26 11:15:21 error WARNING: Write to cache: File /home/airbyte/.cache/snowflake/ocsp_response_cache.json is accessible by others to:
2026-02-26 11:15:21 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedTableNames$2(invoke):231 Querying table names for Snowflake source.
2026-02-26 11:15:21 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedTableNames$2(invoke):252 Discovered 24 tables and views.
2026-02-26 11:15:21 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedColumnMetadata$2(invoke):62 Querying column names for catalog discovery.
2026-02-26 11:15:24 error Feb 26, 2026 11:15:24 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2026-02-26 11:15:24 error WARNING: Write to cache: File /home/airbyte/.cache/snowflake/ocsp_response_cache.json is accessible by others to:
2026-02-26 11:15:28 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedColumnMetadata$2(invoke):79 Discovered 505 column(s).
2026-02-26 11:15:28 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier(queryColumnMetadata):169 Querying SELECT "INVESTOR_ID", "INVESTOR_REFERENCE", "SCC_NUMBER", "INVESTOR_ACCOUNT_ID", "INVESTOR_ACCOUNT_REFERENCE", "MIFID_CATEGORY", "ACCOUNT_TYPE", "PLATFORM", "TAX_FORM_CODE", "TAX_FORM", "SCA_REFERENCE", "LAST_REFRESHED" FROM "OPERATIONAL"."ASSET_APPROVAL_INVESTOR" LIMIT 0 for catalog discovery.
2026-02-26 11:15:28 warn WARN main i.a.c.o.LoggingCatalogValidationFailureHandler(accept):77 In stream 'ASSET_APPROVAL_INVESTOR' in namespace 'OPERATIONAL': field 'INVESTOR_ID' is NUMBER but catalog expects INTEGER.
2026-02-26 11:15:28 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier(queryColumnMetadata):169 Querying SELECT "SEDOL", "ASSET_NAME", "ASSET_TYPE", "ISIN", "CURRENTLY_HELD", "COUNTERPARTY", "IS_DELISTED", "DECIMAL_PLACES", "BLKNET", "ASSET_RESTRICTIONS", "COMPLEX_INSTRUMENT", "SIPP_ELIGIBLE", "ISA_ELIGIBLE", "REGULAR_INVESTMENT_ELIGIBLE", "REGULAR_INVESTMENT_LIMITS", "COUNTRY_OF_REGISTRATION", "SEDOL_POPULARITY_RANK", "ACCOUNTS_HOLDING", "QUANTITY_HELD", "PART_OF_MPS", "AJB_MANAGED_MPS", "DFM_MANAGED_MPS", "MPS_MODEL", "LAST_REFRESHED" FROM "OPERATIONAL"."ASSET_APPROVAL" LIMIT 0 for catalog discovery.
2026-02-26 11:15:29 warn WARN main i.a.c.o.LoggingCatalogValidationFailureHandler(accept):77 In stream 'ASSET_APPROVAL' in namespace 'OPERATIONAL': field 'DECIMAL_PLACES' is NUMBER but catalog expects INTEGER.
2026-02-26 11:15:29 info INFO main i.a.c.d.JdbcMetadataQuerier(close):337 Closing JDBC connection.
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-1#read i.a.c.r.RootReader(read):91 Read configured with data channel medium: STDIO. data channel format: JSONL
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-1#read i.a.c.r.RootReader(read):178 Reading feeds of type class io.airbyte.cdk.read.Global.
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-1#read i.a.c.r.RootReader(read):219 Reading feeds of type class io.airbyte.cdk.read.Stream.
2026-02-26 11:15:29 info INFO main i.a.c.AirbyteConnectorRunnable(run):47 Flushing output consumer prior to shutdown.
2026-02-26 11:15:29 info INFO main i.a.c.AirbyteConnectorRunnable(run):49 Completed integration: airbyte/source-snowflake.
2026-02-26 11:15:29 warn No records detected for enriched STATE stats.
2026-02-26 11:15:29 info Total records read: (0 bytes)
2026-02-26 11:15:29 info Schema validation was performed to a max of 10 records with errors per stream.
2026-02-26 11:15:29 info SourceReader finished.
2026-02-26 11:15:29 warn No records detected for enriched STATE stats.
2026-02-26 11:15:29 info Source queue closed — stopping message processor...
2026-02-26 11:15:29 info MessageProcessor finished.
2026-02-26 11:15:29 info DestinationWriter finished.
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-1 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):101 Saw first record for stream Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR); awaiting setup complete
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-1 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):105 Setup complete, starting stream Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR)
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.i.UpdateCheckpointsTask$execute$3(emit):39 Updating stream checkpoint Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR):CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1)):Stats(recordCount=0, rejectedRecordCount=0, additionalStats={})
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-2 i.a.c.l.s.CheckpointManager(addStreamCheckpoint):118 Added checkpoint for stream: Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR) at index: CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1))
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-3 c.z.h.HikariDataSource(getConnection):109 HikariPool-1 - Starting...
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-2 i.a.c.l.s.CheckpointManager(flushStreamCheckpoints):366 Flushed checkpoint for stream: Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR) at index: CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1)) (records=0, bytes=0)
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.i.UpdateCheckpointsTask$execute$3(emit):39 Updating stream checkpoint Descriptor(namespace=null, name=ASSET_APPROVAL):CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1)):Stats(recordCount=0, rejectedRecordCount=0, additionalStats={})
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-2 i.a.c.l.s.CheckpointManager(addStreamCheckpoint):118 Added checkpoint for stream: Descriptor(namespace=null, name=ASSET_APPROVAL) at index: CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1))
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-2 i.a.c.l.s.CheckpointManager(flushStreamCheckpoints):366 Flushed checkpoint for stream: Descriptor(namespace=null, name=ASSET_APPROVAL) at index: CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1)) (records=0, bytes=0)
2026-02-26 11:15:29 info INFO DefaultDispatcher-worker-3 c.z.h.HikariDataSource(getConnection):122 HikariPool-1 - Start completed.
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):108 Initialization for stream Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR) complete
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):126 Read COMPLETE for stream Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):101 Saw first record for stream Descriptor(namespace=null, name=ASSET_APPROVAL); awaiting setup complete
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):105 Setup complete, starting stream Descriptor(namespace=null, name=ASSET_APPROVAL)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.i.LoadPipelineStepTask$execute$$inlined$fold$1(emit):317 LoadPipelineStepTask(DirectLoadRecordAccumulator, part=0) saw end-of-stream for Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR) after 0 inputs, all workers complete
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR): first-step[0]
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):206 Batch processing complete: Starting close stream task for Descriptor(namespace=null, name=ASSET_APPROVAL_INVESTOR)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.implementor.CloseStreamTask@78cb4aca)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):108 Initialization for stream Descriptor(namespace=null, name=ASSET_APPROVAL) complete
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):126 Read COMPLETE for stream Descriptor(namespace=null, name=ASSET_APPROVAL)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.i.ReservingDeserializingInputFlow(collect):55 Finished processing input
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.i.LoadPipelineStepTask$execute$$inlined$fold$1(emit):317 LoadPipelineStepTask(DirectLoadRecordAccumulator, part=0) saw end-of-stream for Descriptor(namespace=null, name=ASSET_APPROVAL) after 0 inputs, all workers complete
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=ASSET_APPROVAL): first-step[0]
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(close):277 Maybe closing bookkeeping router 1
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=ASSET_APPROVAL)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(close):296 Closing internal control channels
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):206 Batch processing complete: Starting close stream task for Descriptor(namespace=null, name=ASSET_APPROVAL)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.implementor.CloseStreamTask@5167bd47)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.m.MultiProducerChannel(close):26 Closing producer fileMessageQueue (active count=0, initialized count: 1)
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.m.MultiProducerChannel(close):30 Closing underlying queue
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.internal.InputConsumerTask@31f72a10) completed
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.i.UpdateCheckpointsTask(execute):68 All checkpoints (state) updated
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.OpenStreamTask@1498d333) completed
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.internal.UpdateCheckpointsTask@2a5c4edf) completed
2026-02-26 11:15:30 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(LoadPipelineStepTask(DirectLoadRecordAccumulator, part=0)) completed
2026-02-26 11:15:50 info INFO DefaultDispatcher-worker-6 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.implementor.TeardownTask@5894090)
2026-02-26 11:15:50 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.CloseStreamTask@78cb4aca) completed
2026-02-26 11:15:50 info INFO DefaultDispatcher-worker-6 i.a.c.l.t.i.TeardownTask(execute):35 Teardown task awaiting stream processing completion
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.i.TeardownTask(execute):41 All streams processed successfully, awaiting all checkpoints flushed
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.DestinationTaskLauncher(handleStreamClosed):224 Teardown task already enqueued, not enqueuing another one
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.CloseStreamTask@5167bd47) completed
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-2 i.a.c.l.s.CheckpointManager(awaitAllCheckpointsFlushed):429 All checkpoints flushed
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.i.TeardownTask(execute):43 Starting teardown task
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.i.TeardownTask(execute):45 Teardown task complete, marking sync succeeded.
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.TeardownTask@5894090) completed
2026-02-26 11:17:55 info INFO main i.a.c.l.t.TaskScopeProvider(close):46 Closing normally, canceling long-running tasks
2026-02-26 11:17:55 info INFO main i.a.c.l.t.TaskScopeProvider(close):49 Verifying task completion
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task io.airbyte.cdk.load.task.internal.HeartbeatTask@30f23d43 was cancelled.
2026-02-26 11:17:55 info INFO main i.a.c.l.w.WriteOperation$execute$1(invokeSuspend):65 Destination completed successfully and all streams were complete.
2026-02-26 11:17:55 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task io.airbyte.cdk.load.task.internal.UpdateBatchStateTask@4376e4e7 was cancelled.
2026-02-26 11:17:55 info INFO main i.a.c.AirbyteConnectorRunnable(run):47 Flushing output consumer prior to shutdown.
2026-02-26 11:17:55 info INFO main i.a.c.AirbyteConnectorRunnable(run):49 Completed integration: airbyte/destination-mssql.
2026-02-26 11:17:55 info DestinationReader finished.
2026-02-26 11:17:55 info Closing StateCheckSumCountEventHandler
2026-02-26 11:17:55 info No checksum errors were reported in the entire sync.
2026-02-26 11:17:55 info Sync summary: {
"status" : "completed",
"recordsSynced" : 0,
"bytesSynced" : 0,
"startTime" : 1772104518867,
"endTime" : 1772104675642,
"totalStats" : {
"bytesCommitted" : 0,
"bytesEmitted" : 0,
"destinationStateMessagesEmitted" : 2,
"destinationWriteEndTime" : 1772104675529,
"destinationWriteStartTime" : 1772104520237,
"meanSecondsBeforeSourceStateMessageEmitted" : 0,
"maxSecondsBeforeSourceStateMessageEmitted" : 1,
"maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
"meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
"recordsEmitted" : 0,
"recordsCommitted" : 0,
"recordsFilteredOut" : 0,
"bytesFilteredOut" : 0,
"replicationEndTime" : 1772104675532,
"replicationStartTime" : 1772104518867,
"sourceReadEndTime" : 1772104529357,
"sourceReadStartTime" : 1772104520237,
"sourceStateMessagesEmitted" : 2
},
"streamStats" : [ {
"streamName" : "ASSET_APPROVAL",
"streamNamespace" : "OPERATIONAL",
"stats" : {
"bytesCommitted" : 0,
"bytesEmitted" : 0,
"estimatedBytes" : 0,
"estimatedRecords" : 0,
"recordsEmitted" : 0,
"recordsCommitted" : 0,
"recordsFilteredOut" : 0,
"bytesFilteredOut" : 0
}
}, {
"streamName" : "ASSET_APPROVAL_INVESTOR",
"streamNamespace" : "OPERATIONAL",
"stats" : {
"bytesCommitted" : 0,
"bytesEmitted" : 0,
"estimatedBytes" : 0,
"estimatedRecords" : 0,
"recordsEmitted" : 0,
"recordsCommitted" : 0,
"recordsFilteredOut" : 0,
"bytesFilteredOut" : 0
}
} ],
"performanceMetrics" : { }
}
2026-02-26 11:17:55 info Failures: [ ]
2026-02-26 11:17:55 info
2026-02-26 11:17:55 info Closing io.micronaut.context.propagation.instrument.execution.ContextPropagatingExecutorService@cae1f58
2026-02-26 11:17:55 info ----- END REPLICATION -----
2026-02-26 11:17:55 info
2026-02-26 11:17:55 info Closing io.micronaut.context.propagation.instrument.execution.ContextPropagatingExecutorService@1c27d4d9
2026-02-26 11:17:55 info Closing io.airbyte.container.orchestrator.worker.io.LocalContainerAirbyteDestination@2d30bd40
2026-02-26 11:17:55 info Closing io.airbyte.container.orchestrator.worker.io.LocalContainerAirbyteSource@6742e276
2026-02-26 11:17:55 info Closing io.airbyte.container.orchestrator.worker.RecordSchemaValidator@79b1b471
2026-02-26 11:17:55 info Closing io.airbyte.container.orchestrator.persistence.SyncPersistenceImpl@825ab3a
2026-02-26 11:17:55 info Returning output...
2026-02-26 11:17:57 info
----- START POST REPLICATION OPERATIONS -----
2026-02-26 11:17:57 info No post-replication operation(s) to perform.
2026-02-26 11:17:57 info
----- END POST REPLICATION OPERATIONS -----Contribute
- Yes, I want to contribute
Internal Tracking: https://github.com/airbytehq/oncall/issues/11452