apache-flink

0熱度

1回答

我最近在Google Cloud的兩臺服務器上安裝了Flink，以測試它們的一些事情。我創建了一個獨立的集羣，其中一個是作業管理器，並且它們都有一個任務管理器。爲了測試集羣，我通過儀表板界面（使用SSH代理）提交了一個自定義作業。這項工作運行得很好（雖然有一些獨立和不相關的問題）。問題是我無法找到從儀表板提交的作業的日誌。我已在/tmp，$FLINK_HOME和根$HOME中進行了檢查，但我似乎

0熱度

1回答

Apache Beam/Flink ExceptionInChainedStubException

我使用的是Apache Beam 2.0.0和相同版本的FlinkRunner（scala 2.10）。我正在使用FlinkRunner依賴關係測試進程內Flink主控（默認配置），顯然在運行時引入Flink 1.2.1（查看MVN依賴關係樹）。當出現「用戶異常」時，找出實際出錯的最佳方式是什麼？這不是一個關於我這次做錯了的問題;而是如何說明 - 一般來說 - 如何從Beam或Flink中獲取更

0熱度

2回答

Apache Flink - 檢查點和保存點之間的區別？

有人能幫我理解Apache Flink的檢查點&保存點之間的區別。雖然我閱讀文檔，無法理解差異！：■

1熱度

2回答

如何算阿帕奇弗林克在給定時間處理的記錄數窗口

在弗林克定義一個時間窗口，方法如下： val lines = socket.timeWindowAll(Time.seconds(5)) 我如何能夠計算在5特定窗口的記錄數秒？

0熱度

1回答

我可以打印阿帕奇弗林克DataSteam <T>的單個元素，而無需使用內置的print（）函數

我想打印已在弗林克被檢測警告值//生成溫度警告對每個匹配的警告模式 DataStream<TemperatureEvent> warnings = tempPatternStream.select( (Map<String, MonitoringEvent> pattern) -> { TemperatureEvent first = (TemperatureEvent)

0熱度

1回答

warnings.print（）打印以相反的順序事件（最後的情況下第一）節選第一事件中的Apache弗林克CEP

我想篩選是>在弗林克10使用以下圖案中的所有臨時事件， Pattern<MonitoringEvent, ?> warningPattern = Pattern.<MonitoringEvent>begin("first") .subtype(TemperatureEvent.class) .where(new FilterFunction<TemperatureE

1熱度

2回答

Flink 1.2是否支持Python編程？

返回到在線python編程指南： https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html 我沒有看到任何有關像kafka連接器等流媒體編程的材料。也從git集線器的例子（https://github.com/apache/flink/tree/master/flink-examples/f

0熱度

1回答

弗林克S3寫入失敗無法從任何供應商加載鏈AWS憑據

當我使用flinks流API寫S3： // Set StreamExecutionEnvironment final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); // Set checkpoints in ms env.setStreamTimeCharact

0熱度

1回答

無法擴展Flink ProcessFunction

我最近從Flink 1.2升級到Flink 1.3，我試圖更新我的ProcessFunction以使用1.3。我有我期待創建延伸的ProcessFunction類的功能，但它拋出一個編譯錯誤，說我不重寫processElement和onTimer這裏是我的代碼有： class TimeoutStateFunction extends ProcessFunction[ObjectNode, (Str

0熱度

1回答

發送數據流/遙控插座弗林克程序在主機操作系統上運行

正如弗林克文檔中提到，我可以打開使用 [email protected]:~$ nc -l 12345 本地套接字，然後接收讀取來自文本服務器文本輸入它使用 DataStream<String> text = env.socketTextStream("localhost", 12345); text.print(); env.execute(); 然而，當我模擬了一些場景，所以我