Flame Graph
Reset Zoom
Search
all (6,802 samples, 100.00%)
all
/usr/lib64/libstdc++.so.6.0.24 (1,317 samples, 19.36%)
/usr/lib64/libstdc++.so.6.0.24
rocksdb::ThreadPoolImpl::Impl::BGThreadWrapper(void*) (1,317 samples, 19.36%)
rocksdb::ThreadPoolImpl::Impl:..
rocksdb::ThreadPoolImpl::Impl::BGThread(unsigned long) (1,317 samples, 19.36%)
rocksdb::ThreadPoolImpl::Impl:..
rocksdb::DBImpl::BGWorkCompaction(void*) (1,206 samples, 17.73%)
rocksdb::DBImpl::BGWorkComp..
rocksdb::DBImpl::BackgroundCallCompaction(rocksdb::DBImpl::PrepickedCompaction*, rocksdb::Env::Priority) (1,206 samples, 17.73%)
rocksdb::DBImpl::Background..
rocksdb::DBImpl::BackgroundCompaction(bool*, rocksdb::JobContext*, rocksdb::LogBuffer*, rocksdb::DBImpl::PrepickedCompaction*) (1,204 samples, 17.70%)
rocksdb::DBImpl::Background..
rocksdb::CompactionJob::Run() (1,204 samples, 17.70%)
rocksdb::CompactionJob::Run()
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (5 samples, 0.07%)
rocksdb::TableCache::NewIterator(rocksdb::ReadOptions const&, rocksdb::EnvOptions const&, rocksdb::InternalKeyComparator const&, rocksdb::FileMetaData const&, rocksdb::RangeDelAggregator*, rocksdb::SliceTransform const*, rocksdb::TableReader**, rocksdb::HistogramImpl*, bool, rocksdb::Arena*, bool, int) (5 samples, 0.07%)
rocksdb::TableCache::FindTable(rocksdb::EnvOptions const&, rocksdb::InternalKeyComparator const&, rocksdb::FileDescriptor const&, rocksdb::Cache::Handle**, rocksdb::SliceTransform const*, bool, bool, rocksdb::HistogramImpl*, bool, int, bool) (5 samples, 0.07%)
rocksdb::TableCache::GetTableReader(rocksdb::EnvOptions const&, rocksdb::InternalKeyComparator const&, rocksdb::FileDescriptor const&, bool, unsigned long, bool, rocksdb::HistogramImpl*, std::unique_ptr<rocksdb::TableReader, std::default_delete<rocksdb::TableReader> >*, rocksdb::SliceTransform const*, bool, int, bool, bool) (5 samples, 0.07%)
rocksdb::BlockBasedTableFactory::NewTableReader(rocksdb::TableReaderOptions const&, std::unique_ptr<rocksdb::RandomAccessFileReader, std::default_delete<rocksdb::RandomAccessFileReader> >&&, unsigned long, std::unique_ptr<rocksdb::TableReader, std::default_delete<rocksdb::TableReader> >*, bool) const (5 samples, 0.07%)
rocksdb::BlockBasedTable::Open(rocksdb::ImmutableCFOptions const&, rocksdb::EnvOptions const&, rocksdb::BlockBasedTableOptions const&, rocksdb::InternalKeyComparator const&, std::unique_ptr<rocksdb::RandomAccessFileReader, std::default_delete<rocksdb::RandomAccessFileReader> >&&, unsigned long, std::unique_ptr<rocksdb::TableReader, std::default_delete<rocksdb::TableReader> >*, rocksdb::SliceTransform const*, bool, bool, int, bool, unsigned long, rocksdb::TailPrefetchStats*) (5 samples, 0.07%)
rocksdb::BlockBasedTable::NewIndexIterator(rocksdb::ReadOptions const&, bool, rocksdb::IndexBlockIter*, rocksdb::BlockBasedTable::CachableEntry<rocksdb::BlockBasedTable::IndexReader>*, rocksdb::GetContext*) (5 samples, 0.07%)
rocksdb::BlockBasedTable::CreateIndexReader(rocksdb::FilePrefetchBuffer*, rocksdb::BlockBasedTable::IndexReader**, rocksdb::InternalIteratorBase<rocksdb::Slice>*, int) (4 samples, 0.06%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (4 samples, 0.06%)
rocksdb::BlockFetcher::ReadBlockContents() (4 samples, 0.06%)
rocksdb::UncompressBlockContents(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (4 samples, 0.06%)
rocksdb::UncompressBlockContentsForCompressionType(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (4 samples, 0.06%)
snappy::RawUncompress(char const*, unsigned long, char*) (4 samples, 0.06%)
snappy::RawUncompress(snappy::Source*, char*) (4 samples, 0.06%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (4 samples, 0.06%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (4 samples, 0.06%)
void snappy::SnappyDecompressor::DecompressAllTags<snappy::SnappyArrayWriter>(snappy::SnappyArrayWriter*) (4 samples, 0.06%)
snappy::SnappyArrayWriter::AppendFromSelf(unsigned long, unsigned long) (4 samples, 0.06%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
rocksdb::CompactionJob::ProcessKeyValueCompaction(rocksdb::CompactionJob::SubcompactionState*) (1,196 samples, 17.58%)
rocksdb::CompactionJob::Pro..
rocksdb::BlockBasedTableBuilder::Add(rocksdb::Slice const&, rocksdb::Slice const&) (692 samples, 10.17%)
rocksdb::BlockB..
rocksdb::BlockBasedTableBuilder::Flush() (651 samples, 9.57%)
rocksdb::Block..
rocksdb::BlockBasedTableBuilder::WriteBlock(rocksdb::BlockBuilder*, rocksdb::BlockHandle*, bool) (650 samples, 9.56%)
rocksdb::Block..
rocksdb::BlockBasedTableBuilder::WriteBlock(rocksdb::Slice const&, rocksdb::BlockHandle*, bool) (648 samples, 9.53%)
rocksdb::Block..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (36 samples, 0.53%)
rocksdb::BlockBasedTableBuilder::WriteRawBlock(rocksdb::Slice const&, rocksdb::CompressionType, rocksdb::BlockHandle*, bool) (9 samples, 0.13%)
__memcpy_sse2_unaligned_erms (2 samples, 0.03%)
rocksdb::WritableFileWriter::Append(rocksdb::Slice const&) (3 samples, 0.04%)
rocksdb::CompressBlock(rocksdb::Slice const&, rocksdb::CompressionContext const&, rocksdb::CompressionType*, unsigned int, std::string*) (600 samples, 8.82%)
rocksdb::Com..
snappy::RawCompress(char const*, unsigned long, char*, unsigned long*) (599 samples, 8.81%)
snappy::RawC..
snappy::ByteArraySource::ByteArraySource(char const*, unsigned long) (2 samples, 0.03%)
snappy::Source::Source() (2 samples, 0.03%)
snappy::Compress(snappy::Source*, snappy::Sink*) (593 samples, 8.72%)
snappy::Comp..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (27 samples, 0.40%)
__memcmp_avx2_movbe (12 samples, 0.18%)
__memset_avx2_erms (8 samples, 0.12%)
snappy::internal::CompressFragment(char const*, unsigned long, char*, unsigned short*, int) (541 samples, 7.95%)
snappy::int..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (307 samples, 4.51%)
/mnt/..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (110 samples, 1.62%)
snappy::LittleEndian::Store32(void*, unsigned int) (5 samples, 0.07%)
snappy::Bits::FindLSBSetNonZero64(unsigned long) (6 samples, 0.09%)
snappy::LittleEndian::IsLittleEndian() (3 samples, 0.04%)
snappy::LittleEndian::Store32(void*, unsigned int) (2 samples, 0.03%)
std::pair<unsigned long, bool>::pair(unsigned long const&, bool const&) (9 samples, 0.13%)
__memcpy_sse2_unaligned_erms (2 samples, 0.03%)
snappy::LittleEndian::IsLittleEndian() (3 samples, 0.04%)
snappy::LittleEndian::IsLittleEndian() [clone .plt] (8 samples, 0.12%)
snappy::internal::WorkingMemory::GetHashTable(unsigned long, int*) (2 samples, 0.03%)
rocksdb::BlockBuilder::Add(rocksdb::Slice const&, rocksdb::Slice const&, rocksdb::Slice const*) (10 samples, 0.15%)
rocksdb::NotifyCollectTableCollectorsOnAdd(rocksdb::Slice const&, rocksdb::Slice const&, unsigned long, std::vector<std::unique_ptr<rocksdb::IntTblPropCollector, std::default_delete<rocksdb::IntTblPropCollector> >, std::allocator<std::unique_ptr<rocksdb::IntTblPropCollector, std::default_delete<rocksdb::IntTblPropCollector> > > > const&, rocksdb::Logger*) (4 samples, 0.06%)
rocksdb::ShortenedIndexBuilder::AddIndexEntry(std::string*, rocksdb::Slice const*, rocksdb::BlockHandle const&) (17 samples, 0.25%)
__libc_free (3 samples, 0.04%)
rocksdb::BlockBuilder::Add(rocksdb::Slice const&, rocksdb::Slice const&, rocksdb::Slice const*) (3 samples, 0.04%)
rocksdb::InternalKeyComparator::FindShortestSeparator(std::string*, rocksdb::Slice const&) const (4 samples, 0.06%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
rocksdb::BlockBuilder::Add(rocksdb::Slice const&, rocksdb::Slice const&, rocksdb::Slice const*) (2 samples, 0.03%)
rocksdb::CompactionIterator::Next() (471 samples, 6.92%)
rocksdb::..
rocksdb::CompactionIterator::NextFromInput() (82 samples, 1.21%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (2 samples, 0.03%)
__memcmp_avx2_movbe (3 samples, 0.04%)
rocksdb::MergingIterator::Next() (66 samples, 0.97%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (62 samples, 0.91%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::FindKeyForward() (57 samples, 0.84%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::InitDataBlock() (55 samples, 0.81%)
rocksdb::DataBlockIter* rocksdb::BlockBasedTable::NewDataBlockIterator<rocksdb::DataBlockIter>(rocksdb::BlockBasedTable::Rep*, rocksdb::ReadOptions const&, rocksdb::BlockHandle const&, rocksdb::DataBlockIter*, bool, bool, bool, rocksdb::GetContext*, rocksdb::Status, rocksdb::FilePrefetchBuffer*) (55 samples, 0.81%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (48 samples, 0.71%)
rocksdb::BlockFetcher::ReadBlockContents() (46 samples, 0.68%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (7 samples, 0.10%)
rocksdb::RandomAccessFileReader::Read(unsigned long, unsigned long, rocksdb::Slice*, char*) const (4 samples, 0.06%)
/usr/lib64/libpthread-2.26.so (3 samples, 0.04%)
rocksdb::UncompressBlockContents(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (34 samples, 0.50%)
rocksdb::UncompressBlockContentsForCompressionType(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (34 samples, 0.50%)
snappy::RawUncompress(char const*, unsigned long, char*) (34 samples, 0.50%)
snappy::RawUncompress(snappy::Source*, char*) (34 samples, 0.50%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (34 samples, 0.50%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (33 samples, 0.49%)
snappy::LittleEndian::Load32(void const*) (2 samples, 0.03%)
void snappy::SnappyDecompressor::DecompressAllTags<snappy::SnappyArrayWriter>(snappy::SnappyArrayWriter*) (30 samples, 0.44%)
snappy::SnappyArrayWriter::AppendFromSelf(unsigned long, unsigned long) (15 samples, 0.22%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (12 samples, 0.18%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (4 samples, 0.06%)
__memcpy_sse2_unaligned (2 samples, 0.03%)
snappy::SnappyArrayWriter::TryFastAppend(char const*, unsigned long, unsigned long) (4 samples, 0.06%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (2 samples, 0.03%)
rocksdb::BlockBasedTable::MaybeLoadDataBlockToCache(rocksdb::FilePrefetchBuffer*, rocksdb::BlockBasedTable::Rep*, rocksdb::ReadOptions const&, rocksdb::BlockHandle const&, rocksdb::Slice, rocksdb::BlockBasedTable::CachableEntry<rocksdb::Block>*, bool, rocksdb::GetContext*) (3 samples, 0.04%)
rocksdb::BlockBasedTable::GetDataBlockFromCache(rocksdb::Slice const&, rocksdb::Slice const&, rocksdb::Cache*, rocksdb::Cache*, rocksdb::ImmutableCFOptions const&, rocksdb::ReadOptions const&, rocksdb::BlockBasedTable::CachableEntry<rocksdb::Block>*, unsigned int, rocksdb::Slice const&, unsigned long, bool, rocksdb::GetContext*) (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
rocksdb::LRUCacheShard::Lookup(rocksdb::Slice const&, unsigned int) (3 samples, 0.04%)
rocksdb::LRUHandleTable::Lookup(rocksdb::Slice const&, unsigned int) (2 samples, 0.03%)
rocksdb::LRUHandleTable::FindPointer(rocksdb::Slice const&, unsigned int) (2 samples, 0.03%)
rocksdb::ShardedCache::Insert(rocksdb::Slice const&, void*, unsigned long, void (*)(rocksdb::Slice const&, void*), rocksdb::Cache::Handle**, rocksdb::Cache::Priority) (4 samples, 0.06%)
rocksdb::LRUCacheShard::Insert(rocksdb::Slice const&, unsigned int, void*, unsigned long, void (*)(rocksdb::Slice const&, void*), rocksdb::Cache::Handle**, rocksdb::Cache::Priority) (4 samples, 0.06%)
rocksdb::LRUHandleTable::Insert(rocksdb::LRUHandle*) (4 samples, 0.06%)
rocksdb::LRUHandleTable::FindPointer(rocksdb::Slice const&, unsigned int) (3 samples, 0.04%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::Next() (3 samples, 0.04%)
rocksdb::DataBlockIter::Next() (3 samples, 0.04%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::FindKeyForward() (3 samples, 0.04%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::InitDataBlock() (3 samples, 0.04%)
rocksdb::DataBlockIter* rocksdb::BlockBasedTable::NewDataBlockIterator<rocksdb::DataBlockIter>(rocksdb::BlockBasedTable::Rep*, rocksdb::ReadOptions const&, rocksdb::BlockHandle const&, rocksdb::DataBlockIter*, bool, bool, bool, rocksdb::GetContext*, rocksdb::Status, rocksdb::FilePrefetchBuffer*) (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (2 samples, 0.03%)
rocksdb::BlockFetcher::ReadBlockContents() (2 samples, 0.03%)
rocksdb::MergingIterator::Next() (385 samples, 5.66%)
rocksdb..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (242 samples, 3.56%)
/mn..
__libc_free (2 samples, 0.03%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::FindKeyForward() (231 samples, 3.40%)
roc..
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::InitDataBlock() (225 samples, 3.31%)
roc..
rocksdb::DataBlockIter* rocksdb::BlockBasedTable::NewDataBlockIterator<rocksdb::DataBlockIter>(rocksdb::BlockBasedTable::Rep*, rocksdb::ReadOptions const&, rocksdb::BlockHandle const&, rocksdb::DataBlockIter*, bool, bool, bool, rocksdb::GetContext*, rocksdb::Status, rocksdb::FilePrefetchBuffer*) (224 samples, 3.29%)
roc..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (215 samples, 3.16%)
/mn..
rocksdb::BlockFetcher::ReadBlockContents() (214 samples, 3.15%)
roc..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (10 samples, 0.15%)
rocksdb::RandomAccessFileReader::Read(unsigned long, unsigned long, rocksdb::Slice*, char*) const (27 samples, 0.40%)
/usr/lib64/libpthread-2.26.so (25 samples, 0.37%)
entry_SYSCALL_64_after_hwframe (15 samples, 0.22%)
do_syscall_64 (15 samples, 0.22%)
sys_pread64 (10 samples, 0.15%)
__fget_light (2 samples, 0.03%)
__fget (2 samples, 0.03%)
vfs_read (8 samples, 0.12%)
__vfs_read (8 samples, 0.12%)
xfs_file_read_iter?[xfs] (8 samples, 0.12%)
xfs_file_buffered_aio_read?[xfs] (7 samples, 0.10%)
generic_file_read_iter (7 samples, 0.10%)
copy_page_to_iter (3 samples, 0.04%)
copyout (3 samples, 0.04%)
copy_user_enhanced_fast_string (3 samples, 0.04%)
pagecache_get_page (3 samples, 0.04%)
find_get_entry (3 samples, 0.04%)
radix_tree_lookup_slot (2 samples, 0.03%)
__radix_tree_lookup (2 samples, 0.03%)
rocksdb::UncompressBlockContents(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (174 samples, 2.56%)
ro..
rocksdb::UncompressBlockContentsForCompressionType(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (173 samples, 2.54%)
ro..
snappy::RawUncompress(char const*, unsigned long, char*) (170 samples, 2.50%)
sn..
snappy::RawUncompress(snappy::Source*, char*) (170 samples, 2.50%)
sn..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (170 samples, 2.50%)
/m..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (170 samples, 2.50%)
/m..
snappy::LittleEndian::Load32(void const*) (5 samples, 0.07%)
void snappy::SnappyDecompressor::DecompressAllTags<snappy::SnappyArrayWriter>(snappy::SnappyArrayWriter*) (160 samples, 2.35%)
v..
snappy::LittleEndian::Load32(void const*) (3 samples, 0.04%)
snappy::LittleEndian::ToHost32(unsigned int) (2 samples, 0.03%)
snappy::SnappyArrayWriter::AppendFromSelf(unsigned long, unsigned long) (105 samples, 1.54%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (89 samples, 1.31%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (14 samples, 0.21%)
__memcpy_sse2_unaligned (5 samples, 0.07%)
__memcpy_sse2_unaligned_erms (25 samples, 0.37%)
snappy::SnappyArrayWriter::Produced() const (2 samples, 0.03%)
snappy::SnappyArrayWriter::Produced() const (3 samples, 0.04%)
snappy::SnappyArrayWriter::TryFastAppend(char const*, unsigned long, unsigned long) (12 samples, 0.18%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (6 samples, 0.09%)
snappy::Varint::Parse32WithLimit(char const*, char const*, unsigned int*) (2 samples, 0.03%)
rocksdb::ShardedCache::Insert(rocksdb::Slice const&, void*, unsigned long, void (*)(rocksdb::Slice const&, void*), rocksdb::Cache::Handle**, rocksdb::Cache::Priority) (7 samples, 0.10%)
rocksdb::LRUCacheShard::Insert(rocksdb::Slice const&, unsigned int, void*, unsigned long, void (*)(rocksdb::Slice const&, void*), rocksdb::Cache::Handle**, rocksdb::Cache::Priority) (5 samples, 0.07%)
rocksdb::LRUHandleTable::Insert(rocksdb::LRUHandle*) (4 samples, 0.06%)
rocksdb::LRUHandleTable::FindPointer(rocksdb::Slice const&, unsigned int) (4 samples, 0.06%)
rocksdb::LRUCacheShard::Release(rocksdb::Cache::Handle*, bool) (2 samples, 0.03%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::Next() (4 samples, 0.06%)
__memcpy_sse2_unaligned_erms (2 samples, 0.03%)
rocksdb::GetVarint32PtrFallback(char const*, char const*, unsigned int*) (2 samples, 0.03%)
__memcmp_avx2_movbe (3 samples, 0.04%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::FindKeyForward() (130 samples, 1.91%)
r..
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::InitDataBlock() (126 samples, 1.85%)
r..
rocksdb::DataBlockIter* rocksdb::BlockBasedTable::NewDataBlockIterator<rocksdb::DataBlockIter>(rocksdb::BlockBasedTable::Rep*, rocksdb::ReadOptions const&, rocksdb::BlockHandle const&, rocksdb::DataBlockIter*, bool, bool, bool, rocksdb::GetContext*, rocksdb::Status, rocksdb::FilePrefetchBuffer*) (124 samples, 1.82%)
r..
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (115 samples, 1.69%)
rocksdb::BlockFetcher::ReadBlockContents() (115 samples, 1.69%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (5 samples, 0.07%)
rocksdb::RandomAccessFileReader::Read(unsigned long, unsigned long, rocksdb::Slice*, char*) const (13 samples, 0.19%)
/usr/lib64/libpthread-2.26.so (12 samples, 0.18%)
entry_SYSCALL_64_after_hwframe (8 samples, 0.12%)
do_syscall_64 (8 samples, 0.12%)
sys_pread64 (6 samples, 0.09%)
vfs_read (5 samples, 0.07%)
__vfs_read (5 samples, 0.07%)
xfs_file_read_iter?[xfs] (5 samples, 0.07%)
xfs_file_buffered_aio_read?[xfs] (5 samples, 0.07%)
generic_file_read_iter (5 samples, 0.07%)
copy_page_to_iter (3 samples, 0.04%)
copyout (3 samples, 0.04%)
copy_user_enhanced_fast_string (3 samples, 0.04%)
pagecache_get_page (2 samples, 0.03%)
find_get_entry (2 samples, 0.03%)
rocksdb::UncompressBlockContents(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (97 samples, 1.43%)
rocksdb::UncompressBlockContentsForCompressionType(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (97 samples, 1.43%)
snappy::RawUncompress(char const*, unsigned long, char*) (97 samples, 1.43%)
snappy::RawUncompress(snappy::Source*, char*) (97 samples, 1.43%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (97 samples, 1.43%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (96 samples, 1.41%)
void snappy::SnappyDecompressor::DecompressAllTags<snappy::SnappyArrayWriter>(snappy::SnappyArrayWriter*) (94 samples, 1.38%)
snappy::LittleEndian::Load32(void const*) (3 samples, 0.04%)
snappy::LittleEndian::ToHost32(unsigned int) (2 samples, 0.03%)
snappy::SnappyArrayWriter::AppendFromSelf(unsigned long, unsigned long) (56 samples, 0.82%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (43 samples, 0.63%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (9 samples, 0.13%)
__memcpy_sse2_unaligned (2 samples, 0.03%)
__memcpy_sse2_unaligned_erms (11 samples, 0.16%)
memcpy@plt (2 samples, 0.03%)
snappy::MaxCompressedLength(unsigned long) (2 samples, 0.03%)
snappy::SnappyArrayWriter::TryFastAppend(char const*, unsigned long, unsigned long) (5 samples, 0.07%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (4 samples, 0.06%)
rocksdb::BlockBasedTable::MaybeLoadDataBlockToCache(rocksdb::FilePrefetchBuffer*, rocksdb::BlockBasedTable::Rep*, rocksdb::ReadOptions const&, rocksdb::BlockHandle const&, rocksdb::Slice, rocksdb::BlockBasedTable::CachableEntry<rocksdb::Block>*, bool, rocksdb::GetContext*) (4 samples, 0.06%)
rocksdb::BlockBasedTable::GetDataBlockFromCache(rocksdb::Slice const&, rocksdb::Slice const&, rocksdb::Cache*, rocksdb::Cache*, rocksdb::ImmutableCFOptions const&, rocksdb::ReadOptions const&, rocksdb::BlockBasedTable::CachableEntry<rocksdb::Block>*, unsigned int, rocksdb::Slice const&, unsigned long, bool, rocksdb::GetContext*) (4 samples, 0.06%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
rocksdb::LRUCacheShard::Lookup(rocksdb::Slice const&, unsigned int) (2 samples, 0.03%)
rocksdb::ShardedCache::Insert(rocksdb::Slice const&, void*, unsigned long, void (*)(rocksdb::Slice const&, void*), rocksdb::Cache::Handle**, rocksdb::Cache::Priority) (4 samples, 0.06%)
rocksdb::LRUCacheShard::Insert(rocksdb::Slice const&, unsigned int, void*, unsigned long, void (*)(rocksdb::Slice const&, void*), rocksdb::Cache::Handle**, rocksdb::Cache::Priority) (4 samples, 0.06%)
rocksdb::LRUHandleTable::Insert(rocksdb::LRUHandle*) (3 samples, 0.04%)
rocksdb::LRUHandleTable::FindPointer(rocksdb::Slice const&, unsigned int) (3 samples, 0.04%)
rocksdb::DataBlockIter::SeekToFirst() (2 samples, 0.03%)
rocksdb::BlockBasedTableIterator<rocksdb::DataBlockIter, rocksdb::Slice>::Next() (4 samples, 0.06%)
rocksdb::DataBlockIter::Next() (2 samples, 0.03%)
rocksdb::CompactionIterator::PrepareOutput() (2 samples, 0.03%)
rocksdb::CompactionJob::FinishCompactionOutputFile(rocksdb::Status const&, rocksdb::CompactionJob::SubcompactionState*, rocksdb::RangeDelAggregator*, CompactionIterationStats*, rocksdb::Slice const*) (15 samples, 0.22%)
rocksdb::BlockBasedTableBuilder::Finish() (12 samples, 0.18%)
rocksdb::BlockBasedTableBuilder::WriteIndexBlock(rocksdb::MetaIndexBuilder*, rocksdb::BlockHandle*) (12 samples, 0.18%)
rocksdb::BlockBasedTableBuilder::WriteBlock(rocksdb::Slice const&, rocksdb::BlockHandle*, bool) (12 samples, 0.18%)
rocksdb::CompressBlock(rocksdb::Slice const&, rocksdb::CompressionContext const&, rocksdb::CompressionType*, unsigned int, std::string*) (11 samples, 0.16%)
snappy::RawCompress(char const*, unsigned long, char*, unsigned long*) (11 samples, 0.16%)
snappy::Compress(snappy::Source*, snappy::Sink*) (11 samples, 0.16%)
snappy::internal::CompressFragment(char const*, unsigned long, char*, unsigned short*, int) (11 samples, 0.16%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (8 samples, 0.12%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (2 samples, 0.03%)
rocksdb::WritableFileWriter::Sync(bool) (3 samples, 0.04%)
rocksdb::WritableFileWriter::SyncInternal(bool) (3 samples, 0.04%)
fdatasync (3 samples, 0.04%)
entry_SYSCALL_64_after_hwframe (3 samples, 0.04%)
do_syscall_64 (3 samples, 0.04%)
sys_fdatasync (3 samples, 0.04%)
do_fsync (3 samples, 0.04%)
xfs_file_fsync?[xfs] (3 samples, 0.04%)
file_write_and_wait_range (3 samples, 0.04%)
__filemap_fdatawrite_range (3 samples, 0.04%)
do_writepages (3 samples, 0.04%)
xfs_vm_writepages?[xfs] (3 samples, 0.04%)
write_cache_pages (3 samples, 0.04%)
xfs_do_writepage?[xfs] (3 samples, 0.04%)
xfs_start_page_writeback?[xfs] (2 samples, 0.03%)
__test_set_page_writeback (2 samples, 0.03%)
__lock_text_start (2 samples, 0.03%)
rocksdb::MergingIterator::SeekToFirst() (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
rocksdb::TableCache::NewIterator(rocksdb::ReadOptions const&, rocksdb::EnvOptions const&, rocksdb::InternalKeyComparator const&, rocksdb::FileMetaData const&, rocksdb::RangeDelAggregator*, rocksdb::SliceTransform const*, rocksdb::TableReader**, rocksdb::HistogramImpl*, bool, rocksdb::Arena*, bool, int) (3 samples, 0.04%)
rocksdb::BlockBasedTable::NewIterator(rocksdb::ReadOptions const&, rocksdb::SliceTransform const*, rocksdb::Arena*, bool, bool) (3 samples, 0.04%)
rocksdb::BlockBasedTable::NewIndexIterator(rocksdb::ReadOptions const&, bool, rocksdb::IndexBlockIter*, rocksdb::BlockBasedTable::CachableEntry<rocksdb::BlockBasedTable::IndexReader>*, rocksdb::GetContext*) (3 samples, 0.04%)
rocksdb::BlockBasedTable::CreateIndexReader(rocksdb::FilePrefetchBuffer*, rocksdb::BlockBasedTable::IndexReader**, rocksdb::InternalIteratorBase<rocksdb::Slice>*, int) (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
rocksdb::BlockFetcher::ReadBlockContents() (3 samples, 0.04%)
rocksdb::UncompressBlockContents(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (3 samples, 0.04%)
rocksdb::UncompressBlockContentsForCompressionType(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (3 samples, 0.04%)
snappy::RawUncompress(char const*, unsigned long, char*) (3 samples, 0.04%)
snappy::RawUncompress(snappy::Source*, char*) (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
void snappy::SnappyDecompressor::DecompressAllTags<snappy::SnappyArrayWriter>(snappy::SnappyArrayWriter*) (3 samples, 0.04%)
rocksdb::ShortenedIndexBuilder::AddIndexEntry(std::string*, rocksdb::Slice const*, rocksdb::BlockHandle const&) (2 samples, 0.03%)
rocksdb::DBImpl::PurgeObsoleteFiles(rocksdb::JobContext&, bool) (2 samples, 0.03%)
rocksdb::DBImpl::DeleteObsoleteFileImpl(int, std::string const&, std::string const&, rocksdb::FileType, unsigned long) (2 samples, 0.03%)
rocksdb::DeleteSSTFile(rocksdb::ImmutableDBOptions const*, std::string const&, std::string const&) (2 samples, 0.03%)
rocksdb::SstFileManagerImpl::ScheduleFileDeletion(std::string const&, std::string const&) (2 samples, 0.03%)
rocksdb::DeleteScheduler::DeleteFile(std::string const&, std::string const&) (2 samples, 0.03%)
__unlink (2 samples, 0.03%)
entry_SYSCALL_64_after_hwframe (2 samples, 0.03%)
do_syscall_64 (2 samples, 0.03%)
do_unlinkat (2 samples, 0.03%)
evict (2 samples, 0.03%)
truncate_inode_pages_range (2 samples, 0.03%)
rocksdb::DBImpl::BackgroundCallFlush() (111 samples, 1.63%)
rocksdb::DBImpl::BackgroundFlush(bool*, rocksdb::JobContext*, rocksdb::LogBuffer*, rocksdb::FlushReason*) (111 samples, 1.63%)
rocksdb::DBImpl::FlushMemTablesToOutputFiles(rocksdb::autovector<rocksdb::DBImpl::BGFlushArg, 8ul> const&, bool*, rocksdb::JobContext*, rocksdb::LogBuffer*) (111 samples, 1.63%)
rocksdb::DBImpl::FlushMemTableToOutputFile(rocksdb::ColumnFamilyData*, rocksdb::MutableCFOptions const&, bool*, rocksdb::JobContext*, rocksdb::SuperVersionContext*, rocksdb::LogBuffer*) (111 samples, 1.63%)
rocksdb::FlushJob::Run(rocksdb::LogsWithPrepTracker*, rocksdb::FileMetaData*) (111 samples, 1.63%)
rocksdb::FlushJob::WriteLevel0Table() (111 samples, 1.63%)
rocksdb::BuildTable(std::string const&, rocksdb::Env*, rocksdb::ImmutableCFOptions const&, rocksdb::MutableCFOptions const&, rocksdb::EnvOptions const&, rocksdb::TableCache*, rocksdb::InternalIteratorBase<rocksdb::Slice>*, std::unique_ptr<rocksdb::InternalIteratorBase<rocksdb::Slice>, std::default_delete<rocksdb::InternalIteratorBase<rocksdb::Slice> > >, rocksdb::FileMetaData*, rocksdb::InternalKeyComparator const&, std::vector<std::unique_ptr<rocksdb::IntTblPropCollectorFactory, std::default_delete<rocksdb::IntTblPropCollectorFactory> >, std::allocator<std::unique_ptr<rocksdb::IntTblPropCollectorFactory, std::default_delete<rocksdb::IntTblPropCollectorFactory> > > > const*, unsigned int, std::string const&, std::vector<unsigned long, std::allocator<unsigned long> >, unsigned long, rocksd (111 samples, 1.63%)
rocksdb::BlockBasedTableBuilder::Add(rocksdb::Slice const&, rocksdb::Slice const&) (99 samples, 1.46%)
rocksdb::BlockBasedTableBuilder::Flush() (94 samples, 1.38%)
rocksdb::BlockBasedTableBuilder::WriteBlock(rocksdb::BlockBuilder*, rocksdb::BlockHandle*, bool) (94 samples, 1.38%)
rocksdb::BlockBasedTableBuilder::WriteBlock(rocksdb::Slice const&, rocksdb::BlockHandle*, bool) (94 samples, 1.38%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
rocksdb::CompressBlock(rocksdb::Slice const&, rocksdb::CompressionContext const&, rocksdb::CompressionType*, unsigned int, std::string*) (91 samples, 1.34%)
snappy::RawCompress(char const*, unsigned long, char*, unsigned long*) (89 samples, 1.31%)
snappy::Compress(snappy::Source*, snappy::Sink*) (89 samples, 1.31%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
snappy::internal::CompressFragment(char const*, unsigned long, char*, unsigned short*, int) (85 samples, 1.25%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (47 samples, 0.69%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (15 samples, 0.22%)
rocksdb::ShortenedIndexBuilder::AddIndexEntry(std::string*, rocksdb::Slice const*, rocksdb::BlockHandle const&) (2 samples, 0.03%)
rocksdb::CompactionIterator::Next() (7 samples, 0.10%)
rocksdb::CompactionIterator::NextFromInput() (7 samples, 0.10%)
rocksdb::MemTableIterator::key() const (5 samples, 0.07%)
rocksdb::TableCache::NewIterator(rocksdb::ReadOptions const&, rocksdb::EnvOptions const&, rocksdb::InternalKeyComparator const&, rocksdb::FileMetaData const&, rocksdb::RangeDelAggregator*, rocksdb::SliceTransform const*, rocksdb::TableReader**, rocksdb::HistogramImpl*, bool, rocksdb::Arena*, bool, int) (4 samples, 0.06%)
rocksdb::TableCache::FindTable(rocksdb::EnvOptions const&, rocksdb::InternalKeyComparator const&, rocksdb::FileDescriptor const&, rocksdb::Cache::Handle**, rocksdb::SliceTransform const*, bool, bool, rocksdb::HistogramImpl*, bool, int, bool) (4 samples, 0.06%)
rocksdb::TableCache::GetTableReader(rocksdb::EnvOptions const&, rocksdb::InternalKeyComparator const&, rocksdb::FileDescriptor const&, bool, unsigned long, bool, rocksdb::HistogramImpl*, std::unique_ptr<rocksdb::TableReader, std::default_delete<rocksdb::TableReader> >*, rocksdb::SliceTransform const*, bool, int, bool, bool) (4 samples, 0.06%)
rocksdb::BlockBasedTableFactory::NewTableReader(rocksdb::TableReaderOptions const&, std::unique_ptr<rocksdb::RandomAccessFileReader, std::default_delete<rocksdb::RandomAccessFileReader> >&&, unsigned long, std::unique_ptr<rocksdb::TableReader, std::default_delete<rocksdb::TableReader> >*, bool) const (4 samples, 0.06%)
rocksdb::BlockBasedTable::Open(rocksdb::ImmutableCFOptions const&, rocksdb::EnvOptions const&, rocksdb::BlockBasedTableOptions const&, rocksdb::InternalKeyComparator const&, std::unique_ptr<rocksdb::RandomAccessFileReader, std::default_delete<rocksdb::RandomAccessFileReader> >&&, unsigned long, std::unique_ptr<rocksdb::TableReader, std::default_delete<rocksdb::TableReader> >*, rocksdb::SliceTransform const*, bool, bool, int, bool, unsigned long, rocksdb::TailPrefetchStats*) (4 samples, 0.06%)
rocksdb::BlockBasedTable::NewIndexIterator(rocksdb::ReadOptions const&, bool, rocksdb::IndexBlockIter*, rocksdb::BlockBasedTable::CachableEntry<rocksdb::BlockBasedTable::IndexReader>*, rocksdb::GetContext*) (4 samples, 0.06%)
rocksdb::BlockBasedTable::CreateIndexReader(rocksdb::FilePrefetchBuffer*, rocksdb::BlockBasedTable::IndexReader**, rocksdb::InternalIteratorBase<rocksdb::Slice>*, int) (4 samples, 0.06%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (4 samples, 0.06%)
rocksdb::BlockFetcher::ReadBlockContents() (4 samples, 0.06%)
rocksdb::UncompressBlockContents(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (3 samples, 0.04%)
rocksdb::UncompressBlockContentsForCompressionType(rocksdb::UncompressionContext const&, char const*, unsigned long, rocksdb::BlockContents*, unsigned int, rocksdb::ImmutableCFOptions const&) (3 samples, 0.04%)
snappy::RawUncompress(char const*, unsigned long, char*) (3 samples, 0.04%)
snappy::RawUncompress(snappy::Source*, char*) (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
/mnt/yarn/usercache/hadoop/appcache/application_1622554697095_0002/rocksdb-lib-46dd0cafc03a458fdd604bc63992028c/librocksdbjni-linux64.so (3 samples, 0.04%)
void snappy::SnappyDecompressor::DecompressAllTags<snappy::SnappyArrayWriter>(snappy::SnappyArrayWriter*) (3 samples, 0.04%)
[no_Java_frame] (2 samples, 0.03%)
[not_walkable_Java] (7 samples, 0.10%)
BarrierSet::static_write_ref_array_post(HeapWord*, unsigned long) (2 samples, 0.03%)
G1SATBCardTableLoggingModRefBS::write_ref_array_work(MemRegion) (2 samples, 0.03%)
[unknown] (4 samples, 0.06%)
clock_gettime (4 samples, 0.06%)
__vdso_clock_gettime (4 samples, 0.06%)
entry_SYSCALL_64_after_hwframe (3 samples, 0.04%)
do_syscall_64 (3 samples, 0.04%)
[unknown] (20 samples, 0.29%)
clock_gettime (5 samples, 0.07%)
__vdso_clock_gettime (5 samples, 0.07%)
entry_SYSCALL_64_after_hwframe (5 samples, 0.07%)
do_syscall_64 (5 samples, 0.07%)
sys_clock_gettime (4 samples, 0.06%)
posix_ktime_get_ts (3 samples, 0.04%)
ktime_get_ts64 (3 samples, 0.04%)
xen_clocksource_get_cycles (3 samples, 0.04%)
pvclock_clocksource_read (2 samples, 0.03%)
malloc (12 samples, 0.18%)
[unknown_Java] (11 samples, 0.16%)
BarrierSet::static_write_ref_array_post(HeapWord*, unsigned long) (2 samples, 0.03%)
Interpreter (5 samples, 0.07%)
oop_disjoint_arraycopy (2 samples, 0.03%)
__memmove_avx_unaligned_erms (25 samples, 0.37%)
__memset_avx2_erms (3 samples, 0.04%)
_int_free (6 samples, 0.09%)
_int_malloc (125 samples, 1.84%)
_..
java/lang/Thread.run (4,476 samples, 65.80%)
java/lang/Thread.run
akka/actor/LightArrayRevolverScheduler$$anon$4.run (4 samples, 0.06%)
akka/actor/LightArrayRevolverScheduler$$anon$4.nextTick (4 samples, 0.06%)
akka/actor/LightArrayRevolverScheduler.waitNanos (3 samples, 0.04%)
java/lang/Thread.sleep (3 samples, 0.04%)
JVM_Sleep (2 samples, 0.03%)
os::sleep(Thread*, long, bool) (2 samples, 0.03%)
__lll_unlock_wake (2 samples, 0.03%)
entry_SYSCALL_64_after_hwframe (2 samples, 0.03%)
do_syscall_64 (2 samples, 0.03%)
java/util/concurrent/ThreadPoolExecutor$Worker.run (9 samples, 0.13%)
java/util/concurrent/ThreadPoolExecutor.runWorker (9 samples, 0.13%)
akka/dispatch/Mailbox.run (9 samples, 0.13%)
akka/dispatch/Mailbox.processMailbox (9 samples, 0.13%)
akka/actor/ActorCell.invoke (9 samples, 0.13%)
akka/actor/ActorCell.receiveMessage (9 samples, 0.13%)
akka/actor/AbstractActor.aroundReceive (9 samples, 0.13%)
akka/actor/Actor$class.aroundReceive (9 samples, 0.13%)
scala/PartialFunction$OrElse.applyOrElse (9 samples, 0.13%)
scala/PartialFunction$OrElse.applyOrElse (9 samples, 0.13%)
scala/PartialFunction$OrElse.applyOrElse (9 samples, 0.13%)
akka/japi/pf/UnitCaseStatement.applyOrElse (9 samples, 0.13%)
scala/PartialFunction$class.applyOrElse (9 samples, 0.13%)
akka/japi/pf/UnitCaseStatement.apply (9 samples, 0.13%)
akka/japi/pf/UnitCaseStatement.apply (9 samples, 0.13%)
org/apache/flink/runtime/rpc/akka/AkkaRpcActor$$Lambda$93/1919701891.apply (9 samples, 0.13%)
org/apache/flink/runtime/rpc/akka/AkkaRpcActor.handleMessage (9 samples, 0.13%)
org/apache/flink/runtime/rpc/akka/AkkaRpcActor.handleRpcMessage (9 samples, 0.13%)
org/apache/flink/runtime/rpc/akka/AkkaRpcActor.handleCallAsync (9 samples, 0.13%)
org/apache/flink/runtime/metrics/dump/MetricQueryService$$Lambda$1543/1223202904.call (9 samples, 0.13%)
org/apache/flink/runtime/metrics/dump/MetricQueryService.lambda$queryMetrics$2 (9 samples, 0.13%)
org/apache/flink/runtime/metrics/dump/MetricDumpSerialization$MetricDumpSerializer.serialize (9 samples, 0.13%)
org/apache/flink/runtime/metrics/dump/MetricDumpSerialization.access$200 (8 samples, 0.12%)
org/apache/flink/runtime/metrics/dump/MetricDumpSerialization.serializeGauge (8 samples, 0.12%)
org/apache/flink/runtime/io/network/metrics/AbstractBuffersUsageGauge.getValue (2 samples, 0.03%)
org/apache/flink/runtime/io/network/metrics/AbstractBuffersUsageGauge.getValue (2 samples, 0.03%)
org/apache/flink/runtime/metrics/dump/MetricDumpSerialization.serializeMetricInfo (3 samples, 0.04%)
org/apache/flink/core/memory/DataOutputSerializer.writeUTF (3 samples, 0.04%)
org/apache/flink/runtime/taskmanager/Task.run (4,374 samples, 64.30%)
org/apache/flink/runtime/taskmanager/Task.run
org/apache/flink/runtime/taskmanager/Task.doRun (4,374 samples, 64.30%)
org/apache/flink/runtime/taskmanager/Task.doRun
org/apache/flink/streaming/runtime/tasks/StreamTask.invoke (4,374 samples, 64.30%)
org/apache/flink/streaming/runtime/tasks/StreamTask.invoke
org/apache/flink/streaming/runtime/tasks/StreamTask.runWithCleanUpOnFail (4,374 samples, 64.30%)
org/apache/flink/streaming/runtime/tasks/StreamTask.runWithCleanUpOnFail
org/apache/flink/streaming/runtime/tasks/StreamTask$$Lambda$624/1960744205.run (4,374 samples, 64.30%)
org/apache/flink/streaming/runtime/tasks/StreamTask$$Lambda$624/1960744205.run
org/apache/flink/streaming/runtime/tasks/StreamTask.executeInvoke (4,374 samples, 64.30%)
org/apache/flink/streaming/runtime/tasks/StreamTask.executeInvoke
org/apache/flink/streaming/runtime/tasks/StreamTask.runMailboxLoop (4,374 samples, 64.30%)
org/apache/flink/streaming/runtime/tasks/StreamTask.runMailboxLoop
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.runMailboxLoop (4,374 samples, 64.30%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.runMailboxLoop
org/apache/flink/streaming/runtime/tasks/StreamTask$$Lambda$214/1073548875.runDefaultAction (4,351 samples, 63.97%)
org/apache/flink/streaming/runtime/tasks/StreamTask$$Lambda$214/1073548875.runDefaultAction
org/apache/flink/streaming/runtime/tasks/StreamTask.processInput (4,351 samples, 63.97%)
org/apache/flink/streaming/runtime/tasks/StreamTask.processInput
java/util/concurrent/CompletableFuture.thenRun (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.processInput (236 samples, 3.47%)
org..
org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.emitNext (236 samples, 3.47%)
org..
org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.getNextRecord (5 samples, 0.07%)
org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.readNextRecord (3 samples, 0.04%)
org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.readNonSpanningRecord (2 samples, 0.03%)
org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.readInto (2 samples, 0.03%)
org/apache/flink/runtime/plugable/NonReusingDeserializationDelegate.read (2 samples, 0.03%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.deserialize (2 samples, 0.03%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.deserialize (2 samples, 0.03%)
org/apache/flink/runtime/io/network/buffer/NetworkBuffer.recycleBuffer (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/buffer/AbstractReferenceCountedByteBuf.release (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/buffer/AbstractReferenceCountedByteBuf.handleRelease (2 samples, 0.03%)
org/apache/flink/runtime/io/network/buffer/NetworkBuffer.deallocate (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/consumer/BufferManager.recycle (2 samples, 0.03%)
org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.processElement (230 samples, 3.38%)
org..
org/apache/flink/streaming/runtime/tasks/OneInputStreamTask$StreamTaskNetworkOutput.emitRecord (230 samples, 3.38%)
org..
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setKeyContextElement1 (4 samples, 0.06%)
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setKeyContextElement (4 samples, 0.06%)
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setCurrentKey (2 samples, 0.03%)
org/apache/flink/streaming/api/operators/StreamOperatorStateHandler.setCurrentKey (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/streaming/api/operators/KeyedProcessOperator.processElement (226 samples, 3.32%)
org..
org/apache/flink/table/runtime/operators/deduplicate/ProcTimeDeduplicateKeepLastRowFunction.processElement (225 samples, 3.31%)
org..
org/apache/flink/table/runtime/operators/deduplicate/ProcTimeDeduplicateKeepLastRowFunction.processElement (225 samples, 3.31%)
org..
org/apache/flink/table/runtime/operators/deduplicate/DeduplicateFunctionHelper.processLastRowOnChangelog (225 samples, 3.31%)
org..
org/apache/flink/contrib/streaming/state/RocksDBValueState.update (36 samples, 0.53%)
org/rocksdb/RocksDB.put (36 samples, 0.53%)
org/rocksdb/RocksDB.put (35 samples, 0.51%)
org/apache/flink/contrib/streaming/state/RocksDBValueState.value (169 samples, 2.48%)
or..
org/rocksdb/RocksDB.get (168 samples, 2.47%)
or..
org/rocksdb/RocksDB.get (168 samples, 2.47%)
or..
org/apache/flink/streaming/api/operators/TimestampedCollector.collect (20 samples, 0.29%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (20 samples, 0.29%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (20 samples, 0.29%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (19 samples, 0.28%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (19 samples, 0.28%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (19 samples, 0.28%)
StreamExecCalc$1994.processElement (10 samples, 0.15%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (4 samples, 0.06%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (4 samples, 0.06%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (4 samples, 0.06%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (4 samples, 0.06%)
org/apache/flink/table/data/RowData$$Lambda$282/25672700.getFieldOrNull (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.emitRecord (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.finishUnicastBufferBuilder (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryStringData.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (2 samples, 0.03%)
StreamExecCalc$2856.processElement (6 samples, 0.09%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (3 samples, 0.04%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (2 samples, 0.03%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (2 samples, 0.03%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (2 samples, 0.03%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryStringData.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessor.getAvailableFuture (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessor.processInput (4,102 samples, 60.31%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessor.processInput
org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.processInput (4,097 samples, 60.23%)
org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.processInput
org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.emitNext (4,095 samples, 60.20%)
org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.emitNext
org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.getNextRecord (15 samples, 0.22%)
org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.readNextRecord (13 samples, 0.19%)
org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.readNonSpanningRecord (12 samples, 0.18%)
org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.readInto (12 samples, 0.18%)
org/apache/flink/runtime/plugable/NonReusingDeserializationDelegate.read (10 samples, 0.15%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.deserialize (10 samples, 0.15%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.deserialize (10 samples, 0.15%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.deserialize (8 samples, 0.12%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.deserialize (8 samples, 0.12%)
org/apache/flink/table/runtime/typeutils/BinaryRowDataSerializer.deserialize (8 samples, 0.12%)
org/apache/flink/core/memory/MemorySegmentFactory.wrap (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.readFully (2 samples, 0.03%)
org/apache/flink/runtime/io/network/buffer/NetworkBuffer.recycleBuffer (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/buffer/AbstractReferenceCountedByteBuf.release (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/buffer/AbstractReferenceCountedByteBuf.handleRelease (2 samples, 0.03%)
org/apache/flink/runtime/io/network/buffer/NetworkBuffer.deallocate (2 samples, 0.03%)
org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.processBuffer (2 samples, 0.03%)
org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.getActiveSerializer (2 samples, 0.03%)
org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.processElement (4,076 samples, 59.92%)
org/apache/flink/streaming/runtime/io/AbstractStreamTaskNetworkInput.processElement
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory$StreamTaskNetworkOutput.emitRecord (4,076 samples, 59.92%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory$StreamTaskNetworkOutput.emitRe..
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory$$Lambda$499/1258285532.accept (794 samples, 11.67%)
org/apache/flink/..
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory.lambda$create$0 (794 samples, 11.67%)
org/apache/flink/..
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory.processRecord1 (794 samples, 11.67%)
org/apache/flink/..
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setKeyContextElement1 (5 samples, 0.07%)
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setKeyContextElement (5 samples, 0.07%)
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setCurrentKey (2 samples, 0.03%)
org/apache/flink/streaming/api/operators/StreamOperatorStateHandler.setCurrentKey (2 samples, 0.03%)
org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.setCurrentKey (2 samples, 0.03%)
org/apache/flink/runtime/state/SerializedCompositeKeyBuilder.setKeyAndKeyGroup (2 samples, 0.03%)
org/apache/flink/runtime/state/SerializedCompositeKeyBuilder.serializeKeyGroupAndKey (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (3 samples, 0.04%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (3 samples, 0.04%)
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.processElement1 (789 samples, 11.60%)
org/apache/flink/..
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.processElement (789 samples, 11.60%)
org/apache/flink/..
org/apache/flink/table/runtime/operators/join/stream/AbstractStreamingJoinOperator$AssociatedRecords.of (252 samples, 3.70%)
org/..
org/apache/flink/table/runtime/operators/join/stream/AbstractStreamingJoinOperator$JoinConditionWithNullFilters.apply (3 samples, 0.04%)
org/apache/flink/table/runtime/operators/join/stream/state/JoinRecordStateViews$JoinKeyContainsUniqueKey.getRecords (247 samples, 3.63%)
org/..
org/apache/flink/contrib/streaming/state/RocksDBValueState.value (246 samples, 3.62%)
org/..
org/rocksdb/RocksDB.get (245 samples, 3.60%)
org/..
org/rocksdb/RocksDB.get (243 samples, 3.57%)
org/..
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.output (165 samples, 2.43%)
or..
org/apache/flink/streaming/api/operators/TimestampedCollector.collect (165 samples, 2.43%)
or..
org/apache/flink/streaming/api/operators/CountingOutput.collect (165 samples, 2.43%)
or..
org/apache/flink/streaming/api/operators/CountingOutput.collect (165 samples, 2.43%)
or..
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (165 samples, 2.43%)
or..
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (165 samples, 2.43%)
or..
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (165 samples, 2.43%)
or..
StreamExecCalc$2398.processElement (6 samples, 0.09%)
StreamExecCalc$2619.processElement (19 samples, 0.28%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (7 samples, 0.10%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (7 samples, 0.10%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (7 samples, 0.10%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (7 samples, 0.10%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (7 samples, 0.10%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (7 samples, 0.10%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (7 samples, 0.10%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (7 samples, 0.10%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (7 samples, 0.10%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (6 samples, 0.09%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullAt (2 samples, 0.03%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullBit (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinarySegmentUtils.bitSet (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryStringData.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (2 samples, 0.03%)
StreamExecCalc$2827.processElement (18 samples, 0.26%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (7 samples, 0.10%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (7 samples, 0.10%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (7 samples, 0.10%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (6 samples, 0.09%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (6 samples, 0.09%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (6 samples, 0.09%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (6 samples, 0.09%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (6 samples, 0.09%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (6 samples, 0.09%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (6 samples, 0.09%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullAt (4 samples, 0.06%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullBit (3 samples, 0.04%)
org/apache/flink/table/data/binary/BinarySegmentUtils.bitSet (3 samples, 0.04%)
StreamExecCalc$3314.processElement (90 samples, 1.32%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (18 samples, 0.26%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (18 samples, 0.26%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (18 samples, 0.26%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (18 samples, 0.26%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (18 samples, 0.26%)
org/apache/flink/streaming/api/operators/StreamFilter.processElement (6 samples, 0.09%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (5 samples, 0.07%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (5 samples, 0.07%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (4 samples, 0.06%)
org/apache/flink/table/data/binary/BinaryRowData.copy (4 samples, 0.06%)
org/apache/flink/table/data/binary/BinaryRowData.copy (4 samples, 0.06%)
org/apache/flink/table/data/binary/BinaryRowData.copyInternal (3 samples, 0.04%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (3 samples, 0.04%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (12 samples, 0.18%)
org/apache/flink/table/data/RowData$$Lambda$282/25672700.getFieldOrNull (3 samples, 0.04%)
org/apache/flink/table/data/RowData.lambda$createFieldGetter$25774257$1 (2 samples, 0.03%)
itable stub (2 samples, 0.03%)
org/apache/flink/table/data/utils/JoinedRowData.getArity (2 samples, 0.03%)
org/apache/flink/table/data/BoxedWrapperRowData.getRowKind (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (5 samples, 0.07%)
org/apache/flink/table/data/binary/BinaryRowData.copy (5 samples, 0.07%)
org/apache/flink/table/data/binary/BinaryRowData.copy (5 samples, 0.07%)
org/apache/flink/table/data/binary/BinaryRowData.copyInternal (4 samples, 0.06%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (4 samples, 0.06%)
org/apache/flink/table/data/binary/BinaryRowData.setInt (2 samples, 0.03%)
org/apache/flink/table/data/writer/BinaryRowWriter.writeString (2 samples, 0.03%)
org/apache/flink/table/data/writer/AbstractBinaryWriter.writeString (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (30 samples, 0.44%)
itable stub (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (25 samples, 0.37%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (24 samples, 0.35%)
itable stub (2 samples, 0.03%)
org/apache/flink/table/data/RowData$$Lambda$282/25672700.getFieldOrNull (3 samples, 0.04%)
org/apache/flink/table/data/RowData.lambda$createFieldGetter$25774257$1 (3 samples, 0.04%)
org/apache/flink/table/data/utils/JoinedRowData.getArity (3 samples, 0.04%)
org/apache/flink/table/data/utils/JoinedRowData.isNullAt (7 samples, 0.10%)
itable stub (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (4 samples, 0.06%)
org/apache/flink/table/data/binary/BinaryStringData.copy (3 samples, 0.04%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (3 samples, 0.04%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (2 samples, 0.03%)
org/apache/flink/core/memory/MemorySegment.get (2 samples, 0.03%)
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.outputNullPadding (234 samples, 3.44%)
org..
org/apache/flink/streaming/api/operators/TimestampedCollector.collect (234 samples, 3.44%)
org..
org/apache/flink/streaming/api/operators/CountingOutput.collect (234 samples, 3.44%)
org..
org/apache/flink/streaming/api/operators/CountingOutput.collect (234 samples, 3.44%)
org..
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (233 samples, 3.43%)
org..
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (233 samples, 3.43%)
org..
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (233 samples, 3.43%)
org..
StreamExecCalc$1865.processElement (5 samples, 0.07%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.emitRecord (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.finishUnicastBufferBuilder (2 samples, 0.03%)
org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.selectChannel (2 samples, 0.03%)
org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.selectChannel (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryRowData.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryRowData.copy (2 samples, 0.03%)
StreamExecCalc$2164.processElement (8 samples, 0.12%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (5 samples, 0.07%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (5 samples, 0.07%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (4 samples, 0.06%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (4 samples, 0.06%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (4 samples, 0.06%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (4 samples, 0.06%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullAt (3 samples, 0.04%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullBit (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinarySegmentUtils.bitSet (2 samples, 0.03%)
org/apache/flink/core/memory/MemorySegment.get (2 samples, 0.03%)
StreamExecCalc$2398.processElement (54 samples, 0.79%)
I2C/C2I adapters (3 samples, 0.04%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (17 samples, 0.25%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (17 samples, 0.25%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (17 samples, 0.25%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (17 samples, 0.25%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (17 samples, 0.25%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (17 samples, 0.25%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (15 samples, 0.22%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (14 samples, 0.21%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (14 samples, 0.21%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (14 samples, 0.21%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (14 samples, 0.21%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (14 samples, 0.21%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (14 samples, 0.21%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (14 samples, 0.21%)
org/apache/flink/table/data/RowData$$Lambda$282/25672700.getFieldOrNull (2 samples, 0.03%)
org/apache/flink/table/data/RowData.lambda$createFieldGetter$25774257$1 (2 samples, 0.03%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullAt (6 samples, 0.09%)
org/apache/flink/core/memory/MemorySegment.putLong (3 samples, 0.04%)
org/apache/flink/core/memory/MemorySegment.put (2 samples, 0.03%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullBit (3 samples, 0.04%)
org/apache/flink/table/data/binary/BinarySegmentUtils.bitSet (3 samples, 0.04%)
org/apache/flink/table/data/writer/BinaryWriter.write (3 samples, 0.04%)
org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.selectChannel (2 samples, 0.03%)
org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.selectChannel (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (2 samples, 0.03%)
StreamExecCalc$2619.processElement (59 samples, 0.87%)
I2C/C2I adapters (3 samples, 0.04%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (15 samples, 0.22%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (15 samples, 0.22%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (15 samples, 0.22%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (15 samples, 0.22%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (15 samples, 0.22%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (15 samples, 0.22%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (15 samples, 0.22%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (12 samples, 0.18%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (12 samples, 0.18%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (12 samples, 0.18%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (12 samples, 0.18%)
itable stub (3 samples, 0.04%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullAt (6 samples, 0.09%)
org/apache/flink/core/memory/MemorySegment.putLong (2 samples, 0.03%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullBit (4 samples, 0.06%)
org/apache/flink/table/data/binary/BinarySegmentUtils.bitSet (4 samples, 0.06%)
org/apache/flink/core/memory/MemorySegment.get (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.emitRecord (3 samples, 0.04%)
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.appendUnicastDataForRecordContinuation (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.add (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.add (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.notifyDataAvailable (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.notifyDataAvailable (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryStringData.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (2 samples, 0.03%)
StreamExecCalc$2827.processElement (40 samples, 0.59%)
I2C/C2I adapters (2 samples, 0.03%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (3 samples, 0.04%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (3 samples, 0.04%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (3 samples, 0.04%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (3 samples, 0.04%)
itable stub (2 samples, 0.03%)
org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.selectChannel (2 samples, 0.03%)
org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.selectChannel (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
StreamExecCalc$3314.processElement (8 samples, 0.12%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (3 samples, 0.04%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (3 samples, 0.04%)
org/apache/flink/streaming/api/operators/StreamFilter.processElement (3 samples, 0.04%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (3 samples, 0.04%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (59 samples, 0.87%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (59 samples, 0.87%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (57 samples, 0.84%)
itable stub (6 samples, 0.09%)
org/apache/flink/table/data/RowData$$Lambda$282/25672700.getFieldOrNull (6 samples, 0.09%)
org/apache/flink/table/data/RowData.lambda$createFieldGetter$25774257$1 (5 samples, 0.07%)
org/apache/flink/table/data/RowData$$Lambda$283/374807113.getFieldOrNull (2 samples, 0.03%)
org/apache/flink/table/data/utils/JoinedRowData.getArity (4 samples, 0.06%)
org/apache/flink/table/data/utils/JoinedRowData.isNullAt (22 samples, 0.32%)
itable stub (7 samples, 0.10%)
org/apache/flink/table/data/GenericRowData.getArity (4 samples, 0.06%)
org/apache/flink/table/data/binary/BinaryRowData.getArity (6 samples, 0.09%)
org/apache/flink/table/data/binary/BinaryRowData.isNullAt (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (11 samples, 0.16%)
org/apache/flink/table/runtime/typeutils/StringDataSerializer.copy (10 samples, 0.15%)
org/apache/flink/table/data/binary/BinaryStringData.copy (10 samples, 0.15%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (10 samples, 0.15%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (3 samples, 0.04%)
org/apache/flink/table/runtime/operators/join/stream/state/JoinRecordStateViews$JoinKeyContainsUniqueKey.addRecord (2 samples, 0.03%)
org/apache/flink/table/runtime/operators/join/stream/state/OuterJoinRecordStateViews$InputSideHasUniqueKey.addRecord (119 samples, 1.75%)
org/apache/flink/runtime/state/UserFacingMapState.put (110 samples, 1.62%)
org/apache/flink/contrib/streaming/state/RocksDBMapState.put (109 samples, 1.60%)
org/apache/flink/contrib/streaming/state/AbstractRocksDBState.serializeValueNullSensitive (5 samples, 0.07%)
org/apache/flink/contrib/streaming/state/AbstractRocksDBState.serializeValueInternal (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (3 samples, 0.04%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (3 samples, 0.04%)
org/rocksdb/RocksDB.put (104 samples, 1.53%)
org/rocksdb/RocksDB.put (103 samples, 1.51%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (9 samples, 0.13%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (9 samples, 0.13%)
KeyProjection$1769.apply (2 samples, 0.03%)
KeyProjection$1769.apply (2 samples, 0.03%)
org/apache/flink/table/data/writer/BinaryRowWriter.writeString (2 samples, 0.03%)
org/apache/flink/table/data/writer/AbstractBinaryWriter.writeString (2 samples, 0.03%)
KeyProjection$2860.apply (2 samples, 0.03%)
KeyProjection$2860.apply (2 samples, 0.03%)
org/apache/flink/table/data/writer/BinaryRowWriter.writeString (2 samples, 0.03%)
org/apache/flink/table/data/writer/AbstractBinaryWriter.writeString (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryRowData.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryRowData.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryRowData.copyInternal (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (2 samples, 0.03%)
org/apache/flink/table/runtime/operators/join/stream/state/OuterJoinRecordStateViews$InputSideHasUniqueKey.retractRecord (16 samples, 0.24%)
org/apache/flink/runtime/state/UserFacingMapState.remove (14 samples, 0.21%)
org/apache/flink/contrib/streaming/state/RocksDBMapState.remove (14 samples, 0.21%)
org/rocksdb/RocksDB.delete (14 samples, 0.21%)
org/rocksdb/RocksDB.delete (14 samples, 0.21%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (2 samples, 0.03%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory$$Lambda$500/423626541.accept (3,282 samples, 48.25%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory$$Lambda$50..
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory.lambda$create$1 (3,282 samples, 48.25%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory.lambda$cre..
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory.processRecord2 (3,282 samples, 48.25%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory.processRec..
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setKeyContextElement2 (8 samples, 0.12%)
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setKeyContextElement (8 samples, 0.12%)
org/apache/flink/streaming/api/operators/AbstractStreamOperator.setCurrentKey (3 samples, 0.04%)
org/apache/flink/streaming/api/operators/StreamOperatorStateHandler.setCurrentKey (3 samples, 0.04%)
org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.setCurrentKey (2 samples, 0.03%)
org/apache/flink/runtime/state/SerializedCompositeKeyBuilder.setKeyAndKeyGroup (2 samples, 0.03%)
org/apache/flink/runtime/state/SerializedCompositeKeyBuilder.serializeKeyGroupAndKey (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (2 samples, 0.03%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (5 samples, 0.07%)
org/apache/flink/table/runtime/keyselector/BinaryRowDataKeySelector.getKey (5 samples, 0.07%)
org/apache/flink/table/data/binary/BinaryRowData.copy (5 samples, 0.07%)
org/apache/flink/table/data/binary/BinaryRowData.copy (5 samples, 0.07%)
itable stub (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryRowData.copyInternal (3 samples, 0.04%)
org/apache/flink/table/data/binary/BinarySegmentUtils.copyToBytes (3 samples, 0.04%)
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.processElement2 (3,274 samples, 48.13%)
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.proc..
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.processElement (3,274 samples, 48.13%)
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.proc..
org/apache/flink/table/runtime/operators/join/stream/AbstractStreamingJoinOperator$AssociatedRecords.of (3,153 samples, 46.35%)
org/apache/flink/table/runtime/operators/join/stream/AbstractStreamingJoinOp..
org/apache/flink/contrib/streaming/state/RocksDBMapState$RocksDBMapIterator.hasNext (3,149 samples, 46.30%)
org/apache/flink/contrib/streaming/state/RocksDBMapState$RocksDBMapIterator...
org/apache/flink/contrib/streaming/state/RocksDBMapState$RocksDBMapIterator.loadCache (3,149 samples, 46.30%)
org/apache/flink/contrib/streaming/state/RocksDBMapState$RocksDBMapIterator...
org/apache/flink/contrib/streaming/state/RocksDBOperationUtils.getRocksIterator (21 samples, 0.31%)
org/rocksdb/RocksDB.newIterator (21 samples, 0.31%)
org/rocksdb/RocksDB.iteratorCF (17 samples, 0.25%)
org/rocksdb/RocksIterator.<init> (4 samples, 0.06%)
org/rocksdb/AbstractRocksIterator.<init> (4 samples, 0.06%)
org/rocksdb/RocksObject.<init> (4 samples, 0.06%)
org/rocksdb/AbstractImmutableNativeReference.<init> (4 samples, 0.06%)
org/rocksdb/AbstractNativeReference.<init> (4 samples, 0.06%)
java/lang/Object.<init> (4 samples, 0.06%)
org/apache/flink/contrib/streaming/state/RocksIteratorWrapper.close (11 samples, 0.16%)
org/rocksdb/AbstractImmutableNativeReference.close (11 samples, 0.16%)
org/rocksdb/AbstractRocksIterator.disposeInternal (11 samples, 0.16%)
org/rocksdb/RocksIterator.disposeInternal (11 samples, 0.16%)
org/apache/flink/contrib/streaming/state/RocksIteratorWrapper.next (9 samples, 0.13%)
org/rocksdb/AbstractRocksIterator.next (8 samples, 0.12%)
org/rocksdb/RocksIterator.next0 (8 samples, 0.12%)
org/apache/flink/contrib/streaming/state/RocksIteratorWrapper.seek (3,106 samples, 45.66%)
org/apache/flink/contrib/streaming/state/RocksIteratorWrapper.seek
org/rocksdb/AbstractRocksIterator.seek (3,106 samples, 45.66%)
org/rocksdb/AbstractRocksIterator.seek
org/rocksdb/RocksIterator.seek0 (3,104 samples, 45.63%)
org/rocksdb/RocksIterator.seek0
org/apache/flink/contrib/streaming/state/RocksIteratorWrapper.value (2 samples, 0.03%)
org/rocksdb/RocksIterator.value (2 samples, 0.03%)
org/rocksdb/RocksIterator.value0 (2 samples, 0.03%)
org/apache/flink/table/runtime/operators/join/stream/state/JoinRecordStateViews$JoinKeyContainsUniqueKey.getRecords (2 samples, 0.03%)
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.output (52 samples, 0.76%)
org/apache/flink/streaming/api/operators/TimestampedCollector.collect (52 samples, 0.76%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (52 samples, 0.76%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (52 samples, 0.76%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (52 samples, 0.76%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (52 samples, 0.76%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (52 samples, 0.76%)
StreamExecCalc$2164.processElement (9 samples, 0.13%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (5 samples, 0.07%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (5 samples, 0.07%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (5 samples, 0.07%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (5 samples, 0.07%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (5 samples, 0.07%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullAt (2 samples, 0.03%)
StreamExecCalc$3314.processElement (30 samples, 0.44%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (7 samples, 0.10%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (7 samples, 0.10%)
org/apache/flink/streaming/api/operators/StreamFilter.processElement (2 samples, 0.03%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (2 samples, 0.03%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (4 samples, 0.06%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryRowData.copy (2 samples, 0.03%)
org/apache/flink/table/data/binary/BinaryRowData.copy (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (12 samples, 0.18%)
itable stub (3 samples, 0.04%)
org/apache/flink/table/data/RowData$$Lambda$282/25672700.getFieldOrNull (3 samples, 0.04%)
org/apache/flink/table/data/RowData.lambda$createFieldGetter$25774257$1 (3 samples, 0.04%)
org/apache/flink/table/data/utils/JoinedRowData.isNullAt (3 samples, 0.04%)
org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.outputNullPadding (18 samples, 0.26%)
org/apache/flink/streaming/api/operators/TimestampedCollector.collect (18 samples, 0.26%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (18 samples, 0.26%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (18 samples, 0.26%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (18 samples, 0.26%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.collect (18 samples, 0.26%)
org/apache/flink/streaming/runtime/tasks/CopyingChainingOutput.pushToOperator (18 samples, 0.26%)
StreamExecCalc$2164.processElement (10 samples, 0.15%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (6 samples, 0.09%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (6 samples, 0.09%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (5 samples, 0.07%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (5 samples, 0.07%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (5 samples, 0.07%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (5 samples, 0.07%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (5 samples, 0.07%)
org/apache/flink/table/data/writer/BinaryRowWriter.setNullAt (2 samples, 0.03%)
org/apache/flink/table/data/GenericRowData.isNullAt (2 samples, 0.03%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (8 samples, 0.12%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copy (8 samples, 0.12%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.copyRowData (7 samples, 0.10%)
org/apache/flink/table/data/utils/JoinedRowData.getArity (2 samples, 0.03%)
org/apache/flink/table/data/utils/JoinedRowData.isNullAt (2 samples, 0.03%)
org/apache/flink/table/runtime/operators/join/stream/state/JoinRecordStateViews$JoinKeyContainsUniqueKey.addRecord (46 samples, 0.68%)
org/apache/flink/contrib/streaming/state/RocksDBValueState.update (46 samples, 0.68%)
org/apache/flink/contrib/streaming/state/AbstractRocksDBState.serializeValue (2 samples, 0.03%)
org/apache/flink/contrib/streaming/state/AbstractRocksDBState.serializeValue (2 samples, 0.03%)
org/apache/flink/contrib/streaming/state/AbstractRocksDBState.serializeValueInternal (2 samples, 0.03%)
org/rocksdb/RocksDB.put (44 samples, 0.65%)
org/rocksdb/RocksDB.put (43 samples, 0.63%)
org/apache/flink/table/runtime/operators/join/stream/state/OuterJoinRecordStateViews$InputSideHasUniqueKey.updateNumOfAssociations (5 samples, 0.07%)
org/apache/flink/runtime/state/UserFacingMapState.put (4 samples, 0.06%)
org/apache/flink/contrib/streaming/state/RocksDBMapState.put (4 samples, 0.06%)
org/rocksdb/RocksDB.put (4 samples, 0.06%)
org/rocksdb/RocksDB.put (4 samples, 0.06%)
org/apache/flink/streaming/runtime/io/checkpointing/CheckpointedInputGate.pollNext (2 samples, 0.03%)
org/apache/flink/runtime/taskmanager/InputGateWithMetrics.pollNext (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.pollNext (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.getNextBufferOrEvent (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.waitAndGetNextData (2 samples, 0.03%)
org/apache/flink/streaming/runtime/io/StreamTwoInputProcessor.selectNextReadingInputIndex (2 samples, 0.03%)
org/apache/flink/streaming/runtime/io/TwoInputSelectionHandler.nextSelection (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor$MailboxController.suspendDefaultAction (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.access$100 (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.suspendDefaultAction (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.ensureControlFlowSignalCheck (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.sendControlMail (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.putFirst (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/StreamTask.processInput (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.processMail (21 samples, 0.31%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.processMailsNonBlocking (4 samples, 0.06%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.maybePauseIdleTimer (2 samples, 0.03%)
org/apache/flink/runtime/metrics/TimerGauge.markEnd (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.processMailsWhenDefaultActionUnavailable (16 samples, 0.24%)
org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.take (14 samples, 0.21%)
java/util/concurrent/locks/AbstractQueuedSynchronizer$ConditionObject.await (12 samples, 0.18%)
java/util/concurrent/locks/LockSupport.parkNanos (11 samples, 0.16%)
sun/misc/Unsafe.park (10 samples, 0.15%)
org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.takeOrNull (2 samples, 0.03%)
java/util/ArrayDeque$DeqIterator.remove (2 samples, 0.03%)
java/util/ArrayDeque.access$200 (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/util/internal/ThreadExecutorMap$2.run (89 samples, 1.31%)
org/apache/flink/shaded/netty4/io/netty/util/concurrent/SingleThreadEventExecutor$4.run (89 samples, 1.31%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/EpollEventLoop.run (89 samples, 1.31%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/EpollEventLoop.epollWaitNoTimerChange (5 samples, 0.07%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/Native.epollWait (5 samples, 0.07%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/Native.epollWait (5 samples, 0.07%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/Native.epollWait (5 samples, 0.07%)
epoll_wait (4 samples, 0.06%)
entry_SYSCALL_64_after_hwframe (3 samples, 0.04%)
do_syscall_64 (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/EpollEventLoop.processReady (34 samples, 0.50%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady (33 samples, 0.49%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline.fireChannelRead (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelRead (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelRead (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline$HeadContext.channelRead (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.fireChannelRead (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelRead (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelRead (23 samples, 0.34%)
org/apache/flink/runtime/io/network/netty/NettyMessageClientDecoderDelegate.channelRead (18 samples, 0.26%)
org/apache/flink/runtime/io/network/netty/BufferResponseDecoder.onChannelRead (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/buffer/AbstractByteBuf.writeBytes (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/buffer/AbstractByteBuf.writeBytes (2 samples, 0.03%)
org/apache/flink/runtime/io/network/buffer/NetworkBuffer.setBytes (2 samples, 0.03%)
org/apache/flink/runtime/io/network/buffer/NetworkBuffer.setBytes (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.fireChannelRead (16 samples, 0.24%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelRead (16 samples, 0.24%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelRead (16 samples, 0.24%)
org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.channelRead (14 samples, 0.21%)
org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.decodeMsg (14 samples, 0.21%)
org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.decodeBufferOrEvent (14 samples, 0.21%)
org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.onBuffer (14 samples, 0.21%)
org/apache/flink/runtime/io/network/partition/consumer/InputChannel.notifyChannelNonEmpty (10 samples, 0.15%)
org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.notifyChannelNonEmpty (10 samples, 0.15%)
org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.queueChannel (10 samples, 0.15%)
org/apache/flink/runtime/io/network/partition/consumer/GateNotificationHelper.close (10 samples, 0.15%)
java/util/concurrent/CompletableFuture.complete (10 samples, 0.15%)
java/util/concurrent/CompletableFuture.postComplete (10 samples, 0.15%)
java/util/concurrent/CompletableFuture$UniRun.tryFire (10 samples, 0.15%)
java/util/concurrent/CompletableFuture.uniRun (10 samples, 0.15%)
org/apache/flink/streaming/runtime/tasks/StreamTask$ResumeWrapper.run (10 samples, 0.15%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor$DefaultActionSuspension.resume (10 samples, 0.15%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.access$200 (10 samples, 0.15%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.sendControlMail (10 samples, 0.15%)
org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.putFirst (8 samples, 0.12%)
java/util/concurrent/locks/ReentrantLock.unlock (8 samples, 0.12%)
java/util/concurrent/locks/AbstractQueuedSynchronizer.release (8 samples, 0.12%)
java/util/concurrent/locks/AbstractQueuedSynchronizer.unparkSuccessor (8 samples, 0.12%)
java/util/concurrent/locks/LockSupport.unpark (8 samples, 0.12%)
sun/misc/Unsafe.unpark (8 samples, 0.12%)
pthread_cond_signal@@GLIBC_2.3.2 (8 samples, 0.12%)
entry_SYSCALL_64_after_hwframe (7 samples, 0.10%)
do_syscall_64 (7 samples, 0.10%)
sys_futex (6 samples, 0.09%)
do_futex (6 samples, 0.09%)
futex_wake (6 samples, 0.09%)
wake_up_q (5 samples, 0.07%)
try_to_wake_up (5 samples, 0.07%)
__lock_text_start (5 samples, 0.07%)
os::javaTimeMillis() (2 samples, 0.03%)
gettimeofday (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.onSenderBacklog (4 samples, 0.06%)
org/apache/flink/runtime/io/network/partition/consumer/BufferManager.requestFloatingBuffers (3 samples, 0.04%)
org/apache/flink/runtime/io/network/buffer/LocalBufferPool.requestBuffer (3 samples, 0.04%)
org/apache/flink/runtime/io/network/buffer/LocalBufferPool.requestMemorySegment (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/handler/codec/ByteToMessageDecoder.channelRead (4 samples, 0.06%)
org/apache/flink/shaded/netty4/io/netty/handler/codec/ByteToMessageDecoder.fireChannelRead (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.fireChannelRead (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelRead (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelRead (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/channel/SimpleChannelInboundHandler.channelRead (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.channelRead0 (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.channelRead0 (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.addCreditOrResumeConsumption (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.enqueueAvailableReader (2 samples, 0.03%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.writeAndFlushNextMessageIfPossible (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel.writeAndFlush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline.writeAndFlush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.writeAndFlush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.writeAndFlush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.write (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeWriteAndFlush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush0 (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/ChannelOutboundHandlerAdapter.flush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.flush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush0 (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline$HeadContext.flush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel$AbstractUnsafe.flush (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollChannel$AbstractEpollUnsafe.flush0 (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel$AbstractUnsafe.flush0 (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.doWrite (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.doWriteMultiple (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.writeBytesMultiple (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline.fireChannelReadComplete (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelReadComplete (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeChannelReadComplete (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollChannel.doReadBytes (4 samples, 0.06%)
org/apache/flink/shaded/netty4/io/netty/channel/unix/FileDescriptor.readAddress (4 samples, 0.06%)
org/apache/flink/shaded/netty4/io/netty/channel/unix/FileDescriptor.readAddress (4 samples, 0.06%)
__read (4 samples, 0.06%)
entry_SYSCALL_64_after_hwframe (4 samples, 0.06%)
do_syscall_64 (4 samples, 0.06%)
sys_read (4 samples, 0.06%)
vfs_read (2 samples, 0.03%)
__vfs_read (2 samples, 0.03%)
sock_read_iter (2 samples, 0.03%)
inet_recvmsg (2 samples, 0.03%)
tcp_recvmsg (2 samples, 0.03%)
skb_copy_datagram_iter (2 samples, 0.03%)
copy_page_to_iter (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/EpollRecvByteAllocatorHandle.allocate (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultMaxMessagesRecvByteBufAllocator$MaxMessageHandle.allocate (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/channel/unix/PreferredDirectByteBufAllocator.ioBuffer (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/buffer/AbstractByteBufAllocator.directBuffer (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/buffer/AbstractByteBufAllocator.directBuffer (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/buffer/PooledByteBufAllocator.newDirectBuffer (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/util/concurrent/SingleThreadEventExecutor.runAllTasks (50 samples, 0.74%)
org/apache/flink/shaded/netty4/io/netty/util/concurrent/AbstractEventExecutor.safeExecute (47 samples, 0.69%)
org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler$$Lambda$824/1717456313.run (19 samples, 0.28%)
org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.lambda$notifyCreditAvailable$0 (19 samples, 0.28%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline.fireUserEventTriggered (19 samples, 0.28%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (19 samples, 0.28%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (19 samples, 0.28%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline$HeadContext.userEventTriggered (19 samples, 0.28%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.fireUserEventTriggered (19 samples, 0.28%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (19 samples, 0.28%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (19 samples, 0.28%)
org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.userEventTriggered (18 samples, 0.26%)
org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.writeAndFlushNextMessageIfPossible (18 samples, 0.26%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel.writeAndFlush (18 samples, 0.26%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline.writeAndFlush (18 samples, 0.26%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.writeAndFlush (18 samples, 0.26%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.writeAndFlush (18 samples, 0.26%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.write (18 samples, 0.26%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeWriteAndFlush (18 samples, 0.26%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush0 (15 samples, 0.22%)
org/apache/flink/shaded/netty4/io/netty/channel/ChannelOutboundHandlerAdapter.flush (15 samples, 0.22%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.flush (15 samples, 0.22%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush (15 samples, 0.22%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush0 (15 samples, 0.22%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline$HeadContext.flush (15 samples, 0.22%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel$AbstractUnsafe.flush (15 samples, 0.22%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollChannel$AbstractEpollUnsafe.flush0 (14 samples, 0.21%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel$AbstractUnsafe.flush0 (14 samples, 0.21%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.doWrite (14 samples, 0.21%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.doWriteSingle (14 samples, 0.21%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.writeBytes (14 samples, 0.21%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollChannel.doWriteBytes (14 samples, 0.21%)
org/apache/flink/shaded/netty4/io/netty/channel/unix/FileDescriptor.writeAddress (13 samples, 0.19%)
org/apache/flink/shaded/netty4/io/netty/channel/unix/FileDescriptor.writeAddress (13 samples, 0.19%)
write (13 samples, 0.19%)
entry_SYSCALL_64_after_hwframe (11 samples, 0.16%)
do_syscall_64 (11 samples, 0.16%)
sys_write (10 samples, 0.15%)
vfs_write (9 samples, 0.13%)
__vfs_write (9 samples, 0.13%)
sock_write_iter (8 samples, 0.12%)
sock_sendmsg (8 samples, 0.12%)
tcp_sendmsg (8 samples, 0.12%)
tcp_sendmsg_locked (8 samples, 0.12%)
__tcp_push_pending_frames (5 samples, 0.07%)
tcp_write_xmit (5 samples, 0.07%)
__tcp_transmit_skb (5 samples, 0.07%)
ip_queue_xmit (5 samples, 0.07%)
ip_local_out (2 samples, 0.03%)
__ip_local_out (2 samples, 0.03%)
nf_hook_slow (2 samples, 0.03%)
nf_conntrack_in?[nf_conntrack] (2 samples, 0.03%)
ip_output (3 samples, 0.04%)
ip_finish_output2 (3 samples, 0.04%)
__dev_queue_xmit (3 samples, 0.04%)
sch_direct_xmit (3 samples, 0.04%)
dev_hard_start_xmit (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeWrite0 (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/NettyMessage$NettyMessageEncoder.write (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/NettyMessage$AddCredit.write (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue$$Lambda$634/1669062237.run (27 samples, 0.40%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.lambda$notifyReaderNonEmpty$0 (27 samples, 0.40%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline.fireUserEventTriggered (27 samples, 0.40%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (27 samples, 0.40%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (27 samples, 0.40%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline$HeadContext.userEventTriggered (26 samples, 0.38%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.fireUserEventTriggered (25 samples, 0.37%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (25 samples, 0.37%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (25 samples, 0.37%)
org/apache/flink/shaded/netty4/io/netty/handler/codec/ByteToMessageDecoder.userEventTriggered (25 samples, 0.37%)
org/apache/flink/shaded/netty4/io/netty/channel/ChannelInboundHandlerAdapter.userEventTriggered (24 samples, 0.35%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.fireUserEventTriggered (24 samples, 0.35%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (24 samples, 0.35%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeUserEventTriggered (24 samples, 0.35%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.userEventTriggered (24 samples, 0.35%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.enqueueAvailableReader (24 samples, 0.35%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.writeAndFlushNextMessageIfPossible (24 samples, 0.35%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel.writeAndFlush (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline.writeAndFlush (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.writeAndFlush (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.writeAndFlush (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.write (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeWriteAndFlush (23 samples, 0.34%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush0 (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/ChannelOutboundHandlerAdapter.flush (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.flush (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeFlush0 (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/DefaultChannelPipeline$HeadContext.flush (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel$AbstractUnsafe.flush (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollChannel$AbstractEpollUnsafe.flush0 (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannel$AbstractUnsafe.flush0 (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.doWrite (20 samples, 0.29%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.doWriteMultiple (19 samples, 0.28%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/AbstractEpollStreamChannel.writeBytesMultiple (18 samples, 0.26%)
org/apache/flink/shaded/netty4/io/netty/channel/unix/FileDescriptor.writevAddresses (16 samples, 0.24%)
org/apache/flink/shaded/netty4/io/netty/channel/unix/FileDescriptor.writevAddresses (16 samples, 0.24%)
__writev (16 samples, 0.24%)
entry_SYSCALL_64_after_hwframe (15 samples, 0.22%)
do_syscall_64 (15 samples, 0.22%)
do_writev (15 samples, 0.22%)
vfs_writev (15 samples, 0.22%)
do_iter_write (14 samples, 0.21%)
do_iter_readv_writev (14 samples, 0.21%)
sock_write_iter (14 samples, 0.21%)
sock_sendmsg (14 samples, 0.21%)
tcp_sendmsg (14 samples, 0.21%)
tcp_sendmsg_locked (13 samples, 0.19%)
__tcp_push_pending_frames (9 samples, 0.13%)
tcp_write_xmit (9 samples, 0.13%)
__tcp_transmit_skb (7 samples, 0.10%)
ip_queue_xmit (5 samples, 0.07%)
ip_output (5 samples, 0.07%)
ip_finish_output2 (4 samples, 0.06%)
__dev_queue_xmit (4 samples, 0.06%)
netdev_pick_tx (2 samples, 0.03%)
sch_direct_xmit (2 samples, 0.03%)
dev_hard_start_xmit (2 samples, 0.03%)
ena_start_xmit?[ena] (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.invokeWrite0 (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/NettyMessage$NettyMessageEncoder.write (3 samples, 0.04%)
org/apache/flink/runtime/io/network/netty/NettyMessage$BufferResponse.write (3 samples, 0.04%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.write (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/channel/AbstractChannelHandlerContext.write (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/util/concurrent/SingleThreadEventExecutor.pollTask (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/util/concurrent/SingleThreadEventExecutor.pollTaskFrom (2 samples, 0.03%)
org/apache/flink/shaded/netty4/io/netty/util/internal/shaded/org/jctools/queues/MpscUnboundedArrayQueue.poll (2 samples, 0.03%)
java/lang/ref/Reference$ReferenceHandler.run (2 samples, 0.03%)
java/lang/ref/Reference.tryHandlePending (2 samples, 0.03%)
java/lang/ref/ReferenceQueue.enqueue (2 samples, 0.03%)
java/lang/Object.notifyAll (2 samples, 0.03%)
malloc (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter$OutputFlusher.run (266 samples, 3.91%)
org/..
java/lang/Thread.sleep (51 samples, 0.75%)
JVM_Sleep (4 samples, 0.06%)
os::sleep(Thread*, long, bool) (4 samples, 0.06%)
__lll_unlock_wake (2 samples, 0.03%)
[unknown] (6 samples, 0.09%)
clock_gettime (6 samples, 0.09%)
__vdso_clock_gettime (6 samples, 0.09%)
__pthread_cond_timedwait (10 samples, 0.15%)
entry_SYSCALL_64_after_hwframe (9 samples, 0.13%)
do_syscall_64 (9 samples, 0.13%)
sys_futex (7 samples, 0.10%)
do_futex (6 samples, 0.09%)
futex_wait (6 samples, 0.09%)
futex_wait_queue_me (4 samples, 0.06%)
schedule (4 samples, 0.06%)
__sched_text_start (4 samples, 0.06%)
finish_task_switch (4 samples, 0.06%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.flushAll (215 samples, 3.16%)
org..
org/apache/flink/runtime/io/network/partition/PipelinedResultPartition.flushAll (213 samples, 3.13%)
org..
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.flushAllSubpartitions (213 samples, 3.13%)
org..
org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.flush (213 samples, 3.13%)
org..
org/apache/flink/runtime/io/network/buffer/BufferConsumer.isDataAvailable (5 samples, 0.07%)
org/apache/flink/runtime/io/network/buffer/BufferConsumer$CachedPositionMarker.access$200 (5 samples, 0.07%)
org/apache/flink/runtime/io/network/buffer/BufferConsumer$CachedPositionMarker.getLatest (5 samples, 0.07%)
org/apache/flink/runtime/io/network/buffer/BufferBuilder$PositionMarker.getAbsolute (5 samples, 0.07%)
org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.notifyDataAvailable (201 samples, 2.96%)
or..
org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.notifyDataAvailable (201 samples, 2.96%)
or..
org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.notifyDataAvailable (4 samples, 0.06%)
org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.notifyReaderNonEmpty (4 samples, 0.06%)
org/apache/flink/shaded/netty4/io/netty/util/concurrent/SingleThreadEventExecutor.execute (4 samples, 0.06%)
org/apache/flink/shaded/netty4/io/netty/util/concurrent/SingleThreadEventExecutor.execute (4 samples, 0.06%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/EpollEventLoop.wakeup (4 samples, 0.06%)
org/apache/flink/shaded/netty4/io/netty/channel/epoll/Native.eventFdWrite (3 samples, 0.04%)
org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.notifyDataAvailable (5 samples, 0.07%)
org/apache/flink/runtime/io/network/partition/consumer/InputChannel.notifyChannelNonEmpty (5 samples, 0.07%)
org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.notifyChannelNonEmpty (5 samples, 0.07%)
org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.queueChannel (5 samples, 0.07%)
org/apache/flink/runtime/io/network/partition/consumer/GateNotificationHelper.close (3 samples, 0.04%)
java/util/concurrent/CompletableFuture.complete (3 samples, 0.04%)
java/util/concurrent/CompletableFuture.postComplete (3 samples, 0.04%)
java/util/concurrent/CompletableFuture$UniRun.tryFire (3 samples, 0.04%)
java/util/concurrent/CompletableFuture.uniRun (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/StreamTask$ResumeWrapper.run (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor$DefaultActionSuspension.resume (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.access$200 (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.sendControlMail (3 samples, 0.04%)
org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.putFirst (3 samples, 0.04%)
java/util/concurrent/locks/ReentrantLock.unlock (3 samples, 0.04%)
java/util/concurrent/locks/AbstractQueuedSynchronizer.release (3 samples, 0.04%)
java/util/concurrent/locks/AbstractQueuedSynchronizer.unparkSuccessor (3 samples, 0.04%)
java/util/concurrent/locks/LockSupport.unpark (3 samples, 0.04%)
sun/misc/Unsafe.unpark (3 samples, 0.04%)
org/apache/flink/runtime/io/network/partition/consumer/GateNotificationHelper.notifyDataAvailable (2 samples, 0.03%)
java/lang/Object.notifyAll (2 samples, 0.03%)
org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.run (53 samples, 0.78%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/KafkaConsumer.poll (53 samples, 0.78%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/KafkaConsumer.poll (53 samples, 0.78%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/KafkaConsumer.pollForFetches (47 samples, 0.69%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.poll (36 samples, 0.53%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.poll (36 samples, 0.53%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/NetworkClient.poll (25 samples, 0.37%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/Selector.poll (22 samples, 0.32%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/Selector.pollSelectionKeys (15 samples, 0.22%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/KafkaChannel.write (10 samples, 0.15%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/KafkaChannel.send (10 samples, 0.15%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/ByteBufferSend.writeTo (10 samples, 0.15%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/SslTransportLayer.write (10 samples, 0.15%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/SslTransportLayer.write (10 samples, 0.15%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/SslTransportLayer.write (10 samples, 0.15%)
javax/net/ssl/SSLEngine.wrap (4 samples, 0.06%)
sun/security/ssl/SSLEngineImpl.wrap (4 samples, 0.06%)
sun/security/ssl/SSLEngineImpl.wrap (4 samples, 0.06%)
sun/security/ssl/SSLEngineImpl.writeRecord (4 samples, 0.06%)
sun/security/ssl/SSLEngineImpl.encode (3 samples, 0.04%)
sun/security/ssl/SSLEngineOutputRecord.encode (3 samples, 0.04%)
sun/security/ssl/SSLEngineOutputRecord.encode (3 samples, 0.04%)
sun/security/ssl/OutputRecord.encrypt (3 samples, 0.04%)
sun/security/ssl/OutputRecord.t10Encrypt (3 samples, 0.04%)
sun/security/ssl/SSLCipher$T12GcmWriteCipherGenerator$GcmWriteCipher.encrypt (3 samples, 0.04%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/SslTransportLayer.flush (6 samples, 0.09%)
sun/nio/ch/SocketChannelImpl.write (6 samples, 0.09%)
sun/nio/ch/IOUtil.write (6 samples, 0.09%)
sun/nio/ch/IOUtil.writeFromNativeBuffer (5 samples, 0.07%)
sun/nio/ch/SocketDispatcher.write (5 samples, 0.07%)
sun/nio/ch/FileDispatcherImpl.write0 (5 samples, 0.07%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/Selector$SelectorMetrics.recordBytesSent (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/metrics/Sensor.record (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/metrics/Sensor.record (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/metrics/stats/Meter.record (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/metrics/stats/Rate.record (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/Selector.attemptRead (3 samples, 0.04%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/KafkaChannel.read (3 samples, 0.04%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/KafkaChannel.receive (3 samples, 0.04%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/NetworkReceive.readFrom (3 samples, 0.04%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/SslTransportLayer.read (3 samples, 0.04%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/SslTransportLayer.readFromSocketChannel (2 samples, 0.03%)
sun/nio/ch/SocketChannelImpl.read (2 samples, 0.03%)
sun/nio/ch/IOUtil.read (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/network/Selector.select (5 samples, 0.07%)
sun/nio/ch/SelectorImpl.select (5 samples, 0.07%)
sun/nio/ch/SelectorImpl.lockAndDoSelect (5 samples, 0.07%)
sun/nio/ch/EPollSelectorImpl.doSelect (5 samples, 0.07%)
sun/nio/ch/EPollArrayWrapper.poll (5 samples, 0.07%)
sun/nio/ch/EPollArrayWrapper.epollWait (3 samples, 0.04%)
sun/nio/ch/EPollArrayWrapper.updateRegistrations (2 samples, 0.03%)
sun/nio/ch/EPollArrayWrapper.epollCtl (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/KafkaConsumer$$Lambda$821/1814547044.shouldBlock (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/KafkaConsumer.lambda$pollForFetches$1 (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/Fetcher.hasAvailableFetches (2 samples, 0.03%)
java/util/stream/ReferencePipeline.anyMatch (2 samples, 0.03%)
java/util/stream/AbstractPipeline.evaluate (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.trySend (9 samples, 0.13%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/NetworkClient.send (8 samples, 0.12%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/NetworkClient.doSend (8 samples, 0.12%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/NetworkClient.doSend (8 samples, 0.12%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/requests/AbstractRequest.toSend (8 samples, 0.12%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/requests/AbstractRequest.serialize (8 samples, 0.12%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/requests/FetchRequest.toStruct (3 samples, 0.04%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/protocol/types/Struct.setIfExists (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/protocol/types/Struct.setIfExists (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/protocol/types/Schema.get (2 samples, 0.03%)
java/util/HashMap.get (2 samples, 0.03%)
java/util/HashMap.getNode (2 samples, 0.03%)
java/util/HashMap$TreeNode.getTreeNode (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/requests/RequestUtils.serialize (5 samples, 0.07%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/protocol/types/Struct.writeTo (4 samples, 0.06%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/protocol/types/Schema.write (4 samples, 0.06%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/protocol/types/Type$10.write (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/common/utils/Utils.utf8 (2 samples, 0.03%)
java/lang/String.getBytes (2 samples, 0.03%)
java/lang/StringCoding.encode (2 samples, 0.03%)
sun/nio/cs/UTF_8.newEncoder (2 samples, 0.03%)
sun/nio/cs/UTF_8$Encoder.<init> (2 samples, 0.03%)
sun/nio/cs/UTF_8$Encoder.<init> (2 samples, 0.03%)
java/nio/charset/CharsetEncoder.<init> (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/Fetcher.fetchedRecords (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/Fetcher.fetchRecords (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/Fetcher.sendFetches (9 samples, 0.13%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/Fetcher.prepareFetchRequests (9 samples, 0.13%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/FetchSessionHandler$Builder.build (3 samples, 0.04%)
java/util/LinkedHashMap.<init> (3 samples, 0.04%)
java/util/HashMap.putMapEntries (3 samples, 0.04%)
java/util/HashMap.putVal (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/Fetcher.fetchablePartitions (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/SubscriptionState.fetchablePartitions (2 samples, 0.03%)
java/util/stream/ReferencePipeline.collect (2 samples, 0.03%)
java/util/stream/AbstractPipeline.evaluate (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/KafkaConsumer.updateAssignmentMetadataIfNeeded (6 samples, 0.09%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/KafkaConsumer.updateFetchPositions (6 samples, 0.09%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/Fetcher.validateOffsetsIfNeeded (4 samples, 0.06%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/SubscriptionState.partitionsNeedingValidation (3 samples, 0.04%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/SubscriptionState.collectPartitions (3 samples, 0.04%)
java/util/stream/ReferencePipeline.collect (3 samples, 0.04%)
java/util/stream/AbstractPipeline.evaluate (3 samples, 0.04%)
java/util/stream/ReduceOps$ReduceOp.evaluateSequential (3 samples, 0.04%)
java/util/stream/AbstractPipeline.wrapAndCopyInto (3 samples, 0.04%)
java/util/stream/AbstractPipeline.copyInto (3 samples, 0.04%)
java/util/stream/Sink$ChainedReference.end (2 samples, 0.03%)
java/util/stream/Sink$ChainedReference.end (2 samples, 0.03%)
org/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/internals/SubscriptionState.hasAllFetchPositions (2 samples, 0.03%)
java/util/stream/ReferencePipeline.allMatch (2 samples, 0.03%)
org/apache/flink/streaming/runtime/tasks/SourceStreamTask$LegacySourceFunctionThread.run (315 samples, 4.63%)
org/a..
org/apache/flink/streaming/api/operators/StreamSource.run (315 samples, 4.63%)
org/a..
org/apache/flink/streaming/api/operators/StreamSource.run (315 samples, 4.63%)
org/a..
org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.run (315 samples, 4.63%)
org/a..
org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.runFetchLoop (315 samples, 4.63%)
org/a..
org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.partitionConsumerRecordsHandler (315 samples, 4.63%)
org/a..
org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.emitRecordsWithTimestamps (19 samples, 0.28%)
org/apache/flink/streaming/api/operators/StreamSourceContexts$NonTimestampContext.collectWithTimestamp (18 samples, 0.26%)
org/apache/flink/streaming/api/operators/StreamSourceContexts$NonTimestampContext.collect (18 samples, 0.26%)
SharedRuntime::complete_monitor_locking_C(oopDesc*, BasicLock*, JavaThread*) (2 samples, 0.03%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (16 samples, 0.24%)
org/apache/flink/streaming/api/operators/CountingOutput.collect (16 samples, 0.24%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (16 samples, 0.24%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.collect (16 samples, 0.24%)
org/apache/flink/streaming/runtime/io/RecordWriterOutput.pushToRecordWriter (16 samples, 0.24%)
org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.emit (16 samples, 0.24%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.emit (15 samples, 0.22%)
org/apache/flink/runtime/io/network/api/writer/RecordWriter.serializeRecord (12 samples, 0.18%)
org/apache/flink/runtime/plugable/SerializationDelegate.write (12 samples, 0.18%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (12 samples, 0.18%)
org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.serialize (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.serialize (12 samples, 0.18%)
org/apache/flink/table/runtime/typeutils/RowDataSerializer.toBinaryRow (12 samples, 0.18%)
itable stub (3 samples, 0.04%)
org/apache/flink/table/data/RowData$$Lambda$282/25672700.getFieldOrNull (6 samples, 0.09%)
org/apache/flink/table/data/RowData.lambda$createFieldGetter$25774257$1 (5 samples, 0.07%)
org/apache/flink/table/data/writer/BinaryWriter.write (3 samples, 0.04%)
org/apache/flink/table/data/writer/BinaryRowWriter.writeString (2 samples, 0.03%)
org/apache/flink/table/data/writer/AbstractBinaryWriter.writeString (2 samples, 0.03%)
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.emitRecord (3 samples, 0.04%)
org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.finishUnicastBufferBuilder (2 samples, 0.03%)
org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.deserialize (295 samples, 4.34%)
org/a..
org/apache/flink/api/common/serialization/DeserializationSchema.deserialize (295 samples, 4.34%)
org/a..
org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.deserialize (294 samples, 4.32%)
org/a..
org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.deserialize (294 samples, 4.32%)
org/a..
org/apache/flink/formats/avro/AvroToRowDataConverters$$Lambda$313/1073631524.convert (2 samples, 0.03%)
org/apache/flink/formats/avro/AvroToRowDataConverters.lambda$createRowConverter$482848eb$1 (2 samples, 0.03%)
org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.deserialize (291 samples, 4.28%)
org/a..
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.read (114 samples, 1.68%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.getResolver (100 samples, 1.47%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.applyAliases (9 samples, 0.13%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$RecordSchema.equals (2 samples, 0.03%)
java/util/Objects.equals (2 samples, 0.03%)
java/util/AbstractList.equals (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getAliases (7 samples, 0.10%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getAliases (5 samples, 0.07%)
org/apache/flink/avro/shaded/org/apache/avro/io/DecoderFactory.resolvingDecoder (84 samples, 1.23%)
org/apache/flink/avro/shaded/org/apache/avro/io/ResolvingDecoder.<init> (84 samples, 1.23%)
org/apache/flink/avro/shaded/org/apache/avro/io/ResolvingDecoder.resolve (84 samples, 1.23%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/ResolvingGrammarGenerator.generate (84 samples, 1.23%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver.resolve (30 samples, 0.44%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver.resolve (30 samples, 0.44%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver.resolve (26 samples, 0.38%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver$RecordAdjust.resolve (26 samples, 0.38%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver.access$000 (8 samples, 0.12%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver.resolve (6 samples, 0.09%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver$WriterUnion.resolve (5 samples, 0.07%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver.access$000 (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver.resolve (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/Resolver$Promote.resolve (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$RecordSchema.getField (9 samples, 0.13%)
java/util/HashMap.get (9 samples, 0.13%)
java/util/HashMap.getNode (9 samples, 0.13%)
java/util/HashMap$TreeNode.getTreeNode (8 samples, 0.12%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericData.getDefaultValue (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.applyAliases (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getAliases (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getAliases (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getAliases (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/ResolvingGrammarGenerator.generate (16 samples, 0.24%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/ResolvingGrammarGenerator.generate (15 samples, 0.22%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/ResolvingGrammarGenerator.simpleGen (14 samples, 0.21%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getFullName (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/ResolvingGrammarGenerator.simpleGen (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol.root (38 samples, 0.56%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Root.<init> (38 samples, 0.56%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Root.<init> (38 samples, 0.56%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Root.makeProduction (38 samples, 0.56%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol.flatten (36 samples, 0.53%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Sequence.flatten (36 samples, 0.53%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Sequence.flatten (36 samples, 0.53%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol.flatten (34 samples, 0.50%)
java/util/HashMap.get (2 samples, 0.03%)
java/util/HashMap.getNode (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Sequence.flatten (28 samples, 0.41%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Sequence.flatten (28 samples, 0.41%)
java/util/HashMap.get (6 samples, 0.09%)
java/util/HashMap.getNode (3 samples, 0.04%)
java/util/HashMap$TreeNode.getTreeNode (2 samples, 0.03%)
java/util/HashMap.hash (3 samples, 0.04%)
java/lang/Object.hashCode (3 samples, 0.04%)
JVM_IHashCode (3 samples, 0.04%)
ObjectSynchronizer::FastHashCode(Thread*, oopDesc*) (3 samples, 0.04%)
java/util/HashMap.put (11 samples, 0.16%)
java/util/HashMap.hash (5 samples, 0.07%)
java/lang/Object.hashCode (5 samples, 0.07%)
JVM_IHashCode (4 samples, 0.06%)
ObjectSynchronizer::FastHashCode(Thread*, oopDesc*) (3 samples, 0.04%)
BiasedLocking::revoke_and_rebias(Handle, bool, Thread*) (3 samples, 0.04%)
java/util/HashMap.putVal (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol.flatten (10 samples, 0.15%)
java/util/HashMap.get (3 samples, 0.04%)
java/util/HashMap.getNode (3 samples, 0.04%)
java/util/HashMap$TreeNode.getTreeNode (3 samples, 0.04%)
vtable stub (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Alternative.flatten (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Alternative.flatten (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Sequence.flatten (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/io/parsing/Symbol$Sequence.flatten (4 samples, 0.06%)
java/util/HashMap.get (2 samples, 0.03%)
java/util/HashMap.getNode (2 samples, 0.03%)
java/util/HashMap$TreeNode.getTreeNode (2 samples, 0.03%)
java/util/HashMap.put (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/util/WeakIdentityHashMap.get (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/util/WeakIdentityHashMap.reap (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/util/WeakIdentityHashMap.put (3 samples, 0.04%)
java/util/HashMap.put (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.read (13 samples, 0.19%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.readWithoutConversion (13 samples, 0.19%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.readRecord (12 samples, 0.18%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.readField (9 samples, 0.13%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.read (8 samples, 0.12%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.readWithoutConversion (8 samples, 0.12%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.read (7 samples, 0.10%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.readWithoutConversion (7 samples, 0.10%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.readString (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/generic/GenericDatumReader.readString (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/io/ResolvingDecoder.readString (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/io/BinaryDecoder.readString (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/io/BinaryDecoder.readLong (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/io/BinaryDecoder.ensureBounds (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/io/BinaryDecoder$ByteSource.compactAndFill (3 samples, 0.04%)
org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSchemaCoder.readSchema (177 samples, 2.60%)
or..
org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryInputStreamDeserializer.getSchemaAndDeserializedStream (177 samples, 2.60%)
or..
com/amazonaws/services/schemaregistry/deserializers/AWSDeserializer.getSchema (3 samples, 0.04%)
com/amazonaws/services/schemaregistry/deserializers/AWSDeserializer.getAwsDeserializerSchema (3 samples, 0.04%)
com/amazonaws/services/schemaregistry/deserializers/AWSDeserializer.retrieveSchemaRegistrySchema (3 samples, 0.04%)
com/amazonaws/services/schemaregistry/caching/AWSSchemaRegistryDeserializerCache.get (3 samples, 0.04%)
com/amazonaws/services/schemaregistry/caching/AWSSchemaRegistryDeserializerCache.get (3 samples, 0.04%)
org/apache/flink/avro/gsr/shaded/com/google/common/cache/LocalCache$LocalManualCache.getIfPresent (3 samples, 0.04%)
org/apache/flink/avro/gsr/shaded/com/google/common/cache/LocalCache.getIfPresent (3 samples, 0.04%)
org/apache/flink/avro/gsr/shaded/com/google/common/cache/LocalCache$Segment.get (2 samples, 0.03%)
org/apache/flink/avro/gsr/shaded/com/google/common/cache/LocalCache$Segment.recordRead (2 samples, 0.03%)
java/util/concurrent/ConcurrentLinkedQueue.add (2 samples, 0.03%)
java/util/concurrent/ConcurrentLinkedQueue.offer (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$Parser.parse (173 samples, 2.54%)
or..
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/JsonFactory.createParser (5 samples, 0.07%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/JsonFactory._createContext (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/JsonFactory._getBufferRecycler (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$Parser.parse (168 samples, 2.47%)
or..
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/ObjectMapper.readTree (93 samples, 1.37%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/ObjectMapper._readValue (93 samples, 1.37%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/deser/DefaultDeserializationContext.readRootValue (93 samples, 1.37%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/deser/std/JsonNodeDeserializer.deserialize (93 samples, 1.37%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/deser/std/JsonNodeDeserializer.deserialize (93 samples, 1.37%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/deser/std/BaseNodeDeserializer.deserializeObject (93 samples, 1.37%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser.nextFieldName (2 samples, 0.03%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/deser/std/BaseNodeDeserializer.deserializeArray (90 samples, 1.32%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/deser/std/BaseNodeDeserializer.deserializeObject (89 samples, 1.31%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser.getText (7 samples, 0.10%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser._finishString (7 samples, 0.10%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/util/TextBuffer.resetWithShared (7 samples, 0.10%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser.nextFieldName (28 samples, 0.41%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser._parseName (10 samples, 0.15%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/sym/CharsToNameCanonicalizer.findSymbol (10 samples, 0.15%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser._skipComma (7 samples, 0.10%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser._skipWSOrEnd (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/deser/std/BaseNodeDeserializer.deserializeArray (30 samples, 0.44%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser.getText (5 samples, 0.07%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser._finishString (5 samples, 0.07%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/util/TextBuffer.resetWithShared (5 samples, 0.07%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser.nextToken (16 samples, 0.24%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser._skipComma (9 samples, 0.13%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/core/json/ReaderBasedJsonParser._skipWSOrEnd (7 samples, 0.10%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/JsonNodeFactory.textNode (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/TextNode.valueOf (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/TextNode.<init> (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/ValueNode.<init> (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/BaseJsonNode.<init> (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/JsonNode.<init> (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/JsonSerializable$Base.<init> (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/ObjectNode.replace (12 samples, 0.18%)
java/util/HashMap.put (11 samples, 0.16%)
java/util/HashMap.putVal (11 samples, 0.16%)
java/util/HashMap.resize (3 samples, 0.04%)
java/util/LinkedHashMap.newNode (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.parse (74 samples, 1.09%)
java/util/Collections$UnmodifiableCollection.contains (2 samples, 0.03%)
java/util/HashSet.contains (2 samples, 0.03%)
java/util/HashMap.containsKey (2 samples, 0.03%)
java/util/HashMap.getNode (2 samples, 0.03%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/ArrayNode.getNodeType (2 samples, 0.03%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/ObjectNode.get (2 samples, 0.03%)
java/util/LinkedHashMap.get (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$Field.<init> (13 samples, 0.19%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.access$500 (13 samples, 0.19%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.validateDefault (13 samples, 0.19%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$RecordSchema.setFields (8 samples, 0.12%)
java/util/HashMap.put (6 samples, 0.09%)
java/util/HashMap.putVal (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getOptionalText (2 samples, 0.03%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/ObjectNode.get (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getRequiredText (3 samples, 0.04%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.getOptionalText (3 samples, 0.04%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/ObjectNode.get (3 samples, 0.04%)
java/util/LinkedHashMap.get (2 samples, 0.03%)
java/util/HashMap.getNode (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.parse (35 samples, 0.51%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$UnionSchema.<init> (8 samples, 0.12%)
java/util/HashMap.put (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.parse (19 samples, 0.28%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$Names.get (18 samples, 0.26%)
java/util/HashMap.get (9 samples, 0.13%)
java/util/HashMap.getNode (9 samples, 0.13%)
java/lang/String.equals (4 samples, 0.06%)
java/util/HashMap$TreeNode.getTreeNode (4 samples, 0.06%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.create (9 samples, 0.13%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$DoubleSchema.<init> (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.<init> (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/JsonProperties.<init> (2 samples, 0.03%)
org/apache/flink/avro/shaded/org/apache/avro/Schema$NullSchema.<init> (6 samples, 0.09%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.<init> (6 samples, 0.09%)
org/apache/flink/avro/shaded/org/apache/avro/JsonProperties.<init> (6 samples, 0.09%)
org/apache/flink/avro/shaded/org/apache/avro/Schema.parseAliases (2 samples, 0.03%)
org/apache/flink/avro/shaded/com/fasterxml/jackson/databind/node/ObjectNode.get (2 samples, 0.03%)
java/util/LinkedHashMap.get (2 samples, 0.03%)
java/util/HashMap.getNode (2 samples, 0.03%)
start_thread (146 samples, 2.15%)
s..
java_start(Thread*) (146 samples, 2.15%)
j..
ConcurrentG1RefineThread::run() (13 samples, 0.19%)
ConcurrentG1RefineThread::run_young_rs_sampling() (2 samples, 0.03%)
YoungList::rs_length_sampling_next() (2 samples, 0.03%)
DirtyCardQueueSet::apply_closure_to_completed_buffer(CardTableEntryClosure*, unsigned int, int, bool) (11 samples, 0.16%)
RefineCardTableEntryClosure::do_card_ptr(signed char*, unsigned int) (11 samples, 0.16%)
G1RemSet::refine_card(signed char*, unsigned int, bool) [clone .part.72] (11 samples, 0.16%)
HeapRegion::oops_on_card_seq_iterate_careful(MemRegion, FilterOutOfRegionClosure*, bool, signed char*) (11 samples, 0.16%)
G1BlockOffsetArray::forward_to_block_containing_addr_slow(HeapWord*, HeapWord*, void const*) (3 samples, 0.04%)
G1UpdateRSOrPushRefOopClosure::do_oop(unsigned int*) (2 samples, 0.03%)
InstanceKlass::oop_oop_iterate_nv(oopDesc*, FilterOutOfRegionClosure*) (2 samples, 0.03%)
OtherRegionsTable::add_reference(void*, int) (2 samples, 0.03%)
GangWorker::loop() (131 samples, 1.93%)
G..
G1ParTask::work(unsigned int) (131 samples, 1.93%)
G..
G1ParEvacuateFollowersClosure::do_void() (120 samples, 1.76%)
G1ParScanThreadState::trim_queue() (117 samples, 1.72%)
G1ParScanThreadState::copy_to_survivor_space(InCSetState, oopDesc*, markOopDesc*) (67 samples, 0.99%)
G1ParScanClosure::do_oop(unsigned int*) (2 samples, 0.03%)
InstanceKlass::oop_oop_iterate_backwards_nv(oopDesc*, G1ParScanClosure*) (15 samples, 0.22%)
void G1ParScanClosure::do_oop_nv<unsigned int>(unsigned int*) (11 samples, 0.16%)
InstanceRefKlass::oop_oop_iterate_backwards_nv(oopDesc*, G1ParScanClosure*) (2 samples, 0.03%)
ObjArrayKlass::oop_oop_iterate_v(oopDesc*, ExtendedOopClosure*) (12 samples, 0.18%)
G1ParScanClosure::do_oop(unsigned int*) (5 samples, 0.07%)
G1SATBCardTableModRefBS::mark_card_deferred(unsigned long) (2 samples, 0.03%)
objArrayOopDesc::object_size(int) (3 samples, 0.04%)
void G1ParScanClosure::do_oop_nv<unsigned int>(unsigned int*) (2 samples, 0.03%)
ObjArrayKlass::oop_oop_iterate_range_nv(oopDesc*, G1ParScanClosure*, int, int) (14 samples, 0.21%)
void G1ParScanClosure::do_oop_nv<unsigned int>(unsigned int*) (3 samples, 0.04%)
__memmove_avx_unaligned_erms (5 samples, 0.07%)
void G1ParScanClosure::do_oop_nv<unsigned int>(unsigned int*) (13 samples, 0.19%)
G1RootProcessor::scan_remembered_sets(G1ParPushHeapRSClosure*, OopClosure*, unsigned int) (10 samples, 0.15%)
G1RemSet::oops_into_collection_set_do(G1ParPushHeapRSClosure*, CodeBlobClosure*, unsigned int) (10 samples, 0.15%)
G1CollectedHeap::iterate_dirty_card_closure(CardTableEntryClosure*, DirtyCardQueue*, bool, unsigned int) (9 samples, 0.13%)
DirtyCardQueueSet::apply_closure_to_completed_buffer(CardTableEntryClosure*, unsigned int, int, bool) (9 samples, 0.13%)
RefineRecordRefsIntoCSCardTableEntryClosure::do_card_ptr(signed char*, unsigned int) (9 samples, 0.13%)
G1RemSet::refine_card(signed char*, unsigned int, bool) [clone .part.72] (9 samples, 0.13%)
HeapRegion::oops_on_card_seq_iterate_careful(MemRegion, FilterOutOfRegionClosure*, bool, signed char*) (8 samples, 0.12%)
ObjArrayKlass::oop_oop_iterate_nv(oopDesc*, FilterOutOfRegionClosure*) (2 samples, 0.03%)
ObjArrayKlass::oop_oop_iterate_nv_m(oopDesc*, FilterOutOfRegionClosure*, MemRegion) (2 samples, 0.03%)
VMThread::run() (2 samples, 0.03%)
VMThread::loop() (2 samples, 0.03%)
VMThread::evaluate_operation(VM_Operation*) [clone .constprop.55] (2 samples, 0.03%)
VM_Operation::evaluate() (2 samples, 0.03%)
VM_G1IncCollectionPause::doit() (2 samples, 0.03%)
G1CollectedHeap::do_collection_pause_at_safepoint(double) (2 samples, 0.03%)
G1CollectedHeap::evacuate_collection_set(EvacuationInfo&) (2 samples, 0.03%)
G1CollectedHeap::process_discovered_references(unsigned int) (2 samples, 0.03%)
ReferenceProcessor::process_discovered_references(BoolObjectClosure*, OopClosure*, VoidClosure*, AbstractRefProcTaskExecutor*, GCTimer*, GCId) (2 samples, 0.03%)
ReferenceProcessor::process_discovered_reflist(DiscoveredList*, ReferencePolicy*, bool, BoolObjectClosure*, OopClosure*, VoidClosure*, AbstractRefProcTaskExecutor*) [clone .constprop.46] (2 samples, 0.03%)
ReferenceProcessor::process_phase3(DiscoveredList&, bool, BoolObjectClosure*, OopClosure*, VoidClosure*) (2 samples, 0.03%)
std::string::_M_mutate(unsigned long, unsigned long, unsigned long) (5 samples, 0.07%)
write (12 samples, 0.18%)
entry_SYSCALL_64_after_hwframe (12 samples, 0.18%)
do_syscall_64 (12 samples, 0.18%)
sys_write (12 samples, 0.18%)
vfs_write (12 samples, 0.18%)
__vfs_write (12 samples, 0.18%)
xfs_file_write_iter?[xfs] (12 samples, 0.18%)
xfs_file_buffered_aio_write?[xfs] (12 samples, 0.18%)
iomap_file_buffered_write (12 samples, 0.18%)
iomap_apply (12 samples, 0.18%)
iomap_write_actor (12 samples, 0.18%)
iomap_write_begin.constprop.17 (2 samples, 0.03%)
grab_cache_page_write_begin (2 samples, 0.03%)
pagecache_get_page (2 samples, 0.03%)
add_to_page_cache_lru (2 samples, 0.03%)
__add_to_page_cache_locked (2 samples, 0.03%)
iov_iter_copy_from_user_atomic (9 samples, 0.13%)
copyin (9 samples, 0.13%)
copy_user_enhanced_fast_string (9 samples, 0.13%)