text:
[AIRFLOW-25] Configuration for Celery always required

Dear Airflow Maintainers,
Please accept this PR that addresses the following issues:

AIRFLOW-25

This patch is not perfect, but it makes all subcommands which are not related to celery work if the config file doesn't have the [celery] section.
Before applying this:
(env)sekikn@ubuntu-trusty:~/dev/incubator-airflow$ grep celery ~/airflow/airflow.cfg
(env)sekikn@ubuntu-trusty:~/dev/incubator-airflow$ for i in resetdb render variables pause version initdb test unpause run list_tasks backfill list_dags webserver scheduler task_state trigger_dag clear upgradedb; do echo $i; airflow $i; done
resetdb
[2016-05-22 16:57:25,357] {configuration.py:508} WARNING - section/key [celery/broker_url] not found in config
[2016-05-22 16:57:25,358] {__init__.py:36} INFO - Using executor SequentialExecutor
[2016-05-22 16:57:25,471] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
[2016-05-22 16:57:25,504] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt
[2016-05-22 16:57:25,804] {configuration.py:508} WARNING - section/key [celery/celeryd_concurrency] not found in config
Traceback (most recent call last):
  File "/home/sekikn/.virtualenvs/env/bin/airflow", line 6, in <module>
    exec(compile(open(__file__).read(), __file__, 'exec'))
  File "/home/sekikn/dev/incubator-airflow/airflow/bin/airflow", line 5, in <module>
    from airflow.bin.cli import CLIFactory
  File "/home/sekikn/dev/incubator-airflow/airflow/bin/cli.py", line 620, in <module>
    class CLIFactory(object):
  File "/home/sekikn/dev/incubator-airflow/airflow/bin/cli.py", line 815, in CLIFactory
    default=conf.get('celery', 'celeryd_concurrency')),
  File "/home/sekikn/dev/incubator-airflow/airflow/configuration.py", line 675, in get
    return conf.get(section, key, **kwargs)
  File "/home/sekikn/dev/incubator-airflow/airflow/configuration.py", line 512, in get
    "in config".format(**locals()))
airflow.configuration.AirflowConfigException: section/key [celery/celeryd_concurrency] not found in config

(all subcommands fail in the same way)

upgradedb
[2016-05-22 16:57:44,137] {configuration.py:508} WARNING - section/key [celery/broker_url] not found in config
[2016-05-22 16:57:44,138] {__init__.py:36} INFO - Using executor SequentialExecutor
[2016-05-22 16:57:44,249] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
[2016-05-22 16:57:44,283] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt
[2016-05-22 16:57:44,584] {configuration.py:508} WARNING - section/key [celery/celeryd_concurrency] not found in config
Traceback (most recent call last):
  File "/home/sekikn/.virtualenvs/env/bin/airflow", line 6, in <module>
    exec(compile(open(__file__).read(), __file__, 'exec'))
  File "/home/sekikn/dev/incubator-airflow/airflow/bin/airflow", line 5, in <module>
    from airflow.bin.cli import CLIFactory
  File "/home/sekikn/dev/incubator-airflow/airflow/bin/cli.py", line 620, in <module>
    class CLIFactory(object):
  File "/home/sekikn/dev/incubator-airflow/airflow/bin/cli.py", line 815, in CLIFactory
    default=conf.get('celery', 'celeryd_concurrency')),
  File "/home/sekikn/dev/incubator-airflow/airflow/configuration.py", line 675, in get
    return conf.get(section, key, **kwargs)
  File "/home/sekikn/dev/incubator-airflow/airflow/configuration.py", line 512, in get
    "in config".format(**locals()))
airflow.configuration.AirflowConfigException: section/key [celery/celeryd_concurrency] not found in config

and after:
(env)sekikn@ubuntu-trusty:~/dev/incubator-airflow$ for i in resetdb render variables pause version initdb test unpause run list_tasks backfill list_dags webserver scheduler task_state trigger_dag clear upgradedb; do echo $i; airflow $i; done
resetdb
[2016-05-22 16:58:15,115] {configuration.py:509} WARNING - section/key [celery/broker_url] not found in config
[2016-05-22 16:58:15,116] {__init__.py:36} INFO - Using executor SequentialExecutor
[2016-05-22 16:58:15,226] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
[2016-05-22 16:58:15,259] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt
DB: sqlite:////home/sekikn/airflow/airflow.db
This will drop existing tables if they exist. Proceed? (y/n)
Bail.
render
[2016-05-22 16:58:17,720] {configuration.py:509} WARNING - section/key [celery/broker_url] not found in config
[2016-05-22 16:58:17,722] {__init__.py:36} INFO - Using executor SequentialExecutor
[2016-05-22 16:58:17,831] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
[2016-05-22 16:58:17,865] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt
usage: airflow render [-h] [-sd SUBDIR] dag_id task_id execution_date
airflow render: error: too few arguments

(snip)

upgradedb
[2016-05-22 16:58:50,016] {configuration.py:509} WARNING - section/key [celery/broker_url] not found in config
[2016-05-22 16:58:50,017] {__init__.py:36} INFO - Using executor SequentialExecutor
[2016-05-22 16:58:50,127] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
[2016-05-22 16:58:50,160] {driver.py:120} INFO - Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt
DB: sqlite:////home/sekikn/airflow/airflow.db
[2016-05-22 16:58:50,481] {db.py:222} INFO - Creating tables
INFO  [alembic.runtime.migration] Context impl SQLiteImpl.
INFO  [alembic.runtime.migration] Will assume non-transactional DDL.

But I'm not sure we should add other properties for celery into the "defaults" dict in the same way. I'd be glad if you'd give me some advice.

Please follow the guidelines (as is mentioned in the template) from http://chris.beams.io/posts/git-commit/ for your commit messages thanks!

Thanks for the feedback @bolkedebruin, I'll close this and open another PR with a more appropriate commit message :)

authors: bolkedebruin sekikn

repo: apache/incubator-airflow

license_source: bigquery


text:
[AIRFLOW-2234] Enable insert_rows for PrestoHook

Make sure you have checked all steps below.
JIRA

[x] My PR addresses the following Airflow JIRA issues and references them in the PR title. For example, "[AIRFLOW-XXX] My Airflow PR"

https://issues.apache.org/jira/browse/AIRFLOW-2234

Description

[x] Here are some details about my PR, including screenshots of any UI changes:

PrestoHook.insert_rows() raises NotImplementedError for now.
But Presto 0.126+ allows specifying column names in INSERT queries,
so we can leverage DbApiHook.insert_rows() almost as is.
This PR implements this function, and includes some flake8 fixes.
Tests

[x] My PR adds the following unit tests OR does not need testing for this extremely good reason:

Added some tests to TestDbApiHook and newly added TestPrestoHook.
In addition, I manually called PrestoHook.insert_rows() and confirmed that it worked as expected.
Commits

[x] My commits all reference JIRA issues in their subject lines, and I have squashed multiple commits if they address the same issue. In addition, my commits follow the guidelines from "How to write a good git commit message":

Subject is separated from body by a blank line
Subject is limited to 50 characters
Subject does not end with a period
Subject uses the imperative mood ("add", not "adding")
Body wraps at 72 characters
Body explains "what" and "why", not "how"

[x] Passes git diff upstream/master -u -- "*.py" | flake8 --diff

Codecov Report

Merging #3146 into master will increase coverage by 0.07%.
The diff coverage is 100%.

@@            Coverage Diff             @@
##           master    #3146      +/-   ##
==========================================
+ Coverage   73.05%   73.13%   +0.07%
==========================================
  Files         180      180
  Lines       12654    12654
==========================================
+ Hits         9245     9254       +9
+ Misses       3409     3400       -9

Impacted Files
Coverage Δ

airflow/hooks/dbapi_hook.py
82.6% <100%> (+6.08%)
:arrow_up:

airflow/hooks/presto_hook.py
39.13% <100%> (+2.17%)
:arrow_up:

airflow/models.py
87.33% <0%> (+0.04%)
:arrow_up:

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 f642242...b5e631f. Read the comment docs.

source: gharchive/pull-request

authors: codecov-io sekikn

license_type: permissive


text:
add skywalking plugin instructions

NOTE: Please read the Contributing.md guidelines before submitting your patch:
https://github.com/apache/incubator-apisix/blob/master/Contributing.md#how-to-add-a-new-feature-or-change-an-existing-one
Summary
SUMMARY_HERE
Full changelog

[Implement ...]
[Add related tests]
...

Issues resolved
Fix #XXX

please take a look at the outputs of Travis-CI:
https://travis-ci.org/github/apache/incubator-apisix/jobs/693361232
Reading configuration file [.travis/ASF-Release.cfg]...
Scanning files starting at [./]...
Scan detected 95 error(s) in 2 file(s):
  [./doc/plugins/skywalking-cn.md]:
      85: line contains tabs.
      86: line contains tabs.
      87: line contains tabs.
      88: line contains tabs.
      90: line contains tabs.
      91: line contains tabs.
      92: line contains tabs.
      93: line contains tabs.
      95: line contains tabs.
      96: line contains tabs.
      97: line contains tabs.
      98: line contains tabs.
      98: line has trailing whitespace.
      99: line contains tabs.
     100: line contains tabs.

I have removed the tabs character.

Scan detected 15 error(s) in 2 file(s):

  [./doc/plugins/skywalking-cn.md]:

      98: line has trailing whitespace.

     102: line has trailing whitespace.

     116: line has trailing whitespace.

     122: line has trailing whitespace.

     127: line has trailing whitespace.

     128: line has trailing whitespace.

     129: line has trailing whitespace.

  [./doc/plugins/skywalking.md]:

      37: line has trailing whitespace.

      85: line has trailing whitespace.

     100: line has trailing whitespace.

     104: line has trailing whitespace.

     118: line has trailing whitespace.

     124: line has trailing whitespace.

     130: line has trailing whitespace.

     131: line has trailing whitespace.

@cyxinda please take a look

have done.
发自我的iPhone

在 2020年6月3日，上午10:00，Wen Ming notifications@github.com 写道：

Scan detected 15 error(s) in 2 file(s):
[./doc/plugins/skywalking-cn.md]:
  98: line has trailing whitespace.

 102: line has trailing whitespace.

 116: line has trailing whitespace.

 122: line has trailing whitespace.

 127: line has trailing whitespace.

 128: line has trailing whitespace.

 129: line has trailing whitespace.

[./doc/plugins/skywalking.md]:
  37: line has trailing whitespace.

  85: line has trailing whitespace.

 100: line has trailing whitespace.

 104: line has trailing whitespace.

 118: line has trailing whitespace.

 124: line has trailing whitespace.

 130: line has trailing whitespace.

 131: line has trailing whitespace.

@cyxinda please take a look
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub, or unsubscribe.

@cyxinda merged, thx

发自我的iPhone

在 2020年6月3日，下午3:41，Wen Ming notifications@github.com 写道：

@cyxinda merged, thx
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub, or unsubscribe.

authors: cyxinda membphis moonming

repo: apache/incubator-apisix

license_source: github-api


text:
[BEAM-847] Use a Random Long instead of a Random UUID for Aggregator IDs

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

