duplicated block id: 1
size: 10 cleaned lines of code
in 2 files:
 - pyspark-sdk/integration_test/BatchIngestionTest.py (122:131)
 - pyspark-sdk/integration_test/BatchIngestionTest.py (177:186)

duplicated block id: 2
size: 7 cleaned lines of code
in 2 files:
 - pyspark-sdk/integration_test/BatchIngestionTest.py (166:172)
 - pyspark-sdk/integration_test/BatchIngestionTest.py (211:217)