[jira] [Created] (FLINK-5770) Flink yarn session stop in non-detached model

2017-02-09 Thread zhangrucong1982 (JIRA)
zhangrucong1982 created FLINK-5770: -- Summary: Flink yarn session stop in non-detached model Key: FLINK-5770 URL: https://issues.apache.org/jira/browse/FLINK-5770 Project: Flink Issue Type: B

Re: Fwd: Setup Flink on windows link not accessible

2017-02-09 Thread Tzu-Li (Gordon) Tai
Hi Kush! The link is broken, thank you for reporting this. This is the correct link:  https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/flink_on_windows.html Cheers, Gordon On February 10, 2017 at 12:54:01 PM, kush batra (kush.ba...@gmail.com) wrote: Hi, In Quickstart section

Fwd: Setup Flink on windows link not accessible

2017-02-09 Thread kush batra
Hi, In Quickstart section of apache flink site, I am trying to look at the section to setup Apache flink on Windows using link given on site: https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/flink_on_ windows But link is not accessible. Can you have a look at the same? Regards,

[jira] [Created] (FLINK-5769) Apply new aggregation functions for dataset tables

2017-02-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5769: Summary: Apply new aggregation functions for dataset tables Key: FLINK-5769 URL: https://issues.apache.org/jira/browse/FLINK-5769 Project: Flink Issue Type:

[jira] [Created] (FLINK-5768) Apply new aggregation functions and aggregate DataStream API for streaming tables

2017-02-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5768: Summary: Apply new aggregation functions and aggregate DataStream API for streaming tables Key: FLINK-5768 URL: https://issues.apache.org/jira/browse/FLINK-5768 Proje

[jira] [Created] (FLINK-5767) Add a new aggregate function interface

2017-02-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5767: Summary: Add a new aggregate function interface Key: FLINK-5767 URL: https://issues.apache.org/jira/browse/FLINK-5767 Project: Flink Issue Type: Sub-task

Re: FLINK-5734 : Code Generation for NormalizedKeySorter

2017-02-09 Thread Greg Hogan
On Thu, Feb 9, 2017 at 3:50 PM, pat.chormai wrote: > Hi Greg, > > Thanks for your feedback. I would like to answer your questions here. > > Q: Do I understand correctly that the generated code is only dependent on > the > length of the sort key? > > A: Yes, you're right. The generated code is mai

Re: FLINK-5734 : Code Generation for NormalizedKeySorter

2017-02-09 Thread pat.chormai
Hi Greg, Thanks for your feedback. I would like to answer your questions here. Q: Do I understand correctly that the generated code is only dependent on the length of the sort key? A: Yes, you're right. The generated code is mainly dependent on the length of the sort key. However, I'm not sure

[jira] [Created] (FLINK-5766) Unify NoAvailableResourceException handling on ExecutionGraph

2017-02-09 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5766: --- Summary: Unify NoAvailableResourceException handling on ExecutionGraph Key: FLINK-5766 URL: https://issues.apache.org/jira/browse/FLINK-5766 Project: Flink Is

[jira] [Created] (FLINK-5765) Add noindex meta tag for older docs

2017-02-09 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5765: -- Summary: Add noindex meta tag for older docs Key: FLINK-5765 URL: https://issues.apache.org/jira/browse/FLINK-5765 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5764) Don't serve ancient docs

2017-02-09 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5764: -- Summary: Don't serve ancient docs Key: FLINK-5764 URL: https://issues.apache.org/jira/browse/FLINK-5764 Project: Flink Issue Type: Improvement Componen

[jira] [Created] (FLINK-5763) Make savepoints self-contained and relocatable

2017-02-09 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5763: -- Summary: Make savepoints self-contained and relocatable Key: FLINK-5763 URL: https://issues.apache.org/jira/browse/FLINK-5763 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-5762) Execute initializeState() and open() "atomically"

2017-02-09 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5762: - Summary: Execute initializeState() and open() "atomically" Key: FLINK-5762 URL: https://issues.apache.org/jira/browse/FLINK-5762 Project: Flink Issue Type:

[jira] [Created] (FLINK-5761) ClassNotFoundException during cancel job

2017-02-09 Thread Andrey (JIRA)
Andrey created FLINK-5761: - Summary: ClassNotFoundException during cancel job Key: FLINK-5761 URL: https://issues.apache.org/jira/browse/FLINK-5761 Project: Flink Issue Type: Bug Reporter

[jira] [Created] (FLINK-5760) "Introduction to Apache Flink" links to 1.1 release

2017-02-09 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5760: --- Summary: "Introduction to Apache Flink" links to 1.1 release Key: FLINK-5760 URL: https://issues.apache.org/jira/browse/FLINK-5760 Project: Flink Issue Type: B