[x] Make sure the PR title is formatted like:
[BEAM-<Jira issue #>] Description of pull request
[x] Make sure tests pass via mvn clean verify. (Even better, enable
Travis-CI on your fork and ensure the whole test matrix passes).
[x] Replace <Jira issue #> in the title with the actual Jira issue
number, if there is one.
[x] If this contribution is large, please file an Apache
Individual Contributor License Agreement.

Aggregator IDs are used to ensure that an Aggregator's identity is
consistent across synchronization barriers. This is only relevant when
constructing the map of Step -> Aggregator to enable querying, as the
DoFns represented within the graph may be serialized. The identity has
no impact on the interaction between the runner and aggregator, which is
the responsibility of the ProcessContext object and
setupDelegateAggregators.
UUID#randomUUID uses a shared SecureRandom to create the bytes of the
UUID; SecureRandom#nextBytes is a synchronized method, so regardless of
the underlying source of randomness, only one random UUID can be
generated at a time. Instead, use a random long to identify aggregators.
This should be sufficient for user-created aggregators, and system
aggregators should not care about the id.

Any reason to use a random ID rather than unique sequential IDs, i.e. from a static AtomicLong? Using random values risks spurious collisions (albeit improbable).

LGTM, merging.

authors: dhalperi swegner tgroh

repo: apache/incubator-beam


text:
[Doc][Advanced Mode] Provide docs on how to set up subtasks and more configurations for advanced mode

Some subtasks and configurations can only be set in advanced mode, but there is no documentation on how to set subtasks and more other configurations in advanced mode. Please provide documentation on how to set up subtasks and other configurations that are only supported in advanced mode.

Can you add it when you're available? @abeizn

Hi @chenggui53 , I think this doc can solve your problem, feel free to reopen the issue if it doesn't. https://devlake.apache.org/docs/Configuration/AdvancedMode#examples

source: gharchive/issue

repo: apache/incubator-devlake


text:
Improve OverlordResourceTest to actually verify API calls

Currently OverlordResourceTest is calling Java methods directly instead of calling HTTP endpoints. This sometimes makes somethings to test hard. For example, https://github.com/apache/incubator-druid/pull/6679 isn't easy to test by directly calling Java methods. Testing resourceFilters is also difficult.
Probably this test can be improved using jersey-test-framework or something else similar. Also we may need to consider upgrading jersey first.

@QiuMM yes, sounds great.

repo: apache/incubator-druid


text:
Why  generated  subquery  and use DruidOuterQueryRel

how to write this with json context
SELECT "Time", sum("<3"),sum("3~5"),sum("6~15")
from (
    SELECT
    "Time",
     case WHEN "Count1" < 3 then 1 ELSE 0  end as "<3",
     case WHEN "Count1" >= 3 and "Count1"<= 5 then 2  ELSE 0  end as "3~5",
     case WHEN "Count1" >= 6 and "Count1"<= 15 then 3  ELSE 0  end as "6~15"
    from (
          SELECT
            TIME_FLOOR("__time", 'PT5M') AS "Time", "uuid", COUNT(*) AS "Count1"
          FROM "app_time"
          WHERE "__time" >= CURRENT_TIMESTAMP - INTERVAL '1' HOUR AND "__time" <= CURRENT_TIMESTAMP
          GROUP BY 1, 2
          ORDER BY "Time" ASC ))
GROUP BY 1
ORDER BY "Time"

When i use EXPLAIN PLAN FOR to see plan , I saw
DruidOuterQueryRel(query=[{"queryType":"groupBy","dataSource":{"type":"table","name":"__subquery__"}.......

But I don't have this data source，How can I do

Hm, I don't think the nested groupBy is returning the final plan when using EXPLAIN PLAN FOR, "subquery" there is a dummy value.
If you need to run nested queries, you would want to use GroupBy with a Query datasource (https://druid.apache.org/docs/latest/querying/datasource.html) where you specify another GroupBy as the subquery

authors: Doslin jon-wei


text:
[Backport] Set new keys for integration-tests.

Backport of #6554 to 0.13.0-incubating.

merging since travis passed and changes are to files not checked by TeamCity

authors: gianm jon-wei


text:
Fix bugs: class no found for servlet; no applications, services... menu entries; no log output. enhance script start.sh

#3
Fix bugs:

class no found for servlet;
no applications, services... menu entries;
no log output.

Enhance start script:
enhance script start.sh

@huadong 多谢！
另外，作为提醒：要是只fix没有applications和services目录，改下配置文件就可以了

我使用最新版的dubbo，monitor中心后台还是没有 Applications, Services, Hosts 菜单入口，怎么解决？

jetty-monitor=com.alibaba.dubbo.monitor.simple.container.JettyContainer
dubbo.container=log4j,spring,registry,jetty-monitor
这样改就好了

this PR looks good to me.
I have a little concern about including slf4j-log4j12 as a dependency, user should able to have more choice. but we can discuss this later.

Run mvn clean package, all pass.

authors: htynkn huadong huanzhang jiaopy kingyoungfan

repo: apache/incubator-dubbo-ops


text:
When will EDAS extend be updated to support the latest version 2.7.0

[x] I have searched the issues of this repository and believe that this is not a duplicate.
[x] I have checked the FAQ of this repository and believe that this is not a duplicate.

Environment

Dubbo version: 2.7.0
Operating System version: MAC
Java version: 1.8

Steps to reproduce this issue

update dubbo to 2.7.0
update edas-dubbo-extension to 1.0.4
start app

Expected Result
services successfully registery to edas config center
Actual Result
java.lang.IllegalStateException: Failed to load extension class(interface: interface org.apache.dubbo.registry.RegistryFactory, class line: com.alibaba.edas.dubbo.EdasRegistryFactory) in jar, cause: com.alibaba.dubbo.registry.support.AbstractRegistryFactory
java.lang.IllegalStateException: Failed to load extension class(interface: interface org.apache.dubbo.registry.RegistryFactory, class line: com.alibaba.edas.dubbo.EdasRegistryFactory) in jar:file:/Users/nobody/.m2/repository/com/alibaba/edas/edas-dubbo-extension/1.0.4/edas-dubbo-extension-1.0.4.jar!/META-INF/dubbo/com.alibaba.dubbo.registry.RegistryFactory, cause: com.alibaba.dubbo.registry.support.AbstractRegistryFactory
	at org.apache.dubbo.common.extension.ExtensionLoader.loadResource(ExtensionLoader.java:675) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.ExtensionLoader.loadDirectory(ExtensionLoader.java:643) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.ExtensionLoader.loadExtensionClasses(ExtensionLoader.java:624) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.ExtensionLoader.getExtensionClasses(ExtensionLoader.java:595) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.ExtensionLoader.getSupportedExtensions(ExtensionLoader.java:373) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.factory.SpiExtensionFactory.getExtension(SpiExtensionFactory.java:32) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.factory.AdaptiveExtensionFactory.getExtension(AdaptiveExtensionFactory.java:47) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.ExtensionLoader.injectExtension(ExtensionLoader.java:562) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.ExtensionLoader.createExtension(ExtensionLoader.java:529) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.common.extension.ExtensionLoader.getExtension(ExtensionLoader.java:344) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.rpc.Protocol$Adaptive.export(Protocol$Adaptive.java) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.config.ServiceConfig.doExportUrlsFor1Protocol(ServiceConfig.java:553) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.config.ServiceConfig.doExportUrls(ServiceConfig.java:402) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.config.ServiceConfig.doExport(ServiceConfig.java:363) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.config.ServiceConfig.export(ServiceConfig.java:345) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.config.spring.ServiceBean.export(ServiceBean.java:318) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.config.spring.ServiceBean.onApplicationEvent(ServiceBean.java:112) ~[dubbo-2.7.0.jar:2.7.0]
	at org.apache.dubbo.config.spring.ServiceBean.onApplicationEvent(ServiceBean.java:58) ~[dubbo-2.7.0.jar:2.7.0]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172) ~[spring-context-5.1.5.RELEASE.jar:5.1.5.RELEASE]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165) ~[spring-context-5.1.5.RELEASE.jar:5.1.5.RELEASE]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139) ~[spring-context-5.1.5.RELEASE.jar:5.1.5.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:402) ~[spring-context-5.1.5.RELEASE.jar:5.1.5.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:359) ~[spring-context-5.1.5.RELEASE.jar:5.1.5.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:896) ~[spring-context-5.1.5.RELEASE.jar:5.1.5.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:552) ~[spring-context-5.1.5.RELEASE.jar:5.1.5.RELEASE]
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775) ~[spring-boot-2.1.3.RELEASE.jar:2.1.3.RELEASE]
	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) ~[spring-boot-2.1.3.RELEASE.jar:2.1.3.RELEASE]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:316) ~[spring-boot-2.1.3.RELEASE.jar:2.1.3.RELEASE]
	at org.springframework.boot.builder.SpringApplicationBuilder.run(SpringApplicationBuilder.java:139) [spring-boot-2.1.3.RELEASE.jar:2.1.3.RELEASE]
	at com.copote.nstamp.AuthRpcServiceApplication.main(AuthRpcServiceApplication.java:25) [classes/:na]
Caused by: java.lang.NoClassDefFoundError: com.alibaba.dubbo.registry.support.AbstractRegistryFactory
	at java.lang.Class.forName0(Native Method) ~[na:1.8.0_192]
	at java.lang.Class.forName(Class.java:348) ~[na:1.8.0_192]
	at org.apache.dubbo.common.extension.ExtensionLoader.loadResource(ExtensionLoader.java:672) ~[dubbo-2.7.0.jar:2.7.0]
	... 29 common frames omitted

Hi,
Thanks for reporting. I have contacted the support from EDAS, and will get back to you as soon as possible. IMO, future report should go to EDAS, not here.

Thanks for reply. i will open a new ticket at Alibaba cloud console ask for help too

Hi, I did confirm with support from EDAS, they confirm that edas-dubbo-extension would fail on 2.7.0, they are looking into this issue.
The issue on Dubbo side is when you are writing a custom plugin that depends on dubbo 2.6.x, it is possible that it will fail when upgrading to 2.7.x, the compatibility is not 100% guaranteed. For example, if your plugin depends on com.alibaba.dubbo.registry.support.AbstractRegistry, there is no compatible class provided in 2.7.x.
The community is addressing this issue, and will notify you when there is an update.

change edas-dubbo-extension version to 2.0.1 will work.
edas-dubbo-extension 2.x.x is compatible with dubbo  2.7.x
edas-dubbo-extension 1.x.x is compatible with dubbo  between 2.6.0 and 2.7.0

where is edas-dubbo-extension 2.x.x and 1.x.x?

@mostcool  search it in maven central directly, you can also refer to EDAS documents here https://help.aliyun.com/document_detail/97471.html

Thanks for working efficiently

repo: apache/incubator-dubbo


text:
#2134 Fix dependency conflict issue for com.alibaba:dubbo-rpc-thrift

https://github.com/apache/incubator-dubbo/issues/2134

@kimmking PR to solve #2134. Thanks a lot.

@LeoAugust19 Could you solve the conflict?

@diecui1202 Yes! This patch can solve the conflict problem.

@LeoAugust19 I mean the conflict of the git merge.

https://github.com/LeoAugust19/incubator-dubbo/commit/6d76c5f2dafa5782a0eaf9919e883d0c0357cfba

@diecui1202 The conflict problem is solved by this patch.

@LeoAugust19 I suggest you create a new branch from apache/incubator-dubbo:master, then merge your branch to the new branch. then start a new PR.

I don't know what happened to this PR. I suggest close it first and start a new PR if necessary.

@LeoAugust19


text:
Optimize getExtensionClass method.

Optimize getExtensionClass method.
Just return the class instead of throwing exception.
org.apache.dubbo.common.extension.ExtensionLoader#getExtensionClass just has one caller that is hasExtension. So it will not effect other logic.

Codecov Report

Merging #2788 into master will decrease coverage by 0.11%.
The diff coverage is 100%.

@@            Coverage Diff             @@
##           master    #2788      +/-   ##
==========================================
- Coverage    63.6%   63.49%   -0.12%
==========================================
  Files         577      577
  Lines       25935    25930       -5
  Branches     4544     4544
==========================================
- Hits        16495    16463      -32
- Misses       7283     7302      +19
- Partials     2157     2165       +8

