Re: [FLINK-305] Code test coverage - how FLINK using it?

2016-08-24 Thread Pavel Fadeev
Hi Maximilian, absolutely make sense! Just filed https://issues.apache.org/jira/browse/FLINK-4483 for the same. More than happy to go ahead as an assignee there, but not authorized for this kind of action atm) 2016-08-24 13:32 GMT+03:00 Maximilian Michels : > Hi Pavel! > > Thanks for looking int

[jira] [Created] (FLINK-4483) Complete test coverage integration

2016-08-24 Thread Pavel Fadeev (JIRA)
Pavel Fadeev created FLINK-4483: --- Summary: Complete test coverage integration Key: FLINK-4483 URL: https://issues.apache.org/jira/browse/FLINK-4483 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock

2016-08-24 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4482: - Summary: numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock Key: FLINK-4482 URL: https://issues.apache.org/jira/browse/FLINK-4482 Project: Flink I

[jira] [Created] (FLINK-4481) Maximum results for pairwise algorithms

2016-08-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4481: - Summary: Maximum results for pairwise algorithms Key: FLINK-4481 URL: https://issues.apache.org/jira/browse/FLINK-4481 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4480) Incorrect link to elastic.co in documentation

2016-08-24 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-4480: Summary: Incorrect link to elastic.co in documentation Key: FLINK-4480 URL: https://issues.apache.org/jira/browse/FLINK-4480 Project: Flink Issue Type: Bug

Re: Additional project downloads

2016-08-24 Thread Till Rohrmann
I agree that it would be good to offer these kind of convenience download links. On Wed, Aug 24, 2016 at 5:25 PM, Robert Metzger wrote: > Maybe we should put a link to maven central. We could parameterize the link > so that it always links to the current release linked on our downloads > page. >

Re: Additional project downloads

2016-08-24 Thread Robert Metzger
Maybe we should put a link to maven central. We could parameterize the link so that it always links to the current release linked on our downloads page. On Wed, Aug 24, 2016 at 5:04 PM, Greg Hogan wrote: > Hi, > > Should Flink add-ons such as CEP, Gelly, ML, and the optional Metrics > Reporters

[jira] [Created] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website

2016-08-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4479: - Summary: Replace trademark (tm) with registered trademark (R) sign on Flink website Key: FLINK-4479 URL: https://issues.apache.org/jira/browse/FLINK-4479 Project: F

Additional project downloads

2016-08-24 Thread Greg Hogan
Hi, Should Flink add-ons such as CEP, Gelly, ML, and the optional Metrics Reporters be available from the download page? Is the alternative to direct users to Maven Central? Greg

[jira] [Created] (FLINK-4478) Implement heartbeat logic

2016-08-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4478: Summary: Implement heartbeat logic Key: FLINK-4478 URL: https://issues.apache.org/jira/browse/FLINK-4478 Project: Flink Issue Type: Improvement Com

Re: [DISCUSS] Releasing Flink 1.1.2

2016-08-24 Thread Maximilian Michels
+1 for a 1.1.2 release soon. I think we should have the fixes in by the beginning of next week. Otherwise, further fixes could also make it into 1.1.3. On Wed, Aug 24, 2016 at 12:32 PM, Gyula Fóra wrote: > Hi, > > I agree that there has been some critical issues discovered and it would be > to

Re: [FLINK-305] Code test coverage - how FLINK using it?

2016-08-24 Thread Maximilian Michels
Hi Pavel! Thanks for looking into code coverage! Now that Infra enabled access to coveralls, could you open a Flink issue to address the next steps to display coverage data? Cheers, Max On Mon, Aug 22, 2016 at 11:38 AM, Till Rohrmann wrote: > Thanks a lot for your help with that Pavel :-) > > O

Re: [DISCUSS] Releasing Flink 1.1.2

2016-08-24 Thread Gyula Fóra
Hi, I agree that there has been some critical issues discovered and it would be to get the fixes out as soon as possible :) On my side I would like to add the fixes for: FLINK-4441 FLINK-4471 Both can be critical for applications that use the RocksDB backend. Gyula Ufuk Celebi ezt írta (időpo

Re: [DISCUSS] Releasing Flink 1.1.2

2016-08-24 Thread Tzu-Li (Gordon) Tai
Hi Ufuk, Thanks for bringing up the discussion. There’s also a critical issue with the Kinesis connector when used with window operators downstream: https://issues.apache.org/jira/browse/FLINK-4341. This leads to unbounded state size for the window operators. I’m trying to submit the fix PR befo

[DISCUSS] Releasing Flink 1.1.2

2016-08-24 Thread Ufuk Celebi
It's been ~2 weeks since we released Flink 1.1.1 and I wanted to start discussing releasing Flink 1.1.2. There have been 27 commits in the release-1.1 branch since the release, including at least one critical issue: [FLINK-4332] [checkpoints] Fix SavepointV1Serializer read() / readFully() (2 week

Re: [DISCUSS] FLIP-3 - Organization of Documentation

2016-08-24 Thread Ufuk Celebi
Merged to master :-) Furthermore, updated JIRA with sub tasks for the missing content: https://issues.apache.org/jira/browse/FLINK-4463 On Mon, Aug 22, 2016 at 4:10 PM, Maximilian Michels wrote: > Very nice work Ufuk! > > On Fri, Aug 19, 2016 at 12:07 PM, Till Rohrmann wrote: >> I second Aljos

[jira] [Created] (FLINK-4477) Add and consolidate existing docs about data types

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4477: -- Summary: Add and consolidate existing docs about data types Key: FLINK-4477 URL: https://issues.apache.org/jira/browse/FLINK-4477 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-4476) Add docs about Tuning

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4476: -- Summary: Add docs about Tuning Key: FLINK-4476 URL: https://issues.apache.org/jira/browse/FLINK-4476 Project: Flink Issue Type: Sub-task Components: Do

[jira] [Created] (FLINK-4475) Add docs about Debugging

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4475: -- Summary: Add docs about Debugging Key: FLINK-4475 URL: https://issues.apache.org/jira/browse/FLINK-4475 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-4474) Add docs about Testing & Test Utilities

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4474: -- Summary: Add docs about Testing & Test Utilities Key: FLINK-4474 URL: https://issues.apache.org/jira/browse/FLINK-4474 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4473) Add docs about end-to-end exactly once latency

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4473: -- Summary: Add docs about end-to-end exactly once latency Key: FLINK-4473 URL: https://issues.apache.org/jira/browse/FLINK-4473 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4471) Rocks backend fully async snapshot restore fails with custom serializers

2016-08-24 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-4471: - Summary: Rocks backend fully async snapshot restore fails with custom serializers Key: FLINK-4471 URL: https://issues.apache.org/jira/browse/FLINK-4471 Project: Flink

[jira] [Created] (FLINK-4472) Add docs about Security

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4472: -- Summary: Add docs about Security Key: FLINK-4472 URL: https://issues.apache.org/jira/browse/FLINK-4472 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-4470) Add docs about Failure and Recovery Model

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4470: -- Summary: Add docs about Failure and Recovery Model Key: FLINK-4470 URL: https://issues.apache.org/jira/browse/FLINK-4470 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-08-24 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4469: -- Summary: Add support for user defined table function in Table API & SQL Key: FLINK-4469 URL: https://issues.apache.org/jira/browse/FLINK-4469 Project: Flink Issue Type:

[jira] [Created] (FLINK-4468) Add documentation about processing semantics

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4468: -- Summary: Add documentation about processing semantics Key: FLINK-4468 URL: https://issues.apache.org/jira/browse/FLINK-4468 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4466) Add a metric availability test.

2016-08-24 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4466: --- Summary: Add a metric availability test. Key: FLINK-4466 URL: https://issues.apache.org/jira/browse/FLINK-4466 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4467) Add docs about project structure

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4467: -- Summary: Add docs about project structure Key: FLINK-4467 URL: https://issues.apache.org/jira/browse/FLINK-4467 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-4465) Add docs about system architecture

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4465: -- Summary: Add docs about system architecture Key: FLINK-4465 URL: https://issues.apache.org/jira/browse/FLINK-4465 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-4464) Add docs about version upgrades

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4464: -- Summary: Add docs about version upgrades Key: FLINK-4464 URL: https://issues.apache.org/jira/browse/FLINK-4464 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-4463) FLIP-3: Restructure Documentation

2016-08-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4463: -- Summary: FLIP-3: Restructure Documentation Key: FLINK-4463 URL: https://issues.apache.org/jira/browse/FLINK-4463 Project: Flink Issue Type: Improvement

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

2016-08-24 Thread Fabian Hueske
Starting with a prototype would be great, Jark. We had some trouble with Calcite's StreamableTable interface anyways. A few things can be simplified if we do not declare our tables as streamable. I would try to implement DataStreamTable (and all related classes and methods) equivalent to DataSetTab

[jira] [Created] (FLINK-4462) Add RUN_TIME retention policy for all the flink annotations

2016-08-24 Thread ramkrishna.s.vasudevan (JIRA)
ramkrishna.s.vasudevan created FLINK-4462: - Summary: Add RUN_TIME retention policy for all the flink annotations Key: FLINK-4462 URL: https://issues.apache.org/jira/browse/FLINK-4462 Project:

[jira] [Created] (FLINK-4461) Ensure all the classes are tagged with suitable annotations

2016-08-24 Thread ramkrishna.s.vasudevan (JIRA)
ramkrishna.s.vasudevan created FLINK-4461: - Summary: Ensure all the classes are tagged with suitable annotations Key: FLINK-4461 URL: https://issues.apache.org/jira/browse/FLINK-4461 Project: