dengjie created FLINK-2742:
--
Summary: Flink Configuration URL Not Found
Key: FLINK-2742
URL: https://issues.apache.org/jira/browse/FLINK-2742
Project: Flink
Issue Type: Bug
Reporter: den
Thanks for the correctness, Stephan.
For the micro benchmark, I think it should be better to make a new maven
project inside Flink.
Thanks
Chengxiang
-Original Message-
From: ewenstep...@gmail.com [mailto:ewenstep...@gmail.com] On Behalf Of Stephan
Ewen
Sent: Tuesday, September 22, 20
Found more KafkaITCase failure at:
https://travis-ci.org/apache/flink/jobs/81592146
Failed tests:
KafkaITCase.testConcurrentProducerConsumerTopology:50->KafkaConsumerTestBase.runSimpleConcurrentProducerConsumerTopology:334->KafkaTestBase.tryExecute:313
Test failed: The program execution fail
Ufuk Celebi created FLINK-2741:
--
Summary: Use single log statement in TestLogger
Key: FLINK-2741
URL: https://issues.apache.org/jira/browse/FLINK-2741
Project: Flink
Issue Type: Improvement
I had a discussion with Joe from the NiFi community, and they are
interested in contributing a connector between NiFi and Flink. I created a
JIRA issue for that: https://issues.apache.org/jira/browse/FLINK-2740
I believe that this is the easiest and most useful integration point to
begin with, as
Kostas Tzoumas created FLINK-2740:
-
Summary: Create data consumer for Apache NiFi
Key: FLINK-2740
URL: https://issues.apache.org/jira/browse/FLINK-2740
Project: Flink
Issue Type: New Feature
Maximilian Michels created FLINK-2739:
-
Summary: Release script depends on the order of parent module
information
Key: FLINK-2739
URL: https://issues.apache.org/jira/browse/FLINK-2739
Project: Fli
I saw that now cascading supports Flink..so maybe you could think in
programming a cascading abstraction to have also spark and tez
compatibility for free!what do you think?
On 22 Sep 2015 11:17, "Christian Kreutzfeldt" wrote:
> Hi Slim,
>
> thanks for sharing the presentation. Like Flavio I see
Ufuk Celebi created FLINK-2738:
--
Summary: StackOverflow in case of unbounded restarts
Key: FLINK-2738
URL: https://issues.apache.org/jira/browse/FLINK-2738
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2736:
--
Summary: Failing KafkaConsumerTestBase.runCancelingOnEmptyInputTest
Key: FLINK-2736
URL: https://issues.apache.org/jira/browse/FLINK-2736
Project: Flink
Issue Ty
Stephan Ewen created FLINK-2737:
---
Summary: KeyedDataStream should not be a subclass of DataStream
Key: FLINK-2737
URL: https://issues.apache.org/jira/browse/FLINK-2737
Project: Flink
Issue Type
Robert Metzger created FLINK-2735:
-
Summary: KafkaProducerITCase.testCustomPartitioning sporadically
fails
Key: FLINK-2735
URL: https://issues.apache.org/jira/browse/FLINK-2735
Project: Flink
The Record type will probably stay, some people requested to keep it.
We only discourage its further use in examples and tests.
The Record-based API will definitely go...
On Tue, Sep 22, 2015 at 4:38 PM, Greg Hogan wrote:
> Is org.apache.flink.types.Record to be deprecated or just the Record A
Is org.apache.flink.types.Record to be deprecated or just the Record API?
There is no annotation on the type but FLINK-2479 requests that it not be
used.
Greg Hogan
Stephan Ewen created FLINK-2734:
---
Summary: ArrayKeySelector is wrong
Key: FLINK-2734
URL: https://issues.apache.org/jira/browse/FLINK-2734
Project: Flink
Issue Type: Bug
Components: S
Hi everybody,
I started creating the first release candidate for the 0.10-milestone-1
release.
I will send out a vote mail once all artifacts were created and uploaded.
Cheers,
Fabian
2015-09-11 15:06 GMT+02:00 Stephan Ewen :
> Sure that is fine with me you are the release manager ;-)
>
> I don
Robert Metzger created FLINK-2733:
-
Summary: ZooKeeperLeaderElectionTest.testZooKeeperReelection fails
Key: FLINK-2733
URL: https://issues.apache.org/jira/browse/FLINK-2733
Project: Flink
Iss
Stephan Ewen created FLINK-2732:
---
Summary: Add access to the TaskManagers' log file and out file in
the web dashboard.
Key: FLINK-2732
URL: https://issues.apache.org/jira/browse/FLINK-2732
Project: Flin
Stephan Ewen created FLINK-2731:
---
Summary: Add JobManager log file access
Key: FLINK-2731
URL: https://issues.apache.org/jira/browse/FLINK-2731
Project: Flink
Issue Type: Sub-task
Com
Stephan Ewen created FLINK-2730:
---
Summary: Add CPU/Network utilization graphs to new web dashboard
Key: FLINK-2730
URL: https://issues.apache.org/jira/browse/FLINK-2730
Project: Flink
Issue Typ
Stephan Ewen created FLINK-2729:
---
Summary: Add TaskManager overview
Key: FLINK-2729
URL: https://issues.apache.org/jira/browse/FLINK-2729
Project: Flink
Issue Type: Sub-task
Component
Stephan Ewen created FLINK-2728:
---
Summary: Add missing features to new web dashboard
Key: FLINK-2728
URL: https://issues.apache.org/jira/browse/FLINK-2728
Project: Flink
Issue Type: New Feature
Sounds like a nice idea!
Do you want to make this a new maven project as part of the Flink
repository, or create a dedicated repository for that?
BTW: We are currently not mixing microbenchmarks with test execution. The
code for these benchmarks resides in the test scope of the projects (so it
is
Stephan Ewen created FLINK-2727:
---
Summary: Add a base class for MessageQueue-with-acknowledgement
sources
Key: FLINK-2727
URL: https://issues.apache.org/jira/browse/FLINK-2727
Project: Flink
I
Till Rohrmann created FLINK-2726:
Summary: Harmonise Yarn configuration methods to use a single
configuration for all components
Key: FLINK-2726
URL: https://issues.apache.org/jira/browse/FLINK-2726
P
Hi, folks
During work on Flink, I found several micro benchmarks which come from
different modules, these benchmarks measure on manual, annotated with Junit
annotations, so they got executed during unit test as well. There are some
shortage on current implementation:
1. Benchmark test per
Hi Slim,
thanks for sharing the presentation. Like Flavio I see the (UI)
capabilities provided by Apache NiFi as very helpful for (enterprise)
customers.
At the Otto Group we are currently think about how to track data through a
stream based system like we do in the batch world using staging laye
27 matches
Mail list logo
