Till Rohrmann created FLINK-2189:
Summary: NullPointerException in MutableHashTable
Key: FLINK-2189
URL: https://issues.apache.org/jira/browse/FLINK-2189
Project: Flink
Issue Type: Bug
Hilmi Yildirim created FLINK-2188:
-
Summary: Reading from big HBase Tables
Key: FLINK-2188
URL: https://issues.apache.org/jira/browse/FLINK-2188
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2189:
-
Description:
[~Felix Neutatz] reported a {{NullPointerException}} in the
{{MutableHashTable}}
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578668#comment-14578668
]
Till Rohrmann commented on FLINK-2183:
--
The {{TaskManagerFailsWithSlotSharingITCase}}
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578526#comment-14578526
]
Ufuk Celebi commented on FLINK-2183:
Sorry for not being clear before. No, this is not
[
https://issues.apache.org/jira/browse/FLINK-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578550#comment-14578550
]
Sachin Goel commented on FLINK-2187:
Ah. Okay. Should I mark this issue resolved then?
[
https://issues.apache.org/jira/browse/FLINK-2185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578560#comment-14578560
]
Theodore Vasiloudis commented on FLINK-2185:
[~dlyubimov] the SVM in Flink is
[
https://issues.apache.org/jira/browse/FLINK-1844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-1844.
--
Resolution: Fixed
Added via 73f99117f783a1f5c3ae67ade4716512b3ddfd66
Add Normaliser to ML
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110276236
Hi Andra,
you approach basically follows @rmetzger 's suggestion which is necessary
if you need sequential IDs. However, it comes at the cost of doing two passes
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578574#comment-14578574
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel closed FLINK-2187.
--
Resolution: Fixed
KMeans clustering is not present in release-0.9-rc1
[
https://issues.apache.org/jira/browse/FLINK-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578506#comment-14578506
]
Till Rohrmann commented on FLINK-2187:
--
Good point. Will change this.
KMeans
[
https://issues.apache.org/jira/browse/FLINK-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578543#comment-14578543
]
Sachin Goel commented on FLINK-2187:
It should be possible to include it in the
[
https://issues.apache.org/jira/browse/FLINK-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578547#comment-14578547
]
Till Rohrmann commented on FLINK-2187:
--
I guess it's better not to rush things.
[
https://issues.apache.org/jira/browse/FLINK-1844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578569#comment-14578569
]
ASF GitHub Bot commented on FLINK-1844:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/798
---
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-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578724#comment-14578724
]
Ufuk Celebi commented on FLINK-2188:
Thanks for reporting the issue. Just to
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578784#comment-14578784
]
Fabian Hueske commented on FLINK-2188:
--
Which version of Flink are you using (commit
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578786#comment-14578786
]
Ufuk Celebi commented on FLINK-2188:
I've just asked the same question on the mailing
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2188:
-
Priority: Critical (was: Major)
Reading from big HBase Tables
-
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel updated FLINK-2183:
---
Comment: was deleted
(was: I'm not familiar with that. Is this expected? And is someone already
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578424#comment-14578424
]
Sachin Goel commented on FLINK-2183:
I'm not familiar with that. Is this expected? And
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/804#issuecomment-110257970
Thanks for the heads-up. Looking. :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578476#comment-14578476
]
ASF GitHub Bot commented on FLINK-2182:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-110260380
`release-0.9` is forked off, this pull request is not blocked by that any
more. Did you manage to fix the Kafka source or is some help needed there?
---
If your
[
https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578423#comment-14578423
]
Sachin Goel commented on FLINK-2183:
I'm not familiar with that. Is this expected? And
[
https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578479#comment-14578479
]
ASF GitHub Bot commented on FLINK-2180:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/802#issuecomment-11025
Please properly rebase this branch, so we will not see the noise commits
from others.
---
If your project is set up for it, you can reply to this email and have your
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-110261346
I could not fix the kafka test yet. Also I need to fix some tests hardcoded
for the previous interfaces that have been added lately :p
This will probably happen
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/809#issuecomment-110403209
I have modified the commit to fix the \n problem in the Scala graph
examples as well.
---
If your project is set up for it, you can reply to this email and have your
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/810#issuecomment-110406047
:+1: Thanks Gyula, this is pretty handy for ML tasks. If possible I would
recommend including this functionality to the undergoing release.
---
If your project is
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/811
[scripts] cleanup release script and make it more robust
- fail on command error
- make Mac OS X compatible
- fix uberjar file limit detection
- cleanup
You can merge this pull request into
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/792#discussion_r32018559
--- Diff: docs/libs/ml/quickstart.md ---
@@ -24,4 +24,198 @@ under the License.
* This will be replaced by the TOC
{:toc}
-Coming
[
https://issues.apache.org/jira/browse/FLINK-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578986#comment-14578986
]
ASF GitHub Bot commented on FLINK-2072:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578957#comment-14578957
]
Hilmi Yildirim edited comment on FLINK-2188 at 6/9/15 2:19 PM:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/810
[streaming] Optional iteration feedback partitioning added
This commit introduces a new flag for streaming iterations which allows to
set the partitioning for the feedback stream different than the
Github user shghatge commented on the pull request:
https://github.com/apache/flink/pull/807#issuecomment-110380728
Hi @fhueske I am sorry for closing the pull request. Now onwards I will
follow the approach you suggested.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578957#comment-14578957
]
Hilmi Yildirim commented on FLINK-2188:
---
It takes time to embed the original
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578991#comment-14578991
]
ASF GitHub Bot commented on FLINK-2093:
---
Github user shghatge commented on the pull
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/811#discussion_r32029536
--- Diff: tools/create_release_files.sh ---
@@ -36,57 +58,59 @@ if [[ `basename $CURR_DIR` != tools ]] ; then
exit 1
fi
+##
+## Variables
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/804
---
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-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579144#comment-14579144
]
Chiwan Park commented on FLINK-2183:
I can reproduce the hang problem of this test
[
https://issues.apache.org/jira/browse/FLINK-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579201#comment-14579201
]
ASF GitHub Bot commented on FLINK-2182:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-2182.
-
Resolution: Fixed
Fix Version/s: 0.10
Implemented via 31d3eaa
Add stateful Streaming
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579148#comment-14579148
]
Hilmi Yildirim commented on FLINK-2188:
---
FYI. I exported the hbase table to a hdfs
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/811#discussion_r32029849
--- Diff: tools/create_release_files.sh ---
@@ -36,57 +58,59 @@ if [[ `basename $CURR_DIR` != tools ]] ; then
exit 1
fi
+##
+## Variables
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/811#issuecomment-110415347
changes look good modulo inline comments
---
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
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579173#comment-14579173
]
Ufuk Celebi commented on FLINK-2188:
OK, I've looked into the issue. I had a problem
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/808#issuecomment-110448745
I am super excited about this one! :) Will also have a look in the next
days! Awesome job!
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579325#comment-14579325
]
ASF GitHub Bot commented on FLINK-1962:
---
Github user andralungu commented on the
[
https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579262#comment-14579262
]
ASF GitHub Bot commented on FLINK-2093:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579384#comment-14579384
]
Ufuk Celebi commented on FLINK-2192:
Is it the result or
{code}
Caused by:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/810
---
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
Fabian Hueske created FLINK-2192:
Summary: ComplexIntegrationTest.complexIntegrationTest1 fails
Key: FLINK-2192
URL: https://issues.apache.org/jira/browse/FLINK-2192
Project: Flink
Issue
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/807#issuecomment-110438710
@shghatge no worries. It's not a big deal :-)
---
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 andralungu commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110502315
Hi @fhueske ,
To tell the truth, I was a bit reserved regarding your approach, so maybe
we can discuss it a bit further! :) I updated the PR to contain what
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579556#comment-14579556
]
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/799#issuecomment-110481761
uhmm, guys! IMO this should be merged before the release!
Thanks!
---
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-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579464#comment-14579464
]
ASF GitHub Bot commented on FLINK-2178:
---
Github user andralungu commented on the
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/573#issuecomment-110540528
Hi, I rebased to the current master (and new streaming API) as discussed
and cleaned up everything. Unfortunately, I was not able to cherry-pick the
last commits:
-
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/801#discussion_r32067943
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/UniqueLabelAssignmentAlgorithm.java
---
@@ -0,0 +1,92 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579615#comment-14579615
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user fhueske commented on a diff in
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110520392
I think I got it! Have a look 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
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579652#comment-14579652
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user andralungu commented on the
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14579599#comment-14579599
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user fhueske commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-110511102
If you reserve 2 bytes of a long for the task id you have 6 bytes left for
the counter. This gives you 2^16 partitions, with 2^48 elements per partition.
You can also
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/812
[streaming] Allow force-enabling checkpoints for iterative jobs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/gyfora/flink iteration
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/801#discussion_r32067705
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/UniqueLabelAssignmentAlgorithm.java
---
@@ -0,0 +1,92 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578835#comment-14578835
]
ASF GitHub Bot commented on FLINK-2072:
---
Github user thvasilo commented on a diff in
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/804#issuecomment-110350898
Looks good now, we should not really test the ordering there anyway.
---
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-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hilmi Yildirim updated FLINK-2188:
--
Attachment: flinkTest.zip
Source Code
Reading from big HBase Tables
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578830#comment-14578830
]
Ufuk Celebi commented on FLINK-2188:
Thanks! Do you have time to test it with the
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578806#comment-14578806
]
Hilmi Yildirim commented on FLINK-2188:
---
For the cluster I use the SNAPSHOT build
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578834#comment-14578834
]
ASF GitHub Bot commented on FLINK-1962:
---
GitHub user PieterJanVanAeken opened a pull
Sebastian Kruse created FLINK-2190:
--
Summary: Enhance stream decoration/compression extensibility
Key: FLINK-2190
URL: https://issues.apache.org/jira/browse/FLINK-2190
Project: Flink
Issue
GitHub user PieterJanVanAeken opened a pull request:
https://github.com/apache/flink/pull/808
[FLINK-1962] Add Gelly Scala API
Pull request for adding the Gelly Scala API. There were some issues with
rebasing due to both the Java Gelly API and the Testing API changing, so if
[
https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578830#comment-14578830
]
Ufuk Celebi edited comment on FLINK-2188 at 6/9/15 12:49 PM:
-
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/792#discussion_r32008548
--- Diff: docs/libs/ml/quickstart.md ---
@@ -24,4 +24,198 @@ under the License.
* This will be replaced by the TOC
{:toc}
-Coming soon.
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578904#comment-14578904
]
Aljoscha Krettek commented on FLINK-2191:
-
Did you start? I already have a fix.
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-2191:
---
Assignee: Aljoscha Krettek (was: Márton Balassi)
Inconsistent use of Closure
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/812#issuecomment-110595076
Makes sense.
---
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 rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/812#discussion_r32089514
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
---
@@
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/812#discussion_r32090193
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
---
@@
GitHub user ggevay opened a pull request:
https://github.com/apache/flink/pull/809
Fixed a few trivial issues:
- The description of the input format for the graph examples
showed an example input as having a newline at the end
of the last line, but CsvInputFormat doesn't
Aljoscha Krettek created FLINK-2191:
---
Summary: Inconsistent use of Closure Cleaner in Streaming API
Key: FLINK-2191
URL: https://issues.apache.org/jira/browse/FLINK-2191
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-2191:
-
Assignee: Márton Balassi
Inconsistent use of Closure Cleaner in Streaming API
86 matches
Mail list logo
