[jira] [Created] (FLINK-6516) using real row count instead of dummy row count when optimizing plan

godfrey he created FLINK-6516: - Summary: using real row count instead of dummy row count when optimizing plan Key: FLINK-6516 URL: https://issues.apache.org/jira/browse/FLINK-6516 Project: Flink

[jira] [Created] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

Aljoscha Krettek created FLINK-6515: --- Summary: KafkaConsumer checkpointing fails because of ClassLoader issues Key: FLINK-6515 URL: https://issues.apache.org/jira/browse/FLINK-6515 Project: Flink

[jira] [Created] (FLINK-6514) Cannot start Flink Cluster in standalone mode

Aljoscha Krettek created FLINK-6514: --- Summary: Cannot start Flink Cluster in standalone mode Key: FLINK-6514 URL: https://issues.apache.org/jira/browse/FLINK-6514 Project: Flink Issue

[jira] [Created] (FLINK-6513) various typos and grammatical flaws

David Anderson created FLINK-6513: - Summary: various typos and grammatical flaws Key: FLINK-6513 URL: https://issues.apache.org/jira/browse/FLINK-6513 Project: Flink Issue Type: Improvement

Re: interested in volunteering at Flink ML/Stream ML Project

Thanks Gordon! Will do! On Tue, May 9, 2017 at 3:57 PM, Tzu-Li (Gordon) Tai wrote: > Hi Alex, > > I would start searching in the Flink JIRA for tickets tagged with the > component “Machine Learning Library”, and once you find a ticket you’ll > like to work on, ask for the

Re: interested in volunteering at Flink ML/Stream ML Project

Hi Alex, I would start searching in the Flink JIRA for tickets tagged with the component “Machine Learning Library”, and once you find a ticket you’ll like to work on, ask for the JIRA to be assigned to you on the mailing lists. From then on you can also assign any other tasks you’ll like to

[jira] [Created] (FLINK-6512) some code examples are poorly formatted

David Anderson created FLINK-6512: - Summary: some code examples are poorly formatted Key: FLINK-6512 URL: https://issues.apache.org/jira/browse/FLINK-6512 Project: Flink Issue Type:

[jira] [Created] (FLINK-6511) JobClient does not properly clean up BlobCache resources

Till Rohrmann created FLINK-6511: Summary: JobClient does not properly clean up BlobCache resources Key: FLINK-6511 URL: https://issues.apache.org/jira/browse/FLINK-6511 Project: Flink Issue

interested in volunteering at Flink ML/Stream ML Project

Hi there, I wanted to ask how I could start contributing to the Flink ML project/Stream ML project, and how I could ask for a ticket assignment? Many thanks, Alex

Re: [DISCUSS] Release 1.3.0 RC0 (Non voting, testing release candidate)

I looked into AppVeyor and managed to create a working setup that replicates the problems i encounter locally. https://ci.appveyor.com/project/zentol/flink/build/1.0.12 The integration should be as simple as placing an appveyor.yml (similar to the travis.yml) into the repository and asking

[jira] [Created] (FLINK-6510) Add CI integration for Windows

Chesnay Schepler created FLINK-6510: --- Summary: Add CI integration for Windows Key: FLINK-6510 URL: https://issues.apache.org/jira/browse/FLINK-6510 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6509) TestingListener might miss JobLeader notifications

Till Rohrmann created FLINK-6509: Summary: TestingListener might miss JobLeader notifications Key: FLINK-6509 URL: https://issues.apache.org/jira/browse/FLINK-6509 Project: Flink Issue Type:

[jira] [Created] (FLINK-6508) Include license files of packaged dependencies

Fabian Hueske created FLINK-6508: Summary: Include license files of packaged dependencies Key: FLINK-6508 URL: https://issues.apache.org/jira/browse/FLINK-6508 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6507) Potential bug in ContinuousFileProcessing

Stefan Richter created FLINK-6507: - Summary: Potential bug in ContinuousFileProcessing Key: FLINK-6507 URL: https://issues.apache.org/jira/browse/FLINK-6507 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6506) Some tests in flink-tests exceed memory the resources in containerized Travis builds

Stefan Richter created FLINK-6506: - Summary: Some tests in flink-tests exceed memory the resources in containerized Travis builds Key: FLINK-6506 URL: https://issues.apache.org/jira/browse/FLINK-6506

[jira] [Created] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

Stefan Richter created FLINK-6505: - Summary: Proactively cleanup local FS for RocksDBKeyedStateBackend on startup Key: FLINK-6505 URL: https://issues.apache.org/jira/browse/FLINK-6505 Project: Flink

[jira] [Created] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery

Tzu-Li (Gordon) Tai created FLINK-6503: -- Summary: Refactor KinesisDataFetcher to separate concerns for shard discovery Key: FLINK-6503 URL: https://issues.apache.org/jira/browse/FLINK-6503

Re: [DISCUSS] Release 1.3.0 RC0 (Non voting, testing release candidate)

Chesnay, I would propose to look into a CI solution for Windows. I'll try out appveyor.com for my Flink fork and report back how well it works (let me know if you want to look into it). On Tue, May 9, 2017 at 10:05 AM, Stephan Ewen wrote: > @Renjie What functionality are you

Re: [DISCUSS] Release 1.3.0 RC0 (Non voting, testing release candidate)

I'm just looking forward basic functionalities, e.g. a single web port for all flink jobs. On Tue, May 9, 2017 at 4:05 PM Stephan Ewen wrote: > @Renjie What functionality are you looking for? Most stuff should work in > the normal master branch. > > > On Tue, May 9, 2017 at

Re: [DISCUSS] Release 1.3.0 RC0 (Non voting, testing release candidate)

@Renjie What functionality are you looking for? Most stuff should work in the normal master branch. On Tue, May 9, 2017 at 10:02 AM, Renjie Liu wrote: > Stephan: > This means that we can use FLIP 6 for basic functionality now? Any > document for setting up that? Will

Re: [DISCUSS] Release 1.3.0 RC0 (Non voting, testing release candidate)

Stephan: This means that we can use FLIP 6 for basic functionality now? Any document for setting up that? Will FLIP 6 be finished in release 1.3? On Tue, May 9, 2017 at 3:43 PM Stephan Ewen wrote: > @Renjie Liu: A good part of the FLIP-6 code is in there, but not all. > > It

Re: [DISCUSS] Release 1.3.0 RC0 (Non voting, testing release candidate)

This RC (and 1.4-SNAPSHOT for that matter) cannot be compiled on Windows due to the rat-plugin not detecting certain test savepoints as binary files. The files in question are the "savepoints" created by the StreamOperatorTestHarness. This is not a new problem and has happened before, but we

Re: [DISCUSS] Release 1.3.0 RC0 (Non voting, testing release candidate)

@Renjie Liu: A good part of the FLIP-6 code is in there, but not all. It does run well on Yarn, Mesos, Docker, etc. We need to finish the FLIP-6 work mainly for full elasticity. On Tue, May 9, 2017 at 5:24 AM, Renjie Liu wrote: > Hi, does this include the FLIP6? > >

[jira] [Created] (FLINK-6502) Support writing data in DataSet to ElasticSearch

wyp created FLINK-6502: -- Summary: Support writing data in DataSet to ElasticSearch Key: FLINK-6502 URL: https://issues.apache.org/jira/browse/FLINK-6502 Project: Flink Issue Type: New Feature