[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * de880af98f24b8a8195f65bca492883ce4c05846 Azure:

[GitHub] [flink] flinkbot commented on pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

2022-01-24 Thread GitBox
flinkbot commented on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020904530 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481626#comment-17481626 ] Till Rohrmann commented on FLINK-25728: --- cc [~pnowojski] > Potential memory leaks in

[jira] [Updated] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

2022-01-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25728: -- Summary: Potential memory leaks in StreamMultipleInputProcessor (was: Protential memory

[GitHub] [flink] tillrohrmann commented on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-24 Thread GitBox
tillrohrmann commented on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1020903329 What's the state of this PR? Can we resolve the open comments to merge it soon? -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-25801) add cpu processor metric of taskmanager

2022-01-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王俊博 updated FLINK-25801: Description: flink process add cpu load metric, with user know environment of cpu processor they can determine

[GitHub] [flink] zhuzhurk commented on a change in pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

2022-01-24 Thread GitBox
zhuzhurk commented on a change in pull request #18376: URL: https://github.com/apache/flink/pull/18376#discussion_r791440840 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java ## @@ -148,6 +167,80 @@ private

[GitHub] [flink] JingsongLi commented on pull request #18490: [FLINK-25794][sql-runtime] Clean cache after memory segments in it after they are released to MemoryManager

2022-01-24 Thread GitBox
JingsongLi commented on pull request #18490: URL: https://github.com/apache/flink/pull/18490#issuecomment-1020901998 Hi @zjureel I replied you in JIRA. -- 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

[jira] [Commented] (FLINK-25794) Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager

2022-01-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481625#comment-17481625 ] Jingsong Lee commented on FLINK-25794: -- Can you give a specific case of error? > Memory pages in

[jira] [Updated] (FLINK-25801) add cpu processor metric of taskmanager

2022-01-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25801: --- Labels: pull-request-available (was: ) > add cpu processor metric of taskmanager >

[jira] [Commented] (FLINK-25794) Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager

2022-01-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481624#comment-17481624 ] Jingsong Lee commented on FLINK-25794: -- Hi [~zjureel] , `MemoryManager.release` will clear segments

[GitHub] [flink] Kwafoor opened a new pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

2022-01-24 Thread GitBox
Kwafoor opened a new pull request #18498: URL: https://github.com/apache/flink/pull/18498 ## What is the purpose of the change This PR add container access cpu processor metric. ## Brief change log - add container access cpu processor metric. ## Verifying this change

[GitHub] [flink] fapaul commented on pull request #18469: [FLINK-25485][connector/jdbc] Append default JDBC URL option of batch writing in MySQL.

2022-01-24 Thread GitBox
fapaul commented on pull request #18469: URL: https://github.com/apache/flink/pull/18469#issuecomment-1020900986 @leonardBang can you take a look at this? -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * de880af98f24b8a8195f65bca492883ce4c05846 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 11799600e83d55b8150cdb93ad90d1a55fd2651f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * de880af98f24b8a8195f65bca492883ce4c05846 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-995629902 ## CI report: * a01ee8682f200b0332bccc8d96f2e25fe3a056f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1017872223 ## CI report: * 4d4b6ef9bf6c75d3dbbe3d64b58eb5ffcc218ebf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 11799600e83d55b8150cdb93ad90d1a55fd2651f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-995629902 ## CI report: * a01ee8682f200b0332bccc8d96f2e25fe3a056f2 Azure:

[GitHub] [flink] zjureel commented on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
zjureel commented on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1020892847 Thanks @KarmaGYZ , I have updated the doc and comments in `FileExecutionGraphInfoStore` and `FileExecutionGraphInfoStoreTest` -- This is an automated message from the

[jira] [Updated] (FLINK-25802) OverWindow in batch mode failed

2022-01-24 Thread Zoyo Pei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zoyo Pei updated FLINK-25802: - Description: {code:java} StreamExecutionEnvironment env =

[jira] [Updated] (FLINK-25802) OverWindow in batch mode failed

2022-01-24 Thread Zoyo Pei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zoyo Pei updated FLINK-25802: - Description: {code:java} StreamExecutionEnvironment env =

[GitHub] [flink] wanglijie95 commented on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
wanglijie95 commented on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-1020891761 > @wanglijie95 Thanks for the contribution. The code looks generally good to me and I only left several tiny comments. Thanks for review @wsry . I've addressed all

[GitHub] [flink] wanglijie95 commented on a change in pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
wanglijie95 commented on a change in pull request #18130: URL: https://github.com/apache/flink/pull/18130#discussion_r791429730 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java ## @@ -834,14 +817,82 @@

[GitHub] [flink] wanglijie95 commented on a change in pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

2022-01-24 Thread GitBox
wanglijie95 commented on a change in pull request #18130: URL: https://github.com/apache/flink/pull/18130#discussion_r791429362 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputChannel.java ## @@ -94,6 +97,7 @@ protected

[jira] [Created] (FLINK-25802) OverWindow in batch mode failed

2022-01-24 Thread Zoyo Pei (Jira)
Zoyo Pei created FLINK-25802: Summary: OverWindow in batch mode failed Key: FLINK-25802 URL: https://issues.apache.org/jira/browse/FLINK-25802 Project: Flink Issue Type: Bug Affects

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * de880af98f24b8a8195f65bca492883ce4c05846 Azure:

[GitHub] [flink] deadwind4 commented on a change in pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-24 Thread GitBox
deadwind4 commented on a change in pull request #18388: URL: https://github.com/apache/flink/pull/18388#discussion_r791427956 ## File path: flink-connectors/flink-sql-connector-pulsar/pom.xml ## @@ -0,0 +1,73 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Assigned] (FLINK-25794) Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager

2022-01-24 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-25794: -- Assignee: Shammon > Memory pages in LazyMemorySegmentPool should be clear after they are

[GitHub] [flink] flinkbot edited a comment on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020843806 ## CI report: * 52d21ea631d0ff554012d0806e6593eb4e550052 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18464: URL: https://github.com/apache/flink/pull/18464#issuecomment-1019940732 ## CI report: * 71e985936a4ce00e72cb88180100f4479e04b435 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * de880af98f24b8a8195f65bca492883ce4c05846 Azure:

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-01-24 Thread GitBox
syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r791421706 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarConfigUtils.java ## @@ -94,6

[GitHub] [flink] flinkbot edited a comment on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020843806 ## CI report: * 52d21ea631d0ff554012d0806e6593eb4e550052 Azure:

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-01-24 Thread GitBox
syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r791421347 ## File path: flink-connectors/flink-connector-pulsar/pom.xml ## @@ -163,13 +202,22 @@ under the License. -

[GitHub] [flink] flinkbot edited a comment on pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18464: URL: https://github.com/apache/flink/pull/18464#issuecomment-1019940732 ## CI report: * 71e985936a4ce00e72cb88180100f4479e04b435 Azure:

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-01-24 Thread GitBox
syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r791420346 ## File path: flink-connectors/flink-connector-pulsar/pom.xml ## @@ -138,23 +140,60 @@ under the License. ${pulsar.version}

[GitHub] [flink] twalthr commented on pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
twalthr commented on pull request #18464: URL: https://github.com/apache/flink/pull/18464#issuecomment-1020882424 Thanks for the feedback @slinkydeveloper and @matriv. I split the PR into several commits and addressed the module system issue. I also found a bug on the way in the

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-01-24 Thread GitBox
syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r791419782 ## File path: flink-connectors/flink-connector-pulsar/pom.xml ## @@ -36,12 +36,14 @@ under the License. jar - 2.8.0 +

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-01-24 Thread GitBox
syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r791419494 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSink.java ## @@ -0,0 +1,121 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020843806 ## CI report: * 52d21ea631d0ff554012d0806e6593eb4e550052 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18464: URL: https://github.com/apache/flink/pull/18464#issuecomment-1019940732 ## CI report: * 71e985936a4ce00e72cb88180100f4479e04b435 Azure:

[GitHub] [flink] im-pratham commented on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-24 Thread GitBox
im-pratham commented on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020879786 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18497: [FLINK-25290][tests] add table tests for connector testframe

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020875715 ## CI report: * 85206e64e2a833777a2c346c38202b222674bc75 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
twalthr commented on a change in pull request #18464: URL: https://github.com/apache/flink/pull/18464#discussion_r791416041 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/BuiltInSqlFunction.java ## @@ -0,0 +1,244 @@

[GitHub] [flink] syhily commented on a change in pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-24 Thread GitBox
syhily commented on a change in pull request #18388: URL: https://github.com/apache/flink/pull/18388#discussion_r791415871 ## File path: flink-connectors/flink-sql-connector-pulsar/pom.xml ## @@ -0,0 +1,73 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] syhily commented on a change in pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-24 Thread GitBox
syhily commented on a change in pull request #18388: URL: https://github.com/apache/flink/pull/18388#discussion_r791415871 ## File path: flink-connectors/flink-sql-connector-pulsar/pom.xml ## @@ -0,0 +1,73 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] twalthr commented on a change in pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-24 Thread GitBox
twalthr commented on a change in pull request #18464: URL: https://github.com/apache/flink/pull/18464#discussion_r791415561 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/module/Module.java ## @@ -36,17 +36,28 @@ public interface Module {

[GitHub] [flink] flinkbot commented on pull request #18497: [FLINK-25290][tests] add table tests for connector testframe

2022-01-24 Thread GitBox
flinkbot commented on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020875715 ## CI report: * 85206e64e2a833777a2c346c38202b222674bc75 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18497: [FLINK-25290][tests] add table tests for connector testframe

2022-01-24 Thread GitBox
flinkbot commented on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020874705 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-25801) add cpu processor metric of taskmanager

2022-01-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王俊博 updated FLINK-25801: Description: flink process add cpu load metric, with user know environment of cpu processor they can determine

[jira] [Resolved] (FLINK-25739) Include changelog jars into distribution

2022-01-24 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-25739. --- Resolution: Fixed Merged as 21607350ffdf1af371ea9a0728e3b83ee5780f88. > Include

[GitHub] [flink] rkhachatryan merged pull request #18432: [FLINK-25739][dist] Include Changelog to flink-dist jar

2022-01-24 Thread GitBox
rkhachatryan merged pull request #18432: URL: https://github.com/apache/flink/pull/18432 -- 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:

[jira] [Updated] (FLINK-25290) Add table source and sink test suite in connector testing framework

2022-01-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25290: --- Labels: pull-request-available (was: ) > Add table source and sink test suite in connector

[jira] [Comment Edited] (FLINK-18356) Exit code 137 returned from process

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481586#comment-17481586 ] Yun Gao edited comment on FLINK-18356 at 1/25/22, 7:03 AM: ---

[jira] [Resolved] (FLINK-25524) If enabled changelog, RocksDB incremental checkpoint would always be full

2022-01-24 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-25524. --- Resolution: Fixed Merged as d0927dd41e2f0441e4e5825ff423dd0e903713f3. > If enabled

[jira] [Updated] (FLINK-25801) add cpu processor metric of taskmanager

2022-01-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王俊博 updated FLINK-25801: Description: flink process add cpu load metric, with user know environment of cpu processor they can determine

[GitHub] [flink] ruanhang1993 opened a new pull request #18497: [FLINK-25290][tests] add table tests for connector testframe

2022-01-24 Thread GitBox
ruanhang1993 opened a new pull request #18497: URL: https://github.com/apache/flink/pull/18497 ## What is the purpose of the change This pull request adds table tests for the connector testframe. ## Brief change log - add table tests for the connector testframe -

[GitHub] [flink] rkhachatryan merged pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-24 Thread GitBox
rkhachatryan merged pull request #18382: URL: https://github.com/apache/flink/pull/18382 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1020867632 ## CI report: * 909c17a856976df8b5be1729553873ecbd4b Azure:

[GitHub] [flink] flinkbot commented on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-01-24 Thread GitBox
flinkbot commented on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1020867632 -- 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

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481586#comment-17481586 ] Yun Gao commented on FLINK-18356: - !1234.jpg|width=651,height=313! I compared the current master and

[jira] [Updated] (FLINK-25289) Add DataStream sink test suite in connector testing framework

2022-01-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25289: --- Labels: pull-request-available (was: ) > Add DataStream sink test suite in connector

[GitHub] [flink] ruanhang1993 opened a new pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-01-24 Thread GitBox
ruanhang1993 opened a new pull request #18496: URL: https://github.com/apache/flink/pull/18496 ## What is the purpose of the change This pull request adds data stream sink test suite in the connector testframe. ## Brief change log - add data stream sink test suite in

[jira] [Updated] (FLINK-18356) Exit code 137 returned from process

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18356: Attachment: 1234.jpg > Exit code 137 returned from process > --- > >

[jira] [Closed] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24163. --- Resolution: Fixed > PartiallyFinishedSourcesITCase fails due to timeout >

[jira] [Comment Edited] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481581#comment-17481581 ] Yun Gao edited comment on FLINK-24163 at 1/25/22, 6:45 AM: --- Would close this

[jira] [Commented] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

2022-01-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481581#comment-17481581 ] Yun Gao commented on FLINK-24163: - Would close this issue since it does not occur >

[GitHub] [flink] JingsongLi commented on pull request #16207: [FLINK-23031][table-runtime]Make processing time trigger dont repeat itself when no new element come in

2022-01-24 Thread GitBox
JingsongLi commented on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-1020852457 CC: @wuchong -- 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

[jira] [Created] (FLINK-25801) add cpu processor metric of taskmanager

2022-01-24 Thread Jira
王俊博 created FLINK-25801: --- Summary: add cpu processor metric of taskmanager Key: FLINK-25801 URL: https://issues.apache.org/jira/browse/FLINK-25801 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020843806 ## CI report: * 52d21ea631d0ff554012d0806e6593eb4e550052 Azure:

[GitHub] [flink] flinkbot commented on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-24 Thread GitBox
flinkbot commented on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020843806 ## CI report: * 52d21ea631d0ff554012d0806e6593eb4e550052 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-24 Thread GitBox
flinkbot commented on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020843477 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] im-pratham opened a new pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-24 Thread GitBox
im-pratham opened a new pull request #18495: URL: https://github.com/apache/flink/pull/18495 ## What is the purpose of the change *Updated pod template to reflect image name and tag* ## Brief change log - *Updated pod template to reflect image name and tag* ##

