Ted Yu created FLINK-4437:
-
Summary: Lock evasion around lastTriggeredCheckpoint may lead to
lost updates to related fields
Key: FLINK-4437
URL: https://issues.apache.org/jira/browse/FLINK-4437
Project: Flink
Ted Yu created FLINK-4436:
-
Summary: Unclosed DataOutputBuffer in Utils#setTokensFor()
Key: FLINK-4436
URL: https://issues.apache.org/jira/browse/FLINK-4436
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4435:
---
Summary: Replace Guava's VisibleForTesting annotation with Flink's
annotation
Key: FLINK-4435
URL: https://issues.apache.org/jira/browse/FLINK-4435
Project: Flink
Hello,
I would say no, as the general reception of the Python API was
*tumbleweed* so far.
In my opinion this would just lead to a massive increase in code to
maintain; we would need at least 2-3 active long-term python contributors.
Especially so since ML, CEP and Table are afaik still in h
Stephan Ewen created FLINK-4434:
---
Summary: Add a testing RPC service
Key: FLINK-4434
URL: https://issues.apache.org/jira/browse/FLINK-4434
Project: Flink
Issue Type: Sub-task
Componen
Hi Flink developers,
It seems to me that Flink has two important "selling points":
1. It has Java, Scala and Python APIs
2. I has a number of useful libraries (ML, Gelly, CEP, and Table)
But as far as I understand, currently users cannot use any of these
libraries using a Python API. It seems to
Fabian, Till,
thanks for your comments!
I`ve raised https://issues.apache.org/jira/browse/INFRA-12458 for the same.
Will play around to see if this solution acceptable and does not affect
build duration too much.
2016-08-19 12:51 GMT+03:00 Till Rohrmann :
> Hi Pavel,
>
> I think it's a good poin
Kostas Kloudas created FLINK-4433:
-
Summary: Refactor the StreamSource.
Key: FLINK-4433
URL: https://issues.apache.org/jira/browse/FLINK-4433
Project: Flink
Issue Type: Bug
Report
+1 A great proposal.
I'd like to suggest one change. In one paragraph you say "If no savepoint
path is configured, fail the savepoint.". I think this is
problematic because it means that users who forgot to add the setting to
the config will be at a dead if they want to update. Can we make it work
Hi Ufuk,
Great initiative in general I agree with pretty much everything in the
proposal.
Some minor comments:
With these changes savepoints and checkpoints become pretty much the same
thing so we might as well drop one of the concepts and just refer to
checkpoints as savepoints that are discarde
Hey devs! I've created a FLIP to unify savepoints and checkpoints:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-10%3A+Unify+Checkpoints+and+Savepoints#
Looking forward to your feedback.
– Ufuk
Robert Metzger created FLINK-4432:
-
Summary: (YARN) JobManager web port is no longer available in
configuration page in web interface
Key: FLINK-4432
URL: https://issues.apache.org/jira/browse/FLINK-4432
Sure, I've filed a JIRA: https://issues.apache.org/jira/browse/INFRA-12456
On Thu, Aug 18, 2016 at 10:57 AM, Stephan Ewen wrote:
> @max - can you contact infra about that?
>
> On Thu, Aug 18, 2016 at 10:25 AM, Maximilian Michels wrote:
>
>> Actually that is a good suggestion. I know from other A
I second Aljoscha :-)
On Fri, Aug 19, 2016 at 11:53 AM, Aljoscha Krettek
wrote:
> I checked it out and I liked it. :-)
>
> On Thu, 18 Aug 2016 at 19:40 Ufuk Celebi wrote:
>
> > Initial PR for the layout: https://github.com/apache/flink/pull/2387
> >
> > On Tue, Aug 2, 2016 at 5:18 PM, Aljoscha
Stephan Ewen created FLINK-4431:
---
Summary: Introduce a "VisibleForTesting" annotation
Key: FLINK-4431
URL: https://issues.apache.org/jira/browse/FLINK-4431
Project: Flink
Issue Type: Improvemen
+1
On 17-Aug-2016 8:54 PM, "Robert Metzger" wrote:
> Hi,
>
> following the discussions in [1], the community decided to offer
> contributors to submit streaming connectors the Flink community can not
> maintain to Apache Bahir (there is still the option that we are moving
> popular connectors to
I checked it out and I liked it. :-)
On Thu, 18 Aug 2016 at 19:40 Ufuk Celebi wrote:
> Initial PR for the layout: https://github.com/apache/flink/pull/2387
>
> On Tue, Aug 2, 2016 at 5:18 PM, Aljoscha Krettek
> wrote:
> > +1
> >
> > On Tue, 2 Aug 2016 at 03:15 Till Rohrmann wrote:
> >
> >> +1
Hi Pavel,
I think it's a good point you're raising here. The Flink community isn't
using metrics like test coverage to ensure high quality code yet. I think
that is one thing which we can/should improve. Unfortunately, the ASF does
not allow to use codecov.io (or at least the Apache Infra team) [1
Hi Pavel,
the Cobertura plugin was removed in this PR:
https://github.com/apache/flink/pull/454
Not sure if it was accidentally removed or on purpose.
It was not included in the regular builds to reduce build time and AFAIK,
it wasn't manually used either (otherwise somebody would have noticed tha
Hi Jark,
thanks for starting this discussion. Actually, I think we are rather
"blocked" on the internal handling of streaming windows in Calcite than the
SQL parser. IMO, it should be possible to exchange or modify the parser if
we want that.
Regarding Calcite's StreamSQL syntax: Except for the S
Kurt Young created FLINK-4430:
-
Summary: prevent BLOCKING partition data lose when task is finished
Key: FLINK-4430
URL: https://issues.apache.org/jira/browse/FLINK-4430
Project: Flink
Issue Type
Robert Metzger created FLINK-4429:
-
Summary: Move Redis Sink from Flink to Bahir
Key: FLINK-4429
URL: https://issues.apache.org/jira/browse/FLINK-4429
Project: Flink
Issue Type: Task
22 matches
Mail list logo