Impacted Files
Coverage Δ

...apache/dubbo/common/extension/ExtensionLoader.java
80.44% <100%> (-0.2%)
:arrow_down:

...ache/dubbo/remoting/transport/AbstractChannel.java
75% <0%> (-12.5%)
:arrow_down:

...he/dubbo/remoting/transport/netty/NettyClient.java
72.88% <0%> (-8.48%)
:arrow_down:

...e/dubbo/remoting/transport/netty/NettyChannel.java
54.11% <0%> (-8.24%)
:arrow_down:

...org/apache/dubbo/rpc/filter/ActiveLimitFilter.java
83.33% <0%> (-5.56%)
:arrow_down:

...he/dubbo/remoting/transport/netty/NettyServer.java
67.85% <0%> (-3.58%)
:arrow_down:

...c/main/java/org/apache/dubbo/rpc/RpcException.java
85.71% <0%> (-3.58%)
:arrow_down:

...pache/dubbo/remoting/transport/AbstractClient.java
65.94% <0%> (-2.17%)
:arrow_down:

...e/dubbo/registry/integration/RegistryProtocol.java
81.25% <0%> (-1.93%)
:arrow_down:

...ache/dubbo/remoting/transport/mina/MinaClient.java
56.92% <0%> (-1.54%)
:arrow_down:

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 38a6511...0242787. Read the comment docs.

@beiwei30
Simple pr. Would u pls give a review?

authors: carryxyh codecov-io


text:
Consider opening the context menu on a download link to be a download.

The download statistics still don't match those of SourceForge. They're off by roughly an order of magnitude. My theory is that this may be due to the fact that the majority of downloads will not be occurring on the same machine as the browser, but rather remotely on the server where things will actually be installed.
We naturally can't see that information without access to the server logs, but perhaps we can track when the download URL is copied. This change does exactly that, considering the opening of the context menu on a download link to be a download.
If this fills the gap between our statistics and those of SourceForge, it should be almost immediately apparent.

Seems like it's worth keeping track of this as well.

authors: jmuehlner mike-jumper

repo: apache/incubator-guacamole-website


text:
使用 gremlin-console graph computer报错 Graph does not support graph computer

Expected behavior 期望表现
期望能支持graph computer
Actual behavior 实际表现
不支持
Graph does not support graph computer
Steps to reproduce the problem 复现步骤

bin/gremlin-console.sh
:remote connect tinkerpop.server conf/remote.yaml
:> graph.compute().program(PageRankVertexProgram.build().create()).submit().get()

Status of loaded data 数据状态
Vertex/Edge summary 数据量

loaded vertices amount: {like 10 million}
loaded edges amount: {like 20 million}
loaded time: {like 200s}

Vertex/Edge example 数据示例
{type something here...}
Schema(VertexLabel, EdgeLabel, IndexLabel) 元数据结构
{type something here...}
Specifications of environment 环境信息

hugegraph version: {like v0.7.4}
operating system: {like centos 7.4, 32 CPUs, 64G RAM}
hugegraph backend: {like cassandra 3.10, cluster with 20 nodes, 3 x 1TB HDD disk each node}

感谢您的反馈，目前HugeGraph确实是不支持 graph computer 的。

感谢您的反馈，目前HugeGraph确实是不支持 graph computer 的。

我想问一下,features 里面介绍的
与Hadoop、Spark GraphX等大数据系统集成，支持Bulk Load操作

这一点是怎么实现的

这个是通过HugeSpark这个模块实现的，但是目前这个模块还有一些坑，暂时还不会开源。

@Linary 请问如果要自行实现bulk load到hbase的话有什么建议么？

Hey there!
Are there any updates on this matter?
Thank you

Hey there! Are there any updates on this matter?
Thank you

we open source the hugegraph-computer now, please move and try it, current conversation will be locked soon

repo: apache/incubator-hugegraph


text:
[INLONG-2030][Bug]inlong-agent raises NPE error when running

[INLONG-2030][Bug]inlong-agent raises NPE error when running
Fixes #2030
Motivation
inlong-agent raises NPE error when running
Modifications
pass inlong group id in proxy sender
Documentation

Does this pull request introduce a new feature? (no)

Codecov Report

Merging #2031 (50f484b) into master (dd9e8f7) will decrease coverage by 0.00%.
The diff coverage is n/a.

@@             Coverage Diff              @@
##             master    #2031      +/-   ##
============================================
- Coverage     12.28%   12.27%   -0.01%
+ Complexity     1159     1157       -2
============================================
  Files           413      413
  Lines         35225    35225
  Branches       5542     5542
============================================
- Hits           4328     4325       -3
- Misses        30127    30129       +2
- Partials        770      771       +1

Impacted Files
Coverage Δ

.../inlong/tubemq/corebase/policies/FlowCtrlItem.java
38.88% <0.00%> (-1.12%)
:arrow_down:

.../tubemq/corebase/policies/FlowCtrlRuleHandler.java
34.07% <0.00%> (-0.45%)
:arrow_down:

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 dd9e8f7...50f484b. Read the comment docs.

authors: EMsnap codecov-commenter

repo: apache/incubator-inlong


text:
Add Grafana IoTDB Bridge Artefact to distrbution in tools/grafana fol…

…der.
NOTE: Should also be picked to develop.

@chrisdutz thanks for the hint I changed it to use the dependencySet. You can have a look if you like :)

LGTM now :-)

LGTM.
Chris is an expert of Maven... If he says "LGTM", it really looks good for how to use Maven :D

Oh, sorry too late @jixuan1989. We could do separate downloads if we use multiple assembly files. Then user can decide what to download. Thats the way to go, I guess?

It is ok. I have approved it...
Maybe we can separate it in v0.10 and release more connectors at that time.

+1. So I do not pick it for master, yet?
WDYT? (currently about to do that :) ).

If we can not implement separating these binaries into several files quickly, I think we can pick this commit to master... to keep consistent between 0.9 and the master branch...
And then consider separating them as a new feature.
How do you think?

Besides, when we are in the incubator, there is an issue that we can retain at most 10 files. Otherwise, there will be a warning on this page to say incubator project can have at most 10 files, please delete stale version files: http://incubator.apache.org/clutch/iotdb.html (the Release Chapter).

authors: JulianFeinauer chrisdutz jixuan1989

repo: apache/incubator-iotdb


text:
[incubator-kie-drools-5784] Review DRLParser.g4 and DRL6Expressions.g…

…4 to replace IDENTIFIER with drlIdentifier
Issue:

https://github.com/apache/incubator-kie-drools/issues/5784

Before PR in drools-model-codegen
[ERROR] Tests run: 2434, Failures: 74, Errors: 0, Skipped: 9

After PR in drools-model-codegen
[ERROR] Tests run: 2434, Failures: 72, Errors: 0, Skipped: 9

The main purpose is to hardening backward compatibility with the new test DRLParserIdentifierTest.

@yurloc @mariofusco @gitgabrio Please review, thanks!

repo: apache/incubator-kie-drools


text:
[incubator-kie-issues#1624] Add missing auth header to data-index SVG request

Closes https://github.com/apache/incubator-kie-issues/issues/1624

Many thanks for submitting your Pull Request :heart:!
Please make sure that your PR meets the following requirements:

[ ] You have read the contributors guide
[ ] Pull Request title is properly formatted: KOGITO-XYZ Subject
[ ] Pull Request title contains the target branch if not targeting main: [0.9.x] KOGITO-XYZ Subject
[ ] Pull Request contains link to the JIRA issue
[ ] Pull Request contains link to any dependent or related Pull Request
[ ] Pull Request contains description of the issue
[ ] Pull Request does not include fixes for issues other than the main ticket

How to replicate CI configuration locally?

Build Chain tool does "simple" maven build(s), the builds are just Maven commands, but because the repositories relates and depends on each other and any change in API or class method could affect several of those repositories there is a need to use build-chain tool to handle cross repository builds and be sure that we always use latest version of the code for each repository.
build-chain tool is a build tool which can be used on command line locally or in Github Actions workflow(s), in case you need to change multiple repositories and send multiple dependent pull requests related with a change you can easily reproduce the same build by executing it on Github hosted environment or locally in your development environment. See local execution details to get more information about it.

How to retest this PR or trigger a specific build:

for pull request checks
Please add comment: Jenkins retest this

for a specific pull request check
Please add comment: Jenkins (re)run [kogito-apps|kogito-examples] tests

for quarkus branch checks
Run checks against Quarkus current used branch
Please add comment: Jenkins run quarkus-branch

for a quarkus branch specific check
Run checks against Quarkus current used branch
Please add comment: Jenkins (re)run [kogito-apps|kogito-examples] quarkus-branch

for quarkus main checks
Run checks against Quarkus main branch
Please add comment: Jenkins run quarkus-main

for a specific quarkus main check
Run checks against Quarkus main branch
Please add comment: Jenkins (re)run [kogito-apps|kogito-examples] quarkus-main

for quarkus lts checks
Run checks against Quarkus lts branch
Please add comment: Jenkins run quarkus-lts

for a specific quarkus lts check
Run checks against Quarkus lts branch
Please add comment: Jenkins (re)run [kogito-apps|kogito-examples] quarkus-lts

for native checks
Run native checks
Please add comment: Jenkins run native

for a specific native check
Run native checks
Please add comment: Jenkins (re)run [kogito-apps|kogito-examples] native

for native lts checks
Run native checks against quarkus lts branch
Please add comment: Jenkins run native-lts

for a specific native lts check
Run native checks against quarkus lts branch
Please add comment: Jenkins (re)run [kogito-apps|kogito-examples] native-lts

How to backport a pull request to a different branch?

In order to automatically create a backporting pull request please add one or more labels having the following format backport-<branch-name>, where <branch-name> is the name of the branch where the pull request must be backported to (e.g., backport-7.67.x to backport the original PR to the 7.67.x branch).

NOTE: backporting is an action aiming to move a change (usually a commit) from a branch (usually the main one) to another one, which is generally referring to a still maintained release branch. Keeping it simple: it is about to move a specific change or a set of them from one branch to another.

Once the original pull request is successfully merged, the automated action will create one backporting pull request per each label (with the previous format) that has been added.
If something goes wrong, the author will be notified and at this point a manual backporting is needed.

NOTE: this automated backporting is triggered whenever a pull request on main branch is labeled or closed, but both conditions must be satisfied to get the new PR created.

Quarkus-3 PR check is failing ... what to do ?

The Quarkus 3 check is applying patches from the `.ci/environments/quarkus-3/patches`.
The first patch, called 0001_before_sh.patch, is generated from Openrewrite .ci/environments/quarkus-3/quarkus3.yml recipe. The patch is created to speed up the check. But it may be that some changes in the PR broke this patch.
No panic, there is an easy way to regenerate it. You just need to comment on the PR:
jenkins rewrite quarkus-3

and it should, after some minutes (~20/30min) apply a commit on the PR with the patch regenerated.
Other patches were generated manually. If any of it fails, you will need to manually update it... and push your changes.

PR job #2 was: UNSTABLE
Possible explanation: This should be test failures

Reproducer
build-chain build full_downstream  -f 'https://raw.githubusercontent.com/${AUTHOR:apache}/incubator-kie-kogito-pipelines/${BRANCH:main}/.ci/buildchain-config-pr-cdb.yaml' -o 'bc' -p apache/incubator-kie-kogito-apps -u https://github.com/apache/incubator-kie-kogito-apps/pull/2143 --skipParallelCheckout
NOTE: To install the build-chain tool, please refer to https://github.com/kiegroup/github-action-build-chain#local-execution

Please look here: https://ci-builds.apache.org/job/KIE/job/kogito/job/main/job/pullrequest_jobs/job/kogito-apps-pr/job/PR-2143/2/display/redirect
Test results:

PASSED: 1767
FAILED: 1

Those are the test failures:

org.kie.kogito.index.infinispan.ProcessDataIndexInfinispanKafkaIT.testProcessInstanceEvents
1 expectation failed.JSON path data.UserTaskInstances[0].potentialGroups[0] doesn't match.Expected: managers  Actual: null

repo: apache/incubator-kie-kogito-apps


text:
QuarkusTopicDiscoveryTest failure in quarkus3 migration branch

Describe the bug
Currently I'm working on quarkus3 migration branch and QuarkusTopicDiscoveryTest fails probably because of @SetSystemProperty
[INFO] Running org.kie.kogito.addon.quarkus.messaging.common.QuarkusTopicDiscoveryTest
[ERROR] Tests run: 4, Failures: 2, Errors: 0, Skipped: 0, Time elapsed: 0.103 s <<< FAILURE! -- in org.kie.kogito.addon.quarkus.messaging.common.QuarkusTopicDiscoveryTest
[ERROR] org.kie.kogito.addon.quarkus.messaging.common.QuarkusTopicDiscoveryTest.verifyTopicsWithPropertiesSameTopic -- Time elapsed: 0.018 s <<< FAILURE!
java.lang.AssertionError:

Expected size: 2 but was: 0 in:
[]
	at org.kie.kogito.addon.quarkus.messaging.common.QuarkusTopicDiscoveryTest.verifyTopicsWithPropertiesSameTopic(QuarkusTopicDiscoveryTest.java:68)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)