[GitHub] [flink] jelly-1203 removed a comment on pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

2022-01-24 Thread GitBox
jelly-1203 removed a comment on pull request #18493: URL: https://github.com/apache/flink/pull/18493#issuecomment-1020840973 thanks -- 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

[GitHub] [flink] jelly-1203 commented on pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

2022-01-24 Thread GitBox
jelly-1203 commented on pull request #18493: URL: https://github.com/apache/flink/pull/18493#issuecomment-1020840973 thanks -- 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.

[GitHub] [flink] shouzuo1 removed a comment on pull request #18358: [FLINK-25651][docs] Update kafka.md

2022-01-24 Thread GitBox
shouzuo1 removed a comment on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1020840716 thanks -- 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

[GitHub] [flink] shouzuo1 commented on pull request #18358: [FLINK-25651][docs] Update kafka.md

2022-01-24 Thread GitBox
shouzuo1 commented on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1020840716 thanks -- 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.

[GitHub] [flink] flinkbot edited a comment on pull request #18494: [FLINK-25307][DEBUG-ONLY] Add debug message

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18494: URL: https://github.com/apache/flink/pull/18494#issuecomment-1020833870 ## CI report: * 9055d4a7796442f616f805c0dd48f97abb3587bb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18489: [FLINK-25790][flink-gs-fs-hadoop] Support authentication via core-site.xml in GCS FileSystem plugin

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18489: URL: https://github.com/apache/flink/pull/18489#issuecomment-1020643947 ## CI report: * 6d23f67c6515ebfeef972314b5c19bb02fc3d2ed Azure:

