[jira] [Created] (FLINK-1879) Simplify JobClient

Stephan Ewen created FLINK-1879: --- Summary: Simplify JobClient Key: FLINK-1879 URL: https://issues.apache.org/jira/browse/FLINK-1879 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-1878) Add mode to Environments to deactivate sysout printing

Stephan Ewen created FLINK-1878: --- Summary: Add mode to Environments to deactivate sysout printing Key: FLINK-1878 URL: https://issues.apache.org/jira/browse/FLINK-1878 Project: Flink Issue

[jira] [Updated] (FLINK-1867) TaskManagerFailureRecoveryITCase causes stalled travis builds

[ https://issues.apache.org/jira/browse/FLINK-1867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1867: Assignee: Aljoscha Krettek TaskManagerFailureRecoveryITCase causes stalled travis builds

[jira] [Created] (FLINK-1882) Remove RemoteCollectorOutputFormat

Stephan Ewen created FLINK-1882: --- Summary: Remove RemoteCollectorOutputFormat Key: FLINK-1882 URL: https://issues.apache.org/jira/browse/FLINK-1882 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-1879) Simplify JobClient

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

[jira] [Closed] (FLINK-1879) Simplify JobClient

[ https://issues.apache.org/jira/browse/FLINK-1879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1879. --- Simplify JobClient -- Key: FLINK-1879 URL:

[jira] [Resolved] (FLINK-1878) Add mode to Environments to deactivate sysout printing

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

[jira] [Closed] (FLINK-1878) Add mode to Environments to deactivate sysout printing

[ https://issues.apache.org/jira/browse/FLINK-1878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1878. --- Add mode to Environments to deactivate sysout printing

[jira] [Resolved] (FLINK-1868) EnvironmentInformationTest.testJavaMemory fails on Travis

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

[jira] [Closed] (FLINK-1868) EnvironmentInformationTest.testJavaMemory fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1868. --- EnvironmentInformationTest.testJavaMemory fails on Travis

[jira] [Closed] (FLINK-1845) NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator

[ https://issues.apache.org/jira/browse/FLINK-1845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1845. --- NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator

[jira] [Resolved] (FLINK-1847) Change Scala collect() method to return a Seq

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

[jira] [Resolved] (FLINK-1845) NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator

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

[jira] [Closed] (FLINK-1847) Change Scala collect() method to return a Seq

[ https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1847. --- Change Scala collect() method to return a Seq -

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14482808#comment-14482808 ] Stephan Ewen commented on FLINK-1829: - The `hbase-client` dependency should not be in

[jira] [Closed] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

[ https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1831. --- runtime.taskmanager.RegistrationTests fails spuriously

[jira] [Resolved] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

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

[jira] [Created] (FLINK-1835) Spurious failure of YARN tests

Stephan Ewen created FLINK-1835: --- Summary: Spurious failure of YARN tests Key: FLINK-1835 URL: https://issues.apache.org/jira/browse/FLINK-1835 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1821) simplify coding

[ https://issues.apache.org/jira/browse/FLINK-1821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14481212#comment-14481212 ] Stephan Ewen commented on FLINK-1821: - I also vote to keep it. It is a good way of

[jira] [Resolved] (FLINK-1634) Fix Could not build up connection to JobManager issue on some systems

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

[jira] [Resolved] (FLINK-999) Configurability of LocalExecutor

[ https://issues.apache.org/jira/browse/FLINK-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-999. Resolution: Duplicate Fix Version/s: 0.9 Resolved via [FLINK-1589] Configurability of

[jira] [Closed] (FLINK-999) Configurability of LocalExecutor

[ https://issues.apache.org/jira/browse/FLINK-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-999. -- Configurability of LocalExecutor Key: FLINK-999

[jira] [Resolved] (FLINK-1802) BlobManager directories should be checked before TaskManager startup

[ https://issues.apache.org/jira/browse/FLINK-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1802. - Resolution: Fixed Fixed as part of e74521c1fe5f5842185be5c454d27adc3bd254d5 BlobManager

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

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

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483215#comment-14483215 ] Stephan Ewen commented on FLINK-1820: - Given the discussion here, I agree with Fabian.

[jira] [Commented] (FLINK-1839) Failures in TwitterStreamITCase

[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483441#comment-14483441 ] Stephan Ewen commented on FLINK-1839: - Okay, from my latest Travis logs, this seems to

[jira] [Created] (FLINK-1839) Failures in TwitterStreamITCase

Stephan Ewen created FLINK-1839: --- Summary: Failures in TwitterStreamITCase Key: FLINK-1839 URL: https://issues.apache.org/jira/browse/FLINK-1839 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1839) Failures in TwitterStreamITCase

[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483440#comment-14483440 ] Stephan Ewen commented on FLINK-1839: - Another occurance {code} Tests run: 1,

[jira] [Updated] (FLINK-1839) Failures in TwitterStreamITCase

[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1839: Priority: Critical (was: Major) Failures in TwitterStreamITCase ---

[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=14485131#comment-14485131 ] Stephan Ewen commented on FLINK-1319: - In principle this is good, but I would put it

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485164#comment-14485164 ] Stephan Ewen commented on FLINK-1818: - This is basically a simple addition to the

[jira] [Commented] (FLINK-1812) TaskManager shell scripts restart JVMs on process failures

[ https://issues.apache.org/jira/browse/FLINK-1812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485167#comment-14485167 ] Stephan Ewen commented on FLINK-1812: - Exactly. The wrapping shell script would

[jira] [Commented] (FLINK-1843) Job History gets cleared too fast

[ https://issues.apache.org/jira/browse/FLINK-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485084#comment-14485084 ] Stephan Ewen commented on FLINK-1843: - Keeping the Execution graph on the JobManager

[jira] [Commented] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats

[ https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485163#comment-14485163 ] Stephan Ewen commented on FLINK-1819: - I agree, that would be a very good addition.

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485153#comment-14485153 ] Stephan Ewen commented on FLINK-1827: - I agree, that would be a good fix. Is that

[jira] [Updated] (FLINK-1818) Provide API to cancel running job

[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1818: Labels: starter (was: ) Provide API to cancel running job -

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485166#comment-14485166 ] Stephan Ewen commented on FLINK-1818: - Given that this follows the code in the

[jira] [Commented] (FLINK-1847) Change Scala collect() method to return a Seq

[ https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485217#comment-14485217 ] Stephan Ewen commented on FLINK-1847: - Also, {{collect}} should have parenthesis. It

[jira] [Commented] (FLINK-1847) Change Scala collect() method to return a Seq

[ https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485225#comment-14485225 ] Stephan Ewen commented on FLINK-1847: - Same holds for {{count()}}. Both changes are

[jira] [Commented] (FLINK-1847) Change Scala collect() method to return a Seq

[ https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485228#comment-14485228 ] Stephan Ewen commented on FLINK-1847: - I am actually seeing a common Scala pitfall

[jira] [Created] (FLINK-1847) Change Scala collect() method to return a Seq

Stephan Ewen created FLINK-1847: --- Summary: Change Scala collect() method to return a Seq Key: FLINK-1847 URL: https://issues.apache.org/jira/browse/FLINK-1847 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1845) NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator

Stephan Ewen created FLINK-1845: --- Summary: NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator Key: FLINK-1845 URL: https://issues.apache.org/jira/browse/FLINK-1845 Project: Flink

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485252#comment-14485252 ] Stephan Ewen commented on FLINK-1848: - I think that is legit. If java.net.URI rejects

[jira] [Reopened] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-1793: - Okay, this looks like the source is actually not canceled, but just waits for the input to be

[jira] [Commented] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485339#comment-14485339 ] Stephan Ewen commented on FLINK-1793: - Okay, this looks like the source is actually

[jira] [Updated] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1793: Priority: Critical (was: Major) Streaming jobs can't be canceled

[jira] [Updated] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1793: Summary: Streaming File Source cannot be canceled (was: Streaming jobs can't be canceled)

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485278#comment-14485278 ] Stephan Ewen commented on FLINK-1848: - Agree... What is the result of {{new

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550364#comment-14550364 ] Stephan Ewen commented on FLINK-1952: - Okay, I am able to reproduce it locally with a

[jira] [Created] (FLINK-2058) Hadoop Input Splits do not use proper UserCodeClassloader

Stephan Ewen created FLINK-2058: --- Summary: Hadoop Input Splits do not use proper UserCodeClassloader Key: FLINK-2058 URL: https://issues.apache.org/jira/browse/FLINK-2058 Project: Flink Issue

[jira] [Created] (FLINK-2057) Remove IOReadableWritable interface from input splits

Stephan Ewen created FLINK-2057: --- Summary: Remove IOReadableWritable interface from input splits Key: FLINK-2057 URL: https://issues.apache.org/jira/browse/FLINK-2057 Project: Flink Issue

[jira] [Commented] (FLINK-2060) Let maven fail on travis when modules reference to outdated internal dependency

[ https://issues.apache.org/jira/browse/FLINK-2060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552305#comment-14552305 ] Stephan Ewen commented on FLINK-2060: - +1 We should not use any snapshots (because the

[jira] [Commented] (FLINK-2038) Extend headline of website

[ https://issues.apache.org/jira/browse/FLINK-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14552331#comment-14552331 ] Stephan Ewen commented on FLINK-2038: - I am okay with dropping the unified. It is

[jira] [Created] (FLINK-2062) Fix names of memory segment config parameter

Stephan Ewen created FLINK-2062: --- Summary: Fix names of memory segment config parameter Key: FLINK-2062 URL: https://issues.apache.org/jira/browse/FLINK-2062 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-2058) Hadoop Input Splits do not use proper UserCodeClassloader

[ https://issues.apache.org/jira/browse/FLINK-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2058. --- Hadoop Input Splits do not use proper UserCodeClassloader

[jira] [Resolved] (FLINK-2057) Remove IOReadableWritable interface from input splits

[ https://issues.apache.org/jira/browse/FLINK-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2057. - Resolution: Fixed Fixed via f27025bafbe45fbfe8bfd27d06f01258a4ff9f44 Remove IOReadableWritable

[jira] [Resolved] (FLINK-2058) Hadoop Input Splits do not use proper UserCodeClassloader

[ https://issues.apache.org/jira/browse/FLINK-2058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2058. - Resolution: Fixed Fixed via f27025bafbe45fbfe8bfd27d06f01258a4ff9f44 Hadoop Input Splits do not

[jira] [Closed] (FLINK-2057) Remove IOReadableWritable interface from input splits

[ https://issues.apache.org/jira/browse/FLINK-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2057. --- Remove IOReadableWritable interface from input splits

[jira] [Created] (FLINK-2066) Make delay between execution retries configurable

Stephan Ewen created FLINK-2066: --- Summary: Make delay between execution retries configurable Key: FLINK-2066 URL: https://issues.apache.org/jira/browse/FLINK-2066 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2066) Make delay between execution retries configurable

[ https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2066: Labels: starter (was: ) Make delay between execution retries configurable

[jira] [Closed] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1907. --- Scala Interactive Shell --- Key: FLINK-1907 URL:

[jira] [Resolved] (FLINK-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1907. - Resolution: Implemented Fix Version/s: 0.9 Scala Interactive Shell

[jira] [Resolved] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager

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

[jira] [Closed] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager

[ https://issues.apache.org/jira/browse/FLINK-2070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2070. --- Confusing methods print() that print on client vs on TaskManager

[jira] [Commented] (FLINK-2151) Provide interface to distinguish close() calls in error and regular cases

[ https://issues.apache.org/jira/browse/FLINK-2151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14571704#comment-14571704 ] Stephan Ewen commented on FLINK-2151: - For rich functions, we can add a

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14571677#comment-14571677 ] Stephan Ewen commented on FLINK-1967: - With next version, you mean 0.10, right? I am

[jira] [Commented] (FLINK-2153) Exclude dependency on hbase annotations module

[ https://issues.apache.org/jira/browse/FLINK-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574189#comment-14574189 ] Stephan Ewen commented on FLINK-2153: - Any updates on that. Would like to have this in

[jira] [Commented] (FLINK-2002) Iterative test fails when ran with other tests in the same environment

[ https://issues.apache.org/jira/browse/FLINK-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574153#comment-14574153 ] Stephan Ewen commented on FLINK-2002: - This seems to be related to improper cleanup

[jira] [Commented] (FLINK-2163) VertexCentricConfigurationITCase sometimes fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-2163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574184#comment-14574184 ] Stephan Ewen commented on FLINK-2163: - It is a strong suspicion. Other file based

[jira] [Commented] (FLINK-1940) StockPrice example cannot be visualized

[ https://issues.apache.org/jira/browse/FLINK-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574157#comment-14574157 ] Stephan Ewen commented on FLINK-1940: - I think Marton removed that example, so it is

[jira] [Commented] (FLINK-1892) Local job execution does not exit.

[ https://issues.apache.org/jira/browse/FLINK-1892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574167#comment-14574167 ] Stephan Ewen commented on FLINK-1892: - Let's bump the Tez version to 0.6.1 to get the

[jira] [Commented] (FLINK-2133) Possible deadlock in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-2133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14575036#comment-14575036 ] Stephan Ewen commented on FLINK-2133: - Okay, I found a plausible scenario how this can

[jira] [Updated] (FLINK-2177) NullPointer in task resource release

[ https://issues.apache.org/jira/browse/FLINK-2177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2177: Summary: NullPointer in task resource release (was: NillPointer in task resource release)

[jira] [Commented] (FLINK-2177) NillPointer in task resource release

[ https://issues.apache.org/jira/browse/FLINK-2177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14575213#comment-14575213 ] Stephan Ewen commented on FLINK-2177: - Here are the tests where this occurred (need to

[jira] [Resolved] (FLINK-2133) Possible deadlock in ExecutionGraph

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

[jira] [Closed] (FLINK-2133) Possible deadlock in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-2133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2133. --- Possible deadlock in ExecutionGraph --- Key:

[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573057#comment-14573057 ] Stephan Ewen commented on FLINK-2156: - I have elevated this to critical, because these

[jira] [Closed] (FLINK-2126) Scala shell tests sporadically fail on travis

[ https://issues.apache.org/jira/browse/FLINK-2126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2126. --- Scala shell tests sporadically fail on travis -

[jira] [Resolved] (FLINK-2126) Scala shell tests sporadically fail on travis

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

[jira] [Resolved] (FLINK-2076) Bug in re-openable hash join

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

[jira] [Commented] (FLINK-2244) Add ability to start and stop persistent IaaS cluster

[ https://issues.apache.org/jira/browse/FLINK-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596107#comment-14596107 ] Stephan Ewen commented on FLINK-2244: - This is a very generic/broad feature. This

[jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files

[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596116#comment-14596116 ] Stephan Ewen commented on FLINK-2186: - Not sure if we can/want to fix this on the

[jira] [Commented] (FLINK-2230) Add Support for Null-Values in TupleSerializer

[ https://issues.apache.org/jira/browse/FLINK-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596084#comment-14596084 ] Stephan Ewen commented on FLINK-2230: - There have been many discussions about whether

[jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596187#comment-14596187 ] Stephan Ewen commented on FLINK-2245: - I would actually assume that programs with

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596102#comment-14596102 ] Stephan Ewen commented on FLINK-2235: - Sounds like a good way to fix this... Local

[jira] [Commented] (FLINK-2231) Create a Serializer for Scala Enumerations

[ https://issues.apache.org/jira/browse/FLINK-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596071#comment-14596071 ] Stephan Ewen commented on FLINK-2231: - Exactly, the createTypeInformation macro needs

[jira] [Commented] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596188#comment-14596188 ] Stephan Ewen commented on FLINK-2245: - Ah, sorry, confusion: You were talking about

[jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596100#comment-14596100 ] Stephan Ewen commented on FLINK-2236: - I think this is fixed in the release, correct?

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14596054#comment-14596054 ] Stephan Ewen commented on FLINK-2209: - Reopened this, because I think this

[jira] [Reopened] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-2209: - Assignee: (was: Márton Balassi) Document how to use TableAPI, Gelly and FlinkML,

[jira] [Commented] (FLINK-2193) Partial shuffling

[ https://issues.apache.org/jira/browse/FLINK-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595725#comment-14595725 ] Stephan Ewen commented on FLINK-2193: - I think there is currently no partition

[jira] [Commented] (FLINK-2198) BlobManager tests fail on Windows

[ https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595738#comment-14595738 ] Stephan Ewen commented on FLINK-2198: - The approach to disallow folder creation is

[jira] [Commented] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program

[ https://issues.apache.org/jira/browse/FLINK-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595830#comment-14595830 ] Stephan Ewen commented on FLINK-2197: - How can we solve this? Can we change the

[jira] [Commented] (FLINK-2190) Enhance stream decoration/compression extensibility

[ https://issues.apache.org/jira/browse/FLINK-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14595818#comment-14595818 ] Stephan Ewen commented on FLINK-2190: - Sounds good! Enhance stream

[jira] [Commented] (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:comment-tabpanelfocusedCommentId=14601159#comment-14601159 ] Stephan Ewen commented on FLINK-2239: - There is pending work to support larger results

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14599036#comment-14599036 ] Stephan Ewen commented on FLINK-1962: - Yes, all Scala projects need extra POM entries

[jira] [Updated] (FLINK-2265) Tachyon Tests sometimes fail with pre-mature process exists

[ https://issues.apache.org/jira/browse/FLINK-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2265: Priority: Minor (was: Major) Tachyon Tests sometimes fail with pre-mature process exists

[jira] [Created] (FLINK-2265) Tachyon Tests sometimes fail with pre-mature process exists

Stephan Ewen created FLINK-2265: --- Summary: Tachyon Tests sometimes fail with pre-mature process exists Key: FLINK-2265 URL: https://issues.apache.org/jira/browse/FLINK-2265 Project: Flink

[jira] [Created] (FLINK-2270) Error in KafkaSource Documentation

Stephan Ewen created FLINK-2270: --- Summary: Error in KafkaSource Documentation Key: FLINK-2270 URL: https://issues.apache.org/jira/browse/FLINK-2270 Project: Flink Issue Type: Bug

[jira] [Commented] (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:comment-tabpanelfocusedCommentId=14593150#comment-14593150 ] Stephan Ewen commented on FLINK-2239: - There is code in contrib that collects data

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