问题标签 [spring-cloud-dataflow]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
spring-cloud - spring-cloud-dataflow 从本地存储库注册自定义模块
我有一个带有父 spring-cloud-dataflow-parent 的 jar,我使用本地存储库 --coordinates 注册了它。但是,一旦我对其执行模块信息,就会收到此错误: java.lang.RuntimeException: org.eclipse.aether.resolution.ArtifactResolutionException: Could not find artifact ... in repository 1 ( https://repo.spring.io /libs-snapshot)这个未解决的问题似乎不一样:https ://github.com/spring-cloud/spring-cloud-dataflow/issues/191
看起来 AetherModuleResolver 没有找到我在 ~/.m2/repository... 中的模块并回退到默认存储库。
我试图修改 .../springframework/cloud/dataflow/admin/config/AdminProperties.java 进行测试但没有成功
我试图在 ~/.m2/repository/org/springframework/cloud/spring-cloud-stream-module-launcher/1.0.0.BUILD-SNAPSHOT$ vi META-INF/spring-configuration-metadata 中修改默认存储库.json 但没有成功
spring-cloud-dataflow - 在 spring-cloud-dataflow 中提供 hadoop 作为 Source 的任何方式
有没有办法在 spring-cloud-dataflow 中提供hadoop作为Source ?
我已经阅读了 spring-cloud-dataflow 的文档,发现它只支持hadoop作为Sink。但是我需要运行一个 map-reduce 作业,该作业将从 hdfs 读取数据,对数据进行聚合和转换,最后将数据存储到 hdfs。因此,请提供一种处理上述情况的方法。
spring-cloud-dataflow - CloudFoundry 中的 Spring Cloud Dataflow ticktock 示例失败
我正在尝试获取在 CloudFoundry 上运行的 Spring Cloud Dataflow 的最基本示例。我已按照此处的步骤操作:http: //docs.spring.io/spring-cloud-dataflow-admin-cloudfoundry/docs/current-SNAPSHOT/reference/htmlsingle/#getting-started使管理应用程序在我的组织/空间。然后我尝试从http://cloud.spring.io/spring-cloud-dataflow/创建最基本的示例,即创建“ticktock”流:
我可以看到两个应用程序ticktock-time和ticktock-log都是在空间中创建的,所需的服务“redis”绑定到这些应用程序并尝试启动。不幸的是,他们并没有完全启动,因为他们无法访问“redis”服务。在日志中我们发现:
上下文初始化期间遇到异常 - 取消刷新尝试:org.springframework.context.ApplicationContextException:无法启动 bean 'outputBindingLifecycle';嵌套异常是 org.springframework.context.ApplicationContextException: 无法启动 bean 'inputBindingLifecycle'; 嵌套异常是 org.springframework.data.redis.RedisConnectionFailureException: Cannot get Jedis connection;嵌套异常是 redis.clients.jedis.exceptions.JedisConnectionException: 无法从池中获取资源
这最终是由
引起:redis.clients.jedis.exceptions.JedisConnectionException:java.net.ConnectException:连接被拒绝
我是否缺少介于两者之间的一些配置步骤?
亚历山大
docker-swarm - Swarm 的 Spring Cloud Data Flow 支持
目前我可以看到 Spring Cloud Data Flow 有这些服务器:Local、YARN、Cloud Foundry、Mesos 和 Kubernetes;是否有任何 Swarm 支持计划?
java - Spring Cloud Data Flow @EnableBinding 注解打破了构造函数注入
我正在尝试使用构造函数注入创建一个 bean 并使用 Spring Cloud 注释对其进行@EnableBinding
注释。
我正在使用 Spring Boot1.3.3
和 Spring Cloud Brixton.M5
。
我在应用程序启动期间收到以下异常:
此异常消失,如果
@EnableBinding
已移除- 引入了无参数构造函数(显然,尽管
@Autowired
对包含参数的构造函数进行了注释,但仍使用它) - 改为使用场注入
下面的代码片段:
我猜它与 CGLIB 代理有关,但它应该支持从 Spring 4 开始的构造函数注入。
有人知道出了什么问题吗?是我的错还是 Spring Cloud Data Flow 中的错误?
docker - 如何在docker上部署spring cloud数据流
我使用https://github.com/spring-cloud/spring-cloud-dataflow/tree/master/spring-cloud-dataflow-app-launcher,
操作系统:ubuntu 15.10
然后
但遇到错误:
是我的方法错误?或者如何在docker上部署?
spring-cloud - Spring Cloud Dataflow 在与 Redis 不同的消息代理上?
从我在文档中看到的内容来看,Spring Cloud Dataflow 始终需要一个 Redis 实例才能工作。
是否也可以使用不同的消息代理,例如 RabbitMQ?
在启动期间如何指定不同的消息代理?
spring-cloud - 如何在 SCDF 中使用“标准”部署流
在本指南中提到,在流的部署过程中,可以为每个模块指定一个“标准”属性。例如
解释仅说明该属性是根据“每个当前可用模块的属性”评估的。
但是,这是什么意思?考虑哪些属性?这个属性的目的到底是什么?例如,该属性在所示示例中的含义是什么:module.log.criteria=groups.contains('x')
?
这些“标准”是表达模块传入消息过滤条件的一种方式吗?
是否有任何进一步的文件?
spring - spring-cloud-dataflow 的简单反例
我正在探索 spring-cloud-dataflow,我可以成功浏览twitterstream 示例,并且 field-value-counters 包含一些有用的值。
但是我无法创建其他简单的示例,例如:
stream create test --definition 'http --server.port=9999 | counter --name=httpcounter --store=redis' --deploy
或者
stream create http-log --definition 'http --server.port=1234 | log' --deploy
stream create http-tap-counter --definition ':http-log.http > counter --name=http-tap-counter' --deploy
在这两种情况下,流都会被创建和部署并stream list
显示它们,但是在 shell 中执行“计数器列表”时计数器不会显示。
我还在日志中验证了 http 源正在接收一些输入。
任何想法为什么我在这里缺少创建一个简单的计数器?