text:
Neovim 0.10 Compatible Functions Require a Default

Thank you for maintaining this beautiful plugin. With the latest changes I have encountered a tiny bit of error therefore I have opened up this merge request.
It throws errors when the configured formater does not have a default.
   Error  11:10:56 msg_show.lua_error Error detected while processing BufWritePre Autocommands for "*":
11:10:56 msg_show Error executing lua callback: vim/shared.lua:0: src: expected table, got nil
stack traceback:
	[C]: in function 'error'
	vim/shared.lua: in function 'validate'
	vim/shared.lua: in function 'list_extend'
	....local/share/nvim/lazy/conform.nvim/lua/conform/util.lua:142: in function 'computed_args'
	...ocal/share/nvim/lazy/conform.nvim/lua/conform/runner.lua:29: in function 'build_cmd'
	...ocal/share/nvim/lazy/conform.nvim/lua/conform/runner.lua:280: in function 'run_formatter'
	...ocal/share/nvim/lazy/conform.nvim/lua/conform/runner.lua:622: in function 'format_lines_sync'
	...ocal/share/nvim/lazy/conform.nvim/lua/conform/runner.lua:578: in function 'format_sync'
	....local/share/nvim/lazy/conform.nvim/lua/conform/init.lua:451: in function 'format'
	/Users/cenk/.config/nvim/lua/extensions/conform-nvim.lua:85: in function 'format'
	/Users/cenk/.config/nvim/lua/lvim/lsp/format.lua:10: in function </Users/cenk/.config/nvim/lua/lvim/lsp/format.lua:9>

Thanks for the PR!


text:
[Enhancement] Add support for spelling suggestions

I would love if I could use the same pop up selection menu for picking my spelling suggestions via dressing.nivm (z= keymap).

That is an interesting idea. I think this is something that would have to be done in Neovim core, since z= is a built-in keymap. I didn't see any API for fetching spelling suggestions; do you know of any?

Not that I know of.. the closest thing I could find is under vim.spell (at this url, you'll after to ctrl+f, wasn't able to copy link with header).
This file may interest you, or maybe not. I don't know much C and though searching through Neovim's docs  and source code didn't revealed anything to me, I definitely could have missed something.
Maybe you/I could open an issue on core and see if they add an API? Given the size, I  realize if they do decided to do so, it will take a while but could be worth the effort.

That file does indeed look like where the vim.spell.check function is defined. You should open an issue! I think it's a reasonable request to expose spelling suggestions, especially since there's already precedent for putting some spelling API into lua.

Before I open an issue, I remembered that which-key.nvim is able to do spell suggestions. Based on my limited lua knowledge, it seems that it overrides the z= map and then manually calls the vim spell checking on the word. But you can check it out here and see if that is really the case. If so, I'll make an issue, but if I'm wrong there might be some way to access the API that we missed.

Ah, looks like there's a vim function spellsuggest() that does it! Try this:
vim.keymap.set("n", "z=", function()
  local word = vim.fn.expand("<cword>")
  local suggestions = vim.fn.spellsuggest(word)
  vim.ui.select(
    suggestions,
    {},
    vim.schedule_wrap(function(selected)
      if selected then
        vim.api.nvim_feedkeys("ciw" .. selected, "n", true)
        vim.api.nvim_feedkeys(vim.api.nvim_replace_termcodes("<Esc>", true, true, true), "n", true)
      end
    end)
  )
end)

Note that you'll need to update dressing to get this change: b188b7750c78c0dbe0c61d79d824673a53ff82db

That worked, thanks!

You can use this version to include numbers to facilitate the selection.
`vim.keymap.set("n", "z=", function()
local word = vim.fn.expand("")
local suggestions = vim.fn.spellsuggest(word)
-- Create a new list with formatted suggestions
local formatted_suggestions = {}
for i, suggestion in ipairs(suggestions) do
	table.insert(formatted_suggestions, string.format("%d -> %s", i, suggestion))
end

vim.ui.select(
	formatted_suggestions,
	{},
	vim.schedule_wrap(function(selected)
		if selected then
			-- Extract the actual suggestion from the selected string
			local index = tonumber(selected:match("^(%d+)")) -- Get the number at the start
			local actual_suggestion = suggestions[index] -- Get the corresponding suggestion
			vim.api.nvim_feedkeys("ciw" .. actual_suggestion, "n", true)
			vim.api.nvim_feedkeys(vim.api.nvim_replace_termcodes("<Esc>", true, true, true), "n", true)
		end
	end)
)

end)`

source: gharchive/issue

authors: AniAggarwal daibertdiego stevearc

license: MIT

license_type: permissive

license_source: github-api


text:
bug: can not remap key to open split.

Did you check the docs and existing issues?

[X] I have read the docs
[X] I have searched the existing issues

Neovim version (nvim -v)
0.9.2
Operating system/version
wsl2 ubuntu 22.04
Describe the bug
Thank you for the awesome plugin and I like it a lot!
I encounter this problem to remap another key to open my the file selected. In the setup function, I have this
          ["<C-h>"] = false,
          ["<C-e>"] = { "actions.select", opts = { horizontal = true } },
          ["<C-l>"] = false,
          ["<C-r>"] = "actions.refresh",

I can change refresh to ctrl+r but ctrl+e cannot open the file horizontally. I can still use ctrl+s to open file vertically.
Thank you for your attention!
What is the severity of this bug?
minor (annoyance)
Steps To Reproduce
update the config oil.nvim config in lazyvim.
On oil buffer, Press ctrl+e, and Nothing changed!
Expected Behavior
On oil buffer, Press ctrl+e, and open the file horizotally.
Directory structure
No response
Repro
-- save as repro.lua
-- run with nvim -u repro.lua
-- DO NOT change the paths
local root = vim.fn.fnamemodify("./.repro", ":p")

-- set stdpaths to use .repro
for _, name in ipairs({ "config", "data", "state", "runtime", "cache" }) do
  vim.env[("XDG_%s_HOME"):format(name:upper())] = root .. "/" .. name
end

-- bootstrap lazy
local lazypath = root .. "/plugins/lazy.nvim"
if not vim.loop.fs_stat(lazypath) then
  vim.fn.system({
    "git",
    "clone",
    "--filter=blob:none",
    "--single-branch",
    "https://github.com/folke/lazy.nvim.git",
    lazypath,
  })
end
vim.opt.runtimepath:prepend(lazypath)

-- install plugins
local plugins = {
  "folke/tokyonight.nvim",
  {
        "stevearc/oil.nvim",
        config = function()
            require("oil").setup({
              -- add any needed settings here
            })
        end,
  },
  -- add any other plugins here
}
require("lazy").setup(plugins, {
  root = root .. "/plugins",
})

vim.cmd.colorscheme("tokyonight")
-- add anything else here

Did you check the bug with a clean config?

[X] I have confirmed that the bug reproduces with nvim -u repro.lua using the repro.lua file above.

My guess is you have something else overriding your <C-e> binding. I tried it with this minimal repro file and it works fine
-- save as repro.lua
-- run with nvim -u repro.lua
-- DO NOT change the paths
local root = vim.fn.fnamemodify("./.repro", ":p")

-- set stdpaths to use .repro
for _, name in ipairs({ "config", "data", "state", "runtime", "cache" }) do
  vim.env[("XDG_%s_HOME"):format(name:upper())] = root .. "/" .. name
