remove custom endpoint

brkyvz · brkyvz · commit 5f7a763fe1bd · 2015-11-03T12:34:47.000-08:00
diff --git a/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisTestUtils.scala b/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisTestUtils.scala
@@ -71,7 +71,6 @@ private[kinesis] class KinesisTestUtils extends Logging {
       .setRecordMaxBufferedTime(2000)
       .setMaxConnections(1)
       .setRegion(regionName)
-      .setCustomEndpoint(endpointUrl)
 
     new KinesisProducer(conf)
   }

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,6 @@ private[kinesis] class KinesisTestUtils extends Logging {`
`71`	`71`	`.setRecordMaxBufferedTime(2000)`
`72`	`72`	`.setMaxConnections(1)`
`73`	`73`	`.setRegion(regionName)`
`74`		`- .setCustomEndpoint(endpointUrl)`
`75`	`74`
`76`	`75`	`new KinesisProducer(conf)`
`77`	`76`	`}`