File tree 1 file changed +0
-21
lines changed
1 file changed +0
-21
lines changed Original file line number Diff line number Diff line change @@ -1713,13 +1713,6 @@ def test_serialize_to_avro(self, mocker):
1713
1713
# Arrange
1714
1714
spark_engine = spark .Engine ()
1715
1715
1716
- spark_engine ._spark_session .stop ()
1717
-
1718
- spark_engine ._spark_session = SparkSession .builder \
1719
- .master ("local[*]" ) \
1720
- .config ("spark.jars.packages" , "org.apache.spark:spark-avro_2.12:3.1.1" ) \
1721
- .getOrCreate ()
1722
-
1723
1716
now = datetime .datetime .now ()
1724
1717
1725
1718
fg_data = []
@@ -1764,13 +1757,6 @@ def test_deserialize_from_avro(self, mocker):
1764
1757
# Arrange
1765
1758
spark_engine = spark .Engine ()
1766
1759
1767
- spark_engine ._spark_session .stop ()
1768
-
1769
- spark_engine ._spark_session = SparkSession .builder \
1770
- .master ("local[*]" ) \
1771
- .config ("spark.jars.packages" , "org.apache.spark:spark-avro_2.12:3.1.1" ) \
1772
- .getOrCreate ()
1773
-
1774
1760
data = []
1775
1761
data .append ((b"2121" , b"21212121" ))
1776
1762
data .append ((b"1212" , b"12121212" ))
@@ -1813,13 +1799,6 @@ def test_serialize_deserialize_avro(self, mocker):
1813
1799
# Arrange
1814
1800
spark_engine = spark .Engine ()
1815
1801
1816
- spark_engine ._spark_session .stop ()
1817
-
1818
- spark_engine ._spark_session = SparkSession .builder \
1819
- .master ("local[*]" ) \
1820
- .config ("spark.jars.packages" , "org.apache.spark:spark-avro_2.12:3.1.1" ) \
1821
- .getOrCreate ()
1822
-
1823
1802
now = datetime .datetime .now ()
1824
1803
1825
1804
fg_data = []
You can’t perform that action at this time.
0 commit comments