Skip to content

Commit eee602b

Browse files
committed
improve ctid class
1 parent 8939a02 commit eee602b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/PostgresSourceJdbcStreamState.kt

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ class PostgresSourceJdbcStreamState(val base: DefaultJdbcStreamState) :
3434
partition: JdbcPartition<*>,
3535
jdbcConnectionFactory: JdbcConnectionFactory
3636
) {
37-
val filenode: Filenode? = when (partition) {
37+
val savedFilenode: Filenode? = when (partition) {
3838
is PostgresSourceJdbcSplittableSnapshotPartition -> partition.filenode
3939
is PostgresSourceJdbcSplittableSnapshotWithCursorPartition -> partition.filenode
4040
else -> null
@@ -44,9 +44,9 @@ class PostgresSourceJdbcStreamState(val base: DefaultJdbcStreamState) :
4444
jdbcConnectionFactory
4545
)
4646

47-
if (currentFilenode != filenode) {
47+
if (currentFilenode != savedFilenode) {
4848
throw TransientErrorException(
49-
"Full vacuum on table ${partition.streamState.stream.id} detected. Filenode changed from ${filenode} to $currentFilenode"
49+
"Full vacuum on table ${partition.streamState.stream.id} detected. Filenode changed from ${savedFilenode} to $currentFilenode"
5050
)
5151
}
5252
}

0 commit comments

Comments
 (0)