[jira] [Created] (FLINK-4807) ResourceManager clean up JobManager's registration

Kurt Young created FLINK-4807: - Summary: ResourceManager clean up JobManager's registration Key: FLINK-4807 URL: https://issues.apache.org/jira/browse/FLINK-4807 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-4806) ResourceManager stop listening JobManager's leader address

Kurt Young created FLINK-4806: - Summary: ResourceManager stop listening JobManager's leader address Key: FLINK-4806 URL: https://issues.apache.org/jira/browse/FLINK-4806 Project: Flink Issue Type

[jira] [Created] (FLINK-4805) Stringify() crashes with Python3 (run with pyflink3)

Yakov Goldberg created FLINK-4805: - Summary: Stringify() crashes with Python3 (run with pyflink3) Key: FLINK-4805 URL: https://issues.apache.org/jira/browse/FLINK-4805 Project: Flink Issue Ty

[jira] [Created] (FLINK-4804) Grouping.first() function usage fails

Yakov Goldberg created FLINK-4804: - Summary: Grouping.first() function usage fails Key: FLINK-4804 URL: https://issues.apache.org/jira/browse/FLINK-4804 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4803) Job Cancel can hang forever waiting for OutputFormat.close()

Shannon Carey created FLINK-4803: Summary: Job Cancel can hang forever waiting for OutputFormat.close() Key: FLINK-4803 URL: https://issues.apache.org/jira/browse/FLINK-4803 Project: Flink I

[jira] [Created] (FLINK-4802) distinct() implicitly uses 0th field, when called without a parameter

Yakov Goldberg created FLINK-4802: - Summary: distinct() implicitly uses 0th field, when called without a parameter Key: FLINK-4802 URL: https://issues.apache.org/jira/browse/FLINK-4802 Project: Flink

Re: Type problem in RichFlatMapFunction when using GenericArray type

I identified the problem and opened a issue for it: https://issues.apache.org/jira/browse/FLINK-4801 Am 11/10/16 um 15:31 schrieb Timo Walther: I will also have a look at this issue. Am 11/10/16 um 09:10 schrieb Chesnay Schepler: Yes, i think a JIRA issue would be good for this. On 11.10.20

[jira] [Created] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions

Timo Walther created FLINK-4801: --- Summary: Input type inference is faulty with custom Tuples and RichFunctions Key: FLINK-4801 URL: https://issues.apache.org/jira/browse/FLINK-4801 Project: Flink

Re: S3/S3A support

Hi! The "truncate()" functionality is only needed for the rolling/bucketing sink. The core checkpoint functionality does not need any truncate() behavior... Best, Stephan On Tue, Oct 11, 2016 at 5:22 PM, Vijay Srinivasaraghavan < vijikar...@yahoo.com.invalid> wrote: > Thanks Stephan. My unders

Re: S3/S3A support

Thanks Stephan. My understanding is checkpoint uses truncate API but S3A does not support it. Will this have any impact? Some of the known S3A client limitations are captured in Hortonworks site https://hortonworks.github.io/hdp-aws/s3-s3aclient/index.html and wondering if that has any impact on

Re: [VOTE] Release Apache Flink 1.1.3 (RC2)

+1 for releasing this as Flink 1.1.3 - Checked the staging repository for hadoop2 / hadoop1 mixup; quickstart version; build a test project against repository - Checked the artifacts: - src doesn't contain any binaries - started Flink locally & executed example & checked web interface On

[jira] [Created] (FLINK-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests.

Kostas Kloudas created FLINK-4800: - Summary: Refactor the ContinuousFileMonitoringFunction code and the related tests. Key: FLINK-4800 URL: https://issues.apache.org/jira/browse/FLINK-4800 Project: Fl

Re: Type problem in RichFlatMapFunction when using GenericArray type

I will also have a look at this issue. Am 11/10/16 um 09:10 schrieb Chesnay Schepler: Yes, i think a JIRA issue would be good for this. On 11.10.2016 08:42, Martin Junghanns wrote: Shall I open an issue for that? The Exception gets thrown when using RichFlatJoinFunction or RichFlatMapFunction

[jira] [Created] (FLINK-4799) Re-add build-target symlink to project root

Maximilian Michels created FLINK-4799: - Summary: Re-add build-target symlink to project root Key: FLINK-4799 URL: https://issues.apache.org/jira/browse/FLINK-4799 Project: Flink Issue Typ

Re: [DISCUSS] Removing delete*Timer from the WindowOperator.Context

+Konstantin Knauf looping you in directly because you used the "delete timer" feature in the past and even did some changes to the timer system. Are you still relying on the fact that deleted timers are actually deleted. The main reason for wanting to get rid of delete timer is IMHO that deleting

[jira] [Created] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure

Robert Metzger created FLINK-4798: - Summary: CEPITCase.testSimpleKeyedPatternCEP test failure Key: FLINK-4798 URL: https://issues.apache.org/jira/browse/FLINK-4798 Project: Flink Issue Type:

Re: S3/S3A support

Hi! In 1.2-SNAPSHOT, we recently fixed issues due to the "eventual consistency" nature of S3. The fix is not in v1.1 - that is the only known issue I can think of. It results in occasional (seldom) periods of heavy restart retries, until all files are visible to all participants. If you run into

[jira] [Created] (FLINK-4797) Add Flink 1.1 savepoint backwards compatability

Ufuk Celebi created FLINK-4797: -- Summary: Add Flink 1.1 savepoint backwards compatability Key: FLINK-4797 URL: https://issues.apache.org/jira/browse/FLINK-4797 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-4796) Extend SinkFunction to include also the event timestamp

Robert Metzger created FLINK-4796: - Summary: Extend SinkFunction to include also the event timestamp Key: FLINK-4796 URL: https://issues.apache.org/jira/browse/FLINK-4796 Project: Flink Issue

Re: Type problem in RichFlatMapFunction when using GenericArray type

Yes, i think a JIRA issue would be good for this. On 11.10.2016 08:42, Martin Junghanns wrote: Shall I open an issue for that? The Exception gets thrown when using RichFlatJoinFunction or RichFlatMapFunction (updated the Gist) and the first field of the tuple is an array type. I can look into