# 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 <yzhda...@gridgain.com> Authored: Thu Jul 2 17:54:58 2015 -0700 Committer: Yakov Zhdanov <yzhda...@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 +}
