flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From szape <...@git.apache.org>
Subject [GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout...
Date Mon, 22 Jun 2015 08:28:33 GMT
Github user szape commented on a diff in the pull request:

    --- Diff: flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/SpoutSourceWordCount.java
    @@ -145,7 +145,7 @@ private static boolean parseParameters(final String[] args) {
     		return env.addSource(new StormFiniteSpoutWrapper<String>(new StormInMemorySpout(WordCountData.WORDS),
    -				TypeExtractor.getForClass(String.class));
    +				TypeExtractor.getForClass(String.class)).setParallelism(1);
    --- End diff --
    I thought it was a mistake, because without setting the parallelism to 1, the input will
be duplicated. It does not affect the ITCases directly, though, because they run in 'file
input/output' mode, but it still seems out of order.
    Any reason against setting the parallelism?

If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message