[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731816#comment-14731816
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137912454
I object to break API in this PR. I think that this PR should cover
histogram for `DataSet` only. That's why we split this PR from #1032.
About documentation, adding a
Github user chenliang613 commented on the pull request:
https://github.com/apache/flink/pull/1094#issuecomment-137896176
The implementation method may not the best solution. Actually i tried a
couple of solutions(for example:use finalName tag to replace classifier),but
because there h
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731740#comment-14731740
]
ASF GitHub Bot commented on FLINK-2493:
---
Github user chenliang613 commented on the p
GitHub user chenliang613 opened a pull request:
https://github.com/apache/flink/pull/1094
[FLINK-2493] Simplify names of example program JARs
The names of the example JARs under build-target/examples have some
confusion, the version number might stop users from submitting examples t
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731687#comment-14731687
]
ASF GitHub Bot commented on FLINK-2493:
---
GitHub user chenliang613 opened a pull requ
Github user chenliang613 closed the pull request at:
https://github.com/apache/flink/pull/1087
---
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 i
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731674#comment-14731674
]
ASF GitHub Bot commented on FLINK-2493:
---
Github user chenliang613 closed the pull re
[
https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731546#comment-14731546
]
ASF GitHub Bot commented on FLINK-1320:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1093#issuecomment-137872521
I took the code from #290 (by @mxm and me) as the basis, but heavily
reworked it. Some code is similar most notably, the collapsed
address/release/bound check in the
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1093#issuecomment-137857146
Isn't there another PR sent for this issue by Max? Or was it for something
else.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731461#comment-14731461
]
ASF GitHub Bot commented on FLINK-1320:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1089#issuecomment-137857005
+1
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 feat
[
https://issues.apache.org/jira/browse/FLINK-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731459#comment-14731459
]
ASF GitHub Bot commented on FLINK-2605:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731322#comment-14731322
]
ASF GitHub Bot commented on FLINK-2605:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1089#issuecomment-137837300
+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
[
https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731294#comment-14731294
]
ASF GitHub Bot commented on FLINK-1320:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1093
[FLINK-1320] [core] Add an off-heap variant of the managed memory
This pull request extends the Flink managed memory to work transparently
on-heap and off-heap.
In Flink's core were alw
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137802768
I have split this into two commits.
@thvasilo, if there is need to file a jira, I'll update the second commit
message to indicate that.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731131#comment-14731131
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731024#comment-14731024
]
ASF GitHub Bot commented on FLINK-2583:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1084#issuecomment-137782086
How hard is it to support the truncate file code path also for regular Unix
file systems (rather than only HDFS 2.7+)?
The reason is that this way we would s
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1052#issuecomment-137781257
Yeah, adding warnings fix to this PR is good.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731021#comment-14731021
]
ASF GitHub Bot commented on FLINK-2106:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731017#comment-14731017
]
ASF GitHub Bot commented on FLINK-2106:
---
Github user r-pogalz commented on the pull
Github user r-pogalz commented on the pull request:
https://github.com/apache/flink/pull/1052#issuecomment-137780075
Thanks for you comment @StephanEwen, good to know that. I tried to minimize
the occurrences of warnings where possible by fixing or suppressing it for this
issue. Shoul
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731002#comment-14731002
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137778976
Okay. Instead of adding the Scala api wrappers and add to the complexity
[we might have another import such as
`org.apache.flink.api.scala.DataSetUtils.utilsToDoub
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-13090
If it is actually considered to be API breaking then we should open a new
PR and JIRA to make sure the change is well documented. Let's see what Till
thinks and I can cr
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730986#comment-14730986
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730984#comment-14730984
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137776491
@thvasilo , I'm not sure I got that right. I hadn't tested the changed
`DataSetUtils`.
I'm not sure how to handle the implicit types and class tags. Since you
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730981#comment-14730981
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137775231
Also @tillrohrmann : Is changing the DataSetUtils structure considered an
API breaking change and should we handle it differently?
Any code using `import
org.ap
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730977#comment-14730977
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137772917
I think it would be hard to do otherwise. `java.lang.Double`'s are objects
but `scala.Double`'s are not from what I understand. In this case duplicating
the code might n
[
https://issues.apache.org/jira/browse/FLINK-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730974#comment-14730974
]
ASF GitHub Bot commented on FLINK-2605:
---
Github user tedyu commented on the pull req
Github user tedyu commented on the pull request:
https://github.com/apache/flink/pull/1089#issuecomment-137772269
Your reasoning w.r.t. current scope of try block was the same as mine.
I think it is good to make the scope as accurate as possible. Generally
speaking, we don't w
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730956#comment-14730956
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137768632
IMO this isn't a good idea. We're adding an additional mapping step, and
creating as many objects unnecessarily. Sure, chaining will make the mapping
quite fast, b
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137768373
Re 1: Good change, implicit classes is the way to go here, no need for
implicit conversion in the object.
---
If your project is set up for it, you can reply to this em
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730955#comment-14730955
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730941#comment-14730941
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730947#comment-14730947
]
ASF GitHub Bot commented on FLINK-2583:
---
Github user aljoscha commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137764885
```scala
def createDiscreteHistogram: DataSet[DiscreteHistogram] = {
wrap(jutils.DataSetUtils.createDiscreteHistogram(
self.map(x => new java.
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1084#issuecomment-137764994
I (almost) completely reworked the sink. It is now called `RollingSink` and
the module is called `flink-connector-filesystem` to show that it works with
any Hadoop File
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730946#comment-14730946
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user thvasilo commented on the pull
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137763865
1. @thvasilo , I have changed the scala `DataSetUtils` class to make it a
bit more easy to use. Now, it doesn't require an import of
`org.apache.flink.api.scala.Da
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1089#issuecomment-137761664
Thanks for the PR. The change looks good. It is good to merge.
The following comment is optional to address: I understand that you didn't
add the last two statements
[
https://issues.apache.org/jira/browse/FLINK-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730930#comment-14730930
]
ASF GitHub Bot commented on FLINK-2605:
---
Github user uce commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1090#issuecomment-137760319
Yes, I guess it is a better fit for the examples.
---
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 pro
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/805
---
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-2161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730926#comment-14730926
]
ASF GitHub Bot commented on FLINK-2161:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2161.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via 3d528442f6993c64600224483ee3048c40763c80
>
[
https://issues.apache.org/jira/browse/FLINK-2161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2161.
---
> Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML)
> ---
[
https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730907#comment-14730907
]
ASF GitHub Bot commented on FLINK-2106:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730920#comment-14730920
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137759354
@sachingoel0101 That sounds like a good place for the docs, that
`zip_elements_guide.mb` is linked from the DataSet Transformations doc, so
replacing that link to a more
[
https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730918#comment-14730918
]
Stephan Ewen commented on FLINK-2348:
-
Looks like a temp file thing. Port the test to
[
https://issues.apache.org/jira/browse/FLINK-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730913#comment-14730913
]
Stephan Ewen commented on FLINK-2474:
-
Yes, close it. Will be reopened once we observe
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1052#issuecomment-137757977
I just saw that the OuterJoin runtime classes/tests cause a lot of warnings
when compiling. Manyly raw types, unchecked casts.
Would be good to fix those. In
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1090#issuecomment-137757590
Okay, why not add it to the examples then?
---
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
Stephan Ewen created FLINK-2624:
---
Summary: RabbitMQ source / sink should participate in checkpointing
Key: FLINK-2624
URL: https://issues.apache.org/jira/browse/FLINK-2624
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730869#comment-14730869
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730857#comment-14730857
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on the pul
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1046#issuecomment-137748448
The changes suggested above help with a cleaner separation between the
application (here storm compatibility) and the core code.
---
If your project is set up for i
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730867#comment-14730867
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137748205
Hello @thvasilo , I was unable to access the `create...` functions from the
scala API. I'm not sure how to pass a `DataSet[Double]` to a
`DataSet[java.lang.Double]
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730868#comment-14730868
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1046#issuecomment-137748262
Concerning the changes at the core classes:
- The storm config key is an application specific key and not part of the
system configuration, therefore it should
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730865#comment-14730865
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on the pul
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-137747552
@StephanEwen
@tillrohrmann
Hi,
I get the CI to rerun.
Any new comment?
---
If your project is set up for it, you can reply to this email and have you
[
https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730863#comment-14730863
]
ASF GitHub Bot commented on FLINK-2480:
---
Github user HuangWHWHW commented on the pul
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1073#issuecomment-137746778
@mxm
Hi,
I change the "\r\n" to "\n" since it use println in
PrintSinkFunction.invoke();
---
If your project is set up for it, you can reply to this email an
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-137745160
@mxm
Ok, I make the CI rerun.
Any new comment?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
Github user chenliang613 commented on the pull request:
https://github.com/apache/flink/pull/1087#issuecomment-137744893
The CI failure be reported from flink-yarn-tests .but in my local machine,
i did many times checking with "mvn clean verify" in flink-yarn-tests, all are
successful
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730854#comment-14730854
]
ASF GitHub Bot commented on FLINK-2493:
---
Github user chenliang613 commented on the p
Till Rohrmann created FLINK-2623:
Summary: Extend API completeness check to check signatures
Key: FLINK-2623
URL: https://issues.apache.org/jira/browse/FLINK-2623
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730843#comment-14730843
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1046#issuecomment-137742282
I have just a quick look over it, and so far it like it. Two things are
open to be discussed. I not sure it the change to `ConfigConstants` in a good
choice. Would it be f
[
https://issues.apache.org/jira/browse/FLINK-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730837#comment-14730837
]
Stephan Ewen commented on FLINK-2619:
-
+1 for urgent fixing!
> Some Scala Tests not b
Github user gcpagano closed the pull request at:
https://github.com/apache/flink/pull/1092
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730723#comment-14730723
]
Robert Metzger commented on FLINK-2621:
---
I wrote on the ML again.
I would prefer to
[
https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730712#comment-14730712
]
Behrouz Derakhshan commented on FLINK-2621:
---
Well I had the idea of users not be
Till Rohrmann created FLINK-2622:
Summary: Scala DataStream API does not have writeAsText method
which supports WriteMode
Key: FLINK-2622
URL: https://issues.apache.org/jira/browse/FLINK-2622
Project:
[
https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730709#comment-14730709
]
Robert Metzger commented on FLINK-2621:
---
Looks good. I think that the check for cond
[
https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730709#comment-14730709
]
Robert Metzger edited comment on FLINK-2621 at 9/4/15 12:18 PM:
[
https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Behrouz Derakhshan updated FLINK-2621:
--
Description:
While working on FLINK-2021, we noticed we need to have support for positio
[
https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Behrouz Derakhshan updated FLINK-2621:
--
Description:
While working on FLINK-2021, the need for positional argument support becam
Behrouz Derakhshan created FLINK-2621:
-
Summary: Add support for positional arguments to ParameterTool
Key: FLINK-2621
URL: https://issues.apache.org/jira/browse/FLINK-2621
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730694#comment-14730694
]
Fabian Hueske commented on FLINK-2617:
--
Yes, that could be a fix.
But I think it woul
Matthias J. Sax created FLINK-2620:
--
Summary: StreamPartitioner is not properly initialized for shuffle
and rebalance
Key: FLINK-2620
URL: https://issues.apache.org/jira/browse/FLINK-2620
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730672#comment-14730672
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137714631
Hello, my 2c: This PR should include docs and a wrapper for the Scala API.
We can also do this with a separate issue but it would be best if we merge as a
more complete
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137712869
I also like to take a look before 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 pr
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730671#comment-14730671
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user tillrohrmann commented on the p
GitHub user gcpagano opened a pull request:
https://github.com/apache/flink/pull/1092
Update FlinkTopology.java
Make FlinkTopology public
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/gcpagano/flink patch-1
Alternatively you ca
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-137695084
Haha. This patch is 1000+, 0-. :laughing:
---
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
[
https://issues.apache.org/jira/browse/FLINK-2274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel updated FLINK-2274:
---
Component/s: (was: Machine Learning Library)
Java API
> Add a histogram method fo
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r38736955
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/accumulators/ContinuousHistogram.java
---
@@ -0,0 +1,534 @@
+/*
+ * Licensed to
1 - 100 of 128 matches
Mail list logo
