WindowFunction-extension, WindowedStream apply signature mismatch

2016-12-13 Thread MIkkel Islay
(The following is a cross-post of a Stack Overflow question at https://stackoverflow.com/questions/41105142/windowfunction-extension-does-not-match-windowedstream-apply-signatures ) Why does the below error occur? Given this extension to WindowFunction: class TestWinFunc extends WindowFunction

Re: Azure Blob Storage Connector

2016-08-16 Thread MIkkel Islay
the lib folder), configure > the fs.hdfs.hadoopconf key to point to your Hadoop config directory, > and update the core-site.xml like in the mailing list Thread. > > Then you should be able to access your data via azure://... > > Would appreciate some feedback whether this works as expected. &

Azure Blob Storage Connector

2016-08-16 Thread MIkkel Islay
Hello, I would like to access data in Azure blob storage from Flink, via the Azure storage HDFS-compatibility interface. That is feasible from Apache Drill, and I am thinking something similar should be doable from Flink. A documentation page on eternal storage connectors for Flink exist, but it w