end

-- bootstrap lazy
local lazypath = root .. "/plugins/lazy.nvim"
if not vim.loop.fs_stat(lazypath) then
  vim.fn.system({
    "git",
    "clone",
    "--filter=blob:none",
    "--single-branch",
    "https://github.com/folke/lazy.nvim.git",
    lazypath,
  })
end
vim.opt.runtimepath:prepend(lazypath)

-- install plugins
local plugins = {
  "folke/tokyonight.nvim",
  {
    "stevearc/oil.nvim",
    config = function()
      require("oil").setup({
        keymaps = {
          ["<C-h>"] = false,
          ["<C-e>"] = { "actions.select", opts = { horizontal = true } },
          ["<C-l>"] = false,
          ["<C-r>"] = "actions.refresh",
        },
      })
    end,
  },
  -- add any other plugins here
}
require("lazy").setup(plugins, {
  root = root .. "/plugins",
})

vim.cmd.colorscheme("tokyonight")
-- add anything else here

You can inspect what the keymap for <C-e> is in the oil buffer with :nmap <C-e>.

I have the same issue. I remapped the open in split keybinds to V and H like so:
      ['V'] = { 'actions.select', opts = { vertical = true }, desc = 'Open the entry in a vertical split' },
      ['H'] = { 'actions.select', opts = { horizontal = true }, desc = 'Open the entry in a horizontal split' },

but when I do :map <C-h> I still get
<C-H>       *@<Lua 375: ~/.local/share/nvim/lazy/oil.nvim/lua/oil/keymap_util.lua:42>                                                                                Open the entry in a horizontal split

I'm using kickstart and I added my keybindings to after the custom plugins are loaded but I think because it's lazy loaded it doesn't matter, the oil keybinds still cover my keybinds.

I am having the same issue - I can't figure out how to unbind a key. I use <C-h/j/k/l> to jump between nvim windows. Have tried setting those to nil and false (as in this example) for Oil config, but neither seems to do anything.
Also tysm for this plugin, I am truly loving it!

Please provide a minimal repro file like the one I constructed above that demonstrates the issue

authors: Supetorus lellingsen meicale stevearc


text:
A Git warning occuring only witn PyCall in Pkg.update

I am not sure whether I shall report it here or on JuliaLang/julia.  Recently, when I run Pkg.update(), There is an warning which only exists about PyCall.
julia> Pkg.update()
INFO: Updating METADATA...
INFO: Updating PDMats master...
INFO: Updating Met_Plots_Models master...
WARNING: fetch: GitError(Code:ERROR, Class:Net, Unsupported URL protocol)
INFO: Updating Met_Basic_Types master...
INFO: Updating PyCall master...
WARNING: fetch: GitError(Code:ERROR, Class:Net, Unsupported URL protocol)
INFO: Updating NonlinearSpectralModels master...
INFO: Updating Compose master...
INFO: Updating DataArrays master...
INFO: Updating PyPlot master...
INFO: Updating Gadfly master...
INFO: Updating NetCDF master...
INFO: Updating DataFrames master...
INFO: Computing changes...
INFO: No packages to install, update or remove

The Unsupported URL protocol occurs only with PyCall and another package written for myself...  I am not sure whether there are some git configs in PyCall about this warning
My julia version follows here, and I install the PyCall by Pkg.checkout()
julia> versioninfo()
Julia Version 0.5.0-dev+1165
Commit bbec291 (2015-11-06 20:40 UTC)
Platform Info:
  System: Linux (x86_64-unknown-linux-gnu)
  CPU: Intel(R) Core(TM) i5-5200U CPU @ 2.20GHz
  WORD_SIZE: 64
  BLAS: libopenblas (USE64BITINT DYNAMIC_ARCH NO_AFFINITY Haswell)
  LAPACK: libopenblas64_
  LIBM: libm
  LLVM: libLLVM-3.7.0

Thank you.

The PyCall url is a git:// URL, the same as all other package URLs, so I don't know why there would be a problem only with PyCall.
Does it give a warning if you manually git clone git://github.com/stevengj/PyCall.jl.git, or do a git fetch once it is cloned?

The error disappears after removing and reinstalling PyCall. I think I had made some mistakes about it though I do not know what mistakes I have made.
You can close the issue if you like.  Sorry for wasting your time.

I find how it happens
If I install PyCall with Pkg.add("PyCall"), then the error will not appear.
But if I use Pkg.checkoyt("PyCall"), then the error will appear

Sorry, my mistake.
I find that the error will not occur when I remove all unregistered packages in .julia/v0.5
Sorry for wasting your time.

authors: stevengj zhujinxuan

license: mit

license_source: bigquery


text:
Error in RP-Authentication response-correct-state-value.json

The test is created with a double test suite https://github.com/stfbk/mig/blob/master/testplans/spid-cie-oidc/implementations/spid-cie-oidc-django/input/mig-t/tests/single/RP/RP-Authentication%20response-correct-state-value.json

Closing this issue as it was due tue a typo. The typo has been corrected in the commit b96ead3b63aefc57970a8367792f5415f799140b, which resolves the issue. Thanks for the report.

repo: stfbk/mig


text:
compatibility with recipe stages

can be added compatibility with recipe stages ? for now if put unlocked recipe start crafting but don't make anythings

Heys Alle, IIRC only dynamic mod recipes should need special game-stages integration. The mod uses only the standard recipes, should this not be covered by the game-stages mod/kube/tweaker? Or did I not understand the question correctly (sorry in that case, simply let me know). Cheers,-

the issue is automated crafting with anthillinside, not the recipe

authors: AlleCraft-alterego stfwi

repo: stfwi/anthillinside


text:
Update python-markdown to wikipendium-hosted fork

The new fork includes a fix for incorrect parsing of headers in source-links.

Could you include some pictures to see this effect? I'm not sure what this changes.

Try pressing the edit button on the busy/wait headline:
https://www.wikipendium.no/TDT4258_Energy_Efficient_Computer_Design#busywait
Expected:
The editor will be scrolled down to the busy/wait headline.
Actual:
Scrolls down to the code line starting with #define instead.

https://github.com/wikipendium/Python-Markdown/commit/5e9e8095402e6757f556bfe583527a4ecf701b77

source: gharchive/pull-request

authors: cristeahub stianjensen


text:
Added Mic - Speech to Create/Text

Mic - Speech to Text
Description
Added microphone functionality to allow users to input text via speech. Users can now toggle speech recognition by clicking on the microphone icon. When speech recognition is active, speech input is transcribed into the textarea in real-time. This feature provides an alternative input method for users who prefer speech over typing.
Changes Made

Integrated microphone icon with toggle functionality to start/stop speech recognition.
Implemented speech recognition using the Web Speech API.
Transcribed speech input into the textarea for message input.
Added event handlers for speech recognition errors and end events.
Improved user experience by providing visual feedback with microphone icon state changes.

Usage

Click on the microphone icon to start speech recognition.
Speak into your device's microphone.
Speech input will be transcribed into the textarea in real-time.
Click on the microphone icon again to stop speech recognition.

Notes

Ensure that your browser supports the Web Speech API for speech recognition functionality.
Speech recognition may not be accurate in all environments and may require clear and concise speech input.

