Re: 1.2-SNAPSHOT documentation

Hi Max, > On Dec 5, 2016, at 9:46am, Maximilian Michels wrote: > > The issue [1] has been resolved and I've rebuilt the snapshot version > of the docs. We're back to a nightly up-to-date documentation/JavaDoc. > > [1] https://issues.apache.org/jira/browse/FLINK-5262 Thanks for looking into thi

trouble using maven to deploy master branch to a private repo

Hello, At People Pattern we’ve been using flink 1.x releases in production since June 2016. We’re now at the point where we want to incorporate some of the bleeding edge features before official releases. I’ve forked flink from master, done a build on my local environment, then built flink-di

[jira] [Created] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

Ted Yu created FLINK-5282: - Summary: CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() Key: FLINK-5282 URL: https://issues.apache.org/jira/browse/FLINK-5282

[jira] [Created] (FLINK-5283) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState()

Ted Yu created FLINK-5283: - Summary: CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() Key: FLINK-5283 URL: https://issues.apache.org/jira/browse/FLINK-5283

[jira] [Created] (FLINK-5281) Extend KafkaJsonTableSources to support nested data

Fabian Hueske created FLINK-5281: Summary: Extend KafkaJsonTableSources to support nested data Key: FLINK-5281 URL: https://issues.apache.org/jira/browse/FLINK-5281 Project: Flink Issue Type:

[jira] [Created] (FLINK-5280) Extend TableSource to support nested data

Fabian Hueske created FLINK-5280: Summary: Extend TableSource to support nested data Key: FLINK-5280 URL: https://issues.apache.org/jira/browse/FLINK-5280 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator

Ufuk Celebi created FLINK-5279: -- Summary: Improve error message when trying to access keyed state in non-keyed operator Key: FLINK-5279 URL: https://issues.apache.org/jira/browse/FLINK-5279 Project: Flin

[jira] [Created] (FLINK-5278) Improve Task and checkpoint logging

Till Rohrmann created FLINK-5278: Summary: Improve Task and checkpoint logging Key: FLINK-5278 URL: https://issues.apache.org/jira/browse/FLINK-5278 Project: Flink Issue Type: Improvement

RE: [FLINK-4704 ] Move Table API to org.apache.flink.table

Hi, Timo PR created: https://github.com/apache/flink/pull/2958 Best regards, Anton Mushin -Original Message- From: Anton Mushin [mailto:anton_mus...@epam.com] Sent: Tuesday, December 06, 2016 6:30 PM To: dev@flink.apache.org Cc: Timo Walther Subject: RE: [FLINK-4704 ] Move Table API to

Re: Travis build broken on missing licenses

Thanks for being so honest. I think everyone has had a "faux pas" like this. Since our build process is quite complex, even seemingly trivial changes can break the master. I also learned it the hard way and always run tests on Travis. On Wed, Dec 7, 2016 at 3:17 PM, Greg Hogan wrote: > This was m

[jira] [Created] (FLINK-5277) missing unit test for ensuring ResultPartition#add always recycles buffers

Nico Kruber created FLINK-5277: -- Summary: missing unit test for ensuring ResultPartition#add always recycles buffers Key: FLINK-5277 URL: https://issues.apache.org/jira/browse/FLINK-5277 Project: Flink

Re: Travis build broken on missing licenses

This was my mistake. The commit only involved web assets so I had tested the runtime but had not run mvn verify. Also, I'm typically aware of the CI status (receiving the emails for my own pull requests) but had failed to note the failure of the license check on this PR. On Wed, Dec 7, 2016 at 4:5

[jira] [Created] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts

Ufuk Celebi created FLINK-5276: -- Summary: ExecutionVertex archiving can throw NPE with many previous attempts Key: FLINK-5276 URL: https://issues.apache.org/jira/browse/FLINK-5276 Project: Flink

[jira] [Created] (FLINK-5275) InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled

Ufuk Celebi created FLINK-5275: -- Summary: InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled Key: FLINK-5275 URL: https://issues.apache.org/jira/browse/FLINK-5275 P

[jira] [Created] (FLINK-5274) LocalInputChannel throws NPE if partition reader is released

Ufuk Celebi created FLINK-5274: -- Summary: LocalInputChannel throws NPE if partition reader is released Key: FLINK-5274 URL: https://issues.apache.org/jira/browse/FLINK-5274 Project: Flink Issue

Re: [DISCUSS] Schedule and Scope for Flink 1.2

> - UNRESOLVED Integrate Flink with Apache Mesos (FLINK-1984) The initial integration is already completed with the last issues being resolved in the Mesos component: https://issues.apache.org/jira/browse/FLINK/component/12331068/ The implementation will be further refined after the next release a

[jira] [Created] (FLINK-5273) Refactor stream SQL tests

Fabian Hueske created FLINK-5273: Summary: Refactor stream SQL tests Key: FLINK-5273 URL: https://issues.apache.org/jira/browse/FLINK-5273 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-5272) Refactor the stream Scala-expression Table API tests

Fabian Hueske created FLINK-5272: Summary: Refactor the stream Scala-expression Table API tests Key: FLINK-5272 URL: https://issues.apache.org/jira/browse/FLINK-5272 Project: Flink Issue Type

[jira] [Created] (FLINK-5271) Refactor the batch SQL tests

Fabian Hueske created FLINK-5271: Summary: Refactor the batch SQL tests Key: FLINK-5271 URL: https://issues.apache.org/jira/browse/FLINK-5271 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-5270) Refactor the batch Scala-expression Table API tests

Fabian Hueske created FLINK-5270: Summary: Refactor the batch Scala-expression Table API tests Key: FLINK-5270 URL: https://issues.apache.org/jira/browse/FLINK-5270 Project: Flink Issue Type:

[jira] [Created] (FLINK-5269) Convert string-based Table API tests into unit tests

Fabian Hueske created FLINK-5269: Summary: Convert string-based Table API tests into unit tests Key: FLINK-5269 URL: https://issues.apache.org/jira/browse/FLINK-5269 Project: Flink Issue Type

[jira] [Created] (FLINK-5268) Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase

Fabian Hueske created FLINK-5268: Summary: Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase Key: FLINK-5268 URL: https://issues.apache.org/jira/browse/FLINK-5268

Re: Travis build broken on missing licenses

Since the Rat plugin which fails the build runs in the first seconds of the build process, I wonder how that was not detected before merging the commit? :) On Wed, Dec 7, 2016 at 10:46 AM, Till Rohrmann wrote: > Thanks Marton. > > On Wed, Dec 7, 2016 at 8:24 AM, Fabian Hueske wrote: > >> Thanks

Re: Monitoring backpressure

Hello Alan, the backpressure information can be retrieved from the web ui's REST API . |/jobs//vertices//backpressure This will give you a JSON object that looks something like this: { | |status:"ok"|"d

Re: Travis build broken on missing licenses

Thanks Marton. On Wed, Dec 7, 2016 at 8:24 AM, Fabian Hueske wrote: > Thanks Marton! > > 2016-12-07 2:49 GMT+01:00 Márton Balassi : > > > Done, my Travis build came in all green: > > > > https://travis-ci.org/mbalassi/flink/builds/181809550 > > > > The hotfix is pushed. > > > > On Tue, Dec 6, 20