[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-18 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 810e4e349946878d5727b61b5c76da77a2310ea2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * bee4ba9ac6648dbdb56ed806ef8643b6c84aeb68 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * a65b12ce87fe15a5474b0a740e9a054e7685941d Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

2022-01-18 Thread GitBox
Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r787422412 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -66,16 +71,36 @@ public

[GitHub] [flink] LadyForest edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
LadyForest edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1016159041 > I just feel, the testing classes are too complicate, can we simplify them? We only need to test what we need, there is no need to have very strong features.

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * a65b12ce87fe15a5474b0a740e9a054e7685941d Azure:

[jira] [Closed] (FLINK-25650) Document unaligned checkpoints performance limitations (larger records/flat map/timers/...)

2022-01-18 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25650. -- Fix Version/s: 1.15.0 1.14.4 Resolution: Fixed merged commit

[GitHub] [flink] LadyForest commented on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
LadyForest commented on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1016159041 > I just feel, the testing classes are too complicate, can we simplify them? We only need to test what we need, there is no need to have very strong features. I'm

[GitHub] [flink] pnowojski merged pull request #18354: [FLINK-25650][docs] Added "Interplay with long-running record process…

2022-01-18 Thread GitBox
pnowojski merged pull request #18354: URL: https://github.com/apache/flink/pull/18354 -- 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] [Assigned] (FLINK-25194) Implement an API for duplicating artefacts

2022-01-18 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-25194: Assignee: Dawid Wysakowicz (was: Piotr Nowojski) > Implement an API for

[jira] [Closed] (FLINK-25194) Implement an API for duplicating artefacts

2022-01-18 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-25194. Resolution: Implemented Implemented in fc1d63579ae5bcd9db207e1a5cd1b6365a87e871 >

[GitHub] [flink] dawidwys merged pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

2022-01-18 Thread GitBox
dawidwys merged pull request #18341: URL: https://github.com/apache/flink/pull/18341 -- 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 #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * b8d38cab5e0afaf20f07d9aa707729f19962e2b8 Azure:

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

2022-01-18 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478366#comment-17478366 ] Yun Gao edited comment on FLINK-24163 at 1/19/22, 7:18 AM: --- This seems to be

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

2022-01-18 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478366#comment-17478366 ] Yun Gao commented on FLINK-24163: - This seems to be due to different reason.  Hi [~roman] , by binary

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1013081147 ## CI report: * 22c8ded41179db1141351bb78cebcd77e8d35b2c 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-18 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 2dbb1737df0af1db911cf2b2a449016395991bd1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 6024e28f7d315a7d1157f9af33da9b815f81a27a Azure:

[GitHub] [flink] LadyForest commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
LadyForest commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r787405220 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterTableCompactOperation.java ## @@ -18,41

[GitHub] [flink] zhuzhengjun01 edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2022-01-18 Thread GitBox
zhuzhengjun01 edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-1016148079 @maosuhan hi, flink-protobuf works very well in my job, but i found some corner case that it was not supported `oneof` in proto3. so this will be dealt in future

[GitHub] [flink] zhuzhengjun01 commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2022-01-18 Thread GitBox
zhuzhengjun01 commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-1016148079 @maosuhan hi, flink-protobuf works very well in my job, but i fount some corner case that it was not supported `oneof` in proto3. so this will be dealt in future or not

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d 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-18 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 2dbb1737df0af1db911cf2b2a449016395991bd1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 6024e28f7d315a7d1157f9af33da9b815f81a27a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * b8a9d9704d289aa32e8d040b7090a6fb97c4907c Azure:

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

2022-01-18 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478365#comment-17478365 ] Zhu Zhu commented on FLINK-25649: - >> Would it make sens to say that we encounter this issue because 2

[GitHub] [flink] LadyForest commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
LadyForest commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r787401902 ## File path: flink-formats/flink-orc/pom.xml ## @@ -145,6 +145,19 @@ under the License. test test-jar

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r787389637 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedTableSink.java ## @@ -0,0 +1,468 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #10: [FLINK-25680] Introduce Table Store Flink Sink

2022-01-18 Thread GitBox
tsreaper commented on a change in pull request #10: URL: https://github.com/apache/flink-table-store/pull/10#discussion_r787383851 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/SinkRecord.java ## @@ -0,0 +1,71 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure:

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

2022-01-18 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478355#comment-17478355 ] Yao Zhang commented on FLINK-25683: --- Hi [~twalthr] , This issue and FLINK-25471 is quite similar. 

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r787387670 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/ManagedTableFactory.java ## @@ -50,6 +51,13 @@ default

[jira] [Assigned] (FLINK-25697) Support HTTPS for Prometheus Push Gateway

2022-01-18 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-25697: - Assignee: Mason Chen > Support HTTPS for Prometheus Push Gateway >

[GitHub] [flink] jelly-1203 commented on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

2022-01-18 Thread GitBox
jelly-1203 commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-1016122102 anyone? -- 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] [Commented] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