[ERROR] org.kie.kogito.addon.quarkus.messaging.common.QuarkusTopicDiscoveryTest.verifyTopicsWithPropertiesSet -- Time elapsed: 0.004 s <<< FAILURE!
java.lang.AssertionError:

Expected size: 2 but was: 0 in:
[]
	at org.kie.kogito.addon.quarkus.messaging.common.QuarkusTopicDiscoveryTest.verifyTopicsWithPropertiesSet(QuarkusTopicDiscoveryTest.java:51)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)

[INFO]
[INFO] Results:
[INFO]
[ERROR] Failures:
[ERROR]   QuarkusTopicDiscoveryTest.verifyTopicsWithPropertiesSameTopic:68
Expected size: 2 but was: 0 in:
[]
[ERROR]   QuarkusTopicDiscoveryTest.verifyTopicsWithPropertiesSet:51
Expected size: 2 but was: 0 in:
[]
[INFO]
[ERROR] Tests run: 14, Failures: 2, Errors: 0, Skipped: 0

Note that if you run the whole test class, the 2 test methods fail, but if you run the specific test method, it succeeds.
https://kie.zulipchat.com/#narrow/stream/381961-drools-dev/topic/Quarkus.203.20migration/near/403630691
Expected behavior
All tests in QuarkusTopicDiscoveryTest pass.
Actual behavior
2 test methods in QuarkusTopicDiscoveryTest fail.
How to Reproduce?
Build mario's drools quakus3 branch

git clone https://github.com/mariofusco/drools.git
cd drools
git checkout -b quakus3 origin/quarkus3
mvn clean install -Dquickly

Build mario's kogito-runtimes quakus3 branch

git clone https://github.com/mariofusco/kogito-runtimes.git
cd kogito-runtimes
git checkout -b quakus3 origin/quarkus3
Remove @Disabled in QuarkusTopicDiscoveryTest.java
mvn clean install -Dquickly
cd quarkus/addons/messaging
mvn verify

Output of uname -a or ver
Linux tkobayas.nrt.csb 4.18.0-477.27.1.el8_8.x86_64 #1 SMP Thu Aug 31 10:29:22 EDT 2023 x86_64 x86_64 x86_64 GNU/Linux
Output of java -version
openjdk version "17.0.1" 2021-10-19
GraalVM version (if different from Java)
No response
Kogito version or git rev (or at least Quarkus version if you are using Kogito via Quarkus platform BOM)
3.0.0-SNAPSHOT (as updated by quakus3 migration)
Build tool (ie. output of mvnw --version or gradlew --version)
Apache Maven 3.9.5 (57804ffe001d7215b5e7bcb531cf83df38f93546)
Additional information
The PR for the migration branch :
https://github.com/apache/incubator-kie-drools/pull/5589
https://github.com/apache/incubator-kie-kogito-runtimes/pull/3291

Thank you for the detailed description, @tkobayas 🙏

Updated the reproduce steps to meet mario's branches.

authors: ricardozanini tkobayas

repo: apache/incubator-kie-kogito-runtimes


text:
Enable transaction support for the mset command

Search before asking

[X] I had searched in the issues and found no similar issues.

Motivation
Hi, guys
Currently, using the mset command to write data in batches cannot ensure atomicity. We should let the system perform a rollback when the process is interrupted during data writing.
Regard
Solution
No response
Are you willing to submit a PR?

[ ] I'm willing to submit a PR!

Thanks for @tarvfx filing this issue.

@git-hulk Thanks for you adding this feature to the to do list. In addition, I would like to add that other batch operation instructions other than mset, such as msetnx, should all be applicable to this enhanced feature.

Rather than making mset atomic, I wonder if it is better to add a new flag to mset for atomicity and leave the default behavior align with Redis.

@PragmaTwice Yes, we won't expect to affect the default behavior of the mset command.

This was resolved in #1634

authors: PragmaTwice git-hulk tarvfx

repo: apache/incubator-kvrocks


text:
shell engine cannot support special operations

My linkis version is 1.0.2. When I use the shell engine to submit a shell job, the contents of the job are ls > tmp.txt. This job will report a mistake. I think some special operation can cause a job to fail, such as |、>.

I tried to modify shellEngineConnExecutor's code and this issue was resolved.
val processBuilder: ProcessBuilder = new ProcessBuilder(generateRunCodeToList(code))

private def generateRunCodeToList(code: String): util.List[String] = {
    util.Arrays.asList("sh", "-c", code)
  }

I didn't do the full test and didn't know if there would be any other risks.

I tried to modify shellEngineConnExecutor's code and this issue was resolved.
val processBuilder: ProcessBuilder = new ProcessBuilder(generateRunCodeToList(code))

private def generateRunCodeToList(code: String): util.List[String] = {
    util.Arrays.asList("sh", "-c", code)
  }

I didn't do the full test and didn't know if there would be any other risks.

This code seems to just change the scala.Array type to the java.util.List type. Can you display specific error messages?

Can you display specific error messages

