Jellal-HT opened a new pull request, #5547:
URL: https://github.com/apache/inlong/pull/5547
### Prepare a Pull Request
- Fixes #5099
### Motivation
Support Apache Hudi in sort module and manager module
### Modifications
- Extend a new Extract Node for Apach
Jellal-HT opened a new issue, #516:
URL: https://github.com/apache/inlong-website/issues/516
### Description
Description
The paths of SourceType.java, SinkType.java, LoadNodeUtils.java and
ExtractNodeUtils.java in the manager plugin design document are wrong and need
to be upd
gosonzhang commented on code in PR #5545:
URL: https://github.com/apache/inlong/pull/5545#discussion_r945482405
##
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/common/TubeProducerHolder.java:
##
@@ -0,0 +1,277 @@
+/*
+ * Licensed to the Apache
gosonzhang commented on code in PR #5545:
URL: https://github.com/apache/inlong/pull/5545#discussion_r945486284
##
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/common/TubeProducerHolder.java:
##
@@ -0,0 +1,277 @@
+/*
+ * Licensed to the Apache
gong opened a new pull request, #5548:
URL: https://github.com/apache/inlong/pull/5548
### Prepare a Pull Request
- [INLONG-5461][Sort] Add Audit for mongoDB extract node
- Fixes #5461
### Motivation
Add Audit for mongoDB extract node
### Modifications
Jellal-HT opened a new pull request, #517:
URL: https://github.com/apache/inlong-website/pull/517
### Prepare a Pull Request
- Fixes #516
--
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
gong opened a new pull request, #5549:
URL: https://github.com/apache/inlong/pull/5549
### Prepare a Pull Request
-[INLONG-5462][Sort] Add audit for Oracle extract Node
- Fixes #5462
### Motivation
Add audit for Oracle extract Node
### Modifications
EMsnap commented on code in PR #5548:
URL: https://github.com/apache/inlong/pull/5548#discussion_r945543214
##
inlong-sort/sort-connectors/mongodb-cdc/pom.xml:
##
@@ -41,6 +41,11 @@
sort-connector-base
${project.version}
+
+
gong commented on code in PR #5548:
URL: https://github.com/apache/inlong/pull/5548#discussion_r945547334
##
inlong-sort/sort-connectors/mongodb-cdc/pom.xml:
##
@@ -41,6 +41,11 @@
sort-connector-base
${project.version}
+
+o
gong opened a new pull request, #5550:
URL: https://github.com/apache/inlong/pull/5550
### Prepare a Pull Request
- [INLONG-5462][Sort] Add audit for HBase load node and fix MySqlSource set
inlong metric error
- Fixes #5462
### Motivation
Add audit for HBase load
dockerzhang commented on PR #5547:
URL: https://github.com/apache/inlong/pull/5547#issuecomment-1214824089
@Jellal-HT great job. please add the license file for the new dependency,
and you can refer to
https://inlong.apache.org/zh-CN/community/how-to-maintain-3rd-party-dependencies/.
healchow commented on issue #5506:
URL: https://github.com/apache/inlong/issues/5506#issuecomment-1214877126
File source and auto push source are already supported in
`StreamSourceOperator#getSourcesMap`, so close this issue.
--
This is an automated message from the Apache Git Service.
To
gosonzhang merged PR #5545:
URL: https://github.com/apache/inlong/pull/5545
--
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.a
This is an automated email from the ASF dual-hosted git repository.
gosonzhang 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 27217e34b [INLONG-5538][DataProxy] Optimize
gosonzhang opened a new pull request, #5552:
URL: https://github.com/apache/inlong/pull/5552
- Fixes #5551
--
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 unsubs
baomingyu commented on code in PR #5552:
URL: https://github.com/apache/inlong/pull/5552#discussion_r945653037
##
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java:
##
@@ -121,6 +133,10 @@ public void configure(Context context) {
gosonzhang opened a new pull request, #5554:
URL: https://github.com/apache/inlong/pull/5554
- Fixes #5553
--
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 unsub
woofyzhao opened a new pull request, #5556:
URL: https://github.com/apache/inlong/pull/5556
- Fixes #
### Change list
1. add cluster name and ip fields for agent and dataproxy heartbeat report.
2. remove some redundant fields in file source model.
3. fix the file task
healchow commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r945738359
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSource.java:
##
@@ -48,9 +48,6 @@ public class FileSource extends StreamSourc
healchow commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r945739128
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSourceDTO.java:
##
@@ -42,9 +42,6 @@ public class FileSourceDTO {
priv
healchow commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r945740733
##
inlong-manager/manager-web/sql/apache_inlong_manager.sql:
##
@@ -397,27 +397,27 @@ CREATE TABLE IF NOT EXISTS `source_file_detail`
--
C
healchow commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r945741718
##
inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/StreamSourceEntity.java:
##
@@ -36,9 +36,10 @@ public class StreamSourceEntity implement
Loveca opened a new pull request, #5557:
URL: https://github.com/apache/inlong/pull/5557
### Prepare a Pull Request
- Fix [#5043 ](https://github.com/apache/inlong/issues/5043)
# Motivation
To surport the ability to Doris data integration, we need to add Apache
vernedeng commented on code in PR #5512:
URL: https://github.com/apache/inlong/pull/5512#discussion_r945849755
##
inlong-sdk/sort-sdk/src/test/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManagerTest.java:
##
@@ -0,0 +1,160 @@
+/*
+ * Licensed to the Apache Software
vernedeng commented on code in PR #5512:
URL: https://github.com/apache/inlong/pull/5512#discussion_r945850673
##
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManagerFactory.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foun
vernedeng commented on code in PR #5512:
URL: https://github.com/apache/inlong/pull/5512#discussion_r945851416
##
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/SortClientImpl.java:
##
@@ -39,7 +40,7 @@ public class SortClientImpl extends SortClient {
p
leosanqing opened a new pull request, #5558:
URL: https://github.com/apache/inlong/pull/5558
### Prepare a Pull Request
- Fixes #5290
### Motivation
- The pageInfo object returned by the web contains too many unnecessary and
unused fields
- The client should not cont
jun0315 commented on PR #5379:
URL: https://github.com/apache/inlong/pull/5379#issuecomment-1215360884
checkstyle has a lot to adapt, and I'm still adapting...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946265496
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSource.java:
##
@@ -48,9 +48,6 @@ public class FileSource extends StreamSour
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946265849
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSourceDTO.java:
##
@@ -42,9 +42,6 @@ public class FileSourceDTO {
pri
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946266045
##
inlong-manager/manager-web/sql/apache_inlong_manager.sql:
##
@@ -397,27 +397,27 @@ CREATE TABLE IF NOT EXISTS `source_file_detail`
--
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946266472
##
inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/StreamSourceEntity.java:
##
@@ -36,9 +36,10 @@ public class StreamSourceEntity implemen
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946266472
##
inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/StreamSourceEntity.java:
##
@@ -36,9 +36,10 @@ public class StreamSourceEntity implemen
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946271996
##
inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/StreamSourceEntity.java:
##
@@ -36,9 +36,10 @@ public class StreamSourceEntity implemen
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946275164
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSource.java:
##
@@ -48,9 +48,6 @@ public class FileSource extends StreamSour
healchow commented on code in PR #5367:
URL: https://github.com/apache/inlong/pull/5367#discussion_r946275388
##
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/PostgreSQLReaderTest.java:
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to the Apache Software
healchow commented on code in PR #5502:
URL: https://github.com/apache/inlong/pull/5502#discussion_r946276800
##
inlong-distribution/src/main/assemblies/sort-connectors.xml:
##
@@ -1,159 +1,167 @@
-
-
-
-
-sort-connectors
-
-
-dir
-tar.gz
-
-true
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946265849
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSourceDTO.java:
##
@@ -42,9 +42,6 @@ public class FileSourceDTO {
pri
woofyzhao commented on code in PR #5556:
URL: https://github.com/apache/inlong/pull/5556#discussion_r946275164
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSource.java:
##
@@ -48,9 +48,6 @@ public class FileSource extends StreamSour
healchow commented on code in PR #5557:
URL: https://github.com/apache/inlong/pull/5557#discussion_r946280388
##
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/SinkType.java:
##
@@ -35,6 +35,7 @@ public enum SinkType {
ORACLE,
TDSQLP
healchow commented on code in PR #5503:
URL: https://github.com/apache/inlong/pull/5503#discussion_r946281872
##
inlong-distribution/src/main/assemblies/sort-connectors.xml:
##
@@ -1,159 +1,167 @@
-
-
EMsnap commented on code in PR #5503:
URL: https://github.com/apache/inlong/pull/5503#discussion_r946283705
##
inlong-sort/sort-connectors/doris/pom.xml:
##
@@ -0,0 +1,80 @@
+
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
EMsnap merged PR #5472:
URL: https://github.com/apache/inlong/pull/5472
--
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.apach
This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 27217e34b [INLONG-5538][DataProxy] Optimize the Producer construction
logic in TubeSink (#5545)
add ef15ddd54 [IN
vernedeng opened a new pull request, #5561:
URL: https://github.com/apache/inlong/pull/5561
### Prepare a Pull Request
- Fixes #5560
### Motivation
*Explain here the context, and why you're making that change. What is the
problem you're trying to solve?*
### Modi
dockerzhang merged PR #5554:
URL: https://github.com/apache/inlong/pull/5554
--
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.
dockerzhang commented on PR #5561:
URL: https://github.com/apache/inlong/pull/5561#issuecomment-1216081373
@vernedeng I think `InLong` is right, and it's no need to change it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from ef15ddd54 [INLONG-5047][Agent] Support collect data from SQLServer
(#5472)
add f2ca3b83d [INLONG-5553][Comm
gosonzhang commented on code in PR #5552:
URL: https://github.com/apache/inlong/pull/5552#discussion_r946288733
##
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java:
##
@@ -121,6 +133,10 @@ public void configure(Context context) {
yunqingmoswu commented on code in PR #5503:
URL: https://github.com/apache/inlong/pull/5503#discussion_r946288077
##
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/DorisExtractNode.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache Soft
gosonzhang commented on code in PR #5552:
URL: https://github.com/apache/inlong/pull/5552#discussion_r946288809
##
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java:
##
@@ -338,8 +385,9 @@ public void run() {
thesumery commented on PR #5502:
URL: https://github.com/apache/inlong/pull/5502#issuecomment-1216082349
LGTM
--
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
thesumery commented on PR #5503:
URL: https://github.com/apache/inlong/pull/5503#issuecomment-1216084479
LGTM
--
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
dockerzhang commented on PR #5543:
URL: https://github.com/apache/inlong/pull/5543#issuecomment-1216086877
please change the `1.1-SNAPSHOT` to a stable version.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
EMsnap commented on code in PR #5550:
URL: https://github.com/apache/inlong/pull/5550#discussion_r946299488
##
inlong-sort/sort-connectors/hbase/src/main/java/org/apache/inlong/sort/hbase/sink/HBaseSinkFunction.java:
##
@@ -103,15 +104,17 @@ public HBaseSinkFunction(
yunqingmoswu commented on code in PR #5546:
URL: https://github.com/apache/inlong/pull/5546#discussion_r946300594
##
inlong-sort/sort-connectors/postgres-cdc/pom.xml:
##
@@ -46,6 +46,11 @@
sort-connector-base
${project.version}
+
Revi
yunqingmoswu commented on code in PR #5548:
URL: https://github.com/apache/inlong/pull/5548#discussion_r946301668
##
inlong-sort/sort-connectors/mongodb-cdc/pom.xml:
##
@@ -41,6 +41,11 @@
sort-connector-base
${project.version}
+
+
yunqingmoswu commented on code in PR #5549:
URL: https://github.com/apache/inlong/pull/5549#discussion_r946301884
##
inlong-sort/sort-connectors/oracle-cdc/pom.xml:
##
@@ -44,6 +44,11 @@
sort-connector-base
${project.version}
+
+
gong commented on code in PR #5550:
URL: https://github.com/apache/inlong/pull/5550#discussion_r946302016
##
inlong-sort/sort-connectors/hbase/src/main/java/org/apache/inlong/sort/hbase/sink/HBaseSinkFunction.java:
##
@@ -103,15 +104,17 @@ public HBaseSinkFunction(
dockerzhang commented on code in PR #5552:
URL: https://github.com/apache/inlong/pull/5552#discussion_r94630
##
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java:
##
@@ -121,6 +137,10 @@ public void configure(Context context) {
gong commented on code in PR #5549:
URL: https://github.com/apache/inlong/pull/5549#discussion_r946302708
##
inlong-sort/sort-connectors/oracle-cdc/pom.xml:
##
@@ -44,6 +44,11 @@
sort-connector-base
${project.version}
+
+or
gong commented on code in PR #5548:
URL: https://github.com/apache/inlong/pull/5548#discussion_r946303461
##
inlong-sort/sort-connectors/mongodb-cdc/pom.xml:
##
@@ -41,6 +41,11 @@
sort-connector-base
${project.version}
+
+o
gong commented on code in PR #5546:
URL: https://github.com/apache/inlong/pull/5546#discussion_r946303670
##
inlong-sort/sort-connectors/postgres-cdc/pom.xml:
##
@@ -46,6 +46,11 @@
sort-connector-base
${project.version}
+
Review Comme
gosonzhang commented on code in PR #5552:
URL: https://github.com/apache/inlong/pull/5552#discussion_r946303925
##
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java:
##
@@ -121,6 +137,10 @@ public void configure(Context context) {
leosanqing commented on code in PR #5379:
URL: https://github.com/apache/inlong/pull/5379#discussion_r946304458
##
pom.xml:
##
@@ -250,6 +251,8 @@
4.0.3
2.9.3
3.0.0
+
+1.7
Review Comment:
I can't find a version that says that jdk8 o
yunqingmoswu commented on PR #5543:
URL: https://github.com/apache/inlong/pull/5543#issuecomment-1216101875
> please change the `1.1-SNAPSHOT` to a stable version.
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
haifxu opened a new pull request, #5563:
URL: https://github.com/apache/inlong/pull/5563
- Fixes #5562
### Motivation
Supplement the API that the manager web exists but the client does not exist
for manager client.
### Modifications
Add the workflow API in the ma
gosonzhang merged PR #5552:
URL: https://github.com/apache/inlong/pull/5552
--
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.a
dockerzhang merged PR #5550:
URL: https://github.com/apache/inlong/pull/5550
--
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.
dockerzhang merged PR #5512:
URL: https://github.com/apache/inlong/pull/5512
--
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.
leosanqing commented on code in PR #5563:
URL: https://github.com/apache/inlong/pull/5563#discussion_r946384155
##
inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/WorkflowApi.java:
##
@@ -37,8 +43,29 @@ public interface WorkflowApi {
leezng opened a new pull request, #5566:
URL: https://github.com/apache/inlong/pull/5566
- Fixes #5565
--
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-mai
72 matches
Mail list logo