Hi, community.

Our project is under discussion about joining in the Apache Incubator.

It's helpful to launch a discussion about the initial committers list based on codes and community contributions.

codes

I propose the following 2 rules to soul and soul-dashboard (Both conditions are met):

• Commits count >=7 in one project
• Add code lines >=1000 in one project

community

• Actively running the community as a mentor （mentor ： Meetup organizers or Community keynote speaker）
• Answering community questions

proposal

The following contributors will be nominated initial committers.

soul (github-id) :

yu199195 dengliming tydot SteNicholas Asxing nuo-promise huangxfchn lw1243925457 SaberSola CCLooMi Trafalgar-YuI 0x12FD16B KevinClair

soul-dashboard (github-id)

xlgm fightingting fengzhenbing

community(github-id)

kimmking: as Apache Dubbo & ShardingSphere PMC member, he organizes source sharing activities, bringing important help to the community. tuohai666 : as Apache ShardingSphere PMC member, he is actively involved in community discussions and activities, and give powerful help about the community conform to Apache Way.

Finally

Above is just my suggestion, welcome anybody to discuss together （Fair, just and open）.

Voters can either respond "agree, yes, +1", or "advice".

Hi All guys:

soul will be rename, Could you do me a small favor?

The name rules are as follows :

• The name is easy to understand

• It is best to have a name with the meaning of gateway such as bridge, proxy, governance

• The name cannot be the same as the existing project name

• Don't use your name for other trademarks

thanks ALL

Description

Hi Community: This PR is to format the current SQL, following the principle of right-aligning keywords (Uppercase) and left-aligning fields. I would like to make this task a good first issue so that new comers can get involved in handling the rest of the SQL file. Do you think it's a good idea?

for example: before formatting:

select id, name, age from user where id = 1

after formatting

  SELECT id, 
         name, 
         age 
    FROM user
   WHERE id = 1

Task List

• [x] 1. app-auth-sqlmap.xml @midnight2104
• [x] 2. auth-param-sqlmap.xml @hutaishi
• [x] 3. auth-path-sqlmap.xml @ShawnSiao
• [x] 4. dashboard-user-sqlmap.xml @Jingwugate
• [x] 5. data-permission-sqlmap.xml @Mayank-KS
• [x] 6. meta-data-sqlmap.xml @selectbook
• [x] 7. permission-sqlmap.xml @wklong
• [x] 8. plugin-handle-sqlmap.xml joker-zxs
• [x] 9. plugin-sqlmap.xml @zhangcly
• [x] 10. resouce-sqlmap.xml @nydia
• [x] 11. role-sqlmap.xml @Albertsirius
• [x] 12. rule-condition-sqlmap.xml @UniverseInHeart
• [x] 13. rule-sqlmap.xml @totalo
• [x] 14. selector-condition-sqlmap.xml @lanseBlue
• [x] 15. selector-sqlmap.xml @xiaheshun
• [x] 16. shenyu-dict-sqlmap.xml @shallwetalkge
• [x] 17. user-role-sqlmap.xml @erdengk

Notice: input about issue 3088 in your pr desc .

Volunteer help

• [x] shenyu-plugin-api @songyuequan
• [x] shenyu-plugin-base @songyuequan
• [x] shenyu-plugin-global @heihei180
• [x] shenyu-plugin-logging @YanHui-Yang
• [x] shenyu-plugin-request @dizent
• [x] shenyu-plugin-resilience4j @haibo-duan
• [x] shenyu-plugin-response @haibo-duan
• [x] shenyu-plugin-rewrite @zendwang
• [x] shenyu-plugin-sign @zendwang
• [x] shenyu-plugin-tars @haibo-duan
• [x] shenyu-plugin-uri @haibo-duan
• [x] shenyu-plugin-context-path @AhahaGe
• [x] shenyu-plugin-redirect @YanHui-Yang
• [x] shenyu-plugin-motan @YanHui-Yang
• [x] shenyu-plugin-oauth2 @choconana
• [x] shenyu-plugin-ratelimiter @choconana
• [x] shenyu-plugin-sofa @li-keguo
• [x] shenyu-plugin-cryptor @impactCn
• [x] shenyu-plugin-monitor @Jossc
• [x] shenyu-plugin-grpc @li-keguo
• [x] shenyu-plugin-sentinel @songyuequan
• [x] shenyu-plugin-dubbo @dizent

• [x] shenyu-plugin-waf @zendwang checked
• [x] shenyu-plugin-websocket @zendwang checked
• [x] shenyu-plugin-hystrix @isevenluo checked
• [x] shenyu-plugin-springcloud @choconana checked
• [x] shenyu-plugin-divide @choconana checked
• [x] shenyu-plugin-httpclient @dizent checked
• [x] shenyu-plugin-jwt @songyuequan checked

• [x] shenyu-plugin-modify-response @songyuequan
• [x] shenyu-plugin-param-mapping @songyuequan

Volunteer help

Hi Community:

As the functionality of the apache shenyu project becomes more and more perfect.

Now apache shenyu has 100+ sub-projects and the amount of code is getting bigger and bigger.

To enhance the quality and readability of the code,and code design.

The project modules involved in this activity are deliberately launched as follows (code includes test code):

• [ ] sheyun-admin @prospect167
• [ ] shenyu-client @qicz
• [ ] shenyu-common @qinxu2015
• [ ] shenyu-disruptor @songyuequan
• [ ] shenyu-examples @li-keguo
• [ ] shenyu-integrated-test @lxl910128
• [ ] shenyu-loadbalancer @haibo-duan
• [ ] shenyu-metrics @6freeair2016
• [ ] shenyu-plugin @choconana
• [ ] shenyu-register-center @plutokaito
• [ ] shenyu-spi @heihei180
• [ ] shenyu-spring-boot-starter @Cw404
• [ ] shenyu-sync-data-center @JooKS-me
• [ ] shenyu-web @LXPWing

If you are interested in any of the above modules, please reply ：“ i want to optimize shenyu-xxx” in this and email ：https://lists.apache.org/thread/dr40q6bsrrryn6z19f0d59mor46qwb0s

And then you can create your own issue and break up the optimization of each module into many small tasks. Before that, I suggest you look at: https://shenyu.apache.org/zh/community/code-suggestions

Please read the Contribution Guideline before submitting the PR

hi， branch: master class: AlibabaDubboServiceBeanListener method: onApplicationEvent env: springboot detail: init AlibabaDubboServiceBeanListener invoke onApplicationEvent Map<String, ServiceBean> serviceBean = contextRefreshedEvent.getApplicationContext().getBeansOfType(ServiceBean.class); serviceBean.size() = 0

After several days discussion with some Apache members, the draft is almost ready , please vote for donating the soul and soul-dashboard to Apache Foundation. Soul will renamed Yuking！

