Return-Path: X-Original-To: apmail-falcon-commits-archive@minotaur.apache.org Delivered-To: apmail-falcon-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 691AE188A9 for ; Tue, 9 Jun 2015 05:07:10 +0000 (UTC) Received: (qmail 66453 invoked by uid 500); 9 Jun 2015 05:07:10 -0000 Delivered-To: apmail-falcon-commits-archive@falcon.apache.org Received: (qmail 66420 invoked by uid 500); 9 Jun 2015 05:07:10 -0000 Mailing-List: contact commits-help@falcon.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@falcon.apache.org Delivered-To: mailing list commits@falcon.apache.org Received: (qmail 66406 invoked by uid 99); 9 Jun 2015 05:07:10 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 09 Jun 2015 05:07:10 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 05633DFFCD; Tue, 9 Jun 2015 05:07:09 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: ajayyadava@apache.org To: commits@falcon.apache.org Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: falcon git commit: FALCON-1207 Falcon checkstyle allows wildcard imports. Contributed by Pallavi Rao Date: Tue, 9 Jun 2015 05:07:09 +0000 (UTC) Repository: falcon Updated Branches: refs/heads/master 3849c7c52 -> 4becb74bc FALCON-1207 Falcon checkstyle allows wildcard imports. Contributed by Pallavi Rao Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/4becb74b Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/4becb74b Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/4becb74b Branch: refs/heads/master Commit: 4becb74bc09c3c5fbfde0248f4271c45d7b879db Parents: 3849c7c Author: Ajay Yadava Authored: Tue Jun 9 10:36:42 2015 +0530 Committer: Ajay Yadava Committed: Tue Jun 9 10:36:42 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ checkstyle/src/main/resources/falcon/checkstyle.xml | 3 +++ .../main/java/org/apache/falcon/cli/CLIParser.java | 6 +++++- .../java/org/apache/falcon/entity/v0/EntityType.java | 7 ++++++- .../java/org/apache/falcon/recipe/RecipeTool.java | 3 ++- .../java/org/apache/falcon/resource/EntityList.java | 6 +++++- .../org/apache/falcon/catalog/HiveCatalogService.java | 6 +++++- .../falcon/entity/parser/CrossEntityValidations.java | 5 ++++- .../apache/falcon/entity/parser/FeedEntityParser.java | 7 ++++++- .../apache/falcon/entity/lock/MemoryLocksTest.java | 1 - .../org/apache/falcon/entity/v0/EntityGraphTest.java | 5 ++++- .../org/apache/falcon/security/SecurityUtilTest.java | 2 +- .../apache/falcon/util/ResourcesReflectionUtil.java | 3 ++- .../org/apache/falcon/workflow/LateDataHandler.java | 11 +++++++++-- .../falcon/workflow/engine/OozieWorkflowEngine.java | 10 +++++++++- .../oozie/workflow/FalconPostProcessingTest.java | 8 +++++++- .../resource/AbstractSchedulableEntityManager.java | 8 +++++++- .../apache/falcon/resource/proxy/BufferedRequest.java | 6 +++++- .../resource/proxy/SchedulableEntityManagerProxy.java | 10 +++++++++- .../falcon/resource/metadata/MetadataTestContext.java | 6 +++++- .../falcon/security/ClientCertificateFilterTest.java | 5 ++++- .../org/apache/falcon/replication/FeedReplicator.java | 6 +++++- .../falcon/rerun/handler/LateRerunConsumer.java | 7 ++++++- .../org/apache/falcon/rerun/queue/ActiveMQueue.java | 8 +++++++- .../org/apache/falcon/rerun/queue/InMemoryQueue.java | 9 ++++++++- .../org/apache/falcon/retention/FeedEvictorTest.java | 14 ++++++++++++-- .../org/apache/falcon/resource/ConfigSyncService.java | 8 +++++++- 27 files changed, 145 insertions(+), 27 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index f12e1cc..db4cfa7 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -7,6 +7,8 @@ Trunk (Unreleased) FALCON-1039 Add instance dependency API in falcon(Ajay Yadava) IMPROVEMENTS + FALCON-1207 Falcon checkstyle allows wildcard imports(Pallavi Rao via Ajay Yadava) + FALCON-1147 Allow _ in the names for name value pair(Sowmya Ramesh via Ajay Yadava) FALCON-676 Enable metrics for Titan(Ajay Yadava) http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/checkstyle/src/main/resources/falcon/checkstyle.xml ---------------------------------------------------------------------- diff --git a/checkstyle/src/main/resources/falcon/checkstyle.xml b/checkstyle/src/main/resources/falcon/checkstyle.xml index def097c..2130e73 100644 --- a/checkstyle/src/main/resources/falcon/checkstyle.xml +++ b/checkstyle/src/main/resources/falcon/checkstyle.xml @@ -107,6 +107,9 @@ + + + http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/client/src/main/java/org/apache/falcon/cli/CLIParser.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/falcon/cli/CLIParser.java b/client/src/main/java/org/apache/falcon/cli/CLIParser.java index 18c26e5..9d8554f 100644 --- a/client/src/main/java/org/apache/falcon/cli/CLIParser.java +++ b/client/src/main/java/org/apache/falcon/cli/CLIParser.java @@ -18,7 +18,11 @@ package org.apache.falcon.cli; -import org.apache.commons.cli.*; +import org.apache.commons.cli.CommandLine; +import org.apache.commons.cli.GnuParser; +import org.apache.commons.cli.Options; +import org.apache.commons.cli.ParseException; +import org.apache.commons.cli.HelpFormatter; import java.io.PrintWriter; import java.text.MessageFormat; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/client/src/main/java/org/apache/falcon/entity/v0/EntityType.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/falcon/entity/v0/EntityType.java b/client/src/main/java/org/apache/falcon/entity/v0/EntityType.java index 13c85a4..0657124 100644 --- a/client/src/main/java/org/apache/falcon/entity/v0/EntityType.java +++ b/client/src/main/java/org/apache/falcon/entity/v0/EntityType.java @@ -22,7 +22,12 @@ import org.apache.falcon.entity.v0.cluster.Cluster; import org.apache.falcon.entity.v0.feed.Feed; import org.apache.falcon.entity.v0.process.Process; -import javax.xml.bind.*; +import javax.xml.bind.JAXBContext; +import javax.xml.bind.JAXBException; +import javax.xml.bind.ValidationEvent; +import javax.xml.bind.ValidationEventHandler; +import javax.xml.bind.Marshaller; +import javax.xml.bind.Unmarshaller; import javax.xml.validation.Schema; import javax.xml.validation.SchemaFactory; import java.util.Arrays; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/client/src/main/java/org/apache/falcon/recipe/RecipeTool.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/falcon/recipe/RecipeTool.java b/client/src/main/java/org/apache/falcon/recipe/RecipeTool.java index 3cb64ee..069db9f 100644 --- a/client/src/main/java/org/apache/falcon/recipe/RecipeTool.java +++ b/client/src/main/java/org/apache/falcon/recipe/RecipeTool.java @@ -28,7 +28,8 @@ import org.apache.commons.io.IOUtils; import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configured; -import org.apache.hadoop.fs.*; +import org.apache.hadoop.fs.FileSystem; +import org.apache.hadoop.fs.Path; import org.apache.hadoop.util.Tool; import org.apache.hadoop.util.ToolRunner; import org.apache.commons.cli.Options; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/client/src/main/java/org/apache/falcon/resource/EntityList.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/falcon/resource/EntityList.java b/client/src/main/java/org/apache/falcon/resource/EntityList.java index 6e132f0..f581691 100644 --- a/client/src/main/java/org/apache/falcon/resource/EntityList.java +++ b/client/src/main/java/org/apache/falcon/resource/EntityList.java @@ -25,7 +25,11 @@ import org.apache.falcon.entity.v0.process.Input; import org.apache.falcon.entity.v0.process.Output; import org.apache.falcon.entity.v0.process.Process; -import javax.xml.bind.annotation.*; +import javax.xml.bind.annotation.XmlAccessType; +import javax.xml.bind.annotation.XmlAccessorType; +import javax.xml.bind.annotation.XmlElement; +import javax.xml.bind.annotation.XmlRootElement; +import javax.xml.bind.annotation.XmlElementWrapper; import java.util.ArrayList; import java.util.List; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/common/src/main/java/org/apache/falcon/catalog/HiveCatalogService.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/falcon/catalog/HiveCatalogService.java b/common/src/main/java/org/apache/falcon/catalog/HiveCatalogService.java index 3d57631..7f96827 100644 --- a/common/src/main/java/org/apache/falcon/catalog/HiveCatalogService.java +++ b/common/src/main/java/org/apache/falcon/catalog/HiveCatalogService.java @@ -25,7 +25,11 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.metastore.HiveMetaStoreClient; import org.apache.hadoop.hive.metastore.TableType; -import org.apache.hadoop.hive.metastore.api.*; +import org.apache.hadoop.hive.metastore.api.FieldSchema; +import org.apache.hadoop.hive.metastore.api.NoSuchObjectException; +import org.apache.hadoop.hive.metastore.api.Partition; +import org.apache.hadoop.hive.metastore.api.Table; +import org.apache.hadoop.hive.metastore.api.Database; import org.apache.hadoop.hive.thrift.DelegationTokenIdentifier; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.security.Credentials; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/common/src/main/java/org/apache/falcon/entity/parser/CrossEntityValidations.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/falcon/entity/parser/CrossEntityValidations.java b/common/src/main/java/org/apache/falcon/entity/parser/CrossEntityValidations.java index d8d3d78..7a01d1e 100644 --- a/common/src/main/java/org/apache/falcon/entity/parser/CrossEntityValidations.java +++ b/common/src/main/java/org/apache/falcon/entity/parser/CrossEntityValidations.java @@ -22,8 +22,11 @@ import org.apache.falcon.FalconException; import org.apache.falcon.entity.FeedHelper; import org.apache.falcon.entity.ProcessHelper; import org.apache.falcon.entity.v0.feed.Feed; -import org.apache.falcon.entity.v0.process.*; +import org.apache.falcon.entity.v0.process.Cluster; +import org.apache.falcon.entity.v0.process.Input; +import org.apache.falcon.entity.v0.process.Output; import org.apache.falcon.entity.v0.process.Process; +import org.apache.falcon.entity.v0.process.Validity; import org.apache.falcon.expression.ExpressionHelper; import java.util.Date; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/common/src/main/java/org/apache/falcon/entity/parser/FeedEntityParser.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/falcon/entity/parser/FeedEntityParser.java b/common/src/main/java/org/apache/falcon/entity/parser/FeedEntityParser.java index 4547c23..f22a343 100644 --- a/common/src/main/java/org/apache/falcon/entity/parser/FeedEntityParser.java +++ b/common/src/main/java/org/apache/falcon/entity/parser/FeedEntityParser.java @@ -21,7 +21,12 @@ package org.apache.falcon.entity.parser; import org.apache.commons.lang3.StringUtils; import org.apache.falcon.FalconException; import org.apache.falcon.catalog.CatalogServiceFactory; -import org.apache.falcon.entity.*; +import org.apache.falcon.entity.CatalogStorage; +import org.apache.falcon.entity.ClusterHelper; +import org.apache.falcon.entity.EntityUtil; +import org.apache.falcon.entity.FeedHelper; +import org.apache.falcon.entity.FileSystemStorage; +import org.apache.falcon.entity.Storage; import org.apache.falcon.entity.store.ConfigurationStore; import org.apache.falcon.entity.v0.Entity; import org.apache.falcon.entity.v0.EntityGraph; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/common/src/test/java/org/apache/falcon/entity/lock/MemoryLocksTest.java ---------------------------------------------------------------------- diff --git a/common/src/test/java/org/apache/falcon/entity/lock/MemoryLocksTest.java b/common/src/test/java/org/apache/falcon/entity/lock/MemoryLocksTest.java index 5050b73..66746f1 100644 --- a/common/src/test/java/org/apache/falcon/entity/lock/MemoryLocksTest.java +++ b/common/src/test/java/org/apache/falcon/entity/lock/MemoryLocksTest.java @@ -20,7 +20,6 @@ package org.apache.falcon.entity.lock; import org.apache.falcon.entity.v0.Entity; import org.apache.falcon.entity.v0.EntityType; -import org.apache.falcon.entity.v0.process.*; import org.apache.falcon.entity.v0.process.Process; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/common/src/test/java/org/apache/falcon/entity/v0/EntityGraphTest.java ---------------------------------------------------------------------- diff --git a/common/src/test/java/org/apache/falcon/entity/v0/EntityGraphTest.java b/common/src/test/java/org/apache/falcon/entity/v0/EntityGraphTest.java index a8c5eb1..3863b11 100644 --- a/common/src/test/java/org/apache/falcon/entity/v0/EntityGraphTest.java +++ b/common/src/test/java/org/apache/falcon/entity/v0/EntityGraphTest.java @@ -23,7 +23,10 @@ import org.apache.falcon.entity.store.ConfigurationStore; import org.apache.falcon.entity.v0.cluster.Cluster; import org.apache.falcon.entity.v0.feed.Clusters; import org.apache.falcon.entity.v0.feed.Feed; -import org.apache.falcon.entity.v0.process.*; +import org.apache.falcon.entity.v0.process.Input; +import org.apache.falcon.entity.v0.process.Inputs; +import org.apache.falcon.entity.v0.process.Output; +import org.apache.falcon.entity.v0.process.Outputs; import org.apache.falcon.entity.v0.process.Process; import org.testng.Assert; import org.testng.annotations.Test; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/common/src/test/java/org/apache/falcon/security/SecurityUtilTest.java ---------------------------------------------------------------------- diff --git a/common/src/test/java/org/apache/falcon/security/SecurityUtilTest.java b/common/src/test/java/org/apache/falcon/security/SecurityUtilTest.java index 7f9b405..6e77462 100644 --- a/common/src/test/java/org/apache/falcon/security/SecurityUtilTest.java +++ b/common/src/test/java/org/apache/falcon/security/SecurityUtilTest.java @@ -20,7 +20,7 @@ package org.apache.falcon.security; import org.apache.falcon.FalconException; -import org.apache.falcon.entity.v0.process.*; +import org.apache.falcon.entity.v0.process.ACL; import org.apache.falcon.entity.v0.process.Process; import org.apache.falcon.util.StartupProperties; import org.mockito.Mockito; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/metrics/src/main/java/org/apache/falcon/util/ResourcesReflectionUtil.java ---------------------------------------------------------------------- diff --git a/metrics/src/main/java/org/apache/falcon/util/ResourcesReflectionUtil.java b/metrics/src/main/java/org/apache/falcon/util/ResourcesReflectionUtil.java index 3bafaee..72bc384 100644 --- a/metrics/src/main/java/org/apache/falcon/util/ResourcesReflectionUtil.java +++ b/metrics/src/main/java/org/apache/falcon/util/ResourcesReflectionUtil.java @@ -22,7 +22,8 @@ import org.apache.falcon.monitors.Alert; import org.apache.falcon.monitors.Monitored; import org.apache.falcon.monitors.TimeTaken; -import java.awt.*; + +import java.awt.Dimension; import java.lang.annotation.Annotation; import java.lang.reflect.Method; import java.util.Collections; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/oozie/src/main/java/org/apache/falcon/workflow/LateDataHandler.java ---------------------------------------------------------------------- diff --git a/oozie/src/main/java/org/apache/falcon/workflow/LateDataHandler.java b/oozie/src/main/java/org/apache/falcon/workflow/LateDataHandler.java index 2f5fb4c..a633f59 100644 --- a/oozie/src/main/java/org/apache/falcon/workflow/LateDataHandler.java +++ b/oozie/src/main/java/org/apache/falcon/workflow/LateDataHandler.java @@ -18,7 +18,11 @@ package org.apache.falcon.workflow; -import org.apache.commons.cli.*; +import org.apache.commons.cli.CommandLine; +import org.apache.commons.cli.GnuParser; +import org.apache.commons.cli.Option; +import org.apache.commons.cli.Options; +import org.apache.commons.cli.ParseException; import org.apache.falcon.FalconException; import org.apache.falcon.catalog.CatalogPartition; import org.apache.falcon.catalog.CatalogServiceFactory; @@ -37,7 +41,10 @@ import org.apache.hadoop.util.ToolRunner; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.io.*; +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.io.OutputStream; import java.net.URISyntaxException; import java.util.ArrayList; import java.util.LinkedHashMap; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java ---------------------------------------------------------------------- diff --git a/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java b/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java index 90772b8..02dcb2d 100644 --- a/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java +++ b/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java @@ -51,9 +51,17 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import org.apache.oozie.client.*; +import org.apache.oozie.client.BundleJob; +import org.apache.oozie.client.CoordinatorAction; +import org.apache.oozie.client.CoordinatorJob; import org.apache.oozie.client.CoordinatorJob.Timeunit; +import org.apache.oozie.client.Job; import org.apache.oozie.client.Job.Status; +import org.apache.oozie.client.OozieClient; +import org.apache.oozie.client.OozieClientException; +import org.apache.oozie.client.ProxyOozieClient; +import org.apache.oozie.client.WorkflowAction; +import org.apache.oozie.client.WorkflowJob; import org.apache.oozie.client.rest.RestConstants; import org.slf4j.Logger; import org.slf4j.LoggerFactory; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java ---------------------------------------------------------------------- diff --git a/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java b/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java index 1aad647..d59c5e6 100644 --- a/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java +++ b/oozie/src/test/java/org/apache/falcon/oozie/workflow/FalconPostProcessingTest.java @@ -27,7 +27,13 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import javax.jms.*; +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.Destination; +import javax.jms.JMSException; +import javax.jms.MapMessage; +import javax.jms.MessageConsumer; +import javax.jms.Session; import java.util.concurrent.CountDownLatch; /** http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java ---------------------------------------------------------------------- diff --git a/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java b/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java index e9a2491..95e0e69 100644 --- a/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java +++ b/prism/src/main/java/org/apache/falcon/resource/AbstractSchedulableEntityManager.java @@ -39,7 +39,13 @@ import javax.ws.rs.PathParam; import javax.ws.rs.QueryParam; import javax.ws.rs.core.Context; import javax.ws.rs.core.Response; -import java.util.*; +import java.util.Arrays; +import java.util.ArrayList; +import java.util.Date; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Set; /** * REST resource of allowed actions on Schedulable Entities, Only Process and http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/prism/src/main/java/org/apache/falcon/resource/proxy/BufferedRequest.java ---------------------------------------------------------------------- diff --git a/prism/src/main/java/org/apache/falcon/resource/proxy/BufferedRequest.java b/prism/src/main/java/org/apache/falcon/resource/proxy/BufferedRequest.java index c667114..85041f9 100644 --- a/prism/src/main/java/org/apache/falcon/resource/proxy/BufferedRequest.java +++ b/prism/src/main/java/org/apache/falcon/resource/proxy/BufferedRequest.java @@ -27,7 +27,11 @@ import javax.servlet.http.Cookie; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpSession; import javax.ws.rs.core.Response; -import java.io.*; +import java.io.BufferedReader; +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.io.UnsupportedEncodingException; import java.security.Principal; import java.util.Enumeration; import java.util.Locale; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java ---------------------------------------------------------------------- diff --git a/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java b/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java index 27e2476..eb281d3 100644 --- a/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java +++ b/prism/src/main/java/org/apache/falcon/resource/proxy/SchedulableEntityManagerProxy.java @@ -39,7 +39,15 @@ import org.apache.falcon.resource.channel.ChannelFactory; import org.apache.falcon.util.DeploymentUtil; import javax.servlet.http.HttpServletRequest; -import javax.ws.rs.*; +import javax.ws.rs.Consumes; +import javax.ws.rs.DefaultValue; +import javax.ws.rs.DELETE; +import javax.ws.rs.GET; +import javax.ws.rs.Path; +import javax.ws.rs.PathParam; +import javax.ws.rs.Produces; +import javax.ws.rs.POST; +import javax.ws.rs.QueryParam; import javax.ws.rs.core.Context; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/prism/src/test/java/org/apache/falcon/resource/metadata/MetadataTestContext.java ---------------------------------------------------------------------- diff --git a/prism/src/test/java/org/apache/falcon/resource/metadata/MetadataTestContext.java b/prism/src/test/java/org/apache/falcon/resource/metadata/MetadataTestContext.java index 6f798a8..05cc2e9 100644 --- a/prism/src/test/java/org/apache/falcon/resource/metadata/MetadataTestContext.java +++ b/prism/src/test/java/org/apache/falcon/resource/metadata/MetadataTestContext.java @@ -26,7 +26,11 @@ import org.apache.falcon.entity.Storage; import org.apache.falcon.entity.store.ConfigurationStore; import org.apache.falcon.entity.v0.EntityType; import org.apache.falcon.entity.v0.cluster.Cluster; -import org.apache.falcon.entity.v0.feed.*; +import org.apache.falcon.entity.v0.feed.CatalogTable; +import org.apache.falcon.entity.v0.feed.Feed; +import org.apache.falcon.entity.v0.feed.Location; +import org.apache.falcon.entity.v0.feed.LocationType; +import org.apache.falcon.entity.v0.feed.Locations; import org.apache.falcon.entity.v0.process.EngineType; import org.apache.falcon.metadata.MetadataMappingService; import org.apache.falcon.security.CurrentUser; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/prism/src/test/java/org/apache/falcon/security/ClientCertificateFilterTest.java ---------------------------------------------------------------------- diff --git a/prism/src/test/java/org/apache/falcon/security/ClientCertificateFilterTest.java b/prism/src/test/java/org/apache/falcon/security/ClientCertificateFilterTest.java index b52df28..d1f1fee 100644 --- a/prism/src/test/java/org/apache/falcon/security/ClientCertificateFilterTest.java +++ b/prism/src/test/java/org/apache/falcon/security/ClientCertificateFilterTest.java @@ -33,7 +33,10 @@ import java.security.cert.CertificateExpiredException; import java.security.cert.CertificateNotYetValidException; import java.security.cert.X509Certificate; -import static org.mockito.Mockito.*; +import static org.mockito.Mockito.doThrow; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; + /** * Test for Client Certificate auth. http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/replication/src/main/java/org/apache/falcon/replication/FeedReplicator.java ---------------------------------------------------------------------- diff --git a/replication/src/main/java/org/apache/falcon/replication/FeedReplicator.java b/replication/src/main/java/org/apache/falcon/replication/FeedReplicator.java index a8cc7e7..b2175b2 100644 --- a/replication/src/main/java/org/apache/falcon/replication/FeedReplicator.java +++ b/replication/src/main/java/org/apache/falcon/replication/FeedReplicator.java @@ -17,7 +17,11 @@ */ package org.apache.falcon.replication; -import org.apache.commons.cli.*; +import org.apache.commons.cli.CommandLine; +import org.apache.commons.cli.GnuParser; +import org.apache.commons.cli.Option; +import org.apache.commons.cli.Options; +import org.apache.commons.cli.ParseException; import org.apache.commons.lang3.StringUtils; import org.apache.falcon.FalconException; import org.apache.falcon.entity.EntityUtil; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java ---------------------------------------------------------------------- diff --git a/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java b/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java index 8327abf..ee31952 100644 --- a/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java +++ b/rerun/src/main/java/org/apache/falcon/rerun/handler/LateRerunConsumer.java @@ -32,7 +32,12 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import java.util.*; +import java.util.ArrayList; +import java.util.Date; +import java.util.LinkedHashMap; +import java.util.List; +import java.util.Map; +import java.util.Properties; /** * A consumer of late reruns. http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/rerun/src/main/java/org/apache/falcon/rerun/queue/ActiveMQueue.java ---------------------------------------------------------------------- diff --git a/rerun/src/main/java/org/apache/falcon/rerun/queue/ActiveMQueue.java b/rerun/src/main/java/org/apache/falcon/rerun/queue/ActiveMQueue.java index ec57a53..021e4cc 100644 --- a/rerun/src/main/java/org/apache/falcon/rerun/queue/ActiveMQueue.java +++ b/rerun/src/main/java/org/apache/falcon/rerun/queue/ActiveMQueue.java @@ -25,7 +25,13 @@ import org.apache.falcon.messaging.util.MessagingUtil; import org.apache.falcon.rerun.event.RerunEvent; import org.apache.falcon.rerun.event.RerunEventFactory; -import javax.jms.*; +import javax.jms.ConnectionFactory; +import javax.jms.Destination; +import javax.jms.JMSException; +import javax.jms.MessageConsumer; +import javax.jms.MessageProducer; +import javax.jms.Session; +import javax.jms.TextMessage; import java.util.List; import java.util.concurrent.TimeUnit; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/rerun/src/main/java/org/apache/falcon/rerun/queue/InMemoryQueue.java ---------------------------------------------------------------------- diff --git a/rerun/src/main/java/org/apache/falcon/rerun/queue/InMemoryQueue.java b/rerun/src/main/java/org/apache/falcon/rerun/queue/InMemoryQueue.java index 6035cdb..fe99d05 100644 --- a/rerun/src/main/java/org/apache/falcon/rerun/queue/InMemoryQueue.java +++ b/rerun/src/main/java/org/apache/falcon/rerun/queue/InMemoryQueue.java @@ -26,7 +26,14 @@ import org.apache.falcon.rerun.event.RerunEventFactory; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.io.*; +import java.io.BufferedReader; +import java.io.BufferedWriter; +import java.io.File; +import java.io.FileInputStream; +import java.io.FileOutputStream; +import java.io.IOException; +import java.io.InputStreamReader; +import java.io.OutputStreamWriter; import java.util.ArrayList; import java.util.List; import java.util.concurrent.DelayQueue; http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/retention/src/test/java/org/apache/falcon/retention/FeedEvictorTest.java ---------------------------------------------------------------------- diff --git a/retention/src/test/java/org/apache/falcon/retention/FeedEvictorTest.java b/retention/src/test/java/org/apache/falcon/retention/FeedEvictorTest.java index f68f7f6..259f5b0 100644 --- a/retention/src/test/java/org/apache/falcon/retention/FeedEvictorTest.java +++ b/retention/src/test/java/org/apache/falcon/retention/FeedEvictorTest.java @@ -32,10 +32,20 @@ import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; -import java.io.*; +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.OutputStream; +import java.io.PrintStream; import java.text.DateFormat; import java.text.SimpleDateFormat; -import java.util.*; +import java.util.Arrays; +import java.util.ArrayList; +import java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.TimeZone; import java.util.concurrent.TimeUnit; /** http://git-wip-us.apache.org/repos/asf/falcon/blob/4becb74b/webapp/src/main/java/org/apache/falcon/resource/ConfigSyncService.java ---------------------------------------------------------------------- diff --git a/webapp/src/main/java/org/apache/falcon/resource/ConfigSyncService.java b/webapp/src/main/java/org/apache/falcon/resource/ConfigSyncService.java index 9722116..3bd625c 100644 --- a/webapp/src/main/java/org/apache/falcon/resource/ConfigSyncService.java +++ b/webapp/src/main/java/org/apache/falcon/resource/ConfigSyncService.java @@ -22,7 +22,13 @@ import org.apache.falcon.monitors.Dimension; import org.apache.falcon.monitors.Monitored; import javax.servlet.http.HttpServletRequest; -import javax.ws.rs.*; +import javax.ws.rs.Consumes; +import javax.ws.rs.DELETE; +import javax.ws.rs.Path; +import javax.ws.rs.PathParam; +import javax.ws.rs.Produces; +import javax.ws.rs.POST; +import javax.ws.rs.QueryParam; import javax.ws.rs.core.Context; import javax.ws.rs.core.MediaType;