Other work forked from @ARajgor

Since you're layering on top of #24, you might want to PR to @ARajgor's fork.
Cool work!

Will pull later with more features.

repo: stitionai/devika


text:
Question: Is VL53L4CX the same device as the VL53L4CD?

I ask this question because the driver for either device appears to work for either device.
The following is output during initialization of objects for each device driver for the same physical device:
VL53L4CD Driver Sensor Id: 0xEBAA
VL53L4CX Driver Device Type: AA  Product Revision: 1.1  Product version: 8 1 2 2578
Are the physical devices actually different or
Are they the same but the VL53L4CX driver provides more, expanded functionality?

The official rule is you should use the driver delivered with the sensor.
This is not recommended by ST to use a different driver but if you test it, it might work for you.

authors: AnneBigot ChuckVanzant


text:
Missing "Install" section in readme

Looks really useful, how do I install this on my Debian server?

# successfully tested on Debian 12 bookworm, x86_64 GNU/Linux

git clone https://github.com/stolk/diskgraph.git
cd diskgraph/
make
./diskgraph /dev/sda

repo: stolk/diskgraph


text:
process deletion of registeredcluster

Signed-off-by: Leena Jawale ljawale@redhat.com
/hold
Note: import secret is supposed to be deleted on deletion of registeredcluster as we have added ownerref to import secret. Seems garbage collection is not working properly and it is not deleting import secret

/unhold

Note: import secret is supposed to be deleted on deletion of registeredcluster as we have added ownerref to import secret. Seems garbage collection is not working properly and it is not deleting import secret

This is expected for now as garbage collection is not yet implemented.

authors: leena-jawale robinbobbitt

repo: stolostron/compute-operator


text:
Enable flags for kubeconfig and logs

Signed-off-by: zhujian jiazhu@redhat.com
issue reference: https://github.com/stolostron/backlog/issues/26609

Enable flags for kubeconfig and logs
add a leader-election-namespace to make it possible to run the import controller locally

Before the change:
╰─$ ./build/_output/manager --help
Usage of ./build/_output/manager:
      --feature-gates mapStringBool   A set of key=value pairs that describe feature gates for alpha/experimental features. Options are:
                                      AllAlpha=true|false (ALPHA - default=false)
                                      AllBeta=true|false (BETA - default=false)
                                      KlusterletHostedMode=true|false (ALPHA - default=true)
pflag: help requested

