Skip to content

Commit 73fdf09

Browse files
authored
Merge pull request #3129 from kisimple/Hotfix-TridentState
MINOR: Fix a broken link in Trident-state.md
2 parents 74958a6 + 9611243 commit 73fdf09

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

docs/Trident-state.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ Remember, Trident processes tuples as small batches with each batch being given
2828
2. There's no overlap between batches of tuples (tuples are in one batch or another, never multiple).
2929
3. Every tuple is in a batch (no tuples are skipped)
3030

31-
This is a pretty easy type of spout to understand, the stream is divided into fixed batches that never change. Storm has [an implementation of a transactional spout]({{page.git-tree-base}}/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutTransactional) for Kafka.
31+
This is a pretty easy type of spout to understand, the stream is divided into fixed batches that never change. Storm has [an implementation of a transactional spout]({{page.git-tree-base}}/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutTransactional.java) for Kafka.
3232

3333
You might be wondering – why wouldn't you just always use a transactional spout? They're simple and easy to understand. One reason you might not use one is because they're not necessarily very fault-tolerant. For example, the way TransactionalTridentKafkaSpout works is the batch for a txid will contain tuples from all the Kafka partitions for a topic. Once a batch has been emitted, any time that batch is re-emitted in the future the exact same set of tuples must be emitted to meet the semantics of transactional spouts. Now suppose a batch is emitted from TransactionalTridentKafkaSpout, the batch fails to process, and at the same time one of the Kafka nodes goes down. You're now incapable of replaying the same batch as you did before (since the node is down and some partitions for the topic are not unavailable), and processing will halt.
3434

0 commit comments

Comments
 (0)