[
https://issues.apache.org/jira/browse/FLINK-22522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-22522.
---------------------------
Resolution: Fixed
Fixed in
- master: bf40fa5b8cd5b3a8876f37ab4aa7bf06e8b9f666
- release-1.13: a299ae28802c147ceee656e0bccd8a9656a24b1e
> BytesHashMap has many verbose logs
> ----------------------------------
>
> Key: FLINK-22522
> URL: https://issues.apache.org/jira/browse/FLINK-22522
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 1.13.0
> Reporter: Jark Wu
> Assignee: Jark Wu
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.14.0, 1.13.1
>
>
> I ran a query which contains operators using BytesHashMap, and the logs file
> contain many following logs
> {code}
> 2021-04-29 14:00:47,420 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 758, 24838144 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:48,322 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 672, 22020096 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:48,345 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 764, 25034752 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:49,611 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 634, 20774912 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:49,703 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 757, 24805376 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:50,582 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 658, 21561344 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:50,621 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 762, 24969216 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:51,837 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 636, 20840448 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:51,862 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 758, 24838144 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:52,836 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 649, 21266432 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:52,899 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 761, 24936448 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:54,064 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 617, 20217856 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:54,148 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 754, 24707072 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:54,871 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 673, 22052864 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:54,959 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 765, 25067520 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:55,912 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 641, 21004288 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:56,017 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 761, 24936448 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:56,924 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 639, 20938752 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:57,047 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 759, 24870912 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:57,727 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 666, 21823488 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:57,768 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 764, 25034752 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:58,541 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 665, 21790720 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:58,589 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 766, 25100288 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:59,373 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 657, 21528576 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:00:59,422 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 764, 25034752 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:01:00,201 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 673, 22052864 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:01:00,248 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 766, 25100288 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:01:01,015 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 665, 21790720 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:01:01,080 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 764, 25034752 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:01:01,626 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 689, 22577152 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:01:01,698 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 767, 25133056 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:01:02,017 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 721, 23625728 in bytes, init
> allocating 32 for bucket area.
> 2021-04-29 14:01:02,108 INFO
> org.apache.flink.table.runtime.util.collections.binary.BytesMap [] - reset
> BytesHashMap with record memory segments 773, 25329664 in bytes, init
> allocating 32 for bucket area.
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
