[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627211#comment-14627211 ] Fabian Hueske commented on FLINK-2361: -- Can you give exact instructions how to

[jira] [Created] (FLINK-2353) Hadoop mapred IOFormat wrappers do not respect JobConfigurable interface

Fabian Hueske created FLINK-2353: Summary: Hadoop mapred IOFormat wrappers do not respect JobConfigurable interface Key: FLINK-2353 URL: https://issues.apache.org/jira/browse/FLINK-2353 Project:

[jira] [Closed] (FLINK-2874) Certain Avro generated getters/setters not recognized

[ https://issues.apache.org/jira/browse/FLINK-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2874. Resolution: Fixed Fix Version/s: 0.10 0.9 Fixed for 0.9 with

[jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features

[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14970775#comment-14970775 ] Fabian Hueske commented on FLINK-2901: -- Yes, I agree. Actually, that is already committed in the

[jira] [Resolved] (FLINK-2712) Add some description about tests to "How to Contribute" documentation

[ https://issues.apache.org/jira/browse/FLINK-2712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2712. -- Resolution: Fixed Included in the reworked contribution guideline (commit

[jira] [Closed] (FLINK-2895) Duplicate immutable object creation

[ https://issues.apache.org/jira/browse/FLINK-2895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2895. Resolution: Fixed Fix Version/s: 1.0 0.10 Fixed in 0.10 with

[jira] [Closed] (FLINK-2893) Rename recovery configuration keys

[ https://issues.apache.org/jira/browse/FLINK-2893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2893. Resolution: Fixed Fix Version/s: 1.0 Fixed in 0.10 with

[jira] [Closed] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

[ https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1982. Resolution: Fixed Fix Version/s: 1.0 0.10 Fixed in 0.10 with

[jira] [Closed] (FLINK-2898) Invert Travis CI build order

[ https://issues.apache.org/jira/browse/FLINK-2898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2898. Resolution: Fixed Fix Version/s: 1.0 Fixed with d2e4a27d66faf756c8da5236588c4043ba559ecd >

[jira] [Assigned] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module

[ https://issues.apache.org/jira/browse/FLINK-2900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2900: Assignee: Fabian Hueske > Remove Record-API dependencies from Hadoop Compat module >

[jira] [Created] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module

Fabian Hueske created FLINK-2900: Summary: Remove Record-API dependencies from Hadoop Compat module Key: FLINK-2900 URL: https://issues.apache.org/jira/browse/FLINK-2900 Project: Flink Issue

[jira] [Created] (FLINK-2901) Several flink-test ITCases depend on Record API features

Fabian Hueske created FLINK-2901: Summary: Several flink-test ITCases depend on Record API features Key: FLINK-2901 URL: https://issues.apache.org/jira/browse/FLINK-2901 Project: Flink Issue

[jira] [Assigned] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

[ https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1982: Assignee: Fabian Hueske > Remove dependencies on Record for Flink runtime and core >

[jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features

[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14969924#comment-14969924 ] Fabian Hueske commented on FLINK-2901: -- I started to remove some of the dependencies and tests. The

[jira] [Closed] (FLINK-1988) Port Record API based tests in the common.io

[ https://issues.apache.org/jira/browse/FLINK-1988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1988. Resolution: Invalid Yes, `common.io` is clean. > Port Record API based tests in the common.io >

[jira] [Updated] (FLINK-2922) Add Queryable Window Operator

[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2922: - Labels: requires-design-doc (was: ) > Add Queryable Window Operator >

[jira] [Updated] (FLINK-2883) Combinable reduce produces wrong result

[ https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2883: - Issue Type: Task (was: Bug) > Combinable reduce produces wrong result >

[jira] [Updated] (FLINK-2883) Add documentation to forbid key-modifying ReduceFunction

[ https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2883: - Summary: Add documentation to forbid key-modifying ReduceFunction (was: Combinable reduce

[jira] [Closed] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class.

[ https://issues.apache.org/jira/browse/FLINK-2890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2890. Resolution: Fixed Fix Version/s: 1.0 Fixed with 75a5257412606ac70113850439457cce7da3b2e6 >

[jira] [Closed] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

[ https://issues.apache.org/jira/browse/FLINK-2919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2919. Resolution: Fixed Fix Version/s: 1.0 Fixed with 7265d81ff95aff4ddfbcbd4ef25869ea8f159769 >

[jira] [Closed] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties()

[ https://issues.apache.org/jira/browse/FLINK-2827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2827. Resolution: Fixed Fix Version/s: 1.0 Fixed with 6a8e90b3621bb96304b325a4ae8f7f5575ec909a >

[jira] [Closed] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class

[ https://issues.apache.org/jira/browse/FLINK-2889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2889. Resolution: Fixed Fix Version/s: 1.0 Fixed with 75a5257412606ac70113850439457cce7da3b2e6 >

[jira] [Commented] (FLINK-2907) Bloom filter for Join

[ https://issues.apache.org/jira/browse/FLINK-2907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976126#comment-14976126 ] Fabian Hueske commented on FLINK-2907: -- Hi Greg, this is a really interesting idea. Being able to

[jira] [Updated] (FLINK-2907) Bloom filter for Join

[ https://issues.apache.org/jira/browse/FLINK-2907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2907: - Labels: requires-design-doc (was: ) > Bloom filter for Join > - > >

[jira] [Closed] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http

[ https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2932. Resolution: Fixed Fix Version/s: 1.0 0.10 Fixed in 0.10 with

[jira] [Resolved] (FLINK-2559) Fix Javadoc (e.g. Code Examples)

[ https://issues.apache.org/jira/browse/FLINK-2559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2559. -- Resolution: Done Fix Version/s: 1.0 0.10 Done in 0.10 with

[jira] [Resolved] (FLINK-2902) Web interface sort tasks newest first

[ https://issues.apache.org/jira/browse/FLINK-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2902. -- Resolution: Fixed Fix Version/s: 1.0 0.10 Fixed in 0.10 with

[jira] [Closed] (FLINK-2869) Apply JMH on IOManagerPerformanceBenchmark class.

[ https://issues.apache.org/jira/browse/FLINK-2869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2869. Resolution: Implemented Fix Version/s: 1.0 Implemented with

[jira] [Resolved] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2800. -- Resolution: Fixed Fix Version/s: 1.0 0.10 0.9.2

[jira] [Closed] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module

[ https://issues.apache.org/jira/browse/FLINK-2900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2900. Resolution: Done Fix Version/s: 1.0 Done with 2ff04baa649831fe66a7fa1f3d5b4d7adf632261 >

[jira] [Closed] (FLINK-2920) Apply JMH on KryoVersusAvroMinibenchmark class.

[ https://issues.apache.org/jira/browse/FLINK-2920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2920. Resolution: Implemented Fix Version/s: 1.0 Implemented with

[jira] [Closed] (FLINK-2934) Remove placehoder pages in Web dashboard

[ https://issues.apache.org/jira/browse/FLINK-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2934. Resolution: Fixed Fix Version/s: 1.0 0.10 Fixed in 0.10 with

[jira] [Comment Edited] (FLINK-2942) Dangling operators in web UI's program visualization

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980753#comment-14980753 ] Fabian Hueske edited comment on FLINK-2942 at 10/29/15 4:45 PM: ScreenShot

[jira] [Created] (FLINK-2942) Dangling operators in web UI's program visualization

Fabian Hueske created FLINK-2942: Summary: Dangling operators in web UI's program visualization Key: FLINK-2942 URL: https://issues.apache.org/jira/browse/FLINK-2942 Project: Flink Issue

[jira] [Created] (FLINK-2943) Confusing Bytes/Records "read" and "write" labels in WebUI job view

Fabian Hueske created FLINK-2943: Summary: Confusing Bytes/Records "read" and "write" labels in WebUI job view Key: FLINK-2943 URL: https://issues.apache.org/jira/browse/FLINK-2943 Project: Flink

[jira] [Updated] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2942: - Attachment: Screen Shot 2015-10-29 at 20.51.46.png Screenshot 2: OuterJoin with only one input.

[jira] [Updated] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2942: - Description: When visualizing a program with three {{MapPartition}} operators that branch off

[jira] [Updated] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2942: - Description: When visualizing a program with three {{MapPartition}} operators that branch off

[jira] [Updated] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2942: - Attachment: Screen Shot 2015-10-29 at 20.52.13.png Screenshot 3: Detached MapPartition operators

[jira] [Updated] (FLINK-2942) Dangling operators in web UI's program visualization

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2942: - Attachment: Screen Shot 2015-10-29 at 17.11.19.png Operators "MapPartition

[jira] [Commented] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version

[ https://issues.apache.org/jira/browse/FLINK-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14977430#comment-14977430 ] Fabian Hueske commented on FLINK-2933: -- Thanks for opening this issue. A discussion about artifact

[jira] [Commented] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version

[ https://issues.apache.org/jira/browse/FLINK-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14978887#comment-14978887 ] Fabian Hueske commented on FLINK-2933: -- I'll reply on the thread to get you in the loop. > Flink

[jira] [Commented] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http

[ https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14979160#comment-14979160 ] Fabian Hueske commented on FLINK-2932: -- Committers definitely need a CLA. However,

[jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method

[ https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980068#comment-14980068 ] Fabian Hueske commented on FLINK-2926: -- Hi [~mliesenberg], I attached the `requires-design-doc` label

[jira] [Updated] (FLINK-2926) Add a Strongly Connected Components Library Method

[ https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2926: - Labels: requires-design-doc (was: ) > Add a Strongly Connected Components Library Method >

[jira] [Created] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

Fabian Hueske created FLINK-2936: Summary: ClassCastException when using EventTimeSourceFunction in non-EventTime program Key: FLINK-2936 URL: https://issues.apache.org/jira/browse/FLINK-2936

[jira] [Commented] (FLINK-2940) Deploy multiple Scala versions for Maven artifacts

[ https://issues.apache.org/jira/browse/FLINK-2940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980273#comment-14980273 ] Fabian Hueske commented on FLINK-2940: -- Duplicate of FLINK-2933 > Deploy multiple Scala versions for

[jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features

[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973286#comment-14973286 ] Fabian Hueske commented on FLINK-2901: -- The jobs can be removed as well. They are mainly used for the

[jira] [Closed] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most

[ https://issues.apache.org/jira/browse/FLINK-2206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2206. Resolution: Fixed Fixed for 0.10 with dadb1a8030d8d2e1bd5e6826c1c9632d3d6ddf8b Fixed on master with

[jira] [Created] (FLINK-2906) Remove Record-API

Fabian Hueske created FLINK-2906: Summary: Remove Record-API Key: FLINK-2906 URL: https://issues.apache.org/jira/browse/FLINK-2906 Project: Flink Issue Type: Sub-task Components:

[jira] [Closed] (FLINK-2668) ProjectOperator method to close projection

[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2668. Resolution: Fixed Assignee: Chesnay Schepler Fix Version/s: 0.10 Fixed on master

[jira] [Commented] (FLINK-2898) Invert Travis CI build order

[ https://issues.apache.org/jira/browse/FLINK-2898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14969287#comment-14969287 ] Fabian Hueske commented on FLINK-2898: -- Good idea! +1 > Invert Travis CI build order >

[jira] [Comment Edited] (FLINK-2213) Configure number of vcores

[ https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14996423#comment-14996423 ] Fabian Hueske edited comment on FLINK-2213 at 11/9/15 12:13 PM: Flink does

[jira] [Commented] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14996547#comment-14996547 ] Fabian Hueske commented on FLINK-2942: -- OK, the program does not exactly produce the previous

[jira] [Updated] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2942: - Attachment: Screen Shot 2015-11-09 at 14.48.03.png > Dangling operators in web UI's program

[jira] [Commented] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic)

[ https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14996522#comment-14996522 ] Fabian Hueske commented on FLINK-2942: -- I don't think the problem is specific to MapPartition

[jira] [Created] (FLINK-2999) Support connected keyed streams

Fabian Hueske created FLINK-2999: Summary: Support connected keyed streams Key: FLINK-2999 URL: https://issues.apache.org/jira/browse/FLINK-2999 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3001) Add Support for Java 8 Optional type

[ https://issues.apache.org/jira/browse/FLINK-3001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000181#comment-15000181 ] Fabian Hueske commented on FLINK-3001: -- Do we want to support Option types as keys? If yes, what will

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

[ https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15003872#comment-15003872 ] Fabian Hueske commented on FLINK-3002: -- I am not exactly sure what you mean. Type inference should

[jira] [Created] (FLINK-3010) Add link to powered-by wiki page to project website

Fabian Hueske created FLINK-3010: Summary: Add link to powered-by wiki page to project website Key: FLINK-3010 URL: https://issues.apache.org/jira/browse/FLINK-3010 Project: Flink Issue

[jira] [Updated] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-2695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2695: - Fix Version/s: (was: 0.10.0) 1.0.0 >

[jira] [Updated] (FLINK-2728) Add missing features to new web dashboard

[ https://issues.apache.org/jira/browse/FLINK-2728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2728: - Fix Version/s: (was: 0.10.0) 1.0.0 > Add missing features to new web

[jira] [Updated] (FLINK-2455) Misleading I/O manager error log messages

[ https://issues.apache.org/jira/browse/FLINK-2455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2455: - Fix Version/s: (was: 0.10.0) 1.0.0 > Misleading I/O manager error log

[jira] [Updated] (FLINK-2758) TaskManagerRegistrationTest fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2758: - Fix Version/s: (was: 0.10.0) 1.0.0 > TaskManagerRegistrationTest fails on

[jira] [Updated] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination

[ https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2390: - Fix Version/s: (was: 0.10.0) 1.0.0 > Replace iteration timeout with

[jira] [Updated] (FLINK-2157) Create evaluation framework for ML library

[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2157: - Fix Version/s: (was: 0.10.0) 1.0.0 > Create evaluation framework for ML

[jira] [Updated] (FLINK-2075) Shade akka and protobuf dependencies away

[ https://issues.apache.org/jira/browse/FLINK-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2075: - Fix Version/s: (was: 0.10.0) 1.0.0 > Shade akka and protobuf dependencies

[jira] [Updated] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

[ https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2504: - Fix Version/s: (was: 0.10.0) 1.0.0 >

[jira] [Updated] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2608: - Fix Version/s: (was: 0.10.0) 1.0.0 > Arrays.asList(..) does not work with

[jira] [Updated] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0

[ https://issues.apache.org/jira/browse/FLINK-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2750: - Fix Version/s: (was: 0.10.0) 1.0.0 > FileStateHandleTest fails when

[jira] [Updated] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

[ https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2315: - Fix Version/s: (was: 0.10.0) 1.0.0 > Hadoop Writables cannot exploit

[jira] [Updated] (FLINK-2676) Add abstraction for keyed window state

[ https://issues.apache.org/jira/browse/FLINK-2676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2676: - Fix Version/s: (was: 0.10.0) 1.0.0 > Add abstraction for keyed window

[jira] [Updated] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries

[ https://issues.apache.org/jira/browse/FLINK-2263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2263: - Fix Version/s: (was: 0.10.0) 1.0.0 > ExecutionGraph uses Thread.sleep to

[jira] [Updated] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2732: - Fix Version/s: (was: 0.10.0) 1.0.0 > Add access to the TaskManagers' log

[jira] [Updated] (FLINK-2342) Add new fit operation and more tests for StandardScaler

[ https://issues.apache.org/jira/browse/FLINK-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2342: - Fix Version/s: (was: 0.10.0) 1.0.0 > Add new fit operation and more tests

[jira] [Updated] (FLINK-2719) ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2719: - Fix Version/s: (was: 0.10.0) 1.0.0 >

[jira] [Updated] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2752: - Fix Version/s: (was: 0.10.0) 1.0.0 > Documentation is not easily

[jira] [Updated] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2671: - Fix Version/s: (was: 0.10.0) 1.0.0 > Instable Test

[jira] [Updated] (FLINK-1513) Remove GlobalConfiguration Singleton

[ https://issues.apache.org/jira/browse/FLINK-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1513: - Fix Version/s: (was: 0.10.0) 1.0.0 > Remove GlobalConfiguration Singleton

[jira] [Updated] (FLINK-2838) Inconsistent use of URL and Path classes for resources

[ https://issues.apache.org/jira/browse/FLINK-2838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2838: - Fix Version/s: (was: 0.10.0) 1.0.0 > Inconsistent use of URL and Path

[jira] [Updated] (FLINK-2399) Fail when actor versions don't match

[ https://issues.apache.org/jira/browse/FLINK-2399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2399: - Fix Version/s: (was: 0.10.0) 1.0.0 > Fail when actor versions don't match

[jira] [Updated] (FLINK-2937) Typo in Quickstart->Scala API->Alternative Build Tools: SBT

[ https://issues.apache.org/jira/browse/FLINK-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2937: - Fix Version/s: (was: 0.10.0) 1.0.0 > Typo in Quickstart->Scala

[jira] [Updated] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2823: - Fix Version/s: (was: 0.10.0) 1.0.0 > YARN client should report a proper

[jira] [Updated] (FLINK-2667) Rework configuration parameters

[ https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2667: - Fix Version/s: (was: 0.10.0) 1.0.0 > Rework configuration parameters >

[jira] [Updated] (FLINK-987) Extend TypeSerializers and -Comparators to work directly on Memory Segments

[ https://issues.apache.org/jira/browse/FLINK-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-987: Fix Version/s: (was: 0.10.0) 1.0.0 > Extend TypeSerializers and -Comparators

[jira] [Updated] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException

[ https://issues.apache.org/jira/browse/FLINK-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1989: - Fix Version/s: (was: 0.10.0) 1.0.0 > Sorting of POJO data set from

[jira] [Updated] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext

[ https://issues.apache.org/jira/browse/FLINK-2524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2524: - Fix Version/s: (was: 0.10.0) 1.0.0 > Add "getTaskNameWithSubtasks()" to

[jira] [Updated] (FLINK-2674) Rework windowing logic

[ https://issues.apache.org/jira/browse/FLINK-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2674: - Fix Version/s: (was: 0.10.0) 1.0.0 > Rework windowing logic >

[jira] [Updated] (FLINK-2757) DataSinkTaskTest fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2757: - Fix Version/s: (was: 0.10.0) 1.0.0 > DataSinkTaskTest fails on Windows >

[jira] [Updated] (FLINK-2795) Print JobExecutionResult for interactively invoked jobs

[ https://issues.apache.org/jira/browse/FLINK-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2795: - Fix Version/s: (was: 0.10.0) 1.0.0 > Print JobExecutionResult for

[jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2662: - Fix Version/s: (was: 0.10.0) 1.0.0 > CompilerException: "Bug: Plan

[jira] [Updated] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2508: - Fix Version/s: (was: 0.10.0) 1.0.0 > Confusing sharing of

[jira] [Updated] (FLINK-2348) IterateExampleITCase failing

[ https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2348: - Fix Version/s: (was: 0.10.0) 1.0.0 > IterateExampleITCase failing >

[jira] [Updated] (FLINK-2351) Deprecate config builders in InputFormats and Output formats

[ https://issues.apache.org/jira/browse/FLINK-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2351: - Fix Version/s: (was: 0.10.0) 1.0.0 > Deprecate config builders in

[jira] [Updated] (FLINK-1240) We cannot use sortGroup on a global reduce

[ https://issues.apache.org/jira/browse/FLINK-1240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1240: - Fix Version/s: (was: 0.10.0) 1.0.0 > We cannot use sortGroup on a global

[jira] [Updated] (FLINK-1702) Authenticate via Kerberos from the client only

[ https://issues.apache.org/jira/browse/FLINK-1702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1702: - Fix Version/s: (was: 0.10.0) 1.0.0 > Authenticate via Kerberos from the

[jira] [Updated] (FLINK-1723) Add cross validation for model evaluation

[ https://issues.apache.org/jira/browse/FLINK-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1723: - Fix Version/s: (was: 0.10.0) 1.0.0 > Add cross validation for model

[jira] [Updated] (FLINK-2670) Unstable CombineTaskTest

[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2670: - Fix Version/s: (was: 0.10.0) 1.0.0 > Unstable CombineTaskTest >

[jira] [Updated] (FLINK-2680) Create a dedicated aligned-event time window operator

[ https://issues.apache.org/jira/browse/FLINK-2680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2680: - Fix Version/s: (was: 0.10.0) 1.0.0 > Create a dedicated aligned-event time

[jira] [Updated] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2646: - Fix Version/s: (was: 0.10.0) 1.0.0 > Rich functions should provide a

<    1   2   3   4   5   6   7   8   9   10   >