Re: [DISCUSS] Releasing Flink 1.1.2

2016-08-30 Thread Robert Metzger
I'll create a release candidate now. On Mon, Aug 29, 2016 at 11:51 AM, Robert Metzger wrote: > Gordon fixed the Kinesis consumer already over the weekend. I just merged > the change. > > I'll push a hotfix for the jodatime+quickstart issue to both branches. > > On Fri, Aug 26, 2016 at 6:35 PM, T

Re: [DISCUSS] Some thoughts about unify Stream SQL and Batch SQL grammer

2016-08-30 Thread Timo Walther
Sorry, I thought that StreamTableSourceScanRule always fires but it is only used in StreamTableEnvironment so everything is fine. I think you can open PR if you like. Timo Am 30/08/16 um 05:25 schrieb Jark Wu: It seems that we have done that (?). The BatchTableEnvironment.registerTableSourc

[HEADS-UP] Dev Week 35

2016-08-30 Thread Aljoscha Krettek
Hi Folks, first off, sorry for forgetting about this last week, but here goes the update for this week: - Stefan and I are still working on making https://issues.apache.org/jira/browse/FLINK-3755 a reality. This time we're confident that we're merging it either today or tomorrow. For the rest of

[jira] [Created] (FLINK-4532) Allow independent metrics reporter for tasks

2016-08-30 Thread Renkai Ge (JIRA)
Renkai Ge created FLINK-4532: Summary: Allow independent metrics reporter for tasks Key: FLINK-4532 URL: https://issues.apache.org/jira/browse/FLINK-4532 Project: Flink Issue Type: Improvement

ApacheCon Seville CFP closes September 9th

2016-08-30 Thread Rich Bowen
It's traditional. We wait for the last minute to get our talk proposals in for conferences. Well, the last minute has arrived. The CFP for ApacheCon Seville closes on September 9th, which is less than 2 weeks away. It's time to get your talks in, so that we can make this the best ApacheCon yet. I

[jira] [Created] (FLINK-4533) Unprotected access to meters in StatsDReporter#report()

2016-08-30 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4533: - Summary: Unprotected access to meters in StatsDReporter#report() Key: FLINK-4533 URL: https://issues.apache.org/jira/browse/FLINK-4533 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() w.r.t. state.bucketStates

2016-08-30 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4534: - Summary: Lack of synchronization in BucketingSink#restoreState() w.r.t. state.bucketStates Key: FLINK-4534 URL: https://issues.apache.org/jira/browse/FLINK-4534 Project: Flink

[VOTE] Release Apache Flink 1.1.2 (RC1)

2016-08-30 Thread Robert Metzger
Dear Flink community, Please vote on releasing the following candidate as Apache Flink version 1.1.2. The commit to be voted on: f42f0c69 (http://git-wip-us.apache.org/repos/asf/flink/commit/f42f0c69) The release artifacts to be voted on can be found at: *http://people.apache.org/~rmetzger/flin

Streaming - memory management

2016-08-30 Thread Roshan Naik
As per the docs, in Batch mode, dynamic memory allocation is avoided by storing messages being processed in ByteBuffers via Unsafe methods. Couldn't find any docs describing mem mgmt in Streamingn mode. So... - Am wondering if this is also the case with Streaming ? - If so, how does Flink dete

[jira] [Created] (FLINK-4535) ResourceManager process registration from TaskExecutor

2016-08-30 Thread zhangjing (JIRA)
zhangjing created FLINK-4535: Summary: ResourceManager process registration from TaskExecutor Key: FLINK-4535 URL: https://issues.apache.org/jira/browse/FLINK-4535 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-4536) Possible thread leak in Task Manager

2016-08-30 Thread Scott Kidder (JIRA)
Scott Kidder created FLINK-4536: --- Summary: Possible thread leak in Task Manager Key: FLINK-4536 URL: https://issues.apache.org/jira/browse/FLINK-4536 Project: Flink Issue Type: Bug Co