JLDLaughlin

from airflow.contrib.hooks.gcs_hook import GoogleCloudStorageHook
from airflow.exceptions import AirflowException
from airflow.hooks.http_hook import HttpHook
from airflow.models import BaseOperator
from airflow.utils.decorators import apply_defaults
import json
import time


class AppEngineOperator(BaseOperator):

JLDLaughlin

2020-09-03 14:50:39.705 EDT,"root","jessicalaughlin",82223,"127.0.0.1:54813",5f513aff.1412f,1,"startup",2020-09-03 14:50:39 EDT,4/853,0,FATAL,28000,"role ""root"" does not exist",,,,,,,,,""
2020-09-03 14:50:39.813 EDT,"root","jessicalaughlin",82224,"127.0.0.1:54814",5f513aff.14130,1,"startup",2020-09-03 14:50:39 EDT,4/854,0,FATAL,28000,"role ""root"" does not exist",,,,,,,,,""
2020-09-03 14:52:46.870 EDT,"jessicalaughlin","jessicalaughlin",62561,"[local]",5f500d7b.f461,4,"idle",2020-09-02 17:24:11 EDT,3/5,0,ERROR,42601,"syntax error at or near ""/""",,,,,,"/conninfo
;",1,,"psql"
2020-09-03 14:52:48.086 EDT,"jessicalaughlin","jessicalaughlin",62561,"[local]",5f500d7b.f461,5,"idle",2020-09-02 17:24:11 EDT,3/6,0,LOG,00000,"statement: ;",,,,,,,,,"psql"
2020-09-03 14:52:56.177 EDT,"jessicalaughlin","jessicalaughlin",62561,"[local]",5f500d7b.f461,6,"idle",2020-09-02 17:24:11 EDT,3/7,0,LOG,00000,"statement: select current_user;",,,,,,,,,"psql"
2020-09-03 14:53:06.367 EDT,"jessicalaughlin","jessicalaughlin",82255,"12

JLDLaughlin

diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresOffsetContext.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresOffsetContext.java
index 15c2af574..a7b76aebd 100644
--- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresOffsetContext.java
+++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresOffsetContext.java
@@ -52,7 +52,7 @@ private PostgresOffsetContext(PostgresConnectorConfig connectorConfig, Lsn lsn,
 
         this.lastCompletelyProcessedLsn = lastCompletelyProcessedLsn;
         this.lastCommitLsn = lastCommitLsn;
-        sourceInfo.update(lsn, time, txId, null, sourceInfo.xmin());
+        sourceInfo.update(lsn, time, txId, null, sourceInfo.xmin(), lastCommitLsn);