使用Flink 1.2從Avro文件讀取數據

我一直在試圖弄清楚如何使用Flink 1.2.0（它必須是這個特定的版本）從Avro文件讀取數據現在幾個小時，我只發現了矛盾的信息。使用Flink 1.2從Avro文件讀取數據

對於初學者來說，弗林克的documentation提到，我們應該使用AvroInputFormat但這個類是無處可尋的（至少是不包括在Maven依賴：弗林克的Java，弗林克串流-java_2.10，和flink-clients_2.10）。

我錯過了什麼嗎？

我的具體問題是：是否在版本1.2.0中刪除了Avro支持，並且文檔只是過時了？

感謝

2017-03-22 omrsin

的AvroInputFormat位於flink-avro_2.10依賴。

有沒有計劃放棄Avro支持。

2017-03-23 11:43:17

謝謝。鑑於flink-avro不是任何其他庫的繼承依賴項，我建議在文檔中提到應該包括這種依賴關係。 – omrsin

該文檔是官方flink存儲庫的一部分。如果您有興趣，請隨時將其提供給我們的文檔:) –

我更新了文檔，但根據指導原則，必須有一個描述更改的JIRA票據。你可以創建這個，這樣我可以提交拉請求？ – omrsin

回答