[GitHub] [flink] shouzuo1 removed a comment on pull request #18358: [FLINK-25651][docs] Update kafka.md

2022-01-24 Thread GitBox
shouzuo1 removed a comment on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1020833654 thanks -- 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

[GitHub] [flink] flinkbot commented on pull request #18494: [FLINK-25307][DEBUG-ONLY] Add debug message

2022-01-24 Thread GitBox
flinkbot commented on pull request #18494: URL: https://github.com/apache/flink/pull/18494#issuecomment-1020833870 ## CI report: * 9055d4a7796442f616f805c0dd48f97abb3587bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18481: [FLINK-25307][test] Change e2e nodename used to 127.0.0.1 and add debug information

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18481: URL: https://github.com/apache/flink/pull/18481#issuecomment-1020251442 ## CI report: * ce4954e2d80790b2bcbf2259cf994a5faeed50ff Azure:

[GitHub] [flink] shouzuo1 commented on pull request #18358: [FLINK-25651][docs] Update kafka.md

2022-01-24 Thread GitBox
shouzuo1 commented on pull request #18358: URL: https://github.com/apache/flink/pull/18358#issuecomment-1020833654 thanks -- 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.

[GitHub] [flink] flinkbot commented on pull request #18494: [FLINK-25307][DEBUG-ONLY] Add debug message