After the change:
╰─$ ./build/_output/manager --help
Usage of ./build/_output/manager:
      --add-dir-header                   If true, adds the file directory to the header of the log messages (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --alsologtostderr                  log to standard error as well as files (no effect when -logtostderr=true) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --feature-gates mapStringBool      A set of key=value pairs that describe feature gates for alpha/experimental features. Options are:
                                         AllAlpha=true|false (ALPHA - default=false)
                                         AllBeta=true|false (BETA - default=false)
                                         KlusterletHostedMode=true|false (ALPHA - default=true)
      --kubeconfig string                Paths to a kubeconfig. Only required if out-of-cluster.
      --log-backtrace-at traceLocation   when logging hits line file:N, emit a stack trace (default :0) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --log-dir string                   If non-empty, write log files in this directory (no effect when -logtostderr=true) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --log-file string                  If non-empty, use this log file (no effect when -logtostderr=true) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --log-file-max-size uint           Defines the maximum size a log file can grow to (no effect when -logtostderr=true). Unit is megabytes. If the value is 0, the maximum file size is unlimited. (default 1800) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --log-flush-frequency duration     Maximum number of seconds between log flushes (default 5s)
      --logtostderr                      log to standard error instead of files (default true) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --one-output                       If true, only write logs to their native severity level (vs also writing to each lower severity level; no effect when -logtostderr=true) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --skip-headers                     If true, avoid header prefixes in the log messages (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --skip-log-headers                 If true, avoid headers when opening log files (no effect when -logtostderr=true) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
      --stderrthreshold severity         logs at or above this threshold go to stderr when writing to files and stderr (no effect when -logtostderr=true or -alsologtostderr=false) (default 2) (DEPRECATED: will be removed in a future release, see https://github.com/kubernetes/enhancements/tree/master/keps/sig-instrumentation/2845-deprecate-klog-specific-flags-in-k8s-components)
  -v, --v Level                          number for the log level verbosity
      --vmodule moduleSpec               comma-separated list of pattern=N settings for file-filtered logging
pflag: help requested

/test check

/test check

/assign @skeeey @zhiweiyin318

/hold

/hold cancel

/lgtm

/approved


text:
[release-2.6] Added sonar project properties file to repo

Related issue: https://github.com/stolostron/backlog/issues/24275
Signed-off-by: dislbenn dbennett@redhat.com

/hold

/lgtm

/unhold

repo: stolostron/observatorium-operator


text:
100

UQC0lymzTRdR7Vqr-avoWenlcDTnOvIqp_dcXVs-5qWW_SEd

UQD9Fpyr-qiPozXb-YZHqmh6vXimdZBlDU9QUqqLqsH9dlBC

UQD9Fpyr-qiPozXb-YZHqmh6vXimdZBlDU9QUqqLqsH9dlBC

UQC0lymzTRdR7Vqr-avoWenlcDTnOvIqp_dcXVs-5qWW_SEd

repo: ston-fi/tonlib-rs


text:
text-link-context.css

Test
	https://github.com/stonecrusher/simpleMenuWizard/issues/new

#context-openlinkincurrent

Ah wow, a hidden treasure :-)
I was tempted putting it into link-context, but actually it belongs to select-context.
Thank you. Fixed.

Haha well... happy little mistakes
https://github.com/stonecrusher/simpleMenuWizard/commit/0e76da59e0f441238c57d788d47c2c5d3bafb771

authors: stonecrusher wvxwxvw

repo: stonecrusher/simpleMenuWizard


text:
D favicon

Should be fairly trivial ;-)

http://dlang.org/favicon.ico

authors: stonemaster wilzbach

repo: stonemaster/dlang-tour


text:
❓ Question: "next start" does not work with "output: standalone" configuration. Use "node .next/standalone/server.js" instead?

🙋♂ Question
I got this output on the front-end process; is this a bug or an issue?
● pingvin-front.service - Pingvin Frontend
     Loaded: loaded (/etc/systemd/system/pingvin-front.service; enabled; vendor preset: enabled)
     Active: active (running) since Tue 2024-03-26 02:20:18 PST; 7min ago
   Main PID: 3467416 (npm run start)
      Tasks: 23 (limit: 38231)
     Memory: 110.5M
        CPU: 4.173s
     CGroup: /system.slice/pingvin-front.service
             ├─3467416 "npm run start" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" ""
             ├─3467436 sh -c "next start"
             └─3467437 next-router-worker "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" ""

Mar 26 02:20:18 hostname systemd[1]: Started Pingvin Frontend.
Mar 26 02:20:19 hostname npm[3467416]: > pingvin-share-frontend@0.22.2 start
Mar 26 02:20:19 hostname npm[3467416]: > next start
Mar 26 02:20:20 hostname npm[3467437]:  ⚠ "next start" does not work with "output: standalone" configuration. Use "node .next/standalone/server.js" instead.
Mar 26 02:20:20 hostname npm[3467437]:   ▲ Next.js 13.5.6
Mar 26 02:20:20 hostname npm[3467437]:   - Local:        http://localhost:3030
Mar 26 02:20:20 hostname npm[3467437]:  ✓ Ready in 1418ms

Thanks. I've changed the start command to pm2 start --name="pingvin-share-frontend" .next/standalone/server.js in the Readme.

It works clean now, thanks.
● pingvin-front.service - Pingvin Frontend
     Loaded: loaded (/etc/systemd/system/pingvin-front.service; enabled; vendor preset: enabled)
     Active: active (running) since Sat 2024-03-30 18:17:36 PST; 2min 31s ago
   Main PID: 1099394 (next-router-wor)
      Tasks: 11 (limit: 38231)
     Memory: 80.8M
        CPU: 2.803s
     CGroup: /system.slice/pingvin-front.service
             └─1099394 next-router-worker "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" ""

Mar 30 18:17:36 host systemd[1]: Started Pingvin Frontend.
Mar 30 18:17:37 host node[1099394]:   ▲ Next.js 13.5.6
Mar 30 18:17:37 host node[1099394]:   - Local:        http://localhost:3030
Mar 30 18:17:37 host node[1099394]:   - Network:      http://0.0.0.0:3030
Mar 30 18:17:37 host node[1099394]:  ✓ Ready in 636ms


text:
🐛 Bug Report: Unable to change the logo

👟 Reproduction steps
Try to change the logo on a running pingvin instance
👍 Expected behavior
Logo should be changed to the newly uploaded file
👎 Actual Behavior
Logo remains original (uploaded  ~1y ago) file
📜 Logs
Haven't got any logs, cause I don't know where they are, but I already tried:
-waiting multiple hours after uploading
-clearing browser cache
-restarting docker container
-rebuilding docker container
-restarting host vm
-uploading logo.png manually to /data/images/logo.png
-updating pingvin to the newest version

Are the images in /data/images/ the new logo or the default one?

i can't check the image directly, cos I only have shell access, but the file gets the current date in the "last modified" field, everytime I upload a new logo, so I would assume the upload works

Found a way to access the images folder and downloaded the logo.png file and it is indeed the correct "new" one, but the file on the page, still hasn't updated

Okay thanks. Can you share your docker-compose.yml? What if you try it in a private browser window?

My docker-compose file is basically the standard one from the guide without ClamAV and weirdly enough, if I open the site in a private window in works, indicating, the logo is cached in my browser, but disabling the cache doesn't work... I use firefox btw

Yes, that actually fixed the issue...
Can't believe I'm apparently to stupid to clear the cache in my browser. Thanks very much for the help XD


text:
Option to inject keychain only to list of preallowed websites.

According to the docs, the extension injects itself into every website. It would be a good to add an option/make it default to inject the extension only to websites allowed by a user. This way, websites that do not have the access will not be able to track who has the extension installed. Moreover, the extension will not unnecessarily slow down user's browser. From the user perspective, the user will simple once add a website to a list if he chooses to use this option once and enjoy increased benefits of privacy.

Making it the default would make the extension much less user friendly for most of users.
The code injected is extremely light so I believe the proportion in which it would slow down a browser is insignificant, almost all of the heavy lifting happens on the background, which is independent of the number of open tabs.
I'll leave it open in case someone wants to work on this once the refactor is done, but I'm not ready to commit resources for this now, we have a lot going on.

Okay, thank you for your reply. Also users, for now, have the option to use a separate browser profile with the extension to achieve similar purpose.

authors: remirafun stoodkev

repo: stoodkev/hive-keychain


text:
「陽性患者の属性」表において、備考欄の代わりを用意する

改善詳細 / Details of Improvement

備考を消してしまったことにより、情報量が減ったことが懸念されるが、これを感染経路の特定有無の表記で置き換えることで実質的に対処できるのではないか
今までの備考欄は兵庫県の公開する備考をそのまま表記していたために文字量が多く、読みづらいうえに翻訳の際に手が回らないことから削除に至ったが、「感染経路」で置き換えることで「特定済み」、「行動歴調査中」、「特定できず」の3パターンのみにすることでより分かりやすく、また情報量が減る懸念もほとんどなくなるのではないか

情報元に関しては兵庫県公開データの「クラスター」に〇がついているか否かで判断することが出来るので、自動化的には問題ありませんが、この案に問題がないかどうかの議論をここで出来ればと思います。

https://github.com/stop-covid19-hyogo/covid19/issues/257
こちらでも似たようなことをしようとしていたのを忘れていた...
どちらにも導入するのもあり...?

やるとしたらグラフ追加で対処することにします。


text:
SIGSEGV on Debian

Subject of the issue
I get a segfault when I try to run prism on Debian/buster.
The issue
The environment

prism was installed with the install.sh script, with some changes to it to allow the install when there are spaces in the path (cf PR https://github.com/stoplightio/prism/pull/134). Maybe I've done something wrong here.
debian buster (testing)

Steps to reproduce

install prism with the above script on debian
run prism run --mock --list --spec http://petstore.swagger.io/v2/swagger.json

Expected behaviour

prism should run the mock server

Actual behaviour

prism fails with a segfault

fatal error: unexpected signal during runtime execution
[signal SIGSEGV: segmentation violation code=0x1 addr=0xffffffffff600000 pc=0xffffffffff600000]

According to your commandline, it looks like you are using an old version of prism because of the run option. Probably 0.6.21 or previous.
I tried with Prism 2.0.0.-beta.9-6 with this command : prism mock --spec http://petstore.swagger.io/v2/swagger.json
The mock works fine if I send requests with wget -qO- http://localhost:4010/pet/123
Successfully tested on Ubuntu 16.04 LTS and CentOS 7.3.1611 (Core).
Hoping it can help.
(Btw, not sure that the install.sh is still working because Github responds "API rate limit exceeded" when I request  with curl -s https://api.github.com/repos/stoplightio/prism/tags)

Hi,
Thanks to your help, I managed to run prism after upgrading it. It seems to be working fine now :)
A few notes on that:

I used the install and run instructions on the homepage. This is the same as what's in the doc. Either the install instruction or the install script location should probably be updated.

RUN IT
1) curl https://raw.githubusercontent.com/stoplightio/prism/master/install.sh | sh
2) prism run --mock --list --spec http://petstore.swagger.io/v2/swagger.json

Then I used the install instructions on the README curl https://raw.githubusercontent.com/stoplightio/prism/2.x/install.sh | sh. This still wasn't the right version, as it didn't know the mock option. I had to upgrade it after.

