[jira] [Assigned] (FLINK-1458) Interfaces and abstract classes are not valid types

[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1458: --- Assignee: Aljoscha Krettek Interfaces and abstract classes are not valid types

[jira] [Updated] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

[ https://issues.apache.org/jira/browse/FLINK-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1463: Fix Version/s: 0.8.1 RuntimeStatefulSerializerFactory declares ClassLoader as transient

[jira] [Updated] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

[ https://issues.apache.org/jira/browse/FLINK-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1463: Priority: Blocker (was: Major) RuntimeStatefulSerializerFactory declares ClassLoader as

[jira] [Created] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag

Aljoscha Krettek created FLINK-1521: --- Summary: Some Chained Drivers do not respect object-reuse/non-reuse flag Key: FLINK-1521 URL: https://issues.apache.org/jira/browse/FLINK-1521 Project: Flink

[jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API.

[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293458#comment-14293458 ] Aljoscha Krettek commented on FLINK-1396: - For this to work I have to move the

[jira] [Commented] (FLINK-1458) Interfaces and abstract classes are not valid types

[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295010#comment-14295010 ] Aljoscha Krettek commented on FLINK-1458: - Yes, after the fix is merged it will

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296968#comment-14296968 ] Aljoscha Krettek commented on FLINK-1450: - I see the necessity in the streaming

[jira] [Commented] (FLINK-1452) Add flink-contrib maven module and README.md with the rules

[ https://issues.apache.org/jira/browse/FLINK-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296912#comment-14296912 ] Aljoscha Krettek commented on FLINK-1452: - Or {{flink-staging}}. Add

[jira] [Commented] (FLINK-1456) Projection to fieldnames, keyselectors

[ https://issues.apache.org/jira/browse/FLINK-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296957#comment-14296957 ] Aljoscha Krettek commented on FLINK-1456: - I don't know if this is really

[jira] [Commented] (FLINK-1303) HadoopInputFormat does not work with Scala API

[ https://issues.apache.org/jira/browse/FLINK-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291683#comment-14291683 ] Aljoscha Krettek commented on FLINK-1303: - I think we can easily rework this to

[jira] [Updated] (FLINK-1303) HadoopInputFormat does not work with Scala API

[ https://issues.apache.org/jira/browse/FLINK-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1303: Issue Type: Sub-task (was: Bug) Parent: FLINK-1396 HadoopInputFormat does not

[jira] [Assigned] (FLINK-1378) could not find implicit value for evidence parameter of type TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1378: --- Assignee: Aljoscha Krettek could not find implicit value for evidence parameter of

[jira] [Commented] (FLINK-1378) could not find implicit value for evidence parameter of type TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14271057#comment-14271057 ] Aljoscha Krettek commented on FLINK-1378: - I'm looking into it. could not find

[jira] [Commented] (FLINK-1400) In local mode, the default TaskManager won't listen on the data port.

[ https://issues.apache.org/jira/browse/FLINK-1400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14276731#comment-14276731 ] Aljoscha Krettek commented on FLINK-1400: - You can, with a hack. You start a

[jira] [Commented] (FLINK-1511) Scala classes not identified as Pojos

[ https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315935#comment-14315935 ] Aljoscha Krettek commented on FLINK-1511: - From the flink documentation:

[jira] [Assigned] (FLINK-1511) Scala classes not identified as Pojos

[ https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1511: --- Assignee: Aljoscha Krettek Scala classes not identified as Pojos

[jira] [Resolved] (FLINK-1303) HadoopInputFormat does not work with Scala API

[ https://issues.apache.org/jira/browse/FLINK-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1303. - Resolution: Fixed Fix Version/s: 0.8.1 Resolved in

[jira] [Resolved] (FLINK-1396) Add hadoop input formats directly to the user API.

[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1396. - Resolution: Fixed Fix Version/s: 0.8.1 0.9 Resolved in

[jira] [Resolved] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

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

[jira] [Commented] (FLINK-1303) HadoopInputFormat does not work with Scala API

[ https://issues.apache.org/jira/browse/FLINK-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14322110#comment-14322110 ] Aljoscha Krettek commented on FLINK-1303: - In the development snapshot and the

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

Aljoscha Krettek created FLINK-1720: --- Summary: Integrate ScalaDoc in Scala sources into overall JavaDoc Key: FLINK-1720 URL: https://issues.apache.org/jira/browse/FLINK-1720 Project: Flink

[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=14366933#comment-14366933 ] Aljoscha Krettek commented on FLINK-1710: - It is executed on the same data sets as

[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=14367273#comment-14367273 ] Aljoscha Krettek commented on FLINK-1710: - The more important problem could be

[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=14367213#comment-14367213 ] Aljoscha Krettek commented on FLINK-1710: - It is currently being compiled in one

[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=14371131#comment-14371131 ] Aljoscha Krettek commented on FLINK-1710: - But what should I ask? The Scala

[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=14371518#comment-14371518 ] Aljoscha Krettek commented on FLINK-1710: - This might sound a bit crazy, but we

[jira] [Assigned] (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:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1769: --- Assignee: Aljoscha Krettek Maven deploy is broken (build artifacts are cleaned in

[jira] [Created] (FLINK-1788) Extend Table API to allow logical plan optimisations

Aljoscha Krettek created FLINK-1788: --- Summary: Extend Table API to allow logical plan optimisations Key: FLINK-1788 URL: https://issues.apache.org/jira/browse/FLINK-1788 Project: Flink

[jira] [Assigned] (FLINK-1788) Extend Table API to allow logical plan optimisations

[ https://issues.apache.org/jira/browse/FLINK-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1788: --- Assignee: Aljoscha Krettek Extend Table API to allow logical plan optimisations

[jira] [Updated] (FLINK-1791) Change nightly Javadoc build to use correct profile

[ https://issues.apache.org/jira/browse/FLINK-1791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1791: Assignee: Maximilian Michels Change nightly Javadoc build to use correct profile

[jira] [Resolved] (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:all-tabpanel ] Aljoscha Krettek resolved FLINK-1769. - Resolution: Fixed Fixed in

[jira] [Resolved] (FLINK-1623) Rename Expression API and Operation Representation

[ https://issues.apache.org/jira/browse/FLINK-1623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1623. - Resolution: Fixed Fix Version/s: 0.9 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=14345350#comment-14345350 ] Aljoscha Krettek commented on FLINK-1628: - [~fhueske] and I found the bug in the

[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=14345353#comment-14345353 ] Aljoscha Krettek commented on FLINK-1628: - This is the fix, line 128 in

[jira] [Created] (FLINK-1623) Rename Expression API and Operation Representation

Aljoscha Krettek created FLINK-1623: --- Summary: Rename Expression API and Operation Representation Key: FLINK-1623 URL: https://issues.apache.org/jira/browse/FLINK-1623 Project: Flink Issue

[jira] [Updated] (FLINK-1623) Rename Expression API and Operation Representation

[ https://issues.apache.org/jira/browse/FLINK-1623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1623: Description: Right now the package is called flink-expressions and we refer to the API as

[jira] [Assigned] (FLINK-1623) Rename Expression API and Operation Representation

[ https://issues.apache.org/jira/browse/FLINK-1623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1623: --- Assignee: Aljoscha Krettek Rename Expression API and Operation Representation

[jira] [Created] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

Aljoscha Krettek created FLINK-1463: --- Summary: RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it Key: FLINK-1463 URL: https://issues.apache.org/jira/browse/FLINK-1463

[jira] [Updated] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

[ https://issues.apache.org/jira/browse/FLINK-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1463: Description: At least one user has seen an exception because of this. In theory, the

[jira] [Commented] (FLINK-1452) Add flink-contrib maven module and README.md with the rules

[ https://issues.apache.org/jira/browse/FLINK-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14298502#comment-14298502 ] Aljoscha Krettek commented on FLINK-1452: - Yes Add flink-contrib maven module

[jira] [Resolved] (FLINK-1788) Extend Table API to allow logical plan optimisations

[ https://issues.apache.org/jira/browse/FLINK-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1788. - Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Resolved] (FLINK-671) Python interface for new API (Map/Reduce)

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

[jira] [Resolved] (FLINK-377) Create a general purpose framework for language bindings

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

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

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14504965#comment-14504965 ] Aljoscha Krettek commented on FLINK-1907: - The problem is now, that the

[jira] [Resolved] (FLINK-1880) TaskManagerTest fails spuriously

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

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

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

[jira] [Resolved] (FLINK-1799) Scala API does not support generic arrays

[ https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1799. - Resolution: Fixed Fixed in

[jira] [Created] (FLINK-1936) Normalize keys and default values in ConfigConstants.java

Aljoscha Krettek created FLINK-1936: --- Summary: Normalize keys and default values in ConfigConstants.java Key: FLINK-1936 URL: https://issues.apache.org/jira/browse/FLINK-1936 Project: Flink

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

Aljoscha Krettek created FLINK-1967: --- Summary: Introduce (Event)time in Streaming Key: FLINK-1967 URL: https://issues.apache.org/jira/browse/FLINK-1967 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-924) Extend JarFileCreator to automatically include dependencies

[ https://issues.apache.org/jira/browse/FLINK-924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-924. Resolution: Fixed Added in

[jira] [Resolved] (FLINK-1615) Introduces a new InputFormat for Tweets

[ https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1615. - Resolution: Fixed Added in

[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=14528491#comment-14528491 ] Aljoscha Krettek commented on FLINK-1962: - If would be against reimplementing

[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=14532562#comment-14532562 ] Aljoscha Krettek commented on FLINK-1962: - I have a pending pull request that

[jira] [Commented] (FLINK-1991) Return Table as DataSetTuple

[ https://issues.apache.org/jira/browse/FLINK-1991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534183#comment-14534183 ] Aljoscha Krettek commented on FLINK-1991: - But conversion to a tuple is only

[jira] [Assigned] (FLINK-1990) Uppercase AS keyword not allowed in select expression

[ https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1990: --- Assignee: Aljoscha Krettek Uppercase AS keyword not allowed in select expression

[jira] [Created] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

Aljoscha Krettek created FLINK-1985: --- Summary: Streaming does not correctly forward ExecutionConfig to runtime Key: FLINK-1985 URL: https://issues.apache.org/jira/browse/FLINK-1985 Project: Flink

[jira] [Closed] (FLINK-1997) Neither nor != supported for non-equals predicates in .filter()

[ https://issues.apache.org/jira/browse/FLINK-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1997. --- Resolution: Fixed Fixed in

[jira] [Closed] (FLINK-1998) Equality filter predicate not correctly evaluated by Table API

[ https://issues.apache.org/jira/browse/FLINK-1998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1998. --- Resolution: Fixed Fixed in

[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=14537938#comment-14537938 ] Aljoscha Krettek commented on FLINK-1962: - Yes, this is correct, because the Java

[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=14538018#comment-14538018 ] Aljoscha Krettek commented on FLINK-1962: - Yes, because the Scala type analysis

[jira] [Created] (FLINK-2000) Add SQL-style aggregations for Table API

Aljoscha Krettek created FLINK-2000: --- Summary: Add SQL-style aggregations for Table API Key: FLINK-2000 URL: https://issues.apache.org/jira/browse/FLINK-2000 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException

[ https://issues.apache.org/jira/browse/FLINK-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538407#comment-14538407 ] Aljoscha Krettek commented on FLINK-1989: - I could rework the code generation to

[jira] [Commented] (FLINK-1996) Add output methods to Table API

[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538490#comment-14538490 ] Aljoscha Krettek commented on FLINK-1996: - I would say so, yes. Add output

[jira] [Updated] (FLINK-1996) Add output methods to Table API

[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1996: Assignee: (was: Aljoscha Krettek) Add output methods to Table API

[jira] [Assigned] (FLINK-1998) Equality filter predicate not correctly evaluated by Table API

[ https://issues.apache.org/jira/browse/FLINK-1998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1998: --- Assignee: Aljoscha Krettek Equality filter predicate not correctly evaluated by

[jira] [Commented] (FLINK-1998) Equality filter predicate not correctly evaluated by Table API

[ https://issues.apache.org/jira/browse/FLINK-1998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534461#comment-14534461 ] Aljoscha Krettek commented on FLINK-1998: - Found the problem. The generated code

[jira] [Commented] (FLINK-1996) Add output methods to Table API

[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534464#comment-14534464 ] Aljoscha Krettek commented on FLINK-1996: - In scala this works already, using

[jira] [Commented] (FLINK-1996) Add output methods to Table API

[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534438#comment-14534438 ] Aljoscha Krettek commented on FLINK-1996: - This would require duplicating all the

[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=14541827#comment-14541827 ] Aljoscha Krettek commented on FLINK-1962: - Sorry, your comment did not appear yet

[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=14541810#comment-14541810 ] Aljoscha Krettek commented on FLINK-1962: - I'm sorry. It seems that the Graph API

[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=14539545#comment-14539545 ] Aljoscha Krettek commented on FLINK-1962: - I created a new PR that allows the

[jira] [Updated] (FLINK-2003) Building on some encrypted filesystems leads to File name too long error

[ https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2003: Labels: build starter (was: build) Building on some encrypted filesystems leads to File

[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=14545210#comment-14545210 ] Aljoscha Krettek commented on FLINK-1962: - Which are the syntactic sugar lines? Do

[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=14545348#comment-14545348 ] Aljoscha Krettek commented on FLINK-1962: - Oh my, the gift that keeps on giving.

[jira] [Updated] (FLINK-1990) Uppercase AS keyword not allowed in select expression

[ https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1990: Assignee: Cheng Hao (was: Aljoscha Krettek) Uppercase AS keyword not allowed in select

[jira] [Closed] (FLINK-1711) Replace all usages off commons.Validate with guava.check

[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1711. --- Resolution: Fixed Fixed in

[jira] [Created] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

Aljoscha Krettek created FLINK-2023: --- Summary: TypeExtractor does not work for (some) Scala Classes Key: FLINK-2023 URL: https://issues.apache.org/jira/browse/FLINK-2023 Project: Flink

[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=14545490#comment-14545490 ] Aljoscha Krettek commented on FLINK-1962: - I'm afraid it's the most elegant

[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=14545492#comment-14545492 ] Aljoscha Krettek commented on FLINK-1962: - This is the issue I filed:

[jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547985#comment-14547985 ] Aljoscha Krettek commented on FLINK-2033: - Yes, I think this is the right way to

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14548050#comment-14548050 ] Aljoscha Krettek commented on FLINK-1985: - It says I cannot assign issues to user

[jira] [Assigned] (FLINK-2009) Time-Based Windows fail with Chaining Disabled

[ https://issues.apache.org/jira/browse/FLINK-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2009: --- Assignee: Aljoscha Krettek Time-Based Windows fail with Chaining Disabled

[jira] [Commented] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase

[ https://issues.apache.org/jira/browse/FLINK-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550062#comment-14550062 ] Aljoscha Krettek commented on FLINK-2036: - [~rmetzger] This should be resolved

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1985: Reporter: Aljoscha Krettek (was: Matthias J. Sax) Streaming does not correctly forward

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1985: Assignee: Matthias J. Sax (was: Aljoscha Krettek) Streaming does not correctly forward

[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=14539577#comment-14539577 ] Aljoscha Krettek commented on FLINK-1962: - Dammit, right you are. I will fix it.

[jira] [Closed] (FLINK-1990) Uppercase AS keyword not allowed in select expression

[ https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1990. --- Fixed in https://github.com/apache/flink/commit/6dd241d3bb7b0d057c04187bc114313f9c9e1937

[jira] [Resolved] (FLINK-1900) Table API documentation example does not work

[ https://issues.apache.org/jira/browse/FLINK-1900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1900. - Resolution: Fixed Fixed in

[jira] [Commented] (FLINK-1900) Table API documentation example does not work

[ https://issues.apache.org/jira/browse/FLINK-1900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14499362#comment-14499362 ] Aljoscha Krettek commented on FLINK-1900: - Thanks for catching that, I changed the

[jira] [Resolved] (FLINK-1856) Add required imports to Scala API examples

[ https://issues.apache.org/jira/browse/FLINK-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1856. - Resolution: Fixed Fixed in

[jira] [Assigned] (FLINK-1900) Table API documentation example does not work

[ https://issues.apache.org/jira/browse/FLINK-1900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1900: --- Assignee: Aljoscha Krettek Table API documentation example does not work

[jira] [Created] (FLINK-1903) Joins where one side uses a field more than once don't work

Aljoscha Krettek created FLINK-1903: --- Summary: Joins where one side uses a field more than once don't work Key: FLINK-1903 URL: https://issues.apache.org/jira/browse/FLINK-1903 Project: Flink

[jira] [Created] (FLINK-1904) Add cross() to Table API

Aljoscha Krettek created FLINK-1904: --- Summary: Add cross() to Table API Key: FLINK-1904 URL: https://issues.apache.org/jira/browse/FLINK-1904 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1880) TaskManagerTest fails spuriously

Aljoscha Krettek created FLINK-1880: --- Summary: TaskManagerTest fails spuriously Key: FLINK-1880 URL: https://issues.apache.org/jira/browse/FLINK-1880 Project: Flink Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1710. - Resolution: Fixed Fixed by switching compile backend to janino:

[jira] [Resolved] (FLINK-1910) why this code flink not reurn value when use variable in filter

[ https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1910. - Resolution: Not A Problem Could you please post questions about using Flink to the user

[jira] [Resolved] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue

[ https://issues.apache.org/jira/browse/FLINK-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1823. - Resolution: Fixed Fixed in :

[jira] [Assigned] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue

[ https://issues.apache.org/jira/browse/FLINK-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-1823: --- Assignee: Aljoscha Krettek Rename linq.md to something like table.md to avoid

[jira] [Assigned] (FLINK-2054) StreamOperator rework removed copy calls when passing output to a chained operator

[ https://issues.apache.org/jira/browse/FLINK-2054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2054: --- Assignee: Aljoscha Krettek StreamOperator rework removed copy calls when passing

[jira] [Closed] (FLINK-1977) Rework Stream Operators to always be push based

[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1977. --- Resolution: Fixed Fix Version/s: 0.9 Fixed in

  1   2   3   4   5   6   7   8   9   10   >