2022-01-24 Thread GitBox
flinkbot commented on pull request #18494: URL: https://github.com/apache/flink/pull/18494#issuecomment-1020833025 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18481: [FLINK-25307][test] Change e2e nodename used to 127.0.0.1 and add debug information

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18481: URL: https://github.com/apache/flink/pull/18481#issuecomment-1020251442 ## CI report: * ce4954e2d80790b2bcbf2259cf994a5faeed50ff Azure:

[GitHub] [flink] gaoyunhaii opened a new pull request #18494: [FLINK-25307][DEBUG-ONLY] Add debug message

2022-01-24 Thread GitBox
gaoyunhaii opened a new pull request #18494: URL: https://github.com/apache/flink/pull/18494 This PR tries to debug the hostname resolve with the commit ci pipeline. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 59f46a383a5cca968faf82f8c260217649a6f825 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * bbf72ae73592bd646c44296a59ef70d3eb614701 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18493: URL: https://github.com/apache/flink/pull/18493#issuecomment-1020820553 ## CI report: * 05eecb0902812076e561dab93951c625564233bc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18492: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18492: URL: https://github.com/apache/flink/pull/18492#issuecomment-1020820488 ## CI report: * e2ce82eee950b512b719e2813f7e75591e32fb69 Azure:

[GitHub] [flink] flinkbot commented on pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

2022-01-24 Thread GitBox
flinkbot commented on pull request #18493: URL: https://github.com/apache/flink/pull/18493#issuecomment-1020820627 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

2022-01-24 Thread GitBox
flinkbot commented on pull request #18493: URL: https://github.com/apache/flink/pull/18493#issuecomment-1020820553 ## CI report: * 05eecb0902812076e561dab93951c625564233bc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18492: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

2022-01-24 Thread GitBox
flinkbot commented on pull request #18492: URL: https://github.com/apache/flink/pull/18492#issuecomment-1020820488 ## CI report: * e2ce82eee950b512b719e2813f7e75591e32fb69 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.

2022-01-24 Thread GitBox
flinkbot edited a comment on pull request #18491: URL: https://github.com/apache/flink/pull/18491#issuecomment-1020818213 ## CI report: * a072fd8479b34bf48c84b2786b792f7b55f4e841 Azure:

[GitHub] [flink] flinkbot commented on pull request #18492: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

2022-01-24 Thread GitBox
flinkbot commented on pull request #18492: URL: https://github.com/apache/flink/pull/18492#issuecomment-1020819365 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-25798) Translate datastream/formats/text_files.md page into Chinese.

2022-01-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25798: --- Labels: chinese-translation pull-request-available (was: chinese-translation) > Translate

[GitHub] [flink] RocMarshal opened a new pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

2022-01-24 Thread GitBox
RocMarshal opened a new pull request #18493: URL: https://github.com/apache/flink/pull/18493 ## What is the purpose of the change Translate datastream/formats/text_files.md page into Chinese. ## Brief change log Translate datastream/formats/text_files.md

[GitHub] [flink] flinkbot commented on pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.

2022-01-24 Thread GitBox
flinkbot commented on pull request #18491: URL: https://github.com/apache/flink/pull/18491#issuecomment-1020818213 ## CI report: * a072fd8479b34bf48c84b2786b792f7b55f4e841 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

  1   2   3   4   5   6   7   8   9   10   >