caiconghui has posted comments on this change.
Change subject: feat: add the wrapper for the Iterator by using
InterruptibleIterator
......................................................................
Patch Set 2:
@Dan Burkert I cannot find the appropriate api for canceling task or killing
task, to simulate killing job for webui such as
test("kill task") {
insertRows(100)
val rdd = kuduContext.kuduRDD(sc, tableName, List("key"))
try {
rdd.foreachPartition(iterator =>
while (iterator.hasNext) {
//ToDo
// task kill api
iterator.next()
}
)
} catch {
case _: TaskKilledException => // good
case NonFatal(_) =>
fail("kill job should throw TaskKilledOperationException")
}
}
--
To view, visit http://gerrit.cloudera.org:8080/7753
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I0b4284f2c0a40cd7ba8cf2b76e0403592552c814
Gerrit-PatchSet: 2
Gerrit-Project: kudu
Gerrit-Branch: master
Gerrit-Owner: caiconghui <[email protected]>
Gerrit-Reviewer: Dan Burkert <[email protected]>
Gerrit-Reviewer: Kudu Jenkins
Gerrit-Reviewer: Todd Lipcon <[email protected]>
Gerrit-Reviewer: caiconghui <[email protected]>
Gerrit-HasComments: No
