Re: Exception from in-progress implementation of Python API bulk iterations

Your solution works well, many thanks. This solves the exception that I described previously. However, in a different part of the script I come across another problem about reusing data sets. For example, given the script at https://gist.github.com/GEOFBOT/d670f567f8c886572c8715a6058f8b34, I get

[jira] [Created] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

Ted Yu created FLINK-4848: - Summary: keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Key: FLINK-4848 URL: https://issues.apache.org/jira/browse/FLINK-4848 Project: Flink

[jira] [Created] (FLINK-4849) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

Ted Yu created FLINK-4849: - Summary: keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Key: FLINK-4849 URL: https://issues.apache.org/jira/browse/FLINK-4849 Project: Flink

Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink

Hi Aljoscha, Thanks for the response. I did think about creating a new class similar to TimestampedValue as you suggested, but that class looked almost same as the current StreamRecord class. (Both have a timestamp field and a value field). Do you think it is fine to have another class for

Re: Flink Metrics

Hi colleagues,Is there a link that described Flink Matrices & provides example on how to utilize it pls?I really appreciate it...Cheers From: Till Rohrmann To: u...@flink.apache.org Cc: dev@flink.apache.org Sent: Monday, October 17, 2016 12:52 AM Subject: Re:

[jira] [Created] (FLINK-4840) Introduce an OperatorSystemMetricGroup

zhuhaifeng created FLINK-4840: - Summary: Introduce an OperatorSystemMetricGroup Key: FLINK-4840 URL: https://issues.apache.org/jira/browse/FLINK-4840 Project: Flink Issue Type: Improvement

Re: Flink Metrics

Hi Govind, I think the DropwizardMeterWrapper implementation is just a reference implementation where it was decided to report the minute rate. You can define your own meter class which allows to configure the rate interval accordingly. Concerning Timers, I think nobody requested this metric so