Skip to content

Conversation

@jgao54
Copy link
Contributor

@jgao54 jgao54 commented Nov 15, 2025

Postgres TIME supports range: [00:00:00, 24:00:00], with microsecond precision
MySQL TIME supports range: [-838:59:59.000000, 838:59:59.999999], with microsecond precision
ClickHouse Time64 supports range: [-999:59:59.000000, 999:59:59.999999], with nanosecond precision

In theory ClickHouse could fully support Postgres and MySQL timestamps as is. However, the current implementation converts MySQL time value is in the range of [00:00:00, 24:00:00].

One subtle, but IMO useful improvement from this PR (aside from adding Time64 support) that's worth calling out:
we used to have Postgres convert to QValueTime while MySQL convert to QValueTimestamp prior to Time64 was introduced; meaning Posgres handles conversion to DateTime64 in the destination connector, while MySQL handles the conversion in the source connector. With this PR, conversion is consistently handled in the destination connector. So we always convert Time -> QValueTime, and then handle backwards-compatibility by optionally converting QValueTime -> DateTime64 if on an older version of peerdb or if on an older version of ClickHouse that does not support Time64. This is possible because toTime64 and parseDateTime64BestEffortOrNull both support parsing string with `hh:mm:ss'.

I've also evaluated bringing consistency by aligning Postgres to MySQL, and do the branching when mapping Time (source type) -> QValue, and keep the destination consistent instead. This is a messier approach, because it means we need to know ClickHouse version when we are handling the branching (since we can't convert to Time64 unless it is supported by ClickHouse), so the source connector needs to know about ClickHouse version which is not a concept available today.

That said, if the business for supporting MySQL's handling is strong, the fix would be to implement a custom conversion from duration to int64 representing milliseconds (instead of hh:mm:ss string), and then have MySQL optionally handle that case based on the source colType. It's do-able, just more edge case handling involved; so I would prefer not unless absolutely necessary.

@codecov
Copy link

codecov bot commented Nov 15, 2025

❌ 10 Tests Failed:

Tests completed Failed Passed Skipped
1635 10 1625 162
View the top 3 failed test(s) by shortest run time
github.com/PeerDB-io/peerdb/flow/e2e::TestGenericBQ
Stack Traces | 0s run time
=== RUN   TestGenericBQ
=== PAUSE TestGenericBQ
=== CONT  TestGenericBQ
--- FAIL: TestGenericBQ (0.00s)
github.com/PeerDB-io/peerdb/flow/e2e::TestBigQueryClickhouseSuite
Stack Traces | 0.01s run time
=== RUN   TestBigQueryClickhouseSuite
=== PAUSE TestBigQueryClickhouseSuite
=== CONT  TestBigQueryClickhouseSuite
--- FAIL: TestBigQueryClickhouseSuite (0.01s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH (0.01s)
2026/01/19 03:30:50 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:30:50 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:30:50 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH_Cluster
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH_Cluster
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH_Cluster
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH_Cluster
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH_Cluster (0.01s)
2026/01/19 03:28:38 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:28:38 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH
=== PAUSE TestPeerFlowE2ETestSuitePG_CH
=== CONT  TestPeerFlowE2ETestSuitePG_CH
--- FAIL: TestPeerFlowE2ETestSuitePG_CH (0.01s)
2026/01/19 03:30:54 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:30:54 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:30:54 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT sync_batch_id FROM metadata_last_sync_state WHERE job_name='test_normalize_metadata_with_retry_pgchcl_zelpphhf'"
2026/01/19 03:30:54 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT sync_batch_id FROM metadata_last_sync_state WHERE job_name='test_normalize_metadata_with_retry_pgchcl_zelpphhf'"
2026/01/19 03:30:54 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_13695686087061009079 CURSOR FOR SELECT sync_batch_id FROM metadata_last_sync_state WHERE job_name='test_normalize_metadata_with_retry_pgchcl_zelpphhf'" args=[]
2026/01/19 03:30:54 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT sync_batch_id FROM metadata_last_sync_state WHERE job_name='test_normalize_metadata_with_retry_pgchcl_zelpphhf'" channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13695686087061009079
2026/01/19 03:30:54 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13695686087061009079 records=1 bytes=8 channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT sync_batch_id FROM metadata_last_sync_state WHERE job_name='test_normalize_metadata_with_retry_pgchcl_zelpphhf'" rows=1 bytes=8 channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13695686087061009079
2026/01/19 03:30:54 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13695686087061009079 records=0 bytes=0 channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT sync_batch_id FROM metadata_last_sync_state WHERE job_name='test_normalize_metadata_with_retry_pgchcl_zelpphhf'" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:54 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT sync_batch_id FROM metadata_last_sync_state WHERE job_name='test_normalize_metadata_with_retry_pgchcl_zelpphhf'" rows=1 bytes=8 channelLen=0
2026/01/19 03:30:54 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_ulwwe4ry.\"test_exclude_ch\" ORDER BY id"
2026/01/19 03:30:54 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_ulwwe4ry.\"test_exclude_ch\" ORDER BY id"
2026/01/19 03:30:54 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_3056979199870210018 CURSOR FOR SELECT id,c1,t FROM e2e_test_pgchcl_ulwwe4ry.\"test_exclude_ch\" ORDER BY id" args=[]
2026/01/19 03:30:54 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_ulwwe4ry.\"test_exclude_ch\" ORDER BY id" channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3056979199870210018
2026/01/19 03:30:54 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3056979199870210018 records=4 bytes=80 channelLen=3
2026/01/19 03:30:54 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_ulwwe4ry.\"test_exclude_ch\" ORDER BY id" rows=4 bytes=80 channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3056979199870210018
2026/01/19 03:30:54 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3056979199870210018 records=0 bytes=0 channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_ulwwe4ry.\"test_exclude_ch\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:54 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:54 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_ulwwe4ry.\"test_exclude_ch\" ORDER BY id" rows=4 bytes=80 channelLen=0
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH_Cluster
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH_Cluster
=== PAUSE TestPeerFlowE2ETestSuitePG_CH_Cluster
=== CONT  TestPeerFlowE2ETestSuitePG_CH_Cluster
--- FAIL: TestPeerFlowE2ETestSuitePG_CH_Cluster (0.01s)
2026/01/19 03:32:17 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:32:17 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:32:17 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_api_pwa3vzdx.table1
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time
Stack Traces | 31.1s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time
2026/01/19 03:29:55 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:29:55 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:29:56 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_lb2flmui.test_unsigned
    clickhouse_mysql_test.go:107: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time (31.08s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time
Stack Traces | 31.1s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time
2026/01/19 03:27:47 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:27:47 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    clickhouse_mysql_test.go:107: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time (31.13s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH/Test_Types_CH
Stack Traces | 31.1s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH/Test_Types_CH
=== PAUSE TestPeerFlowE2ETestSuitePG_CH/Test_Types_CH
=== CONT  TestPeerFlowE2ETestSuitePG_CH/Test_Types_CH
2026/01/19 03:28:13 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:28:13 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_5zvdu5mt.\"myMixedCaseTable\" ORDER BY id"
2026/01/19 03:28:13 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_5zvdu5mt.\"myMixedCaseTable\" ORDER BY id"
2026/01/19 03:28:13 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_9119439304936775710 CURSOR FOR SELECT id,\"key\" FROM e2e_test_pgch_5zvdu5mt.\"myMixedCaseTable\" ORDER BY id" args=[]
2026/01/19 03:28:13 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_5zvdu5mt.\"myMixedCaseTable\" ORDER BY id" channelLen=0
2026/01/19 03:28:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9119439304936775710
2026/01/19 03:28:13 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:28:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9119439304936775710 records=2 bytes=15 channelLen=1
2026/01/19 03:28:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_5zvdu5mt.\"myMixedCaseTable\" ORDER BY id" rows=2 bytes=15 channelLen=0
2026/01/19 03:28:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9119439304936775710
2026/01/19 03:28:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9119439304936775710 records=0 bytes=0 channelLen=0
2026/01/19 03:28:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_5zvdu5mt.\"myMixedCaseTable\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:28:13 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:28:13 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_5zvdu5mt.\"myMixedCaseTable\" ORDER BY id" rows=2 bytes=15 channelLen=0
    clickhouse_test.go:1139: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
    clickhouse.go:114: begin tearing down postgres schema pgch_ajssmaeg
--- FAIL: TestPeerFlowE2ETestSuitePG_CH/Test_Types_CH (31.15s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Types_CH
Stack Traces | 31.2s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Types_CH
=== PAUSE TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Types_CH
=== CONT  TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Types_CH
2026/01/19 03:30:57 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:30:57 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgchcl_xmq8xiks.\"test_json\" ORDER BY id"
2026/01/19 03:30:57 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgchcl_xmq8xiks.\"test_json\" ORDER BY id"
2026/01/19 03:30:57 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_15656209928126666260 CURSOR FOR SELECT id,json,jsonb FROM e2e_test_pgchcl_xmq8xiks.\"test_json\" ORDER BY id" args=[]
2026/01/19 03:30:57 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgchcl_xmq8xiks.\"test_json\" ORDER BY id" channelLen=0
2026/01/19 03:30:57 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15656209928126666260
2026/01/19 03:30:57 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15656209928126666260 records=14 bytes=1516 channelLen=6
2026/01/19 03:30:57 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgchcl_xmq8xiks.\"test_json\" ORDER BY id" rows=14 bytes=1516 channelLen=6
2026/01/19 03:30:57 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15656209928126666260
2026/01/19 03:30:57 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15656209928126666260 records=0 bytes=0 channelLen=0
2026/01/19 03:30:57 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgchcl_xmq8xiks.\"test_json\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:57 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:57 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgchcl_xmq8xiks.\"test_json\" ORDER BY id" rows=14 bytes=1516 channelLen=0
    clickhouse_test.go:1139: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
    clickhouse.go:114: begin tearing down postgres schema pgchcl_5zkkv7cv
--- FAIL: TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Types_CH (31.20s)
github.com/PeerDB-io/peerdb/flow/e2e::TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting
Stack Traces | 33.4s run time
=== RUN   TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting
=== PAUSE TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting
=== CONT  TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting
    generic_test.go:978: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
    bigquery.go:86: begin tearing down postgres schema bq_9jizf7jq_20260117222718
--- FAIL: TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting (33.40s)
github.com/PeerDB-io/peerdb/flow/e2e::TestBigQueryClickhouseSuite/Test_Types
Stack Traces | 186s run time
=== RUN   TestBigQueryClickhouseSuite/Test_Types
=== PAUSE TestBigQueryClickhouseSuite/Test_Types
=== CONT  TestBigQueryClickhouseSuite/Test_Types
2026/01/19 03:28:16 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_b4vjrtwj.test_json
2026/01/19 03:28:16 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_qb6wxhle.test_mysql_ghost_schema
    bigquery_source_test.go:498: ClickHouse database: e2e_test_bqch_y9w9megh
    bigquery_source_test.go:504: Creating test table test_types_pfbp5cw6 with all supported types
2026/01/19 03:28:16 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_mmlokgi3.test_coercion
    bigquery_source_test.go:664: Inserted 3 rows into source table
2026/01/19 03:28:19 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_l5y99wzl.test_my_enum
    bigquery_source_test.go:684: WaitFor all types replicated 2026-01-19 03:28:20.501958462 +0000 UTC m=+366.736681950
2026/01/19 03:28:20 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_ons242bf.test_nullengine
    bigquery_source_test.go:684: code: 60, message: Unknown table expression identifier 'test_types_pfbp5cw6_dst' in scope SELECT id FROM test_types_pfbp5cw6_dst FINAL WHERE _peerdb_is_deleted = 0 ORDER BY 1 ASC SETTINGS use_query_cache = false
2026/01/19 03:28:21 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_60ssd744.test_mysql_schema_changes
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:22 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_mmlokgi3.test_coercion
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:23 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_2hqszz11.test_bit
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:25 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_wim0nt5d.test_blobs
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:27 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_2hqszz11.test_bit
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:34 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_ivckruor.test_exclude_ch
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:41 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_ons242bf.test_nullengine
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:49 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9411178952208870771
2026/01/19 03:28:49 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9411178952208870771 records=1 bytes=152 channelLen=0
2026/01/19 03:28:49 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=1 bytes=152 channelLen=0
2026/01/19 03:28:49 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9411178952208870771
2026/01/19 03:28:49 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9411178952208870771 records=0 bytes=0 channelLen=0
2026/01/19 03:28:49 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:28:49 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:28:49 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=1 bytes=152 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:51 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id"
2026/01/19 03:28:51 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id"
2026/01/19 03:28:51 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_15843774474610737527 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" args=[]
2026/01/19 03:28:51 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15843774474610737527
2026/01/19 03:28:51 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15843774474610737527 records=2 bytes=76 channelLen=1
2026/01/19 03:28:51 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=2 bytes=76 channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15843774474610737527
2026/01/19 03:28:51 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15843774474610737527 records=0 bytes=0 channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:28:51 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=2 bytes=76 channelLen=0
2026/01/19 03:28:51 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id"
2026/01/19 03:28:51 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id"
2026/01/19 03:28:51 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_2205195594892488218 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" args=[]
2026/01/19 03:28:51 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2205195594892488218
2026/01/19 03:28:51 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2205195594892488218 records=1 bytes=152 channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=1 bytes=152 channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2205195594892488218
2026/01/19 03:28:51 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2205195594892488218 records=0 bytes=0 channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:28:51 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:28:51 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=1 bytes=152 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:52 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id"
2026/01/19 03:28:52 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id"
2026/01/19 03:28:52 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10474238234248806480 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" args=[]
2026/01/19 03:28:52 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" channelLen=0
2026/01/19 03:28:52 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10474238234248806480
2026/01/19 03:28:52 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10474238234248806480 records=2 bytes=76 channelLen=1
2026/01/19 03:28:52 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=2 bytes=76 channelLen=1
2026/01/19 03:28:52 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10474238234248806480
2026/01/19 03:28:52 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10474238234248806480 records=0 bytes=0 channelLen=0
2026/01/19 03:28:52 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:28:52 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:28:52 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=2 bytes=76 channelLen=0
2026/01/19 03:28:52 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id"
2026/01/19 03:28:52 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id"
2026/01/19 03:28:52 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16573756068157313421 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" args=[]
2026/01/19 03:28:52 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" channelLen=0
2026/01/19 03:28:52 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16573756068157313421
2026/01/19 03:28:52 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16573756068157313421 records=1 bytes=152 channelLen=0
2026/01/19 03:28:52 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=1 bytes=152 channelLen=0
2026/01/19 03:28:52 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16573756068157313421
2026/01/19 03:28:52 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16573756068157313421 records=0 bytes=0 channelLen=0
2026/01/19 03:28:52 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:28:52 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:28:52 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=1 bytes=152 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:28:55 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id"
2026/01/19 03:28:55 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id"
2026/01/19 03:28:55 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_3917280787386447854 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" args=[]
2026/01/19 03:28:55 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3917280787386447854
2026/01/19 03:28:55 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3917280787386447854 records=2 bytes=76 channelLen=1
2026/01/19 03:28:55 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=2 bytes=76 channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3917280787386447854
2026/01/19 03:28:55 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3917280787386447854 records=0 bytes=0 channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:28:55 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector\" ORDER BY id" rows=2 bytes=76 channelLen=0
2026/01/19 03:28:55 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id"
2026/01/19 03:28:55 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id"
2026/01/19 03:28:55 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17309184603093494417 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" args=[]
2026/01/19 03:28:55 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17309184603093494417
2026/01/19 03:28:55 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17309184603093494417 records=1 bytes=152 channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=1 bytes=152 channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17309184603093494417
2026/01/19 03:28:55 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17309184603093494417 records=0 bytes=0 channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:28:55 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:28:55 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pg_8htg2otq.\"pg_pgvector_dst\" ORDER BY id" rows=1 bytes=152 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:29:17 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:29:37 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_zuvj2fkb' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_zuvj2fkb.resync_failed_api_zuvj2fkb_mv_api_zuvj2fkb%'"
2026/01/19 03:29:37 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_zuvj2fkb' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_zuvj2fkb.resync_failed_api_zuvj2fkb_mv_api_zuvj2fkb%'"
2026/01/19 03:29:37 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_15940574249704029435 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_zuvj2fkb' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_zuvj2fkb.resync_failed_api_zuvj2fkb_mv_api_zuvj2fkb%'" args=[]
2026/01/19 03:29:37 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_zuvj2fkb' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_zuvj2fkb.resync_failed_api_zuvj2fkb_mv_api_zuvj2fkb%'" channelLen=0
2026/01/19 03:29:37 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15940574249704029435
2026/01/19 03:29:37 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15940574249704029435 records=1 bytes=8 channelLen=0
2026/01/19 03:29:37 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_zuvj2fkb' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_zuvj2fkb.resync_failed_api_zuvj2fkb_mv_api_zuvj2fkb%'" rows=1 bytes=8 channelLen=0
2026/01/19 03:29:37 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15940574249704029435
2026/01/19 03:29:37 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15940574249704029435 records=0 bytes=0 channelLen=0
2026/01/19 03:29:37 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_zuvj2fkb' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_zuvj2fkb.resync_failed_api_zuvj2fkb_mv_api_zuvj2fkb%'" rows=0 bytes=0 channelLen=0
2026/01/19 03:29:37 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:29:37 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_zuvj2fkb' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_zuvj2fkb.resync_failed_api_zuvj2fkb_mv_api_zuvj2fkb%'" rows=1 bytes=8 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:29:40 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_wt3h7ong.\"qrepapi_api_wt3h7ong\" ORDER BY id"
2026/01/19 03:29:40 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_wt3h7ong.\"qrepapi_api_wt3h7ong\" ORDER BY id"
2026/01/19 03:29:40 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_3638878522153768008 CURSOR FOR SELECT id,val FROM e2e_test_api_wt3h7ong.\"qrepapi_api_wt3h7ong\" ORDER BY id" args=[]
2026/01/19 03:29:40 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_wt3h7ong.\"qrepapi_api_wt3h7ong\" ORDER BY id" channelLen=0
2026/01/19 03:29:40 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3638878522153768008
2026/01/19 03:29:40 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3638878522153768008 records=1 bytes=9 channelLen=0
2026/01/19 03:29:40 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_wt3h7ong.\"qrepapi_api_wt3h7ong\" ORDER BY id" rows=1 bytes=9 channelLen=0
2026/01/19 03:29:40 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3638878522153768008
2026/01/19 03:29:40 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3638878522153768008 records=0 bytes=0 channelLen=0
2026/01/19 03:29:40 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_wt3h7ong.\"qrepapi_api_wt3h7ong\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:29:40 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:29:40 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_wt3h7ong.\"qrepapi_api_wt3h7ong\" ORDER BY id" rows=1 bytes=9 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:29:42 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id"
2026/01/19 03:29:42 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id"
2026/01/19 03:29:42 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_14667984029195664863 CURSOR FOR SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" args=[]
2026/01/19 03:29:42 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" channelLen=0
2026/01/19 03:29:42 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14667984029195664863
2026/01/19 03:29:42 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14667984029195664863 records=2 bytes=19 channelLen=1
2026/01/19 03:29:42 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:29:42 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14667984029195664863
2026/01/19 03:29:42 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14667984029195664863 records=0 bytes=0 channelLen=0
2026/01/19 03:29:42 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:29:42 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:29:42 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:29:48 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_first%'"
2026/01/19 03:29:48 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_first%'"
2026/01/19 03:29:48 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_13439346175737078576 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_first%'" args=[]
2026/01/19 03:29:48 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_first%'" channelLen=0
2026/01/19 03:29:48 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13439346175737078576
2026/01/19 03:29:48 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13439346175737078576 records=1 bytes=8 channelLen=0
2026/01/19 03:29:48 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_first%'" rows=1 bytes=8 channelLen=0
2026/01/19 03:29:48 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13439346175737078576
2026/01/19 03:29:48 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13439346175737078576 records=0 bytes=0 channelLen=0
2026/01/19 03:29:48 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_first%'" rows=0 bytes=0 channelLen=0
2026/01/19 03:29:48 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:29:48 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_first%'" rows=1 bytes=8 channelLen=0
2026/01/19 03:29:48 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id"
2026/01/19 03:29:48 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id"
2026/01/19 03:29:48 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_13942583091006205200 CURSOR FOR SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" args=[]
2026/01/19 03:29:48 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" channelLen=0
2026/01/19 03:29:48 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13942583091006205200
2026/01/19 03:29:48 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13942583091006205200 records=2 bytes=19 channelLen=1
2026/01/19 03:29:48 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=1
2026/01/19 03:29:48 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13942583091006205200
2026/01/19 03:29:48 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13942583091006205200 records=0 bytes=0 channelLen=0
2026/01/19 03:29:48 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:29:48 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:29:48 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8anjwvg8.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:02 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('double_cancel_test_double_cancel_api_tmdknsjo' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_tmdknsjo.t2_mv_double_cancel_api_tmdknsjo%'"
2026/01/19 03:30:02 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('double_cancel_test_double_cancel_api_tmdknsjo' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_tmdknsjo.t2_mv_double_cancel_api_tmdknsjo%'"
2026/01/19 03:30:02 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_13695236050825163625 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('double_cancel_test_double_cancel_api_tmdknsjo' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_tmdknsjo.t2_mv_double_cancel_api_tmdknsjo%'" args=[]
2026/01/19 03:30:02 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('double_cancel_test_double_cancel_api_tmdknsjo' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_tmdknsjo.t2_mv_double_cancel_api_tmdknsjo%'" channelLen=0
2026/01/19 03:30:02 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13695236050825163625
2026/01/19 03:30:02 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13695236050825163625 records=1 bytes=8 channelLen=0
2026/01/19 03:30:02 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('double_cancel_test_double_cancel_api_tmdknsjo' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_tmdknsjo.t2_mv_double_cancel_api_tmdknsjo%'" rows=1 bytes=8 channelLen=0
2026/01/19 03:30:02 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13695236050825163625
2026/01/19 03:30:02 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13695236050825163625 records=0 bytes=0 channelLen=0
2026/01/19 03:30:02 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('double_cancel_test_double_cancel_api_tmdknsjo' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_tmdknsjo.t2_mv_double_cancel_api_tmdknsjo%'" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:02 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:02 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('double_cancel_test_double_cancel_api_tmdknsjo' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_tmdknsjo.t2_mv_double_cancel_api_tmdknsjo%'" rows=1 bytes=8 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:08 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id"
2026/01/19 03:30:08 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id"
2026/01/19 03:30:08 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_7135460159554949039 CURSOR FOR SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:08 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:08 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7135460159554949039
2026/01/19 03:30:08 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7135460159554949039 records=2 bytes=19 channelLen=1
2026/01/19 03:30:08 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:08 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7135460159554949039
2026/01/19 03:30:08 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7135460159554949039 records=0 bytes=0 channelLen=0
2026/01/19 03:30:08 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:08 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:08 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:10 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_second%'"
2026/01/19 03:30:10 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_second%'"
2026/01/19 03:30:10 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10566904072977662924 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_second%'" args=[]
2026/01/19 03:30:10 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_second%'" channelLen=0
2026/01/19 03:30:10 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10566904072977662924
2026/01/19 03:30:10 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10566904072977662924 records=1 bytes=8 channelLen=0
2026/01/19 03:30:10 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_second%'" rows=1 bytes=8 channelLen=0
2026/01/19 03:30:10 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10566904072977662924
2026/01/19 03:30:10 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10566904072977662924 records=0 bytes=0 channelLen=0
2026/01/19 03:30:10 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_second%'" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:10 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:10 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_dlrjavro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_dlrjavro.t2_mv_second%'" rows=1 bytes=8 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:13 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id"
2026/01/19 03:30:13 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id"
2026/01/19 03:30:13 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_4750818085837671136 CURSOR FOR SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:13 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4750818085837671136
2026/01/19 03:30:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4750818085837671136 records=2 bytes=19 channelLen=1
2026/01/19 03:30:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4750818085837671136
2026/01/19 03:30:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4750818085837671136 records=0 bytes=0 channelLen=0
2026/01/19 03:30:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:13 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:13 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:22 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_0x06vpsj' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_0x06vpsj.t2_mv_first%'"
2026/01/19 03:30:22 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_0x06vpsj' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_0x06vpsj.t2_mv_first%'"
2026/01/19 03:30:22 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_3589665201815600034 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_0x06vpsj' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_0x06vpsj.t2_mv_first%'" args=[]
2026/01/19 03:30:22 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_0x06vpsj' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_0x06vpsj.t2_mv_first%'" channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3589665201815600034
2026/01/19 03:30:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3589665201815600034 records=1 bytes=8 channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_0x06vpsj' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_0x06vpsj.t2_mv_first%'" rows=1 bytes=8 channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3589665201815600034
2026/01/19 03:30:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3589665201815600034 records=0 bytes=0 channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_0x06vpsj' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_0x06vpsj.t2_mv_first%'" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:22 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_0x06vpsj' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_0x06vpsj.t2_mv_first%'" rows=1 bytes=8 channelLen=0
2026/01/19 03:30:22 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id"
2026/01/19 03:30:22 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id"
2026/01/19 03:30:22 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16009141009374601452 CURSOR FOR SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:22 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16009141009374601452
2026/01/19 03:30:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16009141009374601452 records=2 bytes=19 channelLen=1
2026/01/19 03:30:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16009141009374601452
2026/01/19 03:30:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16009141009374601452 records=0 bytes=0 channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:22 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:22 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_tmdknsjo.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:25 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id"
2026/01/19 03:30:25 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id"
2026/01/19 03:30:25 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_9754758733300283708 CURSOR FOR SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" args=[]
2026/01/19 03:30:25 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" channelLen=0
2026/01/19 03:30:25 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9754758733300283708
2026/01/19 03:30:25 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9754758733300283708 records=2 bytes=19 channelLen=1
2026/01/19 03:30:25 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:25 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9754758733300283708
2026/01/19 03:30:25 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9754758733300283708 records=0 bytes=0 channelLen=0
2026/01/19 03:30:25 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:25 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:25 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:28 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id"
2026/01/19 03:30:28 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id"
2026/01/19 03:30:28 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_7713093308086944428 CURSOR FOR SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" args=[]
2026/01/19 03:30:28 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" channelLen=0
2026/01/19 03:30:28 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7713093308086944428
2026/01/19 03:30:28 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7713093308086944428 records=2 bytes=19 channelLen=1
2026/01/19 03:30:28 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:28 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7713093308086944428
2026/01/19 03:30:28 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7713093308086944428 records=0 bytes=0 channelLen=0
2026/01/19 03:30:28 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:28 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:28 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_psys9e5x.\"original\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:28 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_t1dkbw3g.test_update_pkey_enabled
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:32 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_normal_api_a5hcz2zl' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_a5hcz2zl.t5_mv_api_a5hcz2zl%'"
2026/01/19 03:30:32 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_normal_api_a5hcz2zl' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_a5hcz2zl.t5_mv_api_a5hcz2zl%'"
2026/01/19 03:30:33 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17332095475050853650 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_normal_api_a5hcz2zl' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_a5hcz2zl.t5_mv_api_a5hcz2zl%'" args=[]
2026/01/19 03:30:33 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_normal_api_a5hcz2zl' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_a5hcz2zl.t5_mv_api_a5hcz2zl%'" channelLen=0
2026/01/19 03:30:33 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17332095475050853650
2026/01/19 03:30:33 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17332095475050853650 records=1 bytes=8 channelLen=0
2026/01/19 03:30:33 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_normal_api_a5hcz2zl' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_a5hcz2zl.t5_mv_api_a5hcz2zl%'" rows=1 bytes=8 channelLen=0
2026/01/19 03:30:33 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17332095475050853650
2026/01/19 03:30:33 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17332095475050853650 records=0 bytes=0 channelLen=0
2026/01/19 03:30:33 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_normal_api_a5hcz2zl' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_a5hcz2zl.t5_mv_api_a5hcz2zl%'" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:33 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:33 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_normal_api_a5hcz2zl' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_a5hcz2zl.t5_mv_api_a5hcz2zl%'" rows=1 bytes=8 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:35 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_ltxizluq.test_unsigned
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:38 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_ltxizluq.test_unsigned
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:39 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id"
2026/01/19 03:30:39 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id"
2026/01/19 03:30:39 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_12735387287772135610 CURSOR FOR SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:39 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:39 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12735387287772135610
2026/01/19 03:30:39 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12735387287772135610 records=2 bytes=19 channelLen=1
2026/01/19 03:30:39 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:39 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12735387287772135610
2026/01/19 03:30:39 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12735387287772135610 records=0 bytes=0 channelLen=0
2026/01/19 03:30:39 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:39 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:39 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:41 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id"
2026/01/19 03:30:41 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id"
2026/01/19 03:30:41 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_14018465791866344528 CURSOR FOR SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:41 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:41 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14018465791866344528
2026/01/19 03:30:41 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14018465791866344528 records=2 bytes=19 channelLen=1
2026/01/19 03:30:41 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:41 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14018465791866344528
2026/01/19 03:30:41 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14018465791866344528 records=0 bytes=0 channelLen=0
2026/01/19 03:30:41 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:41 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:41 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:43 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id"
2026/01/19 03:30:43 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id"
2026/01/19 03:30:43 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_9378075601949508880 CURSOR FOR SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:43 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:43 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9378075601949508880
2026/01/19 03:30:43 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9378075601949508880 records=2 bytes=19 channelLen=1
2026/01/19 03:30:43 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:43 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9378075601949508880
2026/01/19 03:30:43 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9378075601949508880 records=0 bytes=0 channelLen=0
2026/01/19 03:30:43 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:43 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:43 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_a5hcz2zl.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:44 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id"
2026/01/19 03:30:44 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id"
2026/01/19 03:30:44 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17336044475110601969 CURSOR FOR SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:44 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:44 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17336044475110601969
2026/01/19 03:30:44 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17336044475110601969 records=2 bytes=19 channelLen=1
2026/01/19 03:30:44 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=1
2026/01/19 03:30:44 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17336044475110601969
2026/01/19 03:30:44 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17336044475110601969 records=0 bytes=0 channelLen=0
2026/01/19 03:30:44 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:44 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:44 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:45 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id"
2026/01/19 03:30:45 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id"
2026/01/19 03:30:45 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10567498398904370119 CURSOR FOR SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" args=[]
2026/01/19 03:30:45 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" channelLen=0
2026/01/19 03:30:45 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10567498398904370119
2026/01/19 03:30:45 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10567498398904370119 records=3 bytes=38 channelLen=2
2026/01/19 03:30:45 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" rows=3 bytes=38 channelLen=0
2026/01/19 03:30:45 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10567498398904370119
2026/01/19 03:30:45 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10567498398904370119 records=0 bytes=0 channelLen=0
2026/01/19 03:30:45 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:45 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:45 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" rows=3 bytes=38 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:47 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id"
2026/01/19 03:30:47 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id"
2026/01/19 03:30:47 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_2890216078257266913 CURSOR FOR SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:47 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:47 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2890216078257266913
2026/01/19 03:30:47 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2890216078257266913 records=2 bytes=19 channelLen=1
2026/01/19 03:30:47 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=1
2026/01/19 03:30:47 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2890216078257266913
2026/01/19 03:30:47 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2890216078257266913 records=0 bytes=0 channelLen=0
2026/01/19 03:30:47 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:47 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:47 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:49 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id"
2026/01/19 03:30:49 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id"
2026/01/19 03:30:49 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10420826887385290062 CURSOR FOR SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" args=[]
2026/01/19 03:30:49 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" channelLen=0
2026/01/19 03:30:49 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10420826887385290062
2026/01/19 03:30:49 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10420826887385290062 records=3 bytes=38 channelLen=2
2026/01/19 03:30:49 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" rows=3 bytes=38 channelLen=0
2026/01/19 03:30:49 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10420826887385290062
2026/01/19 03:30:49 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10420826887385290062 records=0 bytes=0 channelLen=0
2026/01/19 03:30:49 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:49 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:49 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_g8mlr46g.\"added\" ORDER BY id" rows=3 bytes=38 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:50 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id"
2026/01/19 03:30:50 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id"
2026/01/19 03:30:50 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_4975556699977947224 CURSOR FOR SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:50 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4975556699977947224
2026/01/19 03:30:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4975556699977947224 records=2 bytes=19 channelLen=1
2026/01/19 03:30:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4975556699977947224
2026/01/19 03:30:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4975556699977947224 records=0 bytes=0 channelLen=0
2026/01/19 03:30:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:50 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:50 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_hkmvyrwn.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:51 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_tliawacd.test_nullable_sc_ch
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:57 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0x06vpsj.\"t1\" ORDER BY id"
2026/01/19 03:30:57 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0x06vpsj.\"t1\" ORDER BY id"
2026/01/19 03:30:57 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_3907990055743215777 CURSOR FOR SELECT id,val FROM e2e_test_api_0x06vpsj.\"t1\" ORDER BY id" args=[]
2026/01/19 03:30:57 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0x06vpsj.\"t1\" ORDER BY id" channelLen=0
2026/01/19 03:30:57 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3907990055743215777
2026/01/19 03:30:57 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3907990055743215777 records=2 bytes=19 channelLen=1
2026/01/19 03:30:57 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0x06vpsj.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/01/19 03:30:57 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3907990055743215777
2026/01/19 03:30:57 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3907990055743215777 records=0 bytes=0 channelLen=0
2026/01/19 03:30:57 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0x06vpsj.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/01/19 03:30:57 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/01/19 03:30:57 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0x06vpsj.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:30:59 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_tiu0rxat.test_mysql_schema_changes
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:00 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_w18dkjcl.test_vector
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:02 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_tiu0rxat.test_mysql_schema_changes
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:03 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_w18dkjcl.test_vector
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:06 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_w18dkjcl.test_vector
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:11 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_tiu0rxat.test_mysql_schema_changes
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:12 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_hjgwx8yx.test_mysql_ghost_schema
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:14 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_tiu0rxat.test_mysql_schema_changes
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:15 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_n8j1vzh0.test_json
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:17 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_tiu0rxat.test_mysql_schema_changes
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:18 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_n8j1vzh0.test_json
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
2026/01/19 03:31:20 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_n6tzx0x2.test_blobs
2026/01/19 03:31:20 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_ozv3yjc8.test_coercion
    bigquery_source_test.go:684: q.NumRecords: 3
    bigquery_source_test.go:684: other.NumRecords: 0
    bigquery_source_test.go:684: UNEXPECTED TIMEOUT all types replicated 2026-01-19 03:31:21.746936758 +0000 UTC m=+547.981660244
2026/01/19 03:31:21 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_n8j1vzh0.test_json
--- FAIL: TestBigQueryClickhouseSuite/Test_Types (185.67s)
View the full list of 2 ❄️ flaky test(s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time_BackwardCompatibility

Flake rate in main: 100.00% (Passed 0 times, Failed 6 times)

Stack Traces | 31.1s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time_BackwardCompatibility
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time_BackwardCompatibility
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time_BackwardCompatibility
2026/01/19 03:29:55 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:29:55 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/01/19 03:29:55 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_wvnljigv.test_schema_as_column
    clickhouse_mysql_test.go:182: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH/Test_MySQL_Time_BackwardCompatibility (31.08s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time_BackwardCompatibility

Flake rate in main: 100.00% (Passed 0 times, Failed 6 times)

Stack Traces | 31.1s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time_BackwardCompatibility
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time_BackwardCompatibility
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time_BackwardCompatibility
2026/01/19 03:27:41 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    clickhouse_mysql_test.go:182: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_MySQL_Time_BackwardCompatibility (31.13s)

To view more test analytics, go to the Test Analytics Dashboard
📋 Got 3 mins? Take this short survey to help us improve Test Analytics.

@jgao54 jgao54 force-pushed the TIME64 branch 11 times, most recently from f9e2eb2 to 3eb10eb Compare January 19, 2026 11:07
@jgao54 jgao54 changed the title [test] revert-revert 'adding support of TIME64 datatype' Adding support of TIME64 datatype (attempt 2) Jan 21, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants