[jira] [Created] (FLINK-9583) Wrong number of TaskManagers' slots after recovery.

2018-06-13 Thread Truong Duc Kien (JIRA)
Truong Duc Kien created FLINK-9583: -- Summary: Wrong number of TaskManagers' slots after recovery. Key: FLINK-9583 URL: https://issues.apache.org/jira/browse/FLINK-9583 Project: Flink Issue

[jira] [Created] (FLINK-9582) dist assemblies access files outside of flink-dist

2018-06-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9582: --- Summary: dist assemblies access files outside of flink-dist Key: FLINK-9582 URL: https://issues.apache.org/jira/browse/FLINK-9582 Project: Flink Issue

[jira] [Created] (FLINK-9581) Redundant spaces for Collect at sql.md

2018-06-13 Thread Sergey Nuyanzin (JIRA)
Sergey Nuyanzin created FLINK-9581: -- Summary: Redundant spaces for Collect at sql.md Key: FLINK-9581 URL: https://issues.apache.org/jira/browse/FLINK-9581 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse

2018-06-13 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9580: - Summary: Potentially unclosed ByteBufInputStream in RestClient#readRawResponse Key: FLINK-9580 URL: https://issues.apache.org/jira/browse/FLINK-9580 Project: Flink Issue

Re: WELCOME to dev@flink.apache.org

2018-06-13 Thread Sandish Kumar HN
Hi Tzu-Li, Yes I have JIRA task here it is https://issues.apache.org/jira/browser/FLINK-9548 And account details sanysand...@gmail.com Name: Sandish Kumar HN On Wed, Jun 13, 2018 at 2:32 AM Tzu-Li (Gordon) Tai wrote: > Hi Sandish, > > Welcome to the Flink community! > > Do you mean

[jira] [Created] (FLINK-9578) Allow to define an auto watermark interval in SQL Client

2018-06-13 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9578: --- Summary: Allow to define an auto watermark interval in SQL Client Key: FLINK-9578 URL: https://issues.apache.org/jira/browse/FLINK-9578 Project: Flink Issue

[jira] [Created] (FLINK-9576) Wrong contiguity documentation

2018-06-13 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9576: --- Summary: Wrong contiguity documentation Key: FLINK-9576 URL: https://issues.apache.org/jira/browse/FLINK-9576 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9577) Divide-by-zero in PageRank

2018-06-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9577: --- Summary: Divide-by-zero in PageRank Key: FLINK-9577 URL: https://issues.apache.org/jira/browse/FLINK-9577 Project: Flink Issue Type: Bug

Re: Static code analysis for Flink project

2018-06-13 Thread Chesnay Schepler
We will need a significant amount of exclusions/suppressions. For example, 300 of the 511 vulnerabilities are caused by our TupleX classes, with public mutable fields. The "unclosed resource" inspection is rather simplistic and only tracks the life-cycle in the scope of the method. As a result

[jira] [Created] (FLINK-9575) Potential race condition when removing JobGraph in HA

2018-06-13 Thread JIRA
Dominik Wosiński created FLINK-9575: --- Summary: Potential race condition when removing JobGraph in HA Key: FLINK-9575 URL: https://issues.apache.org/jira/browse/FLINK-9575 Project: Flink

[jira] [Created] (FLINK-9574) Add a dedicated documentation page for state evolution

2018-06-13 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-9574: -- Summary: Add a dedicated documentation page for state evolution Key: FLINK-9574 URL: https://issues.apache.org/jira/browse/FLINK-9574 Project: Flink

Re: [DISCUSS] Long-term goal of making flink-table Scala-free

2018-06-13 Thread Piotr Nowojski
Hi, I do not have an experience with how scala and java interacts with each other, so I can not fully validate your proposal, but generally speaking +1 from me. Does it also mean, that we should slowly migrate `flink-table-core` to Java? How would you envision it? It would be nice to be able

Re: Static code analysis for Flink project

2018-06-13 Thread Piotr Nowojski
Hi, Generally speaking I would be in favour of adding some reasonable static code analysis, however this requires a lot of effort and can not be done at once. Also if such checks are firing incorrectly too often it would be annoying to manually suppress such warnings/errors. > I don't really

Re: [TABLE][SQL] Unify UniqueKeyExtractor and DataStreamRetractionRules

2018-06-13 Thread Piotr Nowojski
Hi, Maybe this boils down to how do we envision plan modifications, after setting up initial upserts/retraction modes/traits. If we do some plan rewrite afterwards, do we want to relay on our current dynamic rules to “fix it”? Do we want to rerun DataStreamRetractionRules shuttle again after

[DISCUSS] Long-term goal of making flink-table Scala-free

2018-06-13 Thread Timo Walther
Hi everyone, as you all know, currently the Table & SQL API is implemented in Scala. This decision was made a long-time ago when the initital code base was created as part of a master's thesis. The community kept Scala because of the nice language features that enable a fluent Table API like

Re: Static code analysis for Flink project

2018-06-13 Thread Chesnay Schepler
I don't really see a benefit in enabling it /continuously/. This wouldn't be part of the build or CI processes, as we can't fail the builds since it happens too often that issues are improperly categorized. Wading through these lists is time-consuming and I very much doubt that we will do

Re: how to build the connectors and examples from the source

2018-06-13 Thread Chesnay Schepler
You can build specific connector/examples by going into the the respective directory and executing mvn clean package -DskipTests. Connector: * cd flink-connectors * cd * mvn clean package -DskipTests * cd target * pick jar Example: * cd flink-examples * cd * mvn clean package -DskipTests *

Re: Static code analysis for Flink project

2018-06-13 Thread Till Rohrmann
Hi Alex, thanks for bringing this topic up. So far the Flink project does not use a static code analysis tool but I think it can strongly benefit from it (simply by looking at the reported bugs). There was a previous discussion about enabling the ASF Sonarcube integration for Flink [1] but it was

Re: WELCOME to dev@flink.apache.org

2018-06-13 Thread Tzu-Li (Gordon) Tai
Hi Sandish, Welcome to the Flink community! Do you mean contributor permissions on JIRA? The community usually only assigns contributor permissions when you find a specific JIRA ticket you would like to start working on. Once you do find one, let us know your JIRA account ID and the ticket,