Merge remote-tracking branch 'origin/master' into branch-0.5
Project: http://git-wip-us.apache.org/repos/asf/eagle/repo Commit: http://git-wip-us.apache.org/repos/asf/eagle/commit/31aa29f5 Tree: http://git-wip-us.apache.org/repos/asf/eagle/tree/31aa29f5 Diff: http://git-wip-us.apache.org/repos/asf/eagle/diff/31aa29f5 Branch: refs/heads/branch-0.5 Commit: 31aa29f593c7adeda50c755569a59493152d3e60 Parents: 31f2582 8da0663 Author: Jay <[email protected]> Authored: Sun May 7 11:11:00 2017 -0700 Committer: Jay <[email protected]> Committed: Sun May 7 11:11:00 2017 -0700 ---------------------------------------------------------------------- .travis.yml | 18 +- eagle-assembly/src/main/doc/metadata-ddl.sql | 7 - .../src/assembly/alert-assembly.xml | 3 +- .../engine/coordinator/AlertDeduplication.java | 71 ++ .../engine/coordinator/PolicyDefinition.java | 13 +- .../engine/coordinator/PublishmentType.java | 21 +- .../publisher/email/AlertEmailGenerator.java | 4 +- .../publisher/impl/AbstractPublishPlugin.java | 17 +- .../publisher/impl/AlertEmailPublisher.java | 2 - .../publisher/impl/AlertPublisherImpl.java | 43 +- .../publisher/impl/DefaultDeduplicator.java | 10 +- .../template/VelocityAlertTemplateEngine.java | 8 +- .../alert/engine/runner/AlertPublisherBolt.java | 18 +- .../alert/engine/spout/CorrelationSpout.java | 14 +- .../main/resources/ALERT_INLINED_TEMPLATE.vm | 2 +- .../VelocityAlertTemplateEngineTest.java | 2 +- .../metadata/impl/JdbcMetadataDaoImpl.java | 2 +- .../metadata/impl/JdbcMetadataHandler.java | 30 + .../app/environment/AbstractEnvironment.java | 10 + .../environment/impl/StormExecutionRuntime.java | 31 +- .../ExecutionRuntimeManagerTest.java | 45 + .../apache/eagle/common/config/EagleConfig.java | 2 +- .../eagle/common/config/EagleConfigFactory.java | 2 +- .../eagle/service/hbase/EmbeddedHBase.java | 141 +++ .../eagle/service/hbase/EmbeddedHbase.java | 141 --- .../eagle/service/hbase/EmbeddedHBaseTest.java | 28 + .../eagle/service/hbase/EmbeddedHbaseTest.java | 28 - .../eagle/audit/listener/TestAuditSupport.java | 2 +- .../eagle/service/client/ClientTestBase.java | 6 +- .../log/entity/TestHBaseWritePerformance.java | 100 +++ .../log/entity/TestHbaseWritePerformance.java | 100 --- .../apache/eagle/query/TestHBaseLogReader2.java | 4 +- .../EagleServiceSelfCheckAPIEntity.java | 8 +- .../EagleServiceSelfCheckResource.java | 4 +- .../storage/hbase/HBaseEntitySchemaManager.java | 2 +- eagle-external/eagle-cdh/README.md | 66 ++ eagle-external/eagle-cdh/assembly.xml | 29 + eagle-external/eagle-cdh/pom.xml | 51 ++ .../eagle-cdh/src/descriptor/service.sdl | 868 +++++++++++++++++++ eagle-external/eagle-cdh/src/images/icon.png | Bin 0 -> 3346 bytes eagle-external/eagle-cdh/src/scripts/control.sh | 35 + eagle-external/pom.xml | 1 + .../analyzer/mr/MRJobPerformanceAnalyzer.java | 12 +- .../mr/suggestion/JobSuggestionEvaluator.java | 12 +- .../apache/eagle/jpm/analyzer/util/Utils.java | 53 +- .../jpm/mr/history/storm/JobHistorySpout.java | 4 +- .../jpm/mr/history/JHFEventReaderBaseTest.java | 74 ++ .../src/test/resources/application.conf | 74 ++ .../resources/job_1479206441898_508949_conf.xml | 191 +++- .../eagle/jpm/util/jobcounter/JobCounters.java | 3 +- .../apps/hbase/ctrls/backupMasterListCtrl.js | 4 +- .../app/apps/hbase/ctrls/regionListCtrl.js | 2 +- .../src/main/webapp/app/apps/hbase/index.js | 4 +- .../app/apps/hdfs/ctrl/datanodeListCtrl.js | 2 +- .../app/apps/hdfs/ctrl/namenodeListCtrl.js | 2 +- .../security/entity/HBaseResourceEntity.java | 105 +++ .../security/entity/HbaseResourceEntity.java | 105 --- .../security/hdfs/MAPRFSAuditLogParser.java | 20 +- .../service/HBaseSensitivityEntity.java | 4 +- .../security/service/InMemMetadataDaoImpl.java | 3 +- .../service/JDBCSecurityMetadataDAO.java | 4 +- .../audit/JDBCSecurityMetadataDAOTest.java | 2 +- .../audit/TestMetaDataAccessConfigRepo.java | 2 +- .../eagle-security-hbase-auditlog/README.md | 2 +- .../hbase/HBaseAuditLogApplication.java | 2 +- .../security/hbase/HBaseAuditLogObject.java | 28 + .../security/hbase/HBaseAuditLogParser.java | 148 ++++ .../security/hbase/HBaseAuditLogParserBolt.java | 4 +- .../HBaseResourceSensitivityDataJoinBolt.java | 80 ++ .../hbase/HBaseSensitivityDataEnrichLCM.java | 2 +- .../security/hbase/HbaseAuditLogObject.java | 28 - .../security/hbase/HbaseAuditLogParser.java | 148 ---- .../HbaseResourceSensitivityDataJoinBolt.java | 80 -- ....security.hbase.HBaseAuditLogAppProvider.xml | 4 +- .../security/hbase/TestHBaseAuditLogParser.java | 44 + .../security/hbase/TestHbaseAuditLogParser.java | 44 - .../hbase/HBaseMetadataBrowseWebResource.java | 189 ++++ .../hbase/HBaseMetadataBrowseWebResponse.java | 45 + .../hbase/HbaseMetadataBrowseWebResource.java | 190 ---- .../hbase/HbaseMetadataBrowseWebResponse.java | 45 - .../hbase/dao/HBaseMetadataDAOImpl.java | 95 ++ .../hbase/dao/HbaseMetadataDAOImpl.java | 95 -- .../hbase/resolver/HBaseActionResolver.java | 41 + .../hbase/resolver/HBaseMetadataResolver.java | 130 +++ .../hbase/resolver/HBaseRequestResolver.java | 67 ++ .../resolver/HBaseSensitivityTypeResolver.java | 58 ++ .../hbase/resolver/HbaseActionResolver.java | 41 - .../hbase/resolver/HbaseMetadataResolver.java | 130 --- .../hbase/resolver/HbaseRequestResolver.java | 67 -- .../resolver/HbaseSensitivityTypeResolver.java | 58 -- .../hbase/TestHBaseMetadataResolver.java | 41 + .../hbase/TestHbaseMetadataResolver.java | 41 - .../extractor/TopologyExtractorFactory.java | 5 +- .../extractor/hbase/HBaseTopologyCrawler.java | 58 ++ .../hbase/HBaseTopologyEntityParser.java | 176 ++++ .../extractor/hbase/HbaseTopologyCrawler.java | 61 -- .../hbase/HbaseTopologyEntityParser.java | 176 ---- ....eagle.topology.TopologyCheckAppProvider.xml | 10 +- .../topology/TestHBaseTopologyCrawler.java | 40 + .../topology/TestHbaseTopologyCrawler.java | 40 - .../eagle/topology/TopologyConstants.java | 2 +- pom.xml | 2 +- 102 files changed, 3383 insertions(+), 1805 deletions(-) ----------------------------------------------------------------------
