[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16249767#comment-16249767
]
ASF GitHub Bot commented on FLINK-7845:
---------------------------------------
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5007
[FLINK-7845] Make NettyMessage public
This a walkaround strange javaassist bug. The issue should go away
once we upgrade netty dependency.
Please check the [ticket](https://issues.apache.org/jira/browse/FLINK-7845)
for more information.
This change was manually tested on this example:
https://github.com/okkam-it/flink-memory-leak
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (yes / **no**)
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (yes / **no**)
- The serializers: (yes / **no** / don't know)
- The runtime per-record code paths (performance sensitive): (yes /
**no** / don't know)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: (yes / **no** / don't know)
- The S3 file system connector: (yes / **no** / don't know)
## Documentation
- Does this pull request introduce a new feature? (yes / **no**)
- If yes, how is the feature documented? (**not applicable** / docs /
JavaDocs / not documented)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pnowojski/flink f7845
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5007.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #5007
----
commit 99b88881bd240e16f6c461893f2cc93a0e5e3db3
Author: Piotr Nowojski <[email protected]>
Date: 2017-11-13T15:51:18Z
[FLINK-7845] Make NettyMessage public
This a walkaround strange javaassist bug. The issue should go away
once we upgrade netty dependency.
Please check the ticket for more information.
----
> Netty Exception when submitting batch job repeatedly
> ----------------------------------------------------
>
> Key: FLINK-7845
> URL: https://issues.apache.org/jira/browse/FLINK-7845
> Project: Flink
> Issue Type: Bug
> Components: Core, Network
> Affects Versions: 1.3.2
> Reporter: Flavio Pompermaier
> Assignee: Piotr Nowojski
> Priority: Blocker
> Fix For: 1.4.0
>
> Attachments: Screen Shot 2017-11-13 at 14.54.38.png
>
>
> We had some problems with Flink and Netty so we wrote a small unit test to
> reproduce the memory issues we have in production. It happens that we have to
> restart the Flink cluster because the memory is always increasing from job to
> job.
> The github project is https://github.com/okkam-it/flink-memory-leak and the
> JUnit test is contained in the MemoryLeakTest class (within src/main/test).
> I don't know if this is the root of our problems but at some point, usually
> around the 28th loop, the job fails with the following exception (actually we
> never faced that in production but maybe is related to the memory issue
> somehow...):
> {code:java}
> Caused by: java.lang.IllegalAccessError:
> org/apache/flink/runtime/io/network/netty/NettyMessage
> at
> io.netty.util.internal.__matchers__.org.apache.flink.runtime.io.network.netty.NettyMessageMatcher.match(NoOpTypeParameterMatcher.java)
> at
> io.netty.channel.SimpleChannelInboundHandler.acceptInboundMessage(SimpleChannelInboundHandler.java:95)
> at
> io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:102)
> ... 16 more
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
