Flume
  1. Flume
  2. FLUME-2937

Integrate checkstyle for non-test classes

    Details

    • Type: Improvement Improvement
    • Status: Resolved
    • Priority: Minor Minor
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: v1.7.0
    • Component/s: None
    • Labels:
      None

      Description

      We should add the maven-checkstyle-plugin to the build process. This plugin can fail a build if the code does not honor the style of our project. This way we can make sure that we have one common style in the code. In addition, reviewers can focus on design, correctness, performance and other important coding aspects other than style issues.

        Issue Links

          Activity

          Hide
          Mike Percy added a comment -

          See Reviewboard for patch

          Show
          Mike Percy added a comment - See Reviewboard for patch
          Hide
          Hari Shreedharan added a comment -

          I just +1-ed the patch.

          Mike Percy - Feel free to commit it.

          Show
          Hari Shreedharan added a comment - I just +1-ed the patch. Mike Percy - Feel free to commit it.
          Hide
          Mike Percy added a comment -

          Thanks Hari! I am about to commit this to trunk.

          Show
          Mike Percy added a comment - Thanks Hari! I am about to commit this to trunk.
          Hide
          Hudson added a comment -

          FAILURE: Integrated in Flume-trunk-hbase-1 #170 (See https://builds.apache.org/job/Flume-trunk-hbase-1/170/)
          FLUME-2937. Integrate checkstyle for non-test classes (mpercy: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=2252fb1938a4fd578f88c64eb444c74777c46212)

          • flume-ng-sdk/src/main/java/org/apache/flume/api/FailoverRpcClient.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/ChannelCounter.java
          • flume-ng-auth/src/main/java/org/apache/flume/auth/UGIExecutor.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/TransactionEventRecord.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Pair.java
          • flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchIndexRequestBuilderFactory.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFileV2.java
          • flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirSourceConfigurationConstants.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkProcessor.java
          • flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java
          • flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/LoggerSink.java
          • flume-ng-core/src/main/java/org/apache/flume/Clock.java
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java
          • flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannelSelector.java
          • flume-ng-core/src/main/java/org/apache/flume/source/AbstractSource.java
          • flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/parser/EntityParserFactory.java
          • flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java
          • flume-ng-core/src/main/java/org/apache/flume/lifecycle/LifecycleSupervisor.java
          • flume-ng-core/src/main/java/org/apache/flume/source/DefaultSourceFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/source/SyslogTcpSource.java
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoringType.java
          • flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumerFactory.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineInterceptor.java
          • flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java
          • flume-tools/src/main/java/org/apache/flume/tools/FileChannelIntegrityTool.java
          • flume-ng-core/src/main/java/org/apache/flume/interceptor/RegexFilteringInterceptor.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannel.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/AESCTRNoPaddingProvider.java
          • flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSourceConstants.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/AbstractHDFSWriter.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogUtils.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/http/HTTPMetricsServer.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java
          • flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleRowKeyGenerator.java
          • flume-ng-core/src/main/java/org/apache/flume/annotations/InterfaceStability.java
          • flume-ng-core/src/main/java/org/apache/flume/formatter/output/DefaultPathManager.java
          • flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAvroHeaders.java
          • flume-ng-core/src/main/java/org/apache/flume/SourceFactory.java
          • flume-ng-sdk/src/main/java/org/apache/flume/event/EventBuilder.java
          • flume-ng-core/src/main/java/org/apache/flume/source/MultiportSyslogTCPSource.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Commit.java
          • flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/WritableUtils.java
          • flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedAgent.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/ReplayHandler.java
          • flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java
          • flume-ng-core/src/main/java/org/apache/flume/serialization/HeaderAndBodyTextEventSerializer.java
          • flume-ng-core/src/main/java/org/apache/flume/source/SyslogUtils.java
          • flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannel.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/SinkCounter.java
          • flume-ng-core/src/main/java/org/apache/flume/serialization/LineDeserializer.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Rollback.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Serialization.java
          • flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchRestClient.java
          • flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSinkConstants.java
          • flume-ng-core/src/main/java/org/apache/flume/source/SyslogUDPSource.java
          • flume-ng-core/src/main/java/org/apache/flume/formatter/output/RollTimePathManager.java
          • flume-ng-core/src/main/java/org/apache/flume/interceptor/SearchAndReplaceInterceptor.java
          • flume-ng-auth/src/main/java/org/apache/flume/auth/FlumeAuthenticationUtil.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileRetryableIOException.java
          • flume-ng-auth/src/main/java/org/apache/flume/auth/KerberosUser.java
          • flume-ng-core/src/main/java/org/apache/flume/source/http/BLOBHandler.java
          • flume-ng-core/src/main/java/org/apache/flume/SystemClock.java
          • flume-ng-core/src/main/java/org/apache/flume/channel/ReplicatingChannelSelector.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java
          • flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/RegexHbaseEventSerializer.java
          • flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/JCEFileKeyProvider.java
          • flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogRecord.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobHandler.java
          • flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySourceConfigurationConstants.java
          • flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedAgentConfiguration.java
          • flume-ng-tests/src/test/java/org/apache/flume/test/agent/TestRpcClientCommunicationFailure.java
          • flume-ng-core/src/main/java/org/apache/flume/interceptor/TimestampInterceptor.java
          • flume-ng-core/src/main/java/org/apache/flume/source/SyslogParser.java
          • flume-ng-channels/flume-spillable-memory-channel/src/main/java/org/apache/flume/channel/SpillableMemoryChannel.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/ThriftSink.java
          • flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/policy/FailurePolicyFactory.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFile.java
          • flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/NonRecoverableEventException.java
          • flume-ng-node/src/main/java/org/apache/flume/node/PollingPropertiesFileConfigurationProvider.java
          • flume-ng-auth/src/main/java/org/apache/flume/api/SecureThriftRpcClient.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoredCounterGroup.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java
          • flume-ng-core/src/main/java/org/apache/flume/tools/GetJavaProperty.java
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java
          • flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManagerFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/source/http/JSONHandler.java
          • flume-ng-core/src/main/java/org/apache/flume/source/AbstractEventDrivenSource.java
          • flume-ng-core/src/main/java/org/apache/flume/Transaction.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkFactory.java
          • flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleHbaseEventSerializer.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/KeyProviderType.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkSelector.java
          • flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
          • flume-ng-core/src/main/java/org/apache/flume/source/ExecSourceConfigurationConstants.java
          • flume-ng-node/src/main/java/org/apache/flume/node/SimpleMaterializedConfiguration.java
          • flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedSource.java
          • flume-ng-sdk/src/main/java/org/apache/flume/api/NettyAvroRpcClient.java
          • flume-checkstyle/src/main/resources/flume/checkstyle.xml
          • flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannel.java
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/source/SourceConfiguration.java
          • flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/RoundRobinList.java
          • flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/InitialContextFactory.java
          • flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java
          • flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandlerImpl.java
          • flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventPointer.java
          • flume-ng-node/src/main/java/org/apache/flume/node/AbstractConfigurationProvider.java
          • flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/CheckpointRebuilder.java
          • flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManagerType.java
          • flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManager.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/util/JMXPollUtil.java
          • flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java
          • flume-ng-core/src/main/java/org/apache/flume/annotations/Disposable.java
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/ComponentConfiguration.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/BasicConfigurationConstants.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java
          • flume-checkstyle/pom.xml
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventUtils.java
          • flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TailFile.java
          • flume-ng-configuration/src/main/java/org/apache/flume/Context.java
          • flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannelConfiguration.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEvent.java
          • flume-ng-legacy-sources/flume-thrift-source/src/main/java/org/apache/flume/source/thriftLegacy/ThriftLegacySource.java
          • flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/SchemaHandlerFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
          • flume-tools/src/main/java/org/apache/flume/tools/FlumeToolsMain.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/KerberosUser.java
          • flume-ng-auth/src/main/java/org/apache/flume/api/SecureRpcClientFactory.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java
          • flume-ng-core/src/main/java/org/apache/flume/client/avro/ReliableSpoolingFileEventReader.java
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java
          • flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientFactory.java
          • flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClientFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/event/EventHelper.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/SequenceFileSerializerType.java
          • flume-ng-core/src/main/java/org/apache/flume/serialization/BodyTextEventSerializer.java
          • flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchIndexRequestBuilderFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/source/http/HTTPSource.java
          • flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/DatasetSink.java
          • flume-ng-sdk/src/main/java/org/apache/flume/event/SimpleEvent.java
          • flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java
          • flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Put.java
          • flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java
          • flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannelConfiguration.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProviderFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/kafka/KafkaChannelCounter.java
          • flume-ng-core/src/main/java/org/apache/flume/source/AbstractPollableSource.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/ComponentConfigurationFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFileV3.java
          • flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirSource.java
          • flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java
          • flume-ng-sdk/src/main/java/org/apache/flume/api/ThriftRpcClient.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFactory.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/DecryptionFailureException.java
          • pom.xml
          • flume-ng-sdk/src/main/java/org/apache/flume/event/JSONEvent.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java
          • flume-ng-auth/src/main/java/org/apache/flume/auth/SimpleAuthenticator.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/TransactionIDOracle.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileV3.java
          • flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/DefaultJMSMessageConverter.java
          • flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHbaseEventSerializer.java
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkGroupConfiguration.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/WriteOrderOracle.java
          • flume-ng-core/src/main/java/org/apache/flume/tools/VersionInfo.java
          • flume-ng-core/src/main/java/org/apache/flume/channel/BasicTransactionSemantics.java
          • flume-ng-core/src/main/java/org/apache/flume/SinkFactory.java
          • flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/LoadBalancingLog4jAppender.java
          • flume-ng-sdk/src/main/java/org/apache/flume/util/OrderSelector.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/SinkProcessorFactory.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProviderType.java
          • flume-ng-core/src/main/java/org/apache/flume/interceptor/StaticInterceptor.java
          • flume-ng-sdk/src/main/java/org/apache/flume/api/HostInfo.java
          • flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/ReliableTaildirEventReader.java
          • flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java
          • flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleAsyncHbaseEventSerializer.java
          • flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/EventSerializerIndexRequestBuilderFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/source/BasicSourceSemantics.java
          • flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/AbstractRpcSink.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/proto/ProtosFactory.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java
          • flume-ng-core/src/main/java/org/apache/flume/lifecycle/LifecycleAware.java
          • flume-ng-node/src/main/java/org/apache/flume/node/ConfigurationProvider.java
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfigurationError.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/BadCheckpointException.java
          • flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java
          • flume-ng-core/src/main/java/org/apache/flume/channel/ChannelSelectorFactory.java
          • flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java
          • flume-ng-core/src/main/java/org/apache/flume/SinkRunner.java
          • flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchTransportClient.java
          • flume-ng-core/src/main/java/org/apache/flume/interceptor/HostInterceptor.java
          • flume-ng-core/src/main/java/org/apache/flume/tools/DirectMemoryUtils.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketClosedException.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java
          • flume-checkstyle/src/main/resources/flume/checkstyle-suppressions.xml
          • flume-ng-core/src/main/java/org/apache/flume/tools/TimestampRoundDownUtil.java
          • flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/ConfigurationConstants.java
          • flume-ng-sinks/flume-irc-sink/src/main/java/org/apache/flume/sink/irc/IRCSink.java
          • flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionImpl.java
          • flume-ng-core/src/main/java/org/apache/flume/instrumentation/SourceCounter.java
          • flume-ng-core/src/main/java/org/apache/flume/formatter/output/BucketPath.java
          • flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientConfigurationConstants.java
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfiguration.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/CorruptEventException.java
          • flume-ng-core/src/main/java/org/apache/flume/source/NetcatSourceConfigurationConstants.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/FailoverSinkProcessor.java
          • flume-ng-core/src/main/java/org/apache/flume/interceptor/RegexExtractorInterceptor.java
          • flume-ng-core/src/main/java/org/apache/flume/annotations/Recyclable.java
          • flume-ng-core/src/main/java/org/apache/flume/SourceRunner.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileV2.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java
          • flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumer.java
          • flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirMatcher.java
          • flume-ng-core/src/main/java/org/apache/flume/serialization/AvroEventDeserializer.java
          • flume-ng-node/src/main/java/org/apache/flume/node/Application.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProvider.java
          • flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HbaseEventSerializer.java
          • flume-ng-core/src/main/java/org/apache/flume/sink/LoadBalancingSinkProcessor.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java
          • flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannelProvider.java
          • flume-ng-auth/src/main/java/org/apache/flume/auth/KerberosAuthenticator.java
          • flume-tools/src/main/java/org/apache/flume/tools/FlumeToolType.java
          • flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/SchemaHandler.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java
          • flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java
          • flume-ng-core/src/main/java/org/apache/flume/ChannelSelector.java
          • flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
          • flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Take.java
          Show
          Hudson added a comment - FAILURE: Integrated in Flume-trunk-hbase-1 #170 (See https://builds.apache.org/job/Flume-trunk-hbase-1/170/ ) FLUME-2937 . Integrate checkstyle for non-test classes (mpercy: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=2252fb1938a4fd578f88c64eb444c74777c46212 ) flume-ng-sdk/src/main/java/org/apache/flume/api/FailoverRpcClient.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/ChannelCounter.java flume-ng-auth/src/main/java/org/apache/flume/auth/UGIExecutor.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/TransactionEventRecord.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Pair.java flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchIndexRequestBuilderFactory.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFileV2.java flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirSourceConfigurationConstants.java flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkProcessor.java flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java flume-ng-core/src/main/java/org/apache/flume/sink/LoggerSink.java flume-ng-core/src/main/java/org/apache/flume/Clock.java flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannelSelector.java flume-ng-core/src/main/java/org/apache/flume/source/AbstractSource.java flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/parser/EntityParserFactory.java flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java flume-ng-core/src/main/java/org/apache/flume/lifecycle/LifecycleSupervisor.java flume-ng-core/src/main/java/org/apache/flume/source/DefaultSourceFactory.java flume-ng-core/src/main/java/org/apache/flume/source/SyslogTcpSource.java flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoringType.java flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumerFactory.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineInterceptor.java flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java flume-tools/src/main/java/org/apache/flume/tools/FileChannelIntegrityTool.java flume-ng-core/src/main/java/org/apache/flume/interceptor/RegexFilteringInterceptor.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannel.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/AESCTRNoPaddingProvider.java flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSourceConstants.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/AbstractHDFSWriter.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogUtils.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/http/HTTPMetricsServer.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleRowKeyGenerator.java flume-ng-core/src/main/java/org/apache/flume/annotations/InterfaceStability.java flume-ng-core/src/main/java/org/apache/flume/formatter/output/DefaultPathManager.java flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAvroHeaders.java flume-ng-core/src/main/java/org/apache/flume/SourceFactory.java flume-ng-sdk/src/main/java/org/apache/flume/event/EventBuilder.java flume-ng-core/src/main/java/org/apache/flume/source/MultiportSyslogTCPSource.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Commit.java flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/WritableUtils.java flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedAgent.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/ReplayHandler.java flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java flume-ng-core/src/main/java/org/apache/flume/serialization/HeaderAndBodyTextEventSerializer.java flume-ng-core/src/main/java/org/apache/flume/source/SyslogUtils.java flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannel.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/SinkCounter.java flume-ng-core/src/main/java/org/apache/flume/serialization/LineDeserializer.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Rollback.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Serialization.java flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchRestClient.java flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSinkConstants.java flume-ng-core/src/main/java/org/apache/flume/source/SyslogUDPSource.java flume-ng-core/src/main/java/org/apache/flume/formatter/output/RollTimePathManager.java flume-ng-core/src/main/java/org/apache/flume/interceptor/SearchAndReplaceInterceptor.java flume-ng-auth/src/main/java/org/apache/flume/auth/FlumeAuthenticationUtil.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileRetryableIOException.java flume-ng-auth/src/main/java/org/apache/flume/auth/KerberosUser.java flume-ng-core/src/main/java/org/apache/flume/source/http/BLOBHandler.java flume-ng-core/src/main/java/org/apache/flume/SystemClock.java flume-ng-core/src/main/java/org/apache/flume/channel/ReplicatingChannelSelector.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/RegexHbaseEventSerializer.java flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/JCEFileKeyProvider.java flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogRecord.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobHandler.java flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySourceConfigurationConstants.java flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedAgentConfiguration.java flume-ng-tests/src/test/java/org/apache/flume/test/agent/TestRpcClientCommunicationFailure.java flume-ng-core/src/main/java/org/apache/flume/interceptor/TimestampInterceptor.java flume-ng-core/src/main/java/org/apache/flume/source/SyslogParser.java flume-ng-channels/flume-spillable-memory-channel/src/main/java/org/apache/flume/channel/SpillableMemoryChannel.java flume-ng-core/src/main/java/org/apache/flume/sink/ThriftSink.java flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/policy/FailurePolicyFactory.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFile.java flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/NonRecoverableEventException.java flume-ng-node/src/main/java/org/apache/flume/node/PollingPropertiesFileConfigurationProvider.java flume-ng-auth/src/main/java/org/apache/flume/api/SecureThriftRpcClient.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoredCounterGroup.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java flume-ng-core/src/main/java/org/apache/flume/tools/GetJavaProperty.java flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManagerFactory.java flume-ng-core/src/main/java/org/apache/flume/source/http/JSONHandler.java flume-ng-core/src/main/java/org/apache/flume/source/AbstractEventDrivenSource.java flume-ng-core/src/main/java/org/apache/flume/Transaction.java flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkFactory.java flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleHbaseEventSerializer.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/KeyProviderType.java flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkSelector.java flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java flume-ng-core/src/main/java/org/apache/flume/source/ExecSourceConfigurationConstants.java flume-ng-node/src/main/java/org/apache/flume/node/SimpleMaterializedConfiguration.java flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedSource.java flume-ng-sdk/src/main/java/org/apache/flume/api/NettyAvroRpcClient.java flume-checkstyle/src/main/resources/flume/checkstyle.xml flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannel.java flume-ng-configuration/src/main/java/org/apache/flume/conf/source/SourceConfiguration.java flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/RoundRobinList.java flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/InitialContextFactory.java flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandlerImpl.java flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventPointer.java flume-ng-node/src/main/java/org/apache/flume/node/AbstractConfigurationProvider.java flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/CheckpointRebuilder.java flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManagerType.java flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManager.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/util/JMXPollUtil.java flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java flume-ng-core/src/main/java/org/apache/flume/annotations/Disposable.java flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java flume-ng-configuration/src/main/java/org/apache/flume/conf/ComponentConfiguration.java flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java flume-ng-configuration/src/main/java/org/apache/flume/conf/BasicConfigurationConstants.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java flume-checkstyle/pom.xml flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventUtils.java flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TailFile.java flume-ng-configuration/src/main/java/org/apache/flume/Context.java flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannelConfiguration.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEvent.java flume-ng-legacy-sources/flume-thrift-source/src/main/java/org/apache/flume/source/thriftLegacy/ThriftLegacySource.java flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/SchemaHandlerFactory.java flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java flume-tools/src/main/java/org/apache/flume/tools/FlumeToolsMain.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/KerberosUser.java flume-ng-auth/src/main/java/org/apache/flume/api/SecureRpcClientFactory.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileFactory.java flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java flume-ng-core/src/main/java/org/apache/flume/client/avro/ReliableSpoolingFileEventReader.java flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientFactory.java flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClientFactory.java flume-ng-core/src/main/java/org/apache/flume/event/EventHelper.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/SequenceFileSerializerType.java flume-ng-core/src/main/java/org/apache/flume/serialization/BodyTextEventSerializer.java flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchIndexRequestBuilderFactory.java flume-ng-core/src/main/java/org/apache/flume/source/http/HTTPSource.java flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/DatasetSink.java flume-ng-sdk/src/main/java/org/apache/flume/event/SimpleEvent.java flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Put.java flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannelConfiguration.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProviderFactory.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/kafka/KafkaChannelCounter.java flume-ng-core/src/main/java/org/apache/flume/source/AbstractPollableSource.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java flume-ng-configuration/src/main/java/org/apache/flume/conf/ComponentConfigurationFactory.java flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFileV3.java flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirSource.java flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java flume-ng-sdk/src/main/java/org/apache/flume/api/ThriftRpcClient.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFactory.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/DecryptionFailureException.java pom.xml flume-ng-sdk/src/main/java/org/apache/flume/event/JSONEvent.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java flume-ng-auth/src/main/java/org/apache/flume/auth/SimpleAuthenticator.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/TransactionIDOracle.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileV3.java flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/DefaultJMSMessageConverter.java flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHbaseEventSerializer.java flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkGroupConfiguration.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/WriteOrderOracle.java flume-ng-core/src/main/java/org/apache/flume/tools/VersionInfo.java flume-ng-core/src/main/java/org/apache/flume/channel/BasicTransactionSemantics.java flume-ng-core/src/main/java/org/apache/flume/SinkFactory.java flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/LoadBalancingLog4jAppender.java flume-ng-sdk/src/main/java/org/apache/flume/util/OrderSelector.java flume-ng-core/src/main/java/org/apache/flume/sink/SinkProcessorFactory.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProviderType.java flume-ng-core/src/main/java/org/apache/flume/interceptor/StaticInterceptor.java flume-ng-sdk/src/main/java/org/apache/flume/api/HostInfo.java flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/ReliableTaildirEventReader.java flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleAsyncHbaseEventSerializer.java flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/EventSerializerIndexRequestBuilderFactory.java flume-ng-core/src/main/java/org/apache/flume/source/BasicSourceSemantics.java flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java flume-ng-core/src/main/java/org/apache/flume/sink/AbstractRpcSink.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/proto/ProtosFactory.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java flume-ng-core/src/main/java/org/apache/flume/lifecycle/LifecycleAware.java flume-ng-node/src/main/java/org/apache/flume/node/ConfigurationProvider.java flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfigurationError.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/BadCheckpointException.java flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java flume-ng-core/src/main/java/org/apache/flume/channel/ChannelSelectorFactory.java flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java flume-ng-core/src/main/java/org/apache/flume/SinkRunner.java flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchTransportClient.java flume-ng-core/src/main/java/org/apache/flume/interceptor/HostInterceptor.java flume-ng-core/src/main/java/org/apache/flume/tools/DirectMemoryUtils.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketClosedException.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java flume-checkstyle/src/main/resources/flume/checkstyle-suppressions.xml flume-ng-core/src/main/java/org/apache/flume/tools/TimestampRoundDownUtil.java flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/ConfigurationConstants.java flume-ng-sinks/flume-irc-sink/src/main/java/org/apache/flume/sink/irc/IRCSink.java flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionImpl.java flume-ng-core/src/main/java/org/apache/flume/instrumentation/SourceCounter.java flume-ng-core/src/main/java/org/apache/flume/formatter/output/BucketPath.java flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientConfigurationConstants.java flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfiguration.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/CorruptEventException.java flume-ng-core/src/main/java/org/apache/flume/source/NetcatSourceConfigurationConstants.java flume-ng-core/src/main/java/org/apache/flume/sink/FailoverSinkProcessor.java flume-ng-core/src/main/java/org/apache/flume/interceptor/RegexExtractorInterceptor.java flume-ng-core/src/main/java/org/apache/flume/annotations/Recyclable.java flume-ng-core/src/main/java/org/apache/flume/SourceRunner.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileV2.java flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumer.java flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirMatcher.java flume-ng-core/src/main/java/org/apache/flume/serialization/AvroEventDeserializer.java flume-ng-node/src/main/java/org/apache/flume/node/Application.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProvider.java flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HbaseEventSerializer.java flume-ng-core/src/main/java/org/apache/flume/sink/LoadBalancingSinkProcessor.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannelProvider.java flume-ng-auth/src/main/java/org/apache/flume/auth/KerberosAuthenticator.java flume-tools/src/main/java/org/apache/flume/tools/FlumeToolType.java flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/SchemaHandler.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java flume-ng-core/src/main/java/org/apache/flume/ChannelSelector.java flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Take.java
          Hide
          Mike Percy added a comment -

          This is done. I filed another JIRA to do the same thing for the unit tests: FLUME-2941

          Show
          Mike Percy added a comment - This is done. I filed another JIRA to do the same thing for the unit tests: FLUME-2941

            People

            • Assignee:
              Mike Percy
              Reporter:
              Lior Zeno
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development