[jira] [Created] (FLINK-5386) Refacturing Window Clause

2016-12-21 Thread sunjincheng (JIRA)
sunjincheng created FLINK-5386: -- Summary: Refacturing Window Clause Key: FLINK-5386 URL: https://issues.apache.org/jira/browse/FLINK-5386 Project: Flink Issue Type: Improvement Compone

[jira] [Created] (FLINK-5385) Add a help function to create Row

2016-12-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-5385: -- Summary: Add a help function to create Row Key: FLINK-5385 URL: https://issues.apache.org/jira/browse/FLINK-5385 Project: Flink Issue Type: Improvement Compone

Re: Flink gives incorrect result when event time windowing used

2016-12-21 Thread Jaromir Vanek
Aljoscha, thank you very much for explanation. It seems that using /AscendingTimestampExtractor/ would really solve my problem, because reading a watermark with "currentTimestamp - 1" is correct way to wait for all elements with identical timestamp. But I can see this is not true for /BoundedOutO

[RESULT] [VOTE] Release Apache Flink 1.1.4 (RC4)

2016-12-21 Thread Ufuk Celebi
This vote has passed with 3 binding and 1 non-binding +1 votes. Thanks to everyone who was involved. I'll go ahead and finalize and package this release. +1s: Gyula Fora (binding) Stephan Ewen (binding) Robert Metzger (binding) Tzu-Li (Gordon) Tai (non-binding) There are no 0s or -1s. On Wed, De

Re: clean up jira

2016-12-21 Thread Aljoscha Krettek
Thanks a lot for going through the issues and preparing this list! >From a first glance some can definitely be closed. I didn't yet find the time to look through all of them but we should definitely work and cleaning up our Jira. Cheers, Aljoscha On Wed, 21 Dec 2016 at 18:19 Anton Solovev wrote

[jira] [Created] (FLINK-5384) clean up jira issues

2016-12-21 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5384: Summary: clean up jira issues Key: FLINK-5384 URL: https://issues.apache.org/jira/browse/FLINK-5384 Project: Flink Issue Type: Improvement Report

clean up jira

2016-12-21 Thread Anton Solovev
Hi folks I found a lot of non-relevant issues: https://issues.apache.org/jira/browse/FLINK-37 -> from stratosphere; https://issues.apache.org/jira/browse/FLINK-87 -> from stratosphere; https://issues.apache.org/jira/browse/FLINK-481 -> from stratosphere; https://issues.apache.org/jira/browse/FLIN

[jira] [Created] (FLINK-5383) TaskManager fails with SIGBUS when loading RocksDB

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5383: - Summary: TaskManager fails with SIGBUS when loading RocksDB Key: FLINK-5383 URL: https://issues.apache.org/jira/browse/FLINK-5383 Project: Flink Issue Type

[jira] [Created] (FLINK-5382) Taskmanager log download button causes 404

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5382: - Summary: Taskmanager log download button causes 404 Key: FLINK-5382 URL: https://issues.apache.org/jira/browse/FLINK-5382 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5381) Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config)

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5381: - Summary: Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config) Key: FLINK-5381 URL: https://issues.apache.org/jira/browse/FLINK-5381

[jira] [Created] (FLINK-5380) Number of outgoing records not reported in web interface

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5380: - Summary: Number of outgoing records not reported in web interface Key: FLINK-5380 URL: https://issues.apache.org/jira/browse/FLINK-5380 Project: Flink Issu

Re: [VOTE] Release Apache Flink 1.1.4 (RC4)

2016-12-21 Thread Tzu-Li (Gordon) Tai
+1 (unbinding) - Assured Kinesis connector works properly across different / older AWS EMR versions with simple job (randomly tested in version 5.0.3, 4.8.2, 4.7.2, 4.5) - Ran Java & Scala quickstart examples (in local IDE mode, cluster mode and multi-node cluster) On December 21, 2016 at 9:38

[jira] [Created] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5379: - Summary: Flink CliFrontend does not return when not logged in with kerberos Key: FLINK-5379 URL: https://issues.apache.org/jira/browse/FLINK-5379 Project: Flink

Re: [VOTE] Release Apache Flink 1.1.4 (RC4)

2016-12-21 Thread Robert Metzger
+1 to release. I tested the RC with my misbehaved job for a longer period of time, and everything went okay (every now and then I had a segfault from rocks). I also created a savepoint and restored from it. The files in the staging repo look good. On Tue, Dec 20, 2016 at 9:43 PM, Stephan Ewen wr

Re: [jira] [Created] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list

2016-12-21 Thread Jark Wu
Hi Sednoh, It seems that the Travis error has nothing to do with the code you changed. - Jark Wu > 在 2016年12月21日,下午7:32,Hung Chang 写道: > > Hi Flink developers, > > Travis CI shows error when I send PR > https://github.com/apache/flink/pull/3036, but I don't find the issue > reading the log

[jira] [Created] (FLINK-5378) Update Scopt version to 3.5.0

2016-12-21 Thread JIRA
Lorenz Bühmann created FLINK-5378: - Summary: Update Scopt version to 3.5.0 Key: FLINK-5378 URL: https://issues.apache.org/jira/browse/FLINK-5378 Project: Flink Issue Type: Wish Affects Ve

Re: [jira] [Created] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list

2016-12-21 Thread Hung Chang
Hi Flink developers, Travis CI shows error when I send PR https://github.com/apache/flink/pull/3036, but I don't find the issue reading the log. Does anyone know what I should do to fix it? test: https://travis-ci.org/apache/flink/jobs/185728861 full log: https://s3.amazonaws.com/archive.travis-

[jira] [Created] (FLINK-5377) Improve savepoint docs

2016-12-21 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5377: -- Summary: Improve savepoint docs Key: FLINK-5377 URL: https://issues.apache.org/jira/browse/FLINK-5377 Project: Flink Issue Type: Improvement Components

Re: Stream Iterations

2016-12-21 Thread Ufuk Celebi
The delta iterations are a batch-only feature. Did you try the DataStream#iterate? https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/index.html#iterations On Mon, Dec 19, 2016 at 5:35 AM, Govindarajan Srinivasaraghavan wrote: > Hi All, > > I have a use case for which I