Yes, you're right.
The Github API URL used in install.sh (https://api.github.com/repos/stoplightio/prism/tags) doesn't sort the tags in the right order : "v2.0.0-beta.9" comes first instead of "v2.0.0-beta.9-6". It's alphabetically sorted. And there is no option to sort the response of the API with ?sort=created :

Doc of API v3 : https://developer.github.com/v3/repos/#list-tags
Issue on Stackoverflow : https://stackoverflow.com/questions/19452244/github-api-v3-order-tags-by-creation-date

A workaround could be to use this url : https://api.github.com/repos/stoplightio/prism/releases or to forge a GraphQL query.
@pytlesk4  😉

Bumping Prism to 2.0.0 today, which should fix this issue. I have to admit that the versioning we were using is a bit weird. There was a issue with the prism update command and the way we were parsing version: https://github.com/hashicorp/go-version/issues/32 which has been fixed.
@ntiss thanks for the info going to look into!

Going to close this, going to go back to normal semantic versioning.

repo: stoplightio/prism


text:
Route component swallows errors

I have following routes configuration:
import {Route, IndexRoute, Redirect} from 'react-router';
import ReactStormpath, {Router, HomeRoute, LoginRoute, LogoutRoute, AuthenticatedRoute} from 'react-stormpath';

ReactDOM.render(
    <Provider store={store}>
      <Router history={history}>
        <AuthenticatedRoute>
          <HomeRoute path="/" component={App}>
            <AuthenticatedRoute path='apps'>
              <IndexRoute component={AppsPage}/>
              // ...
            </AuthenticatedRoute>
    // ...
);

AppsPage.js component code:
// AppsPage.js
componentDidMount() {
    console.log('a')
    fasf // should throw error
    console.log('b')
}

Console logs only 'a' - doesn't log either error or 'b'
If I change code (move route with AppsPage component outside of AuthenticatedRoute and HomeRoute):
ReactDOM.render(
    <Provider store={store}>
      <Router history={history}>
        <Route path="/apps" component={AppsPage}/>
        <AuthenticatedRoute>
          // ...
        </AuthenticatedRoute>
    // ...
);

then it works:
AppsPage.js:26Uncaught ReferenceError: fasf is not defined

I'm having this same problem. On stormpath-react-sdk 1.3.3.

@brandones I don't have this bug anymore on 1.3.4, try to update

Yep, appears to be working on 1.3.4. Thanks!

authors: DCKT brandones lukaszgrolik

repo: stormpath/stormpath-sdk-react


text:
[Bug] Imports in the Writing a Custom Decorator code examples in the docs do not work

Describe the bug
Imports in the Writing a Custom Decorator code examples in the docs are invalid (using v1.0.1),
Typescript warns there are no matching exports:
Module '"@storybook/addon-styling"' has no exported member 'initializeThemeState'. Did you mean to use 'import initializeThemeState from "@storybook/addon-styling"' instead?ts(2614)
pluckThemeFromContext
import { pluckThemeFromContext } from "@storybook/addon-styling";
useThemeParameters
import { useThemeParameters } from "@storybook/addon-styling";
(aside: initializeThemeState doesn't have an import line like the previous 2, should it?)
Workaround:
The code does export a DecoratorHelpers object that contains those functions, so changing the import to the following removes the import error:
import { DecoratorHelpers } from '@storybook/addon-styling';
const { initializeThemeState, pluckThemeFromContext, useThemeParameters } = DecoratorHelpers;

Hey @RegisFrey 👋
Thank you for that catch! you're 100% correct.
Any chance you'd be willing to put together a small PR with the fix? It's just me maintaining this right now and I have a bunch of other stuff on my plate right now 😅 I'd really appreciate it

Put up a PR https://github.com/storybookjs/addon-styling/pull/30

authors: Integrayshaun RegisFrey

repo: storybookjs/addon-styling


text:
Fetch index.json and refer to "index json" mode.

📦 Published PR as canary version: 0.3.1--canary.124.0eebca7.0

:sparkles: Test out this PR locally via:
npm install @storybook/test-runner@0.3.1--canary.124.0eebca7.0
# or
yarn add @storybook/test-runner@0.3.1--canary.124.0eebca7.0

Codecov Report

:exclamation: No coverage uploaded for pull request base (next@358b13d). Click here to learn what that means.
The diff coverage is n/a.

@@           Coverage Diff           @@
##             next     #124   +/-   ##
=======================================
  Coverage        ?   77.52%
=======================================
  Files           ?       11
  Lines           ?      178
  Branches        ?       38
=======================================
  Hits            ?      138
  Misses          ?       40
  Partials        ?        0

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 358b13d...0eebca7. Read the comment docs.

authors: codecov-commenter tmeasday

repo: storybookjs/test-runner


text:
Log network location of Storybook app on startup

Issue:
Fixes #4231
What I did
This change logs an additional network-reachable url for the Storybook app:

How to test
Is this testable with Jest or Chromatic screenshots? Not really
Does this need a new example in the kitchen sink apps? No
Does this need an update to the documentation? No
If your answer is yes to any of these, please make sure to include it in your PR.
For maintainers only: Please tag your pull request with at least one of the following:
["cleanup", "BREAKING CHANGE", "feature request", "bug", "documentation", "maintenance", "dependencies", "other"]

thanks @pksunkara!

repo: storybooks/storybook


text:
transaction building improvement

wip on the transaction building process

superseded by #3930

repo: stratisproject/StratisBitcoinFullNode


text:
Bugfix/pow block asm race issue 500

Depends on PR https://github.com/stratisproject/StratisBitcoinFullNode/pull/534
chainTip now comes as an argument to the block assembler, so the whole assembling instance is working with a fixed chain tip value and this prevents problems when the concurrent chain tip or consensus tip is changed during the process
Fix #500

Up to now looks good but can you resolve the conflicts?

These are expected when I continue on the previously unmerged branch, so of course, I'm going to fix the conflicts very soon.

authors: Aprogiena dangershony


text:
Clean-up activation heights

This PR:

Removes the legacy BIP 9's and replaces them with hard-coded heights
Moves the activation heights into the ActivationHeights array. Some advantages to this:

The PoAConsensusOptions class-definition will remain static instead of changing with almost every release.
Ultimately the array can move to the base class making the activation heights accessible without casting the options.

Good catch. Will make the required changes.

Made the necessary changes to be able to derive PoABuriedDeploymentsArray from BuriedDeploymentsArray.

repo: stratisproject/StratisFullNode


text:
Fails to Start

Issue description
Streama/Java throws errors when attempting to start the first time.
Steps to Reproduce

Download streama-1.6.1.war
Install java 8: sudo apt install openjdk-8-jre
Check java version with java -version:
openjdk version "10.0.2" 2018-07-17 OpenJDK Runtime Environment (build 10.0.2+13-Ubuntu-1ubuntu0.18.04.4) OpenJDK 64-Bit Server VM (build 10.0.2+13-Ubuntu-1ubuntu0.18.04.4, mixed mode)
Change execute permissions with chmod +x streama-1.6.1.war
Attempt to run Streama with java -jar streama-1.6.1.jar
Errors

Expected Behaviour
Streama should start, presumably.
Actual Behaviour
Streama throws errors:
`WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by org.codehaus.groovy.reflection.CachedClass$3$1 (jar:file:/home/duncan/Downloads/streama-1.6.1.war!/WEB-INF/lib/groovy-2.4.7.jar!/) to method java.lang.Object.finalize()
WARNING: Please consider reporting this to the maintainers of org.codehaus.groovy.reflection.CachedClass$3$1
WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
WARNING: All illegal access operations will be denied in a future release
INFO streama.Application - Starting Application on devi with PID 25126 (/home/duncan/Downloads/streama-1.6.1.war started by duncan in /home/duncan/Downloads)
DEBUG streama.Application - Running with Spring Boot v1.4.4.RELEASE, Spring v4.3.6.RELEASE
INFO streama.Application - The following profiles are active: production
Configuring Spring Security Core ...
... finished configuring Spring Security Core
ERROR org.springframework.boot.SpringApplication - Application startup failed
org.springframework.context.ApplicationContextException: Unable to start embedded container; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'tomcatEmbeddedServletContainerFactory' defined in class path resource [org/springframework/boot/autoconfigure/web/EmbeddedServletContainerAutoConfiguration$EmbeddedTomcat.class]: Initialization of bean failed; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'serverProperties' defined in class path resource [org/springframework/boot/autoconfigure/web/ServerPropertiesAutoConfiguration.class]: Initialization of bean failed; nested exception is java.lang.NoClassDefFoundError: javax/xml/bind/ValidationException
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.onRefresh(EmbeddedWebApplicationContext.java:137)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:536)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:762)
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:372)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:316)
at grails.boot.GrailsApp.run(GrailsApp.groovy:83)
at grails.boot.GrailsApp.run(GrailsApp.groovy:388)
at grails.boot.GrailsApp.run(GrailsApp.groovy:375)
at grails.boot.GrailsApp$run.call(Unknown Source)
at org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:48)
at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:113)
at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:133)
at streama.Application.main(Application.groovy:8)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:564)
at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:48)
at org.springframework.boot.loader.Launcher.launch(Launcher.java:87)
at org.springframework.boot.loader.Launcher.launch(Launcher.java:50)
at org.springframework.boot.loader.WarLauncher.main(WarLauncher.java:59)
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'tomcatEmbeddedServletContainerFactory' defined in class path resource [org/springframework/boot/autoconfigure/web/EmbeddedServletContainerAutoConfiguration$EmbeddedTomcat.class]: Initialization of bean failed; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'serverProperties' defined in class path resource [org/springframework/boot/autoconfigure/web/ServerPropertiesAutoConfiguration.class]: Initialization of bean failed; nested exception is java.lang.NoClassDefFoundError: javax/xml/bind/ValidationException
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:564)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:483)
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:202)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.getEmbeddedServletContainerFactory(EmbeddedWebApplicationContext.java:199)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.createEmbeddedServletContainer(EmbeddedWebApplicationContext.java:162)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.onRefresh(EmbeddedWebApplicationContext.java:134)
... 21 common frames omitted
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'serverProperties' defined in class path resource [org/springframework/boot/autoconfigure/web/ServerPropertiesAutoConfiguration.class]: Initialization of bean failed; nested exception is java.lang.NoClassDefFoundError: javax/xml/bind/ValidationException
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:564)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:483)
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:202)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBeansOfType(DefaultListableBeanFactory.java:519)
at org.springframework.context.support.AbstractApplicationContext.getBeansOfType(AbstractApplicationContext.java:1197)
at org.springframework.boot.context.embedded.EmbeddedServletContainerCustomizerBeanPostProcessor.getCustomizers(EmbeddedServletContainerCustomizerBeanPostProcessor.java:77)
at org.springframework.boot.context.embedded.EmbeddedServletContainerCustomizerBeanPostProcessor.postProcessBeforeInitialization(EmbeddedServletContainerCustomizerBeanPostProcessor.java:67)
at org.springframework.boot.context.embedded.EmbeddedServletContainerCustomizerBeanPostProcessor.postProcessBeforeInitialization(EmbeddedServletContainerCustomizerBeanPostProcessor.java:54)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsBeforeInitialization(AbstractAutowireCapableBeanFactory.java:409)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1620)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:555)
... 29 common frames omitted
Caused by: java.lang.NoClassDefFoundError: javax/xml/bind/ValidationException
at java.base/java.lang.ClassLoader.defineClass1(Native Method)
at java.base/java.lang.ClassLoader.defineClass(ClassLoader.java:1009)
at java.base/java.security.SecureClassLoader.defineClass(SecureClassLoader.java:174)
at java.base/java.net.URLClassLoader.defineClass(URLClassLoader.java:545)
at java.base/java.net.URLClassLoader.access$100(URLClassLoader.java:83)
at java.base/java.net.URLClassLoader$1.run(URLClassLoader.java:453)
at java.base/java.net.URLClassLoader$1.run(URLClassLoader.java:447)
at java.base/java.security.AccessController.doPrivileged(Native Method)
at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:446)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:566)
at org.springframework.boot.loader.LaunchedURLClassLoader.loadClass(LaunchedURLClassLoader.java:94)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:499)
at org.hibernate.validator.internal.engine.ConfigurationImpl.(ConfigurationImpl.java:129)
at org.hibernate.validator.internal.engine.ConfigurationImpl.(ConfigurationImpl.java:96)
at org.hibernate.validator.HibernateValidator.createGenericConfiguration(HibernateValidator.java:31)
at javax.validation.Validation$GenericBootstrapImpl.configure(Validation.java:276)
at org.springframework.validation.beanvalidation.LocalValidatorFactoryBean.afterPropertiesSet(LocalValidatorFactoryBean.java:248)
at org.springframework.boot.context.properties.ConfigurationPropertiesBindingPostProcessor$LocalValidatorFactory.run(ConfigurationPropertiesBindingPostProcessor.java:453)
at org.springframework.boot.context.properties.ConfigurationPropertiesBindingPostProcessor.getValidator(ConfigurationPropertiesBindingPostProcessor.java:387)
at org.springframework.boot.context.properties.ConfigurationPropertiesBindingPostProcessor.determineValidator(ConfigurationPropertiesBindingPostProcessor.java:370)
at org.springframework.boot.context.properties.ConfigurationPropertiesBindingPostProcessor.postProcessBeforeInitialization(ConfigurationPropertiesBindingPostProcessor.java:332)
at org.springframework.boot.context.properties.ConfigurationPropertiesBindingPostProcessor.postProcessBeforeInitialization(ConfigurationPropertiesBindingPostProcessor.java:303)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsBeforeInitialization(AbstractAutowireCapableBeanFactory.java:409)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1620)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:555)
... 42 common frames omitted
Caused by: java.lang.ClassNotFoundException: javax.xml.bind.ValidationException
at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:466)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:566)
at org.springframework.boot.loader.LaunchedURLClassLoader.loadClass(LaunchedURLClassLoader.java:94)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:499)
... 67 common frames omitted
`
Environment Information

Operating System: KDE Neon  (Ubuntu 18.04 LTS)
Streama version: 1.6.1
Custom streama build, describe customizations or provide link to fork (If Applicable):  N/A
Container Version (If Applicable): N/A

Check java version with java -version: openjdk version "10.0.2"[...]

That's clearly java 10 not 8.

@HannahRy I installed Java using the command on your documentation. I'll attempt to revert but perhaps an updated command may be useful.

The command is correct. You just installed java 10 at some point and didn't remove it or change your default version when you installed 8.

@HannahRy Thank you for the clarification.

just for your information:
In Debian 10 (buster) openjdk 8 is not available anymore. So you should maybe update to a newer version soon. Couldn't install streama cause of this and will wait, till it is possible.

This will not be trivial. Not even sure if jdk > 8 is supported by grails core. But this will be a big fix and im not sure it will happen within the next months unless otherwise contributed

I had Java 11 installed and got the same error. If you don't want to remove latest version, just use update-alternatives to remap java version (temporarily or not). Output should look like this
$ sudo update-alternatives --config java

[sudo] password for george:
There are 2 choices for the alternative java (providing /usr/bin/java).

  Selection    Path                                            Priority   Status
------------------------------------------------------------
  0            /usr/lib/jvm/java-11-openjdk-amd64/bin/java      1111      auto mode
  1            /usr/lib/jvm/java-11-openjdk-amd64/bin/java      1111      manual mode
* 2            /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/java   1081      manual mode

Press <enter> to keep the current choice[*], or type selection number:

Hit 2 and you can run streama without any errors.

authors: HannahRy askat86 dularion georgegach robotdna

repo: streamaserver/streama


text:
Stop using createFactory

With the release of React 16.13.0, createFactory is deprecated. createStateContext and createReducerContext should be updated not to rely on it.

+1

:tada: This issue has been resolved in version 15.3.3 :tada:
The release is available on:

npm package (@latest dist-tag)
GitHub release

Your semantic-release bot :package::rocket:

authors: mikestopcontinues nghiepit streamich

repo: streamich/react-use

license: Unlicense


text:
Doc pages never finish loading and Ask AI not working

Summary
None of the doc pages finish loading, and the Ask AI button is unresponsive.
If I switch to Safari, there are no issues: pages fully load and the Ask AI button functions correctly.
Steps to reproduce

Chrome: 131.0.6778.205 (Official Build) (arm64)
MacOS: 15.2 (24C101)

Screenshot(s):

Expected behavior:
See above
Actual behavior:
See above
Debug info
See above

Thanks for reporting. I tried the same version of Chrome and Mac and can't reproduce the issue. Can you clear your cache and try loading the page again?

Yeah, clearing the cache fixed the issue. Sorry to waste your time.

authors: nick-youngblut sfc-gh-dmatthews

repo: streamlit/docs


text:
[BUG] Kafka producer client can not connect to kop (Removing node xxxx:9092 (id: 2057312963 rack: null) from least loaded node selection since it is neither ready for sending or connecting)[BUG]

"pulsar-io-26-32" #287 prio=5 os_prio=0 tid=0x00007f10e8767000 nid=0x4ae waiting on condition [0x00007f10c95ba000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager$$Lambda$1120/2085128569.accept(Unknown Source)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.forEach(ConcurrentLongHashMap.java:431)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.forEach(ConcurrentLongHashMap.java:164)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteExpiredCursor(KafkaTopicConsumerManager.java:74)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.lambda$null$0(KafkaTopicManager.java:100)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager$$Lambda$1119/1991303689.accept(Unknown Source)
at java.util.concurrent.ConcurrentHashMap$ValuesView.forEach(ConcurrentHashMap.java:4707)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.lambda$new$1(KafkaTopicManager.java:98)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager$$Lambda$893/144794386.run(Unknown Source)
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:176)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:748)
"pulsar-io-26-31" #286 prio=5 os_prio=0 tid=0x00007f10e8445000 nid=0x4ad waiting on condition [0x00007f10c96bb000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.remove(KafkaTopicConsumerManager.java:142)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.lambda$null$2(MessageFetchContext.java:146)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext$$Lambda$945/1999044484.apply(Unknown Source)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1699)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.lambda$handleFetch$4(MessageFetchContext.java:167)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext$$Lambda$944/1214167246.accept(Unknown Source)
at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792)
at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.handleFetch(MessageFetchContext.java:109)
at io.streamnative.pulsar.handlers.kop.KafkaRequestHandler.handleFetchRequest(KafkaRequestHandler.java:966)
at io.streamnative.pulsar.handlers.kop.KafkaCommandDecoder.channelRead(KafkaCommandDecoder.java:203)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792)
at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:475)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:748)
"pulsar-io-26-30" #285 prio=5 os_prio=0 tid=0x00007f10e8443800 nid=0x4ac waiting on condition [0x00007f10c97bd000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
- locked <0x000000052e940220> (a io.streamnative.pulsar.handlers.kop.KafkaTopicManager)
at io.streamnative.pulsar.handlers.kop.KafkaRequestHandler.close(KafkaRequestHandler.java:212)
at io.streamnative.pulsar.handlers.kop.KafkaRequestHandler.channelInactive(KafkaRequestHandler.java:202)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241)
at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:389)
at io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:354)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901)
at io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:818)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:748)

