flink-streaming

1熱度

2回答

Flink是否提供Java API以將作業提交給JobManager？

我知道喬布斯可以通過flink或flink.bat提交給JobManager。我想知道Flink是否提供Java API將作業提交給JobManager？

0熱度

1回答

如何在檢查點被禁用時配置特定的Zookeeper路徑來提交偏移量？

如果檢查點未啓用，卡夫卡用戶將定期向Zookeeper提交偏移量。是否可以配置動物園管理員路徑？

0熱度

1回答

從VM插座卡夫卡發送的數據流中，並接收對主機操作系統的弗林克計劃：反序列化問題

我從虛擬機發送數據流，以卡夫卡的測試題目用下面 public class WriteToKafka { public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnviro

0熱度

1回答

不能在自定義DataSink（弗林克CEP）

初始化場我與Apache弗林克流API的一個問題。我可以設法建立整個CEP-環境與自定義數據源和源像使用標準的水槽時，「打印（）」，一切工作正常。這是我的片貌似現在： @RequiredArgsConstructor public class EventDataConsumer extends RichSinkFunction<EventData>{ private final tran

2熱度

1回答

弗林克流：在序列化的字符串消息意外charaters

我的流是生產類型的記錄Tuple2<String,String> .toString()輸出(usr12345,{"_key":"usr12345","_temperature":46.6}) 其中鍵是usr12345和值是{"_key":"usr12345","_temperature":46.6} 在流輸出的.print()該值正確： (usr12345,{"_key":"usr12345",

0熱度

1回答

使用Flink和kinesis流的流窗口處理處理不起作用

我正在使用Flink讀取kinesis流。它基於時間窗口和密鑰聚合某個事件。代碼在reduce之後不做任何事情。沒有數據被映射到輸出csv中。我等了很多分鐘（即使時間窗口只有兩分鐘）。 public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExec

0熱度

1回答

處理在弗林克CEP多個圖案並聯

我有以下情況有其發送流卡夫卡正在被由CEP引擎接收其中警告時產生的特定條件2的虛擬機對個人Stream滿意。目前，CEP是檢查兩個流上相同條件下（當心髒率> 65和呼吸率> 68）患者和如下圖所示 // detecting pattern Pattern<joinEvent, ? > pattern = Pattern.<joinEvent>begin("start")

0熱度

2回答

弗林克代碼

我從cqlsh外殼 CREATE KEYSPACE data WITH replication= {'class':'SimpleStrategy', 'replication_factor':1; CREATE TABLE test.patient(id int, heart_rate int, PRIMARY KEY(id)); 我想，如果不從弗林克代碼存在，它創建密鑰空間和表創建密鑰

0熱度

1回答

客戶端未連接到任何Elasticsearch節點弗林克

我使用弗林克1.1.2和Maven中已經添加ElesticSearch依賴性如下 <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-elasticsearch2_2.10</artifactId> <version>1.2.0</version> </

0熱度

1回答

Can Flink可以和Kotlin一起使用嗎？

我有一個需要實時流式傳輸數據的項目。我已經將流量數據寫入了一個kafka主題。現在我需要讀取這些數據並對其進行處理。爲此，我打算使用Flink。我的兩難處境是我不知道Java，Scala或Kotlin。我必須學習其中的一個使用Flink，因爲Kotlin是最新的，我認爲我應該學習，但它實際上是否與Flink兼容？我對任何類型的數據流都是全新的，所以請原諒我的問題中的任何錯誤，如果我錯了，絕對糾