apache-samza

1熱度

1回答

我正在嘗試更改Apache Samza的日誌記錄級別，以便我可以獲得debug語句;缺省值是info。更具體地說，我試圖讓this debug statement出現。我在Clojure項目中使用Samza。做這個的最好方式是什麼？ Samza Logging頁面沒有提供任何有用的信息。

0熱度

1回答

紗線沒有得到節點

這是在具有2個任務節點和主控的AWS EMR集羣中。我在嘗試啓動紗線作業的hello-samza。這項工作陷入了接受狀態。我看了其他帖子，似乎我的紗線沒有節點。什麼紗線沒有獲得任務節點的幫助將有所幫助。 [[email protected] hello-samza]$ deploy/yarn/bin/yarn node -list 17/04/18 23:30:45 INFO client.R

0熱度

1回答

有沒有job.coordinator.system的替代選擇

我想使用samza，但是案例是我們的kafka話題的創造是有限的（話題創作應該被審查，並且應該具體具體）。那麼，有沒有其他的選擇「job.coordinator.system」？我需要使用介紹。非常感謝！

0熱度

1回答

阿帕奇Samza：入門Samza REST和HELLO-samza

我下面的Apache Samza website的Hello-samza教程，想添加一個REST服務如下所述：http://samza.apache.org/learn/tutorials/latest/samza-rest-getting-started.html 我可以看到在紗線的samza工作UI，但下面的生成指令產生的錯誤： ./gradlew samza-rest:clean relea

1熱度

2回答

如何從本地文件系統和hdfs系統讀取Apache Samza中的文件

在Apache Samza中尋找從本地系統或HDFS讀取文件的方法然後將過濾器，聚合，條件，排序，分組應用到批處理數據。請提供一些幫助。

2熱度

2回答

YARN的Samza在哪裏放置KV國家商店？

我需要找到Yarn上的Samza放置其KV國家商店的地方。我懷疑它是在YARN本地應用程序目錄中的所有YARN應用程序，但我相信它是可配置的，因爲我在幾個月前（在不同的環境中映射文件夾到內存）執行此操作，但現在不記得。爲了可能，我需要能夠將samza KV存儲與其他應用程序的其他YARN應用程序數據分開。

0熱度

1回答

如何檢查KeyValueStore中的所有元素

我有一個KeyValueStore類型的KeyValueStore。我不知道鍵的範圍。有什麼方法可以遍歷samza中的整個keyvaluest？謝謝

1熱度

1回答

您好，Samza得到NullPointException

我沒有使用網格腳本來啓動HELLO-samza項目http://samza.apache.org/startup/hello-samza/0.11/ 我按照網格腳本步驟下載Hadoop的，卡夫卡&動物園管理員配置動物園管理員，Hadoop的，卡夫卡，因爲它在電網腳本執行啓動飼養員，紗，卡夫卡，在這個步驟中，可以通過8088端口訪問頁面紗在瀏覽器然後我運行該腳本斌/運行 - job.sh -

0熱度

1回答

一個samza任務如何能夠佔用超過一個卡夫卡劃分流

我有消耗2個主題典型samza任務：從configdata和config，並將郵件作爲rocksdb本地狀態，以檢查是否從data消息確定。如果這兩個主題中的每一個都只有一個分區，則此任務可以正常工作。一旦我將data分爲十個分區，config仍然是一個分區，事情就會改變。默認情況下，samza產生10個任務消耗分區0〜9 data的話題，唯一的任務0的消耗config話題： task[0] -

0熱度

1回答

你好samza無法在windows 7中正常運行

我做了如http://samza.apache.org/startup/hello-samza/0.13/所示的一切基本上，克隆repo並鍵入「bin/grid bootstrap」。然而，最後我收到一條錯誤消息，說zookeeper無法啓動，如下所示，有誰知道我該如何解決這個問題，還有什麼我應該做的，使其工作？