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=15340447#comment-15340447
]
Anıl Chalil commented on FLINK-4094:
https://github.com/capacman/flinkoffheaptest
Above github
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=15340421#comment-15340421
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15340352#comment-15340352
]
Robert Thorman commented on FLINK-3319:
---
Below is a test case I wrote which passes with a new
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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=15340176#comment-15340176
]
Robert Thorman commented on FLINK-3320:
---
Seems like the same situation as the OR operator. I this
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15340166#comment-15340166
]
Robert Thorman commented on FLINK-3318:
---
So would the idea here be something like the following?
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15340166#comment-15340166
]
Robert Thorman edited comment on FLINK-3318 at 6/20/16 6:50 PM:
So would
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=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
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339851#comment-15339851
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339852#comment-15339852
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on a diff in the pull request:
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,
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339845#comment-15339845
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339834#comment-15339834
]
ASF GitHub Bot commented on FLINK-3626:
---
Github user zentol commented on a diff in the pull request:
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,
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
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=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
[
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=15339749#comment-15339749
]
Maximilian Michels commented on FLINK-3757:
---
Does the pull request improve the documentation?
>
[
https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339748#comment-15339748
]
ASF GitHub Bot commented on FLINK-3757:
---
GitHub user mxm opened a pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339744#comment-15339744
]
Maximilian Michels commented on FLINK-3757:
---
It does throw an exception if you previously added
[
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:
[
https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339724#comment-15339724
]
Konstantin Knauf commented on FLINK-3757:
-
Thank you for looking into it. I find the javadoc,
[
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 reopened FLINK-4095:
---
> 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 closed FLINK-4095.
-
Resolution: Duplicate
> Add configDir argument to shell scripts
>
[
https://issues.apache.org/jira/browse/FLINK-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339704#comment-15339704
]
ASF GitHub Bot commented on FLINK-4090:
---
Github user asfgit closed the pull request at:
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
[
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
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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)) {
[
https://issues.apache.org/jira/browse/FLINK-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-4089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339677#comment-15339677
]
Maximilian Michels commented on FLINK-4089:
---
Thank you for reporting!
> Ineffective null check
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339654#comment-15339654
]
Maximilian Michels commented on FLINK-4084:
---
Yes, please go ahead. I'll assign the issue to you.
[
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=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
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
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339627#comment-15339627
]
Andrea Sella commented on FLINK-4084:
-
If no one is already working on it, I am available to do it.
[
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=15339619#comment-15339619
]
Kostas Kloudas commented on FLINK-3752:
---
Should the documentation for that be under the link
[
https://issues.apache.org/jira/browse/FLINK-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339620#comment-15339620
]
Maximilian Michels commented on FLINK-4041:
---
This happens when a TaskManager registers during
[
https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339541#comment-15339541
]
Maximilian Michels commented on FLINK-3964:
---
Thanks for reporting! Have you tried {{bin/flink
[
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=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
[
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=15339492#comment-15339492
]
ASF GitHub Bot commented on FLINK-4078:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339490#comment-15339490
]
ASF GitHub Bot commented on FLINK-4083:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339478#comment-15339478
]
ASF GitHub Bot commented on FLINK-3395:
---
Github user rmetzger commented on a diff in the pull
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=15339463#comment-15339463
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339413#comment-15339413
]
Maximilian Michels commented on FLINK-3838:
---
Issue is fixed in common-cli 1.3.1
> CLI parameter
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339411#comment-15339411
]
Maximilian Michels commented on FLINK-3838:
---
A workaround is to use {{./flink run -- }} The
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=15339405#comment-15339405
]
Maximilian Michels commented on FLINK-3838:
---
Occurs whenever args are present before the jar
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=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=15339390#comment-15339390
]
ASF GitHub Bot commented on FLINK-4087:
---
Github user zentol closed the pull request at:
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
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=15339332#comment-15339332
]
ramkrishna.s.vasudevan commented on FLINK-4094:
---
So if the direct memory cannot be reused
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339331#comment-15339331
]
ramkrishna.s.vasudevan commented on FLINK-4094:
---
Offheap direct memory cannot be cleared
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339286#comment-15339286
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339280#comment-15339280
]
Maximilian Michels commented on FLINK-3838:
---
Seems like this only occurs when running on Yarn,
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
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
[
https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=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
1 - 100 of 126 matches
Mail list logo