2022-01-18 Thread Q Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478347#comment-17478347 ] Q Kang commented on FLINK-25614: [~jingzhang] Sorry for the late response. [~wenlong.lwl] had given the

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

2022-01-18 Thread GitBox
KarmaGYZ commented on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1016116941 Thanks for the PR, @zjureel . I think it is a valid improvement. Regarding the implementation, I think we can simply introduce a config option "jobstore.flush-to-disk" to

[jira] [Created] (FLINK-25697) Support HTTPS for Prometheus Push Gateway

2022-01-18 Thread Mason Chen (Jira)
Mason Chen created FLINK-25697: -- Summary: Support HTTPS for Prometheus Push Gateway Key: FLINK-25697 URL: https://issues.apache.org/jira/browse/FLINK-25697 Project: Flink Issue Type:

[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-18 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 2dbb1737df0af1db911cf2b2a449016395991bd1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * a65b12ce87fe15a5474b0a740e9a054e7685941d 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-18 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 2dbb1737df0af1db911cf2b2a449016395991bd1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * a65b12ce87fe15a5474b0a740e9a054e7685941d Azure:

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2022-01-18 Thread GitBox
ruanhang1993 commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r787369372 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestUtils.java ## @@

[jira] [Updated] (FLINK-25684) Support enhanced show databases syntax

2022-01-18 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moses updated FLINK-25684: -- Description: Enhanced `show databases` statement like ` show databasesfrom like 'db%' ` has been supported

[jira] [Created] (FLINK-25696) Introduce MetadataPublisher interface to SinkWriter

2022-01-18 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-25696: Summary: Introduce MetadataPublisher interface to SinkWriter Key: FLINK-25696 URL: https://issues.apache.org/jira/browse/FLINK-25696 Project: Flink Issue

[GitHub] [flink] wanglijie95 commented on pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
wanglijie95 commented on pull request #18102: URL: https://github.com/apache/flink/pull/18102#issuecomment-1016104566 @zhuzhurk Thanks for review. I've addressed all the comments , please help to review it again. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18102: URL: https://github.com/apache/flink/pull/18102#issuecomment-993332110 ## CI report: * 6ca8ad8ab7817ed28cf8619b36d7a8a21f1db987 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18102: URL: https://github.com/apache/flink/pull/18102#issuecomment-993332110 ## CI report: * 6ca8ad8ab7817ed28cf8619b36d7a8a21f1db987 Azure:

[GitHub] [flink] wsry commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

2022-01-18 Thread GitBox
wsry commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1016097587 I will help to merge after all tests pass. -- 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 #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #17720: URL: https://github.com/apache/flink/pull/17720#issuecomment-963141306 ## CI report: * Unknown: [CANCELED](TBD) * cec9ccbee64a29f43eb24f42dfd8db48e0d9e08a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #17720: URL: https://github.com/apache/flink/pull/17720#issuecomment-963141306 ## CI report: * Unknown: [CANCELED](TBD) * cec9ccbee64a29f43eb24f42dfd8db48e0d9e08a UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] ljz2051 commented on pull request #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

2022-01-18 Thread GitBox
ljz2051 commented on pull request #17720: URL: https://github.com/apache/flink/pull/17720#issuecomment-1016075421 @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] wanglijie95 commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
wanglijie95 commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r787338920 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/RegionPartitionGroupReleaseStrategy.java

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2022-01-18 Thread GitBox
ruanhang1993 commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r787338430 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java

[GitHub] [flink] wanglijie95 commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
wanglijie95 commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r787337783 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -159,50 +162,79 @@ public

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Priority: Critical (was: Major) > TemporalJoin cause state leak in some cases >

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Priority: Major (was: Critical) > TemporalJoin cause state leak in some cases >

[GitHub] [flink] wanglijie95 commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
wanglijie95 commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r787335458 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultResultPartition.java ## @@ -54,16 +55,32 @@

[GitHub] [flink] wanglijie95 commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
wanglijie95 commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r787335115 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultResultPartition.java ## @@ -28,12 +28,13 @@ import

[GitHub] [flink] wanglijie95 commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

2022-01-18 Thread GitBox
wanglijie95 commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r787334289 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -59,8 +59,10 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure:

[GitHub] [flink] flinkbot commented on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

2022-01-18 Thread GitBox
flinkbot commented on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

2022-01-18 Thread GitBox
flinkbot commented on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057431 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-25198) add document about how to debug with the name and description

