Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-82254957
I have revised the commit .. All the files has the license header, except a
resource file which contains 4 tweets for testing purpose .. Could this be the
problem
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-82261434
DONE
---
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
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-83499608
@StephanEwen I have checked and I found that the RAT plugin is included in
parent pom.xml file. Shall I exclude the resources folder in flink-contribute,
or add
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-83519001
@StephanEwen, I have removed the license from the resource file, excluded
it from RAT, and added the license file. Also I did rebase against
upstream/master, before
Github user Elbehery commented on a diff in the pull request:
https://github.com/apache/flink/pull/442#discussion_r26284910
--- Diff:
flink-contrib/src/main/java/org/apache/flink/contrib/tweetinputformat/io/SimpleTweetInputFormat.java
---
@@ -0,0 +1,67 @@
+package
Github user Elbehery commented on a diff in the pull request:
https://github.com/apache/flink/pull/442#discussion_r26288077
--- Diff:
flink-contrib/src/test/java/org/apache/flink/contrib/SimpleTweetInputFormatTest.java
---
@@ -0,0 +1,62 @@
+package org.apache.flink.contrib
Github user Elbehery commented on a diff in the pull request:
https://github.com/apache/flink/pull/442#discussion_r26285363
--- Diff:
flink-contrib/src/main/java/org/apache/flink/contrib/tweetinputformat/io/SimpleTweetInputFormat.java
---
@@ -0,0 +1,67 @@
+package
Github user Elbehery commented on a diff in the pull request:
https://github.com/apache/flink/pull/442#discussion_r26300742
--- Diff:
flink-contrib/src/test/java/org/apache/flink/contrib/SimpleTweetInputFormatTest.java
---
@@ -0,0 +1,76 @@
+package org.apache.flink.contrib
Github user Elbehery commented on a diff in the pull request:
https://github.com/apache/flink/pull/442#discussion_r26299783
--- Diff:
flink-contrib/src/test/java/org/apache/flink/contrib/SimpleTweetInputFormatTest.java
---
@@ -0,0 +1,76 @@
+package org.apache.flink.contrib
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-78480294
@rmetzger This is the standard Tweet format as per Twitter. Here You can
find [Twitter Official
Documentation](https://dev.twitter.com/overview/api/tweets). My parser
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-78480464
@StephanEwen I have added the license.
---
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
Github user Elbehery commented on a diff in the pull request:
https://github.com/apache/flink/pull/442#discussion_r26296323
--- Diff:
flink-contrib/src/main/java/org/apache/flink/contrib/tweetinputformat/io/SimpleTweetInputFormat.java
---
@@ -0,0 +1,67 @@
+package
Github user Elbehery commented on a diff in the pull request:
https://github.com/apache/flink/pull/442#discussion_r26296679
--- Diff:
flink-contrib/src/test/java/org/apache/flink/contrib/SimpleTweetInputFormatTest.java
---
@@ -0,0 +1,76 @@
+package org.apache.flink.contrib
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-84968643
@rmetzger I think it failed again, but I cant see the reason
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user Elbehery opened a pull request:
https://github.com/apache/flink/pull/442
[FLINK-1615] [java api] SimpleTweetInputFormat
This is a contribution with a TweetInputFormat, Jira
[FLINK-1615](https://issues.apache.org/jira/browse/FLINK-1615).
This commit contains
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-95603365
@aljoscha you should be able to see it from the PR .. anyway this is mine
https://github.com/Elbehery/flink
---
If your project is set up for it, you can reply
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-95866843
@aljoscha u were right.. I could not find the code on my repo, somehow it
was lost !!! ..
I have created a new PR now, #621 .. it has the same commit of #442
GitHub user Elbehery opened a pull request:
https://github.com/apache/flink/pull/621
[FLINK-1615] [java api] SimpleTweetInputFormat
A replacement for PR #442
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Elbehery/flink
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/621#issuecomment-96418152
@aljoscha I have checked the Travic log. The problem is in Flink
Streaming, so why my branch failed ?!!
---
If your project is set up for it, you can reply
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-95512206
I did rebase against the master before creating the PR .. but this was long
time ago, could this be the problems for the conflicts ?!!
---
If your project is set up
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/621#issuecomment-96041144
@aljoscha Yes I wrote these Pojos myself, and I have tested the handler to
retrieve distinct data, coz the tweets has redundant fields.
I have added
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/621#issuecomment-97068257
@aljoscha GOT IT .. Now the build success locally.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/621#issuecomment-96809741
@aljoscha I have run code format from Intellij, I think the problem should
be solved now ..
I have tried to read the travis build log, but I could not find
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-92100736
@rmetzger Still not merged, any updates ?
---
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
[
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
[
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 release
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
[
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
36 matches
Mail list logo
