[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541211#comment-14541211
]
Chiwan Park edited comment on FLINK-1731 at 5/13/15 2:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541211#comment-14541211
]
Chiwan Park commented on FLINK-1731:
Hello, [~peedeeX21].
I think you can pass the in
Github user chhao01 commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-101466586
@aljoscha there is nothing when I open the Travis CI link, is there any
hint why this failed?
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541095#comment-14541095
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user chhao01 commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1959.
---
> Accumulators BROKEN after Partitioning
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1959.
-
Resolution: Pending Closed
Fix Version/s: (was: master)
0.9
[
https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540955#comment-14540955
]
Stephan Ewen commented on FLINK-2005:
-
I think those can be simply removed. The regula
Henry Saputra created FLINK-2005:
Summary: Remove dependencies on Record APIs for flink-jdbc module
Key: FLINK-2005
URL: https://issues.apache.org/jira/browse/FLINK-2005
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1935.
-
Resolution: Implemented
Implemented and merged in 54e957614c38fed69baf726fc86059e9b11384cb
> Reim
[
https://issues.apache.org/jira/browse/FLINK-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1935.
---
> Reimplement PersistentKafkaSource using high level Kafka API
> -
[
https://issues.apache.org/jira/browse/FLINK-1973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1973.
---
> JobManager log does not contain state change messages on INFO level
> --
[
https://issues.apache.org/jira/browse/FLINK-1973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1973.
-
Resolution: Fixed
Fixed in ededb6b74a2d388ff1c54ddf0f2733c65675c9a0
> JobManager log does not con
[
https://issues.apache.org/jira/browse/FLINK-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1953.
-
Resolution: Implemented
Implemented in 9b7f8aa121e4a231632296d0809029aca9ebde6a
> Rework Checkpoi
[
https://issues.apache.org/jira/browse/FLINK-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1953.
---
> Rework Checkpoint Coordinator
> -
>
> Key: FLINK-1953
>
[
https://issues.apache.org/jira/browse/FLINK-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540722#comment-14540722
]
ASF GitHub Bot commented on FLINK-1953:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/651
---
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-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540610#comment-14540610
]
Stephan Ewen commented on FLINK-1959:
-
Great debugging, this is perfect!
I will prepa
[
https://issues.apache.org/jira/browse/FLINK-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2004:
Summary: Memory leak in presence of failed checkpoints in KafkaSource
(was: Memory leack in presenc
Stephan Ewen created FLINK-2004:
---
Summary: Memory leack in presence of failed checkpoints in
KafkaSource
Key: FLINK-2004
URL: https://issues.apache.org/jira/browse/FLINK-2004
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2000:
-
Assignee: Cheng Hao
> Add SQL-style aggregations for Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540465#comment-14540465
]
Peter Schrott commented on FLINK-1731:
--
Very nice. The implementation of BreezeVector
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hae Joon Lee updated FLINK-1731:
Comment: was deleted
(was: To load input `Points` in fit function for `BreezeVector` we should use
Github user chhao01 commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-101344334
@aljoscha sorry for the delay, my jira id is `chhao01`, and I can start
working on the `FLINK-2000` once this got merged.
---
If your project is set up for it, you can r
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540178#comment-14540178
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user chhao01 commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540177#comment-14540177
]
Cheng Hao commented on FLINK-2000:
--
Can you please assign this to me?
> Add SQL-style ag
[
https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540156#comment-14540156
]
Alexander Alexandrov commented on FLINK-1999:
-
[~vsldimov] K is the Document I
[
https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540146#comment-14540146
]
Alexander Alexandrov commented on FLINK-1959:
-
After some more debugging with
[
https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540137#comment-14540137
]
Vassil Dimov edited comment on FLINK-1999 at 5/12/15 4:17 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540137#comment-14540137
]
Vassil Dimov commented on FLINK-1999:
-
Hello [~aalexandrov],
We have two questions ab
[
https://issues.apache.org/jira/browse/FLINK-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540037#comment-14540037
]
ASF GitHub Bot commented on FLINK-1885:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/598#issuecomment-101321028
I had a look at this, and it actually looks quite good. The basic idea
seems to be that you emit the original vertex if no update happens.
It would be nice to
[
https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539987#comment-14539987
]
mustafa elbehery commented on FLINK-1959:
-
I have tried debugging to check the pro
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539938#comment-14539938
]
Hae Joon Lee commented on FLINK-1731:
-
To load input `Points` in fit function for `Bre
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539916#comment-14539916
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-101303549
Yes. But my PR will provide two standard implementations (ParameterTool,
Configuration), so only if users want more features they need to implement the
config.
Users
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/573#issuecomment-101301921
Hi, I addressed all your comments. The latest build was successful, too.
Please let me know if there is anything else to improve the pull request.
---
If your project is s
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1525:
-
Assignee: Robert Metzger
> Provide utils to pass -D parameters to UDFs
> ---
[
https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539887#comment-14539887
]
Márton Balassi commented on FLINK-1764:
---
One lingering symptom of this issue is show
[
https://issues.apache.org/jira/browse/FLINK-2001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2001.
---
> DistanceMetric cannot be serialized
> ---
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-2001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2001.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed and merged in 40683718db2233293ee932317102a399ad
[
https://issues.apache.org/jira/browse/FLINK-1987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1987.
---
> Broken links in the add_operator section of the documentation
>
[
https://issues.apache.org/jira/browse/FLINK-1987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1987.
-
Resolution: Pending Closed
Fix Version/s: 0.9
Fixed and merged in cafb8769a22e21c1c6fe04567
[
https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-785.
Resolution: Implemented
Fix Version/s: (was: pre-apache)
0.9
Implemente
[
https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-785.
--
> Add Chained operators for AllReduce and AllGroupReduce
> --
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/662
---
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 user asfgit closed the pull request at:
https://github.com/apache/flink/pull/668
---
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-1987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539697#comment-14539697
]
ASF GitHub Bot commented on FLINK-1987:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539699#comment-14539699
]
ASF GitHub Bot commented on FLINK-2001:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/615
---
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-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539698#comment-14539698
]
ASF GitHub Bot commented on FLINK-785:
--
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/370
---
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-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539694#comment-14539694
]
Robert Metzger commented on FLINK-2003:
---
I think we also should put an entry to our
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/615#issuecomment-101219900
Will update and 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 your project does not have
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/670
---
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-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2003:
Labels: build starter (was: build)
> Building on some encrypted filesystems leads to "File
[
https://issues.apache.org/jira/browse/FLINK-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539598#comment-14539598
]
ASF GitHub Bot commented on FLINK-1980:
---
Github user sekruse commented on the pull r
Github user sekruse commented on the pull request:
https://github.com/apache/flink/pull/658#issuecomment-101215521
I see your point and double-checked it with the Java doc. I will adjust the
seek method accordingly.
---
If your project is set up for it, you can reply to this email an
Theodore Vasiloudis created FLINK-2003:
--
Summary: Building on some encrypted filesystems leads to "File
name too long" error
Key: FLINK-2003
URL: https://issues.apache.org/jira/browse/FLINK-2003
[
https://issues.apache.org/jira/browse/FLINK-1986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539589#comment-14539589
]
Péter Szabó commented on FLINK-1986:
The problem is that the the StreamIterationHead i
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539581#comment-14539581
]
Aljoscha Krettek commented on FLINK-1962:
-
Fixed
> Add Gelly Scala API
>
Péter Szabó created FLINK-2002:
--
Summary: Iterative test fails when ran with other tests in the
same environment
Key: FLINK-2002
URL: https://issues.apache.org/jira/browse/FLINK-2002
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539577#comment-14539577
]
Aljoscha Krettek commented on FLINK-1962:
-
Dammit, right you are. I will fix it.
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/670#issuecomment-101210297
+1 ship 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 feature
en
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30117434
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/test/java/org/apache/flink/stormcompatibility/wrappers/StormWrapperSetupHelperTest.java
---
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/670
[QA] store messages in file instead of in the environment
Bash can run out of environment memory if environment variables store
too much data. When the memory is exceeded, bash can't run system
co
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30117273
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/test/java/org/apache/flink/stormcompatibility/wrappers/StormWrapperSetupHelperTest.java
---
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/648#issuecomment-101206877
Manually merged in fbea2da26d01c470687a5ad217a5fd6ad1de89e4
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/648
---
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
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30117019
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/main/java/org/apache/flink/stormcompatibility/api/FlinkClient.java
---
@@ -0,0 +1,321 @@
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/662#issuecomment-101205803
Will 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
[
https://issues.apache.org/jira/browse/FLINK-1987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539564#comment-14539564
]
ASF GitHub Bot commented on FLINK-1987:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/668#issuecomment-101205344
+1
Will 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 no
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30116720
--- Diff:
flink-staging/flink-streaming/flink-storm-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountLocal.java
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-2001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539562#comment-14539562
]
ASF GitHub Bot commented on FLINK-2001:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539558#comment-14539558
]
PJ Van Aeken commented on FLINK-1962:
-
I suspect there is some IDE shannanigans going
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539550#comment-14539550
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-101203099
Does every user need to implement the user config object?
In the code, do you always need to cast the user config to your specific
class?
---
If your project is
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-101201653
I thought its much nicer for users to provide a typed POJO (implementing
`UserConfig`) instead of a String map.
This approach leaves at least the door open for a type
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539548#comment-14539548
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/660#issuecomment-101199537
See here: https://github.com/apache/flink/pull/669
---
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
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539545#comment-14539545
]
Aljoscha Krettek commented on FLINK-1962:
-
I created a new PR that allows the Scal
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/669
Some fixes for Scala type analysis
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink scala-type-analysis-fix
Alternatively you can
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/660
---
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
[
https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539539#comment-14539539
]
Alexander Alexandrov commented on FLINK-1999:
-
I'm not sure whether Seq[String
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539532#comment-14539532
]
Stephan Ewen commented on FLINK-1962:
-
In Scala, you usually use the Scala tuples.
Th
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/660#issuecomment-101190844
How hard is it to add Java Tuple support to the Scala API? May be also
interesting for people that want to use mutable tuples in Scala...
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1676.
---
Resolution: Pending Closed
Fix Version/s: 0.9
Assignee: Robert Metzger
Resolve
[
https://issues.apache.org/jira/browse/FLINK-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539518#comment-14539518
]
ASF GitHub Bot commented on FLINK-1676:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/473
---
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 user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30113961
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/main/java/org/apache/flink/stormcompatibility/api/FlinkClient.java
---
@@ -0,0 +1,321 @
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30113871
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/main/java/org/apache/flink/stormcompatibility/api/FlinkClient.java
---
@@ -0,0 +1,321 @
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30113838
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/main/java/org/apache/flink/stormcompatibility/api/FlinkClient.java
---
@@ -0,0 +1,321 @
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30113510
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/test/java/org/apache/flink/stormcompatibility/wrappers/StormFiniteSpoutWrapperTest.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30113453
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/test/java/org/apache/flink/stormcompatibility/wrappers/StormTupleTest.java
---
@@ -0,0
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30113379
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/test/java/org/apache/flink/stormcompatibility/wrappers/StormWrapperSetupHelperTest.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30113258
--- Diff:
flink-staging/flink-streaming/flink-storm-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountLocal.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539500#comment-14539500
]
ASF GitHub Bot commented on FLINK-1980:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/658#issuecomment-101185563
That is a good point. It is a bit tricky, though, since the skip method
does not guarantee efficient skipping. It also reserves the right to skip less
(and return the
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30113138
--- Diff:
flink-staging/flink-streaming/flink-storm-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/stormoperators/StormBoltFileSink.java
--
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r30112988
--- Diff:
flink-staging/flink-streaming/flink-storm-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/stormoperators/StormFileSpout.java
---
1 - 100 of 103 matches
Mail list logo
