[jira] [Resolved] (FLINK-1546) Failed job causes JobManager to shutdown due to uncatched WebFrontend exception

[ https://issues.apache.org/jira/browse/FLINK-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1546. - Resolution: Fixed Fix Version/s: 0.9 Job Archiving was fixed in

[jira] [Commented] (FLINK-1635) Remove Apache Thrift dependency from Flink

[ https://issues.apache.org/jira/browse/FLINK-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366023#comment-14366023 ] Stephan Ewen commented on FLINK-1635: - [~rmetzger] This is removed an fixed, if I

[jira] [Resolved] (FLINK-1584) Spurious failure of TaskManagerFailsITCase

[ https://issues.apache.org/jira/browse/FLINK-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1584. - Resolution: Fixed Fixed with the switch to the newer akka version (enabled by shading away

[jira] [Commented] (FLINK-1500) exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis

[ https://issues.apache.org/jira/browse/FLINK-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366001#comment-14366001 ] Stephan Ewen commented on FLINK-1500: - Have we seen this again, or was this an

[jira] [Updated] (FLINK-1535) Use usercode class loader to serialize/deserialize accumulators

[ https://issues.apache.org/jira/browse/FLINK-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1535: Priority: Blocker (was: Major) Use usercode class loader to serialize/deserialize accumulators

[jira] [Resolved] (FLINK-1459) Collect DataSet to client

[ https://issues.apache.org/jira/browse/FLINK-1459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1459. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen This has been

[jira] [Commented] (FLINK-1467) Job deployment fails with NPE on JobManager, if TMs did not start properly

[ https://issues.apache.org/jira/browse/FLINK-1467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366026#comment-14366026 ] Stephan Ewen commented on FLINK-1467: - The null-pointer exception has fixed in one of

[jira] [Resolved] (FLINK-947) Add support for Named Datasets

[ https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-947. Resolution: Fixed Fix Version/s: 0.9 Merged under {{flink-staging/flink-expressions}} Add

[jira] [Resolved] (FLINK-1018) Logistic Regression deadlocks

[ https://issues.apache.org/jira/browse/FLINK-1018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1018. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 9c77f0785e43326521da5e535f9ab1f05a9c6280

[jira] [Resolved] (FLINK-952) TypeExtractor requires the argument types of the UDF to be identical to the parameter types

[ https://issues.apache.org/jira/browse/FLINK-952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-952. Resolution: Fixed Fix Version/s: 0.9 Fixed with the introduction of the subclass aware pojo

[jira] [Resolved] (FLINK-1090) Join deadlocks when used inside Delta iteration

[ https://issues.apache.org/jira/browse/FLINK-1090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1090. - Resolution: Fixed Fix Version/s: 0.9 Solved via 9c77f0785e43326521da5e535f9ab1f05a9c6280

[jira] [Resolved] (FLINK-1088) Iteration head deadlock

[ https://issues.apache.org/jira/browse/FLINK-1088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1088. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 9c77f0785e43326521da5e535f9ab1f05a9c6280

[jira] [Created] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

Stephan Ewen created FLINK-1756: --- Summary: Rename Stream Monitoring to Stream Checkpointing Key: FLINK-1756 URL: https://issues.apache.org/jira/browse/FLINK-1756 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1710) Expression API Tests take very long

[ https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14371133#comment-14371133 ] Stephan Ewen commented on FLINK-1710: - Maybe there are some known tweaks / best

[jira] [Commented] (FLINK-1430) Add test for streaming scala api completeness

[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14371256#comment-14371256 ] Stephan Ewen commented on FLINK-1430: - The completeness test is to ensure that the

[jira] [Commented] (FLINK-1759) Execution statistics for vertex-centric iterations

[ https://issues.apache.org/jira/browse/FLINK-1759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14371300#comment-14371300 ] Stephan Ewen commented on FLINK-1759: - Robert has started an effort to integrate more

[jira] [Resolved] (FLINK-1760) Add support for building Flink with Scala 2.11

[ https://issues.apache.org/jira/browse/FLINK-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1760. - Resolution: Fixed Fixed via 2cd5e93daa9dc7b1e024ec7c1f1fc665f953510a Add support for building

[jira] [Created] (FLINK-1762) Make Statefulness of a Streaming Function explicit

Stephan Ewen created FLINK-1762: --- Summary: Make Statefulness of a Streaming Function explicit Key: FLINK-1762 URL: https://issues.apache.org/jira/browse/FLINK-1762 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-974) TaskManager startup script does not respect JAVA_HOME

[ https://issues.apache.org/jira/browse/FLINK-974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-974. Resolution: Invalid This is invalid. The taskmanager takes the JAVA home from its environment. In a

[jira] [Resolved] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc

[ https://issues.apache.org/jira/browse/FLINK-1720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1720. - Resolution: Fixed Fixed via ce39c190a2befa837fd03436a8420d40edf8d713 Integrate ScalaDoc in

[jira] [Created] (FLINK-1760) Add support for building Flink with Scala 2.11

Stephan Ewen created FLINK-1760: --- Summary: Add support for building Flink with Scala 2.11 Key: FLINK-1760 URL: https://issues.apache.org/jira/browse/FLINK-1760 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14371673#comment-14371673 ] Stephan Ewen commented on FLINK-1764: - The chained filter invokable does that in my

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14371706#comment-14371706 ] Stephan Ewen commented on FLINK-1764: - I think that very much depends on the contract

[jira] [Created] (FLINK-1765) Reducer grouping is skippted when parallelism is one

Stephan Ewen created FLINK-1765: --- Summary: Reducer grouping is skippted when parallelism is one Key: FLINK-1765 URL: https://issues.apache.org/jira/browse/FLINK-1765 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1710) Expression API Tests take very long

[ https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14371543#comment-14371543 ] Stephan Ewen commented on FLINK-1710: - That would be a major rewrite, I guess? Is

[jira] [Created] (FLINK-1763) Remove cancel from streaming SinkFunction

Stephan Ewen created FLINK-1763: --- Summary: Remove cancel from streaming SinkFunction Key: FLINK-1763 URL: https://issues.apache.org/jira/browse/FLINK-1763 Project: Flink Issue Type:

[jira] [Created] (FLINK-1764) Rework record copying logic in streaming API

Stephan Ewen created FLINK-1764: --- Summary: Rework record copying logic in streaming API Key: FLINK-1764 URL: https://issues.apache.org/jira/browse/FLINK-1764 Project: Flink Issue Type:

[jira] [Created] (FLINK-1668) Add a config option to specify delays between restarts

Stephan Ewen created FLINK-1668: --- Summary: Add a config option to specify delays between restarts Key: FLINK-1668 URL: https://issues.apache.org/jira/browse/FLINK-1668 Project: Flink Issue

[jira] [Created] (FLINK-1667) Add tests for recovery with distributed process failure

Stephan Ewen created FLINK-1667: --- Summary: Add tests for recovery with distributed process failure Key: FLINK-1667 URL: https://issues.apache.org/jira/browse/FLINK-1667 Project: Flink Issue

[jira] [Commented] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14357146#comment-14357146 ] Stephan Ewen commented on FLINK-1690: - I will create a patch with increased timeout...

[jira] [Created] (FLINK-1691) Inprove CountCollectITCase

Stephan Ewen created FLINK-1691: --- Summary: Inprove CountCollectITCase Key: FLINK-1691 URL: https://issues.apache.org/jira/browse/FLINK-1691 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-1671) Add execution modes for programs

Stephan Ewen created FLINK-1671: --- Summary: Add execution modes for programs Key: FLINK-1671 URL: https://issues.apache.org/jira/browse/FLINK-1671 Project: Flink Issue Type: Bug Affects

[jira] [Commented] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14357144#comment-14357144 ] Stephan Ewen commented on FLINK-1690: - I retract my statement. After careful log

[jira] [Resolved] (FLINK-1648) Add a mode where the system automatically sets the parallelism to the available task slots

[ https://issues.apache.org/jira/browse/FLINK-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1648. - Resolution: Implemented Implemented in d8d642fd6d7d9b8526325d4efff1015f636c5ddb Add a mode

[jira] [Created] (FLINK-1705) InstanceConnectionInfo returns wrong hostname when no DNS entry exists

Stephan Ewen created FLINK-1705: --- Summary: InstanceConnectionInfo returns wrong hostname when no DNS entry exists Key: FLINK-1705 URL: https://issues.apache.org/jira/browse/FLINK-1705 Project: Flink

[jira] [Commented] (FLINK-1106) Deprecate old Record API

[ https://issues.apache.org/jira/browse/FLINK-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14355063#comment-14355063 ] Stephan Ewen commented on FLINK-1106: - A bit of test coverage depends on the

[jira] [Created] (FLINK-1675) Rework Accumulators

Stephan Ewen created FLINK-1675: --- Summary: Rework Accumulators Key: FLINK-1675 URL: https://issues.apache.org/jira/browse/FLINK-1675 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-1659) Rename classes and packages that contains Pact

[ https://issues.apache.org/jira/browse/FLINK-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360185#comment-14360185 ] Stephan Ewen commented on FLINK-1659: - I am working on getting the configurable data

[jira] [Updated] (FLINK-441) Renaming in pact-compiler

[ https://issues.apache.org/jira/browse/FLINK-441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-441: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-1659 Renaming in pact-compiler

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360230#comment-14360230 ] Stephan Ewen commented on FLINK-1650: - I this YARN specific? Does the shading affect

[jira] [Resolved] (FLINK-1668) Add a config option to specify delays between restarts

[ https://issues.apache.org/jira/browse/FLINK-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1668. - Resolution: Implemented Implemented in abbb0a93ca67da17197dc5372e6d95edd8149d44 Add a config

[jira] [Commented] (FLINK-1776) APIs provide invalid Semantic Properties for Operators with SelectorFunction keys

[ https://issues.apache.org/jira/browse/FLINK-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377789#comment-14377789 ] Stephan Ewen commented on FLINK-1776: - That is critical, I agree. Can we make the

[jira] [Resolved] (FLINK-1761) IndexOutOfBoundsException when receiving empty buffer at remote channel

[ https://issues.apache.org/jira/browse/FLINK-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1761. - Resolution: Fixed Fix Version/s: 0.9 Fixed in 380ef878c850f83b5e12176e465d59c737066e20 and

[jira] [Commented] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

[ https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377791#comment-14377791 ] Stephan Ewen commented on FLINK-1769: - Anyone looking into this already? This

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

Stephan Ewen created FLINK-1778: --- Summary: Improve normalized keys in composite key case Key: FLINK-1778 URL: https://issues.apache.org/jira/browse/FLINK-1778 Project: Flink Issue Type:

[jira] [Created] (FLINK-1782) Change Quickstart Java version to 1.7

Stephan Ewen created FLINK-1782: --- Summary: Change Quickstart Java version to 1.7 Key: FLINK-1782 URL: https://issues.apache.org/jira/browse/FLINK-1782 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1781) Quickstarts broken due to Scala Version Variables

Stephan Ewen created FLINK-1781: --- Summary: Quickstarts broken due to Scala Version Variables Key: FLINK-1781 URL: https://issues.apache.org/jira/browse/FLINK-1781 Project: Flink Issue Type:

[jira] [Created] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

Stephan Ewen created FLINK-1783: --- Summary: Quickstart shading should not created shaded jar and dependency reduced pom Key: FLINK-1783 URL: https://issues.apache.org/jira/browse/FLINK-1783 Project:

[jira] [Resolved] (FLINK-1774) Remove the redundant code in try{} block

[ https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1774. - Resolution: Fixed Fixed in c89c657ae16bbe89da54669a234713a3811813ee Thank you for the patch!

[jira] [Resolved] (FLINK-1779) Rename the function name from getCurrentyActiveConnections to getCurrentActiveConnections in org.apache.flink.runtime.blob

[ https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1779. - Resolution: Fixed Fixed in fb3f3ee845a3aae295c9aae00f3d406d9f1d5813 Thank you for the patch!

[jira] [Created] (FLINK-1801) NetworkEnvironment should start without JobManager association

Stephan Ewen created FLINK-1801: --- Summary: NetworkEnvironment should start without JobManager association Key: FLINK-1801 URL: https://issues.apache.org/jira/browse/FLINK-1801 Project: Flink

[jira] [Resolved] (FLINK-1348) Move Stream Connector Jars from lib to Client JARs

[ https://issues.apache.org/jira/browse/FLINK-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1348. - Resolution: Fixed Fix Version/s: 0.9 Fixed with the updated dependency management in the

[jira] [Resolved] (FLINK-1754) Deadlock in job execution

[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1754. - Resolution: Not a Problem Is actually a known bug in 0.8 and fixed in 0.9 Deadlock in job

[jira] [Resolved] (FLINK-1435) TaskManager does not log missing memory error on start up

[ https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1435. - Resolution: Not a Problem TaskManager does not log missing memory error on start up

[jira] [Resolved] (FLINK-1801) NetworkEnvironment should start without JobManager association

[ https://issues.apache.org/jira/browse/FLINK-1801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1801. - Resolution: Implemented Implemented in ee273dbe01e95d2b260fa690e21e2c244a2a5711

[jira] [Resolved] (FLINK-1465) GlobalBufferPool reports negative memory allocation

[ https://issues.apache.org/jira/browse/FLINK-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1465. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen (was: Ufuk Celebi)

[jira] [Commented] (FLINK-1435) TaskManager does not log missing memory error on start up

[ https://issues.apache.org/jira/browse/FLINK-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386949#comment-14386949 ] Stephan Ewen commented on FLINK-1435: - I think we misunderstood this issue initially.

[jira] [Commented] (FLINK-1465) GlobalBufferPool reports negative memory allocation

[ https://issues.apache.org/jira/browse/FLINK-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386966#comment-14386966 ] Stephan Ewen commented on FLINK-1465: - This is actually an integer overflow issue. I

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14382269#comment-14382269 ] Stephan Ewen commented on FLINK-1319: - I think there is no reason they are not

[jira] [Commented] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

[ https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14382294#comment-14382294 ] Stephan Ewen commented on FLINK-1783: - It does not affect one, it only causes maven to

[jira] [Commented] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

[ https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14382295#comment-14382295 ] Stephan Ewen commented on FLINK-1783: - Even though they were identical in the end...

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14382291#comment-14382291 ] Stephan Ewen commented on FLINK-1789: - I think that is a great idea. We can even use

[jira] [Commented] (FLINK-1782) Change Quickstart Java version to 1.7

[ https://issues.apache.org/jira/browse/FLINK-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14382276#comment-14382276 ] Stephan Ewen commented on FLINK-1782: - I'll take a quick stab at fixing the quickstart

[jira] [Resolved] (FLINK-1796) Local mode TaskManager should have a process reaper

[ https://issues.apache.org/jira/browse/FLINK-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1796. - Resolution: Fixed Fixed via 8c32142528590a030693529c7c8d93f194968c0a Local mode TaskManager

[jira] [Resolved] (FLINK-1795) Solution set allows duplicates upon construction.

[ https://issues.apache.org/jira/browse/FLINK-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1795. - Resolution: Fixed Fixed via 923a2ae259bd72a2d48639ae0e64db0a04a4aa91 Solution set allows

[jira] [Resolved] (FLINK-1669) Streaming tests for recovery with distributed process failure

[ https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1669. - Resolution: Fixed Fixed in c284745ee4612054339842789b0d87eb4f9a821d Streaming tests for

[jira] [Resolved] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

[ https://issues.apache.org/jira/browse/FLINK-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1608. - Resolution: Fixed Assignee: Stephan Ewen Resolved in

[jira] [Commented] (FLINK-1628) Strange behavior of where function during a join

[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14343584#comment-14343584 ] Stephan Ewen commented on FLINK-1628: - Is this specific to the combination of tuple

[jira] [Created] (FLINK-1631) Port collisions in ProcessReaping tests

Stephan Ewen created FLINK-1631: --- Summary: Port collisions in ProcessReaping tests Key: FLINK-1631 URL: https://issues.apache.org/jira/browse/FLINK-1631 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1616) Action list -r gives IOException when there are running jobs

[ https://issues.apache.org/jira/browse/FLINK-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345457#comment-14345457 ] Stephan Ewen commented on FLINK-1616: - There are a few issues with the CLI frontend.

[jira] [Resolved] (FLINK-1631) Port collisions in ProcessReaping tests

[ https://issues.apache.org/jira/browse/FLINK-1631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1631. - Resolution: Fixed Fixed via 94a66d570e4bb40824813911a4f1bb47a8bf8b90 Port collisions in

[jira] [Created] (FLINK-1648) Add a mode where the system automatically sets the parallelism to the available task slots

Stephan Ewen created FLINK-1648: --- Summary: Add a mode where the system automatically sets the parallelism to the available task slots Key: FLINK-1648 URL: https://issues.apache.org/jira/browse/FLINK-1648

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14347450#comment-14347450 ] Stephan Ewen commented on FLINK-1650: - The logged error is below. Setting the log

[jira] [Created] (FLINK-1649) Give a good error message when a user program emits a null record

Stephan Ewen created FLINK-1649: --- Summary: Give a good error message when a user program emits a null record Key: FLINK-1649 URL: https://issues.apache.org/jira/browse/FLINK-1649 Project: Flink

[jira] [Commented] (FLINK-1572) Output directories are created before input paths are checked

[ https://issues.apache.org/jira/browse/FLINK-1572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348675#comment-14348675 ] Stephan Ewen commented on FLINK-1572: - Can we always remove the output directory? What

[jira] [Commented] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348685#comment-14348685 ] Stephan Ewen commented on FLINK-1601: - [~rmetzger] Any insight where this may come

[jira] [Resolved] (FLINK-1649) Give a good error message when a user program emits a null record

[ https://issues.apache.org/jira/browse/FLINK-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1649. - Resolution: Fixed Fixed via 482766e949d69e282ed862bd97f2a8378b2f699e Give a good error message

[jira] [Commented] (FLINK-1635) Remove Apache Thrift dependency from Flink

[ https://issues.apache.org/jira/browse/FLINK-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14344841#comment-14344841 ] Stephan Ewen commented on FLINK-1635: - I agree, let's remove this. The way that it

[jira] [Updated] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

[ https://issues.apache.org/jira/browse/FLINK-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1608: Description: The taskmanagers use a NetUtils routine to find an interface that lets them talk to

[jira] [Commented] (FLINK-1580) Cleanup TaskManager initialization logic

[ https://issues.apache.org/jira/browse/FLINK-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14335468#comment-14335468 ] Stephan Ewen commented on FLINK-1580: - Partially solved in

[jira] [Updated] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

[ https://issues.apache.org/jira/browse/FLINK-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1608: Description: The TaskManager uses a NetUtils routine to pick a network interface that lets it talk

[jira] [Resolved] (FLINK-1590) Log environment information also in YARN mode

[ https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1590. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen (was: Robert Metzger)

[jira] [Commented] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

[ https://issues.apache.org/jira/browse/FLINK-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14335442#comment-14335442 ] Stephan Ewen commented on FLINK-1608: - As a safety fallback, I suggest that we allow

[jira] [Commented] (FLINK-1610) Java docs do not build

[ https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14336993#comment-14336993 ] Stephan Ewen commented on FLINK-1610: - May be related to referring to Scala classes

[jira] [Commented] (FLINK-1162) Cannot serialize Scala classes with Avro serializer

[ https://issues.apache.org/jira/browse/FLINK-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14333167#comment-14333167 ] Stephan Ewen commented on FLINK-1162: - Yep, this one should be resolved. Cannot

[jira] [Resolved] (FLINK-1596) FileIOChannel introduces space in temp file name

[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1596. - Resolution: Fixed Fixed in 0.9 in 98bc7b951b30961871958a4483e0b186bfb785b8 FileIOChannel

[jira] [Resolved] (FLINK-1598) Give better error messages when serializers run out of space.

[ https://issues.apache.org/jira/browse/FLINK-1598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1598. - Resolution: Fixed Fixed via 9528a521f56e0c6b0c70d43e62ad84b19c048c36 Give better error messages

[jira] [Commented] (FLINK-1613) Cannost submit to remote ExecutionEnvironment from IDE

[ https://issues.apache.org/jira/browse/FLINK-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14338714#comment-14338714 ] Stephan Ewen commented on FLINK-1613: - This is somewhat expected, currently. The

[jira] [Resolved] (FLINK-1781) Quickstarts broken due to Scala Version Variables

[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1781. - Resolution: Fixed Fixed in 1aba942c1fd7c4dbf1c4d4f30602d69c2cb3540e Quickstarts broken due to

[jira] [Commented] (FLINK-1754) Deadlock in job execution

[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14384450#comment-14384450 ] Stephan Ewen commented on FLINK-1754: - Is this issue resolved? The issue with

[jira] [Commented] (FLINK-1796) Local mode TaskManager should have a process reaper

[ https://issues.apache.org/jira/browse/FLINK-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14384458#comment-14384458 ] Stephan Ewen commented on FLINK-1796: - I have a fix for this coming up... Local mode

[jira] [Resolved] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

[ https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1783. - Resolution: Fixed Assignee: Stephan Ewen Fixed in d11e0910880a48bbd5c452e4c76ffdca000f5614

[jira] [Commented] (FLINK-1795) Solution set allows duplicates upon construction.

[ https://issues.apache.org/jira/browse/FLINK-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14384456#comment-14384456 ] Stephan Ewen commented on FLINK-1795: - I have a fix and test coming up... Solution

[jira] [Created] (FLINK-1796) Local mode TaskManager should have a process reaper

Stephan Ewen created FLINK-1796: --- Summary: Local mode TaskManager should have a process reaper Key: FLINK-1796 URL: https://issues.apache.org/jira/browse/FLINK-1796 Project: Flink Issue Type:

[jira] [Created] (FLINK-1795) Solution set allows duplicates upon construction.

Stephan Ewen created FLINK-1795: --- Summary: Solution set allows duplicates upon construction. Key: FLINK-1795 URL: https://issues.apache.org/jira/browse/FLINK-1795 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1782) Change Quickstart Java version to 1.7

[ https://issues.apache.org/jira/browse/FLINK-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14384254#comment-14384254 ] Stephan Ewen commented on FLINK-1782: - This is currently not possible, since the

[jira] [Resolved] (FLINK-1782) Change Quickstart Java version to 1.7

[ https://issues.apache.org/jira/browse/FLINK-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1782. - Resolution: Won't Fix Fix Version/s: (was: 0.9) Change Quickstart Java version to 1.7

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14376899#comment-14376899 ] Stephan Ewen commented on FLINK-1319: - Very nice result, a very much anticipated

[jira] [Commented] (FLINK-1916) EOFException when running delta-iteration job

[ https://issues.apache.org/jira/browse/FLINK-1916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14505338#comment-14505338 ] Stephan Ewen commented on FLINK-1916: - Confirmed, this is a bug in the

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14505313#comment-14505313 ] Stephan Ewen commented on FLINK-1908: - I don't think that this issue will be fixed in

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