[jira] [Commented] (FLINK-3607) Decrease default forkCount for tests

[ https://issues.apache.org/jira/browse/FLINK-3607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15307824#comment-15307824 ] Maximilian Michels commented on FLINK-3607: --- Correct. > Decrease default forkCount for tests >

[jira] [Closed] (FLINK-3607) Decrease default forkCount for tests

[ https://issues.apache.org/jira/browse/FLINK-3607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3607. - Resolution: Fixed Fix Version/s: 1.1.0 Defaulting to the saner {{1C}} with

[jira] [Assigned] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

[ https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3937: - Assignee: Maximilian Michels > Make flink cli list, savepoint, cancel and stop

[jira] [Commented] (FLINK-3994) Instable KNNITSuite

[ https://issues.apache.org/jira/browse/FLINK-3994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15307607#comment-15307607 ] Maximilian Michels commented on FLINK-3994: --- Thanks [~chiwanpark]! > Instable KNNITSuite >

[jira] [Updated] (FLINK-3994) Instable KNNITSuite

[ https://issues.apache.org/jira/browse/FLINK-3994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3994: -- Fix Version/s: 1.1.0 > Instable KNNITSuite > --- > >

[jira] [Closed] (FLINK-3887) Improve dependency management for building docs

[ https://issues.apache.org/jira/browse/FLINK-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3887. - Resolution: Fixed Fix Version/s: 0.8.0 0.10.0

[jira] [Updated] (FLINK-3887) Improve dependency management for building docs

[ https://issues.apache.org/jira/browse/FLINK-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3887: -- Affects Version/s: 0.6-incubating 0.7.0-incubating

[jira] [Updated] (FLINK-3887) Improve dependency management for building docs

[ https://issues.apache.org/jira/browse/FLINK-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3887: -- Fix Version/s: 1.1.0 > Improve dependency management for building docs >

[jira] [Updated] (FLINK-3887) Improve dependency management for building docs

[ https://issues.apache.org/jira/browse/FLINK-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3887: -- Affects Version/s: 1.1.0 > Improve dependency management for building docs >

[jira] [Closed] (FLINK-3982) Multiple ResourceManagers register at JobManager in standalone HA mode

[ https://issues.apache.org/jira/browse/FLINK-3982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3982. - Resolution: Fixed Fixed with 1212b6d3ff676877f84a51e9c849f9e484297947 > Multiple

[jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics

[ https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306417#comment-15306417 ] Maximilian Michels commented on FLINK-3962: --- In the Yarn tests, I'm still seeing these

[jira] [Created] (FLINK-3982) Multiple ResourceManagers register at JobManager in standalone HA mode

Maximilian Michels created FLINK-3982: - Summary: Multiple ResourceManagers register at JobManager in standalone HA mode Key: FLINK-3982 URL: https://issues.apache.org/jira/browse/FLINK-3982

[jira] [Created] (FLINK-3981) Don't log duplicate TaskManager registrations as exceptions

Maximilian Michels created FLINK-3981: - Summary: Don't log duplicate TaskManager registrations as exceptions Key: FLINK-3981 URL: https://issues.apache.org/jira/browse/FLINK-3981 Project: Flink

[jira] [Closed] (FLINK-3972) Subclasses of ResourceID may not to be serializable

[ https://issues.apache.org/jira/browse/FLINK-3972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3972. - Resolution: Fixed Fixed via 4d41bd8fa787315d203bb34973f8608d84c5b6ac > Subclasses of

[jira] [Updated] (FLINK-3960) Disable, fix and re-enable EventTimeWindowCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3960: -- Summary: Disable, fix and re-enable EventTimeWindowCheckpointingITCase (was:

[jira] [Reopened] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault

[ https://issues.apache.org/jira/browse/FLINK-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-3960: --- Keeping this for the record to revert 98a939552e12fc699ff39111bbe877e112460ceb. >

[jira] [Created] (FLINK-3972) Subclasses of ResourceID may not to be serializable

Maximilian Michels created FLINK-3972: - Summary: Subclasses of ResourceID may not to be serializable Key: FLINK-3972 URL: https://issues.apache.org/jira/browse/FLINK-3972 Project: Flink

[jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics

[ https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300102#comment-15300102 ] Maximilian Michels commented on FLINK-3962: --- Thanks for looking into this! > JMXReporter

[jira] [Closed] (FLINK-3963) AbstractReporter uses shaded dependency

[ https://issues.apache.org/jira/browse/FLINK-3963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3963. - Resolution: Fixed Fixed via 5b9872492394026f3e6ac31b9937141ebedb1481 by replacing Netty's

[jira] [Reopened] (FLINK-3963) AbstractReporter uses shaded dependency

[ https://issues.apache.org/jira/browse/FLINK-3963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-3963: --- The import is still not correct and let's Hadoop 1 builds fail. > AbstractReporter uses

[jira] [Updated] (FLINK-2155) Add an additional checkstyle validation for illegal imports

[ https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2155: -- Fix Version/s: 1.1.0 > Add an additional checkstyle validation for illegal imports >

[jira] [Updated] (FLINK-2155) Add an additional checkstyle validation for illegal imports

[ https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2155: -- Affects Version/s: 1.1.0 > Add an additional checkstyle validation for illegal imports

[jira] [Closed] (FLINK-3963) AbstractReporter uses shaded dependency

[ https://issues.apache.org/jira/browse/FLINK-3963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3963. - Resolution: Fixed Fixed with cbee4ef20431be9d934a25ba89a801b16b4f85dd > AbstractReporter

[jira] [Reopened] (FLINK-2155) Add an additional checkstyle validation for illegal imports

[ https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-2155: --- Assignee: Kostas Kloudas (was: Lokesh Rajaram) The Checkstyle rule for checking

[jira] [Commented] (FLINK-3963) AbstractReporter uses shaded dependency

[ https://issues.apache.org/jira/browse/FLINK-3963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298035#comment-15298035 ] Maximilian Michels commented on FLINK-3963: --- Thanks for reporting [~kkl0u]. Do you want to open

[jira] [Created] (FLINK-3963) AbstractReporter uses shaded dependency

Maximilian Michels created FLINK-3963: - Summary: AbstractReporter uses shaded dependency Key: FLINK-3963 URL: https://issues.apache.org/jira/browse/FLINK-3963 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault

[ https://issues.apache.org/jira/browse/FLINK-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298010#comment-15298010 ] Maximilian Michels commented on FLINK-3960: --- Merged temporary fix which should be reverted once

[jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics

[ https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298008#comment-15298008 ] Maximilian Michels commented on FLINK-3962: --- [~Zentol] I assigned you because you had been

[jira] [Created] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics

Maximilian Michels created FLINK-3962: - Summary: JMXReporter doesn't properly register/deregister metrics Key: FLINK-3962 URL: https://issues.apache.org/jira/browse/FLINK-3962 Project: Flink

[jira] [Updated] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault

[ https://issues.apache.org/jira/browse/FLINK-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3960: -- Summary: EventTimeWindowCheckpointingITCase fails with a segmentation fault (was:

[jira] [Created] (FLINK-3960) EventTimeCheckpointingITCase fails with a segmentation fault

Maximilian Michels created FLINK-3960: - Summary: EventTimeCheckpointingITCase fails with a segmentation fault Key: FLINK-3960 URL: https://issues.apache.org/jira/browse/FLINK-3960 Project: Flink

[jira] [Closed] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match

[ https://issues.apache.org/jira/browse/FLINK-3927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3927. - Resolution: Fixed Fixed via 017106e140f3c17ebaaa0507e1dcbbc445c8f0ac > TaskManager

[jira] [Closed] (FLINK-3953) Surefire plugin executes unit tests twice

[ https://issues.apache.org/jira/browse/FLINK-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3953. - Resolution: Fixed Fixed via 5fdf39b1fec032f5816cb188334c129ff9186415 > Surefire plugin

[jira] [Commented] (FLINK-3953) Surefire plugin executes unit tests twice

[ https://issues.apache.org/jira/browse/FLINK-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296185#comment-15296185 ] Maximilian Michels commented on FLINK-3953: --- Follow-up of FLINK-3909. > Surefire plugin

[jira] [Created] (FLINK-3953) Surefire plugin executes unit tests twice

Maximilian Michels created FLINK-3953: - Summary: Surefire plugin executes unit tests twice Key: FLINK-3953 URL: https://issues.apache.org/jira/browse/FLINK-3953 Project: Flink Issue

[jira] [Closed] (FLINK-3893) LeaderChangeStateCleanupTest times out

[ https://issues.apache.org/jira/browse/FLINK-3893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3893. - Resolution: Fixed Fix Version/s: 1.1.0 9b8de6a6cb3b1cc9ebeb623371e7fef3a6cb763d >

[jira] [Closed] (FLINK-3938) Yarn tests don't run on the current master

[ https://issues.apache.org/jira/browse/FLINK-3938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3938. - Resolution: Fixed 9a4fdd5fb3a7097035e74b0bf685553bbfdf7f43 > Yarn tests don't run on the

[jira] [Closed] (FLINK-3892) ConnectionUtils may die with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-3892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3892. - Resolution: Fixed 5dfb8a013cbf769bee641c04ebc666a8dc2f3e14 > ConnectionUtils may die

[jira] [Closed] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests

[ https://issues.apache.org/jira/browse/FLINK-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3909. - Resolution: Fixed 38698c0b101cbb48f8c10adf4060983ac07e2f4b > Maven Failsafe plugin may

[jira] [Created] (FLINK-3938) Yarn tests don't run on the current master

Maximilian Michels created FLINK-3938: - Summary: Yarn tests don't run on the current master Key: FLINK-3938 URL: https://issues.apache.org/jira/browse/FLINK-3938 Project: Flink Issue

[jira] [Commented] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently

[ https://issues.apache.org/jira/browse/FLINK-3863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15290870#comment-15290870 ] Maximilian Michels commented on FLINK-3863: --- Fixing this with FLINK-3667. > Yarn Cluster

[jira] [Closed] (FLINK-3543) Introduce ResourceManager component

[ https://issues.apache.org/jira/browse/FLINK-3543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3543. - Resolution: Implemented Closing this because we have the ResourceManager in place. >

[jira] [Commented] (FLINK-3543) Introduce ResourceManager component

[ https://issues.apache.org/jira/browse/FLINK-3543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15290858#comment-15290858 ] Maximilian Michels commented on FLINK-3543: --- Hi! Scheduling is not part of the ResourceManager.

[jira] [Created] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match

Maximilian Michels created FLINK-3927: - Summary: TaskManager registration may fail if Yarn versions don't match Key: FLINK-3927 URL: https://issues.apache.org/jira/browse/FLINK-3927 Project:

[jira] [Updated] (FLINK-3661) Make Scala 2.11.x the default Scala version

[ https://issues.apache.org/jira/browse/FLINK-3661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3661: -- Assignee: (was: Robert Metzger) > Make Scala 2.11.x the default Scala version >

[jira] [Updated] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2821: -- Assignee: (was: Robert Metzger) > Change Akka configuration to allow accessing

[jira] [Updated] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x

[ https://issues.apache.org/jira/browse/FLINK-3662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3662: -- Assignee: (was: Robert Metzger) > Bump Akka version to 2.4.x for Scala 2.11.x >

[jira] [Commented] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests

[ https://issues.apache.org/jira/browse/FLINK-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286742#comment-15286742 ] Maximilian Michels commented on FLINK-3909: --- Failing tests are not supposed to fail the entire

[jira] [Assigned] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests

[ https://issues.apache.org/jira/browse/FLINK-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3909: - Assignee: Maximilian Michels > Maven Failsafe plugin may report SUCCESS on

[jira] [Resolved] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3701. --- Resolution: Fixed Fixed in 48b469ad4f0da466b347071cea82913965645de3. > Cant call

[jira] [Created] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests

Maximilian Michels created FLINK-3909: - Summary: Maven Failsafe plugin may report SUCCESS on failed tests Key: FLINK-3909 URL: https://issues.apache.org/jira/browse/FLINK-3909 Project: Flink

[jira] [Commented] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp

[ https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282843#comment-15282843 ] Maximilian Michels commented on FLINK-3856: --- There is something wrong with our Maven

[jira] [Commented] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp

[ https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282839#comment-15282839 ] Maximilian Michels commented on FLINK-3856: --- Additional fix with

[jira] [Commented] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp

[ https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282696#comment-15282696 ] Maximilian Michels commented on FLINK-3856: --- This breaks

[jira] [Commented] (FLINK-3887) Improve dependency management for building docs

[ https://issues.apache.org/jira/browse/FLINK-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282554#comment-15282554 ] Maximilian Michels commented on FLINK-3887: --- The related Infra issue > Improve dependency

[jira] [Created] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded

Maximilian Michels created FLINK-3904: - Summary: GlobalConfiguration doesn't ensure config has been loaded Key: FLINK-3904 URL: https://issues.apache.org/jira/browse/FLINK-3904 Project: Flink

[jira] [Resolved] (FLINK-3776) Flink Scala shell does not allow to set configuration for local execution

[ https://issues.apache.org/jira/browse/FLINK-3776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3776. --- Resolution: Fixed Assignee: Dongwon Kim Fix Version/s: 1.1.0 Fixed

[jira] [Resolved] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode()

[ https://issues.apache.org/jira/browse/FLINK-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3733. --- Resolution: Duplicate Assignee: Maximilian Michels >

[jira] [Commented] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode()

[ https://issues.apache.org/jira/browse/FLINK-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15280193#comment-15280193 ] Maximilian Michels commented on FLINK-3733: --- I think this might be a duplicate of FLINK-3701. >

[jira] [Commented] (FLINK-3893) LeaderChangeStateCleanupTest times out

[ https://issues.apache.org/jira/browse/FLINK-3893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15278245#comment-15278245 ] Maximilian Michels commented on FLINK-3893: --- After fixing this, I get the following: {noformat}

[jira] [Created] (FLINK-3893) LeaderChangeStateCleanupTest times out

Maximilian Michels created FLINK-3893: - Summary: LeaderChangeStateCleanupTest times out Key: FLINK-3893 URL: https://issues.apache.org/jira/browse/FLINK-3893 Project: Flink Issue Type:

[jira] [Created] (FLINK-3892) ConnectionUtils may die with NullPointerException

Maximilian Michels created FLINK-3892: - Summary: ConnectionUtils may die with NullPointerException Key: FLINK-3892 URL: https://issues.apache.org/jira/browse/FLINK-3892 Project: Flink

[jira] [Created] (FLINK-3890) Deprecate streaming mode flag from Yarn CLI

Maximilian Michels created FLINK-3890: - Summary: Deprecate streaming mode flag from Yarn CLI Key: FLINK-3890 URL: https://issues.apache.org/jira/browse/FLINK-3890 Project: Flink Issue

[jira] [Resolved] (FLINK-3880) Improve performance of Accumulator map

[ https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3880. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed with

[jira] [Created] (FLINK-3887) Improve dependency management for building docs

Maximilian Michels created FLINK-3887: - Summary: Improve dependency management for building docs Key: FLINK-3887 URL: https://issues.apache.org/jira/browse/FLINK-3887 Project: Flink

[jira] [Updated] (FLINK-3880) Improve performance of Accumulator map

[ https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3880: -- Summary: Improve performance of Accumulator map (was: Use ConcurrentHashMap for

[jira] [Commented] (FLINK-3880) Use ConcurrentHashMap for Accumulators

[ https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15274298#comment-15274298 ] Maximilian Michels commented on FLINK-3880: --- You're right, the synchronized map is a bottle

[jira] [Assigned] (FLINK-3880) Use ConcurrentHashMap for Accumulators

[ https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3880: - Assignee: Maximilian Michels > Use ConcurrentHashMap for Accumulators >

[jira] [Updated] (FLINK-3876) Improve documentation of Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3876: -- Fix Version/s: (was: 1.0.3) > Improve documentation of Scala Shell >

[jira] [Closed] (FLINK-3876) Improve documentation of Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3876. - Resolution: Fixed Fixed in 8ec47f17be0b20e5204d309f72b0bec9b234a7fb > Improve

[jira] [Updated] (FLINK-3876) Improve documentation of Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3876: -- Affects Version/s: (was: 1.0.3) > Improve documentation of Scala Shell >

[jira] [Created] (FLINK-3876) Improve documentation of Scala Shell

Maximilian Michels created FLINK-3876: - Summary: Improve documentation of Scala Shell Key: FLINK-3876 URL: https://issues.apache.org/jira/browse/FLINK-3876 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270497#comment-15270497 ] Maximilian Michels commented on FLINK-2821: --- Awww, that's unfortunate :( I wonder, would it make

[jira] [Updated] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3864: -- Description: {{YarnTestBase.runWithArgs(...)}} provides a parameter for strings which

[jira] [Updated] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3864: -- Summary: Yarn tests don't check for prohibited strings in log output (was: Yarn

[jira] [Updated] (FLINK-3864) Yarn per-job cluster sets parallelism to 1 instead of #taskmanagers * #slots

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3864: -- Description: {{YarnTestBase.runWithArgs(...)}} provides a parameter for strings which

[jira] [Updated] (FLINK-3864) Yarn per-job cluster sets parallelism to 1 instead of #taskmanagers * #slots

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3864: -- Summary: Yarn per-job cluster sets parallelism to 1 instead of #taskmanagers * #slots

[jira] [Created] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

Maximilian Michels created FLINK-3864: - Summary: Yarn tests don't check for prohibited strings in log output Key: FLINK-3864 URL: https://issues.apache.org/jira/browse/FLINK-3864 Project: Flink

[jira] [Created] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently

Maximilian Michels created FLINK-3863: - Summary: Yarn Cluster shutdown may fail if leader changed recently Key: FLINK-3863 URL: https://issues.apache.org/jira/browse/FLINK-3863 Project: Flink

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268708#comment-15268708 ] Maximilian Michels commented on FLINK-2821: --- Sure, go ahead! > Change Akka configuration to

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268379#comment-15268379 ] Maximilian Michels commented on FLINK-1984: --- Great news :) > Integrate Flink with Apache Mesos

[jira] [Resolved] (FLINK-3601) JobManagerTest times out on StopSignal test

[ https://issues.apache.org/jira/browse/FLINK-3601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3601. --- Resolution: Fixed Fix Version/s: 1.1.0 Thanks for the reminder! Had a fix

[jira] [Closed] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode

[ https://issues.apache.org/jira/browse/FLINK-3824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3824. - Resolution: Fixed Fixed with 7ec1300a740e9b8e1eb595bc15e752a167592e00. > ResourceManager

[jira] [Created] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode

Maximilian Michels created FLINK-3824: - Summary: ResourceManager may repeatedly connect to outdated JobManager in HA mode Key: FLINK-3824 URL: https://issues.apache.org/jira/browse/FLINK-3824

[jira] [Updated] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3701: -- Fix Version/s: 1.1.0 > Cant call execute after first execution >

[jira] [Updated] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3701: -- Affects Version/s: 1.1.0 > Cant call execute after first execution >

[jira] [Created] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods

Maximilian Michels created FLINK-3796: - Summary: FileSourceFunction doesn't respect InputFormat's life cycle methods Key: FLINK-3796 URL: https://issues.apache.org/jira/browse/FLINK-3796

[jira] [Commented] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247644#comment-15247644 ] Maximilian Michels commented on FLINK-3701: --- The issue is that the serializer lists in the

[jira] [Assigned] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3701: - Assignee: Maximilian Michels > Cant call execute after first execution >

[jira] [Closed] (FLINK-1427) Configuration through environment variables

[ https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-1427. - Resolution: Won't Fix Thanks, closing for now. > Configuration through environment

[jira] [Resolved] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell

[ https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2522. --- Resolution: Implemented Fix Version/s: 1.1.0 Implemented with

[jira] [Closed] (FLINK-3529) Add pull request template

[ https://issues.apache.org/jira/browse/FLINK-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3529. - Resolution: Implemented Merged with 24f89b7f1695ee095a2a161990bdcfd8c09283a5 > Add pull

[jira] [Commented] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227912#comment-15227912 ] Maximilian Michels commented on FLINK-3689: --- Another follow-up fixed by

[jira] [Comment Edited] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226474#comment-15226474 ] Maximilian Michels edited comment on FLINK-3655 at 4/5/16 3:37 PM: ---

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226474#comment-15226474 ] Maximilian Michels commented on FLINK-3655: --- Sounds good. It is important to maintain backwards

[jira] [Closed] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3686. - Resolution: Duplicate Assignee: Maximilian Michels Thanks for reporting! The issue

[jira] [Resolved] (FLINK-3638) Invalid default ports in documentation

[ https://issues.apache.org/jira/browse/FLINK-3638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3638. --- Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 1.0.0

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15223797#comment-15223797 ] Maximilian Michels commented on FLINK-3655: --- Hi! Great. Feel free to open a PR. The PR should

[jira] [Closed] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3689. - Resolution: Fixed Fixed in c2f2122c0ba0d0b16eb59aa3ad7958c72fb486b7 > JobManager blocks

[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication

[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15222084#comment-15222084 ] Maximilian Michels commented on FLINK-3667: --- The clients don't communicate directly with the

<    4   5   6   7   8   9   10   11   12   13   >