[jira] [Commented] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent()

[ https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007974#comment-15007974 ] ASF GitHub Bot commented on FLINK-2914: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: [FLINK-2914] Add missing break Statement in ZK...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1359#issuecomment-157262540 Any way to test for this fix? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[jira] [Commented] (FLINK-2956) Migrate integration tests for Table API

[ https://issues.apache.org/jira/browse/FLINK-2956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007842#comment-15007842 ] ASF GitHub Bot commented on FLINK-2956: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-2956] [tests] Migrate integration tests...

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1349#issuecomment-157239452 Okay I'll review soon. Thanks for update. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your proj

[GitHub] flink pull request: [FLINK-2956] [tests] Migrate integration tests...

Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1349#issuecomment-157236280 Hi, @chiwanpark . I have modified the code and submitted a new commit. Can you help me with review work? --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-2956) Migrate integration tests for Table API

[ https://issues.apache.org/jira/browse/FLINK-2956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007815#comment-15007815 ] ASF GitHub Bot commented on FLINK-2956: --- Github user gallenvara commented on the pul

[jira] [Commented] (FLINK-2956) Migrate integration tests for Table API

[ https://issues.apache.org/jira/browse/FLINK-2956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007814#comment-15007814 ] ASF GitHub Bot commented on FLINK-2956: --- Github user gallenvara commented on the pul

[GitHub] flink pull request: [FLINK-2956] [tests] Migrate integration tests...

Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1349#issuecomment-157236045 Hi, @chiwanpark . I have modified the code and committed a new commit. Can you help me with review work? --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-3009) Cannot build docs with Jekyll 3.0.0

[ https://issues.apache.org/jira/browse/FLINK-3009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007584#comment-15007584 ] jun aoki commented on FLINK-3009: - [~StephanEwen], how about here flink/docs/docker/Docke

[GitHub] flink pull request: Change the parameter 'numSample' in DataSetUti...

GitHub user smarthi opened a pull request: https://github.com/apache/flink/pull/1362 Change the parameter 'numSample' in DataSetUtils.sampleWithSize() to … …'numSamples', and remove redundant Java 6 code You can merge this pull request into a Git repository by running: $ gi

[jira] [Commented] (FLINK-3009) Cannot build docs with Jekyll 3.0.0

[ https://issues.apache.org/jira/browse/FLINK-3009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007410#comment-15007410 ] Stephan Ewen commented on FLINK-3009: - I think that would actually be very nice! If y

[jira] [Commented] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs

[ https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007263#comment-15007263 ] ASF GitHub Bot commented on FLINK-2967: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-2967] Enhance TaskManager network detec...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1361 [FLINK-2967] Enhance TaskManager network detection JIRA: https://issues.apache.org/jira/browse/FLINK-2967 - Increase timeout for `LOCAL_HOST` address detection strategy - give the local

[GitHub] flink pull request: FLINK-3013: Incorrect package declaration in G...

Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/1356#issuecomment-157158385 Updated the PR title and description --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-3013) Incorrect package declaration in GellyScalaAPICompletenessTest.scala

[ https://issues.apache.org/jira/browse/FLINK-3013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007250#comment-15007250 ] ASF GitHub Bot commented on FLINK-3013: --- Github user smarthi commented on the pull r

[GitHub] flink pull request: minor javadoc fix in JobManager

Github user jaoki commented on the pull request: https://github.com/apache/flink/pull/1358#issuecomment-157143864 @mxm for sure will send to the community once it is done. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-2441) [py] Introduce an OpInfo object on the python side

[ https://issues.apache.org/jira/browse/FLINK-2441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007134#comment-15007134 ] ASF GitHub Bot commented on FLINK-2441: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: [FLINK-2441] Introduce Python OperationInfo

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1352#issuecomment-157137646 LGTM +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-3013) Incorrect package declaration in GellyScalaAPICompletenessTest.scala

[ https://issues.apache.org/jira/browse/FLINK-3013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007126#comment-15007126 ] ASF GitHub Bot commented on FLINK-3013: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: FLINK-3013: Incorrect package declaration in G...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1356#issuecomment-157136261 Thanks for the PR =) There seems like some extra changes which not related to changing the package declaration which related to code clean up. We prefer to have

[GitHub] flink pull request: minor javadoc fix in JobManager

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1358#issuecomment-157126156 Yes, that's correct. Nice diagram :) Could you post it to the mailing list when you're finished? Thank you! --- If your project is set up for it, you can reply to this emai

[jira] [Commented] (FLINK-3020) Local streaming execution: set number of task manager slots to the maximum parallelism

[ https://issues.apache.org/jira/browse/FLINK-3020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007041#comment-15007041 ] ASF GitHub Bot commented on FLINK-3020: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-3020][streaming] set local default para...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1360 [FLINK-3020][streaming] set local default parallelism to maxmium parallelism You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-3020 A

[jira] [Commented] (FLINK-3020) Local execution: set number of task manager slots to the maximum parallelism

[ https://issues.apache.org/jira/browse/FLINK-3020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007003#comment-15007003 ] Maximilian Michels commented on FLINK-3020: --- Just saw, this is already the case

[jira] [Updated] (FLINK-3020) Local streaming execution: set number of task manager slots to the maximum parallelism

[ https://issues.apache.org/jira/browse/FLINK-3020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3020: -- Summary: Local streaming execution: set number of task manager slots to the maximum para

[jira] [Created] (FLINK-3020) Local execution: set number of task manager slots to the maximum parallelism

Maximilian Michels created FLINK-3020: - Summary: Local execution: set number of task manager slots to the maximum parallelism Key: FLINK-3020 URL: https://issues.apache.org/jira/browse/FLINK-3020

[jira] [Commented] (FLINK-3009) Cannot build docs with Jekyll 3.0.0

[ https://issues.apache.org/jira/browse/FLINK-3009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006961#comment-15006961 ] jun aoki commented on FLINK-3009: - Is the community interested in dockerizing Jekyll and d

[jira] [Created] (FLINK-3019) CLI does not list running/restarting jobs

Ufuk Celebi created FLINK-3019: -- Summary: CLI does not list running/restarting jobs Key: FLINK-3019 URL: https://issues.apache.org/jira/browse/FLINK-3019 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line

[ https://issues.apache.org/jira/browse/FLINK-3011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-3011: --- Priority: Critical (was: Major) > Cannot cancel failing/restarting streaming job from the command lin

[jira] [Assigned] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line

[ https://issues.apache.org/jira/browse/FLINK-3011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-3011: -- Assignee: Ufuk Celebi > Cannot cancel failing/restarting streaming job from the command line >

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1338#issuecomment-157061461 I will probably do this for future runs. :+1: --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your pro

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

[ https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006754#comment-15006754 ] ASF GitHub Bot commented on FLINK-2978: --- Github user gyfora commented on the pull re

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

[ https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006740#comment-15006740 ] ASF GitHub Bot commented on FLINK-2978: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1338#issuecomment-157056790 @gyfora this is the PR I was talking about regarding your *connection reset* exception. If you want, you can add the `PipelineErrorHandler` at the end of current

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

[ https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006713#comment-15006713 ] ASF GitHub Bot commented on FLINK-2978: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1338#issuecomment-157045679 I am excited to see this in as well :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project doe

[jira] [Updated] (FLINK-2344) Deprecate/Remove the old Pact Pair type

[ https://issues.apache.org/jira/browse/FLINK-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2344: - Fix Version/s: (was: 0.10.0) 1.0.0 > Deprecate/Remove the old Pact Pair typ

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

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

[jira] [Updated] (FLINK-2799) Yarn tests cannot be executed with DEBUG log level

[ https://issues.apache.org/jira/browse/FLINK-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2799: - Fix Version/s: (was: 0.10.0) 1.0.0 > Yarn tests cannot be executed with DEB

[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: - Fix Version/s: (was: 0.10.0) > Dangling operators in web UI's program visualization (non-deter

[jira] [Updated] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

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

[jira] [Updated] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type

[ https://issues.apache.org/jira/browse/FLINK-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2788: - Fix Version/s: (was: 0.10.0) 1.0.0 > Add type hint with TypeExtactor call o

[jira] [Updated] (FLINK-2573) Add Kerberos test case

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

[jira] [Updated] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant

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

[jira] [Updated] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility

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

[jira] [Updated] (FLINK-2392) Instable test in flink-yarn-tests

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

[jira] [Updated] (FLINK-2239) print() on DataSet: stream results and print incrementally

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

[jira] [Updated] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement

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

[jira] [Updated] (FLINK-2759) TaskManagerProcessReapingTest fails on Windows

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

[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 method

[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 Run

[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-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 generati

[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 cli

[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 evaluat

[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-2803) Add test case for Flink's memory allocation

[ https://issues.apache.org/jira/browse/FLINK-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2803: - Fix Version/s: (was: 0.10.0) 1.0.0 > Add test case for Flink's memory alloc

[jira] [Updated] (FLINK-2185) Rework semantics for .setSeed function of SVM

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

[jira] [Updated] (FLINK-1278) Remove the Record special code paths

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

[jira] [Updated] (FLINK-2739) Release script depends on the order of parent module information

[ https://issues.apache.org/jira/browse/FLINK-2739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2739: - Fix Version/s: (was: 0.10.0) 1.0.0 > Release script depends on the order of

[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 exc

[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 t

[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 TableEnv

[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 StreamExecutionEn

[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 InputForm

[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 re

[jira] [Updated] (FLINK-2586) Unstable Storm Compatibility Tests

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

[jira] [Updated] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis

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

[jira] [Updated] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream

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

[jira] [Updated] (FLINK-2518) Avoid predetermination of ports for network services

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

[jira] [Updated] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

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

[jira] [Updated] (FLINK-1778) Improve normalized keys in composite key case

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

[jira] [Updated] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api

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

[jira] [Updated] (FLINK-2491) Operators are not participating in state checkpointing in some cases

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

[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 f

[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 > ProcessFailureStreamingRecoveryITCase>

[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 differenti

[jira] [Updated] (FLINK-2523) Make task canceling interrupt interval configurable

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

[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 StreamCheckpointNotifier

[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 API->Alterna

[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 interacti

[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-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 buildin

[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 implem

[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 state

[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 de

[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 fi

[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 class

[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 algorit

[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 lib

[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 > ExternalSortLargeRecordsITCase.testSor

[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 C

[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 > KafkaITCase.testConcurrentProducerCons

[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 dashbo

[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 messa

  1   2   >