spring-xd

0熱度

1回答

我們擁有小型集羣。其中spring xd分佈式運行時體系結構是ETL的組件。我們使用cron.But計劃了批處理作業。但是當作業失敗或中斷時，我們沒有通過指定通道或電子郵件得到通知，並且可以通過向指定通道發送消息來觸發批處理作業？目前，運行在以下環境：春XD分佈式運行 - 1.2.1 Hadoop發行版 - PHD3.0 上任何幫助將不勝感激。

0熱度

1回答

春XD紗口的要求

我上線配置Spring XD。數據導入導出和加工彈簧XD其上所需要的所有端口打開裏面集羣數據節點紗。我可以看到端口的Redis，兔，數據庫，我們要運行下一個走集羣。感謝，

1熱度

2回答

SpringXD無法找到目前在尤伯杯罐的lib

我已經創建了一個自定義的模塊在春季XD其中，「類別中號擊中Oracle數據庫和緩存使用ehcache.Other比目前在XD/lib下我是罐子結果在我的模塊中使用「ehcache-2.9.0.jar和ojdbc6-11.1.0.7.0.jar」。我爲我的自定義模塊創建了UBER jar。尤伯杯罐/ lib目錄既包含了額外的罐子，我added.Module上傳命令的工作效果很好，當我在XD env.

1熱度

1回答

在MySQL SpringXD-問題，因爲源.FAILED來驗證新建立的連接

我創建一個春天XD流象下面這樣： stream create foo --definition "jdbc --url=jdbc:mysql://localhost:3306/test --driverClassName=com.mysql.jdbc.Driver --query='select * from employee' |hdfs --inputType=text/plain --rol

0熱度

1回答

時出現例外春-XD聯繫

我想看到一個工作，我跑的執行狀態作業執行狀態的時候，但在某些隨機點我收到以下錯誤： 2015-10-14T14:41:24-0400 1.2.0.RELEASE ERROR qtp195949131-28 rest.RestControllerAdvice - Caught exception while handling a request org.springframework.http.c

0熱度

1回答

上Ambari

安裝彈簧XD我安裝以下軟件：的CentOS 6.7 阿帕奇Ambari 2.1.2 我試着通過Ambari安裝彈簧XD，所以我閱讀以下教程： https://github.com/spring-projects/spring-xd-ambari/blob/master/src/docs/asciidoc/InstallingXDwithAmbari.asciidoc 當我嘗試安裝春天XD通過Am

0熱度

1回答

Spring xd流web服務響應

我想使用spring xd從Web服務使用HTTP/1.1協議來獲取text/xml響應。目標是將xml響應轉換爲json並插入到mongodb中。但現在我無法從流中獲得任何迴應。我想這樣做編程，而不是在殼，下面是我的代碼 public static void main(String[] args) { SpringXDTemplate template = null; t

0熱度

1回答

如何順流春季XD執行同樣的工作

我們有以下要求，春天XD，我們有工作讓我們假設中的任務名稱爲MyJob 將由另一個進程使用調用Spring xd的其餘服務，讓我們假設進程名稱爲OutsideProcess（非Spring xd進程）。當有一個文件添加到OutsideJob正在偵聽的位置（讓我們假設FILES_LOC）時，OutsideJob會調用MyJob。在這種情況下，我們假設MyJob需要5分鐘才能完成作業。上午10

0熱度

1回答

響應HTTP POST的Spring XD流

我想在Spring XD中創建一個以HTTP源開始的流，將流執行的結果作爲響應的主體。在下面的例子中，我想知道是否有任何東西我可以用在轉換後的大寫字母后面，這樣原始http post的響應正文就是上層的實體。 stream create --name httptest --definition "http | transform --expression=payload.toUpperCase(

0熱度

1回答

Spring XD Java配置不加載xml資源

我正在使用Spring XD創建流twittersearch，然後連線到我的tweet處理器，然後連接到日誌。我使用的Java配置類的所有罰款沒有任何問題的話，我想用@ImportResource @Configuration @ImportResource("config/applicationContext.xml") @EnableIntegration public class M