Findbugs on develop branch

Build: #954 was successful Scheduled with changes by Ali Anwar and Sreevatsan Raman

Code commits

Showing 100 of 276 code changes

CDAP

  • Sreevatsan Raman

    Sreevatsan Raman 750e66b8d5ef927f25b795ba21dd13823b5309e6

    Merge pull request #9517 from caskdata/merge-release/4.3-to-develop
    Merge release/4.3 to develop

  • Ali Anwar

    Ali Anwar 25d3c985905a76ac46c0093c577bd2ca63def064

    Merge branch 'release/4.3' into merge-release/4.3-to-develop

  • Tony Bach

    Tony Bach 9a336e8b04dc20c859835a805e63d5474fecab2c m

    Merge pull request #9508 from caskdata/bugfix_release/microservice-missing-message
    Fixes regression where helper text doesn't show up even when user doesn't have microservice-core artifact

  • Tony Bach

    Tony Bach 903b50fda1bbaac082ef76cd1b24756d2f5d5ce5 m

    Fixes regression where helper text doesn't show up even when user doesn't have microservice-core artifact - Changes helper text, as well as change Rules engine welcome screen message

    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/index.js (version 903b50fda1bbaac082ef76cd1b24756d2f5d5ce5)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesEngineServiceControl/index.js (version 903b50fda1bbaac082ef76cd1b24756d2f5d5ce5)
    • cdap-ui/app/cdap/text/text-en.yaml (version 903b50fda1bbaac082ef76cd1b24756d2f5d5ce5)
  • Chengfeng Mao <mao@cask.co>

    Chengfeng Mao <mao@cask.co> 435931b968f9c2f2c479b1d5d9bff5a4c0de1722 m

    Merge pull request #9510 from caskdata/feature_release/fix-app-with-tx-timeout
    Fix TestFrameworkTestRun#testAppWithTxTimeout

  • Chengfeng <mao@cask.co>

    Chengfeng <mao@cask.co> da35a3dad2370de28fd0f92580f88c2bf5dc3cbf m

    Fix TestFrameworkTestRun#testAppWithTxTimeout by waiting for FAILED status

    • cdap-unit-test/src/test/java/co/cask/cdap/test/app/TestFrameworkTestRun.java (version da35a3dad2370de28fd0f92580f88c2bf5dc3cbf)
  • Joe Farned <joefarned@gmail.com>

    Joe Farned <joefarned@gmail.com> 300977e4049d1ccdd64aaf94f0a4ac187b401904 m

    Merge pull request #9449 from caskdata/docs/update-user-guide
    Add four new tutorials

  • Joe Farned <joefarned@Joes-MacBook-Pro-2.local>

    Joe Farned <joefarned@Joes-MacBook-Pro-2.local> 6c6a252c7c10b9026b34578eee8a0a16e67c434d m

    moved videos to Cask channel, updated plugin names for 4.3

    • cdap-docs/user-guide/source/tutorials/campaign.rst (version 6c6a252c7c10b9026b34578eee8a0a16e67c434d)
    • cdap-docs/user-guide/source/tutorials/fitbit.rst (version 6c6a252c7c10b9026b34578eee8a0a16e67c434d)
    • cdap-docs/user-guide/source/tutorials/logistic.rst (version 6c6a252c7c10b9026b34578eee8a0a16e67c434d)
    • cdap-docs/user-guide/source/tutorials/nytimes-xml.rst (version 6c6a252c7c10b9026b34578eee8a0a16e67c434d)
    • cdap-docs/user-guide/source/tutorials/stocks.rst (version 6c6a252c7c10b9026b34578eee8a0a16e67c434d)
  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> 0ec3c72106f5f1b5c1d30070be9b20c2627d2009 m

    Merge pull request #9507 from caskdata/fix/CDAP-12263
    CDAP-12263 Updated documentation to make it clear that in truncate method implementation has to disable/enable table.

  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> c14e78515dcc429bd70580568d68f8e41184eefe m

    CDAP-12263 Updated documentation to make it clear that in truncate method implmentation has to disable/enable table.

    • cdap-hbase-spi/src/main/java/co/cask/cdap/spi/hbase/HBaseDDLExecutor.java (version c14e78515dcc429bd70580568d68f8e41184eefe)
  • Sreevatsan Raman

    Sreevatsan Raman f1dd85edfe1921c5db146244074cc30d223323c6 m

    Merge pull request #9505 from caskdata/feature_release/fix-app-meta-test
    Fix AppMetadataStoreTest by only recording valid run status

  • Sreevatsan Raman

    Sreevatsan Raman aa29a7f7c8033f7fc1fc5691c37d3bedf8d64900 m

    Merge pull request #9506 from caskdata/feature_release/CDAP-12277-upgrade-twill
    Upgrade to Twill 0.12.0 release

  • Terence Yim

    Terence Yim 759403eaa6b3ec9b8be065ec1935e89a7dc1e954 m

    Upgrade to Twill 0.12.0 release

    • pom.xml (version 759403eaa6b3ec9b8be065ec1935e89a7dc1e954)
  • Chengfeng <mao@cask.co>

    Chengfeng <mao@cask.co> 5e746711155450dabf594a3148a7f30ca5a5c24a m

    Fix AppMetadataStoreTest by only recording valid run status

    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/store/AppMetadataStore.java (version 5e746711155450dabf594a3148a7f30ca5a5c24a)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/store/AppMetadataStoreTest.java (version 5e746711155450dabf594a3148a7f30ca5a5c24a)
  • Chengfeng Mao <mao@cask.co>

    Chengfeng Mao <mao@cask.co> f32e3d9b93ec440c34b6c58d9eba71d64b8e3dda m

    Merge pull request #9496 from caskdata/feature_release/triggering-pipeline-property
    [CDAP-12382] Properties mapping from triggering pipeline to arguments in triggered pipeline

  • Chengfeng <mao@cask.co>

    Chengfeng <mao@cask.co> 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb m

    [CDAP-12382] Properties mapping from triggering pipeline to arguments in triggered pipeline

    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/main/java/co/cask/cdap/datapipeline/JavaSparkMainWrapper.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/main/java/co/cask/cdap/datapipeline/SmartWorkflow.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/main/scala/co/cask/cdap/datapipeline/ScalaSparkMainWrapper.scala (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/test/java/co/cask/cdap/datapipeline/DataPipelineTest.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/ETLWorkflow.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/condition/PipelineCondition.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/customaction/PipelineAction.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/mapreduce/ETLMapReduce.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/mapreduce/MapReduceTransformExecutorFactory.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/BasicArguments.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/DefaultMacroEvaluator.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-proto/src/main/java/co/cask/cdap/etl/proto/v2/ArgumentMapping.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-proto/src/main/java/co/cask/cdap/etl/proto/v2/PluginPropertyMapping.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/cdap-etl-proto/src/main/java/co/cask/cdap/etl/proto/v2/TriggeringPropertyMapping.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/SparkPipelineRunner.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/batch/ETLSpark.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/PluginFunctionContext.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/streaming/function/StreamingAlertPublishFunction.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/streaming/function/StreamingBatchSinkFunction.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/streaming/function/StreamingSparkSinkFunction.java (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-ui/app/cdap/components/PipelineTriggers/PipelineListTab/PipelineTriggersRow.js (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
    • cdap-ui/app/cdap/components/PipelineTriggers/ScheduleRuntimeArgs/ScheduleRuntimeArgsStore.js (version 4617f1b1c6763d69cfcd4f98589f36d4800b8bbb)
  • Chengfeng Mao <mao@cask.co>

    Chengfeng Mao <mao@cask.co> 57429b24f0d141d965d05e9775343fa7c0d85aae m

    Merge pull request #9470 from caskdata/feature_release/program-state-transition-refactor
    [CDAP-12423] Refactor AppMetadataStore to prevent program status change race condition

  • Chengfeng <mao@cask.co>

    Chengfeng <mao@cask.co> ce0b6b4c2aa078054fce3ca958856b314314fd79 m

    [CDAP-12423] Refactor AppMetadataStore to prevent program status change race condition

    • cdap-app-fabric-tests/src/test/java/co/cask/cdap/internal/app/services/http/handlers/WorkflowStatsSLAHttpHandlerTest.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric-tests/src/test/java/co/cask/cdap/runtime/WorkflowTest.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/guice/DistributedProgramRunnerModule.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/guice/InMemoryProgramRunnerModule.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/store/Store.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/AbstractNotificationSubscriberService.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/AbstractRunRecordCorrectorService.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/DistributedRunRecordCorrectorService.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/LocalRunRecordCorrectorService.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/ProgramNotificationSubscriberService.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/store/AppMetadataStore.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/store/DefaultStore.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/ScheduleNotificationSubscriberService.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/AppFabricTestHelper.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/schedule/constraint/ConcurrencyConstraintTest.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/schedule/constraint/LastRunConstraintTest.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/RunRecordCorrectorServiceTest.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/store/AppMetadataStoreTest.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/store/DefaultStoreTest.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-app-fabric/src/test/java/co/cask/cdap/metadata/LineageAdminTest.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-common/src/main/java/co/cask/cdap/internal/app/store/RunRecordMeta.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-data-fabric/src/main/java/co/cask/cdap/data2/dataset2/lib/table/MetadataStoreDataset.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
    • cdap-gateway/src/test/java/co/cask/cdap/gateway/handlers/log/MockLogReader.java (version ce0b6b4c2aa078054fce3ca958856b314314fd79)
  • Yaojie Feng

    Yaojie Feng b84ae7de8ddb94ddcd9a3c9ab79844f6e1c2381b m

    Merge pull request #9504 from caskdata/feature_release/cdap-12489-change-get-to-any-privilegese
    CDAP-12489 change get to any privilege

  • Yaojie Feng

    Yaojie Feng 910d6cbf5da485f9e4a8342671d353c94dd1b3c0 m

    CDAP-12489 change get to any privilege

    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/artifact/AuthorizationArtifactRepository.java (version 910d6cbf5da485f9e4a8342671d353c94dd1b3c0)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/ApplicationLifecycleService.java (version 910d6cbf5da485f9e4a8342671d353c94dd1b3c0)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/ProgramLifecycleService.java (version 910d6cbf5da485f9e4a8342671d353c94dd1b3c0)
    • cdap-data-fabric/src/main/java/co/cask/cdap/data2/datafabric/dataset/service/AuthorizationDatasetTypeService.java (version 910d6cbf5da485f9e4a8342671d353c94dd1b3c0)
    • cdap-data-fabric/src/main/java/co/cask/cdap/data2/datafabric/dataset/service/DatasetInstanceService.java (version 910d6cbf5da485f9e4a8342671d353c94dd1b3c0)
    • cdap-data-fabric/src/main/java/co/cask/cdap/data2/transaction/stream/FileStreamAdmin.java (version 910d6cbf5da485f9e4a8342671d353c94dd1b3c0)
  • Ajai Narayan

    Ajai Narayan 0f0cc6955080224213bfb30cf6b852d32360f934 m

    Merge pull request #9503 from caskdata/bugfix_release/ui-CDAP-12475
    [CDAP-12475] Reskins Dataprep/Rules Engine welcome screen

  • Ajai Narayan

    Ajai Narayan be0713524cf5f7c460f36d1f4d0ec39c4f40d987 m

    [CDAP-12475] Reskins Dataprep/Rules Engine welcome screen
      - Reskins welcome screen in Rules Engine home page
      - Modifies daatprep welcome screen to be consistent(ish)

    • cdap-ui/app/cdap/components/DataPrep/DataPrepServiceControl/DataPrepServiceControl.scss (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/components/DataPrep/DataPrepServiceControl/index.js (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesEngineServiceControl/RulesEngineServiceControl.scss (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesEngineServiceControl/index.js (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/styles/img/RulesEnginePreview1.png (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/styles/img/RulesEnginePreview1_old.png (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/styles/img/RulesEnginePreview2.png (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/styles/img/RulesEngine_preview_1.png (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/styles/img/RulesEngine_preview_2.png (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
    • cdap-ui/app/cdap/text/text-en.yaml (version be0713524cf5f7c460f36d1f4d0ec39c4f40d987)
  • Sreevatsan Raman

    Sreevatsan Raman bdd10a4f71bbd5c9398622b101a71da3b7254bb8 m

    Merge pull request #9482 from caskdata/bugfix_release/fix-authorizable-parsing
    CDAP-12473 Fix parsing of dataset names in authorizable

  • Ajai Narayan

    Ajai Narayan 44173f3b5d0e08de8bbfdf43336613f55ce10ae3 m

    Merge pull request #9465 from caskdata/bugfix_release/ui-pipeline-upgrade
    [CDAP-12447] Pipeline Upgrade Bugfix

  • Tony Bach

    Tony Bach 048e17c4718474406cca45ad90428d54b0ce11d8 m

    Merge pull request #9502 from caskdata/bugfix_release/rules_engine_hide_delete
    [CDAP-12483] Remove delete and add icons from rule details view in Rules Engine

  • Tony Bach

    Tony Bach 0ac6815898d4f1910a8b8191b50780f5bbd0ac83 m

    [CDAP-12483] Remove delete and add icons from rule details view in Rules Engine - Shows full width now since there are no more buttons

    • cdap-ui/app/cdap/components/DSVEditor/DSVRow.js (version 0ac6815898d4f1910a8b8191b50780f5bbd0ac83)
    • cdap-ui/app/cdap/components/DSVEditor/index.js (version 0ac6815898d4f1910a8b8191b50780f5bbd0ac83)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesTab/Rule/Rule.scss (version 0ac6815898d4f1910a8b8191b50780f5bbd0ac83)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesTab/Rule/index.js (version 0ac6815898d4f1910a8b8191b50780f5bbd0ac83)
  • Poorna Chandra

    Poorna Chandra e92583ca96aec4f909489b95e914624e318bd446 m

    CDAP-12473 Allow executing all programs in an app

    • cdap-proto/src/main/java/co/cask/cdap/proto/security/Authorizable.java (version e92583ca96aec4f909489b95e914624e318bd446)
    • cdap-proto/src/test/java/co/cask/cdap/proto/security/AuthorizableTest.java (version e92583ca96aec4f909489b95e914624e318bd446)
  • Sreevatsan Raman

    Sreevatsan Raman 7552ea9317f6fd67f4a46fceac67ecff667c1b47 m

    Merge pull request #9497 from caskdata/fix/data-migration-thread-start
    fix to start thread instead of run; fix to get dataset spec with retr…

  • Sreevatsan Raman

    Sreevatsan Raman 82505873119755ef69f84e11a6eb11137b5dc536 m

    Merge pull request #9501 from caskdata/feature/fix-log-flood
    Rate limit logs

  • Sreevatsan Raman <sree@Sreevatsans-MacBook-Pro.local>

    Sreevatsan Raman <sree@Sreevatsans-MacBook-Pro.local> 7b18eb86167a6b15a53f42af5b501cc904987998 m

    Rate limit logs

    • cdap-data-fabric/src/main/java/co/cask/cdap/data/stream/service/DistributedStreamService.java (version 7b18eb86167a6b15a53f42af5b501cc904987998)
  • Tony Bach

    Tony Bach 489c0d472850b38e4ae5439f9bbad5d2469c2469 m

    Merge pull request #9457 from caskdata/feature_release/microservice-updated
    [CDAP-12408] Updates microservice upload wizard

  • Tony Bach

    Tony Bach db2c2610eaff1d8e438df3243b46634657f34e16 m

    [CDAP-12408] Updates microservice upload wizard - Shows no queue at defaul - Changes the core app from microservice-app to microservice-core - Adds type mapr-stream

    • cdap-ui/app/cdap/api/artifact.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/EndpointStep/DSVInboundQueues.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/EndpointStep/DSVOutboundQueues.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/EndpointStep/EndpointStep.scss (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/EndpointStep/index.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/GeneralInfoStep/index.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/InboundQueueStep/index.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/MicroserviceQueue.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/MicroserviceQueue.scss (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/MicroserviceQueueEditor.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/MicroserviceUpload.scss (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/OutboundQueueStep/index.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/PropertiesStep/index.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/CaskWizards/MicroserviceUpload/index.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/components/Wizard/Wizard.scss (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/services/WizardConfigs/MicroserviceUploadWizardConfig.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/services/WizardStores/MicroserviceUpload/ActionCreator.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/services/WizardStores/MicroserviceUpload/MicroserviceQueueActions.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/services/WizardStores/MicroserviceUpload/MicroserviceQueueStore.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/services/WizardStores/MicroserviceUpload/MicroserviceUploadActions.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/services/WizardStores/MicroserviceUpload/MicroserviceUploadStore.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/services/helpers.js (version db2c2610eaff1d8e438df3243b46634657f34e16)
    • cdap-ui/app/cdap/text/text-en.yaml (version db2c2610eaff1d8e438df3243b46634657f34e16)
  • Edwin Elia

    Edwin Elia 11fd45caa8b13de8854232e55472b8d32c5eb3b7 m

    fix importing different pipeline artifact that is not the active pipelineType

    • cdap-ui/app/hydrator/controllers/create/partials/pipelineupgrade-modal-ctrl.js (version 11fd45caa8b13de8854232e55472b8d32c5eb3b7)
    • cdap-ui/app/hydrator/services/create/actions/available-plugins-action-creator.js (version 11fd45caa8b13de8854232e55472b8d32c5eb3b7)
    • cdap-ui/app/hydrator/services/hydrator-upgrade-service.js (version 11fd45caa8b13de8854232e55472b8d32c5eb3b7)
  • Edwin Elia

    Edwin Elia b9f0e636d0ca724b997cf4248b5b8d03b12c8beb m

    Merge pull request #9500 from caskdata/bugfix_release/ui-CDAP-12484-hide-triggers-in-realtime
    [CDAP-12484] hide pipeline triggers on realtime pipeline

  • Ajai Narayan

    Ajai Narayan bda295f95da9c296893049f9521d0468d56f4047 m

    Merge pull request #9467 from caskdata/feature/ui-header-design-change
    [CDAP-12319] Modifies Header component based on new restructuring of Header elements

  • Ajai Narayan

    Ajai Narayan 494f7fbe5bd8cd66e1ed3f66ba5eee1af011cc2a m

    [CDAP-12319] Modifies Header component based on new restructuring of Header elements
     - Modifies Header component based on new restructuring of Header elements
     - Modifies links in header to be consistent
     - Modifies Overview to Control Center + minor styling changes
     - Minor restructure in i18n text for Header component
     - Fixes media query breaking point to be 1040px to show collapsed menu in Header

    • cdap-ui/app/cdap/components/Header/DataPrepDropdown/DataPrepDropdown.scss (version 494f7fbe5bd8cd66e1ed3f66ba5eee1af011cc2a)
    • cdap-ui/app/cdap/components/Header/DataPrepDropdown/index.js (version 494f7fbe5bd8cd66e1ed3f66ba5eee1af011cc2a)
    • cdap-ui/app/cdap/components/Header/Header.scss (version 494f7fbe5bd8cd66e1ed3f66ba5eee1af011cc2a)
    • cdap-ui/app/cdap/components/Header/index.js (version 494f7fbe5bd8cd66e1ed3f66ba5eee1af011cc2a)
    • cdap-ui/app/cdap/text/text-en.yaml (version 494f7fbe5bd8cd66e1ed3f66ba5eee1af011cc2a)
  • Edwin Elia

    Edwin Elia 0d83af435f9ead15449d71652b0fba8db83130a0 m

    Merge pull request #9498 from caskdata/bugfix_release/ui-CDAP-12467-textarea-validate
    [CDAP-12467] add textarea validate widget for conditional node

  • Edwin Elia

    Edwin Elia 56147302fd893301a32fc9edc841f195efae2ffd m

    hide pipeline triggers on realtime pipeline

    • cdap-ui/app/hydrator/controllers/detail-ctrl.js (version 56147302fd893301a32fc9edc841f195efae2ffd)
    • cdap-ui/app/hydrator/routes.js (version 56147302fd893301a32fc9edc841f195efae2ffd)
    • cdap-ui/app/hydrator/templates/detail.html (version 56147302fd893301a32fc9edc841f195efae2ffd)
  • Ajai Narayan

    Ajai Narayan f94c5332df1306888cb2143897bcff63a59eb9b4 m

    Merge pull request #9471 from caskdata/bugfix_release/ui-CDAP-12434
    [CDAP-12434] Removes debounce during sorting rules in rulebook detail view

  • albertshau <albert@cask.co>

    albertshau <albert@cask.co> ff24ccbdbf4be7945b3209498345c14d4c348dc9 m

    Merge pull request #9485 from caskdata/feature_release/CDAP-12472
    CDAP-12472 add a method to get macro evaluated plugin properties

  • Ajai Narayan

    Ajai Narayan 1cbfdf6f8177d91f013ba256a1202bf2b9e32170 m

    [CDAP-12434] Removes debounce during sorting rules in rulebook detail view
     - Removes debounce during sorting rules in rulebook detail view
     - Unsubscribes from RulesnengineStore on component unmount in all cases in rules engine

    • cdap-ui/app/cdap/components/RulesEngineHome/RuleBookDetails/index.js (version 1cbfdf6f8177d91f013ba256a1202bf2b9e32170)
    • cdap-ui/app/cdap/components/RulesEngineHome/RuleBooksTab/index.js (version 1cbfdf6f8177d91f013ba256a1202bf2b9e32170)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesEngineAlert/index.js (version 1cbfdf6f8177d91f013ba256a1202bf2b9e32170)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesEngineWrapper.js (version 1cbfdf6f8177d91f013ba256a1202bf2b9e32170)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesTab/Rule/index.js (version 1cbfdf6f8177d91f013ba256a1202bf2b9e32170)
    • cdap-ui/app/cdap/components/RulesEngineHome/RulesTab/index.js (version 1cbfdf6f8177d91f013ba256a1202bf2b9e32170)
  • Ajai Narayan

    Ajai Narayan dd2e5c0c1980ec159a135dda04de1b8208f2c208 m

    Merge pull request #9477 from caskdata/feature/ui-CDAP-12455
    [CDAP-12455] Fixes the positioning of second and third level popover position

  • Edwin Elia

    Edwin Elia 9a0c07c19dc173025c6b8bc2760ee0ca9698bd80 m

    add textarea validate widget for conditional node Added docs

    • cdap-docs/developer-manual/source/pipelines/developing-plugins/presentation-plugins.rst (version 9a0c07c19dc173025c6b8bc2760ee0ca9698bd80)
    • cdap-ui/app/directives/widget-container/widget-container.js (version 9a0c07c19dc173025c6b8bc2760ee0ca9698bd80)
    • cdap-ui/app/directives/widget-container/widget-factory.js (version 9a0c07c19dc173025c6b8bc2760ee0ca9698bd80)
    • cdap-ui/app/directives/widget-container/widget-textarea-validate/widget-textarea-validate.html (version 9a0c07c19dc173025c6b8bc2760ee0ca9698bd80)
    • cdap-ui/app/directives/widget-container/widget-textarea-validate/widget-textarea-validate.js (version 9a0c07c19dc173025c6b8bc2760ee0ca9698bd80)
    • cdap-ui/app/directives/widget-container/widget-textarea-validate/widget-textarea-validate.less (version 9a0c07c19dc173025c6b8bc2760ee0ca9698bd80)
    • cdap-ui/app/hydrator/templates/partial/node-config-modal/node-config/plugin-edit-properties-template.html (version 9a0c07c19dc173025c6b8bc2760ee0ca9698bd80)
  • Ajai Narayan

    Ajai Narayan b86c1e6bb1923c6c76f28fed20a8899344401120 m

    [CDAP-12455] Fixes the positioning of second and third level popover position
     - Fixes the positioning of second and third level popover position
     - Fixes all directives having second level popover to use setPopoverOffset helper function to position the second level menu correctly

    • cdap-ui/app/cdap/components/DataPrep/Directives/Calculate/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/CopyColumn/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/CustomTransform/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/EncodeDecode/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/Explode/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/ExtractFields/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/FillNullOrEmpty/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/Filter/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/FindAndReplace/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/MarkAsError/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/MaskData/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/Directives/MergeColumns/index.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
    • cdap-ui/app/cdap/components/DataPrep/helper.js (version b86c1e6bb1923c6c76f28fed20a8899344401120)
  • Ajai Narayan

    Ajai Narayan 3048b8630fdb7f94b2fba88d2e159eec66cf727c m

    Merge pull request #9462 from caskdata/bugfix_release/ui-CDAP-12393
    Bug fixes in UI: ruleengine, pipeline summary + UI down modal messaging

  • Ajai Narayan

    Ajai Narayan 29145f685ee3b4567269e3c6f2e04c12f57926d8 m

    Bug fixes in UI: ruleengine, pipeline summary + UI down modal messaging
     - Fixes querying statistics api for realtime pipelines
     - Fixes fetching rules in rules tab when import rulebook + fixes number of rules in rulebook in rulebooks tab
     - Fixes subtitle in the UI down modal based on environment

    • cdap-ui/app/cdap/components/LoadingIndicator/index.js (version 29145f685ee3b4567269e3c6f2e04c12f57926d8)
    • cdap-ui/app/cdap/components/PipelineSummary/index.js (version 29145f685ee3b4567269e3c6f2e04c12f57926d8)
    • cdap-ui/app/cdap/components/RulesEngineHome/ImportRulebookWizard/index.js (version 29145f685ee3b4567269e3c6f2e04c12f57926d8)
    • cdap-ui/app/cdap/components/RulesEngineHome/RuleBookDetails/index.js (version 29145f685ee3b4567269e3c6f2e04c12f57926d8)
    • cdap-ui/app/cdap/services/helpers.js (version 29145f685ee3b4567269e3c6f2e04c12f57926d8)
    • cdap-ui/app/cdap/text/text-en.yaml (version 29145f685ee3b4567269e3c6f2e04c12f57926d8)
    • cdap-ui/app/directives/my-pipeline-summary/my-pipeline-summary-ctrl.js (version 29145f685ee3b4567269e3c6f2e04c12f57926d8)
    • cdap-ui/app/directives/my-pipeline-summary/my-pipeline-summary.html (version 29145f685ee3b4567269e3c6f2e04c12f57926d8)
  • Edwin Elia

    Edwin Elia d388cd762cdf7937c30fbdc7a037aa315754b0d9 m

    Merge pull request #9483 from caskdata/bugfix_release/ui-trigger-update-schedule-filtering-api
    change api usage to filter based on schedule status

  • Edwin Elia

    Edwin Elia 0b4ca5d4f72fa3f503a77d732aae03fd11469788 m

    Merge pull request #9481 from caskdata/bugfix_release/ui-CDAP-12304-pipeline-summary-run-id
    [CDAP-12304] fix run number ordering in table view

  • Tony Bach

    Tony Bach 8c7275595b96176c8d255579466bdca704329306 m

    Merge pull request #9488 from caskdata/bugfix_release/condition-node-connections
    [CDAP-12463] Allows condition node to connect to and be connected from any type of node

  • Tony Bach

    Tony Bach c77fe8c5339a48a226ac4c9ccb808cc45d99b7a9 m

    [CDAP-12463] Allows condition node to connect to or be connected from any node - Removes spark program from list of plugin types to show cdap-data-streams (to not show any conditions and actions)

    • cdap-ui/app/directives/dag-plus/my-dag-ctrl.js (version c77fe8c5339a48a226ac4c9ccb808cc45d99b7a9)
    • cdap-ui/app/hydrator/controllers/create/canvas-ctrl.js (version c77fe8c5339a48a226ac4c9ccb808cc45d99b7a9)
    • cdap-ui/app/hydrator/controllers/create/partials/nodeconfig-ctrl.js (version c77fe8c5339a48a226ac4c9ccb808cc45d99b7a9)
    • cdap-ui/app/hydrator/controllers/detail/canvas-ctrl.js (version c77fe8c5339a48a226ac4c9ccb808cc45d99b7a9)
    • cdap-ui/app/hydrator/services/non-store-pipeline-error-factory.js (version c77fe8c5339a48a226ac4c9ccb808cc45d99b7a9)
    • cdap-ui/app/hydrator/templates/partial/node-config-modal/node-config/plugin-edit-config-form.html (version c77fe8c5339a48a226ac4c9ccb808cc45d99b7a9)
    • cdap-ui/app/services/constants.js (version c77fe8c5339a48a226ac4c9ccb808cc45d99b7a9)
  • Ali Anwar

    Ali Anwar ab3d57a89bcf15ffc46a3ef7cae2da6b6565b474 m

    Merge pull request #9486 from caskdata/bugfix_release/CDAP-12301
    Bring back ScheduleDetail's constructor from 4.2.

  • Shankar Selvam

    Shankar Selvam f6abea9636ab0de452cde86366391789c7e3b8b1 m

    fix to start thread instead of run; fix to get dataset spec with retry during initialization; migration chreate v3 table if not exitsl and minorlog improvements

    • cdap-data-fabric-tests/src/test/java/co/cask/cdap/data2/dataset2/lib/table/hbase/HBaseMetricsTableTest.java (version f6abea9636ab0de452cde86366391789c7e3b8b1)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/DataMigrator.java (version f6abea9636ab0de452cde86366391789c7e3b8b1)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/MessagingMetricsProcessorService.java (version f6abea9636ab0de452cde86366391789c7e3b8b1)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/MetricsTableMigration.java (version f6abea9636ab0de452cde86366391789c7e3b8b1)
  • Ali Anwar

    Ali Anwar 3f5755a41c23dd1091c87ed9f4ce76bd3cee72c5 m

    Merge pull request #9479 from caskdata/update-loglevel
    Change YarnTokenUtils log level to debug.

  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> f8754dd0ace36153896a1fc659984722aa61ffd2 m

    CDAP-12471 Disable collecting stage statistics when no conditions are present in the pipeline.

    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/main/java/co/cask/cdap/datapipeline/SmartWorkflow.java (version f8754dd0ace36153896a1fc659984722aa61ffd2)
    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/test/java/co/cask/cdap/datapipeline/DataPipelineTest.java (version f8754dd0ace36153896a1fc659984722aa61ffd2)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/ETLBatchApplication.java (version f8754dd0ace36153896a1fc659984722aa61ffd2)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/mapreduce/MapReduceTransformExecutorFactory.java (version f8754dd0ace36153896a1fc659984722aa61ffd2)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/mapreduce/TransformRunner.java (version f8754dd0ace36153896a1fc659984722aa61ffd2)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/test/java/co/cask/cdap/etl/batch/BatchPhaseSpecTest.java (version f8754dd0ace36153896a1fc659984722aa61ffd2)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/batch/BatchPhaseSpec.java (version f8754dd0ace36153896a1fc659984722aa61ffd2)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/batch/BatchSparkPipelineDriver.java (version f8754dd0ace36153896a1fc659984722aa61ffd2)
  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> 113b35454e5b9a2da09ee67dd411047e42519cec m

    Merge pull request #9478 from caskdata/fix/disable-stats-collection-when-no-condition
    Disable collecting stage statistics when no conditions are present in the pipeline.

  • anew <andreas@cask.co>

    anew <andreas@cask.co> e49be45faae610b3a49c7d549b6fab688812ca6b m

    Merge branch 'bugfix_releasecdap-12351-fix-fileset-truncate' into release/4.3

  • Derek Wood

    Derek Wood f621eb5b620933ad7ac6b79b667d88d82efe83a1 m

    Merge pull request #9487 from caskdata/feature/shrink-vm
    Feature/shrink vm

  • Chengfeng Mao <mao@cask.co>

    Chengfeng Mao <mao@cask.co> 1bef71d194cde28db4849889f44beeb7a987aa60 m

    Merge pull request #9476 from caskdata/feature_release/schedule-info-passing
    [CDAP-12382] Schedule info passing between triggering and triggered program

  • Chengfeng <mao@cask.co>

    Chengfeng <mao@cask.co> ca51af8d00933f4b615584b348a7604d5d4f2725 m

    [CDAP-12382] Schedule info passing between triggering and triggered program

    • cdap-api-spark-base/src/main/java/co/cask/cdap/api/spark/JavaSparkExecutionContextBase.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api-spark-base/src/main/scala/co/cask/cdap/api/spark/SparkExecutionContextBase.scala (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/SchedulableProgramContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/customaction/CustomActionContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/mapreduce/MapReduceContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/mapreduce/MapReduceTaskContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/schedule/PartitionTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/schedule/ProgramStatusTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/schedule/StreamSizeTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/schedule/TimeTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/schedule/Trigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/schedule/TriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/schedule/TriggeringScheduleInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/spark/SparkClientContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/api/workflow/WorkflowContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-api/src/main/java/co/cask/cdap/internal/app/runtime/schedule/DefaultTriggeringScheduleInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/AbstractContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/ProgramOptionConstants.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/MapReduceLifecycleContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/ScheduleTaskPublisher.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/ScheduleTaskRunner.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/TriggeringScheduleInfoAdapter.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/queue/JobQueueDataset.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/AbstractCompositeTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/AbstractCompositeTriggerBuilder.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/AbstractTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/AndTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/AndTriggerBuilder.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/DefaultPartitionTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/DefaultProgramStatusTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/DefaultStreamSizeTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/DefaultTimeTriggerInfo.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/OrTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/OrTriggerBuilder.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/PartitionTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/ProgramStatusTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/ProgramStatusTriggerBuilder.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/SatisfiableTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/StreamSizeTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/TimeTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/TriggerCodec.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/TriggerInfoCodec.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/TriggerInfoContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/store/AppMetadataStore.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/ConstraintCheckerService.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/test/java/co/cask/cdap/AppWithMultipleSchedules.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/AppFabricClient.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/schedule/TriggeringScheduleInfoAdapterTest.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/service/http/HttpHandlerGeneratorTest.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/store/AppMetadataStoreTest.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-app-fabric/src/test/java/co/cask/cdap/scheduler/CoreSchedulerServiceTest.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-client/src/main/java/co/cask/cdap/client/ApplicationClient.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-common/src/main/java/co/cask/cdap/common/app/RunIds.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-integration-test/src/main/java/co/cask/cdap/test/remote/RemoteApplicationManager.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-proto/src/main/java/co/cask/cdap/proto/ProtoTrigger.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-proto/src/main/java/co/cask/cdap/proto/ScheduleType.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-spark-core-base/src/main/java/co/cask/cdap/app/runtime/spark/BasicSparkClientContext.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-spark-core-base/src/main/scala/co/cask/cdap/app/runtime/spark/AbstractSparkExecutionContext.scala (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-spark-core-base/src/main/scala/co/cask/cdap/app/runtime/spark/DefaultJavaSparkExecutionContext.scala (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-spark-core-base/src/main/scala/co/cask/cdap/app/runtime/spark/SerializableSparkExecutionContext.scala (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-test/src/main/java/co/cask/cdap/test/ApplicationManager.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-unit-test/src/main/java/co/cask/cdap/test/internal/DefaultApplicationManager.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-unit-test/src/test/java/co/cask/cdap/spark/SparkTestRun.java (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-unit-test/src/test/scala/co/cask/cdap/spark/app/TestSparkApp.scala (version ca51af8d00933f4b615584b348a7604d5d4f2725)
    • cdap-unit-test/src/test/scala/co/cask/cdap/spark/app/TriggeredSpark.scala (version ca51af8d00933f4b615584b348a7604d5d4f2725)
  • Terence Yim

    Terence Yim 4285dddda14c84abf82eb33ec1745135d281c739 m

    Merge pull request #9475 from caskdata/feature_release/CDAP-12466-simple-fencing
    (CDAP-12466) Added a simple fencing mechanism to TMS

  • Poorna Chandra

    Poorna Chandra a24c9ecb5f2eebd74b71cdbfa96b1994e6c6c49d m

    CDAP-12473 Fix parsing of dataset names in authorizable

    • cdap-proto/src/main/java/co/cask/cdap/proto/security/Authorizable.java (version a24c9ecb5f2eebd74b71cdbfa96b1994e6c6c49d)
    • cdap-proto/src/test/java/co/cask/cdap/proto/security/AuthorizableTest.java (version a24c9ecb5f2eebd74b71cdbfa96b1994e6c6c49d)
  • Ali Anwar

    Ali Anwar 468269f8407e661f33873852b6c8d5cfa4002fd1 m

    Bring back ScheduleDetail's constructor from 4.2.

    • cdap-proto/src/main/java/co/cask/cdap/proto/ScheduleDetail.java (version 468269f8407e661f33873852b6c8d5cfa4002fd1)
  • Albert Shau <albert@cask.co>

    Albert Shau <albert@cask.co> 54f64bd7221cabbfb35844d0b354cb263165611c m

    CDAP-12472 add a method to get macro evaluated plugin properties
    Adding a method to PluginContext to get macro evaluated plugin
    properties.

    • cdap-api/src/main/java/co/cask/cdap/api/plugin/PluginContext.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/AbstractContext.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/DefaultPluginContext.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/MapReduceLifecycleContext.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/plugin/PluginInstantiator.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/artifact/ArtifactRepositoryTest.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/service/http/HttpHandlerGeneratorTest.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/batch/PipelinePluginInstantiator.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/plugin/PipelinePluginContext.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-spark-core-base/src/main/java/co/cask/cdap/app/runtime/spark/BasicSparkClientContext.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
    • cdap-spark-core-base/src/main/java/co/cask/cdap/app/runtime/spark/SparkPluginContext.java (version 54f64bd7221cabbfb35844d0b354cb263165611c)
  • albertshau <albert@cask.co>

    albertshau <albert@cask.co> 7208676ee77378130033057c16790b72573fe257 m

    Merge pull request #9474 from caskdata/bugfix_release/CDAP-12465-remove-second-init
    CDAP-12465 dont initialize and destroy if there are no alerts

  • Shankar <gowrishankar1988@gmail.com>

    Shankar <gowrishankar1988@gmail.com> e57646224ffebe718adc08958becc55b5d313835 m

    Merge pull request #9369 from caskdata/feature/CDAP-12068-metrics-processor-status
    adding metrics processor delay metric at topic level and surfacing th…

  • Edwin Elia

    Edwin Elia 07619c3bc693e7e8e860e22d99cd77e7181c4b49 m

    change api usage to filter based on schedule status

    • cdap-ui/app/cdap/api/schedule.js (version 07619c3bc693e7e8e860e22d99cd77e7181c4b49)
    • cdap-ui/app/cdap/components/PipelineTriggers/PipelineListTab/index.js (version 07619c3bc693e7e8e860e22d99cd77e7181c4b49)
    • cdap-ui/app/cdap/components/PipelineTriggers/store/PipelineTriggersActionCreator.js (version 07619c3bc693e7e8e860e22d99cd77e7181c4b49)
    • cdap-ui/app/cdap/components/TriggeredPipelines/TriggeredPipelineRow.js (version 07619c3bc693e7e8e860e22d99cd77e7181c4b49)
    • cdap-ui/app/cdap/components/TriggeredPipelines/index.js (version 07619c3bc693e7e8e860e22d99cd77e7181c4b49)
  • Edwin Elia

    Edwin Elia b8c940aa1cb0b88520953feb14a28312da85e167 m

    [CDAP-12304] fix run number ordering in table view

    • cdap-ui/app/cdap/components/PipelineSummary/LogsMetricsGraph/index.js (version b8c940aa1cb0b88520953feb14a28312da85e167)
    • cdap-ui/app/cdap/components/PipelineSummary/NodesMetricsGraph/index.js (version b8c940aa1cb0b88520953feb14a28312da85e167)
    • cdap-ui/app/cdap/components/PipelineSummary/RunsHistoryGraph/index.js (version b8c940aa1cb0b88520953feb14a28312da85e167)
  • anew <andreas@cask.co>

    anew <andreas@cask.co> 99e02a9ff717b617edd3a3b18caf2ea2cc92574b m

    [CDAP-12351] Fix FileSet.truncate() to preserve the base path

    • cdap-data-fabric/src/main/java/co/cask/cdap/data2/dataset2/lib/file/FileSetAdmin.java (version 99e02a9ff717b617edd3a3b18caf2ea2cc92574b)
    • cdap-data-fabric/src/test/java/co/cask/cdap/data2/dataset2/lib/FileSetTest.java (version 99e02a9ff717b617edd3a3b18caf2ea2cc92574b)
  • Derek Wood

    Derek Wood abf71653d4448d9fab1112ce746cd5e4abe03c82 m

    use clean over autoclean to reduce disk usage

    • cdap-distributions/src/packer/scripts/apt-cleanup.sh (version abf71653d4448d9fab1112ce746cd5e4abe03c82)
  • Derek Wood

    Derek Wood f78c56c45b957d67498eec22da16f429643b89b3 m

    remove flume_agent, not relevant anymore

    • cdap-distributions/src/packer/cdap-sdk-ubuntu16-with-uri.json (version f78c56c45b957d67498eec22da16f429643b89b3)
  • Derek Wood

    Derek Wood 94d1fb3bb784de677619cbe6dcdc6c0f5a9a4beb m

    Merge pull request #9445 from caskdata/feature/11448-hdinsight36
    enable for hdinsight3.6

  • Terence Yim

    Terence Yim 8abbb1d0a1b4e0a0e18ad7c458ee65177a7c67b5 m

    (CDAP-12466) Added a simple fencing mechanism to TMS
    - Just delaying making the service becomes available

    • cdap-common/src/main/java/co/cask/cdap/common/conf/Constants.java (version 8abbb1d0a1b4e0a0e18ad7c458ee65177a7c67b5)
    • cdap-common/src/main/resources/cdap-default.xml (version 8abbb1d0a1b4e0a0e18ad7c458ee65177a7c67b5)
    • cdap-docs/admin-manual/build.sh (version 8abbb1d0a1b4e0a0e18ad7c458ee65177a7c67b5)
    • cdap-tms/src/main/java/co/cask/cdap/messaging/distributed/LeaderElectionMessagingService.java (version 8abbb1d0a1b4e0a0e18ad7c458ee65177a7c67b5)
    • cdap-tms/src/test/java/co/cask/cdap/messaging/distributed/LeaderElectionMessagingServiceTest.java (version 8abbb1d0a1b4e0a0e18ad7c458ee65177a7c67b5)
  • Ali Anwar

    Ali Anwar 8fb467c1d9a80d910c46f945efb47af3cfb7b0d1 m

    Merge pull request #9442 from caskdata/bugfix_release/CDAP-1952-refactor-mr
    CDAP-1952 Refactor MapReduce to make DatasetOutputCommitter execute in the MapReduce job

  • Albert Shau <albert@cask.co>

    Albert Shau <albert@cask.co> c48a18d0e2be0949e9062682d25ecef038befa42 m

    CDAP-12465 dont initialize and destroy if there are no alerts
    Fixing a bug where alert publishers would get initialized and
    destroyed even when there are no alerts to publish, which would
    cause a possible second initialization in spark pipelines.

    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/main/java/co/cask/cdap/datapipeline/SmartWorkflow.java (version c48a18d0e2be0949e9062682d25ecef038befa42)
  • Tony Bach

    Tony Bach 124c57252e6f5c00982c58d59c4d9e01455c5455 m

    Merge pull request #9463 from caskdata/bugfix_release/ui-bugfixes
    UI Bugfixes in Studio

  • Tony Bach

    Tony Bach b7984cc2dcaf6994db9d56430f8cd57c959f6f9d m

    UI Bugfixes in Studio - Fixes stage/arrow position not updated when opening a draft pipeline with only one node - Changes tooltip message of the yellow warning blob on pipeline stages - Waits for backendproperties to be fetched before fetching macros when opening a draft - Fixes problem when macros are not shown when creating a new pipeline

    • cdap-ui/app/directives/dag-plus/my-dag-ctrl.js (version b7984cc2dcaf6994db9d56430f8cd57c959f6f9d)
    • cdap-ui/app/directives/dag-plus/my-dag.html (version b7984cc2dcaf6994db9d56430f8cd57c959f6f9d)
    • cdap-ui/app/hydrator/controllers/create/toppanel-ctrl.js (version b7984cc2dcaf6994db9d56430f8cd57c959f6f9d)
  • Edwin Elia

    Edwin Elia cd92be6854f628bf949a694252fa262abbb27bef m

    Merge pull request #9469 from caskdata/bugfix_releae/ui-router-check-logging
    [CDAP-12312] add debug statements for router ping

  • Ajai Narayan

    Ajai Narayan 524d108670f1c5d2bc08afd11a02520003d67970 m

    Merge pull request #9454 from caskdata/feature/ui-rulesengine-context-jump
    Adds rulebookid as hidden property while navigating between rulesengine and pipeline

  • Ajai Narayan

    Ajai Narayan 10094b89af01f98447b862ed19ac652dd4f34386 m

    Adds rulebookid as hidden property while navigating between rulesengine and pipeline
     - Adds the context of rulebookid to be passed from pipeline to RulesEngineHome
     - Updates RulesEngineHome to accept rulebookid. This is used when navigating from pipeline to rulesengine and viceversa

    • cdap-ui/app/cdap/components/RulesEngineHome/RuleBookDetails/RulebookMenu/AddRulesEngineToPipelineModal.js (version 10094b89af01f98447b862ed19ac652dd4f34386)
    • cdap-ui/app/cdap/components/RulesEngineHome/RuleBookDetails/index.js (version 10094b89af01f98447b862ed19ac652dd4f34386)
    • cdap-ui/app/cdap/components/RulesEngineHome/index.js (version 10094b89af01f98447b862ed19ac652dd4f34386)
    • cdap-ui/app/directives/widget-container/widget-rulesengine-editor/rules-engine-modal-ctrl.js (version 10094b89af01f98447b862ed19ac652dd4f34386)
    • cdap-ui/app/directives/widget-container/widget-rulesengine-editor/rules-engine-modal.html (version 10094b89af01f98447b862ed19ac652dd4f34386)
  • Chengfeng Mao <mao@cask.co>

    Chengfeng Mao <mao@cask.co> 5d92c8173dc8ab2809bf7abae52c17b6a59a6dff m

    Merge pull request #9404 from caskdata/feature_release/schedule-detail
    [CDAP-12293][CDAP-12301] Add app info and schedule status in ScheduleDetail

  • Chengfeng <mao@cask.co>

    Chengfeng <mao@cask.co> 4902b4b76116df6acfd82de4baf802b18149f522 m

    [CDAP-12293][CDAP-12301] Add app info and schedule status in ScheduleDetail; add REST API to filter schedules by status

    • cdap-app-fabric-tests/src/test/java/co/cask/cdap/internal/app/services/http/handlers/WorkflowHttpHandlerTest.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/gateway/handlers/ProgramLifecycleHttpHandler.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/gateway/handlers/WorkflowHttpHandler.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/ProgramSchedule.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/ProgramScheduleMeta.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/ProgramScheduleRecord.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/store/ProgramScheduleStoreDataset.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/store/Schedulers.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/trigger/ProgramStatusTrigger.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/CoreSchedulerService.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/NoOpScheduler.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/Scheduler.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/AppFabricClient.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/http/AppFabricTestBase.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/http/handlers/ProgramLifecycleHttpHandlerTest.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-proto/src/main/java/co/cask/cdap/proto/ScheduleDetail.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
    • cdap-proto/src/test/java/co/cask/cdap/proto/ProtoTriggerCodecTest.java (version 4902b4b76116df6acfd82de4baf802b18149f522)
  • Sreevatsan Raman

    Sreevatsan Raman 27c104d6174db2ecca7b6653e3a9750e8bf696f4 m

    Merge pull request #9473 from caskdata/feature_release/CDAP-12460-fix-remote-authorization-enforcer
    CDAP-12460 fix remote authorization enforcer due to the UnAuthorizedE…

  • Sreevatsan Raman

    Sreevatsan Raman d1d9e95266ce15c6c5a3645a6c3c8ff39e389efd m

    Merge pull request #9461 from caskdata/feature_release/CDAP-12423-fix-program-state
    (CDAP-12423) Fix program state and scheduler

  • Yaojie Feng

    Yaojie Feng 84d2c37f1f1e85bc886a7b721bbf46341a8ad6d0 m

    CDAP-12460 fix remote authorization enforcer due to the UnAuthorizedException change

    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/store/remote/RemotePrivilegesTestBase.java (version 84d2c37f1f1e85bc886a7b721bbf46341a8ad6d0)
    • cdap-security/src/main/java/co/cask/cdap/security/authorization/RemoteAuthorizationEnforcer.java (version 84d2c37f1f1e85bc886a7b721bbf46341a8ad6d0)
  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> 94ad7459b3ab34d8a41358d1b00cf44320236c48 m

    CDAP-12109 Supporting actions with conditions plugins in the pipeline.

    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/main/java/co/cask/cdap/datapipeline/SmartWorkflow.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/test/java/co/cask/cdap/datapipeline/DataPipelineTest.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/planner/Dag.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/planner/DisjointConnectionsException.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/planner/PipelinePlanner.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/spec/PipelineSpecGenerator.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/test/java/co/cask/cdap/etl/planner/ConnectorDagTest.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/test/java/co/cask/cdap/etl/planner/DagTest.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/cdap-etl-proto/src/main/java/co/cask/cdap/etl/proto/Connection.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
    • cdap-app-templates/cdap-etl/hydrator-test/src/main/java/co/cask/cdap/etl/mock/action/MockAction.java (version 94ad7459b3ab34d8a41358d1b00cf44320236c48)
  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> 15ec8f542dfff04338ab2c6bbae3cd61f87786d9 m

    Merge pull request #9437 from caskdata/fix/condition-action-expr
    Ability to allow conditions and actions together in the pipeline.

  • Ali Anwar

    Ali Anwar e00ac6f5d75872fd21b66bffb162f07bad93a7cc m

    CDAP-1952 Update MapReduceRuntimeService to always use MultipleOutputsMainOutputWrapper/MainOutputCommitter.
    Simply introduce a MainOutputCommitter.

    Move committing of the data event topic (TMS) and committing of the long tx into MainOutputCommitter.java.
    This required delaying the instantiation of the OutputCommitters in MultipleOutputsCommitter until after MainOutputCommitter#setupJob starts the transacion and sets it into the job confs. We need to set the tx into both JobContext and TaskAttemptContext (at least for LocalJobRunner).

    wip - rename. MapReduceWithMultipleOutputs#testMultipleOutputs works with a hack.

    Start the tx in the MRRS.

    Better error message.

    Revert "Start the tx in the MRRS."
    We're going to simple persist the tx somewhere on hdfs and tasks can read it from there.

    This reverts commit 1e8c998cb0c47cc55bb776fa429d0b666eaaf8b5.

    wip - move setting conf from outputs to MRRS.

    Use /tmp/_job_id/ to persist tx, instead of hconf.

    Leverage MapReduce staging directory for tx file.

    cleanup

    Fix a bug with DatasetCache.

    Cleanup logic in MainOutputCommiter, to better handle failures.

    Simplify calling of DatasetOutputCommitter's onSuccess/onFailure methods.

    Fix the case, where user doesn't call addOutput APIs to configure MR output. Also fix MapReduceTaskContextProvider for cases where TaskAttemptID is null, such as for Partitioner or Comparator classes.

    Fix a bug where OutputCommiter methods were being called multiple times.

    cleanup

    Simplify serialization/deserialization of Outputs/DatasetOutputs

    Handle multiple calls to OutputCommitter#abortJob

    Fix issue where DatasetOutputCommitter's dataset operations were not being flushed.

    Fix a bug where a DatasetOutputCommiter's methods are not called if it isn't added via Output.ofDataset API.

    Address comments

    Call postTxCommit for the txAwares after committing the transaction.

    Make postTxCommit not throw exception.

    Move DatasetOutputCommitter method execution out of short transaction.

    Avoid calling MapReduceTaskContext.flushOperations from OutputCommitter, since it is called on the taskContext in MainOutputCommittter.

    Perform operation rollback in PartitionedFileSet#onFailure.

    • cdap-api/src/main/java/co/cask/cdap/api/data/batch/Output.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/BasicMapReduceContext.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/BasicMapReduceTaskContext.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/BasicOutputFormatProvider.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/MainOutputCommitter.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/MapReduceContextConfig.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/MapReduceProgramRunner.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/MapReduceRuntimeService.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/MapReduceTaskContextProvider.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/dataset/DatasetOutputFormatProvider.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/dataset/UnsupportedOutputFormat.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/dataset/output/MultipleOutputsCommitter.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/dataset/output/MultipleOutputsMainOutputWrapper.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/dataset/output/Outputs.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/dataset/output/ProvidedOutput.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/dataset/partitioned/DynamicPartitioningOutputCommitter.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/batch/MapReduceProgramRunnerTest.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/batch/MapReduceRunnerTestBase.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-app-templates/cdap-etl/hydrator-test/src/main/java/co/cask/cdap/etl/mock/batch/MockExternalSink.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-data-fabric/src/main/java/co/cask/cdap/data2/dataset2/SingleThreadDatasetCache.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-data-fabric/src/main/java/co/cask/cdap/data2/dataset2/lib/partitioned/PartitionedFileSetDataset.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-data-fabric/src/main/java/co/cask/cdap/data2/dataset2/lib/partitioned/PartitionedFileSetDefinition.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
    • cdap-unit-test/src/test/java/co/cask/cdap/partitioned/AppWithPartitionConsumers.java (version e00ac6f5d75872fd21b66bffb162f07bad93a7cc)
  • Terence Yim

    Terence Yim 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35 m

    (CDAP-12423) Fix program status publish and consumption.
    - Class refactoring
      - Allow batch processing of notifications
      - Allow partial processing of a batch
      - Added metrics for progress tracking
      - Added trace log
      - Use transaction to fetch data partition events

    - Correct program state publishing
      - Avoid publishing duplicate completion states from the event handler.
      - Implement StateChangeListener.init to publish states in correct order.

    - Fix flaky tests

    • cdap-app-fabric-tests/src/test/java/co/cask/cdap/internal/app/services/http/handlers/WorkflowHttpHandlerTest.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/main/java/co/cask/cdap/common/twill/TwillAppLifecycleEventHandler.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/program/MessagingProgramStateWriter.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/program/StateChangeListener.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/AbstractNotificationSubscriberService.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/ProgramLifecycleService.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/ProgramNotificationSubscriberService.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/ScheduleNotificationSubscriberService.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/test/java/co/cask/cdap/SleepingWorkflowApp.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/http/handlers/ProgramLifecycleHttpHandlerTest.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-app-fabric/src/test/java/co/cask/cdap/scheduler/CoreSchedulerServiceTest.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-common/src/main/java/co/cask/cdap/common/conf/Constants.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-common/src/main/resources/cdap-default.xml (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-docs/admin-manual/build.sh (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
    • cdap-proto/src/main/java/co/cask/cdap/proto/Notification.java (version 7bf4ab6c25f9b4690e2cd10b37c751da1d756d35)
  • Terence Yim

    Terence Yim a84d2e9e4215c625dd0950bd8748603d97798981 m

    Merge pull request #9464 from caskdata/feature_release/CDAP-12307-tms-ha
    (CDAP-12307) Supports HA for TMS service

  • Shankar Selvam

    Shankar Selvam 4078df87628b282c9e11dff28645b01d01a04bc3 m

    addressing comments

    • cdap-watchdog-api/src/main/java/co/cask/cdap/api/metrics/MetricStore.java (version 4078df87628b282c9e11dff28645b01d01a04bc3)
    • cdap-watchdog-api/src/main/java/co/cask/cdap/api/metrics/MetricsMessageId.java (version 4078df87628b282c9e11dff28645b01d01a04bc3)
    • cdap-watchdog-api/src/main/java/co/cask/cdap/api/metrics/MetricsProcessorStatus.java (version 4078df87628b282c9e11dff28645b01d01a04bc3)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/MessagingMetricsProcessorService.java (version 4078df87628b282c9e11dff28645b01d01a04bc3)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/MetricsConsumerMetaTable.java (version 4078df87628b282c9e11dff28645b01d01a04bc3)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/TopicProcessMeta.java (version 4078df87628b282c9e11dff28645b01d01a04bc3)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/store/DefaultMetricStore.java (version 4078df87628b282c9e11dff28645b01d01a04bc3)
    • cdap-watchdog/src/test/java/co/cask/cdap/metrics/process/MessagingMetricsProcessorServiceTest.java (version 4078df87628b282c9e11dff28645b01d01a04bc3)
  • Ali Anwar

    Ali Anwar 02e02579cd95ef5139dbce97e508e59e60f66361 m

    Change log level to debug.

    • cdap-common/src/main/java/co/cask/cdap/common/security/YarnTokenUtils.java (version 02e02579cd95ef5139dbce97e508e59e60f66361)
  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> 9c00387bc0f1ca48982d57211d4fe52f6c8596c2 m

    Merge pull request #9472 from caskdata/fix/make-serializable
    Make NoopStageStatisicsCollector serializable since its used in Streaming pipelines where no statistics are emitted

  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> 22b88abe2fc5a4e425bf37c1ebf87aa04f0a3d24 m

    Make NoopStageStatisicsCollector serializable.

    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/NoopStageStatisticsCollector.java (version 22b88abe2fc5a4e425bf37c1ebf87aa04f0a3d24)
  • Terence Yim

    Terence Yim 452c063d6647933195fc21ad468d666ad8268089 m

    (CDAP-12307) Supports HA for TMS service

    • cdap-common/src/main/resources/cdap-default.xml (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-docs/admin-manual/build.sh (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-master/src/main/java/co/cask/cdap/data/runtime/main/MessagingServiceTwillRunnable.java (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-tms/src/main/java/co/cask/cdap/messaging/distributed/LeaderElectionMessagingService.java (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-tms/src/main/java/co/cask/cdap/messaging/guice/MessagingServerRuntimeModule.java (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-tms/src/main/java/co/cask/cdap/messaging/store/cache/DefaultMessageTableCacheProvider.java (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-tms/src/main/java/co/cask/cdap/messaging/store/cache/MessageTableCacheProvider.java (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-tms/src/main/java/co/cask/cdap/messaging/store/leveldb/LevelDBTableFactory.java (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-tms/src/test/java/co/cask/cdap/messaging/distributed/LeaderElectionMessagingServiceTest.java (version 452c063d6647933195fc21ad468d666ad8268089)
    • cdap-tms/src/test/java/co/cask/cdap/messaging/store/cache/CachingMessageTableTest.java (version 452c063d6647933195fc21ad468d666ad8268089)
  • Sreevatsan Raman

    Sreevatsan Raman e229e023f928f225c446c04400681e68675ffa33 m

    Merge pull request #9466 from caskdata/bugfix_release/CDAP-12437-destroy-alert-publishers
    CDAP-12437 call destroy on alert publishers

  • Shankar Selvam

    Shankar Selvam 487eb8656bd6127da34b14c618bcacaacb742971 m

    restructuring changes to use a single class to store all the meta and stat information and one method to write those information

    • cdap-watchdog-api/src/main/java/co/cask/cdap/api/metrics/MetricStore.java (version 487eb8656bd6127da34b14c618bcacaacb742971)
    • cdap-watchdog-api/src/main/java/co/cask/cdap/api/metrics/MetricsProcessorStatus.java (version 487eb8656bd6127da34b14c618bcacaacb742971)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/MessagingMetricsProcessorService.java (version 487eb8656bd6127da34b14c618bcacaacb742971)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/MetricsConsumerMetaTable.java (version 487eb8656bd6127da34b14c618bcacaacb742971)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/MetricsProcessorStats.java (version 487eb8656bd6127da34b14c618bcacaacb742971)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/process/TopicProcessMeta.java (version 487eb8656bd6127da34b14c618bcacaacb742971)
    • cdap-watchdog/src/main/java/co/cask/cdap/metrics/store/DefaultMetricStore.java (version 487eb8656bd6127da34b14c618bcacaacb742971)
    • cdap-watchdog/src/test/java/co/cask/cdap/metrics/process/MessagingMetricsProcessorServiceTest.java (version 487eb8656bd6127da34b14c618bcacaacb742971)
  • Rohit Sinha

    Rohit Sinha 43b4cba2ccb1def6b44b38f5944ba0db7c5631f6 m

    Merge pull request #9433 from caskdata/feature/CDAP-12135-wildcard-entity
    CDAP-12135 Support Wildcard grant/revoke

  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> bae3fd854f6726c4c8a936631184986287fb7b9d m

    Merge pull request #9425 from caskdata/fix/data-statistics-collector-impl
    Make stage statistics available in the Workflow token through Spark accumulators and MapReduce counters.

  • Rohit Sinha

    Rohit Sinha 74c852bdf1723166f499316beba3b0847a8005f1 m

    CDAP-12135 Support Wildcard grant/revoke

    • cdap-app-fabric/src/main/java/co/cask/cdap/gateway/handlers/AuthorizationHandler.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-app-fabric/src/test/java/co/cask/cdap/gateway/handlers/AuthorizationHandlerTest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/DefaultSecureStoreServiceTest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-cli/src/main/java/co/cask/cdap/cli/command/security/GrantActionCommand.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-cli/src/main/java/co/cask/cdap/cli/command/security/ListPrivilegesCommand.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-cli/src/main/java/co/cask/cdap/cli/command/security/RevokeActionCommand.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-client/src/main/java/co/cask/cdap/client/AuthorizationClient.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/main/java/co/cask/cdap/proto/id/EntityId.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/main/java/co/cask/cdap/proto/security/Authorizable.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/main/java/co/cask/cdap/proto/security/AuthorizationRequest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/main/java/co/cask/cdap/proto/security/GrantRequest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/main/java/co/cask/cdap/proto/security/Privilege.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/main/java/co/cask/cdap/proto/security/RevokeRequest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/test/java/co/cask/cdap/proto/security/AuthorizableTest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/test/java/co/cask/cdap/proto/security/GrantRequestTest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-proto/src/test/java/co/cask/cdap/proto/security/RevokeRequestTest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-security-spi/src/main/java/co/cask/cdap/security/spi/authorization/AbstractAuthorizer.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-security-spi/src/main/java/co/cask/cdap/security/spi/authorization/NoOpAuthorizer.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-security-spi/src/main/java/co/cask/cdap/security/spi/authorization/PrivilegesManager.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-security/src/main/java/co/cask/cdap/proto/security/AuthorizationPrivilege.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-security/src/main/java/co/cask/cdap/security/authorization/DelegatingPrivilegeManager.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-security/src/main/java/co/cask/cdap/security/authorization/RemotePrivilegesManager.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-security/src/test/java/co/cask/cdap/security/authorization/DefaultAuthorizationEnforcerTest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-security/src/test/java/co/cask/cdap/security/authorization/InMemoryAuthorizer.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
    • cdap-unit-test/src/test/java/co/cask/cdap/security/AuthorizationTest.java (version 74c852bdf1723166f499316beba3b0847a8005f1)
  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> de409ea23489d067c20dabc2252a3a2b7f761994 m

    CDAP-12456 Make stage statistics available in the Workflow token through Spark accumulators and MapReduce counters.

    • cdap-app-templates/cdap-etl/cdap-data-pipeline/src/test/java/co/cask/cdap/datapipeline/DataPipelineTest.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-data-streams/src/main/java/co/cask/cdap/datastreams/SparkStreamingPipelineDriver.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-data-streams/src/main/java/co/cask/cdap/datastreams/SparkStreamingPipelineRunner.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/condition/BasicConditionContext.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/condition/BasicStageStatistics.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/etl/batch/mapreduce/MapReduceTransformExecutorFactory.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/batch/mapreduce/MapReduceStageStatisticsCollector.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/Constants.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/NoopStageStatisticsCollector.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/StageStatisticsCollector.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/TrackedEmitter.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/TrackedMultiOutputEmitter.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/TrackedMultiOutputTransform.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/common/TrackedTransform.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/SparkCollection.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/SparkPipelineRunner.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/SparkStageStatisticsCollector.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/batch/BatchSparkPipelineDriver.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/batch/RDDCollection.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/AggregatorAggregateFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/AggregatorGroupByFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/BatchSinkFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/BatchSourceFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/ErrorTransformFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/JoinMergeFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/JoinOnFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/PluginFunctionContext.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/function/TransformFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/streaming/DStreamCollection.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/streaming/DynamicDriverContext.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-spark-core-base/src/main/java/co/cask/cdap/etl/spark/streaming/function/StreamingBatchSinkFunction.java (version de409ea23489d067c20dabc2252a3a2b7f761994)
    • cdap-app-templates/cdap-etl/hydrator-test/src/main/java/co/cask/cdap/etl/mock/condition/MockCondition.java (version de409ea23489d067c20dabc2252a3a2b7f761994)