[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544260#comment-15544260
]
ASF GitHub Bot commented on FLINK-4406:
---
Github user KurtYoung closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544259#comment-15544259
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user KurtYoung closed the pull reque
Github user KurtYoung closed the pull request at:
https://github.com/apache/flink/pull/2550
---
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 e
Github user KurtYoung closed the pull request at:
https://github.com/apache/flink/pull/2565
---
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 e
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544170#comment-15544170
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/4/16 3:17 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544170#comment-15544170
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/4/16 3:04 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544170#comment-15544170
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/4/16 3:01 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544170#comment-15544170
]
Tzu-Li (Gordon) Tai commented on FLINK-4722:
One last comment:
Iterating over
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2425
Addressed [FLINK-4635] Netty data transfer authentication (missing piece of
FLINK-3930)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543956#comment-15543956
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543749#comment-15543749
]
Neelesh Srinivas Salian commented on FLINK-3999:
Apologies. Haven't had th
[
https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543370#comment-15543370
]
ASF GitHub Bot commented on FLINK-4728:
---
GitHub user greghogan opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543365#comment-15543365
]
ASF GitHub Bot commented on FLINK-4406:
---
Github user tillrohrmann commented on the i
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2582
[FLINK-4728] [core,optimizer] Replace reference equality with object
equality
Some cases of testing Integer equality using == rather than
Integer.equals(Integer), and some additional cleanup.
Yo
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543367#comment-15543367
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2565
Thanks for your contribution @KurtYoung. I've merged the code. You can
close the PR now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2550
Thanks for your contribution @KurtYoung. I've merged the code. You can
close the PR now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4657.
--
Resolution: Fixed
Added via f7cfc1bb66affab43bb9e2643d48ac5bfc28fe3e
> Implement HighAvailabili
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4406.
--
Resolution: Fixed
Added via ba2b59096022b480a70f6410d9b1643da5158608
> Implement job master reg
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543355#comment-15543355
]
ASF GitHub Bot commented on FLINK-4478:
---
Github user tillrohrmann closed the pull re
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2435
---
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-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543308#comment-15543308
]
Greg Hogan commented on FLINK-3888:
---
Okay, that sounds better than requiring the user to
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543256#comment-15543256
]
Vasia Kalavri commented on FLINK-3888:
--
We shouldn't override the default convergence
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543190#comment-15543190
]
Greg Hogan commented on FLINK-3888:
---
This looks quite useful. Why have a function to ena
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3888:
-
Component/s: Iterations
> Custom Aggregator with Convergence can't be registered directly with
>
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543133#comment-15543133
]
Vasia Kalavri commented on FLINK-3888:
--
I had a quick look into this and I don't see
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543036#comment-15543036
]
Sudhanshu Sekhar Lenka commented on FLINK-4722:
---
according to your solution
Greg Hogan created FLINK-4729:
-
Summary: Use optional VertexCentric CombineFunction
Key: FLINK-4729
URL: https://issues.apache.org/jira/browse/FLINK-4729
Project: Flink
Issue Type: Improvement
Greg Hogan created FLINK-4728:
-
Summary: Replace reference equality with object equality
Key: FLINK-4728
URL: https://issues.apache.org/jira/browse/FLINK-4728
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542855#comment-15542855
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/3/16 4:58 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542855#comment-15542855
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/3/16 4:58 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542855#comment-15542855
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/3/16 4:55 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542855#comment-15542855
]
Tzu-Li (Gordon) Tai commented on FLINK-4722:
I'm not sure if I fully understan
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542840#comment-15542840
]
Sudhanshu Sekhar Lenka commented on FLINK-4722:
---
i am able to figure out so
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542828#comment-15542828
]
Sudhanshu Sekhar Lenka commented on FLINK-4722:
---
Real case is i am sending 1
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542796#comment-15542796
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/3/16 4:35 PM:
---
Github user mtanski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2002#discussion_r81589240
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/compression/InflaterInputStreamFactory.java
---
@@ -23,13 +23,12 @@
import java.io.IOE
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542796#comment-15542796
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/3/16 4:30 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542796#comment-15542796
]
Tzu-Li (Gordon) Tai commented on FLINK-4722:
Is there any reason / use case wh
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542774#comment-15542774
]
Sudhanshu Sekhar Lenka commented on FLINK-4722:
---
Thnx for your reply.
Is th
Github user mtanski commented on the issue:
https://github.com/apache/flink/pull/2002
I tried changing the name from to InflaterInputStreamFactory ->
DecompressingStreamFactory
But now it will not build because of:
[ERROR] Failed to execute goal
com.github.siom79.japicmp:
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-3734.
---
Resolution: Cannot Reproduce
> Unclosed DataInputView in
> AbstractAlignedProcessingTimeWindowOperator#restor
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2580
Seems like one of the new IT tests is a bit unstable, fixing it ...
---
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 do
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542696#comment-15542696
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user tzulitai commented on the issue
GitHub user fholger opened a pull request:
https://github.com/apache/flink/pull/2581
[FLINK-4709] Fix resource leak in InputStreamFSInputWrapper
InputStreamFSInputWrapper is a wrapper around an arbitrary Java
InputStream. As such, it needs to reimplement the close() function and for
[
https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542651#comment-15542651
]
ASF GitHub Bot commented on FLINK-4709:
---
GitHub user fholger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4643.
-
Resolution: Implemented
Implemented in 95c08eab36bfa09c501a84f5b5f116d666d03ae1
> Average Clustering Coef
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4624.
-
Resolution: Fixed
Fixed in a79efdc23e1bd35eb7cd2e5eb9551cc297c02dd5
> Gelly's summarization algorithm can
[
https://issues.apache.org/jira/browse/FLINK-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4643:
--
Fix Version/s: 1.2.0
> Average Clustering Coefficient
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542606#comment-15542606
]
ASF GitHub Bot commented on FLINK-4624:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2527
---
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-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542605#comment-15542605
]
ASF GitHub Bot commented on FLINK-4643:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2528
---
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-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542449#comment-15542449
]
ASF GitHub Bot commented on FLINK-4624:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2527
Will merge today. I'll add a note that the `TypeInformation` will be
removed once we resolve the issues typing `Either`.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542348#comment-15542348
]
ASF GitHub Bot commented on FLINK-4723:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/2580
[FLINK-4723] [kafka-connector] Unify committed offsets to Kafka to be the
next record to process
The description within the JIRA ticket
([FLINK-4723](https://issues.apache.org/jira/browse/FLINK-47
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542267#comment-15542267
]
Martin Junghanns commented on FLINK-4624:
-
ping [~greghogan]
> Gelly's summarizat
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542145#comment-15542145
]
Tzu-Li (Gordon) Tai commented on FLINK-4722:
Hi [~sudhanshulenka],
I think thi
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15542145#comment-15542145
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/3/16 11:00 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15541994#comment-15541994
]
Faye Beligianni commented on FLINK-1815:
Hey,
I am not sure why I wasn't aware o
[
https://issues.apache.org/jira/browse/FLINK-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-3204:
--
Assignee: Nikolay Vasilishin
> TaskManagers are not shutting down properly on YARN
> ---
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4727:
---
Description:
This is basically the 0.9 version counterpart for FLINK-3440.
When the 0
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15541912#comment-15541912
]
ASF GitHub Bot commented on FLINK-3734:
---
Github user lw-lin closed the pull request
Github user lw-lin closed the pull request at:
https://github.com/apache/flink/pull/2557
---
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-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15541909#comment-15541909
]
ASF GitHub Bot commented on FLINK-3734:
---
Github user lw-lin commented on the issue:
Github user lw-lin commented on the issue:
https://github.com/apache/flink/pull/2557
Glad to see this issue got fixed along with
https://github.com/apache/flink/pull/2512 -- the fix is [this line in
StreamTask](https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/
Tzu-Li (Gordon) Tai created FLINK-4727:
--
Summary: Kafka 0.9 Consumer should also checkpoint auto retrieved
offsets even when no data is read
Key: FLINK-4727
URL: https://issues.apache.org/jira/browse/FLINK-47
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15541713#comment-15541713
]
ASF GitHub Bot commented on FLINK-4315:
---
Github user kenmy closed the pull request a
Github user kenmy commented on the issue:
https://github.com/apache/flink/pull/2576
Merge this PR when 2.0 branch will be created
---
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
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15541714#comment-15541714
]
ASF GitHub Bot commented on FLINK-4315:
---
Github user kenmy commented on the issue:
Github user kenmy closed the pull request at:
https://github.com/apache/flink/pull/2576
---
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
72 matches
Mail list logo