2022-01-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25198: --- Labels: pull-request-available (was: ) > add document about how to debug with the name and

[GitHub] [flink] wenlong88 opened a new pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

2022-01-18 Thread GitBox
wenlong88 opened a new pull request #18400: URL: https://github.com/apache/flink/pull/18400 ## What is the purpose of the change this is part of This PR is part of

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

2022-01-18 Thread GitBox
Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r787321825 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/SharedStateRegistryTest.java ## @@ -98,6 +106,77 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #17720: URL: https://github.com/apache/flink/pull/17720#issuecomment-963141306 ## CI report: * 0c8d9c69ed2cf13ebdb1dfb6e0b44ca31ad4e706 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18399: [FLINK-25118][streaming] Add vertex topology index prefix in vertex name

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18399: URL: https://github.com/apache/flink/pull/18399#issuecomment-1016036536 ## CI report: * 1b59e0775a0fc8288e915036f8ba7a658069881d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[jira] [Closed] (FLINK-25494) Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources

2022-01-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-25494. Resolution: Invalid > Duplicate element serializer during >

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail:

[GitHub] [flink] Myasuka commented on a change in pull request #18387: [FLINK-25494][state] Duplicate element serializer during operator state sync snapshot phase

2022-01-18 Thread GitBox
Myasuka commented on a change in pull request #18387: URL: https://github.com/apache/flink/pull/18387#discussion_r787316200 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/PartitionableListState.java ## @@ -45,23 +47,25 @@ private final

[GitHub] [flink] Myasuka closed pull request #18387: [FLINK-25494][state] Duplicate element serializer during operator state sync snapshot phase

2022-01-18 Thread GitBox
Myasuka closed pull request #18387: URL: https://github.com/apache/flink/pull/18387 -- 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-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail:

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25695: --- Labels: pull-request-available (was: ) > TemporalJoin cause state leak in some cases >

[GitHub] [flink] flinkbot commented on pull request #18399: [FLINK-25118][streaming] Add vertex topology index prefix in vertex name

2022-01-18 Thread GitBox
flinkbot commented on pull request #18399: URL: https://github.com/apache/flink/pull/18399#issuecomment-1016036536 ## CI report: * 1b59e0775a0fc8288e915036f8ba7a658069881d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

2022-01-18 Thread GitBox
flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

  1   2   3   4   5   6   >