[GitHub] flink pull request: [FLINK-610] Replace Avro with Kryo as the Gene...

Github user Elbehery commented on the pull request: https://github.com/apache/flink/pull/271#issuecomment-70624472 @rmetzger I have a problem with the Kryo serializer, it creates a reference of my Pojo and not an object. I am using an event driven Json parser, in which I should fill

[jira] [Commented] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283628#comment-14283628 ] mustafa elbehery commented on FLINK-629: @rmetzger I have a problem with the Kryo s

[jira] [Commented] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283640#comment-14283640 ] Robert Metzger commented on FLINK-629: -- This screenshot from github is related I guess

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

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/318#discussion_r23212042 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/instance/SharedSlot.java --- @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foun

[jira] [Updated] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1421: -- Assignee: Paris Carbone (was: Gyula Fora) > Implement a SAMOA Adapter for Flink Streaming > ---

[jira] [Assigned] (FLINK-1417) Automatically register nested types at Kryo

[ https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1417: - Assignee: Robert Metzger > Automatically register nested types at Kryo >

[GitHub] flink pull request: [FLINK-1369] [types] Add support for Subclasse...

Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/316#issuecomment-70635445 Looks good. You should add generics or least `` to `TypeSerializer` in the `PojoSerializer`. My IDE shows me lots of warnings. --- If your project is set up for it, you c

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

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-1319: --- Assignee: Timo Walther > Add static code analysis for UDFs >

[jira] [Commented] (FLINK-1353) Execution always uses DefaultAkkaAskTimeout, rather than the configured value

[ https://issues.apache.org/jira/browse/FLINK-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283731#comment-14283731 ] Till Rohrmann commented on FLINK-1353: -- Good catch. I'll forward the timeout set in t

[GitHub] flink pull request: [FLINK-1296] Add sorter support for very large...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/249#issuecomment-70645554 +1 I will merge this in the next batch. --- 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 proje

[jira] [Updated] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mustafa elbehery updated FLINK-629: --- Attachment: Selection_006.png > Add support for null values to the java api > -

[jira] [Updated] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mustafa elbehery updated FLINK-629: --- Attachment: Selection_006.png GenericType not Pojo. I have attached a screenShot of the debugge

[jira] [Updated] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mustafa elbehery updated FLINK-629: --- Attachment: (was: Selection_006.png) > Add support for null values to the java api > --

[GitHub] flink pull request: [FLINK-1353] Fixes the Execution to use the co...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/325 [FLINK-1353] Fixes the Execution to use the configured Akka timeout value Loops through the JobManager's timeout value to the Execution to make the timeout for the Execution configurable. You c

[jira] [Commented] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283815#comment-14283815 ] mustafa elbehery commented on FLINK-629: I have tried to set the type explicitly By

[jira] [Commented] (FLINK-1351) Inconclusive error when TaskManager cannot connect to JobManager

[ https://issues.apache.org/jira/browse/FLINK-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283932#comment-14283932 ] Till Rohrmann commented on FLINK-1351: -- I could not reproduce the timeout error. What

[jira] [Commented] (FLINK-1352) Buggy registration from TaskManager to JobManager

[ https://issues.apache.org/jira/browse/FLINK-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283945#comment-14283945 ] Till Rohrmann commented on FLINK-1352: -- That is a good point. I'll let the JobManager

[GitHub] flink pull request: Rename coGroupDataSet.scala to CoGroupDataSet....

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/324#issuecomment-70676663 Why do you want to move them? On Jan 20, 2015 4:42 AM, "Henry Saputra" wrote: > FYI @aljoscha > > — > Reply to thi

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/326 [FLINK-1201] Add flink-gelly to flink-addons This PR adds an initial version of Gelly, a graph API for Flink, to the flink-addons project. The development of Gelly took place as a collaboration on

[GitHub] flink pull request: [FLINK-1296] Add sorter support for very large...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/249#issuecomment-70702082 OK I've rebased this PR on the current master. All tests are running locally (Travis is still flaky). @mxm is running some cluster tests. I'll push to master after his OK. :-)

[GitHub] flink pull request: [FLINK-1372] [runtime] Fix akka logging

Github user uce commented on the pull request: https://github.com/apache/flink/pull/321#issuecomment-70705539 I've tested this and the logging works as before (pre akka), e.g. everything is in the jm/tm log file. :-) Logging of the temp directories got somehow lost on the way.

[GitHub] flink pull request: Rename coGroupDataSet.scala to CoGroupDataSet....

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/324#issuecomment-70715529 I rename the file from coGroupDataSet.scala to CoGroupDataSet.scala and crossDataSet.scala to CrossDataSet.scala to follow convention Scala file naming. And move

[GitHub] flink pull request: [FLINK-1372] [runtime] Fix akka logging

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/321 --- 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] [Resolved] (FLINK-1372) TaskManager and JobManager do not log startup settings any more

[ https://issues.apache.org/jira/browse/FLINK-1372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1372. Resolution: Fixed Fixed in 4e197d5..ce8acc4 > TaskManager and JobManager do not log startup setting

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70717064 Great, I'm super excited to see the graph API being offered to the main project. I'll start reviewing the code right away, to merge it as soon as possible. On

[jira] [Created] (FLINK-1422) Missing usage example for "withParameters"

Alexander Alexandrov created FLINK-1422: --- Summary: Missing usage example for "withParameters" Key: FLINK-1422 URL: https://issues.apache.org/jira/browse/FLINK-1422 Project: Flink Issue

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/326#discussion_r23248831 --- Diff: flink-addons/flink-gelly/src/test/java/org/apache/flink/gelly/test/TestWeaklyConnected.java --- @@ -0,0 +1,143 @@ +/* + * Licensed to the A

[GitHub] flink pull request: Implement the convenience methods count and co...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/210#issuecomment-70718732 I've implemented count and collect in the Scala API. There is still a problem with the `ListAccumulator` for non-primitive Objects (e.g. not Integer or Long) probably due to O

[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 ] Robert Metzger updated FLINK-1303: -- Component/s: Scala API > HadoopInputFormat does not work with Scala API > --

[GitHub] flink pull request: [FLINK-1147][Java API] TypeInference on POJOs

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/315#issuecomment-70723442 I didn't find any issues in the code. Good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If yo

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/326#discussion_r23252081 --- Diff: flink-addons/flink-gelly/src/main/java/org/apache/flink/gelly/Edge.java --- @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache Software Foundat

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70725539 Hi @rmetzger! Thanks for starting on it so fast ^^ Regarding the name, we thought it'd be nice to have one.. It was actually @ktzoumas that came up with Gelly :)

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70740654 Regarding the name: I would actually vote to call it "flink-graph". Mh, back then @mbalassi and @gyfora figured it out the last time. Maybe they can remember how

[jira] [Commented] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284480#comment-14284480 ] Robert Metzger commented on FLINK-629: -- I think the issue is that Kryo is currently no

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70743431 Woot! :) As for merging the streaming back then, it was @StephanEwen who came up with the solution, pasting the important parts here: " BTW: I used t

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70744282 I also prefer flink-graph. After having a quick look at the commits I would suggest to squash a couple of them, e. g. fda6e4c, which is empty or 393902c which deletes

[jira] [Commented] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284534#comment-14284534 ] mustafa elbehery commented on FLINK-629: It is proper POJO with all the setters and

[jira] [Updated] (FLINK-629) Add support for null values to the java api

[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mustafa elbehery updated FLINK-629: --- Attachment: SimpleTweetInputFormat.java Tweet.java > Add support for null value

[GitHub] flink pull request: [FLINK-1296] Add sorter support for very large...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/249#issuecomment-70758622 Cluster tests worked fine. If no one objects I'll merge this later today. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user uce commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70759342 I'm very exited about this :-) I will have a look later as well. Regarding the name: I like the name gelly, but would also prefer flink-graph (or something along the l

[jira] [Created] (FLINK-1423) No Tags for new release on the github repo

Carsten Brandt created FLINK-1423: - Summary: No Tags for new release on the github repo Key: FLINK-1423 URL: https://issues.apache.org/jira/browse/FLINK-1423 Project: Flink Issue Type: Task

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user ktzoumas commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70767467 I think Gelly has way more personality than flink-graph --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Created] (FLINK-1424) bin/flink run does not recognize -c parameter anymore

Carsten Brandt created FLINK-1424: - Summary: bin/flink run does not recognize -c parameter anymore Key: FLINK-1424 URL: https://issues.apache.org/jira/browse/FLINK-1424 Project: Flink Issue T

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-70796718 +1 for Gelly :) It's good to personalize flink libraries somehow, people remember these. Though, to be honest, it would be more consistent in that case if oth