----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/73317/ -----------------------------------------------------------
(Updated June 1, 2021, 6:55 p.m.) Review request for atlas, Ashutosh Mestry, Pinal Shah, and Sarath Subramanian. Repository: atlas Description ------- ATLAS-3812: Add schema for Apache Flink Diffs (updated) ----- addons/kafka-bridge/src/main/java/org/apache/atlas/kafka/bridge/KafkaBridge.java f9548244364a8f79f346411739348d0d53298c99 addons/models/1000-Hadoop/1110-flink_model.json PRE-CREATION build-tools/src/main/resources/ui-dist/index.html 653c38b1614680ea58d7a72aa0a3a9370ec28e31 build-tools/src/main/resources/ui-dist/index.js 3ae40764c6cde3ee13a0fcb94e9e0a437ac530bc common/src/main/java/org/apache/atlas/CommonConfiguration.java edea42ba8b92722c7a90af690c409cb648bb4255 common/src/main/java/org/apache/atlas/annotation/Timed.java b892a16c743ba6747b51bb849f3d9f2164e33d9c common/src/main/java/org/apache/atlas/repository/Constants.java aea0c13111b1928a4ac3b687dcc904e729e4deaa common/src/main/java/org/apache/atlas/utils/KafkaUtils.java 16744225977088e86fa81649a1413182fdc0ffb8 common/src/test/java/org/apache/atlas/utils/KafkaUtilsTest.java 562e28ae1e6d992ea03babe2200185d8aae076c9 dashboardv2/package-lock.json 61fd944c6223985efaff10f25a69f590da30d7d6 dashboardv2/public/css/scss/override.scss c51a23c3f684f1944b960cfe3888bc3b7ccaf1a7 dashboardv2/public/css/scss/tab.scss c164b47440d35482ce222e95408b0b29c514c7de dashboardv2/public/css/scss/table.scss 121769b18c57df2c74b211e563b17d373860f4b4 dashboardv2/public/css/scss/theme.scss 4838ca3afb91830084dfd83ad9fd5cb6d26c7f2a dashboardv2/public/js/external_lib/atlas-lineage/dist/index.js 1ff212838e284cbdee092f325f4dad2a6a4c2a33 dashboardv2/public/js/main.js 7c8bbb48768382bee8df53cd72d0b995b0a152d6 dashboardv2/public/js/router/Router.js ea26bf5c08eb3dae14dd26cfe11b794a58f279b9 dashboardv2/public/js/templates/detail_page/DetailPageLayoutView_tmpl.html ee4b9431fdf3d8bda3ed9db16abe1c19eaa04aae dashboardv2/public/js/templates/detail_page/PendingTaskTableLayoutView_tmpl.html 059c42f69090ba8e90570927a9d1b958ccdfb862 dashboardv2/public/js/templates/dev_debug/DebugMetricsLayoutView_tmpl.html 78d91bf13c8f51a12cda4215b030418cb67f92c6 dashboardv2/public/js/templates/site/DebugMetricsTableLayoutView_tmpl.html 8b543680a2a61a22060ac141a9ffd1d9544fc6f5 dashboardv2/public/js/templates/site/Header.html 572e39e7804a97102c60e7e980ed309e8662c24a dashboardv2/public/js/templates/site/MetricsUIInfoView_tmpl.html 837c3b5bf9c1fd160d7ab49a109bff4a8f6937a5 dashboardv2/public/js/utils/CommonViewFunction.js bb3fa3fecd9ee2949cf3a9b27646190f5ab66133 dashboardv2/public/js/utils/Globals.js b0dc5cd77506ed19b1f2338bf9ea7868e027fd72 dashboardv2/public/js/utils/UrlLinks.js eb2980c11850f4ec2ab4c9bd6774d755de87a78b dashboardv2/public/js/utils/Utils.js f426b6c98aa1cb89d8f06196c765830ba0e7285f dashboardv2/public/js/views/audit/AuditTableLayoutView.js 625ae87c5d86280e53d390ed28dd08897b43ffe5 dashboardv2/public/js/views/detail_page/DetailPageLayoutView.js d8e10cce02b1a68fdbf54ae0535a83b0aa2cc5b2 dashboardv2/public/js/views/detail_page/PendingTaskTableLayoutView.js 0e32ebe7a34062f1e525daccc6ddda59705035f0 dashboardv2/public/js/views/dev_debug/DebugMetricsLayoutView.js 375d551c2f6629ae454226437595a4021a0a8b43 dashboardv2/public/js/views/graph/LineageLayoutView.js 5ad657e2552247b263c9bd5b2d10f4304de72b95 dashboardv2/public/js/views/import/ImportLayoutView.js 88d553c6f0f2d9fed2823e39f7260e0b390cfc8c dashboardv2/public/js/views/site/DebugMetricsTableLayoutView.js 407e489adb93599e54af4bc51a36cb583c3706f1 dashboardv2/public/js/views/site/Header.js ffb582ed4bbf80775c15a52a56f3231bebd0e5a8 dashboardv2/public/js/views/site/MetricsUIInfoView.js f46b5b84f57b5018e5d4b1d1a675907e933e0c43 dashboardv2/public/js/views/site/SideNavLayoutView.js e0f717a24cff8fda6c634f4d0e56784d526528c1 dashboardv2/public/js/views/tag/TagAttributeDetailLayoutView.js 9b8b90fc63a98c5d9b0a13541d7c28afff16378b dashboardv2/public/js/views/tag/TagDetailTableLayoutView.js c780deb7d33ee2ee60714ba908fea21c1a032262 dashboardv2/public/js/views/tag/TagLayoutView.js f40846953913531d13b0272ab68fe19d91dd60c4 dashboardv3/package-lock.json 2b00b159e41246e9033466472e69e217cb3a7349 dashboardv3/public/css/scss/override.scss 280afd694d4559cd7cd7a2d0dc6e7cb35071e15a dashboardv3/public/css/scss/tab.scss c164b47440d35482ce222e95408b0b29c514c7de dashboardv3/public/css/scss/table.scss 121769b18c57df2c74b211e563b17d373860f4b4 dashboardv3/public/js/external_lib/atlas-lineage/dist/index.js 1ff212838e284cbdee092f325f4dad2a6a4c2a33 dashboardv3/public/js/main.js 374641ee01b697f9b74d7cc3888fb4e885f1a88e dashboardv3/public/js/router/Router.js bd50715576e6084bd0bb71f3a6da6095fa754b17 dashboardv3/public/js/templates/detail_page/DetailPageLayoutView_tmpl.html b209a49e4af62f211d62e3692b887de78dbb42af dashboardv3/public/js/templates/detail_page/PendingTaskTableLayoutView_tmpl.html 059c42f69090ba8e90570927a9d1b958ccdfb862 dashboardv3/public/js/templates/dev_debug/DebugMetricsLayoutView_tmpl.html 78d91bf13c8f51a12cda4215b030418cb67f92c6 dashboardv3/public/js/templates/site/DebugMetricsTableLayoutView_tmpl.html 8b543680a2a61a22060ac141a9ffd1d9544fc6f5 dashboardv3/public/js/templates/site/Header.html a8ff7f9b5c3bf27a074184f3a2dd34e1a58e3c4a dashboardv3/public/js/templates/site/MetricsUIInfoView_tmpl.html 837c3b5bf9c1fd160d7ab49a109bff4a8f6937a5 dashboardv3/public/js/utils/CommonViewFunction.js 34afa2d20c6b2fa4523ff1d736f4f7bbf6b9c5a1 dashboardv3/public/js/utils/Globals.js b0dc5cd77506ed19b1f2338bf9ea7868e027fd72 dashboardv3/public/js/utils/UrlLinks.js b500ebdd7e54f78a8ac8f257fbc5004a39f20769 dashboardv3/public/js/utils/Utils.js 1a73b7c14649d55ce7541178b13a2373ea6136f2 dashboardv3/public/js/views/audit/AuditTableLayoutView.js 625ae87c5d86280e53d390ed28dd08897b43ffe5 dashboardv3/public/js/views/detail_page/DetailPageLayoutView.js 8e0686bb7c525825b3d9d70713f27b54ce4798ec dashboardv3/public/js/views/detail_page/PendingTaskTableLayoutView.js 0e32ebe7a34062f1e525daccc6ddda59705035f0 dashboardv3/public/js/views/dev_debug/DebugMetricsLayoutView.js 375d551c2f6629ae454226437595a4021a0a8b43 dashboardv3/public/js/views/graph/LineageLayoutView.js 954d9afbda05d1b1d0ebe1fc2434ca67974021cb dashboardv3/public/js/views/import/ImportLayoutView.js 88d553c6f0f2d9fed2823e39f7260e0b390cfc8c dashboardv3/public/js/views/search/tree/ClassificationTreeLayoutView.js 75e53cdb6fd9aa2d20a91a4fbca9c4c98b02f17d dashboardv3/public/js/views/search/tree/GlossaryTreeLayoutView.js e58b17780abb13e6a0d9d9aa75a32de5292e9564 dashboardv3/public/js/views/site/DebugMetricsTableLayoutView.js 407e489adb93599e54af4bc51a36cb583c3706f1 dashboardv3/public/js/views/site/Header.js e2ecd7e725d610cf692f91b9357f28cf94376470 dashboardv3/public/js/views/site/MetricsUIInfoView.js f46b5b84f57b5018e5d4b1d1a675907e933e0c43 dashboardv3/public/js/views/tag/TagAttributeDetailLayoutView.js 6e10155240c1f3e3ff18275131376dddb5568612 dashboardv3/public/js/views/tag/TagDetailTableLayoutView.js 809c1439213d1f1ba9b48d2d53114ae7cc38bbd8 distro/src/conf/hadoop-metrics2.properties 52c1d4fc80b79a5e27a9d69e1c452fbee75036e5 graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasSolrQueryBuilder.java adc552899f78b0a4b58a98e150fcc2430e6e1d14 graphdb/janus/src/test/java/org/apache/atlas/repository/graphdb/janus/AtlasSolrQueryBuilderTest.java 58e2b64f5e81b7f51561f967a0e34e91076910c2 intg/src/main/java/org/apache/atlas/AtlasConfiguration.java e31afa89ae0a4a431744bba9883237fd4179167b intg/src/main/java/org/apache/atlas/AtlasErrorCode.java 2febff469de28c1b527b2f4ccba039b41675fd11 intg/src/main/java/org/apache/atlas/model/discovery/AtlasSearchResult.java ce0f84b6e0120db89f534b93ea0a6dd60dfe6c3e intg/src/main/java/org/apache/atlas/model/discovery/SearchParameters.java 78fb4a48f8165fe2df865a1ff1925f9b3c4a803a intg/src/main/java/org/apache/atlas/model/glossary/AtlasGlossaryTerm.java f0f362b3e4e7056f7c7ae5d2bfde34b3edc602d8 intg/src/main/java/org/apache/atlas/model/glossary/AtlasGlossaryTermHeader.java f807ba2438de4669d5cfe7f8d4da6941ba3d5030 intg/src/main/java/org/apache/atlas/model/instance/ClassificationAssociateRequest.java f22521364be4dd3aa22797f436c5b8e15a58c25f intg/src/main/java/org/apache/atlas/model/notification/AtlasNotificationMessage.java 5869910cbed689c2789b052e10edc96d43f8e1d2 intg/src/main/python/apache_atlas/client/entity.py 14cb4ed602411b70d0988482726d5ed69468ba3d intg/src/main/python/apache_atlas/utils.py 01d0762be267e2474789bb28959aa9e4684fc52e notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java 96dc5856af39c89e509a87af1d91db3c61942092 notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaMessage.java af3727df457421e78e4a6e0b3b0a3f791b430b50 notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java 32f5183a00ae7d4437e8d44249204716d5c7b02d notification/src/main/java/org/apache/atlas/notification/AtlasNotificationMessageDeserializer.java b43bc7c66a7a73c655d19ddf36eb214fa5da7283 notification/src/main/java/org/apache/atlas/notification/NotificationInterface.java 3d8d9cc0a06d5b64b8359e14585205cf8e1cbc98 notification/src/main/java/org/apache/atlas/notification/spool/AtlasFileSpool.java ea3128465c03cd6125b74ceedf718ee37ed11aa0 notification/src/main/java/org/apache/atlas/notification/spool/IndexManagement.java f018983a4135e472f12a4716cf6e4c3a5f0db3c9 notification/src/main/java/org/apache/atlas/notification/spool/Publisher.java 01ead7db503420e56cb398983c4151897a19fa2f notification/src/main/java/org/apache/atlas/notification/spool/SpoolConfiguration.java 76f05efea73432285f49be6b921e51d9792f24de notification/src/main/java/org/apache/atlas/notification/spool/Spooler.java a918e9bb1dd31a9a5608e47bf635239d81874df1 notification/src/test/java/org/apache/atlas/notification/AbstractNotificationTest.java 8078a6ceb39f2c5044a83f3d91690a66ac7b5c32 notification/src/test/java/org/apache/atlas/notification/spool/AtlasFileSpoolTest.java 265598eeb7682f384b6011369c9735d7042e8311 notification/src/test/java/org/apache/atlas/notification/spool/BaseTest.java 304c8212219ed3c7c7da4658561fba065a5c8987 pom.xml 91c23ee044fed1b181d5ceeab9c16c54cff31bc7 repository/src/main/java/org/apache/atlas/discovery/ClassificationSearchProcessor.java dfcc441ccb1c1febd1907ac97e95bba85887984a repository/src/main/java/org/apache/atlas/discovery/EntityDiscoveryService.java f2290c672cb24a2ff410a94acbb2acff9af90dd1 repository/src/main/java/org/apache/atlas/discovery/EntitySearchProcessor.java f45ccaf24f29500ddff1701ff160ea2ebcd409eb repository/src/main/java/org/apache/atlas/discovery/FreeTextSearchProcessor.java 86f2cea236b1b94b016368a6c9ad9f1ba83cefdb repository/src/main/java/org/apache/atlas/discovery/FullTextSearchProcessor.java 2d8a448b13dd3bbab52aef3dc61ba9d4effbaaea repository/src/main/java/org/apache/atlas/discovery/SearchContext.java 01954d07e5e7a11c0f90e7849be31c33e55dc8e0 repository/src/main/java/org/apache/atlas/discovery/SearchProcessor.java f69dc42157befb9563368d9559452bf01ea348ce repository/src/main/java/org/apache/atlas/discovery/TermSearchProcessor.java b8a507eac87edad05866345a365e749fc010840e repository/src/main/java/org/apache/atlas/glossary/GlossaryService.java 9c8459874268f870349b09e76fa2bc638cf8e197 repository/src/main/java/org/apache/atlas/glossary/GlossaryTermUtils.java d92daeea59f05dddb605b76bf557c74b3c9690cb repository/src/main/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexer.java ddfb0089ed6902522f48200dfb8f4a4bc5e85150 repository/src/main/java/org/apache/atlas/repository/store/graph/EntityCorrelationStore.java 4760757ff59023650e2d025cea2aebd87870936b repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java f118ae69abe3f695a7c6fed95699f28941aad881 repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasEntityStoreV2.java 0f12bd31e051489683681a1f1e74c7c567bf70df repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasGraphUtilsV2.java e73f084b883fa316b41ba20570f5d929c1226c2d repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasRelationshipDefStoreV2.java 7bc4b28c36498b4b0ce469b98d62eb4fae7f6fb7 repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphMapper.java b51cbfc78bebb9f1b6c323f83bcf5a6eb667caa6 repository/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphRetriever.java 794847555a22d4ae1ae46307478515a78a32f0f5 repository/src/main/java/org/apache/atlas/repository/store/graph/v2/tasks/ClassificationPropagateTaskFactory.java b3320c60763c827bc409ad9498d6b8a1c72716ca repository/src/main/java/org/apache/atlas/repository/store/graph/v2/tasks/ClassificationPropagationTasks.java aec5b0cf7bbb4d8528abd797cd423c2047f909ce repository/src/main/java/org/apache/atlas/repository/store/graph/v2/tasks/ClassificationTask.java 00c9caaa7a6fda68bb179279912de53782d23b4d repository/src/main/java/org/apache/atlas/tasks/TaskFactoryRegistry.java 4c93f0eeeb8720997fa37badb1d6b1347cdf712a repository/src/main/java/org/apache/atlas/tasks/TaskManagement.java 9a519bacc50d7fe40618442f2f4604c528799835 repository/src/test/java/org/apache/atlas/discovery/AtlasDiscoveryServiceTest.java a9fbd435af19d22b4c973ec70de9e46a0c82249e repository/src/test/java/org/apache/atlas/discovery/ClassificationSearchProcessorTest.java 121dca9f53d522a29f8933a83de53b2b98268e7d repository/src/test/java/org/apache/atlas/repository/store/graph/v2/DifferentialAuditsTest.java d10774f3daa82bb25b9e0cc091dc95fb49f7b337 repository/src/test/java/org/apache/atlas/repository/store/graph/v2/EntityCorrelationStoreTest.java a3be5f4ed282346b39a94180c8beaa60f9fb0a24 repository/src/test/java/org/apache/atlas/repository/tagpropagation/ClassificationPropagationWithTasksTest.java d440f2f2dd9a01e2d15625dc338a35a172fa3257 repository/src/test/resources/json/entities/db01.json 470d180395bb5a0213e4f7006c7d2109fa046d63 repository/src/test/resources/json/entities/tbl01-2cols.json 52f34cd921fdb1289057e1a484cfb74ad4385547 repository/src/test/resources/json/entities/tbl01.json 50251f0fe5c84887e6c0fce5bb67830ebe508f52 test-tools/src/main/resources/solr/core-template/solrconfig.xml e7956cb3633dcb8c471e4a221bd6b54bc418e160 webapp/src/main/java/org/apache/atlas/examples/QuickStartV2.java 5309d199394193b6e18726a39337eaa0e4e06bec webapp/src/main/java/org/apache/atlas/notification/EntityCorrelationManager.java f1d6aff463466594be29e16690c391435deb2b4a webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java 5643af95c05331054194d78d975b2202839c7387 webapp/src/main/java/org/apache/atlas/notification/preprocessor/EntityPreprocessor.java 7f0cafe86b074706339e4b86060fa38b0ef91a6c webapp/src/main/java/org/apache/atlas/notification/preprocessor/HiveDbDDLPreprocessor.java dcff0939d335735eb6719f8f29737c799a75c835 webapp/src/main/java/org/apache/atlas/notification/preprocessor/HivePreprocessor.java bf6a623fe8016a71fcbf76962507ec96c293a8e4 webapp/src/main/java/org/apache/atlas/notification/preprocessor/HiveTableDDLPreprocessor.java 83d4d7c1a26101d44663d50b7b0f7be2d319b367 webapp/src/main/java/org/apache/atlas/notification/preprocessor/PreprocessorContext.java 59f6440d51d0339c20bb6a5dd4979fb00c0ba144 webapp/src/main/java/org/apache/atlas/web/filters/AtlasCSRFPreventionFilter.java 429ff1cf948fceb65380a93fd4aa0641b9504a43 webapp/src/main/java/org/apache/atlas/web/model/DebugMetrics.java 856a6fbecf8116fe648106c63601e00db0813d75 webapp/src/main/java/org/apache/atlas/web/resources/AdminResource.java 01fb8ec0292cd97fd66ef5a6597a80f6bae9176e webapp/src/main/java/org/apache/atlas/web/rest/DiscoveryREST.java e4c74a9d1a4b5a471a4423244d6e758bcb5bc60b webapp/src/main/java/org/apache/atlas/web/rest/EntityREST.java 05d7d13f7ae8120a14346859fc28b855ff88924a webapp/src/main/java/org/apache/atlas/web/rest/GlossaryREST.java c1de83be9a5f90b2cd9f631dd0bd2d48c21955f9 webapp/src/main/java/org/apache/atlas/web/rest/LineageREST.java 30b5626072f76a1ae77ca459be5e8f88ec6a125b webapp/src/main/java/org/apache/atlas/web/rest/RelationshipREST.java 04114d9e67ddcfa8f4867de832ea249bbcb7d890 webapp/src/main/java/org/apache/atlas/web/rest/TypesREST.java 30786dc9dc80072d26c31c090c96dd7a1fd3370c webapp/src/main/java/org/apache/atlas/web/service/AtlasDebugMetricsSink.java ef24b861ea08edeac794c1edf24e052d48d5e8a8 webapp/src/main/java/org/apache/atlas/web/service/AtlasDebugMetricsSource.java 63e979ac2f6bfaadf2904c0cdee5a457f1b69887 webapp/src/main/java/org/apache/atlas/web/service/DebugMetricsWrapper.java 0d2da1b97ecbaf86fe431b348436579c11123f05 webapp/src/main/java/org/apache/atlas/web/service/TimedAspectInterceptor.java 64225d0619c08ce5cb36271c9ef84babb46b0144 webapp/src/main/webapp/WEB-INF/web.xml 7fb56efded4eccbe28ac8443f77c72f741e50bcb webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerKafkaTest.java fdfc2560de4f68c622c2bbffecaa20ad5f6331fd webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerTest.java f440c4293cfa0a00fd248c405fa321e2ccd31e98 webapp/src/test/java/org/apache/atlas/web/filters/AtlasCSRFPreventionFilterTest.java 841cfaf941f584c31a183ea31f1c6a332fc8a706 webapp/src/test/java/org/apache/atlas/web/integration/BaseResourceIT.java 9d5a9e5c38343029bcfa0fbced8c7046264a30a8 webapp/src/test/java/org/apache/atlas/web/integration/DebugMetricsIT.java 3c614d480c50cb0213d3f0b672163f01aea7739e webapp/src/test/java/org/apache/atlas/web/resources/AdminResourceTest.java a4d794615f52e9d0e82828b2434539e7ee627f06 webapp/src/test/resources/atlas-application.properties 1d45e78f355f38dfcce028f588ee803aff9acbc1 Diff: https://reviews.apache.org/r/73317/diff/3/ Changes: https://reviews.apache.org/r/73317/diff/2-3/ Testing ------- Tested on my CDH cluster with flink example wordcount streaming job. File Attachments ---------------- Screen Shot 2021-04-30 at 12.38.27 AM.png https://reviews.apache.org/media/uploaded/files/2021/04/30/2ff59445-7237-4be1-a1a0-b6db70bc7827__Screen_Shot_2021-04-30_at_12.38.27_AM.png Thanks, Josh Yeh
