[PR] [INLONG-8676][Manager] Modify the elasticsearch calling method from SDK to HTTP [inlong]
haibo-duan opened a new pull request, #9057: URL: https://github.com/apache/inlong/pull/9057 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title Example: [INLONG-XYZ][Component] Title of the pull request *(The following *XYZ* should be replaced by the actual [GitHub Issue](https://github.com/apache/inlong/issues) number)* - Fixes #8676 ### Motivation *Explain here the context, and why you're making that change. What is the problem you're trying to solve?* ### Modifications Modify the elasticsearch calling method from SDK to HTTP ### Verifying this change *(Please pick either of the following options)* - [ ] This change is a trivial rework/code cleanup without any test coverage. - [ ] This change is already covered by existing tests, such as: *(please describe tests)* - [ ] This change added tests and can be verified as follows: *(example:)* - *Added integration tests for end-to-end deployment with large payloads (10MB)* - *Extended integration test for recovery after broker failure* ### Documentation - Does this pull request introduce a new feature? (yes / no) - If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) - If a feature is not applicable for documentation, explain why? - If a feature is not documented yet in this PR, please create a follow-up issue for adding the documentation -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[inlong] branch master updated: [INLONG-8922][Sort] Add TubeMQ source and sink connector on flink 1.15 (#9031)
This is an automated email from the ASF dual-hosted git repository.
zirui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 12e1a46dc4 [INLONG-8922][Sort] Add TubeMQ source and sink connector on
flink 1.15 (#9031)
12e1a46dc4 is described below
commit 12e1a46dc43d74acc489798cdd1c6b96b84a2044
Author: Zfancy <47296299+fancycode...@users.noreply.github.com>
AuthorDate: Mon Oct 16 15:58:08 2023 +0800
[INLONG-8922][Sort] Add TubeMQ source and sink connector on flink 1.15
(#9031)
---
.../src/main/assemblies/sort-connectors-v1.15.xml | 8 +
.../sort-flink-v1.15/sort-connectors/pom.xml | 1 +
.../sort-connectors/tubemq/pom.xml | 107 +++
.../inlong/sort/tubemq/FlinkTubeMQConsumer.java| 351 +
.../inlong/sort/tubemq/FlinkTubeMQProducer.java| 175 ++
.../table/DynamicTubeMQDeserializationSchema.java | 134
.../table/DynamicTubeMQSerializationSchema.java| 35 ++
.../tubemq/table/TubeMQDynamicTableFactory.java| 233 ++
.../inlong/sort/tubemq/table/TubeMQOptions.java| 289 +
.../inlong/sort/tubemq/table/TubeMQTableSink.java | 131
.../sort/tubemq/table/TubeMQTableSource.java | 341
.../org.apache.flink.table.factories.Factory | 16 +
12 files changed, 1821 insertions(+)
diff --git a/inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml
b/inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml
index 90dfa48893..d71d98dbfa 100644
--- a/inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml
+++ b/inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml
@@ -83,5 +83,13 @@
0644
+
+
../inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/target
+inlong-sort/connectors
+
+
sort-connector-tubemq-v1.15-${project.version}.jar
+
+0644
+
diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pom.xml
b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pom.xml
index 82a4b2949e..151ed4757b 100644
--- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pom.xml
+++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pom.xml
@@ -39,6 +39,7 @@
iceberg
mongodb-cdc
pulsar
+tubemq
diff --git
a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/pom.xml
b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/pom.xml
new file mode 100644
index 00..ba5cce64a9
--- /dev/null
+++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/pom.xml
@@ -0,0 +1,107 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+4.0.0
+
+org.apache.inlong
+sort-connectors-v1.15
+1.10.0-SNAPSHOT
+
+
+sort-connector-tubemq-v1.15
+jar
+Apache InLong - Sort-connector-tubemq
+
+
+
${project.parent.parent.parent.parent.parent.basedir}
+
+
+
+
+org.apache.inlong
+tubemq-client
+${project.version}
+
+
+org.apache.flink
+flink-table-common
+
+
+com.google.guava
+guava
+
+
+
+
+
+
+
+org.apache.maven.plugins
+maven-shade-plugin
+${plugin.shade.version}
+
+
+
+shade-flink
+
+shade
+
+package
+
+
+
+
+
+org.apache.inlong:*
+com.fasterxml.*:*
+
+
+
+
+
+
org.apache.inlong:sort-connector-*
+
+org/apache/inlong/**
+
META-INF/services/org.apache.flink.table.factories.Factory
+
+
+
+*:*
+
+META-INF/*.SF
+META-INF/*.DSA
+META-INF/*.RSA
+
+
Re: [PR] [INLONG-8922][Sort] Add TubeMQ source and sink connector on flink 1.15 [inlong]
EMsnap merged PR #9031: URL: https://github.com/apache/inlong/pull/9031 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [INLONG-9009][Sort] Add HBase source and sink connector on flink 1.15 [inlong]
EMsnap merged PR #9043: URL: https://github.com/apache/inlong/pull/9043 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[inlong] branch master updated: [INLONG-9009][Sort] Add HBase source and sink connector on flink 1.15 (#9043)
This is an automated email from the ASF dual-hosted git repository.
zirui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 0e4907a548 [INLONG-9009][Sort] Add HBase source and sink connector on
flink 1.15 (#9043)
0e4907a548 is described below
commit 0e4907a5488fcb708ada6fc6dde38223016a136d
Author: Zfancy <47296299+fancycode...@users.noreply.github.com>
AuthorDate: Mon Oct 16 17:19:55 2023 +0800
[INLONG-9009][Sort] Add HBase source and sink connector on flink 1.15
(#9043)
---
.../src/main/assemblies/sort-connectors-v1.15.xml |8 +
.../sort-flink-v1.15/sort-connectors/hbase/pom.xml | 232 +++
.../sort/hbase/HBase2DynamicTableFactory.java | 148 ++
.../sort/hbase/sink/HBaseDynamicTableSink.java | 117 ++
.../inlong/sort/hbase/sink/HBaseSinkFunction.java | 376
.../org.apache.flink.table.factories.Factory | 16 +
.../hbase/src/main/resources/hbase-default.xml | 1816
.../sort-flink-v1.15/sort-connectors/pom.xml |1 +
licenses/inlong-sort-connectors/LICENSE|7 +
9 files changed, 2721 insertions(+)
diff --git a/inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml
b/inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml
index d71d98dbfa..3b8b56497d 100644
--- a/inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml
+++ b/inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml
@@ -91,5 +91,13 @@
0644
+
+
../inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/target
+inlong-sort/connectors
+
+
sort-connector-hbase-v1.15-${project.version}.jar
+
+0644
+
diff --git
a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/pom.xml
b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/pom.xml
new file mode 100644
index 00..25ffa9637f
--- /dev/null
+++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/pom.xml
@@ -0,0 +1,232 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+4.0.0
+
+org.apache.inlong
+sort-connectors-v1.15
+1.10.0-SNAPSHOT
+
+
+sort-connector-hbase-v1.15
+jar
+Apache InLong - Sort-connector-hbase
+
+
+
${project.parent.parent.parent.parent.parent.basedir}
+3.4.14
+
+
+
+
+
+
+org.apache.zookeeper
+zookeeper
+${zookeeper.version}
+
+
+
+
+
+
+org.apache.inlong
+sort-connector-base
+${project.version}
+
+
+org.apache.flink
+flink-connector-hbase-2.2
+
+
+com.github.spotbugs
+spotbugs-annotations
+
+
+
+
+org.apache.hadoop
+hadoop-common
+provided
+
+
+org.apache.inlong
+sort-format-common
+${project.version}
+test
+
+
+org.apache.inlong
+sort-core
+${project.version}
+test
+
+
+
+
+
+
+org.apache.maven.plugins
+maven-shade-plugin
+${plugin.shade.version}
+
+
+shade-flink
+
+shade
+
+package
+
+
+
+
+hbase-default.xml
+hbase-default.xml
+
+
+
+false
+
+
+org.apache.inlong:*
+
org.apache.flink:flink-connector-hbase-base
+
org.apache.flink:flink-connector-hbase-2.2
+org.apache.hbase:hbase-*
+
org.apache.hbase.thirdparty:hbase-shaded-*
+
org.apache.zookeeper:zookeeper
+
org.apache.htrace:htrace-core4
+
com.google.protobuf:protobuf-java
+
commons-codec:comm
Re: [PR] [INLONG-877][Improve] Update document of TubeMQ extract node [inlong-website]
dockerzhang commented on PR #882: URL: https://github.com/apache/inlong-website/pull/882#issuecomment-1764187645 group.id changed in https://github.com/apache/inlong/pull/9031 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [INLONG-8676][Manager] Elasticsearch - Modify the calling method from SDK to HTTP [inlong]
vernedeng commented on code in PR #9057:
URL: https://github.com/apache/inlong/pull/9057#discussion_r1360465445
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java:
##
@@ -365,27 +362,36 @@ private List getAuditIds(String groupId, String
streamId, String sourceN
}
/**
- * Convert to elasticsearch search request
+ * Convert to elasticsearch search request json
*
- * @param index The index of elasticsearch
* @param groupId The groupId of inlong
* @param streamId The streamId of inlong
- * @return The search request of elasticsearch
+ * @return The search request of elasticsearch json
*/
-private SearchRequest toAuditSearchRequest(String index, String groupId,
String streamId) {
-TermsAggregationBuilder builder =
AggregationBuilders.terms("log_ts").field("log_ts")
-
.size(Integer.MAX_VALUE).subAggregation(AggregationBuilders.sum("count").field("count"))
-
.subAggregation(AggregationBuilders.sum("delay").field("delay"));
-BoolQueryBuilder filterBuilder = new BoolQueryBuilder();
-filterBuilder.must(termQuery("inlong_group_id", groupId));
-filterBuilder.must(termQuery("inlong_stream_id", streamId));
-SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
-sourceBuilder.aggregation(builder);
-sourceBuilder.query(filterBuilder);
-sourceBuilder.from(0);
-sourceBuilder.size(0);
-sourceBuilder.sort("log_ts", SortOrder.ASC);
-return new SearchRequest(new String[]{index}, sourceBuilder);
+public static JsonObject toAuditSearchRequestJson(String groupId, String
streamId) {
+JsonObject result = new JsonObject();
+result.addProperty("from", 0);
+result.addProperty("size", 0);
+JsonObject query = new JsonObject();
+final String termGroupId =
"{\"term\":{\"inlong_group_id\":{\"value\":\"" + groupId + "\",\"boost\":1.0
}}}";
+final String termStreamId =
"{\"term\":{\"inlong_stream_id\":{\"value\":\"" + streamId +
"\",\"boost\":1.0}}}";
+JsonArray mustArray = new JsonArray();
+mustArray.add(GSON.fromJson(termGroupId, JsonElement.class));
+mustArray.add(GSON.fromJson(termStreamId, JsonElement.class));
+JsonObject bool = new JsonObject();
+bool.add("must", mustArray);
+bool.addProperty("adjust_pure_negative", true);
+bool.addProperty("boost", 1.0);
+query.add("bool", bool);
+result.add("query", query);
+final String sortStr = "[{\"log_ts\": {\"order\": \"asc\"}}]";
+result.add("sort", GSON.fromJson(sortStr, JsonArray.class));
+final String aggregationsStr = "{\"log_ts\": {\"terms\": {\"field\":
\"log_ts\",\"size\": 2147483647, "
++ "\"min_doc_count\": 1,\"shard_min_doc_count\": 0,
\"show_term_doc_count_error\": false,"
++ "\"order\":[{\"_count\": \"desc\" },{\"_key\": \"asc\"
}]},\"aggregations\": "
++ "{\"count\":{\"sum\":{\"field\":\"count\" }},\"delay\":
{\"sum\":{\"field\":\"delay\"}";
+result.add("aggregations", GSON.fromJson(aggregationsStr,
JsonElement.class));
+return result;
Review Comment:
Why so many magic numbers
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] [INLONG-8674][Manager] Pulsar - Modify the calling method from SDK to HTTP [inlong]
vernedeng commented on code in PR #8941:
URL: https://github.com/apache/inlong/pull/8941#discussion_r1360477012
##
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/util/HttpUtils.java:
##
@@ -112,6 +112,22 @@ public static T request(RestTemplate restTemplate,
String url, HttpMethod ht
return response.getBody();
}
+/**
+ * Send an void HTTP request
+ */
+public static void request(RestTemplate restTemplate, String url,
HttpMethod httpMethod, Object requestBody,
+HttpHeaders header) {
+if (log.isDebugEnabled()) {
+log.debug("begin request to {} by request body {}", url,
GSON.toJson(requestBody));
Review Comment:
just print the debug log directly
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] [INLONG-8674][Manager] Pulsar - Modify the calling method from SDK to HTTP [inlong]
vernedeng commented on code in PR #8941: URL: https://github.com/apache/inlong/pull/8941#discussion_r1360484031 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarUtils.java: ## @@ -17,18 +17,29 @@ package org.apache.inlong.manager.service.resource.queue.pulsar; -import org.apache.inlong.manager.common.enums.ErrorCodeEnum; -import org.apache.inlong.manager.common.util.Preconditions; +import org.apache.inlong.manager.common.util.HttpUtils; import org.apache.inlong.manager.pojo.cluster.pulsar.PulsarClusterInfo; +import org.apache.inlong.manager.pojo.queue.pulsar.PulsarLookupTopicInfo; +import org.apache.inlong.manager.pojo.queue.pulsar.PulsarNamespacePolicies; +import org.apache.inlong.manager.pojo.queue.pulsar.PulsarPartitionedInternalStats; +import org.apache.inlong.manager.pojo.queue.pulsar.PulsarTenantInfo; +import org.apache.inlong.manager.pojo.queue.pulsar.PulsarTopicMetadata; +import com.alibaba.fastjson.JSON; Review Comment: please use Jackson -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [INLONG-8674][Manager] Pulsar - Modify the calling method from SDK to HTTP [inlong]
vernedeng commented on code in PR #8941:
URL: https://github.com/apache/inlong/pull/8941#discussion_r1360484391
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/queue/pulsar/PulsarNamespacePolicies.java:
##
@@ -0,0 +1,34 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.inlong.manager.pojo.queue.pulsar;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class PulsarNamespacePolicies {
+
+private int message_ttl_in_seconds;
Review Comment:
camel style
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[PR] Bump undici from 5.25.1 to 5.26.3 [inlong-website]
dependabot[bot] opened a new pull request, #884: URL: https://github.com/apache/inlong-website/pull/884 Bumps [undici](https://github.com/nodejs/undici) from 5.25.1 to 5.26.3. Release notes Sourced from https://github.com/nodejs/undici/releases";>undici's releases. v5.26.3 No release notes provided. v5.26.2 Security Release, CVE-2023-45143. v5.26.1 What's Changed Fix publish undici-types once and for all! by https://github.com/Ethan-Arrowood";>@Ethan-Arrowood in https://redirect.github.com/nodejs/undici/pull/2338";>nodejs/undici#2338 Fix node detection omfg by https://github.com/KhafraDev";>@KhafraDev in https://redirect.github.com/nodejs/undici/pull/2341";>nodejs/undici#2341 Full Changelog: https://github.com/nodejs/undici/compare/v5.26.0...v5.26.1";>https://github.com/nodejs/undici/compare/v5.26.0...v5.26.1 v5.26.0 What's Changed use npm install instead of npm ci by https://github.com/Ethan-Arrowood";>@Ethan-Arrowood in https://redirect.github.com/nodejs/undici/pull/2309";>nodejs/undici#2309 change default header to node by https://github.com/Ethan-Arrowood";>@Ethan-Arrowood in https://redirect.github.com/nodejs/undici/pull/2310";>nodejs/undici#2310 chore: change order of the pseudo-headers by https://github.com/kyrylodolynskyi";>@kyrylodolynskyi in https://redirect.github.com/nodejs/undici/pull/2308";>nodejs/undici#2308 fix: Agent.Options.factory should accept URL object or string as parameter by https://github.com/nicole0707";>@nicole0707 in https://redirect.github.com/nodejs/undici/pull/2295";>nodejs/undici#2295 build(deps-dev): bump sinon from 15.2.0 to 16.1.0 by https://github.com/dependabot";>@dependabot in https://redirect.github.com/nodejs/undici/pull/2312";>nodejs/undici#2312 test: handle npm ignore-scripts settings by https://github.com/panva";>@panva in https://redirect.github.com/nodejs/undici/pull/2313";>nodejs/undici#2313 feat: respect --max-http-header-size Node.js flag by https://github.com/balazsorban44";>@balazsorban44 in https://redirect.github.com/nodejs/undici/pull/2234";>nodejs/undici#2234 fix(https://redirect.github.com/nodejs/undici/issues/2311";>#2311): End stream after body sent by https://github.com/metcoder95";>@metcoder95 in https://redirect.github.com/nodejs/undici/pull/2314";>nodejs/undici#2314 disallow setting host header in fetch by https://github.com/KhafraDev";>@KhafraDev in https://redirect.github.com/nodejs/undici/pull/2322";>nodejs/undici#2322 [StepSecurity] ci: Harden GitHub Actions by https://github.com/step-security-bot";>@step-security-bot in https://redirect.github.com/nodejs/undici/pull/2325";>nodejs/undici#2325 fix fetch with coverage enabled by https://github.com/KhafraDev";>@KhafraDev in https://redirect.github.com/nodejs/undici/pull/2330";>nodejs/undici#2330 Fix stuck when using http2 POST Buffer by https://github.com/binsee";>@binsee in https://redirect.github.com/nodejs/undici/pull/2336";>nodejs/undici#2336 fix: 🏷️ add allowH2 to BuildOptions by https://github.com/binsee";>@binsee in https://redirect.github.com/nodejs/undici/pull/2334";>nodejs/undici#2334 fix: 🐛 fix process http2 header by https://github.com/binsee";>@binsee in https://redirect.github.com/nodejs/undici/pull/2332";>nodejs/undici#2332 New Contributors https://github.com/kyrylodolynskyi";>@kyrylodolynskyi made their first contribution in https://redirect.github.com/nodejs/undici/pull/2308";>nodejs/undici#2308 https://github.com/nicole0707";>@nicole0707 made their first contribution in https://redirect.github.com/nodejs/undici/pull/2295";>nodejs/undici#2295 https://github.com/balazsorban44";>@balazsorban44 made their first contribution in https://redirect.github.com/nodejs/undici/pull/2234";>nodejs/undici#2234 https://github.com/binsee";>@binsee made their first contribution in https://redirect.github.com/nodejs/undici/pull/2336";>nodejs/undici#2336 Full Changelog: https://github.com/nodejs/undici/compare/v5.23.4...v5.26.0";>https://github.com/nodejs/undici/compare/v5.23.4...v5.26.0 v5.25.3 What's Changed perf: improve parse-url implementation by https://github.com/anonrig";>@anonrig in https://redirect.github.com/nodejs/undici/pull/2286";>nodejs/undici#2286 test: enable websockets inclusion in WPTReport by https://github.com/panva";>@panva in https://redirect.github.com/nodejs/undici/pull/2284";>nodejs/undici#2284 remove npm run test from pre-commit hook by https://github.com/dancastillo";>@dancastillo in https://redirect.github.com/nodejs/undici/pull/2296";>nodejs/undici#2296 perf: use @fastify/busboy by https://github.com/gurgunday";>@gurgunday in https://redirect.github.com/nodejs/undici/pull/2211";>nodejs/undici#2211 Disable finalizationregistry if node code cov by https://github.com/mcollina";>@mcollina in https://redirect.github.com/nodejs/undici/pull/2298";>nodejs/undici#2298 New Co
[inlong-website] branch dependabot/npm_and_yarn/undici-5.26.3 created (now 93dd1c9918)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/npm_and_yarn/undici-5.26.3 in repository https://gitbox.apache.org/repos/asf/inlong-website.git at 93dd1c9918 Bump undici from 5.25.1 to 5.26.3 No new revisions were added by this update.
Re: [PR] [INLONG-877][Improve] Update document of TubeMQ extract node [inlong-website]
dockerzhang merged PR #882: URL: https://github.com/apache/inlong-website/pull/882 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Improve] Update document of TubeMQ extract node [inlong-website]
dockerzhang closed issue #877: [Improve] Update document of TubeMQ extract node URL: https://github.com/apache/inlong-website/issues/877 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[inlong-website] branch master updated: [INLONG-877][Improve] Update document of TubeMQ extract node (#882)
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong-website.git The following commit(s) were added to refs/heads/master by this push: new c61cc6fd16 [INLONG-877][Improve] Update document of TubeMQ extract node (#882) c61cc6fd16 is described below commit c61cc6fd16fb32cd8c337adf48e31bbb0957d6b6 Author: Zfancy <47296299+fancycode...@users.noreply.github.com> AuthorDate: Tue Oct 17 09:41:19 2023 +0800 [INLONG-877][Improve] Update document of TubeMQ extract node (#882) --- docs/data_node/extract_node/tube.md | 4 ++-- .../current/data_node/extract_node/tube.md| 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/docs/data_node/extract_node/tube.md b/docs/data_node/extract_node/tube.md index 89ce32803d..9bcbb8e084 100644 --- a/docs/data_node/extract_node/tube.md +++ b/docs/data_node/extract_node/tube.md @@ -46,9 +46,9 @@ Flink SQL> CREATE TABLE tube_extract_node ( ) WITH ( 'connector' = 'tubemq', 'topic' = 'topicName', - 'masterRpc' = 'rpcUrl', -- 127.0.0.1:8715 + 'master.rpc' = 'rpcUrl', -- 127.0.0.1:8715 'format' = 'json', - 'groupId' = 'groupName'); + 'group.name' = 'groupName'); -- Read data from tube_extract_node Flink SQL> SELECT * FROM tube_extract_node; diff --git a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/tube.md b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/tube.md index d09c83ed88..25459772ef 100644 --- a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/tube.md +++ b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/tube.md @@ -45,9 +45,9 @@ Flink SQL> CREATE TABLE tube_extract_node ( ) WITH ( 'connector' = 'tubemq', 'topic' = 'topicName', - 'masterRpc' = 'rpcUrl', -- 127.0.0.1:8715 + 'master.rpc' = 'rpcUrl', -- 127.0.0.1:8715 'format' = 'json', - 'groupId' = 'groupName'); + 'group.name' = 'groupName'); -- Read data from tube_extract_node Flink SQL> SELECT * FROM tube_extract_node;
[PR] [INLONG-9058][SDK] Limit the number of inlong-groupid and inlong-streamid [inlong]
doleyzi opened a new pull request, #9059: URL: https://github.com/apache/inlong/pull/9059 ### Prepare a Pull Request - Fixes #9058 ### Motivation *Limit the number of inlong-groupid and inlong-streamid of a single SDK instance to prevent excessive resource consumption* ### Modifications *Through configuration, limit the number of inlong-groupid and inlong-streamid of a single SDK instance to prevent excessive resource consumption.* -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
