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 T
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
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
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
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 contributo
aitozi created FLINK-9579:
-
Summary: Remove unnecessary check with cep elementQueue
Key: FLINK-9579
URL: https://issues.apache.org/jira/browse/FLINK-9579
Project: Flink
Issue Type: Improvement
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 Ty
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
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
Comp
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
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
Iss
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
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 to
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 s
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 re
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
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 that
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
* cd
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
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, and
20 matches
Mail list logo
