Jessica Laughlin JLDLaughlin
JLDLaughlin
/ sequence.patch
Last active
February 26, 2021 15:52
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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); |
JLDLaughlin
/ hasura_postgres_connection_logs.csv
Created
September 3, 2020 18:58
We can make this file beautiful and searchable if this error is corrected: Unclosed quoted field in line 6.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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): |