[
https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113627#comment-15113627
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1465#issuecomment-174157061
@fhueske I have implemented your feedback and rebased it onto the current
master. Unfortunately, Git had problems with the new package structure. I had
to squash my comm
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113603#comment-15113603
]
ramkrishna.s.vasudevan commented on FLINK-2168:
---
[~fhueske]
Thanks for the u
[
https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113602#comment-15113602
]
ramkrishna.s.vasudevan commented on FLINK-3135:
---
[~rmetzger]
Thank you for w
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113204#comment-15113204
]
Trevor Grant commented on FLINK-2030:
-
Anything going on with this? Anything I can do
[
https://issues.apache.org/jira/browse/FLINK-3280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113123#comment-15113123
]
Robert Metzger commented on FLINK-3280:
---
Hi,
This pull request contains a fix for th
Ted Yu created FLINK-3280:
-
Summary: Wrong usage of Boolean.getBoolean()
Key: FLINK-3280
URL: https://issues.apache.org/jira/browse/FLINK-3280
Project: Flink
Issue Type: Bug
Reporter: Ted
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113112#comment-15113112
]
Thang Nguyen edited comment on FLINK-1733 at 1/22/16 9:26 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113112#comment-15113112
]
Thang Nguyen commented on FLINK-1733:
-
Hi [~till.rohrmann]!
I am a software engineer
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112865#comment-15112865
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull re
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-174012431
Thanks! I've found the JIRA:
https://issues.apache.org/jira/browse/FLINK-2246
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-2246:
--
Assignee: Gabor Gevay
> Add chained combine driver strategy for ReduceFunction
> --
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112857#comment-15112857
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-174010704
No one got around to do it in an efficient/safe manner. There is a JIRA for
it afaik.
---
If your project is set up for it, you can reply to this email and have your
rep
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112808#comment-15112808
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull re
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-173997370
Quick question: Is there a reason why there is no chained version of
ReduceCombineDriver? (GroupReduceDriver and AllReduceDriver both have chained
versions: SynchronousCh
Greg Hogan created FLINK-3279:
-
Summary: Optionally disable DistinctOperator combiner
Key: FLINK-3279
URL: https://issues.apache.org/jira/browse/FLINK-3279
Project: Flink
Issue Type: New Feature
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1542
[FLINK-3178] Don't Emit In-Flight Windows When Closing Window Operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink window-no
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112529#comment-15112529
]
ASF GitHub Bot commented on FLINK-3178:
---
GitHub user aljoscha opened a pull request:
Greg Hogan created FLINK-3277:
-
Summary: Use Value types in Gelly API
Key: FLINK-3277
URL: https://issues.apache.org/jira/browse/FLINK-3277
Project: Flink
Issue Type: Improvement
Compon
Aljoscha Krettek created FLINK-3278:
---
Summary: Add Partitioned State Backend Based on RocksDB
Key: FLINK-3278
URL: https://issues.apache.org/jira/browse/FLINK-3278
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1994.
Resolution: Fixed
Added via 9c2f516671660fbb588eeadfe73c93fb775aa085
> Add different gain calculati
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112514#comment-15112514
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1397
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112326#comment-15112326
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user rawkintrevo commented on the pu
Github user rawkintrevo commented on the pull request:
https://github.com/apache/flink/pull/1397#issuecomment-173893702
Thank you guys!
---
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 fe
[
https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-3276:
-
Assignee: Maximilian Michels
> Move runtime parts of flink-streaming-java to flin
Maximilian Michels created FLINK-3276:
-
Summary: Move runtime parts of flink-streaming-java to
flink-runtime
Key: FLINK-3276
URL: https://issues.apache.org/jira/browse/FLINK-3276
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112296#comment-15112296
]
Robert Metzger commented on FLINK-2973:
---
Okay, I changed the priority to Minor (it w
[
https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2973:
--
Summary: Add flink-benchmark with compliant licenses again (was: Remove
OpenJDK JMH dependency
[
https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2973:
--
Priority: Minor (was: Blocker)
> Remove OpenJDK JMH dependency from flink-benchmark
> -
Chesnay Schepler created FLINK-3275:
---
Summary: [py] Add support for Dataset.setParallelism()
Key: FLINK-3275
URL: https://issues.apache.org/jira/browse/FLINK-3275
Project: Flink
Issue Type:
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1536#issuecomment-173876414
I'll take some time. I've spotted another possible issue in the docs, I'll
look into it as we gain more feedback from the mailing list. Thank you!
---
If your pr
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112288#comment-15112288
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112281#comment-15112281
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1536#issuecomment-173874750
mh, I understand that you are motivated to move on with this task. I think
most likely other Flink committers agree to the change, but it might also
happen that the dis
[
https://issues.apache.org/jira/browse/FLINK-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2581:
--
Assignee: (was: Robert Metzger)
> Add warning to the YARN client when using an older Hadoop
[
https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2609:
--
Assignee: (was: Robert Metzger)
> Automatic type registration is only called from the batch
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1541
[FLINK-3274] Make accumulator names of Kafka connector unique
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink3274
Alterna
[
https://issues.apache.org/jira/browse/FLINK-3274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112273#comment-15112273
]
ASF GitHub Bot commented on FLINK-3274:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112257#comment-15112257
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1536#issuecomment-173871987
It seems like your improvements have had a positive feedback from the ML.
Shall I proceed replicating those on other examples as well?
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112250#comment-15112250
]
Robert Metzger commented on FLINK-3135:
---
Hi Ramkrishna, I'm sorry that nobody respon
[
https://issues.apache.org/jira/browse/FLINK-3065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3065.
---
Resolution: Fixed
Assignee: Robert Metzger
Resolved.
> Can't cancel failing jobs
>
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1397#issuecomment-173869263
@tillrohrmann Thanks! It is good news.
@rawkintrevo Thanks for contribution :+1:
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112248#comment-15112248
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user chiwanpark commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112237#comment-15112237
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1397#issuecomment-173867691
LGTM, will merge it then. I'll address @chiwanpark comment concerning the
`decay` value while merging it. Thanks for your work @rawkintrevo :-)
---
If your project
Robert Metzger created FLINK-3274:
-
Summary: Prefix Kafka connector accumulators with unique id
Key: FLINK-3274
URL: https://issues.apache.org/jira/browse/FLINK-3274
Project: Flink
Issue Type
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50519736
--- Diff: docs/libs/ml/optimization.md ---
@@ -189,9 +187,26 @@ The following list contains a mapping between the
implementing classes and the r
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112234#comment-15112234
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50519644
--- Diff: docs/libs/ml/optimization.md ---
@@ -276,6 +369,8 @@ val sgd = GradientDescentL1()
.setRegularizationConstant(0.2)
.setIterations(
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112232#comment-15112232
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1397#issuecomment-173866185
Not squashing the commits here is the right way to go. We'll squash them
once we merge it.
---
If your project is set up for it, you can reply to this email and ha
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112230#comment-15112230
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112226#comment-15112226
]
Till Rohrmann commented on FLINK-1936:
--
+1 for a uniform naming scheme. Personally I
Maximilian Michels created FLINK-3273:
-
Summary: Remove Scala dependency from flink-streaming-java
Key: FLINK-3273
URL: https://issues.apache.org/jira/browse/FLINK-3273
Project: Flink
Iss
Martin Junghanns created FLINK-3272:
---
Summary: Generalize vertex value type in ConnectedComponents
Key: FLINK-3272
URL: https://issues.apache.org/jira/browse/FLINK-3272
Project: Flink
Issue
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50511127
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java
---
@@ -1558,7 +1641,209 @@ public void reset() {
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112091#comment-15112091
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
60 matches
Mail list logo
