Skip to content

Commit 5415389

Browse files
committed
Fixed syntax error for test_batch_info_reports
1 parent 9e4e04a commit 5415389

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

python/pyspark/streaming/tests.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -444,15 +444,15 @@ def func(dstream):
444444
self.assertEqual(len(batchInfosSubmitted), 4)
445445
for info in batchInfosSubmitted:
446446

447-
self.assertEqual(info.schedulingDelay(), -1L)
448-
self.assertEqual(info.processingDelay(), -1L)
449-
self.assertEqual(info.totalDelay(), -1L)
447+
self.assertEqual(info.schedulingDelay(), -1)
448+
self.assertEqual(info.processingDelay(), -1)
449+
self.assertEqual(info.totalDelay(), -1)
450450

451451
self.assertEqual(len(batchInfosStarted), 4)
452452
for info in batchInfosStarted:
453453
self.assertGreaterEqual(info.schedulingDelay(), 0)
454-
self.assertEqual(info.processingDelay(), -1L)
455-
self.assertEqual(info.totalDelay(), -1L)
454+
self.assertEqual(info.processingDelay(), -1)
455+
self.assertEqual(info.totalDelay(), -1)
456456

457457
self.assertEqual(len(batchInfosCompleted), 4)
458458

0 commit comments

Comments
 (0)