Skip to content

[To region_migration] sync commit#12192

Closed
liyuheng55555 wants to merge 73 commits intoapache:region_migrationfrom
liyuheng55555:Working/region_migration_clear2
Closed

[To region_migration] sync commit#12192
liyuheng55555 wants to merge 73 commits intoapache:region_migrationfrom
liyuheng55555:Working/region_migration_clear2

Conversation

@liyuheng55555
Copy link
Collaborator

No description provided.

liyuheng55555 and others added 30 commits February 28, 2024 13:56
remove JDBC IoTDBConnection commit  "Does not support commit"
Signed-off-by: OneSizeFitQuorum <tanxinyu@apache.org>
Bumps [org.scala-lang:scala-library](https://github.com/scala/scala) from 2.12.18 to 2.12.19.
- [Release notes](https://github.com/scala/scala/releases)
- [Commits](scala/scala@v2.12.18...v2.12.19)

---
updated-dependencies:
- dependency-name: org.scala-lang:scala-library
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps `flink.version` from 1.17.0 to 1.17.2.

Updates `org.apache.flink:flink-clients` from 1.17.0 to 1.17.2
- [Commits](apache/flink@release-1.17.0...release-1.17.2)

Updates `org.apache.flink:flink-core` from 1.17.0 to 1.17.2
- [Commits](apache/flink@release-1.17.0...release-1.17.2)

Updates `org.apache.flink:flink-java` from 1.17.0 to 1.17.2
- [Commits](apache/flink@release-1.17.0...release-1.17.2)

Updates `org.apache.flink:flink-streaming-java` from 1.17.0 to 1.17.2
- [Commits](apache/flink@release-1.17.0...release-1.17.2)

Updates `org.apache.flink:flink-table-test-utils` from 1.17.0 to 1.17.2

Updates `org.apache.flink:flink-table-api-java` from 1.17.0 to 1.17.2

Updates `org.apache.flink:flink-table-runtime` from 1.17.0 to 1.17.2

Updates `org.apache.flink:flink-table-planner-loader` from 1.17.0 to 1.17.2

Updates `org.apache.flink:flink-connector-files` from 1.17.0 to 1.17.2

Updates `org.apache.flink:flink-connector-datagen` from 1.17.0 to 1.17.2

Updates `org.apache.flink:flink-test-utils` from 1.17.0 to 1.17.2

---
updated-dependencies:
- dependency-name: org.apache.flink:flink-clients
  dependency-type: direct:development
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-core
  dependency-type: direct:development
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-java
  dependency-type: direct:development
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-streaming-java
  dependency-type: direct:development
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-table-test-utils
  dependency-type: direct:production
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-table-api-java
  dependency-type: direct:development
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-table-runtime
  dependency-type: direct:production
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-table-planner-loader
  dependency-type: direct:production
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-connector-files
  dependency-type: direct:production
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-connector-datagen
  dependency-type: direct:production
  update-type: version-update:semver-patch
- dependency-name: org.apache.flink:flink-test-utils
  dependency-type: direct:development
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Xiangpeng Hu <65238551+BUAAserein@users.noreply.github.com>
SimpleConsensus triggers the start and notifyLeaderReady functions of SimpleConsensusImpl before the consensusGroup in the map has been written. In the initialization logic of some asynchronous calls, if it is executed fast enough, SimpleConsensus may still have a map size of 0, causing an error to fail startup.

The fix is as simple as calling start after a successful put.

Signed-off-by: OneSizeFitQuorum <tanxinyu@apache.org>
…ache#11794)

Co-authored-by: Caideyipi <87789683+Caideyipi@users.noreply.github.com>
Co-authored-by: Zikun Ma <55695098+DanielWang2035@users.noreply.github.com>
liyuheng55555 and others added 29 commits March 13, 2024 12:25
# Conflicts:
#	integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AbstractEnv.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/IManager.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigPlanExecutor.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/AddRegionPeerProcedure.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionPeerProcedure.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ProcedureFactory.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
#	iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/ConfigNodeClient.java
#	iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/FileUtils.java
#	iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
…ration_clear2

# Conflicts:
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
#	iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
#	iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
…pache#12168)

Bumps google.golang.org/protobuf from 1.31.0 to 1.33.0.

---
updated-dependencies:
- dependency-name: google.golang.org/protobuf
  dependency-type: indirect
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
1. Support translating snapshot file to statements, so you can use schema region snapshot parser to construct a same Schema tree in another cluster.
2. Add some UTs.
3. refine memory use when translating schema region snapshot. The node num depends on the longest path and Its children num. If one path is root.t1.t2.t3, and It has 100 measurements, so the node num will be 4 + 100.
…rocessor (apache#12114)

Co-authored-by: Steve Yurong Su <rong@apache.org>
…2146)

This commit adds a UDF function for envelope demodulation analysis. The function of envelope demodulation analysis is designed to realize the demodulation and envelope extraction of the signal by inputting one-dimensional floating-point numbers and the modulation frequency specified by the user. The goal of demodulation is to extract parts of interest from complex signals and make them easier to understand. For example, demodulation can find the envelope of the signal, that is, the trend of amplitude change. The realization principle is to convert the time domain signal into the frequency domain signal, and the algorithms involved include Hilbert transform (Hilbert), fast Fourier transform (FFT), fast Fourier inverse transform (IFFT) and so on.
# Conflicts:
#	integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/AbstractNodeWrapper.java
spotless
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.