Build #2,885

Cask Data Application Platform - Develop Build and Test

Build: #2885 was successful Child of CDAP-DRC-4852

Code commits

caskdata/cdap

  • Terence Yim <885032+chtyim@users.noreply.github.com>

    Terence Yim <885032+chtyim@users.noreply.github.com> 97dfbdd421a4bed4516dc85904cd12a96cf3a239

    Merge pull request #12044 from cdapio/feature/CDAP-16369-runtime-client
    (CDAP-16369) Introduce new runtime service

  • Terence Yim

    Terence Yim bf8f9b0da111d464ca41c5b1650ad81dc9182372 m

    (CDAP-16369) Added RuntimeServiceMain and tests
    - This is for running RuntimeServer in a separate process

    • cdap-app-fabric/src/main/java/io/cdap/cdap/app/guice/RuntimeServerModule.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/app/runtime/ProgramOptions.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/program/MessagingProgramStatePublisher.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/program/MessagingProgramStateWriter.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/DirectRuntimeRequestValidator.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeClient.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeClientService.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeProgramStatusSubscriberService.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/services/ProgramNotificationSubscriberService.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/store/AppMetadataStore.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/store/DefaultStore.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/store/StoreProgramRunRecordFetcher.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/master/environment/k8s/AbstractServiceMain.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/test/java/io/cdap/cdap/internal/app/runtime/monitor/DirectRuntimeRequestValidatorTest.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-app-fabric/src/test/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeClientServiceTest.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-common/src/main/java/io/cdap/cdap/common/conf/Constants.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-common/src/main/java/io/cdap/cdap/internal/app/store/RunRecordDetail.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-common/src/main/resources/cdap-default.xml (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-master/src/main/java/io/cdap/cdap/master/environment/k8s/RuntimeServiceMain.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-master/src/test/java/io/cdap/cdap/master/environment/k8s/MasterServiceMainTestBase.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
    • cdap-master/src/test/java/io/cdap/cdap/master/environment/k8s/RuntimeServiceMainTest.java (version bf8f9b0da111d464ca41c5b1650ad81dc9182372)
  • Terence Yim

    Terence Yim d51add93b010e434eada65b8b0fb9fcd28fd6e1a m

    (CDAP-16369) Added RuntimeClientService
    For periodically sending data to runtime server

    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeClientService.java (version d51add93b010e434eada65b8b0fb9fcd28fd6e1a)
    • cdap-app-fabric/src/test/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeClientServiceTest.java (version d51add93b010e434eada65b8b0fb9fcd28fd6e1a)
    • cdap-common/src/main/java/io/cdap/cdap/common/service/AbstractRetryableScheduledService.java (version d51add93b010e434eada65b8b0fb9fcd28fd6e1a)
    • cdap-common/src/main/resources/cdap-default.xml (version d51add93b010e434eada65b8b0fb9fcd28fd6e1a)
  • Terence Yim

    Terence Yim fb6564cf986497945be117f09bbfc2e6b9b09236 m

    Refactor methods from RuntimeMonitor into util class

    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeMonitor.java (version fb6564cf986497945be117f09bbfc2e6b9b09236)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeMonitors.java (version fb6564cf986497945be117f09bbfc2e6b9b09236)
  • Terence Yim

    Terence Yim 96659c516b2098ba8385c5a541407cd3e1503f45 m

    (CDAP-16369) Adds DirectRuntimeRequestValidator
    - An implementation that reads from underlying store directly

    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/distributed/remote/RemoteRuntimeTable.java (version 96659c516b2098ba8385c5a541407cd3e1503f45)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/DirectRuntimeRequestValidator.java (version 96659c516b2098ba8385c5a541407cd3e1503f45)
    • cdap-app-fabric/src/test/java/io/cdap/cdap/internal/app/runtime/monitor/DirectRuntimeRequestValidatorTest.java (version 96659c516b2098ba8385c5a541407cd3e1503f45)
  • Terence Yim

    Terence Yim 6e6d01eae1ab58560559e9b26708b82f932a85ac m

    (CDAP-16369) Simplifies Guice bindings for k8s services

    • cdap-app-fabric/src/main/java/io/cdap/cdap/app/guice/DefaultProgramRunnerFactory.java (version 6e6d01eae1ab58560559e9b26708b82f932a85ac)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/master/environment/k8s/AbstractServiceMain.java (version 6e6d01eae1ab58560559e9b26708b82f932a85ac)
    • cdap-app-fabric/src/test/java/io/cdap/cdap/internal/app/services/http/handlers/NamespaceHttpHandlerTest.java (version 6e6d01eae1ab58560559e9b26708b82f932a85ac)
    • cdap-kubernetes/src/main/java/io/cdap/cdap/k8s/common/AbstractWatcherThread.java (version 6e6d01eae1ab58560559e9b26708b82f932a85ac)
    • cdap-master-spi/src/main/java/io/cdap/cdap/master/spi/discovery/DefaultServiceDiscovered.java (version 6e6d01eae1ab58560559e9b26708b82f932a85ac)
    • cdap-master/src/main/java/io/cdap/cdap/master/environment/k8s/LogsServiceMain.java (version 6e6d01eae1ab58560559e9b26708b82f932a85ac)
    • cdap-master/src/main/java/io/cdap/cdap/master/environment/k8s/MetadataServiceMain.java (version 6e6d01eae1ab58560559e9b26708b82f932a85ac)
  • Terence Yim

    Terence Yim f2426fe8aceefcdf26b92fca42928cbe19c9cda7 m

    (CDAP-16369) Use RemoteExecutionLogProcessor to process logs from remote runtime

    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeHandler.java (version f2426fe8aceefcdf26b92fca42928cbe19c9cda7)
    • cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeServer.java (version f2426fe8aceefcdf26b92fca42928cbe19c9cda7)
    • cdap-app-fabric/src/test/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeClientServerTest.java (version f2426fe8aceefcdf26b92fca42928cbe19c9cda7)
    • cdap-app-fabric/src/test/java/io/cdap/cdap/internal/app/runtime/monitor/RuntimeServiceRoutingTest.java (version f2426fe8aceefcdf26b92fca42928cbe19c9cda7)