Build #198

Build: #198 was successful Child of CDAP-DRC-3488

Code commits

CDAP

  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> 47c16f88dbad90f2ee6f70ebd23727ad8f879791

    Merge pull request #9338 from caskdata/fix/phase-changes
    CDAP-12109 Create phases and phase connections for the conditions in the pipeline.

  • Sameet Sapra <sameetandpotatoes@gmail.com>

    Sameet Sapra <sameetandpotatoes@gmail.com> 436300281533c1168dcc2612d1907e2c5b1af7dd

    Merge pull request #9297 from caskdata/feature/use-tms-for-program-states
    [CDAP-11914] Send Program Status Notifications with TMS

  • Sameet Sapra <sameetandpotatoes@gmail.com>

    Sameet Sapra <sameetandpotatoes@gmail.com> c536a92d2cc0b4d1f1e59a6433f26db968d444eb

    [CDAP-11914] Use TMS to publish program status notifications

    • cdap-app-fabric-tests/src/test/java/co/cask/cdap/internal/app/services/http/handlers/WorkflowHttpHandlerTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/guice/AppFabricServiceRuntimeModule.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/guice/DistributedProgramRunnableModule.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/guice/DistributedProgramRunnerModule.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/guice/InMemoryProgramRunnerModule.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/preview/PreviewRunnerModule.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/runtime/ProgramController.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/store/RuntimeStore.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/app/store/Store.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/gateway/handlers/meta/RemoteRuntimeStoreHandler.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/program/MessagingProgramStateWriter.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/ProgramOptionConstants.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/messaging/TopicMessageIdStore.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/queue/JobQueue.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/schedule/queue/JobQueueDataset.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/AbstractNotificationSubscriberService.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/ProgramLifecycleService.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/services/ProgramNotificationSubscriberService.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/store/AppMetadataStore.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/store/DirectStoreProgramStateWriter.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/store/remote/RemoteRuntimeStore.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/CoreSchedulerService.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/NotificationSubscriberService.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/main/java/co/cask/cdap/scheduler/ScheduleNotificationSubscriberService.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/test/java/co/cask/cdap/app/runtime/AbstractProgramRuntimeServiceTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/AppFabricClient.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/runtime/schedule/SchedulerTestBase.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/ApplicationLifecycleServiceTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/RunRecordCorrectorServiceTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/http/AppFabricTestBase.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/services/http/handlers/ProgramLifecycleHttpHandlerTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-app-fabric/src/test/java/co/cask/cdap/internal/app/store/remote/RemoteRuntimeStoreTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/AbstractClientTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/LineageTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/MetricsClientTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/PreferencesClientTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/ProgramClientTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/QueryClientTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/ServiceClientTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/UsageHandlerTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-client-tests/src/test/java/co/cask/cdap/client/WorkflowClientTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-common/src/main/java/co/cask/cdap/common/conf/Constants.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-common/src/main/resources/cdap-default.xml (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-gateway/src/test/java/co/cask/cdap/gateway/GatewayTestBase.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-gateway/src/test/java/co/cask/cdap/gateway/handlers/RuntimeArgumentTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-gateway/src/test/java/co/cask/cdap/gateway/run/StreamWriterTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-integration-test/src/main/java/co/cask/cdap/test/remote/RemoteApplicationManager.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-proto/src/main/java/co/cask/cdap/proto/Notification.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-proto/src/main/java/co/cask/cdap/proto/ProgramRunStatus.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-test/src/main/java/co/cask/cdap/test/AbstractApplicationManager.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-test/src/main/java/co/cask/cdap/test/ApplicationManager.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-unit-test/src/main/java/co/cask/cdap/test/TestBase.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-unit-test/src/main/java/co/cask/cdap/test/internal/DefaultApplicationManager.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-unit-test/src/test/java/co/cask/cdap/security/AuthorizationTest.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-unit-test/src/test/java/co/cask/cdap/service/FileUploadServiceTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
    • cdap-unit-test/src/test/java/co/cask/cdap/test/app/TestFrameworkTestRun.java (version c536a92d2cc0b4d1f1e59a6433f26db968d444eb)
  • Edwin Elia

    Edwin Elia 056ca102ceca09cd8183685ad8e443ab6951b0b3

    Merge pull request #9259 from caskdata/feature/ui-set-transient-variable
    [CDAP-12091] add Define Variable and Set Counter directive

  • Chengfeng Mao <mao@cask.co>

    Chengfeng Mao <mao@cask.co> 53f7bf93008a01587565083651bc47b8de6da035

    Merge pull request #9295 from caskdata/feature/propagate-twill-error
    [CDAP-12202] Propagate errors from MapReduce, Spark, Workflow TwillRunnable

  • Edwin Elia

    Edwin Elia e07332e1a3accec7b73c26ae2e5e49be1f670d67 m

    add Define Variable and Set Counter directive

    • cdap-ui/app/cdap/components/DataPrep/ColumnActionsDropdown/index.js (version e07332e1a3accec7b73c26ae2e5e49be1f670d67)
    • cdap-ui/app/cdap/components/DataPrep/Directives/DefineVariable/DefineVariable.scss (version e07332e1a3accec7b73c26ae2e5e49be1f670d67)
    • cdap-ui/app/cdap/components/DataPrep/Directives/DefineVariable/index.js (version e07332e1a3accec7b73c26ae2e5e49be1f670d67)
    • cdap-ui/app/cdap/components/DataPrep/Directives/SetCounter/SetCounter.scss (version e07332e1a3accec7b73c26ae2e5e49be1f670d67)
    • cdap-ui/app/cdap/components/DataPrep/Directives/SetCounter/index.js (version e07332e1a3accec7b73c26ae2e5e49be1f670d67)
    • cdap-ui/app/cdap/components/DataPrep/helper.js (version e07332e1a3accec7b73c26ae2e5e49be1f670d67)
    • cdap-ui/app/cdap/components/ScrollableList/index.js (version e07332e1a3accec7b73c26ae2e5e49be1f670d67)
    • cdap-ui/app/cdap/text/text-en.yaml (version e07332e1a3accec7b73c26ae2e5e49be1f670d67)
  • sagarkapare <sagar@cask.co>

    sagarkapare <sagar@cask.co> dd5721c69a85565efeb92b6420333b571b979860 m

    CDAP-12109 Create phases and phase connections for the conditions in the pipeline.

    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/planner/ConditionBranches.java (version dd5721c69a85565efeb92b6420333b571b979860)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/planner/Dag.java (version dd5721c69a85565efeb92b6420333b571b979860)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/main/java/co/cask/cdap/etl/planner/PipelinePlanner.java (version dd5721c69a85565efeb92b6420333b571b979860)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/test/java/co/cask/cdap/etl/planner/ConnectorDagTest.java (version dd5721c69a85565efeb92b6420333b571b979860)
    • cdap-app-templates/cdap-etl/cdap-etl-core/src/test/java/co/cask/cdap/etl/planner/PipelinePlannerTest.java (version dd5721c69a85565efeb92b6420333b571b979860)
  • Chengfeng <mao@cask.co>

    Chengfeng <mao@cask.co> 09634c1cc145f321ad1da7c7195a26426941fb0c m

    [CDAP-12202] Porpagate erros from MR, SPark, WF TwillRunnable

    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/distributed/DistributedMapReduceProgramRunner.java (version 09634c1cc145f321ad1da7c7195a26426941fb0c)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/distributed/MapReduceTwillRunnable.java (version 09634c1cc145f321ad1da7c7195a26426941fb0c)
    • cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/distributed/WorkflowTwillRunnable.java (version 09634c1cc145f321ad1da7c7195a26426941fb0c)
    • cdap-spark-core-base/src/main/java/co/cask/cdap/app/runtime/spark/distributed/DistributedSparkProgramRunner.java (version 09634c1cc145f321ad1da7c7195a26426941fb0c)
    • cdap-spark-core-base/src/main/java/co/cask/cdap/app/runtime/spark/distributed/SparkTwillRunnable.java (version 09634c1cc145f321ad1da7c7195a26426941fb0c)