[source-snowflake] Incremental sync returns 0 records when cursor equals MAX(cursor_field)

### Connector Name

source-snowflake

### Connector Version

1.0.5

### What step the error happened?

During the sync

### Relevant information

## Bug Description

When the stored cursor value equals the current `MAX(cursor_field)` in the source table, the connector incorrectly sets **both** the lower and upper bound query parameters to the same value. This results in a zero-width time range query that returns 0 records, even when records exist at that timestamp.

## Evidence from Logs

### Working Sync (cursor < MAX)
```
INFO i.a.c.r.JdbcPartitionsCreator(ensureCursorUpperBound):86 - Maximum cursor column value is '"2025-11-29T08:56:19.000000"'.
Setting parameter #1 to Binding(value="2025-11-25T09:18:13.000000", type=LocalDateTimeFieldType).
Setting parameter #2 to Binding(value="2025-11-29T08:56:19.000000", type=LocalDateTimeFieldType).
```
**Result**: 399,925 records synced ✅

### Broken Sync (cursor == MAX)
```
INFO i.a.c.r.JdbcPartitionsCreator(ensureCursorUpperBound):86 - Maximum cursor column value is '"2025-11-30T07:31:44.000000"'.
Setting parameter #1 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
Setting parameter #2 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
```
**Result**: 0 records synced ❌ (26,537 records exist at this timestamp)

## Steps to Reproduce

1. Set up Snowflake source with incremental sync using timestamp cursor
2. Run sync - cursor updates to MAX(cursor_field)
3. Source receives new records with **same timestamp** as cursor (common with batch inserts)
4. Run another sync
5. **Result**: 0 records synced despite records existing

## Environment
- Cursor field type: TIMESTAMP_NTZ(9)
- Table type: Secure View
- Destination: S3 (Append mode)
- Airbyte version: 1.7.0

## Workaround
Manually set cursor to 1 second before current value to force different bounds.

## Impact
- **Severity**: High - Silent data loss
- **Sync status**: Shows "succeeded" with 0 records, no errors
```

---

**Relevant log output** (paste the key lines):
2025-12-01 13:50:00 INFO i.a.c.r.JdbcPartitionsCreator(ensureCursorUpperBound):86 Maximum cursor column value in 'REDACTED_SCHEMA.REDACTED_TABLE' is '"2025-11-30T07:31:44.000000"'.
2025-12-01 13:50:00 INFO i.a.c.r.JdbcSelectQuerier$Result(initQueryExecution):98 Setting parameter #1 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
2025-12-01 13:50:00 INFO i.a.c.r.JdbcSelectQuerier$Result(initQueryExecution):98 Setting parameter #2 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
2025-12-01 13:51:46 INFO i.a.c.r.JdbcPartitionsCreator(collectSample):124 Sampled 0 rows in EMPTY stream 'REDACTED_SCHEMA.REDACTED_TABLE'.
2025-12-01 13:51:47 info Sync summary: { "status" : "completed", "recordsSynced" : 0 }
```

### Relevant log output