Toggle the constructor of the ProcessBuilder, Pass List<String> instead of String...,  To avoid parsing special symbols in scripts.
There is no explicit error message, just a prompt for the shell code is wrong.The following is a detailed error:
2021-12-02 14:24:04.538 ERROR [Linkis-Default-Scheduler-Thread-5] com.webank.wedatasphere.linkis.manager.engineplugin.shell.executor.ShellEngineConnExecutor 61 error - exitCode is 1
2021-12-02 14:24:04.539 ERROR [Linkis-Default-Scheduler-Thread-5] com.webank.wedatasphere.linkis.manager.engineplugin.shell.executor.ShellEngineConnExecutor 61 error -
2021-12-02 14:24:04.555 ERROR [Linkis-Default-Scheduler-Thread-5] com.webank.wedatasphere.linkis.manager.engineplugin.shell.executor.ShellEngineConnExecutor 57 error - execute code failed! com.webank.wedatasphere.linkis.manager.engineplugin.shell.exception.ShellCodeErrorException: errCode: 50037 ,desc: shell code is wrong ,ip: ct6 ,port: 44542 ,serviceKind: linkis-cg-engineconn
	at com.webank.wedatasphere.linkis.manager.engineplugin.shell.executor.ShellEngineConnExecutor.executeLine(ShellEngineConnExecutor.scala:88) ~[linkis-engineplugin-shell-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor$$anonfun$toExecuteTask$2$$anonfun$apply$10$$anonfun$apply$11.apply(ComputationExecutor.scala:179) ~[linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor$$anonfun$toExecuteTask$2$$anonfun$apply$10$$anonfun$apply$11.apply(ComputationExecutor.scala:178) ~[linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:39) ~[linkis-common-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor$$anonfun$toExecuteTask$2$$anonfun$apply$10.apply(ComputationExecutor.scala:180) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor$$anonfun$toExecuteTask$2$$anonfun$apply$10.apply(ComputationExecutor.scala:174) [linkis-computation-engineconn-1.0.2.jar:?]
	at scala.collection.immutable.Range.foreach(Range.scala:160) [scala-library-2.11.12.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor$$anonfun$toExecuteTask$2.apply(ComputationExecutor.scala:173) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor$$anonfun$toExecuteTask$2.apply(ComputationExecutor.scala:149) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.common.utils.Utils$.tryFinally(Utils.scala:60) [linkis-common-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor.toExecuteTask(ComputationExecutor.scala:222) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor$$anonfun$3.apply(ComputationExecutor.scala:237) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor$$anonfun$3.apply(ComputationExecutor.scala:237) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.common.utils.Utils$.tryFinally(Utils.scala:60) [linkis-common-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.acessible.executor.entity.AccessibleExecutor.ensureIdle(AccessibleExecutor.scala:54) [linkis-accessible-executor-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.acessible.executor.entity.AccessibleExecutor.ensureIdle(AccessibleExecutor.scala:48) [linkis-accessible-executor-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor.ensureOp(ComputationExecutor.scala:133) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.execute.ComputationExecutor.execute(ComputationExecutor.scala:236) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.service.TaskExecutionServiceImpl.com$webank$wedatasphere$linkis$engineconn$computation$executor$service$TaskExecutionServiceImpl$$executeTask(TaskExecutionServiceImpl.scala:239) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.service.TaskExecutionServiceImpl$$anon$1$$anonfun$run$1.apply$mcV$sp(TaskExecutionServiceImpl.scala:172) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.service.TaskExecutionServiceImpl$$anon$1$$anonfun$run$1.apply(TaskExecutionServiceImpl.scala:170) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.service.TaskExecutionServiceImpl$$anon$1$$anonfun$run$1.apply(TaskExecutionServiceImpl.scala:170) [linkis-computation-engineconn-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:39) [linkis-common-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.common.utils.Utils$.tryAndWarn(Utils.scala:68) [linkis-common-1.0.2.jar:?]
	at com.webank.wedatasphere.linkis.engineconn.computation.executor.service.TaskExecutionServiceImpl$$anon$1.run(TaskExecutionServiceImpl.scala:170) [linkis-computation-engineconn-1.0.2.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_281]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_281]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_281]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_281]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_281]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_281]

The two construction methods seem to be equivalent. I tested the shell and found no errors. Is it caused by others?
ls /home/hadoop > /home/hadoop/tmp.txt

For me, with the changes above, my Shell Engine can successfully execute 'ls > tmp.txt'. If you can pass the 'ls /home/hadoop > /home/hadoop/tmp.txt' test, I can't think of any other reason.

repo: apache/incubator-linkis


text:
[Feature] Optimize the state storage of Statement in the JDBC engine to support richer functions and solve some potential concurrency problems

Search before asking

[X] I had searched in the issues and found no similar feature requirement.

Problem Description
优化JDBC引擎中，statement对象的状态存储，以支持更加丰富的功能，例如，利用statement来cancel一些在进行的SQL查询，以及解决潜在的一些并发问题。
In the JDBC engine, the state storage of the statement object is optimized to support richer functions, for example, using the statement to cancel some ongoing SQL queries and solve some potential concurrency problems.
Description
优化JDBC引擎中，statement对象的状态存储，以支持更加丰富的功能，例如，利用statement来cancel一些在进行的SQL查询，以及解决潜在的一些并发问题。
In the JDBC engine, the state storage of the statement object is optimized to support richer functions, for example, using the statement to cancel some ongoing SQL queries and solve some potential concurrency problems.
Use case
No response
solutions
No response
Anything else
No response
Are you willing to submit a PR?

[X] Yes I am willing to submit a PR!

Thank you, this is a concurrency issue and needs to be fixed

authors: CCweixiao peacewong


text:
METRON-113 Update documentation based on project reorganization

Fixing some really minor documentation misses based on the project reorganization.

+1

+1 - looks good to me.

authors: dlyle65535 merrimanr nickwallen

repo: apache/incubator-metron


text:
MXNet operator profile aggregate counter issue

It looks the operator counter of the aggregated output is the 2x of real value.
I used below gluon model (mainly copied from https://mxnet.incubator.apache.org/tutorials/gluon/gluon.html, contains 2 convolutions for each forward pass) and did profiling, the aggregated convolution counter is 4 instead of 2, the counter doubled for other OPs as well.
# import dependencies
from __future__ import print_function
import numpy as np
import mxnet as mx
import mxnet.ndarray as F
import mxnet.gluon as gluon
from mxnet.gluon import nn
from mxnet import autograd

class Net(gluon.Block):
    def __init__(self, **kwargs):
        super(Net, self).__init__(**kwargs)
        with self.name_scope():
            # layers created in name_scope will inherit name space
            # from parent layer.
            self.conv1 = nn.Conv2D(6, kernel_size=5)
            self.pool1 = nn.MaxPool2D(pool_size=(2,2))
            self.conv2 = nn.Conv2D(16, kernel_size=5)
            self.pool2 = nn.MaxPool2D(pool_size=(2,2))
            self.fc1 = nn.Dense(120)
            self.fc2 = nn.Dense(84)
            self.fc3 = nn.Dense(10)

    def forward(self, x):
        x = self.pool1(F.relu(self.conv1(x)))
        x = self.pool2(F.relu(self.conv2(x)))
        # 0 means copy over size from corresponding dimension.
        # -1 means infer size from the rest of dimensions.
        x = x.reshape((0, -1))
        x = F.relu(self.fc1(x))
        x = F.relu(self.fc2(x))
        x = self.fc3(x)
        return x

net = Net()
# Initialize on CPU. Replace with `mx.gpu(0)`, or `[mx.gpu(0), mx.gpu(1)]`,
# etc to use one or more GPUs.
net.collect_params().initialize(mx.init.Xavier(), ctx=mx.cpu())

mx.profiler.set_config(aggregate_stats=True)
mx.profiler.set_state('run')

data = mx.nd.random_normal(shape=(10, 1, 32, 32))  # dummy data
output = net(data)
output.wait_to_read()

print(mx.profiler.dumps())

The profile output is below:
[jinhuang@mlt-ace image-classification]$ python test_gluon.py

Profile Statistics.
        Note that counter items are counter values and not time units.
Device Storage
=================
Name                          Total Count        Time (ms)    Min Time (ms)    Max Time (ms)    Avg Time (ms)
----                          -----------        ---------    -------------    -------------    -------------
Memory: cpu/0                          65         535.0320           0.0240         726.1520         363.0640

MXNET_C_API
=================
Name                          Total Count        Time (ms)    Min Time (ms)    Max Time (ms)    Avg Time (ms)
----                          -----------        ---------    -------------    -------------    -------------
MXNDArrayReshape64                      1           0.0140           0.0140           0.0140           0.0140
MXNDArrayFree                          21           0.1100           0.0000           0.0290           0.0052
MXAutogradMarkVariables                10           0.1080           0.0080           0.0180           0.0108
MXNDArrayCreateEx                      10           0.0340           0.0020           0.0070           0.0034
MXNDArrayGetDType                      15           0.0000           0.0000           0.0000           0.0000
MXSymbolSetAttr                        47           0.0920           0.0010           0.0130           0.0020
MXNDArrayGetContext                    13           0.0070           0.0000           0.0010           0.0005
MXNDArrayWaitToRead                     1          12.0930          12.0930          12.0930          12.0930
MXSymbolInferShape                      7           0.5700           0.0490           0.2320           0.0814
MXNet C API Calls                     230           0.2300           0.0010           0.2300           0.1145
MXNet C API Concurrency               459           0.0010           0.0000           0.0010           0.0005
MXSymbolCreateAtomicSymbol               7           0.3780           0.0190           0.1540           0.0540
MXAutogradSetIsRecording               10           0.0140           0.0000           0.0070           0.0014
MXAutogradSetIsTraining                10           0.0040           0.0000           0.0010           0.0004
MXImperativeInvokeEx                   52           3.7600           0.0150           1.7250           0.0723
MXNDArrayGetShape                      25           0.0190           0.0000           0.0030           0.0008

operator
=================
Name                          Total Count        Time (ms)    Min Time (ms)    Max Time (ms)    Avg Time (ms)
----                          -----------        ---------    -------------    -------------    -------------
WaitForVar                              2           0.0080           0.0040           0.0040           0.0040
FullyConnected                          6           0.7770           0.0590           0.2380           0.1295
Pooling                                 4           0.5280           0.0890           0.1750           0.1320
_zeros                                 20           0.6220           0.0020           0.1410           0.0311
ResourceParallelRandomSetSeed               2          14.7190           7.3580           7.3610           7.3595
DeleteVariable                         40           0.1130           0.0010           0.0070           0.0028
relu                                    8           0.2220           0.0070           0.0770           0.0278
_random_normal                          2          10.8890           5.4430           5.4460           5.4445
_random_uniform                        10           0.7370           0.0100           0.2740           0.0737
_full                                  10           0.0350           0.0010           0.0080           0.0035
Convolution                             4          12.5590           0.5260           5.7530           3.1398
zeros_like                             20           0.3800           0.0030           0.1490           0.0190
CopyCPU2CPU                            20           0.4690           0.0030           0.1530           0.0235
Reorder                                 4           0.0110           0.0010           0.0050           0.0027

@pengzhao-intel

@nswamy Can you please add labels-
Python, Gluon, Profiler

@cjolivier01 This functionality is really useful and we apply it in our daily works.
Could you help fix the issue?

authors: Roshrini jinhuang415 pengzhao-intel

repo: apache/incubator-mxnet


text:
avoiding jitter in loading data set

Hi All,
Are the data sets stored in the GPU after the first epoch or do they have to copied for every run?
I am running cifar10 and notice lot of fluctuations for every batch.
If the data sets are copied for every new batch, is there a way to keep them on the GPU for all the epochs?

You can write a data iter that hold data on the gpu and feed a slice each time

can you please point me to the relevant files/functions? I will give it a shot

@piiswrong  hello,I have some captcha data and build lst and rec form, but I don't know how to write a iterator for my data while use example/warpctc/lstm_ocr.py, I also don't know if you run your data with mxnet and hope to be abel to get your answer, thank you!

This issue is closed due to lack of activity in the last 90 days. Feel free to reopen if this is still an active issue. Thanks!


text:
Gradient accumulation of several sample

I search to compute a triplet ranking loss.
To achieve this, I need to accumulate gradient through several example and update weight with the resulting gradient.
In chainer we can easily do that because backward function accumulate gradient by default :

We need to clear the gradients first because the backward() method accumulates gradients instead of overwriting the previous values.

Is there a way to do this with Mxnet Gluon and the autograd API ?
That similar to gradient accumulation inside a batch.

You mean only collect several examples' gradients in a batch to update weight? You can create a 0-1 mask and use it as the outermost out_grad to backward。

A bit more description of the process (it's for image retrieval-like task):

compute triplet loss on 10000 (query, relevant, non-relevant) images
sort these triplet to keep the 100 first with higher loss
compute gradient on these 100 samples
aggregate gradients
update weight

I can't pack these 100 samples in one batch and make the learning process on this batch because a batch of 100*3 images take too much place in graphic card memory.

If you want to do this on whole dataset level. Then you should do an extra forward on whole dataset every time to get the indices of top-100, then create a batch, run forward-backward and update weight.

I try but I can't run forward-backward on a batch of 100+ images, it consume too much memory and crash.
That's why I ask if there is a way to accumulate gradient outside of batch usage.

I think you can hack update  in optimizer, store the gradients into states in previous batches. For example, if batch size is 10, then in the first 9 batches only aggregate the gradients into states and in the 10th batch aggregate the gradients then update the weights.

I was looking for a more regular way :(
I will test to hack the optimizer thx

I'm afraid that there is no regular way because actually this is not a regular case. I think hacking optimizer is the easiest way.
On 09/23/2017 18:07, Erwan BERNARD wrote:
I was looking for a more regular way :(
I will test to hack the optimizer thx
—
You are receiving this because you commented.
Reply to this email directly, view it on GitHub, or mute the thread.

authors: ZiyueHuang edmBernard


text:
[android] mxnet succeed build but link to mxnet.so failed in my project

I can build arm-android(generate the mxnet.so and mxnet.a, and checked them with readelf, they are for arm machine), but when linked mxnet.so in my project, the error is:
incubator-mxnet/lib/libmxnet.so: error: undefined reference to 'stderr'

Environment info (Required)
----------Python Info----------
('Version      :', '2.7.12')
('Compiler     :', 'GCC 5.4.0 20160609')
('Build        :', ('default', 'Nov 19 2016 06:48:10'))
('Arch         :', ('64bit', 'ELF'))
------------Pip Info-----------
('Version      :', '9.0.1')
('Directory    :', '/usr/local/lib/python2.7/dist-packages/pip')
----------MXNet Info-----------
('Version      :', '0.12.1')
('Directory    :', '/home/luban/incubator-mxnet/python/mxnet')
Traceback (most recent call last):
  File "diagnose.py", line 171, in <module>
    check_mxnet()
  File "diagnose.py", line 113, in check_mxnet
    except FileNotFoundError:
NameError: global name 'FileNotFoundError' is not defined

```bash
Package used (Python/R/Scala/Julia): c_predict_api
## Build info (Required if built from source)
Compiler (gcc/clang/mingw/visual studio):
export CC = /path/to/android-toolchains/bin/arm-linux-androideabi-clang
export CXX = /path/to/android-toolchains/bin/arm-linux-androideabi-clang++
export AS = /path/to/android-toolchains/bin/arm-linux-androideabi-as
export AR = /path/to/android-toolchains/bin/arm-linux-androideabi-ar
export LD = /path/to/android-toolchains/bin/arm-linux-androideabi-ld
export CPP =/path/to/android-toolchains/bin/arm-linux-androideabi-cpp
MXNet commit hash:
(e0c7906693f0c79b0ce34a4d777c26a6bf1903c1

Build config:
#-------------------------------------------------------------------------------
#  Template configuration for compiling mxnet
#
#  If you want to change the configuration, please use the following
#  steps. Assume you are on the root directory of mxnet. First copy the this
#  file so that any local changes will be ignored by git
#
#  $ cp make/config.mk .
#
#  Next modify the according entries, and then compile by
#
#  $ make
#
#  or build in parallel with 8 threads
#
#  $ make -j8
#-------------------------------------------------------------------------------

#---------------------
# We do not assign compilers here.  Often when cross-compiling these will already
# be set correctly.
#--------------------

export NVCC = nvcc
export CC = /home/luban/android-toolchains/bin/arm-linux-androideabi-clang
export CXX = /home/luban/android-toolchains/bin/arm-linux-androideabi-clang++
export AS = /home/luban/android-toolchains/bin/arm-linux-androideabi-as
export AR = /home/luban/android-toolchains/bin/arm-linux-androideabi-ar
export LD = /home/luban/android-toolchains/bin/arm-linux-androideabi-ld
export CPP =/home/luban/android-toolchains/bin/arm-linux-androideabi-cpp

# whether compile with options for MXNet developer
DEV = 0

# whether compile with debug
DEBUG = 0

# whether compiler with profiler
USE_PROFILER =

# the additional link flags you want to add
# TODO: Move flags here
ADD_LDFLAGS=-static-libstdc++ -L/path/to/OpenBLAS

# the additional compile flags you want to add
ADD_CFLAGS = -I/path/to/OpenBLAS

#---------------------------------------------
# matrix computation libraries for CPU/GPU
#---------------------------------------------

# whether use CUDA during compile
USE_CUDA = 0

# add the path to CUDA library to link and compile flag
# if you have already add them to environment variable, leave it as NONE
# USE_CUDA_PATH = /usr/local/cuda
USE_CUDA_PATH = NONE

# whether use CuDNN R3 library
USE_CUDNN = 0

# whether use cuda runtime compiling for writing kernels in native language (i.e. Python)
USE_NVRTC = 0

# whether use opencv during compilation
# you can disable it, however, you will not able to use
# imbin iterator
USE_OPENCV = 0

# use openmp for parallelization
USE_OPENMP = 1

# MKL ML Library for Intel CPU/Xeon Phi
# Please refer to MKL_README.md for details

# MKL ML Library folder, need to be root for /usr/local
# Change to User Home directory for standard user
# For USE_BLAS!=mkl only
MKLML_ROOT=/usr/local

# whether use MKL2017 library
USE_MKL2017 = 0

# whether use MKL2017 experimental feature for high performance
# Prerequisite USE_MKL2017=1
USE_MKL2017_EXPERIMENTAL = 0

# whether use NNPACK library
USE_NNPACK = 0

# For arm builds we're using openblas
USE_BLAS = openblas

# whether use lapack during compilation
# only effective when compiled with blas versions openblas/apple/atlas/mkl
USE_LAPACK = 0

# path to lapack library in case of a non-standard installation
USE_LAPACK_PATH =

# add path to intel library, you may need it for MKL, if you did not add the path
# to environment variable
USE_INTEL_PATH = NONE

# If use MKL only for BLAS, choose static link automatically to allow python wrapper
ifeq ($(USE_MKL2017), 0)
ifeq ($(USE_BLAS), mkl)
USE_STATIC_MKL = 1
endif
else
USE_STATIC_MKL = NONE
endif

#----------------------------
# distributed computing
#----------------------------

# whether or not to enable multi-machine supporting
USE_DIST_KVSTORE = 0

# whether or not allow to read and write HDFS directly. If yes, then hadoop is
# required
USE_HDFS = 0

# path to libjvm.so. required if USE_HDFS=1
LIBJVM=$(JAVA_HOME)/jre/lib/amd64/server

# whether or not allow to read and write AWS S3 directly. If yes, then
# libcurl4-openssl-dev is required, it can be installed on Ubuntu by
# sudo apt-get install -y libcurl4-openssl-dev
USE_S3 = 0

#----------------------------
# additional operators
#----------------------------

# path to folders containing projects specific operators that you don't want to put in src/operators
EXTRA_OPERATORS =

#----------------------------
# other features
#----------------------------

# Create C++ interface package
USE_CPP_PACKAGE = 0

#----------------------------
# plugins
#----------------------------

# whether to use caffe integration. This requires installing caffe.
# You also need to add CAFFE_PATH/build/lib to your LD_LIBRARY_PATH
# CAFFE_PATH = $(HOME)/caffe
# MXNET_PLUGINS += plugin/caffe/caffe.mk

# whether to use torch integration. This requires installing torch.
# You also need to add TORCH_PATH/install/lib to your LD_LIBRARY_PATH
# TORCH_PATH = $(HOME)/torch
# MXNET_PLUGINS += plugin/torch/torch.mk

# WARPCTC_PATH = $(HOME)/warp-ctc
# MXNET_PLUGINS += plugin/warpctc/warpctc.mk

# whether to use sframe integration. This requires build sframe
# git@github.com:dato-code/SFrame.git
# SFRAME_PATH = $(HOME)/SFrame
# MXNET_PLUGINS += plugin/sframe/plugin.mk

Error Message:
/home/luban/mxnet-android/incubator-mxnet/lib/libmxnet.so: error: undefined reference to 'stderr'
clang50++: error: linker command failed with exit code 1 (use -v to see invocation)
CMakeFiles/detect.dir/build.make:95: recipe for target 'detect' failed
make[2]: *** [detect] Error 1
CMakeFiles/Makefile2:67: recipe for target 'CMakeFiles/detect.dir/all' failed
make[1]: *** [CMakeFiles/detect.dir/all] Error 2
Makefile:83: recipe for target 'all' failed
make: *** [all] Error 2

Minimum reproducible example
(If you are using your own code, please provide a short script that reproduces the error. Otherwise, please provide link to the existing example.)
Steps to reproduce
(Paste the commands you ran that produced the error.)

What have you tried to solve it?

change to ndk15

Can you please add the labels "Android", "Installation" to this issue

authors: mbaijal shuokay


text:
Add MKLDNN header files in include dir

We are hitting segfault when using MKLDNN enabled MXNet library with Horovod. MKLDNN is enabled by default when we are building MXNet from source in Linux OS. This PR adds the MKLDNN header files to the include directory which is needed to properly install Horovod with MKLDNN enabled MXNet library.

@pengzhao-intel @wuxun-zhang @apeforest please help review

@mxnet-label-bot update [pr-awaiting-review]

Thanks. The PR has been Merged : )

Do you think tools for making pip wheels need be updated accordingly? @szha

authors: TaoLv wkcn yuxihu


text:
[MXNET-1404] Implement storage tagging, the first half of the memory profiler

Description
implement storage tagging, the first half of the memory profiler
Checklist
Essentials
Please feel free to remove inapplicable items for your PR.

[x] The PR title starts with [MXNET-$JIRA_ID], where $JIRA_ID refers to the relevant JIRA issue created (except PRs with tiny changes)
[x] Changes are complete (i.e. I finished coding on this PR)
[x] Code is well-documented:
For user-facing API changes, API doc string has been updated.
For new C++ functions in header files, their functionalities and arguments are documented.
For new examples, README.md is added to explain the what the example does, the source of the dataset, expected performance on test set and reference to the original paper if applicable
Check the API doc at http://mxnet-ci-doc.s3-accelerate.dualstack.amazonaws.com/PR-$PR_ID/$BUILD_ID/index.html
[x] To the my best knowledge, examples are either not affected by this change, or have been fixed to be compatible with this change

Changes

[x] This PR is the first half of the GPU memory profiler. It implements storage tagging which adds profiler scope, name, and data structure information to each allocated storage handle.

FYI, @szha @eric-haibin-lin

Thanks to all for the valuable feedbacks. I opened another PR to address them. Closing this PR now.


text:
[CI] run operator tests with naive engine

Description
run operator tests with naive engine
Checklist
Essentials
Please feel free to remove inapplicable items for your PR.

[ ] Changes are complete (i.e. I finished coding on this PR)
[ ] To the best of my knowledge, examples are either not affected by this change, or have been fixed to be compatible with this change

Changes

[ ] run operator tests with naive engine

What's our strategy to test multi threaded engine?

@marcoabreu all but the operator unit tests still run on threaded engine.

hey @szha , this commit breaks the nightly CD pipeline.
tests/python/unittest/test_extensions.py::test_subgraph should be SKIPPED, but after this commit it is not getting skipped.
Basically, this change is not working as expected: https://github.com/apache/incubator-mxnet/commit/10b6b4887ef494ea985c9ea75a393a985476d08e#diff-460d06cb3af2af996c5ec259b086712fR100
Can you please fix this?

I realize this PR is over a year old, but does anyone remember the original problem being solved, i.e. why can't the operator unittests run with the threaded_engine_per_device?  Seems like if we're only running the unittests once, it should be with the default engine.


text:
temporary solution for instancenorm, will refactor using backend

Description
(Brief description on what this PR is about)
Checklist
Essentials

[ ] Passed code style checking (make lint)
[ ] Changes are complete (i.e. I finished coding on this PR)
[ ] All changes have test coverage:
Unit tests are added for small changes to verify correctness (e.g. adding a new operator)
Nightly tests are added for complicated/long-running ones (e.g. changing distributed kvstore)
Build tests will be added for build configuration changes (e.g. adding a new build option with NCCL)
[ ] Code is well-documented:
For user-facing API changes, API doc string has been updated.
For new C++ functions in header files, their functionalities and arguments are documented.
For new examples, README.md is added to explain the what the example does, the source of the dataset, expected performance on test set and reference to the original paper if applicable
[ ] To the my best knowledge, examples are either not affected by this change, or have been fixed to be compatible with this change

Changes

[ ] Feature1, tests, (and when applicable, API doc)
[ ] Feature2, tests, (and when applicable, API doc)

Comments

If this change is a backward incompatible change, why must this change be made.
Interesting edge cases to note here

Correct me if I'm wrong, but isn't this an API change?

The API was only recently added in master and hasn’t been introduced in release yet.

Okay, thanks for elaborating

authors: marcoabreu szha zhanghang1989


text:
Ant 1.10.4 emilian + fixes

fixes for NETBEANS-781. Unsquashed to separate out emilians fixes.

Could you comment on my original fix https://reviews.apache.org/r/67721/ and mention the bugs you found?

done

Any reason not to merge this?

i consider it low risk, because ant 1.10.4 was a minor revision and no actual code is changed in netbeans.

Aside from 'master' does this also need to be in 'release90'?

Maybe @emilianbold should handle this PR because he is the author of the original fix.

This is a bit unusual but I don't mind.
@sijskes followed NETBEANS-781 from start till end, he should also get a commit in the codebase for it.
@sijskes : please change if you can my commit to have the original author. You seem to have imported the patch but it doesn't show me as the author.
The .patch (from https://reviews.apache.org/r/67721/diff/raw/ ) does have the correct author.

@emilianbold i've tried to give you proper attribution:
applied: 0001-NETBEANS-781-Upgrades-Ant-to-1.10.4.patch
from: Emilian Bold emilian.bold@protonmail.ch.INVALID
is in the comments of the commit.
if this is not enough, please use your id when merging.

@sijskes you are listed as the author in the commit. Git allows you to differ between the committer and the author. The author is the one that created the initial changeset, the committer is the one integrating the changeset. In many cases these two are identical, in other case (here) they are not.
If a git formated patch is supplied, the easiest way for integration is:

change into the root of the project you are working with
fetch the patch: wget -O diff.patch https://reviews.apache.org/r/67721/diff/raw/
apply it with git: git am diff.patch
remove the patch: rm diff.patch

After this, the changeset is commited to the branch, the executing user is set as the committer, the author is set as author.
This is the result:
matthias@athena:~/src/incubator-netbeans$ git log -n 1 --pretty=fuller
commit 388b27ff749de94b979dc2097e571fd0ca721140 (HEAD -> test)
Author:     Emilian Bold <emi@apache.org>
AuthorDate: Mon Jun 25 20:16:57 2018 +0300
Commit:     Matthias Bläsing <mblaesing@doppel-helix.eu>
CommitDate: Wed Jul 4 20:17:15 2018 +0200

    Upgrades Ant to 1.10.4
matthias@athena:~/src/incubator-netbeans$

Maybe this helps.

I recommend we go ahead with putting together the first vote candidate for the final release and that we deal with this one in the pretty much inevitable second vote candidate.

BTW, this was included in release90. I've cherry-picked these two commits back into master: https://github.com/apache/incubator-netbeans/commit/dc04a3e144276f2ce83991be0a92cc2c657e97a3

authors: emilianbold geertjanw junichi11 matthiasblaesing sijskes

repo: apache/incubator-netbeans


text:
Replace all wget with curl

Summary
wget is missing from some system (like macOS and Windows native), it's better to use curl to simplify build environment.
Impact
None
Testing
Test build with stm32f429i-disco on Mac

@no1wudi please do the same replacement in nuttx too.

please add commit description (the same as the PR message should be ok )

Any other uses of wget anywhere else on NuttX? If not, you could look into removing any reference to wget from documentation.

curl should be added to the required tools in the top-level README.md file.  That provides the "getting started" info that people need to know.
I am not sure if there are other tools lists under Documentation/ because I am no long familiar with that.  It is worth checking.

How about in the windows native environment?  Would the user need to install something like:
https://curl.se/windows/
https://develop.zendesk.com/hc/en-us/articles/360001068567-Installing-and-using-cURL

The Windows native build has other problems more significant that this.  It is probably sufficient to know that some solution exists.  Cygwin or MSYS are more typical environments and curl is available under Cygwin (don't know about MSYS).

How about in the windows native environment? Would the user need to install something like:
https://curl.se/windows/
https://develop.zendesk.com/hc/en-us/articles/360001068567-Installing-and-using-cURL

The Windows native build has other problems more significant that this. It is probably sufficient to know that some solution exists. Cygwin or MSYS are more typical environments and curl is available under Cygwin (don't know about MSYS).

Now curl is installed on Windows native by default (tested on my Windows 20H2).

please add commit description (the same as the PR message should be ok )

commit message updated

curl is much better than wget from compatibility perspective:

let's merge it.

repo: apache/incubator-nuttx-apps


text:
nxstyle: reports brace alignment problem on solitary blocks

When having something like:

void function(void)
{
  .. code ..
  {
    ... code ...
  }
}

it reports a problem on the inner braces as if they were not aligned correctly.

nxstyle expects all braces to align in vertical.  Indenting by two spaces vs. the usual for causes nxstyle to complete.  The coding standard is silent on this but does say that all of the braces should align vertically.
When I encounter this complaint from nxstyle, I change the code as follows:
void function(void)
{
  .. code ..
    {
      ... code ...
    }
}

And nxstyle is appy.

I imagined that this is what nxstyle expects, but as you say the standard does not define this. Maybe if that is the expected style the standard should be augmented.

repo: apache/incubator-nuttx


text:
Add lcd_dev_s pointer to lcd_planeinfo_s to support multiple LCDs per board

Summary
In order to support multiple LCD instances per board add a pointer from lcd_planeinfo_s to the lcd_dev_s to which it belongs to.  Also enhance the putrun, getrun, putarea and getarea methods to pass through the LCD pointer to the respective driver.
Also, as an example, enhance SSD1306 driver to support multiple LCDs.
Impact
This pull request affects all lcd_dev_s drivers.  Due to missing hardware I was only able to make sure they still compile.  However, the changes to the drivers are pretty trivial.
Testing
It works fine for me with two SSD1309 based OLEDs on a Nucleo-144 with an STM32U5 MCU.

@xiaoxiang781216, @pkarashchenko and/or other committers: Could you please have a look?

@pkarashchenko, @xiaoxiang781216: Is there anything left to be done for to get this upstreamed? Thanks!


text:
Bp 7015

Summary
Bp-7015
Impact
RELEASE
Testing
Compiled

let's merge directly to save github resource.


text:
boards: Update telnetd related config after apps/nshlib change

Summary
paired with https://github.com/apache/incubator-nuttx-apps/pull/1362
Impact
telnetd
Testing
Pass CI

@xiaoxiang781216 is this a "breaking change"

The new draft release notes for NuttX-11.1.0 is on the CWIKI at https://cwiki.apache.org/confluence/display/NUTTX/NuttX+11.1.0. When this PR is merged, I will add the changes under "Compatibility Concerns" -> "Renamed or Modified Kconfig Options".
Feel free to document things there as work progresses. It makes for less work around release time. :-)

The new draft release notes for NuttX-11.1.0 is on the CWIKI at https://cwiki.apache.org/confluence/display/NUTTX/NuttX+11.1.0. When this PR is merged, I will add the changes under "Compatibility Concerns" -> "Renamed or Modified Kconfig Options".
Feel free to document things there as work progresses. It makes for less work around release time. :-)

I will update the document after merging.

Thanks for creating the page
Best regards
Alin
From: hartmannathan @.>
Sent: den 19 oktober 2022 05:12
To: apache/incubator-nuttx @.>
Cc: Subscribed @.***>
Subject: Re: [apache/incubator-nuttx] boards: Update telnetd related config after apps/nshlib change (PR #7351)
The new draft release notes for NuttX-11.1.0 is on the CWIKI at https://cwiki.apache.org/confluence/display/NUTTX/NuttX+11.1.0https://urldefense.com/v3/__https:/cwiki.apache.org/confluence/display/NUTTX/NuttX*11.1.0__;Kw!!JmoZiZGBv3RvKRSx!_YMFBWtV6L_wHZ6BL_BC-au_5Y9KSWMznzdo-fRHlHnIqy9l13dr0jzHMVWdKAC84NjNQml467-UMXXaR4tpWC2h_w$. When this PR is merged, I will add the changes under "Compatibility Concerns" -> "Renamed or Modified Kconfig Options".
Feel free to document things there as work progresses. It makes for less work around release time. :-)
—
Reply to this email directly, view it on GitHubhttps://urldefense.com/v3/__https:/github.com/apache/incubator-nuttx/pull/7351*issuecomment-1283353603__;Iw!!JmoZiZGBv3RvKRSx!_YMFBWtV6L_wHZ6BL_BC-au_5Y9KSWMznzdo-fRHlHnIqy9l13dr0jzHMVWdKAC84NjNQml467-UMXXaR4tfJf1dxg$, or unsubscribehttps://urldefense.com/v3/__https:/github.com/notifications/unsubscribe-auth/AB32XCTEORRT6UHYA3647PTWD5RHRANCNFSM6AAAAAARIJ7ZYE__;!!JmoZiZGBv3RvKRSx!_YMFBWtV6L_wHZ6BL_BC-au_5Y9KSWMznzdo-fRHlHnIqy9l13dr0jzHMVWdKAC84NjNQml467-UMXXaR4szUSUpWg$.
You are receiving this because you are subscribed to this thread.Message ID: @.@.>>

authors: hartmannathan jerpelea pkarashchenko xiaoxiang781216


text:
Interactive mode should be configurable

We need to make the interactive mode of wskdeploy configurable, so that we do not have to enter "yes" all the time to issue a command.

fixed in https://github.com/apache/incubator-openwhisk-wskdeploy/pull/375

authors: houshengbo mrutkows

repo: apache/incubator-openwhisk-wskdeploy


text:
[Bug] MysqlCdcAction can not convert decimal type correct

Search before asking

[X] I searched in the issues and found nothing similar.

Paimon version
0.4
Compute Engine
flink
Minimal reproduce step

start a flink cdc action , sync the mysql data to paimon.
the mysql table has a column with decimal type.

mysql> SELECT * FROM products;
+----+----------+-------+
| ID | CREATEBY | a     |
+----+----------+-------+
| 1  | aa       | 1.230 |
| 2  | bb       | 1.230 |
+----+----------+-------+
2 rows in set (0.00 sec)

mysql> desc products;
+----------+---------------+------+-----+---------+-------+
| Field    | Type          | Null | Key | Default | Extra |
+----------+---------------+------+-----+---------+-------+
| ID       | varchar(100)  | NO   | PRI | NULL    |       |
| CREATEBY | varchar(100)  | YES  |     | NULL    |       |
| a        | decimal(10,3) | YES  |     | NULL    |       |
+----------+---------------+------+-----+---------+-------+
3 rows in set (0.01 sec)

stop the flink job
start the flink job again, the paimon will throw an exception.

What doesn't meet your expectations?
java.lang.IllegalArgumentException: Paimon schema and MySQL schema are not compatible.
Paimon fields are: [ID VARCHAR(100) NOT NULL, CREATEBY VARCHAR(100), a DECIMAL(10, 3)].
MySQL fields are: {ID=VARCHAR(100), CREATEBY=VARCHAR(100), a=DECIMAL(10, 3)}
Anything else?
No response
Are you willing to submit a PR?

[X] I'm willing to submit a PR!

longtext also not work?

longtext also not work?

I'll check the other types again

longtext also not work?

I check it ,found that longtext throws an exception Don't support MySQL type ,I add the longtext and longblob in MySqlTypeUtils#toDataType.
time datatype is also don't support, but I think it may be complex, It will involve issues of timezone and precision，I will fix it in another pr。
I also add the date type to check compatibility.

Thanks @zhangjun0x01

repo: apache/incubator-paimon


text:
Fix state change when consumption is stopped

When a server stops consumption due to any exception or error, it invokes
a controller operation to mark itself as being OFFLINE. It may happen that
this condition takes place right after a segment is marked as ONLINE,
but the consumer thread on the server is still alive and waiting for the
completion response (of KEEP/COMMIT/DISCARD, etc.)
While updating the ideal state, the controller should ensure that the
Helix state of the segment is CONSUMING and not anything else. If it
is not CONSUMING, then we don't want to error out, but just quietly report
back success to the server, and let it do its thing.

Codecov Report

Merging #4739 into master will decrease coverage by 19.49%.
The diff coverage is 66.66%.

@@             Coverage Diff              @@
##             master    #4739      +/-   ##
============================================
- Coverage     57.66%   38.16%   -19.5%
============================================
  Files          1203     1203
  Lines         64681    64685       +4
  Branches       9403     9404       +1
============================================
- Hits          37298    24688   -12610
- Misses        24530    37757   +13227
+ Partials       2853     2240     -613

Impacted Files
Coverage Δ
Complexity Δ

.../core/realtime/PinotLLCRealtimeSegmentManager.java
58.74% <66.66%> (-15.85%)
0 <0> (ø)

.../org/apache/pinot/common/http/MultiGetRequest.java
0% <0%> (-100%)
0% <0%> (ø)

...n/function/PercentileEstMVAggregationFunction.java
0% <0%> (-100%)
0% <0%> (ø)

...che/pinot/common/restlet/resources/TablesList.java
0% <0%> (-100%)
0% <0%> (ø)

...ransformer/timeunit/CustomTimeUnitTransformer.java
0% <0%> (-100%)
0% <0%> (ø)

...che/pinot/pql/parsers/pql2/ast/OptionsAstNode.java
0% <0%> (-100%)
0% <0%> (ø)

...ot/core/query/scheduler/TableBasedGroupMapper.java
0% <0%> (-100%)
0% <0%> (ø)

...t/core/segment/index/readers/OnHeapDictionary.java
0% <0%> (-100%)
0% <0%> (ø)

...mmon/config/instance/InstanceAssignmentConfig.java
0% <0%> (-100%)
0% <0%> (ø)

...ommon/utils/retry/RetriableOperationException.java
0% <0%> (-100%)
0% <0%> (ø)

... and 583 more

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 b00b66c...48d6b3a. Read the comment docs.

authors: codecov-io mcvsubbu

repo: apache/incubator-pinot


text:
Why is the MaxNumberOfEventsPerBatchRequest is 50?

If I change that value and build the pio, will that work?, I saw the code, the val is being compared to the current length of events at the time of a new batch request, i do not see any other dependency with that val parameter, will this work if i change the value to a higher number?

Please bring this to user@predictionio.incubator.apache.org (http://predictionio.incubator.apache.org/support/). GitHub issues is no longer supported after ASF migration and will eventually shutdown. Thanks!

repo: apache/incubator-predictionio


text:
[REEF-14]: A logo for REEF

Added logo to website

JIRA: REEF-14

By the way, the other logo files are on our wiki.

repo: apache/incubator-reef


text:
global session size exceeded, size : 550 maxBranchSessionSize : 512

用的是1.7.0的版本：

确认用的是mysql模式

启动时的日志发出来
The log at startup is sent out.

已经确认你使用的是file模式了，请检查你自己的配置是否生效，比如application.yml中压根没使用nacos拉取对应的配置
It has been confirmed that you are using file mode. Please check whether your own configuration takes effect. For example, nacos is not used to pull the corresponding configuration in application.yml at all.

启动时的日志发出来 The log at startup is sent out.

很诡异 我配置的是mysql 但是从阿里云上面看 没有找到seata用户的连接数，正常是要5个 我备用实例 有5个连接数，之前好像也出现过一次这种情况，就是能正常用但是数据库不生效，最后重启完有可以 跟docker有没有关系

The log at startup is sent out.

如果是存file,数据的读写存放路径在哪里，我去看一下

sessionStore

先调整这两项配置，让程序启动吧
Adjust these two configurations first and let the program start

repo: apache/incubator-seata


text:
[Task #2970] Add support multiple microservice yml(#2970)

// Describe your PR here; eg. Fixes #issueNo

Make sure that:

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

Codecov Report

Merging #2971 (0a55f7f) into master (45308a3) will decrease coverage by 0.15%.
The diff coverage is n/a.

@@             Coverage Diff              @@
##             master    #2971      +/-   ##
============================================
- Coverage     59.40%   59.24%   -0.16%
- Complexity     4425     4432       +7
============================================
  Files           691      695       +4
  Lines         20034    20076      +42
  Branches       1800     1807       +7
============================================
- Hits          11901    11894       -7
- Misses         7123     7170      +47
- Partials       1010     1012       +2

Impacted Files
Coverage Δ

...e/shenyu/plugin/base/fallback/FallbackHandler.java
61.53% <0.00%> (-38.47%)
:arrow_down:

...shenyu/register/client/http/utils/OkHttpTools.java
44.44% <0.00%> (-10.73%)
:arrow_down:

...a/org/apache/shenyu/common/utils/VersionUtils.java
67.85% <0.00%> (-10.72%)
:arrow_down:

.../shenyu/plugin/resilience4j/executor/Executor.java
29.41% <0.00%> (-9.30%)
:arrow_down:

...ache/shenyu/admin/utils/PluginHandleH2Trigger.java
63.63% <0.00%> (-9.10%)
:arrow_down:

...che/shenyu/sync/data/http/HttpSyncDataService.java
69.10% <0.00%> (-8.14%)
:arrow_down:

...in/response/strategy/NettyClientMessageWriter.java
69.56% <0.00%> (-4.35%)
:arrow_down:

...pache/shenyu/agent/core/yaml/ShenyuYamlEngine.java
92.85% <0.00%> (-0.90%)
:arrow_down:

...shenyu/plugin/resilience4j/Resilience4JPlugin.java
48.14% <0.00%> (ø)

...bytebuddy/interceptor/StaticMethodInterceptor.java
0.00% <0.00%> (ø)

... and 8 more

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 45308a3...0a55f7f. Read the comment docs.

repo: apache/incubator-shenyu


text:
reactor shenyu agent logging #3064

Reconstruct Shenyu agent logging in the form of Shenyu plugins.

Codecov Report

Merging #3073 (c015e38) into master (f2790fc) will decrease coverage by 0.33%.
The diff coverage is 100.00%.

@@             Coverage Diff              @@
##             master    #3073      +/-   ##
============================================
- Coverage     58.24%   57.91%   -0.34%
+ Complexity     4381     4350      -31
============================================
  Files           704      705       +1
  Lines         20137    20138       +1
  Branches       1814     1813       -1
============================================
- Hits          11728    11662      -66
- Misses         7418     7487      +69
+ Partials        991      989       -2

Impacted Files
Coverage Δ

...ava/org/apache/shenyu/common/enums/PluginEnum.java
95.74% <100.00%> (+0.09%)
:arrow_up:

...g/rocketmq/LoggingRocketMQPluginConfiguration.java
100.00% <100.00%> (ø)

...ache/shenyu/plugin/grpc/cache/GrpcClientCache.java
68.75% <0.00%> (-31.25%)
:arrow_down:

...henyu/admin/service/impl/UpstreamCheckService.java
42.85% <0.00%> (-12.70%)
:arrow_down:

...henyu/plugin/grpc/resolver/ShenyuNameResolver.java
52.12% <0.00%> (-11.71%)
:arrow_down:

...a/org/apache/shenyu/common/utils/VersionUtils.java
67.85% <0.00%> (-10.72%)
:arrow_down:

.../apache/shenyu/admin/model/dto/BatchCommonDTO.java
50.00% <0.00%> (-7.15%)
:arrow_down:

...apache/shenyu/admin/model/dto/AuthPathWarpDTO.java
57.14% <0.00%> (-7.15%)
:arrow_down:

...org/apache/shenyu/admin/model/dto/AuthPathDTO.java
58.82% <0.00%> (-5.89%)
:arrow_down:

...che/shenyu/sync/data/http/HttpSyncDataService.java
78.04% <0.00%> (-5.70%)
:arrow_down:

... and 25 more

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 f2790fc...c015e38. Read the comment docs.

We discuss the remove the agent module in the meeting
：https://lists.apache.org/thread/ow8o0hkym6p72gsoxxk0pyk895yk4wzv
Check the email for more information

authors: codecov-commenter hutaishi


text:
[ISSUE #3556] downgrade curator version to 4.3.0 to compatible with some plugin like sofa

For #3556 , all tasks should be finished and the pom should be cleaned. I also changed zookeeper dep to 3.5.7 because the curator ver 4.3.0 depends on it. I've tested below functions and they're works well. Welcome to help to test these or others test cases!

[x] data sync between admin and bootstrap
[x] register between admin and sofa client
[x] bootstrap instance
[x] sofa example works well

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.

Codecov Report

Merging #3569 (84a3649) into master (dc2a159) will increase coverage by 0.05%.
The diff coverage is 63.23%.

@@             Coverage Diff              @@
##             master    #3569      +/-   ##
============================================
+ Coverage     62.54%   62.59%   +0.05%
- Complexity     5562     5566       +4
============================================
  Files           848      848
  Lines         23465    23491      +26
  Branches       2132     2139       +7
============================================
+ Hits          14676    14705      +29
+ Misses         7436     7428       -8
- Partials       1353     1358       +5

Impacted Files
Coverage Δ

...nyu/register/client/zookeeper/ZookeeperClient.java
58.97% <40.00%> (-2.67%)
:arrow_down:

...u/register/instance/zookeeper/ZookeeperClient.java
58.97% <40.00%> (-2.67%)
:arrow_down:

...ister/client/server/zookeeper/ZookeeperClient.java
69.23% <66.66%> (-4.75%)
:arrow_down:

...eeper/ZookeeperClientServerRegisterRepository.java
94.59% <90.47%> (-2.24%)
:arrow_down:

...admin/listener/zookeeper/HttpServiceDiscovery.java
90.32% <100.00%> (+1.61%)
:arrow_up:

...controller/ShenyuClientHttpRegistryController.java
77.77% <0.00%> (-22.23%)
:arrow_down:

...ruptor/RegisterClientServerDisruptorPublisher.java
52.94% <0.00%> (-11.77%)
:arrow_down:

...nyu/plugin/motan/cache/ApplicationConfigCache.java
52.00% <0.00%> (-5.00%)
:arrow_down:

.../logging/rocketmq/utils/LogCollectConfigUtils.java
71.11% <0.00%> (-4.45%)
:arrow_down:

...ng/rocketmq/rocketmq/RocketMQLogCollectClient.java
74.00% <0.00%> (-2.00%)
:arrow_down:

... and 5 more

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 dc2a159...84a3649. Read the comment docs.

authors: codecov-commenter hgaol


text:
SINGA-77 Integrate with Apache RAT

(Thanks Zhongle for the help with the Makefile.am)
Apache RAT enables automatic checking of license headers in source files. SINGA supports RAT by adding
a target into the Makefile, and providing a rat-excludes file at the top-level directory.
Specifically, the make rat target does the following:

Check for java and Apache RAT .jar file in the $RAT_PATH variable.
Invoke make clean
Invoke RAT and write the output to rat_check file.

Notice the side-effect of make rat that removes all built files. Thus, it is recommended to use before
building the source.

Would it be better to print the output on the screen?
Did you see any other temporary or binary files left by make clean except .dirstamp?

repo: apache/incubator-singa


text:
Field named rt in service_name index not found.

2018-09-11 14:58:27,416 - org.apache.skywalking.apm.collector.boot.CollectorBootStartUp -21342 [main] ERROR [] - Field named rt in service_name index not found.
org.apache.skywalking.apm.collector.core.module.ModuleStartException: Field named rt in service_name index not found.
at org.apache.skywalking.apm.collector.storage.es.StorageModuleEsProvider.start(StorageModuleEsProvider.java:127) ~[collector-storage-es-provider-5.0.0-beta2.jar:5.0.0-beta2]
at org.apache.skywalking.apm.collector.core.module.BootstrapFlow.start(BootstrapFlow.java:61) ~[apm-collector-core-5.0.0-beta2.jar:5.0.0-beta2]
at org.apache.skywalking.apm.collector.core.module.ModuleManager.init(ModuleManager.java:68) ~[apm-collector-core-5.0.0-beta2.jar:5.0.0-beta2]
at org.apache.skywalking.apm.collector.boot.CollectorBootStartUp.main(CollectorBootStartUp.java:45) [apm-collector-boot-5.0.0-beta2.jar:5.0.0-beta2]
Caused by: org.apache.skywalking.apm.collector.storage.StorageInstallException: Field named rt in service_name index not found.
at org.apache.skywalking.apm.collector.storage.es.base.define.ElasticSearchStorageInstaller.columnCheck(ElasticSearchStorageInstaller.java:72) ~[collector-storage-es-provider-5.0.0-beta2.jar:5.0.0-beta2]
at org.apache.skywalking.apm.collector.storage.StorageInstaller.install(StorageInstaller.java:60) ~[collector-storage-define-5.0.0-beta2.jar:5.0.0-beta2]
at org.apache.skywalking.apm.collector.storage.es.StorageModuleEsProvider.start(StorageModuleEsProvider.java:125) ~[collector-storage-es-provider-5.0.0-beta2.jar:5.0.0-beta2]
... 3 more

If you do upgrade, es need to rebuild. Please reset your es.

authors: ranmao wu-sheng

repo: apache/incubator-skywalking


text:
[Feature] add support svn

Search before asking

[X] I had searched in the feature and found no similar feature requirement.

Description
support svn
Usage Scenario
No response
Related issues
No response
Are you willing to submit a PR?

[X] Yes I am willing to submit a PR!

Code of Conduct

[X] I agree to follow this project's Code of Conduct

Thanks for your feedback, currently, no one is driving this feature. If you are interested in contributing to this feature, we will accept this feature

Currently, there is no plan to support this feature.

repo: apache/incubator-streampark


text:
[Improve#3068] Improve streampark-console module base on [3.5 Concurrent Processing]

What changes were proposed in this pull request
Issue Number: close #3068

Brief change log
Unified definition of thread pool

Verifying this change

This change is a trivial rework / code cleanup without any test coverage.

Does this pull request potentially affect one of the following parts

Dependencies (does it add or upgrade a dependency): (no)

Thanks for your recent positive contributions. Keep up the good work. Let's continue working together to make the project better!

Next step I'll try to replace the Thread Pool created in the code

Next step I'll try to replace the Thread Pool created in the code

Looking forward to your next contribution

authors: caicancai wolfboys zzzk1