[
https://issues.apache.org/jira/browse/FLINK-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15398744#comment-15398744
]
ASF GitHub Bot commented on FLINK-4269:
---
Github user nssalian commented on the issue:
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2307
Hi @aditivin , welcome to the community. Thank you for the PR as well.
A few suggestions:
1) Upon opening a PR, it is best to add more information regarding testing
or even checks that you
[
https://issues.apache.org/jira/browse/FLINK-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15398727#comment-15398727
]
ASF GitHub Bot commented on FLINK-4269:
---
GitHub user aditivin opened a pull request:
GitHub user aditivin opened a pull request:
https://github.com/apache/flink/pull/2307
[FLINK-4269] Decrease log level in RuntimeMonitorHandler
@uce - I changed the log level to DEBUG in RuntimeMonitorHandler.
PS - This is my first contribution, please forgive any mistakes
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15398696#comment-15398696
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/1690
@shikhar Ok, sure no problem :)
---
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
Github user shikhar commented on the issue:
https://github.com/apache/flink/pull/1690
@tzulitai sorry I meant I won't be able to get to this change at all, so
anyone please feel free to take this up!
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15398684#comment-15398684
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user shikhar commented on the issue:
Github user shikhar closed the pull request at:
https://github.com/apache/flink/pull/1690
---
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
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15398683#comment-15398683
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user shikhar closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15398641#comment-15398641
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/1690
@shikhar Sure, please feel free to tag me for a review once you are done. I
think you'll need to manually close this PR yourself, you can close it when the
new PR is opened. Another option is to
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan reassigned FLINK-4094:
-
Assignee: ramkrishna.s.vasudevan
> Off heap memory deallocation might
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15398153#comment-15398153
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user shikhar commented on the issue:
Github user shikhar commented on the issue:
https://github.com/apache/flink/pull/1690
Thanks @tzulitai! I like your proposal, I'm afraid I won't be able to get
around to shaping up this PR though so might be best to start a new one (please
feel free to close).
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15398081#comment-15398081
]
Neelesh Srinivas Salian commented on FLINK-4278:
[~tedyu] any thoughts how this can be
Neelesh Srinivas Salian created FLINK-4278:
--
Summary: Unclosed FSDataOutputStream in multiple files in the
project
Key: FLINK-4278
URL: https://issues.apache.org/jira/browse/FLINK-4278
[
https://issues.apache.org/jira/browse/FLINK-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-4259.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 5d7e949.
> Unclosed FSDataOutputStream
[
https://issues.apache.org/jira/browse/FLINK-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397892#comment-15397892
]
ASF GitHub Bot commented on FLINK-4259:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2299
---
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
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397634#comment-15397634
]
ramkrishna.s.vasudevan commented on FLINK-4094:
---
Can I work on this? I saw the code - if
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4266:
Summary: Cassandra StateBackend (was: Cassandra Statebackend)
> Cassandra StateBackend
>
Chesnay Schepler created FLINK-4277:
---
Summary: TaskManagerConfigurationTest fails
Key: FLINK-4277
URL: https://issues.apache.org/jira/browse/FLINK-4277
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-4276:
---
Summary: TextInputFormatTest.testNestedFileRead fails on Windows OS
Key: FLINK-4276
URL: https://issues.apache.org/jira/browse/FLINK-4276
Project: Flink
Gyula Fora created FLINK-4275:
-
Summary: Generic Folding, Reducing and List states behave
differently from other state backends
Key: FLINK-4275
URL: https://issues.apache.org/jira/browse/FLINK-4275
Maximilian Michels created FLINK-4274:
-
Summary: Expose new JobClient in the DataSet/DataStream API
Key: FLINK-4274
URL: https://issues.apache.org/jira/browse/FLINK-4274
Project: Flink
Maximilian Michels created FLINK-4273:
-
Summary: Refactor JobClientActor to watch already submitted jobs
Key: FLINK-4273
URL: https://issues.apache.org/jira/browse/FLINK-4273
Project: Flink
Maximilian Michels created FLINK-4272:
-
Summary: Create a JobClient for job control and monitoring
Key: FLINK-4272
URL: https://issues.apache.org/jira/browse/FLINK-4272
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4272:
--
Priority: Minor (was: Major)
> Create a JobClient for job control and monitoring
>
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397346#comment-15397346
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2305
The CI failed because of japicmp, as we changed the public API.
Have no idea how to fix this...
---
If your project is set up for it, you can reply to this email and have your
reply
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2306
[FLINK-4270] [table] fix 'as' in front of join does not work
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397332#comment-15397332
]
ASF GitHub Bot commented on FLINK-4270:
---
GitHub user wuchong opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4270:
--
Assignee: Jark Wu
> 'as' in front of join does not work
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397273#comment-15397273
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/1690
What's the status of this PR? I think it is a good functionality to add.
@shikhar if you'd like to continue working on this, I'm happy to help shepherd
this PR for merging.
Some of my
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397229#comment-15397229
]
ASF GitHub Bot commented on FLINK-4271:
---
GitHub user wuchong opened a pull request:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2305
[FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and JoinedStreams to
set parallellism
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following
[
https://issues.apache.org/jira/browse/FLINK-4179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4179.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 185b5f6c6b91e4ae61ff77c7d22d1296153a320c.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2232
---
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
[
https://issues.apache.org/jira/browse/FLINK-4179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397221#comment-15397221
]
ASF GitHub Bot commented on FLINK-4179:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397187#comment-15397187
]
Jark Wu commented on FLINK-4271:
Yea, SingleOutputStreamOperator can set parallelism, uid, name and so on.
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397140#comment-15397140
]
Wenlong Lyu edited comment on FLINK-4271 at 7/28/16 7:05 AM:
-
I think the
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397140#comment-15397140
]
Wenlong Lyu commented on FLINK-4271:
I think the solution can be better. Not only the parallelism but
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397018#comment-15397018
]
ramkrishna.s.vasudevan commented on FLINK-3674:
---
[~aljoscha]
Any feed back/suggestions here?
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397004#comment-15397004
]
Jark Wu edited comment on FLINK-4271 at 7/28/16 6:17 AM:
-
The CoGroupStream will
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397004#comment-15397004
]
Jark Wu commented on FLINK-4271:
The CoGroupStream will construct the following graph.
{code}
source ->
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4271:
--
Assignee: Jark Wu
> There is no way to set parallelism of operators produced by CoGroupedStreams
>
48 matches
Mail list logo
