GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/817
[FLINK-2196] [javaAPI] Moved misplaced SortPartitionOperator class
`SortPartitionOperator` is API facing and misplaced.
It should be in the `org.apache.flink.api.java.operators` package.
You
Fabian Hueske created FLINK-2198:
Summary: Build fails on Windows
Key: FLINK-2198
URL: https://issues.apache.org/jira/browse/FLINK-2198
Project: Flink
Issue Type: Bug
Components:
GitHub user shghatge opened a pull request:
https://github.com/apache/flink/pull/818
[FLINK-2093][gelly] Added difference Method
Tasks given on 5th June:
Add a difference function to the Graph.java
Modify the docs 'gelly-guide.md'
Add the test case for difference()
Fabian Hueske created FLINK-2199:
Summary: Build with skipped tests fails on Windows
Key: FLINK-2199
URL: https://issues.apache.org/jira/browse/FLINK-2199
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-2197:
Summary: Scala API is not working when using batch and streaming
API in the same program
Key: FLINK-2197
URL: https://issues.apache.org/jira/browse/FLINK-2197
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580387#comment-14580387
]
Chiwan Park commented on FLINK-2183:
After I clear my local maven repository, the test
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580412#comment-14580412
]
ASF GitHub Bot commented on FLINK-2093:
---
GitHub user shghatge opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580332#comment-14580332
]
ASF GitHub Bot commented on FLINK-2196:
---
GitHub user fhueske opened a pull request:
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-110681501
@tillrohrmann great. no worries. was just not sure what is going on. :)
good luck with the new release!
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580345#comment-14580345
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580406#comment-14580406
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user tammymendt commented on the
Github user tammymendt commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-110702228
Everything seems to be OK now. Is there still a chance to merge this before
the upcoming release?
I have pushed two commits. The first is the original version
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580425#comment-14580425
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user fhueske commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-110715816
Hi @tammymendt
thanks for the update! I'm afraid, we are already in the testing phase for
the release and don't want to add new features. Since we postponed a
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580424#comment-14580424
]
Maximilian Michels commented on FLINK-2183:
---
Thanks Chiwan, I'm also looking
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580331#comment-14580331
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user aljoscha commented on a diff in
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/816#issuecomment-110691858
:+1:
---
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
Till Rohrmann created FLINK-2194:
Summary: Type extractor does not support Writable type
Key: FLINK-2194
URL: https://issues.apache.org/jira/browse/FLINK-2194
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580172#comment-14580172
]
ASF GitHub Bot commented on FLINK-2194:
---
GitHub user tillrohrmann opened a pull
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/814
[FLINK-2194] [type extractor] Treats Writable type as generic type
(interface)
Adds check so that the `Writable` type is treated as a generic type.
You can merge this pull request into a Git
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580238#comment-14580238
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110656116
+1 as well.
On Wed, Jun 10, 2015 at 10:38 AM Fabian Hueske notificati...@github.com
wrote:
+1 for adding both methods in a utility class as
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/811#discussion_r32099679
--- Diff: tools/create_release_files.sh ---
@@ -36,57 +58,59 @@ if [[ `basename $CURR_DIR` != tools ]] ; then
exit 1
fi
+##
+## Variables
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/815#issuecomment-110670779
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
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580235#comment-14580235
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user fhueske commented on the pull
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-110658920
Will do @peedeeX21. Currently I'm busy with the upcoming release, but once
we're done with it, I'll work on this PR.
---
If your project is set up for it, you can
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/815
[hotfix] Bring KMeansDataGenerator and KMeans quickstart in sync
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580272#comment-14580272
]
ASF GitHub Bot commented on FLINK-1962:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-2194:
Assignee: Till Rohrmann
Type extractor does not support Writable type
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/814#issuecomment-110664983
Travis gives green light. Will merge since it's a trivial fix.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580489#comment-14580489
]
ASF GitHub Bot commented on FLINK-2145:
---
Github user ggevay commented on the pull
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/819
[release-0.9] [runtime] Logging update for checkpointed streaming topologies
Also adding a log message when delaying the retry of the execution graph.
This change is motivated by my
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/684#issuecomment-110739389
I did the Scala part, and added a Jira (FLINK-2145).
As for the placement:
@StephanEwen:
I think we should put the code into a streaming operator library. The
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580487#comment-14580487
]
ASF GitHub Bot commented on FLINK-2093:
---
Github user andralungu commented on the
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/815
---
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-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu updated FLINK-1520:
---
Assignee: Shivani Ghatge (was: Carsten Brandt)
Read edges and vertices from CSV files
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580465#comment-14580465
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580484#comment-14580484
]
ASF GitHub Bot commented on FLINK-2196:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/817
---
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-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580433#comment-14580433
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user tammymendt commented on the
Github user tammymendt commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-110720993
Sounds good! Thanks =)
---
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
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580481#comment-14580481
]
Timo Walther commented on FLINK-2099:
-
I had a private discussion with [~rmetzger],
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580491#comment-14580491
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user gyfora commented on the pull
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/813#issuecomment-110739702
Looks good to me :+1:
---
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-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2196.
Resolution: Fixed
Fixed via a8e085078499319113a213575c9f057144395f98
Missplaced Class in
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/818#issuecomment-110739263
Hi @shghatge,
Apart from the minor cosmetic suggestions I made, everything looks well.
@vasia, could you double check this? After Shivani simplifies
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/816#issuecomment-110739304
:+1:
---
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 mxm commented on the pull request:
https://github.com/apache/flink/pull/811#issuecomment-110643230
Thanks for the review.
---
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-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580203#comment-14580203
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580199#comment-14580199
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110645638
Why only offering this method for Gelly? Can't we generalize the index
algorithm for generic types? It could also be useful for the ML library, for
example. I'm
Ufuk Celebi created FLINK-2195:
--
Summary: Set Configuration for Configurable Hadoop InputFormats
Key: FLINK-2195
URL: https://issues.apache.org/jira/browse/FLINK-2195
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-2192.
-
Resolution: Duplicate
This is a duplicate of FLINK-2180.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/814
---
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 mbalassi commented on the pull request:
https://github.com/apache/flink/pull/809#issuecomment-110641826
Merging.
---
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
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/801#discussion_r32096127
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/UniqueLabelAssignmentAlgorithm.java
---
@@ -0,0 +1,101 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580231#comment-14580231
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110653949
If I'm not mistaken then something like
```
int log2(long value){
if(value 0x 0) {
64 -
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110654447
I agree, it makes sense to offer that externally.
There is a JIRA for zipWithIndex (FLINK-2152). zipWithUniqueID could be
added correspondingly.
---
If your
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/779#issuecomment-110654021
If no objections, I'd like to merge this one within the next week. There is
a direction issue for GSA(FLINK-2141) that will actually touch the same files.
---
If
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580233#comment-14580233
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user fhueske commented on the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/809
---
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 mbalassi opened a pull request:
https://github.com/apache/flink/pull/816
[streaming] Fixed streaming example jars packaging and termination
Now all the streaming java examples are packaged into self-contained jars
and finish.
You can merge this pull request into a Git
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580207#comment-14580207
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user andralungu commented on the
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110647258
Hi @tillrohrmann ,
For the log2 part, you mean something like this: ceil(log2(x)) = 32 -
numberOfLeadingZeros(x - 1)? 32 because it's int, in this case it
[
https://issues.apache.org/jira/browse/FLINK-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580232#comment-14580232
]
ASF GitHub Bot commented on FLINK-2140:
---
Github user andralungu commented on the
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110655024
+1 for adding both methods in a utility class as suggested in FLINK-2152.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/811#discussion_r32098664
--- Diff: tools/create_release_files.sh ---
@@ -36,57 +58,59 @@ if [[ `basename $CURR_DIR` != tools ]] ; then
exit 1
fi
+##
+## Variables
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580249#comment-14580249
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user tillrohrmann commented on the
Fabian Hueske created FLINK-2196:
Summary: Missplaced Class in flink-java SortPartitionOperator
Key: FLINK-2196
URL: https://issues.apache.org/jira/browse/FLINK-2196
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580280#comment-14580280
]
ASF GitHub Bot commented on FLINK-2194:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-2194.
Resolution: Fixed
Fixed via d81f4cf92d7a7d78082c7997c0d1a802f4358617
Type extractor does not
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110642404
Ooops! My bad. Fixed the log and the ceil issue in the latest update.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580189#comment-14580189
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user andralungu commented on the
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/808#issuecomment-110664776
I will thoroughly check it once the release that is currently happening is
done. Then people can check it out and it will have had some expose before
releasing it in
[
https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580293#comment-14580293
]
Márton Balassi commented on FLINK-2192:
---
It is a duplicate, because the failing part
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/811#discussion_r32095648
--- Diff: tools/create_release_files.sh ---
@@ -36,57 +58,59 @@ if [[ `basename $CURR_DIR` != tools ]] ; then
exit 1
fi
+##
+## Variables
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/811#discussion_r32095640
--- Diff: tools/create_release_files.sh ---
@@ -36,57 +58,59 @@ if [[ `basename $CURR_DIR` != tools ]] ; then
exit 1
fi
+##
+## Variables
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/801#discussion_r32096112
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/UniqueLabelAssignmentAlgorithm.java
---
@@ -0,0 +1,101 @@
+/*
+
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/812#issuecomment-110644940
I would be against merging this in the current form. What I propose is to
analyse the topology to verify that there are no checkpointed operators inside
iterations.
[
https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580225#comment-14580225
]
PJ Van Aeken commented on FLINK-2033:
-
If the PR for FLINK-1962 gets accepted, this
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580282#comment-14580282
]
Ufuk Celebi commented on FLINK-2188:
You can try it with this branch:
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/813#discussion_r32102450
--- Diff:
flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
---
@@ -781,11 +780,24 @@
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580316#comment-14580316
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user mbalassi commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580318#comment-14580318
]
Fabian Hueske commented on FLINK-2192:
--
I see. Thanks for the explanation!
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/813#discussion_r32102485
--- Diff:
flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580540#comment-14580540
]
Chiwan Park commented on FLINK-2200:
+1 for this feature
Flink API with Scala 2.11 -
[
https://issues.apache.org/jira/browse/FLINK-2199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-2199:
Assignee: Fabian Hueske
Build with skipped tests fails on Windows
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580531#comment-14580531
]
Shivani Ghatge commented on FLINK-2093:
---
I have done the changes suggested by
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park updated FLINK-2200:
---
Component/s: Scala API
Flink API with Scala 2.11 - Maven Repository
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/820
[build] [streaming] Streaming parent's dependencies pushed to children
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink deps
Philipp Götze created FLINK-2200:
Summary: Flink API with Scala 2.11 - Maven Repository
Key: FLINK-2200
URL: https://issues.apache.org/jira/browse/FLINK-2200
Project: Flink
Issue Type: Wish
[
https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580597#comment-14580597
]
Fabian Hueske commented on FLINK-2198:
--
The problem seems to be caused by the
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/813#issuecomment-110786608
Merging.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580614#comment-14580614
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/816#issuecomment-110786927
Merging.
---
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
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/812#discussion_r32091115
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
---
@@
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/809#issuecomment-110615875
looks good :+1:
---
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 aljoscha opened a pull request:
https://github.com/apache/flink/pull/813
[FLINK-2191] Fix inconsistent use of closure cleaner in Scala Streaming
The closure cleaner still cannot be disabled for the Timestamp extractor
in Time and for the delta function in Delta
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580130#comment-14580130
]
ASF GitHub Bot commented on FLINK-2191:
---
GitHub user aljoscha opened a pull request:
1 - 100 of 112 matches
Mail list logo
