Ted Yu created FLINK-4096:
-
Summary: Nested FileOutputStream is not closed in JarFileCreator
Key: FLINK-4096
URL: https://issues.apache.org/jira/browse/FLINK-4096
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340447#comment-15340447
]
Anıl Chalil commented on FLINK-4094:
https://github.com/capacman/flinkoffheaptest
Abo
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2109
@kl0u I've updated my PR to use FilePathFilter abstract class. I had to
move it to flink-core to avoid circular dependency between packages.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340421#comment-15340421
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340352#comment-15340352
]
Robert Thorman commented on FLINK-3319:
---
Below is a test case I wrote which passes w
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340302#comment-15340302
]
ASF GitHub Bot commented on FLINK-4017:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2115
Thank you for your contribution, I will review this tomorrow :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Thorman reassigned FLINK-3319:
-
Assignee: Robert Thorman
> Add or operator to CEP's pattern API
> ---
[
https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340176#comment-15340176
]
Robert Thorman commented on FLINK-3320:
---
Seems like the same situation as the OR ope
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340166#comment-15340166
]
Robert Thorman commented on FLINK-3318:
---
So would the idea here be something like th
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340166#comment-15340166
]
Robert Thorman edited comment on FLINK-3318 at 6/20/16 6:50 PM:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2075
Thanks a lot for opening a pull request for this.
I like having virtual machines and deployment available for new projects,
so in general I like the idea a lot.
However, I wonder if the
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339853#comment-15339853
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2136#discussion_r67720631
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/functions/CoGroupFunction.py
---
@@ -25,13 +25,13 @@ def __init__(sel
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339851#comment-15339851
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on a diff in t
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2136
Very nice work, only had a few minor comments :)
---
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-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339852#comment-15339852
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2136#discussion_r67720542
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
---
@@ -572,6 +572,41 @@ def set_parallelism(self, pa
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339845#comment-15339845
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2136#discussion_r67720318
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/functions/CoGroupFunction.py
---
@@ -25,13 +25,13 @@ def __init__(sel
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339834#comment-15339834
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2136#discussion_r67719598
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
---
@@ -572,6 +572,41 @@ def set_parallelism(self, pa
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2131
The ManualExactlyOnceTest and ManualExactlyOnceWithStreamReshardingTest is
a bit buggy, fixing with a follow-up commit ...
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339810#comment-15339810
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on the issue
Github user knaufk commented on the issue:
https://github.com/apache/flink/pull/2138
What about:
Add this accumulator. Throws an exception if the accumulator already exists
in the *same* Task.
Note that the namespace of Accumulators is scoped to the Flink Job, and
adding
Github user mxm commented on the pull request:
https://github.com/apache/flink/commit/c8fed99e3e85a4d27c6134cfa3e07fb3a8e1da2a#commitcomment-17936226
In pom.xml:
In pom.xml on line 972:
It does work fine for most cases. However, there are rare race conditions
which render our
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2139
[FLINK-3838] Upgrade commons-cli to fix parsing of jar args
The jar arguments were not parsed correctly if options were
present. For example, in `./flink run file.jar -arg value` the
jar argumen
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339776#comment-15339776
]
ASF GitHub Bot commented on FLINK-3838:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339772#comment-15339772
]
ASF GitHub Bot commented on FLINK-3757:
---
Github user knaufk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3105.
-
Resolution: Fixed
Fix Version/s: 1.1.0
> Submission in per job YARN cluster mode re
[
https://issues.apache.org/jira/browse/FLINK-3105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reopened FLINK-3105:
---
> Submission in per job YARN cluster mode reuses properties file of long-lived
> session
Github user vijikarthi commented on the pull request:
https://github.com/apache/flink/commit/c8fed99e3e85a4d27c6134cfa3e07fb3a8e1da2a#commitcomment-17935989
In pom.xml:
In pom.xml on line 972:
This version (2.18.1) has some issues running scoped test case. For example
it does
[
https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339749#comment-15339749
]
Maximilian Michels commented on FLINK-3757:
---
Does the pull request improve the d
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2138
[FLINK-3757] clarify JavaDoc for addAccumulator method
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-3757
Alternatively you can r
[
https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339748#comment-15339748
]
ASF GitHub Bot commented on FLINK-3757:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339744#comment-15339744
]
Maximilian Michels commented on FLINK-3757:
---
It does throw an exception if you p
[
https://issues.apache.org/jira/browse/FLINK-3380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-3380.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Resolving for now.
> Unstable Test: Job
[
https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339724#comment-15339724
]
Konstantin Knauf commented on FLINK-3757:
-
Thank you for looking into it. I find t
[
https://issues.apache.org/jira/browse/FLINK-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4095.
-
Resolution: Fixed
Seems like custom config dirs are highly request now :) This duplicates
[
https://issues.apache.org/jira/browse/FLINK-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4095.
-
Resolution: Duplicate
> Add configDir argument to shell scripts
>
[
https://issues.apache.org/jira/browse/FLINK-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reopened FLINK-4095:
---
> Add configDir argument to shell scripts
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339704#comment-15339704
]
ASF GitHub Bot commented on FLINK-4090:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2132
---
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-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4090.
-
Resolution: Fixed
Fixed with f2e9c521aa4e0cbc14b71c561b8c5dd46201a45a
> Close of OutputSt
[
https://issues.apache.org/jira/browse/FLINK-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-4090:
-
Assignee: Maximilian Michels
> Close of OutputStream should be in finally clause
[
https://issues.apache.org/jira/browse/FLINK-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4090:
--
Fix Version/s: 1.1.0
> Close of OutputStream should be in finally clause in
> FlinkYarn
[
https://issues.apache.org/jira/browse/FLINK-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339688#comment-15339688
]
ASF GitHub Bot commented on FLINK-4090:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2132
Merging with a slight change to use the `Closeable` feature:
```java
try (final OutputStream out = new
FileOutputStream(propertiesFile)) {
properties.store
[
https://issues.apache.org/jira/browse/FLINK-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339679#comment-15339679
]
ASF GitHub Bot commented on FLINK-4090:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2132
Thank you for the pull request!
---
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 wish
[
https://issues.apache.org/jira/browse/FLINK-4089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339677#comment-15339677
]
Maximilian Michels commented on FLINK-4089:
---
Thank you for reporting!
> Ineffec
[
https://issues.apache.org/jira/browse/FLINK-4089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4089.
-
Resolution: Fixed
Assignee: Maximilian Michels
Fix Version/s: 1.0.4
master
[
https://issues.apache.org/jira/browse/FLINK-4089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4089:
--
Fix Version/s: 1.1.0
> Ineffective null check in YarnClusterClient#getApplicationStatus(
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339654#comment-15339654
]
Maximilian Michels commented on FLINK-4084:
---
Yes, please go ahead. I'll assign t
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4084:
--
Assignee: Andrea Sella
> Add configDir parameter to CliFrontend and flink shell script
>
[
https://issues.apache.org/jira/browse/FLINK-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339637#comment-15339637
]
ASF GitHub Bot commented on FLINK-4041:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-4041:
-
Assignee: Maximilian Michels
> Failure while asking ResourceManager for RegisterR
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2137
[FLINK-4041] reduce log level for JobManager->ResourceManager timeouts
These timeouts can be recovered and don't have to be logged as error with
an Exception.
You can merge this pull request into a Git
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339627#comment-15339627
]
Andrea Sella commented on FLINK-4084:
-
If no one is already working on it, I am availa
[
https://issues.apache.org/jira/browse/FLINK-3752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-3752:
-
Assignee: Kostas Kloudas
> Add Per-Kafka-Partition Watermark Generation to the docs
> ---
[
https://issues.apache.org/jira/browse/FLINK-3752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339619#comment-15339619
]
Kostas Kloudas commented on FLINK-3752:
---
Should the documentation for that be under
[
https://issues.apache.org/jira/browse/FLINK-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339620#comment-15339620
]
Maximilian Michels commented on FLINK-4041:
---
This happens when a TaskManager reg
[
https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339541#comment-15339541
]
Maximilian Michels commented on FLINK-3964:
---
Thanks for reporting! Have you trie
[
https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4078.
--
Resolution: Fixed
Fixed in 78d3c61 (master).
> Use ClosureCleaner for CoGroup where
> -
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339498#comment-15339498
]
ASF GitHub Bot commented on FLINK-3626:
---
GitHub user GEOFBOT opened a pull request:
GitHub user GEOFBOT opened a pull request:
https://github.com/apache/flink/pull/2136
[FLINK-3626] [py] zipWithIndex in Python API
Implement zip_with_index in the Python API along with relevant tests and
documentation.
You can merge this pull request into a Git repository by running
[
https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4083.
--
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in 6a1144e (master).
> Use ClosureCleaner for Join
[
https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339492#comment-15339492
]
ASF GitHub Bot commented on FLINK-4078:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2116
---
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-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339490#comment-15339490
]
ASF GitHub Bot commented on FLINK-4083:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2117
---
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-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339488#comment-15339488
]
ASF GitHub Bot commented on FLINK-3395:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2092
I quickly looked through the changed files. I think the changes are okay.
However, it seems that the the pull request doesn't build (and merge with
master). I've started addressing those issues a
[
https://issues.apache.org/jira/browse/FLINK-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339478#comment-15339478
]
ASF GitHub Bot commented on FLINK-3395:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2092#discussion_r67688097
--- Diff: flink-scala-shell/pom.xml ---
@@ -70,27 +71,19 @@ under the License.
scala-library
${scala.version}
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2109
@kl0u Thank you for your comment. I'll update my PR.
Do you have any thoughts regarding questions raised by @zentol ?
Specifically how to provide include/exclude patterns?
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339463#comment-15339463
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339413#comment-15339413
]
Maximilian Michels commented on FLINK-3838:
---
Issue is fixed in common-cli 1.3.1
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339411#comment-15339411
]
Maximilian Michels commented on FLINK-3838:
---
A workaround is to use {{./flink ru
Ufuk Celebi created FLINK-4095:
--
Summary: Add configDir argument to shell scripts
Key: FLINK-4095
URL: https://issues.apache.org/jira/browse/FLINK-4095
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339405#comment-15339405
]
Maximilian Michels commented on FLINK-3838:
---
Occurs whenever args are present be
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339394#comment-15339394
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user f1yegor commented on the issue:
Github user f1yegor commented on the issue:
https://github.com/apache/flink/pull/1771
Could somebody point to a documentation how we could manage state (pool of
connections) when Sink works inside single JVM.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339389#comment-15339389
]
ASF GitHub Bot commented on FLINK-4087:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339390#comment-15339390
]
ASF GitHub Bot commented on FLINK-4087:
---
Github user zentol closed the pull request
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/2127
---
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
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2127
closing this for now as there are a few PowerMock issues.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339332#comment-15339332
]
ramkrishna.s.vasudevan commented on FLINK-4094:
---
So if the direct memory can
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339331#comment-15339331
]
ramkrishna.s.vasudevan commented on FLINK-4094:
---
Offheap direct memory canno
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339307#comment-15339307
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2109
Recently we added the FilePathFilter abstract class that is now used by
some user-facing functions for exactly the same reason. I would suggest that
this abstraction is also used by this PR, so that we
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4094:
-
Summary: Off heap memory deallocation might not properly work (was: Off
heap memory deallocation
Till Rohrmann created FLINK-4094:
Summary: Off heap memory deallocation might not work properly
Key: FLINK-4094
URL: https://issues.apache.org/jira/browse/FLINK-4094
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339286#comment-15339286
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/1771
You are correct that every CassandraSink instance opens a separate
connection to the cluster. I don't see how we could avoid this without using
Singletons, which should be avoided.
---
If your proje
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339280#comment-15339280
]
Maximilian Michels commented on FLINK-3838:
---
Seems like this only occurs when ru
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2135
[hotfix] [metrics] Prevent log flooding from collisions
This is a small change that reduces clutter due to naming collisions when
registering metrics. It now only logs stacktraces when the logging le
[
https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339263#comment-15339263
]
ASF GitHub Bot commented on FLINK-4091:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15339262#comment-15339262
]
ASF GitHub Bot commented on FLINK-4091:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2133
*now
---
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
1 - 100 of 126 matches
Mail list logo