[jira] [Resolved] (FLINK-1314) Update website about #flink chat room in freenode IRC

[ https://issues.apache.org/jira/browse/FLINK-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra resolved FLINK-1314. -- Resolution: Fixed Fix Version/s: master Committed revision 1656952 > Update website abou

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14304192#comment-14304192 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72752968 @qmlmoon sweet. @rmetzger errors should show up on the console now. and in the .out file. and i suppose by extension in the .log file aswell. --- If your project

[GitHub] flink pull request: Allow KeySelectors to implement ResultTypeQuer...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/354#issuecomment-72752435 Nope, sorry, also have no Idea why this is happening. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14304150#comment-14304150 ] ASF GitHub Bot commented on FLINK-377: -- Github user qmlmoon commented on the pull requ

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user qmlmoon commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72749480 Great. Now it works for me --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have th

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14304119#comment-14304119 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72746379 Ive added a potential fix for the /tmp path issue. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your p

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72744279 about error messages going to command-line: the only way i see for that to work is by wrapping the complete error message into an exception, since they do show up on the co

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14304096#comment-14304096 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[jira] [Commented] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14304088#comment-14304088 ] ASF GitHub Bot commented on FLINK-1471: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request: [FLINK-1471][java-api] Fixes wrong input valid...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/359 [FLINK-1471][java-api] Fixes wrong input validation if function has no generics FLINK-1471 was not implemented properly. See also #354. This PR skips the input validation if no generic param

[GitHub] flink pull request: Allow KeySelectors to implement ResultTypeQuer...

Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/354#issuecomment-72741911 I looked into your issue. Scala has a very strange behavior at this point. I don't know why it converts `Int` to `Object`. The TypeExtractor gets `Tuple3` which results in

[jira] [Commented] (FLINK-592) Add support for secure YARN clusters with Kerberos Auth

[ https://issues.apache.org/jira/browse/FLINK-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14304042#comment-14304042 ] ASF GitHub Bot commented on FLINK-592: -- Github user warneke commented on the pull requ

[GitHub] flink pull request: [FLINK-592] Add support for Kerberos secured Y...

Github user warneke commented on the pull request: https://github.com/apache/flink/pull/358#issuecomment-72739181 Hi, I tried the code and found the following three problems: __Flink launch script (bin/flink) points to the wrong log4j configuration file__ log

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14303979#comment-14303979 ] ASF GitHub Bot commented on FLINK-377: -- Github user qmlmoon commented on the pull requ

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user qmlmoon commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72734478 I got the same issue as fabian on OS X. The problem may result from different tmp files created by java and that used in python. In java you created a file under `$"ja

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14303932#comment-14303932 ] ASF GitHub Bot commented on FLINK-377: -- Github user rmetzger commented on the pull req

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72729815 > "hard to find error messages" what do you mean by that? Mh, for example that the output of the failed python script was logged to the ".out" file, and not immed

[jira] [Commented] (FLINK-1314) Update website about #flink chat room in freenode IRC

[ https://issues.apache.org/jira/browse/FLINK-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303665#comment-14303665 ] Henry Saputra commented on FLINK-1314: -- Awesome! Thanks Robert > Update website abou

[jira] [Commented] (FLINK-592) Add support for secure YARN clusters with Kerberos Auth

[ https://issues.apache.org/jira/browse/FLINK-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303643#comment-14303643 ] ASF GitHub Bot commented on FLINK-592: -- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-592] Add support for Kerberos secured Y...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/358 [FLINK-592] Add support for Kerberos secured YARN setups to Flink. This pull request is basically a port of @warneke's branch (https://github.com/warneke/flink/tree/security) to the latest `master`

[jira] [Commented] (FLINK-1314) Update website about #flink chat room in freenode IRC

[ https://issues.apache.org/jira/browse/FLINK-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303569#comment-14303569 ] Robert Metzger commented on FLINK-1314: --- Sorry, I was too busy today. The change loo

[jira] [Commented] (FLINK-1314) Update website about #flink chat room in freenode IRC

[ https://issues.apache.org/jira/browse/FLINK-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303567#comment-14303567 ] Henry Saputra commented on FLINK-1314: -- If no comment, will merge this end of day >

[GitHub] flink pull request: Improved exception for missing type of InputFo...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/351#issuecomment-72686769 Ah, I meant to suggest different error message to make sure we know either input format or type information is missing. I will send another PR to implement this.

[GitHub] flink pull request: [FLINK-1330] [build] Build creates a link in t...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/333#issuecomment-72678817 Ah, okay. I was on a branch which has not been rebased yet (so it didn't contain the exclude). So for now I have to do a "mvn clean" before going to older branches.

[jira] [Resolved] (FLINK-1468) Config parse failure fails task manager startup w/o an error message

[ https://issues.apache.org/jira/browse/FLINK-1468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1468. Resolution: Fixed Fixed in 2bea793. > Config parse failure fails task manager startup w/o an error

[jira] [Commented] (FLINK-1330) Restructure directory layout

[ https://issues.apache.org/jira/browse/FLINK-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303508#comment-14303508 ] ASF GitHub Bot commented on FLINK-1330: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1330) Restructure directory layout

[ https://issues.apache.org/jira/browse/FLINK-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303497#comment-14303497 ] ASF GitHub Bot commented on FLINK-1330: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1330] [build] Build creates a link in t...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/333#issuecomment-72678344 I modified the merged version to exclude it from rat. I also tried subsequent builds, it worked. See here: https://github.com/apache/flink/commit/0c726f833892

[jira] [Commented] (FLINK-1330) Restructure directory layout

[ https://issues.apache.org/jira/browse/FLINK-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303483#comment-14303483 ] ASF GitHub Bot commented on FLINK-1330: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1330] [build] Build creates a link in t...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/333#issuecomment-72676563 The symlink is not excluded from the rat check. So subsequent builds will fail due to the rat check. --- If your project is set up for it, you can reply to this email an

[jira] [Created] (FLINK-1472) Web frontend config overview shows wrong value

Ufuk Celebi created FLINK-1472: -- Summary: Web frontend config overview shows wrong value Key: FLINK-1472 URL: https://issues.apache.org/jira/browse/FLINK-1472 Project: Flink Issue Type: Bug

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14303420#comment-14303420 ] ASF GitHub Bot commented on FLINK-377: -- Github user qmlmoon commented on the pull requ

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user qmlmoon commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72668635 I would also like to try out some examples. I'm starting with TPCH queries:D --- If your project is set up for it, you can reply to this email and have your reply appear o

[jira] [Resolved] (FLINK-758) Add count method to DataSet and implement CountOperator

[ https://issues.apache.org/jira/browse/FLINK-758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-758. --- Resolution: Won't Fix Subsumed by https://github.com/apache/flink/pull/210 > Add count method to DataS

[GitHub] flink pull request: Allow KeySelectors to implement ResultTypeQuer...

Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/354#issuecomment-72660810 I think that [this StackOverflow article explains my problem](http://stackoverflow.com/questions/11586944/how-to-obtain-the-raw-datatype-of-a-parameter-of-a-field-that-

[GitHub] flink pull request: Allow KeySelectors to implement ResultTypeQuer...

Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/354#issuecomment-72660318 I would advocate to adding this one as well as a fallback option. I have a situation where I want to use KeySelector that might return Java TupleXX instances p

[jira] [Commented] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak

[ https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303334#comment-14303334 ] Stephan Ewen commented on FLINK-1455: - Hmm, this seems a problem of the JVM setup on t

[jira] [Resolved] (FLINK-1326) The output serializers may consume excessive memory

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14303266#comment-14303266 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72652471 hmm...you are now the second person to report that creating the tmp files does not work on OS X. i don't know why that doesn't work. the file creation is done from java, is

[jira] [Resolved] (FLINK-1330) Restructure directory layout

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

[GitHub] flink pull request: [FLINK-1330] [build] Build creates a link in t...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/333 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (FLINK-1330) Restructure directory layout

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

[jira] [Reopened] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-1471: --- The commit Stephan mentions fixes another issue. This is still unresolved. > Allow KeySelectors t

[jira] [Resolved] (FLINK-1464) Added ResultTypeQueryable interface to TypeSerializerInputFormat.

[ https://issues.apache.org/jira/browse/FLINK-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1464. --- Resolution: Fixed Fixed via e3f6c9ba69a3e545fdd8f18b7b652fa111ade93e Thanks for the patch! Th

[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-tabpanel&focusedCommentId=14303187#comment-14303187 ] ASF GitHub Bot commented on FLINK-1458: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1458] Allow Interfaces and abstract typ...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/357#issuecomment-72642370 You're right. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature e

[jira] [Resolved] (FLINK-1437) Bug in PojoSerializer's copy() method

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

[jira] [Resolved] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]]

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

[jira] [Resolved] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

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

[jira] [Commented] (FLINK-1165) No createCollectionsEnvironment in Java API

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

[jira] [Commented] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]]

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

[jira] [Resolved] (FLINK-1165) No createCollectionsEnvironment in Java API

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

[GitHub] flink pull request: [FLINK-1193][java-api][scala-api] Complete sup...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/348 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (FLINK-1464) Added ResultTypeQueryable interface to TypeSerializerInputFormat.

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

[GitHub] flink pull request: [FLINK-1437][Java API] Fixes copy() methods in...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/342 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] flink pull request: [FLINK-1165] No createCollectionsEnvironment i...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/320 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (FLINK-1437) Bug in PojoSerializer's copy() method

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

[GitHub] flink pull request: Improved exception for missing type of InputFo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/351 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] flink pull request: [FLINK-1464] Add ResultTypeQueryable interface...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/349 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14303170#comment-14303170 ] ASF GitHub Bot commented on FLINK-377: -- Github user fhueske commented on the pull requ

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72641447 btw. implementing the program felt quite good. Very nice API, IMO! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14303164#comment-14303164 ] ASF GitHub Bot commented on FLINK-377: -- Github user fhueske commented on the pull requ

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-72640916 Just implemented the basic triangle enumeration job and figured out that this example is already included in this PR ;-) However, when trying to run both programs, I en

[jira] [Commented] (FLINK-1464) Added ResultTypeQueryable interface to TypeSerializerInputFormat.

[ https://issues.apache.org/jira/browse/FLINK-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303075#comment-14303075 ] ASF GitHub Bot commented on FLINK-1464: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1464] Add ResultTypeQueryable interface...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/349#issuecomment-72631504 Looks good to me. I think the API breaking is minor, since it does not affect the methods on `DataSet` or on any of the operators. The TypeSerializerInputFormat is onl

[jira] [Commented] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]]

[ https://issues.apache.org/jira/browse/FLINK-1193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303064#comment-14303064 ] ASF GitHub Bot commented on FLINK-1193: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1193][java-api][scala-api] Complete sup...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/348#issuecomment-72630115 I will merge this, fixing the comment... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your projec

[jira] [Commented] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]]

[ https://issues.apache.org/jira/browse/FLINK-1193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303060#comment-14303060 ] ASF GitHub Bot commented on FLINK-1193: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1193][java-api][scala-api] Complete sup...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/348#discussion_r23995382 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializer.java --- @@ -72,7 +72,9 @@ public boolean isStateful(

[GitHub] flink pull request: Improved exception for missing type of InputFo...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/351#issuecomment-72629129 I tried to implement Henry's idea, but I noticed the error message is very specific to the site where it is created, since it refers to an alternate method of `DataSet

[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-tabpanel&focusedCommentId=14303054#comment-14303054 ] ASF GitHub Bot commented on FLINK-1458: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1458] Allow Interfaces and abstract typ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/357#issuecomment-72628325 The tests cover that the serializer supports this. One issue was that the type extractor rejected the types, even though they were supported. --- If your project is s

[jira] [Resolved] (FLINK-1105) Add support for locally sorted output

[ https://issues.apache.org/jira/browse/FLINK-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1105. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with 5f475599264d3d388e81cbceb71b641e1bb7d83f

[jira] [Commented] (FLINK-1105) Add support for locally sorted output

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

[GitHub] flink pull request: [FLINK-1105] Add support for locally sorted ou...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/347 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] flink pull request: Improved exception for missing type of InputFo...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/351#issuecomment-72623931 I'll merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this f

[jira] [Commented] (FLINK-1437) Bug in PojoSerializer's copy() method

[ https://issues.apache.org/jira/browse/FLINK-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303028#comment-14303028 ] ASF GitHub Bot commented on FLINK-1437: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1437][Java API] Fixes copy() methods in...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/342#issuecomment-72623753 Ah, just saw that the tests are there. My bad... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[jira] [Commented] (FLINK-1437) Bug in PojoSerializer's copy() method

[ https://issues.apache.org/jira/browse/FLINK-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303013#comment-14303013 ] ASF GitHub Bot commented on FLINK-1437: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1437][Java API] Fixes copy() methods in...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/342#issuecomment-72621357 I ran into this error as well. Will merge this and add a test... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14303007#comment-14303007 ] ASF GitHub Bot commented on FLINK-1471: --- Github user rmetzger commented on the pull

[jira] [Created] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable

Robert Metzger created FLINK-1471: - Summary: Allow KeySelectors to implement ResultTypeQueryable Key: FLINK-1471 URL: https://issues.apache.org/jira/browse/FLINK-1471 Project: Flink Issue Typ

[GitHub] flink pull request: Allow KeySelectors to implement ResultTypeQuer...

Github user rmetzger closed the pull request at: https://github.com/apache/flink/pull/354 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is ena

[GitHub] flink pull request: Allow KeySelectors to implement ResultTypeQuer...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/354#issuecomment-72620298 I'll close it. I've filed a jira for the issue and assigned it to @twalthr: https://issues.apache.org/jira/browse/FLINK-1471 --- If your project is set up for it, yo

[jira] [Commented] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14302997#comment-14302997 ] ASF GitHub Bot commented on FLINK-1376: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1376] [runtime] Add proper shared slot ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/317#issuecomment-72618925 I think this is a good fix, overall. There is one issue I would really like to fix, and that is the serializability of the `Instance` class. This class is not meant to

[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-tabpanel&focusedCommentId=14302986#comment-14302986 ] ASF GitHub Bot commented on FLINK-1458: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: Improved exception for missing type of InputFo...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/351#issuecomment-72618284 Good idea, Henry, if we can make sure that the IllegalArgumentException is not thrown in any other cases. --- If your project is set up for it, you can reply to this

[GitHub] flink pull request: [FLINK-1458] Allow Interfaces and abstract typ...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/357#issuecomment-72618070 But I extended the test with a SerializerTest for both Interfaces (traits) and abstract classes. The other thing I will change, yes. --- If your project is set up for it

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14302976#comment-14302976 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on a diff in the

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/202#discussion_r23990492 --- Diff: flink-addons/flink-language-binding/src/main/python/org/apache/flink/languagebinding/api/python/dill/__diff.py --- @@ -0,0 +1,247 @@ +##

[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-tabpanel&focusedCommentId=14302966#comment-14302966 ] ASF GitHub Bot commented on FLINK-1458: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: Allow KeySelectors to implement ResultTypeQuer...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/354#issuecomment-72614564 So, this pull request can be closed? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project do

[GitHub] flink pull request: [FLINK-1458] Allow Interfaces and abstract typ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/357#issuecomment-72614433 Looks good to me so far, modulo two comments: - Since the type extractor code is changed a lot, it would be good to have a test validating that the TypeExtractor

[jira] [Commented] (FLINK-1318) Make quoted String parsing optional and configurable for CSVInputFormats

[ https://issues.apache.org/jira/browse/FLINK-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14302954#comment-14302954 ] ASF GitHub Bot commented on FLINK-1318: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-1318] CsvInputFormat: Made quoted strin...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/265#issuecomment-72613154 The API was just extended, but the parsing logic for strings changed (see PR description). So programs that relied on the previous way of parsing will fail now. --- If y

[jira] [Commented] (FLINK-1318) Make quoted String parsing optional and configurable for CSVInputFormats

[ https://issues.apache.org/jira/browse/FLINK-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14302948#comment-14302948 ] ASF GitHub Bot commented on FLINK-1318: --- Github user StephanEwen commented on the pu

  1   2   >