Aljoscha Krettek created FLINK-2203:
---
Summary: Add Support for Null-Values in RowSerializer
Key: FLINK-2203
URL: https://issues.apache.org/jira/browse/FLINK-2203
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14581080#comment-14581080
]
ASF GitHub Bot commented on FLINK-1732:
---
GitHub user shakir774 opened a pull request
GitHub user shakir774 opened a pull request:
https://github.com/apache/flink/pull/823
FLINK-1732 Gaussian Mixture Model for Flink-ml library
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/shakir774/flink gmm_feature
Alternative
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580785#comment-14580785
]
Maximilian Michels commented on FLINK-2183:
---
Here is the stacktrace isolated for
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/822
[scripts] remove quickstart scripts
- we already decided to host them on the website
- not really useful and they need maintenance
- having the snapshot quickstart in the source is against Apache
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/821
[FLINK-2199] Escape UTF characters in Scala Shell welcome squirrel.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhueske/flink fixWindowsBuild
[
https://issues.apache.org/jira/browse/FLINK-2199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580684#comment-14580684
]
ASF GitHub Bot commented on FLINK-2199:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-2202.
--
Resolution: Duplicate
Duplicate of FLINK-1963
> Calling distinct() requires tuple input
> -
Theodore Vasiloudis created FLINK-2202:
--
Summary: Calling distinct() requires tuple input
Key: FLINK-2202
URL: https://issues.apache.org/jira/browse/FLINK-2202
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-2191.
-
Resolution: Fixed
Fix Version/s: 0.9
Implemented via e2304c4. Minor issue remains, tracked
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580631#comment-14580631
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/813
---
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/816
---
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
Márton Balassi created FLINK-2201:
-
Summary: Inconsistent use of ClosureCleaner in streaming window
helpers
Key: FLINK-2201
URL: https://issues.apache.org/jira/browse/FLINK-2201
Project: Flink
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
enabl
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
enabl
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580614#comment-14580614
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580597#comment-14580597
]
Fabian Hueske commented on FLINK-2198:
--
The problem seems to be caused by the {{File.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/812
---
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 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
Alte
[
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-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
> --
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580540#comment-14580540
]
Chiwan Park commented on FLINK-2200:
+1 for this feature
> Flink API with Scala 2.11
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-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580531#comment-14580531
]
Shivani Ghatge commented on FLINK-2093:
---
I have done the changes suggested by [~andr
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 f
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580491#comment-14580491
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user gyfora commented on the pull re
[
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 flink-ja
[
https://issues.apache.org/jira/browse/FLINK-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580489#comment-14580489
]
ASF GitHub Bot commented on FLINK-2145:
---
Github user ggevay commented on the pull re
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 experien
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-tabpanel&focusedCommentId=14580487#comment-14580487
]
ASF GitHub Bot commented on FLINK-2093:
---
Github user andralungu commented on the pul
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 a
[
https://issues.apache.org/jira/browse/FLINK-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 enabl
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580481#comment-14580481
]
Timo Walther commented on FLINK-2099:
-
I had a private discussion with [~rmetzger], [~
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/813#issuecomment-110733849
I updated it, now we still have several "clean" functions but they just
forward to the StreamingExEnv.scalaClean() function.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580465#comment-14580465
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user aljoscha commented on the pull
[
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
> ---
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 ena
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580433#comment-14580433
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user tammymendt commented on the pul
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 th
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 fe
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580424#comment-14580424
]
Maximilian Michels commented on FLINK-2183:
---
Thanks Chiwan, I'm also looking int
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580425#comment-14580425
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user fhueske commented on the pull r
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
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() method
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580412#comment-14580412
]
ASF GitHub Bot commented on FLINK-2093:
---
GitHub user shghatge opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580406#comment-14580406
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user tammymendt commented on the pul
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
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: Bu
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580387#comment-14580387
]
Chiwan Park commented on FLINK-2183:
After I clear my local maven repository, the test
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
enabl
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/816#issuecomment-110689712
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 an
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580345#comment-14580345
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user peedeeX21 commented on the pull
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 ema
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
Project
[
https://issues.apache.org/jira/browse/FLINK-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580332#comment-14580332
]
ASF GitHub Bot commented on FLINK-2196:
---
GitHub user fhueske opened a pull request:
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 can
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580331#comment-14580331
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/813#discussion_r32103307
--- Diff:
flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala
---
@@ -45
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580319#comment-14580319
]
ASF GitHub Bot commented on FLINK-2191:
---
Github user mbalassi commented on a diff in
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
---
@@ -45
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14580318#comment-14580318
]
Fabian Hueske commented on FLINK-2192:
--
I see. Thanks for the explanation!
> Comple
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 @@
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 r
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 enabl
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 an
[
https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580293#comment-14580293
]
Márton Balassi commented on FLINK-2192:
---
It is a duplicate, because the failing part
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580282#comment-14580282
]
Ufuk Celebi commented on FLINK-2188:
You can try it with this branch:
https://github.
[
https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580280#comment-14580280
]
ASF GitHub Bot commented on FLINK-2194:
---
Github user asfgit closed the pull request
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 enabl
[
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 supp
[
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.
> ComplexIntegrationTest.complexIntegrat
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 GitHub
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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:comment-tabpanel&focusedCommentId=14580277#comment-14580277
]
ASF GitHub Bot commented on FLINK-2194:
---
Github user tillrohrmann commented on the p
[
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 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 0.1
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
+##
+## Variable
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 Type
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 fix-kmeans-data-
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 r
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580249#comment-14580249
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user tillrohrmann commented on the p
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
+##
+## Variable
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:
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
wrote:
> +1 for adding both methods in a utility class as suggested in FLINK-2152.
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580238#comment-14580238
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580235#comment-14580235
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user fhueske commented on the pull r
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
[
https://issues.apache.org/jira/browse/FLINK-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580232#comment-14580232
]
ASF GitHub Bot commented on FLINK-2140:
---
Github user andralungu commented on the pul
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 project
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580231#comment-14580231
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user tillrohrmann commented on the p
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 - Integer.numberOfLeadingZeros((int)(v
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580233#comment-14580233
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user fhueske commented on the pull r
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 you
[
https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580225#comment-14580225
]
PJ Van Aeken commented on FLINK-2033:
-
If the PR for FLINK-1962 gets accepted, this ca
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580207#comment-14580207
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user andralungu commented on the pul
1 - 100 of 120 matches
Mail list logo