ashishmgofficial commented on issue #2149:
URL: https://github.com/apache/hudi/issues/2149#issuecomment-706123886
Following the Kafka data as consumed using Kafkacat
```
{"before": null, "after": {"Value": {"inc_id": 1, "year": {"int": 2016},
"violation_desc": {"string": "DRIVING WHILE INTOXICATED"}, "violation_code":
{"string": "11923"}, "case_individual_id": {"int": 17475366}, "flag":
{"string": "I"}, "last_modified_ts": 1600945380000000}}, "source": {"version":
"1.2.2.Final", "connector": "postgresql", "name": "airflow", "ts_ms":
1601531771650, "snapshot": {"string": "true"}, "db": "airflow", "schema":
"public", "table": "motor_crash_violation_incidents", "txId": {"long":
8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r", "ts_ms":
{"long": 1601531771650}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 3, "year": {"int": 2016},
"violation_desc": {"string": "AGGRAVATED UNLIC OPER 2ND/PREV CONV"},
"violation_code": {"string": "5112A1"}, "case_individual_id": {"int":
17475367}, "flag": {"string": "U"}, "last_modified_ts": 1600959600000000}},
"source": {"version": "1.2.2.Final", "connector": "postgresql", "name":
"airflow", "ts_ms": 1601531771650, "snapshot": {"string": "true"}, "db":
"airflow", "schema": "public", "table": "motor_crash_violation_incidents",
"txId": {"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op":
"r", "ts_ms": {"long": 1601531771650}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 4, "year": {"int": 2019},
"violation_desc": {"string": "AGGRAVATED UNLIC OPER 2ND/PREV"},
"violation_code": {"string": "5112A2"}, "case_individual_id": {"int":
17475368}, "flag": {"string": "I"}, "last_modified_ts": 1569337200000000}},
"source": {"version": "1.2.2.Final", "connector": "postgresql", "name":
"airflow", "ts_ms": 1601531771650, "snapshot": {"string": "true"}, "db":
"airflow", "schema": "public", "table": "motor_crash_violation_incidents",
"txId": {"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op":
"r", "ts_ms": {"long": 1601531771650}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 5, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475569},
"flag": {"string": "I"}, "last_modified_ts": 1601374200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771651, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771651}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 7, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475571},
"flag": {"string": "I"}, "last_modified_ts": 1601375400000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771651, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771651}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 2, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "2180F"}, "case_individual_id": {"int": 17475569},
"flag": {"string": "U"}, "last_modified_ts": 1601377200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771651, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771651}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 6, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "2180F"}, "case_individual_id": {"int": 17475570},
"flag": {"string": "I"}, "last_modified_ts": 1601374800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771651, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771651}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 8, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475572},
"flag": {"string": "I"}, "last_modified_ts": 1601376600000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771651, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771651}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 9, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475573},
"flag": {"string": "I"}, "last_modified_ts": 1601377200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771652, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771652}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 10, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180D"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601377800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771652, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771652}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 11, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180D"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601381400000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771652, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771652}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 12, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601385000000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771652, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771652}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 13, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601388600000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771652, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771652}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 34, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601392200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531771652, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8853671}, "lsn": {"long": 135217816}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601531771653}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 35, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601395800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601531913118, "snapshot": {"string": "false"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8854199}, "lsn": {"long": 135339584}, "xmin": null}, "op": "c",
"ts_ms": {"long": 1601531913459}, "transaction": {"ConnectDefault": {"id":
"8854199", "total_order": 1, "data_collection_order": 1}}}
{"before": null, "after": {"Value": {"inc_id": 1, "year": {"int": 2016},
"violation_desc": {"string": "DRIVING WHILE INTOXICATED"}, "violation_code":
{"string": "11923"}, "case_individual_id": {"int": 17475366}, "flag":
{"string": "I"}, "last_modified_ts": 1600945380000000}}, "source": {"version":
"1.2.2.Final", "connector": "postgresql", "name": "airflow", "ts_ms":
1601532941011, "snapshot": {"string": "true"}, "db": "airflow", "schema":
"public", "table": "motor_crash_violation_incidents", "txId": {"long":
8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r", "ts_ms":
{"long": 1601532941011}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 3, "year": {"int": 2016},
"violation_desc": {"string": "AGGRAVATED UNLIC OPER 2ND/PREV CONV"},
"violation_code": {"string": "5112A1"}, "case_individual_id": {"int":
17475367}, "flag": {"string": "U"}, "last_modified_ts": 1600959600000000}},
"source": {"version": "1.2.2.Final", "connector": "postgresql", "name":
"airflow", "ts_ms": 1601532941011, "snapshot": {"string": "true"}, "db":
"airflow", "schema": "public", "table": "motor_crash_violation_incidents",
"txId": {"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op":
"r", "ts_ms": {"long": 1601532941011}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 4, "year": {"int": 2019},
"violation_desc": {"string": "AGGRAVATED UNLIC OPER 2ND/PREV"},
"violation_code": {"string": "5112A2"}, "case_individual_id": {"int":
17475368}, "flag": {"string": "I"}, "last_modified_ts": 1569337200000000}},
"source": {"version": "1.2.2.Final", "connector": "postgresql", "name":
"airflow", "ts_ms": 1601532941011, "snapshot": {"string": "true"}, "db":
"airflow", "schema": "public", "table": "motor_crash_violation_incidents",
"txId": {"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op":
"r", "ts_ms": {"long": 1601532941012}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 5, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475569},
"flag": {"string": "I"}, "last_modified_ts": 1601374200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941012, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941012}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 7, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475571},
"flag": {"string": "I"}, "last_modified_ts": 1601375400000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941012, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941012}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 2, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "2180F"}, "case_individual_id": {"int": 17475569},
"flag": {"string": "U"}, "last_modified_ts": 1601377200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941012, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941012}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 6, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "2180F"}, "case_individual_id": {"int": 17475570},
"flag": {"string": "I"}, "last_modified_ts": 1601374800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941012, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941012}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 8, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475572},
"flag": {"string": "I"}, "last_modified_ts": 1601376600000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941012, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941012}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 9, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475573},
"flag": {"string": "I"}, "last_modified_ts": 1601377200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941013, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941013}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 10, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180D"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601377800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941013, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941013}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 11, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180D"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601381400000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941013, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941013}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 12, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601385000000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941013, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941013}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 13, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601388600000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941013, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941013}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 34, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601392200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941013, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941013}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 35, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601395800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601532941013, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858001}, "lsn": {"long": 136229808}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601532941013}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 36, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601398800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601533208794, "snapshot": {"string": "false"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 8858996}, "lsn": {"long": 136463936}, "xmin": null}, "op": "c",
"ts_ms": {"long": 1601533208915}, "transaction": {"ConnectDefault": {"id":
"8858996", "total_order": 1, "data_collection_order": 1}}}
{"before": null, "after": {"Value": {"inc_id": 1, "year": {"int": 2016},
"violation_desc": {"string": "DRIVING WHILE INTOXICATED"}, "violation_code":
{"string": "11923"}, "case_individual_id": {"int": 17475366}, "flag":
{"string": "I"}, "last_modified_ts": 1600945380000000}}, "source": {"version":
"1.2.2.Final", "connector": "postgresql", "name": "airflow", "ts_ms":
1601985963857, "snapshot": {"string": "true"}, "db": "airflow", "schema":
"public", "table": "motor_crash_violation_incidents", "txId": {"long":
10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r", "ts_ms":
{"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 3, "year": {"int": 2016},
"violation_desc": {"string": "AGGRAVATED UNLIC OPER 2ND/PREV CONV"},
"violation_code": {"string": "5112A1"}, "case_individual_id": {"int":
17475367}, "flag": {"string": "U"}, "last_modified_ts": 1600959600000000}},
"source": {"version": "1.2.2.Final", "connector": "postgresql", "name":
"airflow", "ts_ms": 1601985963857, "snapshot": {"string": "true"}, "db":
"airflow", "schema": "public", "table": "motor_crash_violation_incidents",
"txId": {"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op":
"r", "ts_ms": {"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 4, "year": {"int": 2019},
"violation_desc": {"string": "AGGRAVATED UNLIC OPER 2ND/PREV"},
"violation_code": {"string": "5112A2"}, "case_individual_id": {"int":
17475368}, "flag": {"string": "I"}, "last_modified_ts": 1569337200000000}},
"source": {"version": "1.2.2.Final", "connector": "postgresql", "name":
"airflow", "ts_ms": 1601985963857, "snapshot": {"string": "true"}, "db":
"airflow", "schema": "public", "table": "motor_crash_violation_incidents",
"txId": {"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op":
"r", "ts_ms": {"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 5, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475569},
"flag": {"string": "I"}, "last_modified_ts": 1601374200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963857, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 7, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475571},
"flag": {"string": "I"}, "last_modified_ts": 1601375400000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963857, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 2, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "2180F"}, "case_individual_id": {"int": 17475569},
"flag": {"string": "U"}, "last_modified_ts": 1601377200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963857, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 6, "year": {"int": 2018},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "2180F"}, "case_individual_id": {"int": 17475570},
"flag": {"string": "I"}, "last_modified_ts": 1601374800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963857, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 8, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475572},
"flag": {"string": "I"}, "last_modified_ts": 1601376600000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963857, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 9, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475573},
"flag": {"string": "I"}, "last_modified_ts": 1601377200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963857, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963857}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 10, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180D"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601377800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963858, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963858}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 11, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180D"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601381400000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963858, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963858}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 12, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601385000000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963858, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963858}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 13, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601388600000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963858, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963858}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 34, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601392200000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963858, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963858}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 35, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601395800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963858, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963858}, "transaction": null}
{"before": null, "after": {"Value": {"inc_id": 36, "year": {"int": 2020},
"violation_desc": {"string": "UNREASONABLE SPEED/SPECIAL HAZARDS"},
"violation_code": {"string": "1180E"}, "case_individual_id": {"int": 17475574},
"flag": {"string": "I"}, "last_modified_ts": 1601398800000000}}, "source":
{"version": "1.2.2.Final", "connector": "postgresql", "name": "airflow",
"ts_ms": 1601985963858, "snapshot": {"string": "true"}, "db": "airflow",
"schema": "public", "table": "motor_crash_violation_incidents", "txId":
{"long": 10537240}, "lsn": {"long": 529139832}, "xmin": null}, "op": "r",
"ts_ms": {"long": 1601985963858}, "transaction": null}
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
