org.apache.flink.streaming.tests

Class NettyShuffleMemoryControlTestProgram

java.lang.Object

org.apache.flink.streaming.tests.NettyShuffleMemoryControlTestProgram

public class NettyShuffleMemoryControlTestProgram
extends Object

Test program to verify the direct memory consumption of Netty. Without zero-copy Netty may create more than one chunk, thus we may encounter OutOfDirectMemoryError if we limit the total direct memory to be less than two chunks. Instead, with zero-copy introduced in (https://issues.apache.org/jira/browse/FLINK-10742) one chunk will be enough and the exception will not occur.

Since Netty uses low level API of Unsafe to allocate direct buffer when using JDK8 and these memory will not be counted in direct memory, the test is only effective when JDK11 is used.

Constructor Summary

Constructors

Constructor and Description
NettyShuffleMemoryControlTestProgram()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NettyShuffleMemoryControlTestProgram

public NettyShuffleMemoryControlTestProgram()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception