[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379359#comment-14379359
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-85866221
Cool, thanks. Will have a look shortly.
Did you rebase to the latest master? We had a few build issues with the
master branch a few days ago.
It is a g
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/534
[FLINK-1775] BarrierBuffer fix to avoid end of stream deadlock
This fixes several corner-cases in the barrier buffer logic.
Still two problems remain:
- If the StreamRecordWriter is a
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379329#comment-14379329
]
ASF GitHub Bot commented on FLINK-1775:
---
GitHub user gyfora opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379285#comment-14379285
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-85830275
Hi, I updated this PR.
* Remove `pojoType(Class targetType)` method in `CsvReader` to force the
user to explicitly specify the fields order.
* Add checking
GitHub user streamnsight opened a pull request:
https://github.com/apache/flink/pull/533
Flink dev cluster on Docker with Docker Compose deployment
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/streamnsight/flink master
Altern
[
https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379142#comment-14379142
]
Henry Saputra commented on FLINK-1783:
--
Could you explain more what does this JIRA me
Stephan Ewen created FLINK-1783:
---
Summary: Quickstart shading should not created shaded jar and
dependency reduced pom
Key: FLINK-1783
URL: https://issues.apache.org/jira/browse/FLINK-1783
Project: Flin
Stephan Ewen created FLINK-1782:
---
Summary: Change Quickstart Java version to 1.7
Key: FLINK-1782
URL: https://issues.apache.org/jira/browse/FLINK-1782
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-1781:
---
Summary: Quickstarts broken due to Scala Version Variables
Key: FLINK-1781
URL: https://issues.apache.org/jira/browse/FLINK-1781
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra resolved FLINK-1770.
--
Resolution: Fixed
Committed to master
> Rename the variable 'contentAdressable' to 'contentAddr
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/515
---
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
[
https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378855#comment-14378855
]
ASF GitHub Bot commented on FLINK-1770:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378851#comment-14378851
]
ASF GitHub Bot commented on FLINK-1776:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/532
[FLINK-1776] Add offsets to field indexes of semantic properties for
operators with key selectors
You can merge this pull request into a Git repository by running:
$ git pull https://github.co
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378843#comment-14378843
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/505#issuecomment-85725549
@vasia ,
I integrated your suggestions, the example works on the cluster for Orkut,
max iter = 20.
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378806#comment-14378806
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user derSascha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378804#comment-14378804
]
ASF GitHub Bot commented on FLINK-1756:
---
GitHub user derSascha opened a pull request
Github user derSascha commented on the pull request:
https://github.com/apache/flink/pull/506#issuecomment-85720375
Looks like the JobGraph missed the renaming.
---
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 proj
GitHub user derSascha opened a pull request:
https://github.com/apache/flink/pull/531
[FLINK-1756] [streaming] Rename Stream Monitoring to Streaming
Checkpointing in JobGraph
This is improves #506 and renames Monitoring to Checkpointing in JobGraph
too.
You can merge this pull req
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378789#comment-14378789
]
ASF GitHub Bot commented on FLINK-1779:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/529#issuecomment-85718215
+1 LGTM
---
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 smarthi commented on the pull request:
https://github.com/apache/flink/pull/530#issuecomment-85697927
@fhueske i think we shuld be LGTM now
---
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
Github user smarthi commented on the pull request:
https://github.com/apache/flink/pull/530#issuecomment-85688590
@fhueske yeah noticed that too, will update the PR
---
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
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/530#issuecomment-85688151
@smarthi Thanks for the PR!
LGTM, except for a few lines where I spotted space indentions that do not
comply with our code style.
---
If your project is set up for i
[
https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378568#comment-14378568
]
ASF GitHub Bot commented on FLINK-1615:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/442#issuecomment-85686759
The failure is not your fault. It failed because your code has been rebased
to a master version with failing tests.
---
If your project is set up for it, you can reply t
[
https://issues.apache.org/jira/browse/FLINK-1777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378538#comment-14378538
]
ASF GitHub Bot commented on FLINK-1777:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/528#issuecomment-85681137
Looks good, Thank you!
---
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
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/518#issuecomment-85678768
I moved the call to the Akka utils.
---
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 n
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378523#comment-14378523
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user rmetzger commented on the pull
GitHub user smarthi opened a pull request:
https://github.com/apache/flink/pull/530
Flink-1780: Rename FlatCombineFunction to GroupCombineFunction
Fixes Flink-1780
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/smarthi/flink Flin
[
https://issues.apache.org/jira/browse/FLINK-1780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suneel Marthi reassigned FLINK-1780:
Assignee: Suneel Marthi
> Rename FlatCombineFunction to GroupCombineFunction
>
Fabian Hueske created FLINK-1780:
Summary: Rename FlatCombineFunction to GroupCombineFunction
Key: FLINK-1780
URL: https://issues.apache.org/jira/browse/FLINK-1780
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong updated FLINK-1779:
--
Description: I think the function name "getCurrentyActiveConnections" in '
org.apache.flink.runtime.blob
[
https://issues.apache.org/jira/browse/FLINK-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378059#comment-14378059
]
ASF GitHub Bot commented on FLINK-1544:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378068#comment-14378068
]
ASF GitHub Bot commented on FLINK-1779:
---
GitHub user matadorhong opened a pull reque
GitHub user matadorhong opened a pull request:
https://github.com/apache/flink/pull/529
[FLINK-1779]Rename the function getCurrentyActiveConnections in '
org.apache.flink.runtime.blob'.
I think the function name "getCurrentyActiveConnections" in '
org.apache.flink.runtime.blob' is
Sibao Hong created FLINK-1779:
-
Summary: Rename the function name from
"getCurrentyActiveConnections" to "getCurrentActiveConnections" in
org.apache.flink.runtime.blob
Key: FLINK-1779
URL: https://issues.apache.org/
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/517#issuecomment-85578193
Pushed it to my master, merging as soon as travis comes in green.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reopened FLINK-1660:
This just occurred again during my local run. I think [~ktzoumas] ran into it
as well last week.
> Mul
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14378021#comment-14378021
]
Ufuk Celebi commented on FLINK-1319:
I vote for a combination of Stephan's and Fabian'
Stephan Ewen created FLINK-1778:
---
Summary: Improve normalized keys in composite key case
Key: FLINK-1778
URL: https://issues.apache.org/jira/browse/FLINK-1778
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377989#comment-14377989
]
ASF GitHub Bot commented on FLINK-1770:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/515#issuecomment-85543938
+1
Will merge this today unless someone beats me to it :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377965#comment-14377965
]
ASF GitHub Bot commented on FLINK-1656:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/525#issuecomment-85531186
Do you think this rule is "easy enough" for users?
It would make the handling consistent for all group-wise operators.
---
If your project is set up for it, you can r
[
https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377959#comment-14377959
]
ASF GitHub Bot commented on FLINK-1656:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/525#issuecomment-85528267
Good catch, that is a critical distinction (one output record forwarded
from same input record). Mostl relevant to MapPartition, though.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-1717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-1717:
Assignee: Till Rohrmann
> Add support to read libSVM and SVMLight input files
> ---
[
https://issues.apache.org/jira/browse/FLINK-1777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377942#comment-14377942
]
ASF GitHub Bot commented on FLINK-1777:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/528
[FLINK-1777] [docs] Update Java 8 Lambdas with Eclipse documentation
See FLINK-1777.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/twalthr/flink
Timo Walther created FLINK-1777:
---
Summary: Update Java 8 Lambdas with Eclipse documentation
Key: FLINK-1777
URL: https://issues.apache.org/jira/browse/FLINK-1777
Project: Flink
Issue Type: Bug
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/527
---
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
[
https://issues.apache.org/jira/browse/FLINK-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377907#comment-14377907
]
Fabian Hueske commented on FLINK-1776:
--
The fix is straight-forward.
We get the numbe
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377902#comment-14377902
]
Fabian Hueske commented on FLINK-1319:
--
(Copying my response from the mailing list)
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/527#issuecomment-85500135
I'll merge it.
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377847#comment-14377847
]
Robert Metzger commented on FLINK-1769:
---
I manually deployed to the snapshot reposit
[
https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377846#comment-14377846
]
ASF GitHub Bot commented on FLINK-1656:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/525#issuecomment-85499509
Yes, I agree. The fix is more conservative than necessary.
I think we can safely relax it if we make the rule for forwarded fields on
group-wise operators as follows:
[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377816#comment-14377816
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/420#issuecomment-85487676
Hi @balidani! I think it's still a bit confusing how this example works.
As far as I understand, you expect a directed graph as input, but then you
convert it to an undir
[
https://issues.apache.org/jira/browse/FLINK-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1761.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed in 380ef878c850f83b5e12176e465d59c737066e20 and
[
https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377791#comment-14377791
]
Stephan Ewen commented on FLINK-1769:
-
Anyone looking into this already?
This effecti
[
https://issues.apache.org/jira/browse/FLINK-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377789#comment-14377789
]
Stephan Ewen commented on FLINK-1776:
-
That is critical, I agree.
Can we make the ass
Github user matadorhong closed the pull request at:
https://github.com/apache/flink/pull/510
---
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
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377761#comment-14377761
]
Maximilian Michels commented on FLINK-1319:
---
This looks like a very promising wa
[
https://issues.apache.org/jira/browse/FLINK-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong reassigned FLINK-1714:
-
Assignee: Sibao Hong
> Fix the bug of logger class loader
> --
>
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377716#comment-14377716
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-85455383
Very good! Let me know, when you want me to have a look again :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-1768.
-
Resolution: Fixed
Fix Version/s: 0.9
Merged. Thank you!
> Fix the bug of BlobServe
[
https://issues.apache.org/jira/browse/FLINK-1768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377712#comment-14377712
]
ASF GitHub Bot commented on FLINK-1768:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/514
---
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
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377710#comment-14377710
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018880
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
---
@@ -223,8 +224,11 @@ class ExecutionEnvironment(javaEnv: JavaEn
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377708#comment-14377708
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377707#comment-14377707
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018849
--- Diff:
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java
---
@@ -98,98 +123,66 @@ public void setFields(int[] sourceF
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018833
--- Diff:
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java
---
@@ -19,66 +19,91 @@
package org.apache.flink.api.sc
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377706#comment-14377706
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018812
--- Diff:
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java
---
@@ -19,66 +19,91 @@
package org.apache.flink.api.sc
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377703#comment-14377703
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018715
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -234,9 +228,21 @@ public OUT readRecord(OUT reuse, byte[] bytes, int
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377700#comment-14377700
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018597
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -52,103 +50,86 @@
public static final String DEFAUL
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377698#comment-14377698
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018473
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -52,103 +50,86 @@
public static final String DEFAUL
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377691#comment-14377691
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377690#comment-14377690
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018316
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -52,103 +50,86 @@
public static final String DEFAUL
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018277
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -52,103 +50,86 @@
public static final String DEFAUL
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377681#comment-14377681
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018151
--- Diff:
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java
---
@@ -98,98 +123,66 @@ public void setFields(int[] sourceF
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377671#comment-14377671
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/505#discussion_r27017460
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SimpleCommunityDetection.java
---
@@ -0,0 +1,151 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377667#comment-14377667
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/505#discussion_r27017296
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SimpleCommunityDetection.java
---
@@ -0,0 +1,151 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377664#comment-14377664
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull r
1 - 100 of 126 matches
Mail list logo
