从DSL在SCDF中设置Java应用程序版本

Question

我正在尝试使用 Java DSL 部署流。

这里创建流的代码（流畅的风格）

    private void create() {
        builder
                .name(this.STREAM_NAME)
                .source(source)
                .sink(sink)
                .create();
    }

部署方法

    private void deploy() {
        dataFlowOperations.streamOperations().deploy(this.STREAM_NAME, new HashMap());
        waitForStatus("deployed");
    }

以及为源应用程序创建bean的方法

    @Bean
    public StreamApplication source() {
        return new StreamApplication("httpsource")
                .addProperty("app.httpsource.version", "0.0.17")
                .addProperty("spring.cloud.dataflow.httpsource.validation.schema", this.properties.getHttpSource().getJsonSchema());

    }

我首先触发创建方法，然后部署。问题是-我想为http源代码应用程序将应用程序版本设置为0.0.17，但为该应用程序部署的最终pod的映像版本等于默认版本0.0.1。是否可以使用JavaDSL设置应用程序版本？

Answer 1

在部署流/任务时，您可以选择将版本参数作为部署属性的一部分传递。具体来说，对于版本，您可以使用版本传递它们。

DataflowIT提供了这样的测试组合（参见：示例）；请随意使用它作为参考。我们依赖这些IT测试以及端到端验收测试。