Re: Data Transfer between TM should be encrypted

Hi Vijay, That's a good news for me. Eagerly waiting for this change so that I can integrate and test it before going live. Regards, Vinay Patil On Tue, Aug 30, 2016 at 4:06 PM, Vijay Srinivasaraghavan [via Apache Flink User Mailing List archive.] wrote:

Re: Firing windows multiple times

I appreciate your suggestion! However, the main problem with your approach is the amount of time that goes by without an updated value from minuteAggregate and hourlyAggregate (lack of a continuously updated aggregate). For example, if we use a tumbling window of 1 month duration, then we only

Re: Data Transfer between TM should be encrypted

Hi Stephan, The dev work is almost complete except the Yarn mode deployment stuff that needs to be patched. We are expecting to send a PR in a week or two. RegardsVijay On Tuesday, August 30, 2016 12:39 AM, Stephan Ewen wrote: Let me loop in Vijay, I think he is the

"select as" in Flink SQL

I am try to execute simple sql like this: DataSet dataSet0 = env.fromCollection( infos0 ); tableEnv.registerDataSet( "table0", dataSet0 ); Table table = tableEnv.sql( "select assetClass as \"asset class\" from tabel0" ); I am getting:

flink dataStream operate dataSet

Hi, i have a problem,a dataStream read from rabbitMQ,and others data from a hbase table,which is a dataSet.Those two data from follow: val words=connectHelper.readFromRabbitMq(...) // words is DataStream[String] val dataSet=HBaseWrite.fullScan() //dataSet is

Re: Accessing state in connected streams

Hi Aljoscha, I removed business objects and logic etc.. I am happy to post here [] I am sure this is a common issue when you start to seriously mess with state. Assuming a type for the Output And assuming that there is a function (EventA :=> String) in the mapWithState operator of

Re: Accessing state in connected streams

Hi Aris, I think you're on the right track with using a CoFlatMap for this. Could you maybe post the code of your CoFlatMapFunction (or you could send it to me privately if you have concerns with publicly posting it) then I could have a look. Cheers, Aljoscha On Mon, 29 Aug 2016 at 15:48 aris

Re: Data Transfer between TM should be encrypted

Let me loop in Vijay, I think he is the one working on this and can probably give the best estimate when it can be expected. @vijay: For the SSL/TLS transport encryption - do you have an estimate for the timeline of that feature? On Mon, Aug 29, 2016 at 8:54 PM, vinay patil