You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2018/02/06 19:03:06 UTC
[06/28] flink git commit: [hotfix] [kafka] Make
AbortedReassignmentException a static class
[hotfix] [kafka] Make AbortedReassignmentException a static class
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a951852f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a951852f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a951852f
Branch: refs/heads/release-1.4
Commit: a951852fb4a2059cbd2c23659e7b456691639873
Parents: 0816300
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
Authored: Sat Jan 13 20:35:03 2018 +0800
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Tue Feb 6 17:31:32 2018 +0100
----------------------------------------------------------------------
.../streaming/connectors/kafka/internal/KafkaConsumerThread.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a951852f/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java b/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
index c462b26..ee0a63b 100644
--- a/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
+++ b/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
@@ -505,7 +505,7 @@ public class KafkaConsumerThread extends Thread {
* Utility exception that serves as a signal for the main loop to continue through the loop
* if a reassignment attempt was aborted due to an pre-reassignment wakeup call on the consumer.
*/
- private class AbortedReassignmentException extends Exception {
+ private static class AbortedReassignmentException extends Exception {
private static final long serialVersionUID = 1L;
}
}