You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by yz...@apache.org on 2015/07/03 02:55:59 UTC
[50/50] incubator-ignite git commit: # minor format (review)
# minor format (review)
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/a33e548e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/a33e548e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/a33e548e
Branch: refs/heads/ignite-428
Commit: a33e548eb50c4574c87e2864d2cfcc74b49cda69
Parents: 845722b
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Thu Jul 2 17:54:58 2015 -0700
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Thu Jul 2 17:54:58 2015 -0700
----------------------------------------------------------------------
modules/kafka/pom.xml | 3 ++-
.../main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java | 5 +++--
2 files changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a33e548e/modules/kafka/pom.xml
----------------------------------------------------------------------
diff --git a/modules/kafka/pom.xml b/modules/kafka/pom.xml
index 43909bc..2d7810a 100644
--- a/modules/kafka/pom.xml
+++ b/modules/kafka/pom.xml
@@ -20,7 +20,8 @@
<!--
POM file.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a33e548e/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java
----------------------------------------------------------------------
diff --git a/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java b/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java
index bc618e3..1316c03 100644
--- a/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java
+++ b/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java
@@ -193,9 +193,10 @@ public class KafkaStreamer<T, K, V> extends StreamAdapter<T, K, V> {
executor.shutdown();
try {
- if (!executor.awaitTermination(5000, TimeUnit.MILLISECONDS))
+ if (!executor.awaitTermination(5000, TimeUnit.MILLISECONDS)) {
if (log.isDebugEnabled())
log.debug("Timed out waiting for consumer threads to shut down, exiting uncleanly");
+ }
}
catch (InterruptedException e) {
if (log.isDebugEnabled())
@@ -203,4 +204,4 @@ public class KafkaStreamer<T, K, V> extends StreamAdapter<T, K, V> {
}
}
}
-}
\ No newline at end of file
+}