gosonzhang opened a new pull request, #5929:
URL: https://github.com/apache/inlong/pull/5929
- Fixes #5924
--
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 un
yunqingmoswu commented on code in PR #5906:
URL: https://github.com/apache/inlong/pull/5906#discussion_r973986871
##
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/configuration/Constants.java:
##
@@ -275,10 +281,17 @@ public class Constants {
.default
dockerzhang commented on issue #4972:
URL: https://github.com/apache/inlong/issues/4972#issuecomment-1250724576
@DavidYoungdj do you still work on this issue?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
iamsee123 commented on code in PR #5780:
URL: https://github.com/apache/inlong/pull/5780#discussion_r973875169
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/RedisReader.java:
##
@@ -0,0 +1,445 @@
+/*
+ * Licensed to the Apache Software
gong commented on code in PR #5906:
URL: https://github.com/apache/inlong/pull/5906#discussion_r973995570
##
inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/SinkMetricData.java:
##
@@ -286,16 +286,17 @@ public void invokeDirty(long rowCount, lon
gong commented on code in PR #5906:
URL: https://github.com/apache/inlong/pull/5906#discussion_r973996813
##
inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/SourceMetricData.java:
##
@@ -229,4 +222,19 @@ public void outputMetrics(long rowCountSi
healchow merged PR #5815:
URL: https://github.com/apache/inlong/pull/5815
--
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.apa
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from eb0c33b61 [INLONG-5874][Agent] Use dataTime to report audit metrics
(#5883)
add 371fc3ff5 [INLONG-5810][Manage
iamsee123 commented on code in PR #5780:
URL: https://github.com/apache/inlong/pull/5780#discussion_r974002773
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/RedisReader.java:
##
@@ -0,0 +1,445 @@
+/*
+ * Licensed to the Apache Software
iamsee123 commented on code in PR #5780:
URL: https://github.com/apache/inlong/pull/5780#discussion_r974003475
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/RedisReader.java:
##
@@ -0,0 +1,445 @@
+/*
+ * Licensed to the Apache Software
Oneal65 commented on code in PR #5906:
URL: https://github.com/apache/inlong/pull/5906#discussion_r972704659
##
inlong-sort/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java:
##
@@ -94,44 +85,20 @@ publi
thesumery commented on code in PR #5906:
URL: https://github.com/apache/inlong/pull/5906#discussion_r974044872
##
inlong-sort/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java:
##
@@ -94,44 +85,20 @@ pub
thesumery commented on code in PR #5906:
URL: https://github.com/apache/inlong/pull/5906#discussion_r974047625
##
inlong-sort/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java:
##
@@ -94,44 +85,20 @@ pub
DavidYoungdj commented on issue #4972:
URL: https://github.com/apache/inlong/issues/4972#issuecomment-1250792318
Sorry for that I'm not work on this issue.I need to focus on my course now.
-- 原始邮件 --
发件人:
gong commented on PR #5906:
URL: https://github.com/apache/inlong/pull/5906#issuecomment-1250795247
```java
public void invoke(long rowCount, long rowSize) {
if (numRecordsOut != null) {
numRecordsOut.inc(rowCount);
}
if (numBytesOut != n
leezng opened a new pull request, #5932:
URL: https://github.com/apache/inlong/pull/5932
- Fixes #5931
--
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
thesumery commented on PR #5906:
URL: https://github.com/apache/inlong/pull/5906#issuecomment-1250864705
>
fixed
--
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.
dockerzhang merged PR #5780:
URL: https://github.com/apache/inlong/pull/5780
--
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.
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.git
The following commit(s) were added to refs/heads/master by this push:
new dfd57b119 [INLONG-5722][Agent] Support Redi
dockerzhang merged PR #5906:
URL: https://github.com/apache/inlong/pull/5906
--
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.
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 dfd57b119 [INLONG-5722][Agent] Support Redis Source (#5780)
add 4fa1218a4 [INLONG-5903][Sort] Make InLong me
gosonzhang merged PR #5929:
URL: https://github.com/apache/inlong/pull/5929
--
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 cdd279ea8 [INLONG-5924][DataProxy] Supplemen
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
from dd34252d9 [INLONG-5784][Sort] Add metric state for PostgreSQL (#5785)
new aaf175ba4 [INLONG-5922][Sor
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
commit eb00535bf0ac9fff42c58aebeb22b05b9b899829
Author: thesumery <107393625+thesum...@users.noreply.github.com>
Aut
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
commit aaf175ba471fdadd09f11f31cb29ac0d69e42de7
Author: Xin Gong
AuthorDate: Mon Sep 19 11:37:57 2022 +0800
[I
EMsnap opened a new pull request, #5934:
URL: https://github.com/apache/inlong/pull/5934
- Fixes #5930
### Motivation
Support metric state recovery for sqlserver-cdc
### Modifications
Support metric state recovery for sqlserver-cdc
### Verifying this change
healchow commented on issue #5926:
URL: https://github.com/apache/inlong/issues/5926#issuecomment-1250919014
> I want to process this issue, could someone assign it to me?
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
gong opened a new pull request, #5935:
URL: https://github.com/apache/inlong/pull/5935
### Prepare a Pull Request
- [INLONG-5913][Sort] Add metric state for oracle and fix speed computing
error
- Fixes #5913
### Motivation
Add metric state for oracle and fix
GanfengTan commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974833238
##
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/JobProfileDb.java:
##
@@ -192,4 +197,20 @@ public List getJobsByState(StateSearchKey
stateSearch
GanfengTan commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974834153
##
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/job/JobManager.java:
##
@@ -241,6 +241,8 @@ public Runnable dbStorageCheckThread() {
haifxu opened a new pull request, #5937:
URL: https://github.com/apache/inlong/pull/5937
### Prepare a Pull Request
- Fixes #5936
### Motivation

 were added to refs/heads/master by this push:
new 9ec281ce6 [INLONG-5931][Dashboard] Support query
leezng opened a new pull request, #5939:
URL: https://github.com/apache/inlong/pull/5939
- Fixes #5938
--
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
gong commented on issue #5914:
URL: https://github.com/apache/inlong/issues/5914#issuecomment-1251779671
duplication with https://github.com/apache/inlong/issues/5933, close this
issue
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
gosonzhang opened a new pull request, #5942:
URL: https://github.com/apache/inlong/pull/5942
- Fixes #5941
--
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 unsubscrib
healchow commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974847223
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/TextFileReader.java:
##
@@ -79,6 +81,10 @@ public void getData() throws IO
yunqingmoswu merged PR #5935:
URL: https://github.com/apache/inlong/pull/5935
--
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
This is an automated email from the ASF dual-hosted git repository.
yunqing 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 4b4f0dc2f [INLONG-5913][Sort] Add metric state
healchow commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974847679
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java:
##
@@ -300,6 +307,24 @@ private void dealWithFetchResult(TaskResu
healchow merged PR #5937:
URL: https://github.com/apache/inlong/pull/5937
--
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.apa
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 4b4f0dc2f [INLONG-5913][Sort] Add metric state for oracle and fix
speed computing error (#5935)
add 02793fe88
GanfengTan commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974855940
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java:
##
@@ -300,6 +307,24 @@ private void dealWithFetchResult(TaskRe
healchow merged PR #5939:
URL: https://github.com/apache/inlong/pull/5939
--
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.apa
This is an automated email from the ASF dual-hosted git repository.
healchow 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 d8d756188 [INLONG-5938][Dashboard] The paramet
GanfengTan commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974856370
##
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/trigger/TriggerManager.java:
##
@@ -156,6 +169,35 @@ private Runnable jobFetchThread() {
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/release-1.3.0 by this push:
new a62e29155 [INLONG-5913][Sort]
GanfengTan commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974857126
##
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/job/JobWrapper.java:
##
@@ -169,4 +170,11 @@ public void addCallbacks() {
public List getAll
GanfengTan commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974858242
##
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/job/Job.java:
##
@@ -83,8 +88,21 @@ public void setJobInstanceId(String jobInstanceId) {
*
GanfengTan commented on code in PR #5910:
URL: https://github.com/apache/inlong/pull/5910#discussion_r974865689
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/TextFileReader.java:
##
@@ -79,6 +81,10 @@ public void getData() throws
dockerzhang merged PR #5942:
URL: https://github.com/apache/inlong/pull/5942
--
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.
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.git
The following commit(s) were added to refs/heads/master by this push:
new 8cde9f3b3 [INLONG-5941][DataProxy] Store th
yunqingmoswu opened a new pull request, #5945:
URL: https://github.com/apache/inlong/pull/5945
### Prepare a Pull Request
*(Change the title refer to the following example)*
Title: [INLONG-5940][Sort] Compatible with the old version of sort protocol
with mysql and kafka extract nod
gosonzhang opened a new pull request, #5947:
URL: https://github.com/apache/inlong/pull/5947
- Fixes #5946
--
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
vernedeng opened a new pull request, #563:
URL: https://github.com/apache/inlong-website/pull/563
### 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
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch fix-5948
in repository https://gitbox.apache.org/repos/asf/inlong.git
at c46d0fa47 [INLONG-5948][Audit] Add the enable audit environment
This branch includes the following new commits
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch fix-5948
in repository https://gitbox.apache.org/repos/asf/inlong.git
commit c46d0fa47319b05cddce4386013be05b8e436cc9
Author: dockerzhang
AuthorDate: Tue Sep 20 14:37:21 2022 +0800
[INL
dockerzhang opened a new pull request, #5949:
URL: https://github.com/apache/inlong/pull/5949
### 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 repl
EMsnap opened a new pull request, #5951:
URL: https://github.com/apache/inlong/pull/5951
- Fixes #5950
### Motivation
[INLONG-5950][Sort] Support metric state recovery for mongo-cdc
### Modifications
[INLONG-5950][Sort] Support metric state recovery for mongo-cdc
kipshi merged PR #5945:
URL: https://github.com/apache/inlong/pull/5945
--
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.
kipshi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 8cde9f3b3 [INLONG-5941][DataProxy] Store the initial number of message
items in Map (#5942)
add 4fe63cf68 [INLON
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/release-1.3.0 by this push:
new 7f002a390 [INLONG-5940][Sort]
63 matches
Mail list logo