[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

[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

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

[jira] [Commented] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster

[ https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006649#comment-15006649 ] ASF GitHub Bot commented on FLINK-2977: --- Github user asfgit closed the pull request at:

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

[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

[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

[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

[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

[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

[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

[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()"

[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

[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

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

[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

[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

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

[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

[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

[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

[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

[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=15006713#comment-15006713 ] ASF GitHub Bot commented on FLINK-2978: --- Github user gyfora commented on the pull request:

[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

[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

[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

[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=15006740#comment-15006740 ] ASF GitHub Bot commented on FLINK-2978: --- Github user sachingoel0101 commented on the pull request:

[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=15006754#comment-15006754 ] ASF GitHub Bot commented on FLINK-2978: --- Github user gyfora commented on the pull request:

[GitHub] flink pull request: [FLINK-2977] Added support for accessing a Ker...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1342 --- 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 enabled and wishes so, or if the feature is

[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=15007003#comment-15007003 ] Maximilian Michels commented on FLINK-3020: --- Just saw, this is already the case for the batch

[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

[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

[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

[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=15007126#comment-15007126 ] ASF GitHub Bot commented on FLINK-3013: --- Github user hsaputra commented on the pull request:

[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

[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

[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=15007134#comment-15007134 ] ASF GitHub Bot commented on FLINK-2441: --- Github user hsaputra commented on the pull request:

[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=15006961#comment-15006961 ] jun aoki commented on FLINK-3009: - Is the community interested in dockerizing Jekyll and doc generation?

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

[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: $

[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=15007410#comment-15007410 ] Stephan Ewen commented on FLINK-3009: - I think that would actually be very nice! If you would

[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

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

[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=15007263#comment-15007263 ] ASF GitHub Bot commented on FLINK-2967: --- GitHub user rmetzger opened a pull request:

[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=15007250#comment-15007250 ] ASF GitHub Bot commented on FLINK-3013: --- Github user smarthi commented on the pull request:

[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

[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=15007584#comment-15007584 ] jun aoki commented on FLINK-3009: - [~StephanEwen], how about here flink/docs/docker/Dockerfile ? I will

[GitHub] flink pull request: FLINK-3017: Fix broken 'Slots' link on Streami...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1357 --- 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 enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide

[ https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006562#comment-15006562 ] ASF GitHub Bot commented on FLINK-3017: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide

[ https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006563#comment-15006563 ] Matthias J. Sax commented on FLINK-3017: Fixed via feb6994ffca04e4b7ad6174ca08048ea452e19f6

[jira] [Closed] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide

[ https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-3017. -- > Broken 'Slots' link on Streaming Programming Guide >

[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=15007974#comment-15007974 ] ASF GitHub Bot commented on FLINK-2914: --- Github user hsaputra commented on the pull request:

  1   2   >