Skip to content

FLUME-2980 : Automated concurrent Kafka offset migration test#96

Open
umesh9794 wants to merge 2 commits intoapache:trunkfrom
umesh9794:umesh
Open

FLUME-2980 : Automated concurrent Kafka offset migration test#96
umesh9794 wants to merge 2 commits intoapache:trunkfrom
umesh9794:umesh

Conversation

@umesh9794
Copy link

No description provided.

@umesh9794
Copy link
Author

umesh9794 commented Nov 29, 2016

Tests are passing locally on trunk :

Command:
mvn -DfailIfNoTests=false -Dtest=org.apache.flume.channel.kafka.TestKafkaChannel#testAutomaticOffsetsMigration clean test

Running org.apache.flume.channel.kafka.TestKafkaChannel
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 90.408 sec

Results :
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 02:28 min
[INFO] Finished at: 2016-11-29T20:01:25+05:30
[INFO] Final Memory: 523M/1982M
[INFO] ------------------------------------------------------------------------

@harishreedharan
Copy link
Contributor

The tests pass fine, but there are checkstyle violations causing the build to fail:

[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[900,18] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not followed by whitespace. Empty blocks may only be represented as {} when not part of a multi-block statement (4.1.3)
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[901,57] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not preceded with whitespace.
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[901,58] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not followed by whitespace. Empty blocks may only be represented as {} when not part of a multi-block statement (4.1.3)
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[910] (sizes) LineLength: Line is longer than 100 characters (found 135).
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[920,18] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not preceded with whitespace.
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[920,19] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not followed by whitespace. Empty blocks may only be represented as {} when not part of a multi-block statement (4.1.3)
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[925] (sizes) LineLength: Line is longer than 100 characters (found 119).
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[927] (sizes) LineLength: Line is longer than 100 characters (found 127).
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[931,18] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not preceded with whitespace.
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[931,19] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not followed by whitespace. Empty blocks may only be represented as {} when not part of a multi-block statement (4.1.3)
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[932] (sizes) LineLength: Line is longer than 100 characters (found 133).
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[936] (sizes) LineLength: Line is longer than 100 characters (found 114).
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[953,17] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not preceded with whitespace.
[ERROR] src/test/java/org/apache/flume/channel/kafka/TestKafkaChannel.java:[953,18] (whitespace) WhitespaceAround: WhitespaceAround: '=' is not followed by whitespace. Empty blocks may only be represented as {} when not part of a multi-block statement (4.1.3)```

Those need to be fixed.

@umesh9794
Copy link
Author

Thanks @harishreedharan for your comment. Actually in the committed TestKafkaChannel.java file there are no such violations which are pointed by Travis. May I request you to verify the first one at least, which is for 900 line and 18 column?

Copy link

@simonati simonati left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please fix build related issues.


@Test
public void testAutomaticOffsetsMigration() throws Exception {
String group="testMigrateOffsets-kafka";

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hi @umesh9794,
Here is an example for violation: missing spaces around '='. I don't know why Trevis is different to github in aspect of the reported line numbers (after applying your patch seem to me that Trevis was correct). You can check style locally by executing mvn clean install -DskipTests

@umesh9794
Copy link
Author

Thanks @simonati for pointing the checkstyle issues. Please review the updated commit.

@asfgit
Copy link

asfgit commented Aug 17, 2018

Can one of the admins verify this patch?

waidr pushed a commit to waidr/flume that referenced this pull request Jul 24, 2019
travis: make pili-base follow travis-branch
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants