[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-tabpanelfocusedCommentId=14287392#comment-14287392 ] mustafa elbehery commented on FLINK-629: Its on Flink 9, I have to stick right now

[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-tabpanelfocusedCommentId=14289753#comment-14289753 ] mustafa elbehery commented on FLINK-629: [~rmetzger] I need this fix into

[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: SimpleTweetInputFormat.java Tweet.java Add support for null

[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-tabpanelfocusedCommentId=14284534#comment-14284534 ] mustafa elbehery commented on FLINK-629: It is proper POJO with all the setters and

[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-tabpanelfocusedCommentId=14288646#comment-14288646 ] mustafa elbehery commented on FLINK-629: Its working now, Thanks a lot robert for

[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 ] mustafa elbehery resolved FLINK-1615. - Resolution: Fixed https://github.com/apache/flink/pull/442 Introduces a new InputFormat

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

mustafa elbehery created FLINK-1615: --- Summary: Introduces a new InputFormat for Tweets Key: FLINK-1615 URL: https://issues.apache.org/jira/browse/FLINK-1615 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521195#comment-14521195 ] mustafa elbehery commented on FLINK-1959: - I just tried with DOP 1,2 and 5 .. All

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519494#comment-14519494 ] mustafa elbehery commented on FLINK-1959: - BTW, the version of Flink is 0.9 but it

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537312#comment-14537312 ] mustafa elbehery commented on FLINK-1959: - Any updates for this bug ?!!This is

[jira] [Commented] (FLINK-1959) Accumulators BROKEN after Partitioning

[ https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14539987#comment-14539987 ] mustafa elbehery commented on FLINK-1959: - I have tried debugging to check the