This did the trick, thanks. I am able to run the streaming examples
after invalidating caches, restarting and rebuild project.
BTW I see a message that says 100 errors during compilation. Is that to
be expected?
Tara
On 2/26/16 4:02 AM, Till Rohrmann wrote:
I just tested executing a streami
/me likes this idea :)
On 29 February 2016 at 12:38, Stephan Ewen wrote:
> How about adding to "flink-gelly-examples" that it packages the examples in
> JAR files. We can then add them even to the "examples/gelly" folder in the
> binary distribution.
>
> On Mon, Feb 29, 2016 at 12:24 PM, Vasilik
Stephan Ewen created FLINK-3552:
---
Summary: Change socket WordCount to be properly windowed
Key: FLINK-3552
URL: https://issues.apache.org/jira/browse/FLINK-3552
Project: Flink
Issue Type: Sub-t
Stephan Ewen created FLINK-3551:
---
Summary: Sync Scala and Java Streaming Examples
Key: FLINK-3551
URL: https://issues.apache.org/jira/browse/FLINK-3551
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-3550:
---
Summary: Rework stream join example
Key: FLINK-3550
URL: https://issues.apache.org/jira/browse/FLINK-3550
Project: Flink
Issue Type: Sub-task
Compone
Stephan Ewen created FLINK-3549:
---
Summary: Make streaming examples more streaming
Key: FLINK-3549
URL: https://issues.apache.org/jira/browse/FLINK-3549
Project: Flink
Issue Type: Improvement
This vote has been cancelled in favor of a new RC.
I resolved the issue I've found in
https://issues.apache.org/jira/browse/FLINK-3540.
I'll now create the next RC.
On Mon, Feb 29, 2016 at 2:49 PM, Robert Metzger wrote:
> I think I have to cancel the vote, because the
> "flink-1.0.0-bin-hadoop
Aljoscha Krettek created FLINK-3548:
---
Summary: Remove unnecessary generic parameter from
SingleOutputStreamOperator
Key: FLINK-3548
URL: https://issues.apache.org/jira/browse/FLINK-3548
Project: Fli
Vasia Kalavri created FLINK-3547:
Summary: Add support for streaming projection, selection, and union
Key: FLINK-3547
URL: https://issues.apache.org/jira/browse/FLINK-3547
Project: Flink
Issu
Vasia Kalavri created FLINK-3546:
Summary: Streaming Table API
Key: FLINK-3546
URL: https://issues.apache.org/jira/browse/FLINK-3546
Project: Flink
Issue Type: New Feature
Component
Maximilian Michels created FLINK-3545:
-
Summary: ResourceManager: YARN integration
Key: FLINK-3545
URL: https://issues.apache.org/jira/browse/FLINK-3545
Project: Flink
Issue Type: Sub-tas
Maximilian Michels created FLINK-3544:
-
Summary: ResourceManager runtime components
Key: FLINK-3544
URL: https://issues.apache.org/jira/browse/FLINK-3544
Project: Flink
Issue Type: Sub-ta
Maximilian Michels created FLINK-3543:
-
Summary: Introduce ResourceManager component
Key: FLINK-3543
URL: https://issues.apache.org/jira/browse/FLINK-3543
Project: Flink
Issue Type: New F
Till Rohrmann created FLINK-3542:
Summary: FlinkKafkaConsumer09 cannot handle changing number of
partitions
Key: FLINK-3542
URL: https://issues.apache.org/jira/browse/FLINK-3542
Project: Flink
Till Rohrmann created FLINK-3541:
Summary: Clean up workaround in FlinkKafkaConsumer09
Key: FLINK-3541
URL: https://issues.apache.org/jira/browse/FLINK-3541
Project: Flink
Issue Type: Improv
Robert Metzger created FLINK-3540:
-
Summary: Hadoop 2.6.3 build contains /com/google/common (guava)
classes in flink-dist.jar
Key: FLINK-3540
URL: https://issues.apache.org/jira/browse/FLINK-3540
Proj
Ufuk Celebi created FLINK-3539:
--
Summary: Sync running Execution and Task instances via heartbeats
Key: FLINK-3539
URL: https://issues.apache.org/jira/browse/FLINK-3539
Project: Flink
Issue Type
Till Rohrmann created FLINK-3538:
Summary: DataStream join API does not enforce consistent usage
Key: FLINK-3538
URL: https://issues.apache.org/jira/browse/FLINK-3538
Project: Flink
Issue Typ
Fabian Hueske created FLINK-3537:
Summary: Faulty code generation for disjunctions
Key: FLINK-3537
URL: https://issues.apache.org/jira/browse/FLINK-3537
Project: Flink
Issue Type: Bug
I think I have to cancel the vote, because the
"flink-1.0.0-bin-hadoop26-scala_2.10.tgz" binary release contains unshaded
guava classes in lib/flink-dist.jar"
I'm currently investigating why only this version is affected.
Tested
- "mvn clean install" (without tests) from source package
- Build a
Till Rohrmann created FLINK-3536:
Summary: Make clearer distinction between event time and
processing time
Key: FLINK-3536
URL: https://issues.apache.org/jira/browse/FLINK-3536
Project: Flink
Ufuk Celebi created FLINK-3535:
--
Summary: Decrease logging verbosity of StackTraceSampleCoordinator
Key: FLINK-3535
URL: https://issues.apache.org/jira/browse/FLINK-3535
Project: Flink
Issue Typ
How about adding to "flink-gelly-examples" that it packages the examples in
JAR files. We can then add them even to the "examples/gelly" folder in the
binary distribution.
On Mon, Feb 29, 2016 at 12:24 PM, Vasiliki Kalavri <
vasilikikala...@gmail.com> wrote:
> In my opinion, the fat jar solution
Robert Metzger created FLINK-3534:
-
Summary: Cancelling a running job can lead to restart instead of
stopping
Key: FLINK-3534
URL: https://issues.apache.org/jira/browse/FLINK-3534
Project: Flink
Vasia Kalavri created FLINK-3533:
Summary: Update the Gelly docs wrt examples and cluster execution
Key: FLINK-3533
URL: https://issues.apache.org/jira/browse/FLINK-3533
Project: Flink
Issue
In my opinion, the fat jar solution is easier than having to copy the Gelly
jar to all task managers.
I would be in favor of including flink-gelly in the flink-examples module,
but we can also simply document the current behavior nicely.
-V.
On 29 February 2016 at 12:15, Till Rohrmann wrote:
>
Good catch :-) I mean we could also change the behaviour to include
flink-gelly in the flink-gelly-examples module.
On Mon, Feb 29, 2016 at 12:13 PM, Vasiliki Kalavri <
vasilikikala...@gmail.com> wrote:
> Thanks Till! Then, we'd better update the docs, too. Currently both links
> to examples and
Thanks Till! Then, we'd better update the docs, too. Currently both links
to examples and cluster execution instructions are broken.
I'll create an issue.
-V.
On 29 February 2016 at 11:54, Till Rohrmann wrote:
> Hi Vasia,
>
> that is because you're missing the flink-gelly dependency. If you jus
Till Rohrmann created FLINK-3532:
Summary: Flink-gelly-examples jar contains an underscore instead
of an hyphen
Key: FLINK-3532
URL: https://issues.apache.org/jira/browse/FLINK-3532
Project: Flink
Hi Vasia,
that is because you're missing the flink-gelly dependency. If you just
build flink-gelly-examples, then it won't contain flink-gelly because it is
not a fat jar. You either have to install flink-gelly on your cluster or
package it in the final user jar.
Cheers,
Till
On Sat, Feb 27, 201
Till Rohrmann created FLINK-3531:
Summary: KafkaShortRetention09ITCase.testAutoOffsetReset fails on
Travis
Key: FLINK-3531
URL: https://issues.apache.org/jira/browse/FLINK-3531
Project: Flink
Till Rohrmann created FLINK-3530:
Summary: Kafka09ITCase.testBigRecordJob fails on Travis
Key: FLINK-3530
URL: https://issues.apache.org/jira/browse/FLINK-3530
Project: Flink
Issue Type: Bug
32 matches
Mail list logo
