spring-xd

2热度

1回答

我现在正在阅读Spring Cloud DataFlow文档，但事实证明PART IV（模块）中包含的章节存在某种错误，因为整个章节已经填满了这一部分类型的文本未解决的伪指令in raw.githubusercontent.com/spring-cloud/spring-cloud-stream-modules/master/ spring-cloud-stream-modules-docs/s

1热度

1回答

Spring XD：使用log4j和logback

我有一组XD作业模块，都使用log4j日志记录。我最近升级到Spring XD 1.3.1，我的模块不再记录。我已经尝试将我的软件包添加到xd-singlenode-logback.groovy配置文件。这没有效果。我创建了一个使用slf4j的虚拟模块，它可以正确记录。我试图找到关于log4j和logback兼容性的任何信息，但还没有找到明确的答案。我是否必须用slf4j切换log4j，或

0热度

1回答

重新加载流而不被取消部署

我有一个自定义接收器模块的流。当部署流时，模块连接并从数据库读取属性。我想刷新模块属性而不取消部署流，即如果在数据库中进行更改，我应该能够刷新属性而不取消部署流。任何想法或建议？在此先感谢。

0热度

1回答

如何在springxd运行时获取通道名称

我有一个流定义为流create --name foo --definition samplesource | sampleprocessor | samplesink --deploy。我使用Redis作为MessageBus。如果sampleprocessor或samplesink失败，则xd会将失败的消息推送到Redis：foo.n队列中。我正在编写代码将错误队列中的消息发送到foo.n.

0热度

1回答

连接mysql数据库时出现Spring XD问题

我是springxd的新手，在传入流下时遇到问题。 stream create foo2 --definition "jdbc --fixedDelay=1 --split=1 --driverClassName=oracle.jdbc.driver.OracleDriver --url=jdbc:mysql://localhost:3306/test --query='select * from

0热度

1回答

使用SpringXD

通配符SQL查询我有一个用例在那里我需要将数据从一个基于SQL的仓库移到每天蒙戈。我们选择SpringXD作为这个ETL工作的工具。然而，我需要传递几个狂放的梳理参数给我每天都在变化的查询。我想知道是否有人知道，也无法向我提供样品DSL为通配符的参数传递给一个SQL SELECT查询使用Spring XD时。

0热度

1回答

春XD sqoop作业失败

HortonWorks版本是2.4 SpringXd版本 - 1.3.1 我试图运行从春天XD进口一sqoop工作。它给出了以下堆栈跟踪。你能让我知道这里有什么问题。 2016-05-16T11:29:54+0530 1.3.1.RELEASE INFO main tool.CodeGenTool - Beginning code generation 2016-05-16T11:29:54+0

3热度

1回答

Spring Cloud数据流是否支持批处理

我们正在探索各种编程/库选项（在世界的Java方面）以实现更快的批处理并且能够部署到云上。我们遇到了Spring批处理/ XD /云数据流。从对http://cloud.spring.io/spring-cloud-dataflow/文档的快速回顾中，我们无法评估Spring云数据流是否具备Spring批处理能够提供的所有批处理功能。例如，以下是SPring批处理文档（http://project

0热度

1回答

SpringXD中的错误处理

我已将Redis配置为我的spring-xd安装程序的MessageBus。当我的流失败时，数据被推送到错误队列。我正在尝试读取它们并将它们推回到目标队列。但是我没有看到我的Sink模块接收数据。有些人可以帮助我了解我哪里出错了。代码片段。 public RedisTemplate<String, byte[]> redisTemplate(RedisConnectionFactory redi

1热度

1回答

为LoggingHandler设置通道

我正在为我的springxd模块编写我自己的单元测试，（但是，我没打算使用xd.test和xd.dirt）。这是一个处理器模块，我就是这样做的测试是：配置方面： ctx = new ClassPathXmlApplicationContext("config/spring-module.xml"); 得到inputDirectChannl和send(Message) input = ctx