[jira] [Created] (FLINK-6218) Not able to access the rows in table after converting dataset to table after using registerdataset

naveen holla U created FLINK-6218: - Summary: Not able to access the rows in table after converting dataset to table after using registerdataset Key: FLINK-6218 URL:

[jira] [Created] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly

Haohui Mai created FLINK-6217: - Summary: ContaineredTaskManagerParameters sets off heap memory size incorrectly Key: FLINK-6217 URL: https://issues.apache.org/jira/browse/FLINK-6217 Project: Flink

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

I commented on FLINK-6214: I think it's working as intended, although we could fix the javadoc/doc. On Wed, Mar 29, 2017, at 17:35, Timo Walther wrote: > A user reported that all tumbling and slinding window assigners contain > a pretty obvious bug about offsets. > >

[jira] [Created] (FLINK-6216) DataStream unbounded groupby aggregate with early firing

Shaoxuan Wang created FLINK-6216: Summary: DataStream unbounded groupby aggregate with early firing Key: FLINK-6216 URL: https://issues.apache.org/jira/browse/FLINK-6216 Project: Flink Issue

[jira] [Created] (FLINK-6215) Make the StatefulSequenceSource scalable.

Kostas Kloudas created FLINK-6215: - Summary: Make the StatefulSequenceSource scalable. Key: FLINK-6215 URL: https://issues.apache.org/jira/browse/FLINK-6215 Project: Flink Issue Type: Bug

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

A user reported that all tumbling and slinding window assigners contain a pretty obvious bug about offsets. https://issues.apache.org/jira/browse/FLINK-6214 I think we should also fix this for 1.2.1. What do you think? Regards, Timo Am 29/03/17 um 11:30 schrieb Robert Metzger: Hi Haohui, I

Re: TumblingEventTimeWindows with negative offset / Wrong documentation

Thanks I would have open the issue but wanted to make sure this is a code bug and not a documentation bug. 2017-03-29 17:18 GMT+02:00 Timo Walther : > Hi Vladislav, > > thank you very much for reporting this. You are right this is bug. I > opened an issue for it:

Re: TumblingEventTimeWindows with negative offset / Wrong documentation

Hi Vladislav, thank you very much for reporting this. You are right this is bug. I opened an issue for it: https://issues.apache.org/jira/browse/FLINK-6214 I think it will be solved soon. Regards, Timo Am 29/03/17 um 16:57 schrieb Vladislav Pernin: Hi, The documentation mentions the

[jira] [Created] (FLINK-6214) WindowAssigners do not allow negative offsets

Timo Walther created FLINK-6214: --- Summary: WindowAssigners do not allow negative offsets Key: FLINK-6214 URL: https://issues.apache.org/jira/browse/FLINK-6214 Project: Flink Issue Type: Bug

TumblingEventTimeWindows with negative offset / Wrong documentation

Hi, The documentation mentions the possibility to use a negative offset with a TumblingEventTimeWindows : // daily tumbling event-time windows offset by -8 hours.input .keyBy() .window(TumblingEventTimeWindows.of(Time.days(1), Time.hours(-8))) .(); But the code will throw an

Re: [DISCUSS] TravisCI auto cancellation

Wow, that was a quick response that this feature was already enabled. > On Mar 29, 2017, at 9:31 AM, Greg Hogan wrote: > > Ticket: https://issues.apache.org/jira/browse/INFRA-13778 > > > >> On Mar 29, 2017, at 4:07 AM,

Re: [DISCUSS] TravisCI auto cancellation

Ticket: https://issues.apache.org/jira/browse/INFRA-13778 > On Mar 29, 2017, at 4:07 AM, Till Rohrmann wrote: > > Looking at Flink's Travis account, I've got the feeling that this feature > has already been activated.

Re: Flink on yarn passing yarn config params.

Hi, you can pass application tags using `yarn.tags` option. See also here for more options: https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/config.html#yarn I hope that helps. Regards, Timo Am 29/03/17 um 01:18 schrieb praveen kanamarlapudi: yarn application tag

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

Hi Haohui, I agree that we should fix the parallelism issue. Otherwise, the 1.2.1 release would introduce a new bug. On Tue, Mar 28, 2017 at 11:59 PM, Haohui Mai wrote: > -1 (non-binding) > > We recently found out that all jobs submitted via UI will have a > parallelism of

[jira] [Created] (FLINK-6213) When number of failed containers exceeds maximum failed containers and application is stopped, the AM container will be released 10 minutes later

Yelei Feng created FLINK-6213: - Summary: When number of failed containers exceeds maximum failed containers and application is stopped, the AM container will be released 10 minutes later Key: FLINK-6213 URL:

Re: [DISCUSS] TravisCI auto cancellation

Looking at Flink's Travis account, I've got the feeling that this feature has already been activated. At least I see some builds (e.g. PR #3625) where multiple commits where created in a short time and then only the latest was actually executed. Apart from that I think it's a good idea since it

[jira] [Created] (FLINK-6212) Missing reference to flink-avro dependency

Omar Erminy created FLINK-6212: -- Summary: Missing reference to flink-avro dependency Key: FLINK-6212 URL: https://issues.apache.org/jira/browse/FLINK-6212 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6211) Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position

Wei-Che Wei created FLINK-6211: -- Summary: Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position Key: FLINK-6211 URL: https://issues.apache.org/jira/browse/FLINK-6211 Project: