Re: [RESULT][VOTE] Release 1.4.0, release candidate #3

Hi >> The voting time has passed and I'm happy to announce that we've collected enough votes to release this RC as Flink 1.3.2. Maybe 1.4.0, because 1.3.2 already exist =) 2017-12-12 13:58 GMT+04:00 Aljoscha Krettek : > The voting time has passed and I'm happy to announce that we've collected

Re: Update Netty version

MT+04:00 Greg Hogan : > Hi Alexey, > > Are you looking to create pull requests for upgrading Netty 4.0 and/or 4.1? > > Greg > > On Thu, May 18, 2017 at 4:41 AM, Alexey Demin wrote: > > > Hi > > > > Problem not directly in flink, but it you use flink wi

Re: Update Netty version

first step and enable select sslengine as second step, not all in one step. > However, if we do the change at the beginning of the next release cycle, we > might have enough exposure time to verify whether things work or not. We just start 1.4 iteration and have time for testing. Thank, A

Update Netty version

Hi For now we use very old netty version. Netty 4.0.27.Final released on 02-Apr-15 If we so worry about slice in LengthFieldBasedFrameDecoder we can add custom LengthFieldBasedCopyFrameDecoder which extend original LengthFieldBasedFrameDecoder and override extractFrame for keep current behavio

Re: [DISCUSS] (Not) tagging reviewers

Hi all View from my prospective: in middle of summer - 150 PR in middle of autumn - 180 now 206. This is mix of bugfixes and improvements. I understand that work on new features important, but when small and trivial fixes stay in states of PR more then 2-3 month, then all users think about changi

Re: Flink CEP development is stalling

Hi Ivan, I think problem not only with CEP project. Main contributors overloaded and simple fixes frequently are staying as PR without merge. You can see how amount of open PR increasing over time. Thanks, Alexey Diomin 2017-01-15 17:18 GMT+04:00 Ivan Mushketyk : > Hi Dmitry, > > Your contrib

Re: Slow duplicated tests

e, Jan 10, 2017 at 3:29 PM, Aljoscha Krettek > wrote: > >> Thanks for looking into this! I think we can put in the fix and remove one >> of the tests, yes. >> >> @Robert What do you think? I think you initially added this test a loooong >> while back. >&g

Slow duplicated tests

Hi, I am trying make small review for slow test and I found small issue: NonReusingReOpenableHashTableITCase testSpillingHashJoinWithMassiveCollisions testSpillingHashJoinWithTwoRecursions for testSpillingHashJoinWithTwoRecursions exist description /* * This test is basically identical to th

Re: time format for akka status

longrunning applications print hours without date very uninformative. What do you think? Thanks, Alexey 2017-01-09 17:25 GMT+04:00 Till Rohrmann : > Hi Alexey, > > this is a good proposal. Could you open a corresponding JIRA issue for this > change? > > Cheers, > Till >

Re: DataStream and CEP - Pattern not matching after applying a window

Hi Because flink use lazy evaluation and because inactivityCEP don't have any output then you pattern not apply. / inactivityCEP.select(new PatternSelectFunction() { @Override public Object select(Map pattern) throws Exception { System.out.println(pattern); return null; } }); / >> What am I mis

time format for akka status

Hi In ExecutionGraphMessages we have code private val DATE_FORMATTER: SimpleDateFormat = new SimpleDateFormat("MM/dd/ HH:mm:ss") But sometimes it cause confusion when main logger configured with "dd/MM/". What are you thinking about making this format configurable or maybe stay only HH