```shell
>> ATTEMPT 1/1

2025-12-01 13:49:35 info Starting async replication
2025-12-01 13:49:35 info Creating workload f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync
2025-12-01 13:49:36 info APPLY Stage: BUILD — (workloadId=f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync)
2025-12-01 13:49:36 info APPLY Stage: CLAIM — (workloadId=f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync)
2025-12-01 13:49:36 info Claimed: true for f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync via API for 5718ac23-36e6-45f0-9903-7e1d0c806747
2025-12-01 13:49:36 info APPLY Stage: LOAD_SHED — (workloadId=f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync)
2025-12-01 13:49:36 info APPLY Stage: CHECK_STATUS — (workloadId=f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync)
2025-12-01 13:49:36 info No pod found running for workload f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync
2025-12-01 13:49:36 info APPLY Stage: MUTEX — (workloadId=f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync)
2025-12-01 13:49:36 info Mutex key: f9673c30-4ce1-4a28-806e-8bf3963893b5 specified for workload: f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync. Attempting to delete existing pods...
2025-12-01 13:49:36 info Mutex key: f9673c30-4ce1-4a28-806e-8bf3963893b5 specified for workload: f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync found no existing pods. Continuing...
2025-12-01 13:49:36 info APPLY Stage: ARCHITECTURE — (workloadId=f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync)
2025-12-01 13:49:36 info APPLY Stage: LAUNCH — (workloadId=f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync)
2025-12-01 13:49:36 info [initContainer] image: airbyte/workload-init-container:1.7.0 resources: ResourceRequirements(claims=[], limits={memory=16000Mi, cpu=4000m}, requests={memory=10000Mi, cpu=3000m}, additionalProperties={})
2025-12-01 13:49:36 info Launching replication pod: replication-job-2998-attempt-0 (selectors = {nodeType=airbyte-sync}) with containers:
2025-12-01 13:49:36 info [source] image: airbyte/source-snowflake:1.0.5 resources: ResourceRequirements(claims=[], limits={memory=16000Mi, cpu=4000m}, requests={memory=10000Mi, cpu=3000m}, additionalProperties={})
2025-12-01 13:49:36 info [destination] image: airbyte/destination-s3:1.9.1 resources: ResourceRequirements(claims=[], limits={memory=16000Mi, cpu=4000m}, requests={memory=10000Mi, cpu=3000m}, additionalProperties={})
2025-12-01 13:49:36 info [orchestrator] image: airbyte/container-orchestrator:1.7.0 resources: ResourceRequirements(claims=[], limits={memory=16000Mi, cpu=4000m}, requests={memory=10000Mi, cpu=3000m}, additionalProperties={})
2025-12-01 13:49:44 info Attempting to update workload: f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync to LAUNCHED.
2025-12-01 13:49:44 info Pipeline completed for workload: f9673c30-4ce1-4a28-806e-8bf3963893b5_2998_0_sync.
2025-12-01 13:49:50 info Running replication worker...
2025-12-01 13:49:50 info Starting replication worker. job id: 2998 attempt: 0
2025-12-01 13:49:50 info
2025-12-01 13:49:50 info ----- START REPLICATION -----
2025-12-01 13:49:50 info
2025-12-01 13:49:50 info Running destination...
2025-12-01 13:49:50 info Writing messages to protocol version 0.2.0
2025-12-01 13:49:50 error WARNING: Unknown module: org.apache.arrow.memory.core specified to --add-opens
2025-12-01 13:49:50 info Reading messages from protocol version 0.2.0
2025-12-01 13:49:50 info Reading messages from protocol version 0.2.0
2025-12-01 13:49:50 info Starting workload heartbeat
2025-12-01 13:49:50 info MessageProcessor started.
2025-12-01 13:49:50 info SourceReader started.
2025-12-01 13:49:50 info DestinationWriter started.
2025-12-01 13:49:50 info DestinationReader started.
2025-12-01 13:49:50 info INFO main i.m.c.e.DefaultEnvironment():168 Established active environments: [k8s, cloud, cli, source, connector]
2025-12-01 13:49:50 info INFO main i.m.c.e.DefaultEnvironment():168 Established active environments: [k8s, cloud, cli, destination, aws, connector]
2025-12-01 13:49:51 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper$$anon$9(myPropertyHandler):1116 Ignoring property 'auth_type' in [simple type, class java.lang.String] since it has already been added, probably as type-property using polymorphism
2025-12-01 13:49:51 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper$$anon$9(myPropertyHandler):1116 Ignoring property 'auth_type' in [simple type, class java.lang.String] since it has already been added, probably as type-property using polymorphism
2025-12-01 13:49:51 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
2025-12-01 13:49:52 info INFO main i.a.c.l.c.DataChannelBeanFactory(dataChannelMedium):60 Using data channel medium STDIO
2025-12-01 13:49:52 info INFO main i.a.c.l.c.DataChannelBeanFactory(namespaceMapper):310 Going to use the given source value: SOURCE for namespace
2025-12-01 13:49:52 info INFO main i.a.c.l.c.DestinationCatalog():49 Destination catalog initialized: [DestinationStream(unmappedNamespace=null, unmappedName=REDACTED_TABLE, importType=Append, schema=ObjectType(properties={CITY=FieldType(type=StringType, nullable=true), STATE=FieldType(type=StringType, nullable=true), GENDER=FieldType(type=StringType, nullable=true), ZIP_CODE=FieldType(type=StringType, nullable=true), LAST_NAME=FieldType(type=StringType, nullable=true), MEMBER_ID=FieldType(type=StringType, nullable=true), FIRST_NAME=FieldType(type=StringType, nullable=true), CASE_STATUS=FieldType(type=StringType, nullable=true), PROGRAM_KEY=FieldType(type=NumberType, nullable=true), IADP_INDV_ID=FieldType(type=NumberType, nullable=true), PHONE_NUMBER=FieldType(type=StringType, nullable=true), INDIVIDUAL_ID=FieldType(type=NumberType, nullable=true), POLICY_NUMBER=FieldType(type=StringType, nullable=true), ADDRESS_LINE_1=FieldType(type=StringType, nullable=true), ADDRESS_LINE_2=FieldType(type=StringType, nullable=true), QUALIFIED_YEAR=FieldType(type=TimestampTypeWithoutTimezone, nullable=true), IDENTIFIED_YEAR=FieldType(type=TimestampTypeWithoutTimezone, nullable=true), OPTUM_SEGMENT_ID=FieldType(type=StringType, nullable=true), SCENARIO_RULE_ID=FieldType(type=NumberType, nullable=true), SF_AUDIT_UPDT_DT=FieldType(type=TimestampTypeWithoutTimezone, nullable=true), TDS_PROGRAM_NAME=FieldType(type=StringType, nullable=true), RELATIONSHIP_CODE=FieldType(type=StringType, nullable=true), SF_AUDIT_CREAT_DT=FieldType(type=TimestampTypeWithoutTimezone, nullable=true), SUBSCRIBER_NUMBER=FieldType(type=StringType, nullable=true), SCENARIO_RULE_CODE=FieldType(type=StringType, nullable=true), MEMBER_ALTERNATE_ID=FieldType(type=StringType, nullable=true), MEMBER_DATE_OF_BIRTH=FieldType(type=DateType, nullable=true), CUSTOMER_SEGMENT_NUMBER=FieldType(type=StringType, nullable=true), SCENARIO_RULE_DESCRIPTION=FieldType(type=StringType, nullable=true)}, additionalProperties=true, required=[]), generationId=10, minimumGenerationId=0, syncId=2998, isFileBased=false, includeFiles=false, destinationObjectName=null, matchingKey=null, namespaceMapper=io.airbyte.cdk.load.command.NamespaceMapper@56b84d4b)]
2025-12-01 13:49:52 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
2025-12-01 13:49:52 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
2025-12-01 13:49:52 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
2025-12-01 13:49:52 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
2025-12-01 13:49:52 info INFO main i.a.c.l.c.DataChannelBeanFactory(logPerNRecords):137 Logging every 100000 records
2025-12-01 13:49:52 info INFO main i.a.c.l.c.DataChannelBeanFactory(dataChannelSocketPaths):69 Using socket paths []
2025-12-01 13:49:52 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper$$anon$9(myPropertyHandler):1116 Ignoring property 'auth_type' in [simple type, class java.lang.String] since it has already been added, probably as type-property using polymorphism
2025-12-01 13:49:52 warn WARN main c.k.j.j.JsonSchemaGenerator$MyJsonFormatVisitorWrapper$$anon$9(myPropertyHandler):1116 Ignoring property 'auth_type' in [simple type, class java.lang.String] since it has already been added, probably as type-property using polymorphism
2025-12-01 13:49:52 info INFO main i.a.c.l.s.PipelineEventBookkeepingRouter():79 Creating bookkeeping router for 1 data channels
2025-12-01 13:49:52 info INFO main i.a.c.AirbyteConnectorRunnable(run):33 Executing class io.airbyte.cdk.read.ReadOperation operation.
2025-12-01 13:49:52 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$Companion$Factory(session):320 Snowflake source metadata session.
2025-12-01 13:49:52 info INFO main i.a.c.l.f.s.S3ClientFactory(make):218 Creating S3 client using Kotlin SDK
2025-12-01 13:49:52 info INFO main i.a.c.j.JdbcConnectionFactory(get):44 Creating new connection for 'jdbc:snowflake://https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com'.
2025-12-01 13:49:52 error Dec 01, 2025 11:49:52 AM net.snowflake.client.core.SFSession open
2025-12-01 13:49:52 error INFO: Opening session with server: https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com:443/, account: REDACTED_ACCOUNT, user: REDACTED_USER, password is not provided, role: REDACTED_ROLE, database: REDACTED_DATABASE, schema: REDACTED_SCHEMA, warehouse: COMPUTE_WH, 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
2025-12-01 13:49:52 error Dec 01, 2025 11:49:52 AM net.snowflake.client.core.SFSession open
2025-12-01 13:49:52 error INFO: Connecting to GLOBAL Snowflake domain
2025-12-01 13:49:52 error Dec 01, 2025 11:49:52 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2025-12-01 13:49:52 error WARNING: Cache file creation: File /home/airbyte/.cache/snowflake/ocsp_response_cache.json is accessible by others to:
2025-12-01 13:49:52 error Dec 01, 2025 11:49:52 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2025-12-01 13:49:52 error WARNING: Read cache: File /home/airbyte/.cache/snowflake/ocsp_response_cache.json is accessible by others to:
2025-12-01 13:49:52 info INFO main i.a.c.l.c.DataChannelBeanFactory(dataChannelFormat):79 Using data channel format JSONL
2025-12-01 13:49:52 info INFO main i.a.c.AirbyteConnectorRunnable(run):33 Executing class io.airbyte.cdk.load.write.WriteOperation operation.
2025-12-01 13:49:52 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):158 Starting input consumer task
2025-12-01 13:49:52 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):163 Starting startup task
2025-12-01 13:49:52 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@57ff0456)
2025-12-01 13:49:52 error Dec 01, 2025 11:49:52 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.i.InputConsumerTask(execute):84 Starting consuming messages from the input flow
2025-12-01 13:49:52 error WARNING: Extract private key from file: File rsa_key.p8 is accessible by others to: read
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.implementor.SetupTask@615e0a90)
2025-12-01 13:49:52 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):167 Launching open stream task 0
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.SetupTask@615e0a90) completed
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-1 i.a.c.l.t.i.ReservingDeserializingInputFlow(collect):32 Reserved 4800mb memory for input processing
2025-12-01 13:49:52 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):171 Setting up load pipeline
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.implementor.OpenStreamTask@5baa92c7)
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartFormatter, part=0))
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartFormatter, part=1))
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartLoader, part=0))
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-6 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartLoader, part=1))
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartLoader, part=2))
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartLoader, part=4))
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-10 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartLoader, part=3))
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(LoadPipelineStepTask(ObjectLoaderUploadCompleter, part=0))
2025-12-01 13:49:52 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):173 Launching update batch task
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.internal.UpdateBatchStateTask@11ef3633)
2025-12-01 13:49:52 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):176 Launching heartbeat task
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-10 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.internal.HeartbeatTask@5041648c)
2025-12-01 13:49:52 info INFO main i.a.c.l.t.DestinationTaskLauncher(run):185 Starting checkpoint update task
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.internal.UpdateCheckpointsTask@ce464a7)
2025-12-01 13:49:52 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.i.UpdateCheckpointsTask(execute):34 Starting to consume checkpoint messages (state) for updating
2025-12-01 13:49:53 error Dec 01, 2025 11:49:53 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2025-12-01 13:49:53 error WARNING: Write to cache: File /home/airbyte/.cache/snowflake/ocsp_response_cache.json is accessible by others to:
2025-12-01 13:49:53 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedTableNames$2(invoke):230 Querying table names for Snowflake source.
2025-12-01 13:49:54 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedTableNames$2(invoke):251 Discovered 36 tables and views.
2025-12-01 13:49:54 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedColumnMetadata$2(invoke):61 Querying column names for catalog discovery.
2025-12-01 13:49:58 info INFO main i.a.i.s.s.SnowflakeSourceMetadataQuerier$memoizedColumnMetadata$2(invoke):78 Discovered 456 column(s).
2025-12-01 13:49:58 info INFO main i.a.c.d.JdbcMetadataQuerier(close):329 Closing JDBC connection.
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-1#read i.a.c.r.RootReader(read):134 Reading feeds of type class io.airbyte.cdk.read.Global.
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-1#read i.a.c.r.RootReader(read):175 Reading feeds of type class io.airbyte.cdk.read.Stream.
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-2#REDACTED_SCHEMA.REDACTED_TABLE i.a.c.r.FeedReader(createPartitions):78 Attempting bootstrap using class io.airbyte.cdk.read.JdbcConcurrentPartitionsCreatorFactory.
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-3#read i.a.c.r.ReadOperation$execute$1$1$1(invokeSuspend):61 coroutine state:
read
└─REDACTED_SCHEMA.REDACTED_TABLE

2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-2#REDACTED_SCHEMA.REDACTED_TABLE-round-1-acquire-resources i.a.c.r.FeedReader(acquirePartitionsCreatorResources):107 acquired resources to create partitions for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 1
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.FeedReader(createPartitionsWithResources):117 creating partitions for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 1
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcPartitionsCreator(ensureCursorUpperBound):67 Querying maximum cursor column value.
2025-12-01 13:49:58 info Stream status TRACE received of status: STARTED for stream REDACTED_SCHEMA:REDACTED_TABLE
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result():74 Querying SELECT MAX("SF_AUDIT_UPDT_DT") FROM "REDACTED_SCHEMA"."REDACTED_TABLE"
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.j.JdbcConnectionFactory(get):44 Creating new connection for 'jdbc:snowflake://https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com'.
2025-12-01 13:49:58 info Sending update for REDACTED_SCHEMA:REDACTED_TABLE - null -> RUNNING
2025-12-01 13:49:58 error Dec 01, 2025 11:49:58 AM net.snowflake.client.core.SFSession open
2025-12-01 13:49:58 error INFO: Opening session with server: https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com:443/, account: REDACTED_ACCOUNT, user: REDACTED_USER, password is not provided, role: REDACTED_ROLE, database: REDACTED_DATABASE, schema: REDACTED_SCHEMA, warehouse: COMPUTE_WH, 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
2025-12-01 13:49:58 error Dec 01, 2025 11:49:58 AM net.snowflake.client.core.SFSession open
2025-12-01 13:49:58 error INFO: Connecting to GLOBAL Snowflake domain
2025-12-01 13:49:58 error Dec 01, 2025 11:49:58 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2025-12-01 13:49:58 error WARNING: Extract private key from file: File rsa_key.p8 is accessible by others to: read
2025-12-01 13:49:58 info Stream Status Update Received: REDACTED_SCHEMA:REDACTED_TABLE - RUNNING
2025-12-01 13:49:58 info Creating status: REDACTED_SCHEMA:REDACTED_TABLE - RUNNING
2025-12-01 13:49:58 info INFO DefaultDispatcher-worker-3#read i.a.c.r.ReadOperation$execute$1$1$1(invokeSuspend):61 coroutine state:
read
└─REDACTED_SCHEMA.REDACTED_TABLE
└─REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions

2025-12-01 13:50:00 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(hasNext):115 Received results from server.
2025-12-01 13:50:00 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(close):161 Closing SELECT MAX("SF_AUDIT_UPDT_DT") FROM "REDACTED_SCHEMA"."REDACTED_TABLE"
2025-12-01 13:50:00 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcPartitionsCreator(ensureCursorUpperBound):86 Maximum cursor column value in 'REDACTED_SCHEMA.REDACTED_TABLE' is '"2025-11-30T07:31:44.000000"'.
2025-12-01 13:50:00 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcPartitionsCreator(collectSample):98 Sampling stream 'REDACTED_SCHEMA.REDACTED_TABLE' at rate 1 / 65536.
2025-12-01 13:50:00 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result():74 Querying SELECT "COL1", "COL2", "COL3", "COL4", "COL5", "COL6", "COL7", "CASE_STATUS", "PROGRAM_KEY", "COL16", "COL8", "COL15", "COL11", "COL9", "COL10", "QUALIFIED_YEAR", "IDENTIFIED_YEAR", "OPTUM_SEGMENT_ID", "SCENARIO_RULE_ID", "SF_AUDIT_UPDT_DT", "TDS_PROGRAM_NAME", "RELATIONSHIP_CODE", "SF_AUDIT_CREAT_DT", "COL12", "SCENARIO_RULE_CODE", "COL13", "COL14", "CUSTOMER_SEGMENT_NUMBER", "SCENARIO_RULE_DESCRIPTION" FROM (SELECT * FROM (SELECT * FROM "REDACTED_SCHEMA"."REDACTED_TABLE" SAMPLE (0.0015258789062500) ORDER BY RANDOM()) LIMIT 1024) WHERE ("SF_AUDIT_UPDT_DT" >= ?) AND ("SF_AUDIT_UPDT_DT" <= ?) ORDER BY "SF_AUDIT_UPDT_DT"
2025-12-01 13:50:00 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.j.JdbcConnectionFactory(get):44 Creating new connection for 'jdbc:snowflake://https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com'.
2025-12-01 13:50:00 error Dec 01, 2025 11:50:00 AM net.snowflake.client.core.SFSession open
2025-12-01 13:50:00 error INFO: Opening session with server: https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com:443/, account: REDACTED_ACCOUNT, user: REDACTED_USER, password is not provided, role: REDACTED_ROLE, database: REDACTED_DATABASE, schema: REDACTED_SCHEMA, warehouse: COMPUTE_WH, 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
2025-12-01 13:50:00 error Dec 01, 2025 11:50:00 AM net.snowflake.client.core.SFSession open
2025-12-01 13:50:00 error INFO: Connecting to GLOBAL Snowflake domain
2025-12-01 13:50:00 error Dec 01, 2025 11:50:00 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2025-12-01 13:50:00 error WARNING: Extract private key from file: File rsa_key.p8 is accessible by others to: read
2025-12-01 13:50:00 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(initQueryExecution):98 Setting parameter #1 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
2025-12-01 13:50:00 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(initQueryExecution):98 Setting parameter #2 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
2025-12-01 13:50:03 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(hasNext):115 Received results from server.
2025-12-01 13:50:03 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(close):161 Closing SELECT "COL1", "COL2", "COL3", "COL4", "COL5", "COL6", "COL7", "CASE_STATUS", "PROGRAM_KEY", "COL16", "COL8", "COL15", "COL11", "COL9", "COL10", "QUALIFIED_YEAR", "IDENTIFIED_YEAR", "OPTUM_SEGMENT_ID", "SCENARIO_RULE_ID", "SF_AUDIT_UPDT_DT", "TDS_PROGRAM_NAME", "RELATIONSHIP_CODE", "SF_AUDIT_CREAT_DT", "COL12", "SCENARIO_RULE_CODE", "COL13", "COL14", "CUSTOMER_SEGMENT_NUMBER", "SCENARIO_RULE_DESCRIPTION" FROM (SELECT * FROM (SELECT * FROM "REDACTED_SCHEMA"."REDACTED_TABLE" SAMPLE (0.0015258789062500) ORDER BY RANDOM()) LIMIT 1024) WHERE ("SF_AUDIT_UPDT_DT" >= ?) AND ("SF_AUDIT_UPDT_DT" <= ?) ORDER BY "SF_AUDIT_UPDT_DT"
2025-12-01 13:50:03 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcPartitionsCreator(collectSample):98 Sampling stream 'REDACTED_SCHEMA.REDACTED_TABLE' at rate 1 / 256.
2025-12-01 13:50:03 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result():74 Querying SELECT "COL1", "COL2", "COL3", "COL4", "COL5", "COL6", "COL7", "CASE_STATUS", "PROGRAM_KEY", "COL16", "COL8", "COL15", "COL11", "COL9", "COL10", "QUALIFIED_YEAR", "IDENTIFIED_YEAR", "OPTUM_SEGMENT_ID", "SCENARIO_RULE_ID", "SF_AUDIT_UPDT_DT", "TDS_PROGRAM_NAME", "RELATIONSHIP_CODE", "SF_AUDIT_CREAT_DT", "COL12", "SCENARIO_RULE_CODE", "COL13", "COL14", "CUSTOMER_SEGMENT_NUMBER", "SCENARIO_RULE_DESCRIPTION" FROM (SELECT * FROM (SELECT * FROM "REDACTED_SCHEMA"."REDACTED_TABLE" SAMPLE (0.39062500) ORDER BY RANDOM()) LIMIT 1024) WHERE ("SF_AUDIT_UPDT_DT" >= ?) AND ("SF_AUDIT_UPDT_DT" <= ?) ORDER BY "SF_AUDIT_UPDT_DT"
2025-12-01 13:50:03 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.j.JdbcConnectionFactory(get):44 Creating new connection for 'jdbc:snowflake://https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com'.
2025-12-01 13:50:03 error Dec 01, 2025 11:50:03 AM net.snowflake.client.core.SFSession open
2025-12-01 13:50:03 error INFO: Opening session with server: https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com:443/, account: REDACTED_ACCOUNT, user: REDACTED_USER, password is not provided, role: REDACTED_ROLE, database: REDACTED_DATABASE, schema: REDACTED_SCHEMA, warehouse: COMPUTE_WH, 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
2025-12-01 13:50:03 error Dec 01, 2025 11:50:03 AM net.snowflake.client.core.SFSession open
2025-12-01 13:50:03 error INFO: Connecting to GLOBAL Snowflake domain
2025-12-01 13:50:03 error Dec 01, 2025 11:50:03 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2025-12-01 13:50:03 error WARNING: Extract private key from file: File rsa_key.p8 is accessible by others to: read
2025-12-01 13:50:04 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(initQueryExecution):98 Setting parameter #1 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
2025-12-01 13:50:04 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(initQueryExecution):98 Setting parameter #2 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
2025-12-01 13:50:07 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(hasNext):115 Received results from server.
2025-12-01 13:50:07 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(close):161 Closing SELECT "COL1", "COL2", "COL3", "COL4", "COL5", "COL6", "COL7", "CASE_STATUS", "PROGRAM_KEY", "COL16", "COL8", "COL15", "COL11", "COL9", "COL10", "QUALIFIED_YEAR", "IDENTIFIED_YEAR", "OPTUM_SEGMENT_ID", "SCENARIO_RULE_ID", "SF_AUDIT_UPDT_DT", "TDS_PROGRAM_NAME", "RELATIONSHIP_CODE", "SF_AUDIT_CREAT_DT", "COL12", "SCENARIO_RULE_CODE", "COL13", "COL14", "CUSTOMER_SEGMENT_NUMBER", "SCENARIO_RULE_DESCRIPTION" FROM (SELECT * FROM (SELECT * FROM "REDACTED_SCHEMA"."REDACTED_TABLE" SAMPLE (0.39062500) ORDER BY RANDOM()) LIMIT 1024) WHERE ("SF_AUDIT_UPDT_DT" >= ?) AND ("SF_AUDIT_UPDT_DT" <= ?) ORDER BY "SF_AUDIT_UPDT_DT"
2025-12-01 13:50:08 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcPartitionsCreator(collectSample):98 Sampling stream 'REDACTED_SCHEMA.REDACTED_TABLE' at rate 1 / 1.
2025-12-01 13:50:08 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result():74 Querying SELECT "COL1", "COL2", "COL3", "COL4", "COL5", "COL6", "COL7", "CASE_STATUS", "PROGRAM_KEY", "COL16", "COL8", "COL15", "COL11", "COL9", "COL10", "QUALIFIED_YEAR", "IDENTIFIED_YEAR", "OPTUM_SEGMENT_ID", "SCENARIO_RULE_ID", "SF_AUDIT_UPDT_DT", "TDS_PROGRAM_NAME", "RELATIONSHIP_CODE", "SF_AUDIT_CREAT_DT", "COL12", "SCENARIO_RULE_CODE", "COL13", "COL14", "CUSTOMER_SEGMENT_NUMBER", "SCENARIO_RULE_DESCRIPTION" FROM (SELECT * FROM (SELECT * FROM "REDACTED_SCHEMA"."REDACTED_TABLE" ORDER BY RANDOM()) LIMIT 1024) WHERE ("SF_AUDIT_UPDT_DT" >= ?) AND ("SF_AUDIT_UPDT_DT" <= ?) ORDER BY "SF_AUDIT_UPDT_DT"
2025-12-01 13:50:08 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.j.JdbcConnectionFactory(get):44 Creating new connection for 'jdbc:snowflake://https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com'.
2025-12-01 13:50:08 error Dec 01, 2025 11:50:08 AM net.snowflake.client.core.SFSession open
2025-12-01 13:50:08 error INFO: Opening session with server: https://REDACTED_ACCOUNT.REDACTED_REGION.snowflakecomputing.com:443/, account: REDACTED_ACCOUNT, user: REDACTED_USER, password is not provided, role: REDACTED_ROLE, database: REDACTED_DATABASE, schema: REDACTED_SCHEMA, warehouse: COMPUTE_WH, 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
2025-12-01 13:50:08 error Dec 01, 2025 11:50:08 AM net.snowflake.client.core.SFSession open
2025-12-01 13:50:08 error INFO: Connecting to GLOBAL Snowflake domain
2025-12-01 13:50:08 error Dec 01, 2025 11:50:08 AM net.snowflake.client.core.FileUtil logWarnWhenAccessibleByOthers
2025-12-01 13:50:08 error WARNING: Extract private key from file: File rsa_key.p8 is accessible by others to: read
2025-12-01 13:50:08 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(initQueryExecution):98 Setting parameter #1 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
2025-12-01 13:50:08 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(initQueryExecution):98 Setting parameter #2 to Binding(value="2025-11-30T07:31:44.000000", type=LocalDateTimeFieldType).
2025-12-01 13:50:52 info INFO DefaultDispatcher-worker-2 i.a.c.l.s.CheckpointManager(flushReadyCheckpointMessages):151 No checkpoints to flush
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(hasNext):115 Received results from server.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcSelectQuerier$Result(close):161 Closing SELECT "COL1", "COL2", "COL3", "COL4", "COL5", "COL6", "COL7", "CASE_STATUS", "PROGRAM_KEY", "COL16", "COL8", "COL15", "COL11", "COL9", "COL10", "QUALIFIED_YEAR", "IDENTIFIED_YEAR", "OPTUM_SEGMENT_ID", "SCENARIO_RULE_ID", "SF_AUDIT_UPDT_DT", "TDS_PROGRAM_NAME", "RELATIONSHIP_CODE", "SF_AUDIT_CREAT_DT", "COL12", "SCENARIO_RULE_CODE", "COL13", "COL14", "CUSTOMER_SEGMENT_NUMBER", "SCENARIO_RULE_DESCRIPTION" FROM (SELECT * FROM (SELECT * FROM "REDACTED_SCHEMA"."REDACTED_TABLE" ORDER BY RANDOM()) LIMIT 1024) WHERE ("SF_AUDIT_UPDT_DT" >= ?) AND ("SF_AUDIT_UPDT_DT" <= ?) ORDER BY "SF_AUDIT_UPDT_DT"
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcPartitionsCreator(collectSample):124 Sampled 0 rows in EMPTY stream 'REDACTED_SCHEMA.REDACTED_TABLE'.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.JdbcConcurrentPartitionsCreator(run):221 Sampling query found that the table was empty.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-create-partitions i.a.c.r.FeedReader(createPartitionsWithResources):121 releasing resources acquired to create partitions for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 1
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-partition-1-acquire-resources i.a.c.r.FeedReader(acquirePartitionReaderResources):186 acquired resources to read partition 1 for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 1
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-partition-1-read i.a.c.r.FeedReader(readPartitionWithResources):196 reading partition 1 for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 1
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-partition-1-read i.a.c.r.FeedReader(readPartitionWithResources):205 Running partition reader with 5m timeout
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-partition-1-read i.a.c.r.FeedReader(readPartitionWithResources):210 completed reading partition 1 for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 1
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#read i.a.c.r.ReadOperation$execute$1$1$1(invokeSuspend):61 coroutine state:
read
└─REDACTED_SCHEMA.REDACTED_TABLE
└─REDACTED_SCHEMA.REDACTED_TABLE-round-1-partition-1-read

2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-partition-1-read i.a.c.r.FeedReader(readPartitionWithResources):222 releasing resources acquired to read partition 1 for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 1
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1#REDACTED_SCHEMA.REDACTED_TABLE-round-1-partition-1-read i.a.c.r.FeedReader(readPartitionWithResources):229 read 0 record(s) from partition 1 for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 1
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#REDACTED_SCHEMA.REDACTED_TABLE i.a.c.r.FeedReader(awaitAllPartitionReaders):287 processing result (success = true) from reading partition 1 / 1 for 'REDACTED_SCHEMA.REDACTED_TABLE'
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#REDACTED_SCHEMA.REDACTED_TABLE i.a.c.r.FeedReader(awaitAllPartitionReaders):294 updated state of 'REDACTED_SCHEMA.REDACTED_TABLE', moved it 0 record(s) forward
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#REDACTED_SCHEMA.REDACTED_TABLE i.a.c.r.FeedReader(maybeCheckpoint):315 checkpoint of 1 state message(s)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#REDACTED_SCHEMA.REDACTED_TABLE i.a.c.r.FeedReader(createPartitions):78 Attempting bootstrap using class io.airbyte.cdk.read.JdbcConcurrentPartitionsCreatorFactory.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#REDACTED_SCHEMA.REDACTED_TABLE-round-2-acquire-resources i.a.c.r.FeedReader(acquirePartitionsCreatorResources):107 acquired resources to create partitions for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 2
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#REDACTED_SCHEMA.REDACTED_TABLE-round-2-create-partitions i.a.c.r.FeedReader(createPartitionsWithResources):117 creating partitions for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 2
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#REDACTED_SCHEMA.REDACTED_TABLE-round-2-create-partitions i.a.c.r.FeedReader(createPartitionsWithResources):121 releasing resources acquired to create partitions for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 2
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3#REDACTED_SCHEMA.REDACTED_TABLE i.a.c.r.FeedReader(read):44 no more partitions to read for 'REDACTED_SCHEMA.REDACTED_TABLE' in round 2
2025-12-01 13:51:46 info INFO main i.a.c.AirbyteConnectorRunnable(run):46 Flushing output consumer prior to shutdown.
2025-12-01 13:51:46 info INFO main i.a.c.AirbyteConnectorRunnable(run):48 Completed integration: airbyte/source-snowflake.
2025-12-01 13:51:46 info Stream status TRACE received of status: COMPLETE for stream REDACTED_SCHEMA:REDACTED_TABLE
2025-12-01 13:51:46 info Total records read: (0 bytes)
2025-12-01 13:51:46 info Schema validation was performed to a max of 10 records with errors per stream.
2025-12-01 13:51:46 info SourceReader finished.
2025-12-01 13:51:46 info MessageProcessor finished.
2025-12-01 13:51:46 info DestinationWriter finished.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):101 Saw first record for stream Descriptor(namespace=null, name=REDACTED_TABLE); awaiting setup complete
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-1 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):105 Setup complete, starting stream Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.i.UpdateCheckpointsTask$execute$3(emit):39 Updating stream checkpoint Descriptor(namespace=null, name=REDACTED_TABLE):CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1)):Stats(recordCount=0, rejectedRecordCount=0)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-4 i.a.c.l.s.CheckpointManager(addStreamCheckpoint):121 Added checkpoint for stream: Descriptor(namespace=null, name=REDACTED_TABLE) at index: CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1))
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):108 Initialization for stream Descriptor(namespace=null, name=REDACTED_TABLE) complete
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(handleStreamMessage):126 Read COMPLETE for stream Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.i.ReservingDeserializingInputFlow(collect):55 Finished processing input
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(close):277 Maybe closing bookkeeping router 1
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3 i.a.c.l.s.PipelineEventBookkeepingRouter(close):296 Closing internal control channels
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=REDACTED_TABLE): record-part-formatter-step[1]
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.i.LoadPipelineStepTask$execute$$inlined$fold$1(emit):317 LoadPipelineStepTask(ObjectLoaderPartFormatter, part=0) saw end-of-stream for Descriptor(namespace=null, name=REDACTED_TABLE) after 0 inputs, all workers complete
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.i.LoadPipelineStepTask$execute$$inlined$fold$1(emit):317 LoadPipelineStepTask(ObjectLoaderPartLoader, part=3) saw end-of-stream for Descriptor(namespace=null, name=REDACTED_TABLE) after 0 inputs, all workers complete
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3 i.a.c.l.m.MultiProducerChannel(close):26 Closing producer fileMessageQueue (active count=0, initialized count: 1)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.i.LoadPipelineStepTask$execute$$inlined$fold$1(emit):317 LoadPipelineStepTask(ObjectLoaderUploadCompleter, part=0) saw end-of-stream for Descriptor(namespace=null, name=REDACTED_TABLE) after 0 inputs, all workers complete
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3 i.a.c.l.m.MultiProducerChannel(close):30 Closing underlying queue
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.OpenStreamTask@5baa92c7) completed
2025-12-01 13:51:46 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@57ff0456) completed
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartFormatter, part=0)) completed
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(LoadPipelineStepTask(ObjectLoaderPartFormatter, part=1)) completed
2025-12-01 13:51:46 info Destination complete for REDACTED_SCHEMA:REDACTED_TABLE
2025-12-01 13:51:46 info Sending update for REDACTED_SCHEMA:REDACTED_TABLE - RUNNING -> COMPLETE
2025-12-01 13:51:46 info Stream Status Update Received: REDACTED_SCHEMA:REDACTED_TABLE - COMPLETE
2025-12-01 13:51:46 info Updating status: REDACTED_SCHEMA:REDACTED_TABLE - COMPLETE
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-4 i.a.c.l.s.CheckpointManager(flushStreamCheckpoints):371 Flushed checkpoint for stream: Descriptor(namespace=null, name=REDACTED_TABLE) at index: CheckpointKey(checkpointIndex=CheckpointIndex(value=1), checkpointId=CheckpointId(value=1)) (records=0, bytes=0)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.i.UpdateCheckpointsTask(execute):68 All checkpoints (state) updated
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.internal.UpdateCheckpointsTask@ce464a7) completed
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):206 Batch processing complete: Starting close stream task for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=REDACTED_TABLE): record-part-loader-step[0]
2025-12-01 13:51:46 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@66a9ffff)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):215 Close stream task has already run, skipping.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=REDACTED_TABLE): record-part-loader-step[1]
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):215 Close stream task has already run, skipping.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=REDACTED_TABLE): record-part-loader-step[4]
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.CloseStreamTask@66a9ffff) completed
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):34 Launching TaskWrapper(io.airbyte.cdk.load.task.implementor.TeardownTask@39322376)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):215 Close stream task has already run, skipping.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=REDACTED_TABLE): record-part-loader-step[2]
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.i.TeardownTask(execute):35 Teardown task awaiting stream processing completion
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):215 Close stream task has already run, skipping.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=REDACTED_TABLE): record-part-formatter-step[0]
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.i.TeardownTask(execute):41 All streams processed successfully, awaiting all checkpoints flushed
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):215 Close stream task has already run, skipping.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=REDACTED_TABLE): record-part-loader-step[3]
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.s.CheckpointManager(awaitAllCheckpointsFlushed):434 All checkpoints flushed
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.i.TeardownTask(execute):43 Starting teardown task
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):215 Close stream task has already run, skipping.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.i.UpdateBatchStateTask$execute$2(emit):48 End-of-stream checks for Descriptor(namespace=null, name=REDACTED_TABLE): final-step[0]
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.i.TeardownTask(execute):45 Teardown task complete, marking sync succeeded.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):203 Processing complete for Descriptor(namespace=null, name=REDACTED_TABLE)
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher(handleStreamComplete):215 Close stream task has already run, skipping.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.TaskScopeProvider$launch$job$1(invokeSuspend):36 Task TaskWrapper(io.airbyte.cdk.load.task.implementor.TeardownTask@39322376) completed
2025-12-01 13:51:46 info INFO main i.a.c.l.t.TaskScopeProvider(close):46 Closing normally, canceling long-running tasks
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-11 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task LoadPipelineStepTask(ObjectLoaderPartLoader, part=2) was cancelled.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-12 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task io.airbyte.cdk.load.task.internal.UpdateBatchStateTask@11ef3633 was cancelled.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-7 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task LoadPipelineStepTask(ObjectLoaderPartLoader, part=1) was cancelled.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-2 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task LoadPipelineStepTask(ObjectLoaderUploadCompleter, part=0) was cancelled.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-3 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task io.airbyte.cdk.load.task.internal.HeartbeatTask@5041648c was cancelled.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-5 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task LoadPipelineStepTask(ObjectLoaderPartLoader, part=4) was cancelled.
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-4 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task LoadPipelineStepTask(ObjectLoaderPartLoader, part=0) was cancelled.
2025-12-01 13:51:46 info INFO main i.a.c.l.t.TaskScopeProvider(close):49 Verifying task completion
2025-12-01 13:51:46 info INFO DefaultDispatcher-worker-10 i.a.c.l.t.DestinationTaskLauncher$WrappedTask(execute):126 Task LoadPipelineStepTask(ObjectLoaderPartLoader, part=3) was cancelled.
2025-12-01 13:51:46 info INFO main i.a.c.l.w.WriteOperation$execute$1(invokeSuspend):65 Destination completed successfully and all streams were complete.
2025-12-01 13:51:46 info INFO main i.a.c.AirbyteConnectorRunnable(run):46 Flushing output consumer prior to shutdown.
2025-12-01 13:51:46 info INFO main i.a.c.AirbyteConnectorRunnable(run):48 Completed integration: airbyte/destination-s3.
2025-12-01 13:51:47 info DestinationReader finished.
2025-12-01 13:51:47 info Closing StateCheckSumCountEventHandler
2025-12-01 13:51:47 info No checksum errors were reported in the entire sync.
2025-12-01 13:51:47 info Sync summary: {
"status" : "completed",
"recordsSynced" : 0,
"bytesSynced" : 0,
"startTime" : 1764589789598,
"endTime" : 1764589907985,
"totalStats" : {
"bytesCommitted" : 0,
"bytesEmitted" : 0,
"destinationStateMessagesEmitted" : 1,
"destinationWriteEndTime" : 1764589907871,
"destinationWriteStartTime" : 1764589790548,
"meanSecondsBeforeSourceStateMessageEmitted" : 0,
"maxSecondsBeforeSourceStateMessageEmitted" : 1,
"maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
"meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
"recordsEmitted" : 0,
"recordsCommitted" : 0,
"recordsFilteredOut" : 0,
"bytesFilteredOut" : 0,
"replicationEndTime" : 1764589907875,
"replicationStartTime" : 1764589789598,
"sourceReadEndTime" : 1764589906443,
"sourceReadStartTime" : 1764589790548,
"sourceStateMessagesEmitted" : 1
},
"streamStats" : [ {
"streamName" : "REDACTED_TABLE",
"streamNamespace" : "REDACTED_SCHEMA",
"stats" : {
"bytesCommitted" : 0,
"bytesEmitted" : 0,
"recordsEmitted" : 0,
"recordsCommitted" : 0,
"recordsFilteredOut" : 0,
"bytesFilteredOut" : 0
}
} ],
"performanceMetrics" : { }
}
2025-12-01 13:51:47 info Failures: [ ]
2025-12-01 13:51:47 info
2025-12-01 13:51:47 info ----- END REPLICATION -----
2025-12-01 13:51:47 info Closing io.micronaut.context.propagation.instrument.execution.ExecutorServiceInstrumenter$2@7db791df
2025-12-01 13:51:47 info
2025-12-01 13:51:47 info Closing io.airbyte.container.orchestrator.worker.io.LocalContainerAirbyteDestination@1bfa5a13
2025-12-01 13:51:48 info Closing io.airbyte.container.orchestrator.worker.io.LocalContainerAirbyteSource@176333ee
2025-12-01 13:51:48 info Closing io.airbyte.container.orchestrator.worker.RecordSchemaValidator@18e6b72b
2025-12-01 13:51:48 info Closing io.airbyte.container.orchestrator.persistence.SyncPersistenceImpl@316d30ad
2025-12-01 13:51:48 info Returning output...
```

### Contribute

- [ ] Yes, I want to contribute