[jira] [Created] (FLINK-3628) ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use

2016-03-19 Thread MaGuowei (JIRA)
MaGuowei created FLINK-3628: --- Summary: ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use Key: FLINK-3628 URL: https://issues.apache.org/jira/browse/FLINK-3628 Project: Flink

[jira] [Created] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs

2016-03-19 Thread Lasse Dalegaard (JIRA)
Lasse Dalegaard created FLINK-3637: -- Summary: Change RollingSink Writer interface to allow wider range of outputs Key: FLINK-3637 URL: https://issues.apache.org/jira/browse/FLINK-3637 Project: Flink

[jira] [Created] (FLINK-3626) zipWithIndex in Python API

2016-03-19 Thread Shannon Quinn (JIRA)
Shannon Quinn created FLINK-3626: Summary: zipWithIndex in Python API Key: FLINK-3626 URL: https://issues.apache.org/jira/browse/FLINK-3626 Project: Flink Issue Type: New Feature Co

Re: 答复: Effort to add SQL / StreamSQL to Flink

2016-03-19 Thread Vasiliki Kalavri
Hi all, tableOnCalcite has been merged to master :) Cheers, -Vasia. On 17 March 2016 at 11:11, Fabian Hueske wrote: > Thanks for the initiative Vasia! > I went over the diff and didn't find anything crucial. > > I would like to do another pass over the tests though and improve the > exceptions

[jira] [Created] (FLINK-3630) Little mistake in documentation

2016-03-19 Thread Riccardo Diomedi (JIRA)
Riccardo Diomedi created FLINK-3630: --- Summary: Little mistake in documentation Key: FLINK-3630 URL: https://issues.apache.org/jira/browse/FLINK-3630 Project: Flink Issue Type: Bug

Re: 答复: Effort to add SQL / StreamSQL to Flink

2016-03-19 Thread Fabian Hueske
Thanks for the initiative Vasia! I went over the diff and didn't find anything crucial. I would like to do another pass over the tests though and improve the exceptions for invalid joins before merging. Will open a PR later today. 2016-03-16 21:17 GMT+01:00 Vasiliki Kalavri : > Yes, the current

Re: GSoC Project Proposal Draft: Code Generation in Serializers

2016-03-19 Thread Gábor Horváth
Thank you! I finalized the project. On 18 March 2016 at 10:29, Márton Balassi wrote: > Thanks Gábor, now I also see it on the internal GSoC interface. I have > indicated that I wish to mentor your project, I think you can hit finalize > on your project there. > > On Mon, Mar 14, 2016 at 11:16 AM

[jira] [Created] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()"

2016-03-19 Thread Li Fanxi (JIRA)
Li Fanxi created FLINK-3629: --- Summary: In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()" Key: FLINK-3629 URL: https://issues.apache.org/jira/browse/FLINK-3629

Re: Association failure ClassNotFoundException

2016-03-19 Thread Till Rohrmann
Hi Greg, I’ve found the problem’s cause. In fact you spotted a really mean and subtle bug introduced by FLINK-3327. In a nutshell, the problem is that we now send the ExecutionConfig as part of the JobGraph to the JobManager. The ExecutionConfig can contain classes (Class) of automatically registe

[jira] [Created] (FLINK-3625) Graph algorithms to permute graph labels and edges

2016-03-19 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3625: - Summary: Graph algorithms to permute graph labels and edges Key: FLINK-3625 URL: https://issues.apache.org/jira/browse/FLINK-3625 Project: Flink Issue Type: New Fe

[jira] [Created] (FLINK-3632) Clean up Table API exceptions

2016-03-19 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3632: Summary: Clean up Table API exceptions Key: FLINK-3632 URL: https://issues.apache.org/jira/browse/FLINK-3632 Project: Flink Issue Type: Improvement

Re: 答复: Effort to add SQL / StreamSQL to Flink

2016-03-19 Thread Vasiliki Kalavri
Yes, the current state corresponds to Task 1. PR #1770 corresponds to Task 5. Task 6 should come right after :) -V. On 16 March 2016 at 20:35, Robert Metzger wrote: > Cool, this is great news! > So "Task 1" from the document [1] is done with the merge? And PR #1770 is > going towards "Task 6".

[jira] [Created] (FLINK-3636) NoClassDefFoundError while running WindowJoin example

2016-03-19 Thread JIRA
Zoltán Zvara created FLINK-3636: --- Summary: NoClassDefFoundError while running WindowJoin example Key: FLINK-3636 URL: https://issues.apache.org/jira/browse/FLINK-3636 Project: Flink Issue Type:

Re: YARN/Flink Job

