[
https://issues.apache.org/jira/browse/FLINK-2141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609398#comment-14609398
]
ASF GitHub Bot commented on FLINK-2141:
---
GitHub user shghatge opened a pull request:
GitHub user shghatge opened a pull request:
https://github.com/apache/flink/pull/877
[FLINK-2141] Allow GSA's Gather to perform this operation in more than one
direction
Added the setDirection() and getDirection() methods to GSAConfiguration.java
Added functionality to gather va
[
https://issues.apache.org/jira/browse/FLINK-2302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2302:
---
Description:
The scripts currently can only run a single component like TaskManager per host.
The mai
Ufuk Celebi created FLINK-2302:
--
Summary: Allow multiple instances to run on single host
Key: FLINK-2302
URL: https://issues.apache.org/jira/browse/FLINK-2302
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2302:
---
Issue Type: Improvement (was: Bug)
> Allow multiple instances to run on single host
> ---
[
https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609140#comment-14609140
]
Andra Lungu commented on FLINK-2299:
Hi [~StephanEwen],
First of all, thanks a lot fo
[
https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608919#comment-14608919
]
ASF GitHub Bot commented on FLINK-2131:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/757#issuecomment-117314238
Hello @sachingoel0101 . If you have a feature in mind that requires the
sampling code then you should file a ticket with the feature request.
What I would like u
[
https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608810#comment-14608810
]
Stephan Ewen commented on FLINK-2299:
-
[~andralungu] - from some LOG debugging, it see
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/876#discussion_r33604736
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClient.java ---
@@ -591,14 +592,17 @@ protected AbstractFlinkYarnCluster
deployInternal(Str
[
https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608785#comment-14608785
]
ASF GitHub Bot commented on FLINK-2298:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608783#comment-14608783
]
ASF GitHub Bot commented on FLINK-2298:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/876#discussion_r33604696
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClient.java ---
@@ -341,7 +342,7 @@ public AbstractFlinkYarnCluster run() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608732#comment-14608732
]
Stephan Ewen commented on FLINK-2299:
-
Aside from the issue that you see, I think you
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/876
[FLINK-2298] Allow setting a custom application name on YARN
With this change, users can pass a "--name" argument to the YARN session to
give the YARN application a custom name.
I've covere
[
https://issues.apache.org/jira/browse/FLINK-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608608#comment-14608608
]
ASF GitHub Bot commented on FLINK-2298:
---
GitHub user rmetzger opened a pull request:
Aljoscha Krettek created FLINK-2301:
---
Summary: In BarrierBuffer newer Barriers trigger old Checkpoints
Key: FLINK-2301
URL: https://issues.apache.org/jira/browse/FLINK-2301
Project: Flink
I
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/875
[storm-contib] added named attribute access to Storm compatibility layer
- added support for named attribute access
- extenden FlinkTopologyBuilder to handle declared output schemas
- adap
Robert Metzger created FLINK-2300:
-
Summary: Links on FAQ page not rendered correctly
Key: FLINK-2300
URL: https://issues.apache.org/jira/browse/FLINK-2300
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608435#comment-14608435
]
ASF GitHub Bot commented on FLINK-2131:
---
Github user sachingoel0101 closed the pull
[
https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608437#comment-14608437
]
ASF GitHub Bot commented on FLINK-2131:
---
GitHub user sachingoel0101 reopened a pull
[
https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608434#comment-14608434
]
ASF GitHub Bot commented on FLINK-2131:
---
Github user sachingoel0101 commented on the
GitHub user sachingoel0101 reopened a pull request:
https://github.com/apache/flink/pull/757
[FLINK-2131][ml]: Initialization schemes for k-means clustering
This adds two most common initialization strategies for the k-means
clustering algorithm, namely, Random initialization and km
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/757#issuecomment-117220314
Hey @thvasilo , I'm going to break up this PR further. The motivation is
that, the Sampling code should be available as a general feature. Given a
probability dist
Github user sachingoel0101 closed the pull request at:
https://github.com/apache/flink/pull/757
---
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
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608419#comment-14608419
]
Stephan Ewen commented on FLINK-2293:
-
[~fhueske] and me have located this and figured
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608411#comment-14608411
]
Stephan Ewen commented on FLINK-2296:
-
+1 to do that so the current state is robust an
[
https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608412#comment-14608412
]
Stephan Ewen commented on FLINK-2299:
-
We are getting more reports where this happens.
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608397#comment-14608397
]
Ufuk Celebi commented on FLINK-2296:
+1 to the renaming.
> Checkpoint committing brok
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis reassigned FLINK-2157:
--
Assignee: Theodore Vasiloudis
> Create evaluation framework for ML library
> --
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608364#comment-14608364
]
Gyula Fora commented on FLINK-2296:
---
+1
> Checkpoint committing broken
> --
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608360#comment-14608360
]
Robert Metzger edited comment on FLINK-2296 at 6/30/15 2:22 PM:
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2111:
---
Description:
Currently, streaming jobs can only be stopped using "cancel" command, what is a
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608360#comment-14608360
]
Robert Metzger commented on FLINK-2296:
---
+1 for renaming the method to {{notifyCheck
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2111:
---
Summary: Add "stop" signal to cleanly shutdown streaming jobs (was: Add
"stop" signal to clea
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2111:
---
Summary: Add "stop" signal to cleanly stop streaming jobs (was: Add
"terminate" signal to cle
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/871#issuecomment-117202580
I believe that the current code covers the scope of the linked issue. We
can now start reviewing the relevant changes and continue with code cleanup to
bring this to a m
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608346#comment-14608346
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608336#comment-14608336
]
Theodore Vasiloudis commented on FLINK-2108:
The for the score function can no
[
https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608336#comment-14608336
]
Theodore Vasiloudis edited comment on FLINK-2108 at 6/30/15 2:07 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608304#comment-14608304
]
Andra Lungu edited comment on FLINK-2299 at 6/30/15 2:00 PM:
-
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-117195363
Thanks @chiwanpark . I don't think I'll have the time to review this week,
I'll set a reminder for Monday.
---
If your project is set up for it, you can reply to this e
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608308#comment-14608308
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608302#comment-14608302
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608304#comment-14608304
]
Andra Lungu commented on FLINK-2299:
No, there was no problem with the network. I beli
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-117194517
What we would like to see actually is this PR and #757 to be merged into
one, so that we can review them as a whole. @sachingoel0101 do you think you
will be able to do
[
https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608296#comment-14608296
]
Robert Metzger commented on FLINK-2299:
---
Looks like wally025 broke up with the JobMa
Andra Lungu created FLINK-2299:
--
Summary: The slot on which the task maanger was scheduled was
killed
Key: FLINK-2299
URL: https://issues.apache.org/jira/browse/FLINK-2299
Project: Flink
Issue
Robert Metzger created FLINK-2298:
-
Summary: Allow setting custom YARN application names through the
CLI
Key: FLINK-2298
URL: https://issues.apache.org/jira/browse/FLINK-2298
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608270#comment-14608270
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/871#issuecomment-117185135
Cherry picked the changes to Predictor and SVM from #874
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608264#comment-14608264
]
Stephan Ewen commented on FLINK-2296:
-
I think there is a misunderstanding on what the
[
https://issues.apache.org/jira/browse/FLINK-2297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608261#comment-14608261
]
ASF GitHub Bot commented on FLINK-2297:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/874#discussion_r33570883
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/classification/SVMITSuite.scala
---
@@ -69,19 +70,38 @@ class SVMITSuite extends FlatSpec
[
https://issues.apache.org/jira/browse/FLINK-2297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608259#comment-14608259
]
ASF GitHub Bot commented on FLINK-2297:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/874#discussion_r33570815
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/SVM.scala
---
@@ -242,8 +275,21 @@ object SVM{
}
}
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2296:
--
Description:
While working on fixing the failing {{PersistentKafkaSource}} test, I realized
tha
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608255#comment-14608255
]
Gyula Fora commented on FLINK-2296:
---
The reason we made these changes for the Checkpoint
[
https://issues.apache.org/jira/browse/FLINK-2297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608253#comment-14608253
]
ASF GitHub Bot commented on FLINK-2297:
---
GitHub user thvasilo opened a pull request:
GitHub user thvasilo opened a pull request:
https://github.com/apache/flink/pull/874
[FLINK-2297] [ml] Add threshold setting for SVM binary predictions
Currently SVM outputs the raw decision function values when using the
predict function.
We should have instead the ability
Theodore Vasiloudis created FLINK-2297:
--
Summary: Add threshold setting for SVM binary predictions
Key: FLINK-2297
URL: https://issues.apache.org/jira/browse/FLINK-2297
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-2296:
-
Assignee: Robert Metzger
> Checkpoint committing broken
>
>
Robert Metzger created FLINK-2296:
-
Summary: Checkpoint committing broken
Key: FLINK-2296
URL: https://issues.apache.org/jira/browse/FLINK-2296
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608238#comment-14608238
]
Gyula Fora commented on FLINK-2294:
---
This was a trivial fix for the current implementati
[
https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608236#comment-14608236
]
Robert Metzger commented on FLINK-2294:
---
It would have been nice if you waited until
[
https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2294.
-
Resolution: Fixed
https://github.com/apache/flink/commit/fef9f115838b3ba3d3769f8669ee251c2cd403c6
> Keyed
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-117161545
Please create JIRAs for changes in the future.
---
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 pr
[
https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608195#comment-14608195
]
Gyula Fora commented on FLINK-2294:
---
Every stream operator has a context and since the c
[
https://issues.apache.org/jira/browse/FLINK-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608183#comment-14608183
]
Aljoscha Krettek commented on FLINK-2295:
-
That's why I said I have the fix, yes.
[
https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608178#comment-14608178
]
Aljoscha Krettek commented on FLINK-2294:
-
{{processElement}} gets the element. Th
[
https://issues.apache.org/jira/browse/FLINK-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608171#comment-14608171
]
Gyula Fora commented on FLINK-2295:
---
I see that the CoReader set in the TwoInput tas doe
[
https://issues.apache.org/jira/browse/FLINK-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608171#comment-14608171
]
Gyula Fora edited comment on FLINK-2295 at 6/30/15 11:55 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608159#comment-14608159
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gaborhermann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608160#comment-14608160
]
Gyula Fora commented on FLINK-2294:
---
The issue was caused by having two output collector
Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-117141916
Okay then. These are the effects of changing I did not know about. Let's
stick to (2) and later on, we might reconsider this.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-2294:
-
Assignee: Gyula Fora
> Keyed State does not work with DOP=1
> ---
[
https://issues.apache.org/jira/browse/FLINK-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608100#comment-14608100
]
Gyula Fora commented on FLINK-2294:
---
I don't understand what you mean by setting it in t
Aljoscha Krettek created FLINK-2295:
---
Summary: TwoInput Task do not react to/forward checkpoint barriers
Key: FLINK-2295
URL: https://issues.apache.org/jira/browse/FLINK-2295
Project: Flink
Aljoscha Krettek created FLINK-2294:
---
Summary: Keyed State does not work with DOP=1
Key: FLINK-2294
URL: https://issues.apache.org/jira/browse/FLINK-2294
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608088#comment-14608088
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-117117294
How about we leave the batch API as it is for now and address that as a
separate issue? There are quite some subtleties in how the optimizer assesses
equality of part
[
https://issues.apache.org/jira/browse/FLINK-2290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2290:
Priority: Blocker (was: Major)
> CoRecordReader Does Not Read Events From Both Inputs When
[
https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608074#comment-14608074
]
ASF GitHub Bot commented on FLINK-2150:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/801#issuecomment-117112526
Okay, can I get some +1s to 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 proj
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14608003#comment-14608003
]
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-117068361
I totally agree on you guys points. We have a little amount of centroids,
and the model is not supposed to be distributed in the end.
The question is now: Shoul
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607968#comment-14607968
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-117060737
Hi. IMO, the purpose of learning is to develop a model which compactly
represents the data somehow. Thus, having a distributed model doesn't make
sense. Besides, t
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607965#comment-14607965
]
Andra Lungu commented on FLINK-2293:
Also reproducible with
https://github.com/andral
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607966#comment-14607966
]
Fabian Hueske commented on FLINK-2105:
--
[~chiwanpark] is right. This issue is about t
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607961#comment-14607961
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-117059705
Hi, I updated this PR. I reimplemented kNN Join with `zipWithIndex` and
fitted to changed pipeline architecture.
---
If your project is set up for it, you can reply
Github user rbraeunlich commented on a diff in the pull request:
https://github.com/apache/flink/pull/730#discussion_r33551797
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/feature/TfIdfTransformer.scala
---
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607954#comment-14607954
]
ASF GitHub Bot commented on FLINK-2131:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2286:
--
Fix Version/s: 0.9.1
> Window ParallelMerge sometimes swallows elements of the last wind
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/757#issuecomment-117055846
Okay. I'll update it today itself with a few trivial fixes.
---
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-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2285:
--
Fix Version/s: 0.9.1
> Active policy emits elements of the last window twice
> -
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607950#comment-14607950
]
Fabian Hueske commented on FLINK-2293:
--
Is it possible to share the 10GB input data (
[
https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14607946#comment-14607946
]
ASF GitHub Bot commented on FLINK-2131:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2293:
-
Priority: Critical (was: Major)
> Division by Zero Exception
> --
>
>
1 - 100 of 118 matches
Mail list logo