cat txt|grep -A 10 pulsar-io
"pulsar-io-26-32" #287 prio=5 os_prio=0 tid=0x00007f10e8767000 nid=0x4ae waiting on condition [0x00007f10c95ba000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-31" #286 prio=5 os_prio=0 tid=0x00007f10e8445000 nid=0x4ad waiting on condition [0x00007f10c96bb000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.remove(KafkaTopicConsumerManager.java:142)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.lambda$null$2(MessageFetchContext.java:146)
"pulsar-io-26-30" #285 prio=5 os_prio=0 tid=0x00007f10e8443800 nid=0x4ac waiting on condition [0x00007f10c97bd000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-29" #284 prio=5 os_prio=0 tid=0x00007f10ec615800 nid=0x4ab waiting on condition [0x00007f10c98bd000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(AbstractQueuedSynchronizer.java:969)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(AbstractQueuedSynchronizer.java:1285)
at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(ReentrantReadWriteLock.java:727)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:85)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-28" #283 prio=5 os_prio=0 tid=0x00007f10ec610800 nid=0x4aa waiting on condition [0x00007f10c99bf000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-27" #282 prio=5 os_prio=0 tid=0x00007f10ecad9800 nid=0x4a9 waiting on condition [0x00007f10c9abf000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(AbstractQueuedSynchronizer.java:969)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(AbstractQueuedSynchronizer.java:1285)
at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(ReentrantReadWriteLock.java:727)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:85)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-26" #281 prio=5 os_prio=0 tid=0x00007f10ecad7000 nid=0x4a8 waiting on condition [0x00007f10c9bc1000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-25" #280 prio=5 os_prio=0 tid=0x00007f10ecad5000 nid=0x4a7 waiting on condition [0x00007f10c9cc1000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(AbstractQueuedSynchronizer.java:969)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(AbstractQueuedSynchronizer.java:1285)
at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(ReentrantReadWriteLock.java:727)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.remove(KafkaTopicConsumerManager.java:136)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.lambda$null$2(MessageFetchContext.java:146)
"pulsar-io-26-24" #279 prio=5 os_prio=0 tid=0x0000560e1d726000 nid=0x4a3 waiting on condition [0x00007f10cbdc4000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(AbstractQueuedSynchronizer.java:969)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(AbstractQueuedSynchronizer.java:1285)
at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(ReentrantReadWriteLock.java:727)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:85)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-23" #278 prio=5 os_prio=0 tid=0x00007f10e855c800 nid=0x4a2 waiting on condition [0x00007f10cbec6000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-22" #277 prio=5 os_prio=0 tid=0x00007f10e855a800 nid=0x4a1 waiting on condition [0x00007f10cbfc6000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(AbstractQueuedSynchronizer.java:969)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(AbstractQueuedSynchronizer.java:1285)
at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(ReentrantReadWriteLock.java:727)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:85)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-21" #276 prio=5 os_prio=0 tid=0x00007f10e8559000 nid=0x4a0 waiting on condition [0x00007f10cc0c7000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-20" #275 prio=5 os_prio=0 tid=0x00007f10e8557800 nid=0x49f waiting on condition [0x00007f10cc1c8000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(AbstractQueuedSynchronizer.java:969)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(AbstractQueuedSynchronizer.java:1285)
at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(ReentrantReadWriteLock.java:727)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:85)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-19" #274 prio=5 os_prio=0 tid=0x00007f10e8cc8800 nid=0x49e waiting on condition [0x00007f10cc2c9000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-18" #273 prio=5 os_prio=0 tid=0x00007f10e8cc7000 nid=0x49d waiting on condition [0x00007f10cc3ca000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(AbstractQueuedSynchronizer.java:969)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(AbstractQueuedSynchronizer.java:1285)
at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(ReentrantReadWriteLock.java:727)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:85)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-17" #272 prio=5 os_prio=0 tid=0x00007f10e803f800 nid=0x49c waiting on condition [0x00007f10cc4cb000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-16" #271 prio=5 os_prio=0 tid=0x00007f10e803d800 nid=0x49b waiting on condition [0x00007f10cc5cc000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-15" #270 prio=5 os_prio=0 tid=0x00007f10ec658000 nid=0x49a waiting on condition [0x00007f10cc6cd000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-14" #269 prio=5 os_prio=0 tid=0x00007f10ec082000 nid=0x499 waiting on condition [0x00007f10cc7ce000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-13" #268 prio=5 os_prio=0 tid=0x00007f10ec081000 nid=0x498 waiting on condition [0x00007f10cc8d0000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-12" #267 prio=5 os_prio=0 tid=0x00007f10ecaa2800 nid=0x497 waiting on condition [0x00007f10cc9d0000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-11" #266 prio=5 os_prio=0 tid=0x0000560e1cc83800 nid=0x496 waiting on condition [0x00007f10ccad1000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.remove(KafkaTopicConsumerManager.java:142)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.lambda$null$2(MessageFetchContext.java:146)
"pulsar-io-26-10" #265 prio=5 os_prio=0 tid=0x0000560e1cc81800 nid=0x495 waiting on condition [0x00007f10ccbd2000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-9" #264 prio=5 os_prio=0 tid=0x0000560e1cc7f800 nid=0x494 waiting on condition [0x00007f10cccd3000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.remove(KafkaTopicConsumerManager.java:142)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.lambda$null$2(MessageFetchContext.java:146)
"pulsar-io-26-8" #263 prio=5 os_prio=0 tid=0x0000560e1cc7d000 nid=0x490 waiting on condition [0x00007f10ccdd4000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-7" #262 prio=5 os_prio=0 tid=0x0000560e1cc25000 nid=0x48e waiting on condition [0x00007f10cced5000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.remove(KafkaTopicConsumerManager.java:142)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.lambda$null$2(MessageFetchContext.java:146)
"pulsar-io-26-6" #261 prio=5 os_prio=0 tid=0x0000560e1cc23000 nid=0x48d waiting on condition [0x00007f10ccfd6000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-5" #260 prio=5 os_prio=0 tid=0x0000560e1cc21000 nid=0x48c waiting on condition [0x00007f10cd0d7000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.remove(KafkaTopicConsumerManager.java:142)
at io.streamnative.pulsar.handlers.kop.MessageFetchContext.lambda$null$2(MessageFetchContext.java:146)
"pulsar-io-26-4" #259 prio=5 os_prio=0 tid=0x0000560e1cd82800 nid=0x48b waiting on condition [0x00007f10cd1d8000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-3" #258 prio=5 os_prio=0 tid=0x0000560e1d439800 nid=0x485 waiting on condition [0x00007f10ce2da000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)
"pulsar-io-26-2" #257 prio=5 os_prio=0 tid=0x0000560e1d0b1000 nid=0x484 waiting on condition [0x00007f10cf3dc000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b910ae0> (a org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section)
at java.util.concurrent.locks.StampedLock.acquireWrite(StampedLock.java:1119)
at java.util.concurrent.locks.StampedLock.writeLock(StampedLock.java:354)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.remove(ConcurrentLongHashMap.java:340)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap$Section.access$300(ConcurrentLongHashMap.java:194)
at org.apache.pulsar.common.util.collections.ConcurrentLongHashMap.remove(ConcurrentLongHashMap.java:141)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.deleteOneExpiredCursor(KafkaTopicConsumerManager.java:91)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.lambda$deleteExpiredCursor$0(KafkaTopicConsumerManager.java:76)
"pulsar-io-26-1" #256 prio=5 os_prio=0 tid=0x0000560e1cdbe800 nid=0x47d waiting on condition [0x00007f10d16e0000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for  <0x000000052b9108a0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:838)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:872)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1201)
at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(ReentrantReadWriteLock.java:943)
at io.streamnative.pulsar.handlers.kop.KafkaTopicConsumerManager.close(KafkaTopicConsumerManager.java:244)
at io.streamnative.pulsar.handlers.kop.KafkaTopicManager.close(KafkaTopicManager.java:336)

