flink-streaming

0熱度

2回答

誤差弗林克0.10.1

隨着當地弗林克0.10.1我不能因以下錯誤jobmanager連接： Association with remote system [akka.tcp://[email protected]:49789] has failed, address is now gated for [5000] ms. Reason is: [scala.Option; local class incompatibl

3熱度

1回答

Apache Flink Streaming類型不匹配在flatMap函數中

試圖在scala 2.10.4中使用0.10.0 flink版本的流api。在試圖編譯這個第一個版本： import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment import org.apache.flink.streaming.api.scala.DataStream import org.apa

2熱度

1回答

弗林克InvalidTypesException：在的TypeVariable「類」「K」的類型不能確定

弗林克0.10.0剛剛發佈最近。我有一些代碼需要從0.9.1遷移。但出現以下錯誤： org.apache.flink.api.common.functions.InvalidTypesException：類'fi.aalto.dmg.frame.FlinkPairWorkloadOperator'中TypeVariable'K'的類型無法確定。這很可能是一種類型的刪除問題。只有在返回類型中的所有變

2熱度

2回答

flink - 羣集未使用羣集

我設置了一個3節點的羣集，可以非常均勻地分配任務（步驟？作業？），直到最近一次分配給一臺機器。拓撲（我們仍然使用這個術語以弗林克）： kafka (3 topics on different feeds) -> flatmap -> union -> map 有什麼關於這一步，將告訴集羣管理器把一切都在一臺機器？此外 - 圖像中的「未設置」值是什麼？我錯過了一些步驟？或者一些即將實施的UI功能

6熱度

1回答

Apache Flink如何實現迭代？

DAG（有向無環圖）執行大數據很常見。我想知道Apache Flink如何實現迭代。因爲它可以是一個循環圖。

1熱度

1回答

Flink - 構建作業以最大化吞吐量

我有4種類型的kafka主題和每種類型的65個主題。目標是對數據做一些簡單的窗口聚合並將其寫入數據庫。的拓撲結構將類似於：卡夫卡 - >窗口 - >減少 - > DB寫入某處在這個組合我想/需要做工會 - 或者可能的幾個（取決於每次組合多少個主題）。主題中的數據流量範圍從10K到> 200K messages/min。我有一個四節點的30個核心/節點的flink羣集。我如何構建這些拓撲來

9熱度

1回答

Flink流事件時間窗口排序

我遇到了一些麻煩，理解事件時間窗口周圍的語義。以下程序會生成一些帶時間戳的元組，用作事件時間並進行簡單的窗口聚合。我希望輸出的順序與輸入相同，但輸出順序不同。爲什麼輸出與事件時間無關？ import java.util.concurrent.TimeUnit import org.apache.flink.streaming.api.TimeCharacteristic import org.