The Yuking Proposal:

Yuking Proposal
Abstract
Yuking is a high performance Microservices API gateway in Java ecosystem, compatible with a variety of mainstream framework systems, supports hot plug. Users can write their own plugin meet the current requirement and future needs in a variety of scenarios, especially in large-scale scenes.

Proposal
The Yuking project already has a large community with many contributors (https://dromara.org/awesome/#contributors). It is also widely adopted by many companies and organizations (https://dromara.org/awesome/#knownusers).

We believe that bringing Yuking into Apache Software Foundation could advance development of a stronger and more diverse open source community.

Dromara submits this proposal to donate Yuking's source codes and all related documentations to Apache Software Foundation. The codes are already under Apache License Version 2.0.

Code base core: https://github.com/dromara/soul/
Code base dashboard: https://github.com/dromara/soul-dashboard/
Documentations: https://dromara.org/projects/soul/
Community: https://dromara.org/awesome/
Voted on submitting the proposal to the Incubator. Check here:

https://github.com/dromara/soul/issues/1237

Background
Yuking has been used in production environment, its performance and flexibility allow us to use up very cool with the following features:

Provides plugins such as current limiting, fusing, forwarding, routing monitoring and so on.
Support HTTP, RESTFul, WebSocket, Dubbo, GRPC, Tars and Spring Cloud Proxy.
Plug-in hot plug, users can customize the implementations.
Selectors and rules are dynamically configured for flexible matching.
Support for cluster deployment.
Support A/B test and grayscale publishing.
Rationale
More than 40 organizations (refer to Who is using Yuking: https://github.com/dromara/soul/issues/68 ) already benefit from running Yuking to make Microservices more easier. More than 40 feature ideas (https://github.com/dromara/soul/issues?q=is%3Aissue+label%3A%22type%3A+new+feature%22+is%3Aclosed) come from Yuking community. 

The rapid growth of Yuking community is empowered by open source. We believe the Apache foundation is a great fit as the long-term home for Yuking, as it provides an established process for community-driven development and decision making by consensus. This is exactly the model we want for future Yuking development.

Current Status
Meritocracy
Yuking was incubated in 2017 and open sourced on GitHub in 2018. Once open sourced, Yuking has been quickly adopted by multiple organization. We have set up the PMC and Committer. New contributors are guided and reviewed by existed PMC members. When they are ready, PMC will start a vote to promote him/her to become a member of PMC or Committer. See the details See the details here(https://dromara.org/projects/soul/committer/). Contributions are always welcomed and highly valued.

Community
Now we have set development teams for Yuking respectively in Dromara.org, didiglobal, PerfMa, YY, and IBM. We hope to grow the base of contributors by inviting all those who offer contributions through The Apache Way. Right now, we make use of GitHub as code hosting as well as for community communication.

Core Developers
The core developers, including experienced open source developers and team leaders, have formed a group full of diversity.

Yu Xiao. He is the founder of this project, Apache ShardingSphere Committer.
Jinwei Qin. He is the PMC member of Apache Dubbo and Apache ShardingSphere, the member of Dromara.
Yonglun Zhang. He is the PMC member of Apache ShardingSphere, the member of Dromara.
Liming Deng. He is the member of OpenTelemetry and Lettuce, the collaborator of jedis, the member of Dromara.
Yudong Tang. He is the member of OpenTelemetry, Caffeine maintainer, the member of Dromara.
Haochao Zhuang. He is the PMC member of Apache SkyWalking, the member of Dromara.
Alignment
In the Microservices ecosystem, Yuking is a very popular high performance Microservices API gateway supports many RPC framework including Apache Dubbo. We believe that it will help the further growth of Microservices community by having Yuking and Dubbo aligned within Apache foundation. The alignment is also beneficial to other Apache communities (such as Zookeeper).

Known Risks
Project Name
Current project name is Soul, will change it to Yuking after it is accepted by the Incubator.

Orphaned Products
The risk of the Yuking project being abandoned is minimal. There are at least 40 organizations (JD, didiglobal, PerfMa, YY, CHINA TELECOM, IBM, STATE GRID etc.) are highly incentivized to continue development. Many of these organizations have built critical business applications upon Yuking, and have devoted significant internal infrastructure investment in Yuking.

Inexperience with Open Source
As mentioned in Core Developers section, the core developers all work for companies that have developed or contributed to many open source projects. There are at least four PMC members from other Apache projects together with members of other famous community.

Therefore, we believe we have enough experience to deal with open source.

Homogenous Developers
The current core developers work across a variety of organizations including Dromara.org, didiglobal, PerfMa, YY; some individual developers are accepted as core developers of Yuking as well. Yuking has an active community of developers, and we are committed to recruiting additional committers based on their contributions to the project.

Reliance on Salaried Developers
It is expected that Yuking development will occur on both salaried time and on volunteer time, after hours. The majority of initial committers are paid by their employer to contribute to this project. However, they are all passionate about the project, and we are confident that the project will continue even if no salaried developers contribute to the project. We are committed to recruiting additional committers including non-salaried developers.

Relationships with Other Apache Products
Yuking is closely integrated with Dubbo, Zookeeper, Curator, Shiro and commons in numerous ways.

Yuking integrates Apache Zookeeper as one of the service registration/discovery mechanisms. Yuking is deeply integrated with Apache Dubbo and supports its protocol.

To some extent, Yuking has overlapping goals with the ASF existing API gateway APISIX, but they are in different ecological niche. APISIX is written by Lua and Perl with technical architecture Nginx + etcd, while Yuking is written by Java. Yuking can be conveniently integrated with the RPC framework in the Java ecosystem.

An Excessive Fascination with the Apache Brand
We acknowledge the value and reputation that the Apache brand would bring to Yuking. However, our primary interest is in the excellent community provided by Apache Software Foundation, in which all the projects could gain stability for long-term development.

Documentation
A complete set of Yuking documentations is provided in both English and Simplified Chinese. The project will be renamed to Yuking when migrating.

English: https://dromara.org/projects/soul/overview/
Chinese: https://dromara.org/zh/projects/soul/overview/
Initial Source
The project consists of three distinct codebases: core, dashboard and document. The address of three existed Git repositories are as follows:

https://github.com/dromara/soul
https://github.com/dromara/soul-dashboard
https://github.com/dromara/dromara.github.io/tree/master/content/en/projects/soul
Initial Source and Intellectual Property Submission Plan
As soon as Yuking is approved to join Apache Incubator, the Initial committers will submit ICLA(s). The code is already licensed under the Apache Software License, version 2.0.

External Dependencies
As all backend codes dependencies are managed using Apache Maven, none of the external libraries need to be packaged in a source distribution.

Most of dependencies have Apache compatible licenses，and the detail as follows:

Backend Dependencies
Dependency	License	Comments
mapstruct	Apache-2.0	
gson	Apache-2.0	
okhttp	Apache-2.0	


lombok	MIT	
simpleclient	Apache-2.0	
simpleclient_httpserver	Apache-2.0	
simpleclient_hotspot	Apache-2.0	
dubbo	Apache-2.0	
sofa-rpc-all	Apache-2.0	
disruptor	Apache-2.0	
mybatis-spring-boot-starter	Apache-2.0	
mysql-connector-java	GPL-2.0	Will be removed, and users who need this library can download it manually.
druid	Apache-2.0	
commons-lang3	Apache-2.0	
guava	Apache-2.0	
commons-collections4	Apache-2.0	
reactor-spring	Apache-2.0	
hessian	Apache-1.1	
kryo-shaded	BSD-3-Clause	
protostuff-core	Apache-2.0	
protostuff-runtime	Apache-2.0	
zookeeper	Apache-2.0	
zkclient	Apache-2.0	
pagehelper	MIT	
springfox-swagger2	Apache-2.0	
springfox-swagger-ui	Apache-2.0	
tars-spring-boot-starter	BSD 3-Clause	
slf4j-api	MIT	
jcl-over-slf4j	MIT	
hamcrest-library	BSD 3-Clause	
junit	EPL-1.0	
mockito-core	MIT	
mockito-inline	MIT	
spring	Apache-2.0	
spring-boot	Apache-2.0	
jetcd-core
Apache-2.0	
nacos	Apache-2.0	
The dashboard UI  dependencies are as follows:

Dashboard UI Dependencies
Dependency	License	Comments
stylelint-config-standard	MIT	
stylelint-config-prettier	MIT	
stylelint	MIT	
roadhog-api-doc	MIT	
roadhog	MIT	
regenerator-runtime	MIT	
redbox-react	MIT	
react-loadable	MIT	
pro-download	ISC	
Setprototypeof	ISC	
prettier	MIT	
mockjs	MIT	
lint-staged	MIT	
husky	MIT	
gh-pages	MIT	
eslint-plugin-react	MIT	
eslint-plugin-markdown	MIT	
eslint-plugin-jsx-a11y	MIT	
eslint-plugin-import	MIT	
eslint-plugin-compat	MIT	
eslint-plugin-babel	MIT	
eslint-config-prettier	MIT	
babel-eslint	MIT	
babel-plugin-dva-hmr	MIT	
babel-plugin-import	MIT	
babel-plugin-module-resolver	MIT	
babel-plugin-transform-decorators-legacy	MIT	
cross-env	MIT	
cross-port-killer	MIT	
enzyme	MIT	
eslint	MIT	
eslint-config-airbnb	MIT	
Url-polyfill	MIT	
Redux-logger	MIT	
react-resizable	MIT	
react-intl-universal	BSD 3-Clause	
react-fittext	MIT	
react-dom	MIT	
react-container-query	MIT	
react-document-title	MIT	
react	MIT	
qs	BSD 3-Clause	
prop-types	MIT	
path-to-regexp	MIT	
omit	MIT	
babel	MIT	
antd	MIT	
classnames	MIT	
dayjs	MIT	
dva	MIT	
dva-loading	MIT	
enquire-js	MIT	
lodash	MIT	
Required Resources
Mailing lists
yuking-dev: for development discussions
yuking-private: for PPMC discussions
yuking-notifications: for user notifications, and notifications from GitHub
Git Repositories:
https://github.com/apache/incubator-yuking
https://github.com/apache/incubator-yuking-dashboard
https://github.com/apache/incubator-yuking-website
Issue Tracking
The community would like to continue using GitHub Issues.

Initial Committers
Yu Xiao <[email protected]>
Jinwei Qin <[email protected]>
Yonglun Zhang <[email protected]>
Liming Deng <[email protected]>
Yudong Tang <[email protected]>
Lei Zhang <[email protected]>
Bin Chen <[email protected]>
Haochao Zhuang <[email protected]>
Jianming Ding <[email protected]>
Zhenbing Feng <[email protected]>
Affiliations
JD TECH: Yu Xiao, Yonglun Zhang
PerfMa: Yudong Tang
HelloBike: Lei Zhang
Shein: Xiaofeng Huang
didiglobal: Ziqiang Liang
YY: Haochao Zhuang
IBM: Ze Yang
Start-ups: Liming Deng, Bin Chen, Jianming Ding, Zhenbing Feng
Sponsors
Champion
Willem Ning Jiang (ningjiang at apache dot org)
Nominated Mentors
Willem Ning Jiang (ningjiang at apache dot org)
Jincheng Sun (jincheng at apache dot org)
Duo Zhang (zhangduo at apache dot org)
Sponsoring Entity
We are expecting the Apache Incubator could sponsor this project.

The vote is for All Initial Committers:

@yu199195 @tuohai666 @kimmking @dengliming @tydhot @SaberSola @nuo-promise @fengzhenbing @prFor @dmsolr Voters can either respond "agree, yes, +1", "disagree, no, -1", or "abstain".

After several days discussion with some Apache members, the draft is almost ready , please vote for donating the soul and soul-dashboard to Apache Foundation. soul will renamed Yuking！

the YukingProposal is :

Yuking Proposal

Abstract

Yuking is a high performance Microservices API gateway in Java ecosystem, compatible with a variety of mainstream framework systems, supports hot plug. Users can write their own plugin meet the current requirement and future needs in a variety of scenarios, especially in large-scale scenes.

Proposal

The Yuking project already has a large community with many contributors (https://dromara.org/awesome/#contributors). It is also widely adopted by many companies and organizations (https://dromara.org/awesome/#knownusers).

We believe that bringing Yuking into Apache Software Foundation could advance development of a stronger and more diverse open source community.

Dromara submits this proposal to donate Yuking's source codes and all related documentations to Apache Software Foundation. The codes are already under Apache License Version 2.0.

• Code base core: https://github.com/dromara/soul/
• Code base dashboard: https://github.com/dromara/soul-dashboard/
• Documentations: https://dromara.org/projects/soul/
• Community: https://dromara.org/awesome/

Background

Yuking has been used in production environment, its performance and flexibility allow us to use up very cool with the following features:

• Provides plugins such as current limiting, fusing, forwarding, routing monitoring and so on.
• Support HTTP, RESTFul, WebSocket, Dubbo, GRPC, Tars and Spring Cloud Proxy.
• Plug-in hot plug, users can customize the implementations.
• Selectors and rules are dynamically configured for flexible matching.
• Support for cluster deployment.
• Support A/B test and grayscale publishing.

Rationale

More than 40 organizations (refer to Who is using Yuking: https://github.com/dromara/soul/issues/68 ) already benefit from running Yuking to make Microservices more easier. More than 40 feature ideas (https://github.com/dromara/soul/issues?q=is%3Aissue+label%3A%22type%3A+new+feature%22+is%3Aclosed) come from Yuking community.

The rapid growth of Yuking community is empowered by open source. We believe the Apache foundation is a great fit as the long-term home for Yuking, as it provides an established process for community-driven development and decision making by consensus. This is exactly the model we want for future Yuking development.

Current Status Meritocracy

Yuking was incubated in 2017 and open sourced on GitHub in 2018. Once open sourced, Yuking has been quickly adopted by multiple organization. We have set up the PMC and Committer. New contributors are guided and reviewed by existed PMC members. When they are ready, PMC will start a vote to promote him/her to become a member of PMC or Committer. See the details See the details here(https://dromara.org/projects/soul/committer/). Contributions are always welcomed and highly valued.

Community

Now we have set development teams for Yuking respectively in Dromara.org, didiglobal, PerfMa, YY, and IBM. We hope to grow the base of contributors by inviting all those who offer contributions through The Apache Way. Right now, we make use of GitHub as code hosting as well as for community communication.

Core Developers

The core developers, including experienced open source developers and team leaders, have formed a group full of diversity.

• Yu Xiao. He is the founder of this project, Apache ShardingSphere Committer.
• Jinwei Qin. He is the PMC member of Apache Dubbo and Apache ShardingSphere, the member of Dromara.
• Yonglun Zhang. He is the PMC member of Apache ShardingSphere, the member of Dromara.
• Liming Deng. He is the member of OpenTelemetry and Lettuce, the collaborator of jedis, the member of Dromara.
• Yudong Tang. He is the member of OpenTelemetry, Caffeine maintainer, the member of Dromara.
• Haochao Zhuang. He is the PMC member of Apache SkyWalking, the member of Dromara.

Alignment

In the Microservices ecosystem, Yuking is a very popular high performance Microservices API gateway supports many RPC framework including Apache Dubbo. We believe that it will help the further growth of Microservices community by having Yuking and Dubbo aligned within Apache foundation. The alignment is also beneficial to other Apache communities (such as Zookeeper).

Known Risks

Project Name

Current project name is Soul, will change it to Yuking after it is accepted by the Incubator.

Orphaned Products

The risk of the Yuking project being abandoned is minimal. There are at least 40 organizations (JD, didiglobal, PerfMa, YY, CHINA TELECOM, IBM, STATE GRID etc.) are highly incentivized to continue development. Many of these organizations have built critical business applications upon Yuking, and have devoted significant internal infrastructure investment in Yuking.

Inexperience with Open Source

As mentioned in Core Developers section, the core developers all work for companies that have developed or contributed to many open source projects. There are at least four PMC members from other Apache projects together with members of other famous community.

Therefore, we believe we have enough experience to deal with open source.

Homogenous Developers

The current core developers work across a variety of organizations including Dromara.org, didiglobal, PerfMa, YY; some individual developers are accepted as core developers of Yuking as well. Yuking has an active community of developers, and we are committed to recruiting additional committers based on their contributions to the project.

Reliance on Salaried Developers

It is expected that Yuking development will occur on both salaried time and on volunteer time, after hours. The majority of initial committers are paid by their employer to contribute to this project. However, they are all passionate about the project, and we are confident that the project will continue even if no salaried developers contribute to the project. We are committed to recruiting additional committers including non-salaried developers.

Relationships with Other Apache Products

Yuking is closely integrated with Dubbo, Zookeeper, Curator, Shiro and commons in numerous ways.

Yuking integrates Apache Zookeeper as one of the service registration/discovery mechanisms. Yuking is deeply integrated with Apache Dubbo and supports its protocol.

To some extent, Yuking has overlapping goals with the ASF existing API gateway APISIX, but they are in different ecological niche. APISIX is written by Lua and Perl with technical architecture Nginx + etcd, while Yuking is written by Java. Yuking can be conveniently integrated with the RPC framework in the Java ecosystem.

An Excessive Fascination with the Apache Brand

We acknowledge the value and reputation that the Apache brand would bring to Yuking. However, our primary interest is in the excellent community provided by Apache Software Foundation, in which all the projects could gain stability for long-term development.

Documentation

A complete set of Yuking documentations is provided in both English and Simplified Chinese. The project will be renamed to Yuking when migrating.

• English: https://dromara.org/projects/soul/overview/
• Chinese: https://dromara.org/zh/projects/soul/overview/

Initial Source

The project consists of three distinct codebases: core, dashboard and document. The address of three existed Git repositories are as follows:

• https://github.com/dromara/soul
• https://github.com/dromara/soul-dashboard
• https://github.com/dromara/dromara.github.io/tree/master/content/en/projects/soul

Initial Source and Intellectual Property Submission Plan

As soon as Yuking is approved to join Apache Incubator, the Initial committers will submit ICLA(s). The code is already licensed under the Apache Software License, version 2.0.

External Dependencies

As all backend codes dependencies are managed using Apache Maven, none of the external libraries need to be packaged in a source distribution.

Most of dependencies have Apache compatible licenses，and the detail as follows:

• Backend Dependencies

| Dependency: | License | Comments | |:-------------------- |:-------------- |:---------------------------------------- | | mapstruct | Apache-2.0 | | | gson | Apache-2.0 | | | okhttp | Apache-2.0 | | | lombok | MIT | | | simpleclient | Apache-2.0 | | | simpleclient_httpserver| Apache-2.0 | | | simpleclient_hotspot | Apache-2.0 | | | dubbo | Apache-2.0 | | | sofa-rpc-all | Apache-2.0 | | | disruptor | Apache-2.0 | | | mybatis-spring-boot-starter | Apache-2.0 | | | mysql-connector-java | GPL-2.0 | Will be removed, and users who need this library can download it manually. | | druid | Apache-2.0 | | | commons-lang3 | Apache-2.0 | | | commons-collections4 | Apache-2.0 | | | reactor-spring | Apache-2.0 | | | hessian | Apache-1.1 | | | kryo-shaded | BSD-3-Clause | | | protostuff-core | BSD-3-Clause | | | protostuff-runtime | BSD-3-Clause | | | protostuff-runtime | BSD-3-Clause | | | zookeeper |Apache-2.0 | | | zkclient | Apache-2.0 | | | pagehelper |MIT | | | springfox-swagger2 |Apache-2.0 | | | springfox-swagger-ui | Apache-2.0 | | | tars-spring-boot-starter | BSD-3-Clause | | | slf4j-api |MIT | | | jcl-over-slf4j |MIT | | | hamcrest-library | BSD-3-Clause | | | junit | EPL-1.0 | | | mockito-core | MIT | | | mockito-inline | MIT | | | spring | Apache-2.0 | | | spring-boot | Apache-2.0 | | | jetcd-core | Apache-2.0 | | | nacos | Apache-2.0 | |

• The dashboard UI dependencies are as follows:

| Dependency | License | Comments | |:-------------------- |:-------------- |:---------------------------------------- | | stylelint-config-standard | MIT | | | stylelint-config-prettier | MIT | | | stylelint | MIT | | | roadhog-api-doc | MIT | | | roadhog | MIT | | | regenerator-runtime | MIT | | | redbox-react | MIT | | | react-loadable | MIT | | | pro-download | ISC | | | Setprototypeof | ISC | | | prettier | MIT | | | prettier | MIT | | | lint-staged | MIT | | | gh-pages | MIT | | | eslint-plugin-react | MIT | | | eslint-plugin-markdown | MIT | | | eslint-plugin-jsx-a11y | MIT | | | eslint-plugin-import | MIT | | | eslint-plugin-compat | MIT | | | eslint-plugin-babel | MIT | | | eslint-config-prettier | MIT | | | babel-eslint | MIT | | | babel-plugin-dva-hmr | MIT | | | babel-plugin-import | MIT | | | babel-plugin-module-resolver | MIT | | | babel-plugin-transform-decorators-legacy | MIT | | | cross-env | MIT | | | cross-port-killer | MIT | | | enzyme | MIT | | | eslint | MIT | | | eslint-config-airbnb | MIT | | | Url-polyfill | MIT | | | Redux-logger | MIT | | | react-resizable | MIT | | | react-intl-universal | BSD 3-Clause | | | react-fittext | MIT | | | react-dom | MIT | | | react-container-query | MIT | | | react-document-title | MIT | | | react | MIT | | | qs | BSD 3-Clause | | | prop-types | MIT | | | path-to-regexp | MIT | | | omit | MIT | | | babel | MIT | | | antd | MIT | | | classnames | MIT | | | dayjs | MIT | | | dva | MIT | | | dva-loading | MIT | | | enquire-js | MIT | | | lodash | MIT | |

Required Resources

Mailing lists

• yuking-dev: for development discussions
• yuking-private: for PPMC discussions
• yuking-notifications: for user notifications, and notifications from GitHub

Git Repositories:

• https://github.com/apache/incubator-yuking
• https://github.com/apache/incubator-yuking-dashboard
• https://github.com/apache/incubator-yuking-website

Issue Tracking

The community would like to continue using GitHub Issues.

Initial Committers

Yu Xiao [email protected] Jinwei Qin [email protected] Yonglun Zhang [email protected] Liming Deng [email protected] Yudong Tang [email protected] Lei Zhang [email protected] Bin Chen [email protected] Haochao Zhuang [email protected] Jianming Ding [email protected] Zhenbing Feng [email protected]

Affiliations

JD TECH: Yu Xiao, Yonglun Zhang PerfMa: Yudong Tang HelloBike: Lei Zhang Shein: Xiaofeng Huang didiglobal: Ziqiang Liang YY: Haochao Zhuang IBM: Ze Yang Start-ups: Liming Deng, Bin Chen, Jianming Ding, Zhenbing Feng

Sponsors

Champion

• Willem Ning Jiang (ningjiang at apache dot org)

Nominated Mentors

• Willem Ning Jiang (ningjiang at apache dot org)
• Jincheng Sun (jincheng at apache dot org)
• Duo Zhang (zhangduo at apache dot org)

Sponsoring Entity

We are expecting the Apache Incubator could sponsor this project.

The vote is for All Initial Committers:

@yu199195 @tuohai666 @kimmking @dengliming @tydhot @SaberSola @nuo-promise @fengzhenbing @prFor @dmsolr Voters can either respond "agree, yes, +1", "disagree, no, -1", or "abstain".

Question

I used the local startup method to test the interface of sofa. The following errors occurred. The registry used was zookeeper and the example provided on the official website was used

Error log printed by the gateway when called

2022-05-31 15:34:38 [boundedElastic-3] INFO org.apache.shenyu.plugin.base.AbstractShenyuPlugin - sofa selector success match , selector name :/sofa 2022-05-31 15:34:38 [boundedElastic-3] INFO org.apache.shenyu.plugin.base.AbstractShenyuPlugin - sofa rule success match , rule name :/sofa/findAll 2022-05-31 15:34:38 [boundedElastic-3] ERROR org.apache.shenyu.web.handler.GlobalErrorHandler - [b54a2486] Resolved [SofaRouteException: RPC-020060001: 没有获得服务[org.apache.shenyu.examples.sofa.api.service.SofaSingleParamService:1.0]的调用地址，请检查服务是否已经推送 ] for HTTP GET /sofa/findAll Information on zookeeper

Describe the bug

It seems that spring cloud dependence failed to register context path correctly, caused the actual path that shenyu visit is very strange.

Environment

• ShenYu version(s): 2.4.0

Steps to reproduce

1. Add dependence to my service: implementation("org.apache.shenyu:shenyu-spring-boot-starter-client-springcloud:${Const.shenYuVersion}")
2. Add properties:

shenyu:
  client:
    registerType: nacos
    props:
      contextPath: "/"
      nacosNameSpace: Shenyu
      isFull: false

3. Add annotation to class and function.

@RestController
@ShenyuSpringCloudClient(path = "/users")
internal class UserController(
    private val userService: UserService,
    private val watchfacePermissionService: WatchfacePermissionService,
) : IUserController {

    @ShenyuSpringCloudClient(path = "/hello")
    override fun hello(): String {
        return "Hello"
    }
}

Then, send a request to shenyu: http://localhost:7000/users/hello.

Expected behavior

Shenyu should redirect to http://xxx.xxx.xx.xx:7010/users/hello.

But the actual is http://192.168.50.20:7010ers/hello.

I checked the context_path's rules, there is a newly added:

After several attempts, I really can't understand the specific behavior of this plugin —— No matter what I fill in, I can't achieve the expected behavior.

Finally, I turned off the plugin (or delete this rule) and everything was fine.

So, does this tool misunderstand the path I set? Or are there other approch for this usecase that context_path is not required?

By the way, I have conformed that this attribute can not be null or empty, otherwise it will throw a Index out of bounds exception due to this code:

// NacosClientRegisterRepository#persistInterface()

@Override
public void persistInterface(final MetaDataRegisterDTO metadata) {
    String contextPath = metadata.getContextPath().substring(1);
    // ...
}

Debug logs

INFO 46443 --- [ctor-http-nio-3] o.a.s.plugin.base.AbstractShenyuPlugin   : context_path selector success match , selector name :/context-path/
INFO 46443 --- [ctor-http-nio-3] o.a.s.plugin.base.AbstractShenyuPlugin   : context_path rule success match , rule name :/context-path/
INFO 46443 --- [ctor-http-nio-3] o.a.s.plugin.base.AbstractShenyuPlugin   : springCloud selector success match , selector name :/
INFO 46443 --- [ctor-http-nio-3] o.a.s.plugin.base.AbstractShenyuPlugin   : springCloud rule success match , rule name ://users/**
INFO 46443 --- [ctor-http-nio-3] o.a.s.plugin.httpclient.WebClientPlugin  : The request urlPath is http://192.168.50.20:7010ers/hello, retryTimes is 0

Is there an existing issue for this?

• [X] I have searched the existing issues

Current Behavior

I'm using the fusing and current limiting functions. I found some problems. Can you help me ?

Expected Behavior

the fallbackUri of flow and degrade all can work

Steps To Reproduce

1：i code this @RestController @RequestMapping("/order") @ShenyuSpringCloudClient(path = "/order/**") public class OrderController {

/**
 * flow
 * @return
 */
@GetMapping("/list")
public String list(){
    return "order-list...";
}

/**
 * degrade
 * @return
 */
@GetMapping("/exception")
public String exception(){
  throw new RuntimeException("exception");
}

/**
 * degrade
 * @return
 */
@GetMapping("/error")
public String error(){
    int i = 0;
    return "" + 10/i;
}

/**
 * fallback
 * @return
 */
@GetMapping("/fallbackOfList")
public String fallbackOfList(){
    return "order-list-fallback...";
}

}

2：the sentinel selector and rules:

3：ask error or exception interface server:

Environment

ShenYu version(s):2.5.0

Debug logs

2022-09-16 16:30:30 [parallel-4] INFO org.apache.shenyu.plugin.base.AbstractShenyuPlugin - contextPath selector success match , selector name :/order-base 2022-09-16 16:30:30 [parallel-4] INFO org.apache.shenyu.plugin.base.AbstractShenyuPlugin - contextPath rule success match , rule name :/order-base 2022-09-16 16:30:30 [parallel-4] INFO org.apache.shenyu.plugin.base.AbstractShenyuPlugin - sentinel selector success match , selector name :/order-base/order/** 2022-09-16 16:30:30 [parallel-4] INFO org.apache.shenyu.plugin.base.AbstractShenyuPlugin - sentinel rule success match , rule name :/order-base/order/** 2022-09-16 16:30:30 [parallel-4] INFO org.apache.shenyu.plugin.base.AbstractShenyuPlugin - springCloud selector success match , selector name :/order-base 2022-09-16 16:30:30 [parallel-4] INFO org.apache.shenyu.plugin.base.AbstractShenyuPlugin - springCloud rule success match , rule name :/order-base/order/** 2022-09-16 16:30:30 [parallel-4] INFO org.apache.shenyu.plugin.httpclient.AbstractHttpClientPlugin - The request urlPath is null://10.167.52.192:8081/order/error, retryTimes is 0, retryStrategy is current 2022-09-16 16:30:31 [shenyu-netty-kqueue-3] ERROR org.apache.shenyu.web.handler.GlobalErrorHandler - handle error: [b6b27f1d-716] Resolved [UnsupportedOperationException: null] for HTTP GET /order-base/order/error java.lang.UnsupportedOperationException: null at org.springframework.http.ReadOnlyHttpHeaders.set(ReadOnlyHttpHeaders.java:106) Suppressed: org.apache.shenyu.plugin.sentinel.SentinelPlugin$SentinelFallbackException: 500 INTERNAL_SERVER_ERROR at org.apache.shenyu.plugin.sentinel.SentinelPlugin.lambda$doExecute$0(SentinelPlugin.java:60) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:289) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:209) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:230) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.netty.FutureMono$FutureSubscription.operationComplete(FutureMono.java:196) at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578) at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:571) at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:550) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491) at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616) at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605) at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104) at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48) at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:717) at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:272) at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:352) at io.netty.channel.kqueue.AbstractKQueueChannel.doWriteBytes(AbstractKQueueChannel.java:281) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.writeBytes(AbstractKQueueStreamChannel.java:111) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWriteSingle(AbstractKQueueStreamChannel.java:323) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWrite(AbstractKQueueStreamChannel.java:281) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931) at io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe.flush0(AbstractKQueueChannel.java:507) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895) at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.flush(CombinedChannelDuplexHandler.java:531) at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125) at io.netty.channel.CombinedChannelDuplexHandler.flush(CombinedChannelDuplexHandler.java:356) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:127) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765) at io.netty.channel.AbstractChannelHandlerContext$WriteTask.run(AbstractChannelHandlerContext.java:1071) at io.netty.util.concurrent.AbstractEventExecutor.runTask$$$capture(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:167) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.kqueue.KQueueEventLoop.run(KQueueEventLoop.java:293) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995) 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) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): *__checkpoint ⇢ org.apache.shenyu.web.configuration.ErrorHandlerConfiguration$1 [DefaultWebFilterChain] *__checkpoint ⇢ org.apache.shenyu.web.filter.FileSizeFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.apache.shenyu.web.filter.CrossFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authorization.AuthorizationWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authorization.ExceptionTranslationWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authentication.logout.LogoutWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.savedrequest.ServerRequestCacheWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.context.SecurityContextServerWebExchangeWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.context.ReactorContextWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.header.HttpHeaderWriterWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.config.web.server.ServerHttpSecurity$ServerWebExchangeReactorContextWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.WebFilterChainProxy [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.boot.actuate.metrics.web.reactive.server.MetricsWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ HTTP GET "/order-base/order/error" [ExceptionHandlingWebHandler] Original Stack Trace: at org.springframework.http.ReadOnlyHttpHeaders.set(ReadOnlyHttpHeaders.java:106) at org.springframework.http.HttpHeaders.setOrRemove(HttpHeaders.java:1636) at org.springframework.http.HttpHeaders.setLocation(HttpHeaders.java:1318) at org.apache.shenyu.plugin.base.fallback.FallbackHandler.fallback(FallbackHandler.java:74) at org.apache.shenyu.plugin.sentinel.SentinelPlugin.lambda$doExecute$1(SentinelPlugin.java:63) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:94) at com.alibaba.csp.sentinel.adapter.reactor.SentinelReactorSubscriber.hookOnError(SentinelReactorSubscriber.java:153) at com.alibaba.csp.sentinel.adapter.reactor.InheritableBaseSubscriber.onError(InheritableBaseSubscriber.java:176) at com.alibaba.csp.sentinel.adapter.reactor.SentinelReactorSubscriber.onError(SentinelReactorSubscriber.java:37) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onError(MonoPeekTerminal.java:258) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:209) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:230) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.netty.FutureMono$FutureSubscription.operationComplete(FutureMono.java:196) at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578) at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:571) at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:550) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491) at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616) at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605) at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104) at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48) at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:717) at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:272) at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:352) at io.netty.channel.kqueue.AbstractKQueueChannel.doWriteBytes(AbstractKQueueChannel.java:281) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.writeBytes(AbstractKQueueStreamChannel.java:111) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWriteSingle(AbstractKQueueStreamChannel.java:323) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWrite(AbstractKQueueStreamChannel.java:281) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931) at io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe.flush0(AbstractKQueueChannel.java:507) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895) at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.flush(CombinedChannelDuplexHandler.java:531) at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125) at io.netty.channel.CombinedChannelDuplexHandler.flush(CombinedChannelDuplexHandler.java:356) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:127) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765) at io.netty.channel.AbstractChannelHandlerContext$WriteTask.run(AbstractChannelHandlerContext.java:1071) at io.netty.util.concurrent.AbstractEventExecutor.runTask$$$capture(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:167) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.kqueue.KQueueEventLoop.run(KQueueEventLoop.java:293) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995) 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) 2022-09-16 16:30:31 [shenyu-netty-kqueue-3] ERROR org.springframework.web.server.adapter.HttpWebHandlerAdapter - [b6b27f1d-716] Error [java.lang.UnsupportedOperationException] for HTTP GET "/order-base/order/error", but ServerHttpResponse already committed (500 INTERNAL_SERVER_ERROR) 2022-09-16 16:30:31 [shenyu-netty-kqueue-3] ERROR reactor.netty.http.server.HttpServerOperations - [b6b27f1d-1, L:/0:0:0:0:0:0:0:1%0:9195 - R:/0:0:0:0:0:0:0:1%0:63900] Error finishing response. Closing connection java.lang.UnsupportedOperationException: null at org.springframework.http.ReadOnlyHttpHeaders.set(ReadOnlyHttpHeaders.java:106) at org.springframework.http.HttpHeaders.setContentType(HttpHeaders.java:977) at org.apache.shenyu.plugin.api.utils.WebFluxResultUtils.result(WebFluxResultUtils.java:64) at org.apache.shenyu.web.handler.GlobalErrorHandler.handle(GlobalErrorHandler.java:59) at org.springframework.web.server.handler.ExceptionHandlingWebHandler.lambda$handle$0(ExceptionHandlingWebHandler.java:77) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:94) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:106) at reactor.core.publisher.Operators.error(Operators.java:198) at reactor.core.publisher.MonoError.subscribe(MonoError.java:53) at reactor.core.publisher.Mono.subscribe(Mono.java:4400) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:106) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.Operators.error(Operators.java:198) at reactor.core.publisher.MonoError.subscribe(MonoError.java:53) at reactor.core.publisher.Mono.subscribe(Mono.java:4400) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber.onError(FluxDoOnEach.java:195) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:192) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:259) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:192) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:259) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:172) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:172) at reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onError(Operators.java:2063) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onError(MonoIgnoreThen.java:278) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:106) at reactor.core.publisher.Operators.error(Operators.java:198) at reactor.core.publisher.MonoError.subscribe(MonoError.java:53) at reactor.core.publisher.Mono.subscribe(Mono.java:4400) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onError(Operators.java:2063) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:100) at com.alibaba.csp.sentinel.adapter.reactor.SentinelReactorSubscriber.hookOnError(SentinelReactorSubscriber.java:153) at com.alibaba.csp.sentinel.adapter.reactor.InheritableBaseSubscriber.onError(InheritableBaseSubscriber.java:176) at com.alibaba.csp.sentinel.adapter.reactor.SentinelReactorSubscriber.onError(SentinelReactorSubscriber.java:37) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onError(MonoPeekTerminal.java:258) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:209) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:230) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.netty.FutureMono$FutureSubscription.operationComplete(FutureMono.java:196) at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578) at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:571) at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:550) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491) at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616) at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605) at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104) at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48) at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:717) at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:272) at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:352) at io.netty.channel.kqueue.AbstractKQueueChannel.doWriteBytes(AbstractKQueueChannel.java:281) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.writeBytes(AbstractKQueueStreamChannel.java:111) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWriteSingle(AbstractKQueueStreamChannel.java:323) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWrite(AbstractKQueueStreamChannel.java:281) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931) at io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe.flush0(AbstractKQueueChannel.java:507) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895) at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.flush(CombinedChannelDuplexHandler.java:531) at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125) at io.netty.channel.CombinedChannelDuplexHandler.flush(CombinedChannelDuplexHandler.java:356) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:127) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765) at io.netty.channel.AbstractChannelHandlerContext$WriteTask.run(AbstractChannelHandlerContext.java:1071) at io.netty.util.concurrent.AbstractEventExecutor.runTask$$$capture(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:167) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.kqueue.KQueueEventLoop.run(KQueueEventLoop.java:293) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995) 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) Suppressed: java.lang.UnsupportedOperationException: null at org.springframework.http.ReadOnlyHttpHeaders.set(ReadOnlyHttpHeaders.java:106) Suppressed: org.apache.shenyu.plugin.sentinel.SentinelPlugin$SentinelFallbackException: 500 INTERNAL_SERVER_ERROR at org.apache.shenyu.plugin.sentinel.SentinelPlugin.lambda$doExecute$0(SentinelPlugin.java:60) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:289) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:209) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:230) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.netty.FutureMono$FutureSubscription.operationComplete(FutureMono.java:196) at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578) at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:571) at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:550) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491) at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616) at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605) at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104) at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48) at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:717) at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:272) at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:352) at io.netty.channel.kqueue.AbstractKQueueChannel.doWriteBytes(AbstractKQueueChannel.java:281) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.writeBytes(AbstractKQueueStreamChannel.java:111) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWriteSingle(AbstractKQueueStreamChannel.java:323) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWrite(AbstractKQueueStreamChannel.java:281) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931) at io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe.flush0(AbstractKQueueChannel.java:507) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895) at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.flush(CombinedChannelDuplexHandler.java:531) at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125) at io.netty.channel.CombinedChannelDuplexHandler.flush(CombinedChannelDuplexHandler.java:356) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:127) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765) at io.netty.channel.AbstractChannelHandlerContext$WriteTask.run(AbstractChannelHandlerContext.java:1071) at io.netty.util.concurrent.AbstractEventExecutor.runTask$$$capture(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:167) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.kqueue.KQueueEventLoop.run(KQueueEventLoop.java:293) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995) 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) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): *__checkpoint ⇢ org.apache.shenyu.web.configuration.ErrorHandlerConfiguration$1 [DefaultWebFilterChain] *__checkpoint ⇢ org.apache.shenyu.web.filter.FileSizeFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.apache.shenyu.web.filter.CrossFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authorization.AuthorizationWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authorization.ExceptionTranslationWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.authentication.logout.LogoutWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.savedrequest.ServerRequestCacheWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.context.SecurityContextServerWebExchangeWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.context.ReactorContextWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.header.HttpHeaderWriterWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.config.web.server.ServerHttpSecurity$ServerWebExchangeReactorContextWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.security.web.server.WebFilterChainProxy [DefaultWebFilterChain] *__checkpoint ⇢ org.springframework.boot.actuate.metrics.web.reactive.server.MetricsWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ HTTP GET "/order-base/order/error" [ExceptionHandlingWebHandler] Original Stack Trace: at org.springframework.http.ReadOnlyHttpHeaders.set(ReadOnlyHttpHeaders.java:106) at org.springframework.http.HttpHeaders.setOrRemove(HttpHeaders.java:1636) at org.springframework.http.HttpHeaders.setLocation(HttpHeaders.java:1318) at org.apache.shenyu.plugin.base.fallback.FallbackHandler.fallback(FallbackHandler.java:74) at org.apache.shenyu.plugin.sentinel.SentinelPlugin.lambda$doExecute$1(SentinelPlugin.java:63) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:94) at com.alibaba.csp.sentinel.adapter.reactor.SentinelReactorSubscriber.hookOnError(SentinelReactorSubscriber.java:153) at com.alibaba.csp.sentinel.adapter.reactor.InheritableBaseSubscriber.onError(InheritableBaseSubscriber.java:176) at com.alibaba.csp.sentinel.adapter.reactor.SentinelReactorSubscriber.onError(SentinelReactorSubscriber.java:37) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onError(MonoPeekTerminal.java:258) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:209) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onComplete(FluxPeekFuseable.java:277) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:230) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:196) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:268) at reactor.netty.FutureMono$FutureSubscription.operationComplete(FutureMono.java:196) at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578) at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:571) at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:550) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491) at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616) at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605) at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104) at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48) at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:717) at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:272) at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:352) at io.netty.channel.kqueue.AbstractKQueueChannel.doWriteBytes(AbstractKQueueChannel.java:281) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.writeBytes(AbstractKQueueStreamChannel.java:111) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWriteSingle(AbstractKQueueStreamChannel.java:323) at io.netty.channel.kqueue.AbstractKQueueStreamChannel.doWrite(AbstractKQueueStreamChannel.java:281) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:931) at io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe.flush0(AbstractKQueueChannel.java:507) at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:895) at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.flush(CombinedChannelDuplexHandler.java:531) at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:125) at io.netty.channel.CombinedChannelDuplexHandler.flush(CombinedChannelDuplexHandler.java:356) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:728) at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:127) at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765) at io.netty.channel.AbstractChannelHandlerContext$WriteTask.run(AbstractChannelHandlerContext.java:1071) at io.netty.util.concurrent.AbstractEventExecutor.runTask$$$capture(AbstractEventExecutor.java:174) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:167) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470) at io.netty.channel.kqueue.KQueueEventLoop.run(KQueueEventLoop.java:293) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995) 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)

Anything else?

When the point is not interrupted, it will never enter the fallback. When I interrupt the point debugging, I can occasionally correctly return the expected fallback.

There are many unexpected returns. I think there must be something wrong

Implmented #4208

Make sure that:

• [x] You have read the contribution guidelines.
• [x] You submit test cases (unit or integration tests) that back your changes.
• [x] Your local test passed ./mvnw clean install -Dmaven.javadoc.skip=true.

#3450

Make sure that:

• [x] You have read the contribution guidelines.
• [x] You submit test cases (unit or integration tests) that back your changes.
• [x] Your local test passed ./mvnw clean install -Dmaven.javadoc.skip=true.

Question

shenyu version-2.5.0

shenyu Admin and gateway data sync by nacos

when i run websocket example project that selector data is empty in proxy of pluginList.

In the picture, the data is inserted by myself

this is a result by postman.

this is config of websocket server

error infomation

2023-01-09 15:07:32 [parallel-5] INFO  org.apache.shenyu.plugin.base.AbstractShenyuPlugin - websocket selector success match , selector name :/ws-annotation
2023-01-09 15:07:32 [parallel-5] INFO  org.apache.shenyu.plugin.base.AbstractShenyuPlugin - websocket rule success match , rule name :/myWs
2023-01-09 15:07:32 [parallel-5] INFO  org.apache.shenyu.plugin.websocket.WebSocketPlugin - you websocket urlPath is :ws://172.1.11.35:8001/ws-annotation/myWs
2023-01-09 15:07:32 [reactor-http-nio-9] WARN  reactor.netty.http.client.HttpClientConnect - [8bf5dd8b-1, L:/172.1.11.35:19834 - R:/172.1.11.35:8001] The connection observed an error
io.netty.handler.codec.http.websocketx.WebSocketClientHandshakeException: Invalid handshake response getStatus: 404 
	at io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker13.verify(WebSocketClientHandshaker13.java:272)
	at io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker.finishHandshake(WebSocketClientHandshaker.java:309)
	at reactor.netty.http.client.WebsocketClientOperations.onInboundNext(WebsocketClientOperations.java:116)
	at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:93)
	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.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
	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.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:327)
	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:299)
	at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
	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.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:722)
	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:658)
	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:584)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:496)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)
	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)
2023-01-09 15:07:32 [reactor-http-nio-9] WARN  reactor.netty.channel.FluxReceive - [8bf5dd8b-1, L:/172.1.11.35:19834 ! R:/172.1.11.35:8001] An exception has been observed post termination, use DEBUG level to see the full stack: io.netty.handler.codec.http.websocketx.WebSocketClientHandshakeException: Connection prematurely closed BEFORE opening handshake is complete.

Is there an existing issue for this?

• [X] I have searched the existing issues

Current Behavior

PENDING_SYNC was not set when checking upstream successfully, resulting in unable to update the handler of selector

Expected Behavior

private void check(final String selectorId, final List upstreamList) { List successList = Lists.newArrayListWithCapacity(upstreamList.size()); for (CommonUpstream commonUpstream : upstreamList) { final boolean pass = UpstreamCheckUtils.checkUrl(commonUpstream.getUpstreamUrl()); if (pass) { if (!commonUpstream.isStatus()) { commonUpstream.setTimestamp(System.currentTimeMillis()); commonUpstream.setStatus(true); // add PENDING_SYNC PENDING_SYNC.add(commonUpstream.hashCode()); LOG.info("UpstreamCacheManager check success the url: {}, host: {} ", commonUpstream.getUpstreamUrl(), commonUpstream.getUpstreamHost()); } successList.add(commonUpstream); ................

Steps To Reproduce

No response

Environment

ShenYu version(s):2.5.0

Debug logs

No response

Anything else?

No response

about https://github.com/apache/shenyu/issues/4249

Make sure that:

• [x] You have read the contribution guidelines.
• [x] You submit test cases (unit or integration tests) that back your changes.
• [x] Your local test passed ./mvnw clean install -Dmaven.javadoc.skip=true.