[jira] [Created] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-09 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5759: --- Summary: Set an UncaughtExceptionHandler for all Thread Pools in JobManager Key: FLINK-5759 URL: https://issues.apache.org/jira/browse/FLINK-5759 Project: Flink

[jira] [Created] (FLINK-5758) Port-range for the web interface via YARN

2017-02-09 Thread Kanstantsin Kamkou (JIRA)
Kanstantsin Kamkou created FLINK-5758: - Summary: Port-range for the web interface via YARN Key: FLINK-5758 URL: https://issues.apache.org/jira/browse/FLINK-5758 Project: Flink Issue Type:

RE: flink-ml test

2017-02-09 Thread Anton Solovev
Thanks for help, but unfortunately it keeps going through all tests -Original Message- From: Stavros Kontopoulos [mailto:st.kontopou...@gmail.com] Sent: Friday, January 27, 2017 11:45 PM To: dev@flink.apache.org Subject: Re: flink-ml test Adding to previous, "suites" option is technicall

[jira] [Created] (FLINK-5757) Initial JobManager address required during access from cli to HA cluster

2017-02-09 Thread Andrey (JIRA)
Andrey created FLINK-5757: - Summary: Initial JobManager address required during access from cli to HA cluster Key: FLINK-5757 URL: https://issues.apache.org/jira/browse/FLINK-5757 Project: Flink Iss

[jira] [Created] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

2017-02-09 Thread Syinchwun Leo (JIRA)
Syinchwun Leo created FLINK-5756: Summary: When there are many values under the same key in ListState, RocksDBStateBackend performances poor Key: FLINK-5756 URL: https://issues.apache.org/jira/browse/FLINK-5756

[jira] [Created] (FLINK-5755) Flink with Kafka connection

2017-02-09 Thread JIRA
Fábio Dias created FLINK-5755: - Summary: Flink with Kafka connection Key: FLINK-5755 URL: https://issues.apache.org/jira/browse/FLINK-5755 Project: Flink Issue Type: Bug Components: Dat

[jira] [Created] (FLINK-5754) released tag missing .gitigonore .travis.yml .gitattributes

2017-02-09 Thread shijinkui (JIRA)
shijinkui created FLINK-5754: Summary: released tag missing .gitigonore .travis.yml .gitattributes Key: FLINK-5754 URL: https://issues.apache.org/jira/browse/FLINK-5754 Project: Flink Issue Typ

[jira] [Created] (FLINK-5753) CEP timeout handler.

2017-02-09 Thread JIRA
Michał Jurkiewicz created FLINK-5753: Summary: CEP timeout handler. Key: FLINK-5753 URL: https://issues.apache.org/jira/browse/FLINK-5753 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-5752) Support push down projections for HBaseTableSource

2017-02-09 Thread ramkrishna.s.vasudevan (JIRA)
ramkrishna.s.vasudevan created FLINK-5752: - Summary: Support push down projections for HBaseTableSource Key: FLINK-5752 URL: https://issues.apache.org/jira/browse/FLINK-5752 Project: Flink

[jira] [Created] (FLINK-5751) 404 in documentation

2017-02-09 Thread Colin Breame (JIRA)
Colin Breame created FLINK-5751: --- Summary: 404 in documentation Key: FLINK-5751 URL: https://issues.apache.org/jira/browse/FLINK-5751 Project: Flink Issue Type: Bug Reporter: Colin

Re: FLINK-5734 : Code Generation for NormalizedKeySorter

2017-02-09 Thread Till Rohrmann
I'm not sure how the code generation and compilation works in detail, but aren't you able to write a class file as the result of the compilation? Then this class file could be uploaded to the JM and from there to all TMs. The class basically becomes another job dependency like the user code jar and

Re: ecosystem proposal, Temporal graph analytics on Flink with Gelly

2017-02-09 Thread otherwise777
Awesome, Thnx! My defense will be on the 20th of February, after that I will work on the finishing touches of the project, and create the things that you mentioned. After that I will submit a pull request -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabb

[jira] [Created] (FLINK-5750) Incorrect parse of brackets inside VALUES subquery

2017-02-09 Thread Anton Mushin (JIRA)
Anton Mushin created FLINK-5750: --- Summary: Incorrect parse of brackets inside VALUES subquery Key: FLINK-5750 URL: https://issues.apache.org/jira/browse/FLINK-5750 Project: Flink Issue Type: Bu

Re: ecosystem proposal, Temporal graph analytics on Flink with Gelly

2017-02-09 Thread Vasiliki Kalavri
Hi Wouter, thank you for sharing your work with the community! When your project is ready, I would suggest you open a pull request to the flink-web repository [1] to add it to the list. It would be nice to add a description and a readme file to your repository. Among others, you could include the