spring-xd

0熱度

2回答

我剛剛下載spring-xd-1.1.0.M2.zip跟着下面的鏈接說明進行安裝： http://docs.spring.io/autorepo/docs/spring-xd/1.1.0.M2/reference/html/ 我有Java7我的機器上（這是列出的唯一先決條件）。當我嘗試啓動春季XD時，出現以下異常： C：\軟件\彈簧XD-1.1.0.M2 \ XD \ BIN> XD-singl

0熱度

2回答

彈簧XD沒有從Twitter上HDFS

我在我的畢業論文寫的工作流和我和春天有-XD一個問題：我從我的XD-shell中運行：流創建--name cyrustweets --definition 「twitterstream --track = '麥莉 - 塞勒斯，麥莉·賽勒斯' |日誌」 --deploy 和它的作品。我的xd-singlenode讓我看到推文。但是當我嘗試HDFS上寫：流創建--name cyrustweet

0熱度

1回答

JDBC使用彈簧批處理作業

HDFS進口我能夠使用JDBCHDFC Spring Batch的jobs.But我的MS SQL到HDFS導入數據如果容器出現故障，作業不會轉移到其他容器中。我如何繼續使工作容錯。我正在使用spring xd 1.0.1發行版

0熱度

1回答

春XD：管鏈分裂，加入和本地執行

我想實現以下目標：鑑於網址（PNG圖像）的列表，下載並行處理的文件（分割）轉換文件格式，用於並行處理下載的文件（例如png2jpg in.png out.jpg）等待，直到所有文件被轉換，然後取所有文件爲單個位置和做他們的最終操作（例如從所有圖像創建巨大的馬賽克圖像）圖像轉換僅作爲示例提供。我的處理實際上更復雜，但我試圖通過我需要分割文件處理來獲得需求，並且我需要在連接操作之後對最終處理進

1熱度

1回答

如何從Spring XD的twittersearch流設置代理詳細信息？

我已經建立了一個節點Spring XD並運行了XD Shell。運行這些主機的主機不會暴露於互聯網，因此我無法使用Spring XD開箱即用的twittersearch流。它拋出的java.net.UnknownHostException：api.twitter.com 現在的問題是，我該如何設置我的代理細節春XD，因此可以使用它們來伸手來Twitter？

0熱度

1回答

如何確保在進入下一個作業步驟之前完成所有步驟分區

在我的工作中，我將數據庫導出爲分區的csv。下一步使用MultiResourceItemReader將這些文件合併到一個文件中。我的問題是，合併步驟開始時，文件似乎不可用。我得到這個異常的作業失敗的所有部分的CSV文件中導出目錄可用 java.lang.IllegalStateException: No resources to read. Set strict=false if this i

0熱度

1回答

春XD自定義的作業執行事件

我能收到我的春節，XD的工作預先定義的作業執行事件如下： xd>job create --name myHttpJob --definition "httpJob" --deploy xd>stream create --name jobExecutionEvents --definition "tap:job:myHttpJob.job >log" --deploy 參考：http://d

0熱度

1回答

在MySQL innodb表中計數（*）會導致數據通過彈簧xd泵浦時出現不一致的結果

echo -e "job create --name $completeJobName --definition \"filejdbc --resources=file:/var/lib/wwhs/eligibility/processing/complete/* --names=file_id,client_id,member_record_number,membe r_first_name,

0熱度

1回答

彈簧XD - 試圖用「Twittersearch」，以流媒體數據時

我創建的這個春天XD代碼寫微博到一個文件流錯誤： stream create --name javatweets --definition "twittersearch --query=java --consumerKey=<my_key> --consumerSecret=<my_secret> | file" --deploy 不幸的是，我得到了以下錯誤消息： WARN Deploym

0熱度

1回答

問題與文件接收器和文件名錶達

試圖建立簡單的文件複製生產工程過程彈簧-XD： stream create --name mystrea --definition "file --dir=/path/source --fixedDelay=5 | sink:file --dir=/path/dest --binary=true --name=headers['file_name']" 這似乎創建和追加費爾文件報頭[「FI