KOP Version :2.7.2.4 + patch :https://github.com/streamnative/kop/pull/586/files

There're two deadlock cases:

Some threads stuck at ConcurrentLongHashMap.remove.
Some threads stuck at acquiring the read-write lock of KafkaTopicConsumerManager.

But the second deadlock is caused by the first deadlock, for example https://github.com/streamnative/kop/blob/fa6571550022df607937531cb0951f11e20ddad2/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaTopicConsumerManager.java#L132-L142
Once consumers.remove(offset) was blocked, the current thread would never release the read lock and close() method would stuck at acquiring the write lock, see
https://github.com/streamnative/kop/blob/fa6571550022df607937531cb0951f11e20ddad2/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaTopicConsumerManager.java#L244
For the first deadlock, there're two cases that consumers.remove() is called:

MessageFetchContext finds the cursor for each partition, which calls KafkaTopicConsumerManager#remove.
The periodic task to delete expired cursor in KafkaTopicManager's constructor. Each time a client connection is established, a KafkaTopicManager instance will be created and a task to delete expired cursors will be scheduled at a fix rate of 1 minute.

https://github.com/streamnative/kop/blob/fa6571550022df607937531cb0951f11e20ddad2/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaTopicManager.java#L91-L103
Let's use thread N to represent pulsar-io-26-N.
Threads that stuck at ConcurrentLongHashMap.remove are:

MessageFetchContext: 5, 7, 9, 11, 31
cursorExpireTask: 2, 4, 6, 8, 10, 12, 14, 16, 32

Threads that stuck at acquiring read-write lock of KafkaTopicConsumerManager are:

Write lock: 1, 3, 13, 15, 17, 19, 21, 23, 26, 28
Read lock: 18, 20, 22, 24, 25, 27, 29

There's one deadlock fix in https://github.com/apache/pulsar/pull/9787. Since KoP 2.7.x.y depends on Pulsar 2.7.x, KoP 2.7.x.y doesn't contain the fix. For branch-2.7, we can use ConcurrentHashMap<Long, V> from the Java standard library to replace ConcurrentLongHashMap<V> from pulsar-common here to avoid the deadlock.
For deadlock of KafkaTopicConsumerManager, we should use atomic boolean to replace read write lock.
Further more, we should avoid creating a cursorExpireTask for each KafkaTopicManager because currently consumerTopicManagers is global but KafkaTopicConsumer will be created for each connection.

repo: streamnative/kop