We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 982459b commit 42d163cCopy full SHA for 42d163c
python/pyspark/streaming/tests.py
@@ -1409,7 +1409,6 @@ def test_kinesis_stream_api(self):
1409
InitialPositionInStream.LATEST, 2, StorageLevel.MEMORY_AND_DISK_2,
1410
"awsAccessKey", "awsSecretKey")
1411
1412
- @unittest.skip("Enable it when we fix SPAKR-12058")
1413
def test_kinesis_stream(self):
1414
if not are_kinesis_tests_enabled:
1415
sys.stderr.write(
0 commit comments