2016-03-19 Thread Chiwan Park
Hi Vijay, Yes, you are right. Flink services (JM & TM) are stopped (not killed) immediately after the job execution. Regards, Chiwan Park > On Mar 18, 2016, at 7:57 AM, Vijay Srinivasaraghavan > wrote: > > If I start a flink job on YARN with below option, does Flink (JM & TM) > service gets

Re: [DISCUSSION] Database state backend

2016-03-19 Thread Gyula Fóra
Hey, Yes, I agree that it is probably best to remove this backend from Flink and make it an external library instead. I will prepare a JIRA and PR. Gyula Aljoscha Krettek ezt írta (időpont: 2016. márc. 16., Sze, 10:35): > Hi, > if you yourself (Gyula) don’t want to maintain it anymore in the

Re: Association failure ClassNotFoundException

2016-03-19 Thread Greg Hogan
I realized shortly after responding that since I had moved the offending code into Gelly, which jar I then copied into the lib folder, that this would not be interfacing the user classloader. So I have merged the Gelly jar as well as the Gelly examples jar into a single jar which is included in my

YARN/Flink Job

2016-03-19 Thread Vijay Srinivasaraghavan
If I start a flink job on YARN with below option, does Flink (JM & TM) service gets killed after the job execution is complete? In otherwords, what is the lifetime of the Flink service after the job is complete?   Run a single Flink job on YARN The documentation above describes how to start a Fl

Re: GSoC Project Proposal Draft: Code Generation in Serializers

2016-03-19 Thread Márton Balassi
Thanks Gábor, now I also see it on the internal GSoC interface. I have indicated that I wish to mentor your project, I think you can hit finalize on your project there. On Mon, Mar 14, 2016 at 11:16 AM, Gábor Horváth wrote: > Hi, > > I have updated this draft to include preliminary benchmarks, m

Re: 答复: Effort to add SQL / StreamSQL to Flink

2016-03-19 Thread Vasiliki Kalavri
Hello everyone, We are happy to announce that the "tableOnCalcite" branch is finally ready to be merged. It essentially provides the existing functionality of the Table API, but now the translation happens through Apache Calcite. You can find the changes rebased on top of the current master in [1]

[jira] [Created] (FLINK-3623) Adjust MurmurHash algorithm

2016-03-19 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3623: - Summary: Adjust MurmurHash algorithm Key: FLINK-3623 URL: https://issues.apache.org/jira/browse/FLINK-3623 Project: Flink Issue Type: Improvement Compone

[jira] [Created] (FLINK-3621) Misleading documentation of memory configuration parameters

2016-03-19 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3621: Summary: Misleading documentation of memory configuration parameters Key: FLINK-3621 URL: https://issues.apache.org/jira/browse/FLINK-3621 Project: Flink Is

Re: 答复: Effort to add SQL / StreamSQL to Flink

2016-03-19 Thread Robert Metzger
Cool, this is great news! So "Task 1" from the document [1] is done with the merge? And PR #1770 is going towards "Task 6". I think good support for Stream SQL is a very interesting new feature for Flink. [1] https://docs.google.com/document/d/1TLayJNOTBle_-m1rQfgA6Ouj1oYsfqRjPcp1h2TVqdI/edit#head

Re: Streaming KV store abstraction

2016-03-19 Thread Nam-Luc Tran
Hi Gyula, I'm currently looking after ways to enrich streams with external data. Have you got any update on the topic in general or on StreamKV? I've checked out the code but it won't build, mainly because StateCheckpointer has been removed since [FLINK-2808]. Any hint on a quick replacement, bef

[jira] [Created] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions

2016-03-19 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3631: Summary: CodeGenerator does not check type compatibility for equality expressions Key: FLINK-3631 URL: https://issues.apache.org/jira/browse/FLINK-3631 Project: Flink

[jira] [Created] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

2016-03-19 Thread JIRA
Zoltán Zvara created FLINK-3624: --- Summary: Use camelCase naming of JSON attributes generated by the REST API instead of dash Key: FLINK-3624 URL: https://issues.apache.org/jira/browse/FLINK-3624 Project

[jira] [Created] (FLINK-3620) Remove DbStateBackend

2016-03-19 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-3620: - Summary: Remove DbStateBackend Key: FLINK-3620 URL: https://issues.apache.org/jira/browse/FLINK-3620 Project: Flink Issue Type: Task Components: Streamin

[jira] [Created] (FLINK-3627) Task stuck on lock in StreamSource when cancelling

2016-03-19 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-3627: -- Summary: Task stuck on lock in StreamSource when cancelling Key: FLINK-3627 URL: https://issues.apache.org/jira/browse/FLINK-3627 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3634) Fix documentation for DataSetUtils.zipWithUniqueId()

2016-03-19 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3634: - Summary: Fix documentation for DataSetUtils.zipWithUniqueId() Key: FLINK-3634 URL: https://issues.apache.org/jira/browse/FLINK-3634 Project: Flink Issue Type: Impr