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%)