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
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112529#comment-15112529
]
ASF GitHub Bot commented on FLINK-3178:
---
GitHub user aljoscha opened a pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113112#comment-15113112
]
Thang Nguyen commented on FLINK-1733:
-
Hi [~till.rohrmann]!
I am a software engineer professionally,
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:
[
https://issues.apache.org/jira/browse/FLINK-3280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113123#comment-15113123
]
Robert Metzger commented on FLINK-3280:
---
Hi,
This pull request contains a fix for the issue:
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113112#comment-15113112
]
Thang Nguyen edited comment on FLINK-1733 at 1/22/16 9:26 PM:
--
Hi
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:
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112808#comment-15112808
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112865#comment-15112865
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112857#comment-15112857
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user zentol commented on the pull request:
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
[
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
>
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=15112234#comment-15112234
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a diff in the pull
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=15112248#comment-15112248
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user chiwanpark commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112250#comment-15112250
]
Robert Metzger commented on FLINK-3135:
---
Hi Ramkrishna, I'm sorry that nobody responded to your pull
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
[
https://issues.apache.org/jira/browse/FLINK-3274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15112288#comment-15112288
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the pull request:
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
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
[
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
>
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112232#comment-15112232
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a diff in the pull
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)
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
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112237#comment-15112237
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112257#comment-15112257
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112281#comment-15112281
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user rmetzger commented on the pull request:
[
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
>
[
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:comment-tabpanel=15112296#comment-15112296
]
Robert Metzger commented on FLINK-2973:
---
Okay, I changed the priority to Minor (it was blocking
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112230#comment-15112230
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113204#comment-15113204
]
Trevor Grant commented on FLINK-2030:
-
Anything going on with this? Anything I can do to help?
>
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112091#comment-15112091
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in the pull
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() {
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
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112326#comment-15112326
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user rawkintrevo commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113602#comment-15113602
]
ramkrishna.s.vasudevan commented on FLINK-3135:
---
[~rmetzger]
Thank you for writing. Let me
[
https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113627#comment-15113627
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user twalthr commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113603#comment-15113603
]
ramkrishna.s.vasudevan commented on FLINK-2168:
---
[~fhueske]
Thanks for the update.
> Add
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112514#comment-15112514
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user asfgit closed the pull request at:
[
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
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
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
58 matches
Mail list logo
