[GitHub] [flink] flinkbot edited a comment on pull request #18319: [FLINK-25531][connectors/kafka] Force immediate shutdown of FlinkInternalKafkaProducer to speed up testRetryComittableOnRetriableErro

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18319: URL: https://github.com/apache/flink/pull/18319#issuecomment-1008898822 ## CI report: * eb853c67af624764b4e5c0c3fce054a7fdedbf0e Azure:

[jira] [Resolved] (FLINK-25266) StreamingKafkaITCase fails with incorrect number of messages

2022-01-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-25266. - Resolution: Fixed > StreamingKafkaITCase fails with incorrect number of messages >

[jira] [Commented] (FLINK-25266) StreamingKafkaITCase fails with incorrect number of messages

2022-01-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472530#comment-17472530 ] Fabian Paul commented on FLINK-25266: - Merged in master: 0bc2234b60d1a0635e238d18990695943158123c >

[GitHub] [flink] fapaul merged pull request #18105: [FLINK-25266][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

2022-01-10 Thread GitBox
fapaul merged pull request #18105: URL: https://github.com/apache/flink/pull/18105 -- 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] [Closed] (FLINK-25603) make the BlobServer use aws s3

2022-01-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25603. -- Resolution: Duplicate > make the BlobServer use aws s3 > -- > >

[jira] [Commented] (FLINK-25584) Azure failed on install node and npm for Flink : Runtime web

2022-01-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472528#comment-17472528 ] Till Rohrmann commented on FLINK-25584: --- cc [~MartijnVisser], [~chesnay] > Azure failed on

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

2022-01-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472526#comment-17472526 ] Martijn Visser commented on FLINK-24456: [~monster#12] What do you think is the status of this

[GitHub] [flink] flinkbot edited a comment on pull request #18323: [FLINK-25601][state backends][config] Update the 'state.backend' option

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18323: URL: https://github.com/apache/flink/pull/18323#issuecomment-1009676741 ## CI report: * 78bd79178543b399f726115f3ea73ff394e37902 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18320: [FLINK-25427] Decreased number of tests

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * cff02a6f62345d451348c8a9646850126f88d3b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18319: [FLINK-25531][connectors/kafka] Force immediate shutdown of FlinkInternalKafkaProducer to speed up testRetryComittableOnRetriableErro

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18319: URL: https://github.com/apache/flink/pull/18319#issuecomment-1008898822 ## CI report: * eb853c67af624764b4e5c0c3fce054a7fdedbf0e Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

2022-01-10 Thread GitBox
zhuzhurk commented on a change in pull request #18126: URL: https://github.com/apache/flink/pull/18126#discussion_r781817552 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/StagewiseSchedulingStrategy.java ## @@ -0,0 +1,156 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #18323: [FLINK-25601][state backends][config] Update the 'state.backend' option

2022-01-10 Thread GitBox
flinkbot commented on pull request #18323: URL: https://github.com/apache/flink/pull/18323#issuecomment-1009676741 ## CI report: * 78bd79178543b399f726115f3ea73ff394e37902 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18320: [FLINK-25427] Decreased number of tests

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * cff02a6f62345d451348c8a9646850126f88d3b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18050: URL: https://github.com/apache/flink/pull/18050#issuecomment-988466514 ## CI report: * e2e89c176f1e20f3583e6bdc850a0c31251cf988 Azure:

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2022-01-10 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472520#comment-17472520 ] Qingsheng Ren commented on FLINK-23391: --- I'm making a refactor for the Kafka test infra with

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2022-01-10 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472517#comment-17472517 ] Qingsheng Ren commented on FLINK-23391: --- [~trohrmann] I'm making a refactor for the Kafka test

[GitHub] [flink] flinkbot commented on pull request #18323: [FLINK-25601][state backends][config] Update the 'state.backend' option

2022-01-10 Thread GitBox
flinkbot commented on pull request #18323: URL: https://github.com/apache/flink/pull/18323#issuecomment-1009673644 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-23946) Application mode fails fatally when being shut down

2022-01-10 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472513#comment-17472513 ] Konstantin Knauf commented on FLINK-23946: -- [~dmvk] This is only missing backports to 1.13 and

[jira] [Commented] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

2022-01-10 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472511#comment-17472511 ] Anton Kalashnikov commented on FLINK-25427: --- [~trohrmann], yes, I have a little progress. I

[GitHub] [flink] flinkbot edited a comment on pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18050: URL: https://github.com/apache/flink/pull/18050#issuecomment-988466514 ## CI report: * e2e89c176f1e20f3583e6bdc850a0c31251cf988 Azure:

[jira] [Updated] (FLINK-25601) Update 'state.backend' in flink-conf.yaml

2022-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25601: --- Labels: pull-request-available (was: ) > Update 'state.backend' in flink-conf.yaml >

[GitHub] [flink] deadwind4 opened a new pull request #18323: [FLINK-25601][state backends][config] Update the 'state.backend' option

2022-01-10 Thread GitBox
deadwind4 opened a new pull request #18323: URL: https://github.com/apache/flink/pull/18323 ## What is the purpose of the change The value and comments of 'state.backend' in flink-conf.yaml is deprecated. ## Brief change log - *Change the 'state.backend' option to new

[jira] [Assigned] (FLINK-25604) Remove useless aggregate function

2022-01-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25604: -- Assignee: godfrey he > Remove useless aggregate function >

[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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * fe76d7d6e608811708815b939b83b5daff9049d1 Azure:

[jira] [Comment Edited] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

2022-01-10 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472136#comment-17472136 ] Etienne Chauchot edited comment on FLINK-23843 at 1/11/22, 7:28 AM:

[jira] [Comment Edited] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

2022-01-10 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472136#comment-17472136 ] Etienne Chauchot edited comment on FLINK-23843 at 1/11/22, 7:28 AM:

[jira] [Commented] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

2022-01-10 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472506#comment-17472506 ] Etienne Chauchot commented on FLINK-23843: -- [~trohrmann] [~sewen] [~chesnay] WDYT? >

[jira] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

2022-01-10 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23843 ] Etienne Chauchot deleted comment on FLINK-23843: -- was (Author: echauchot): [~trohrmann] [~sewen] [~chesnay] WDYT? > Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()"

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

2022-01-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472504#comment-17472504 ] Yang Wang commented on FLINK-25495: --- I agree that the per-job with attach mode also has such

[jira] [Updated] (FLINK-25593) A redundant scan could be skipped if it is an input of join and the other input is empty after partition prune

2022-01-10 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25593: --- Description: A redundant scan could be skipped if it is an input of join and the other input is

[jira] [Created] (FLINK-25604) Remove useless aggregate function

2022-01-10 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-25604: -- Summary: Remove useless aggregate function Key: FLINK-25604 URL: https://issues.apache.org/jira/browse/FLINK-25604 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18322: [FLINK-25589][docs][connectors] Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18322: URL: https://github.com/apache/flink/pull/18322#issuecomment-1009605866 ## CI report: * 310b62a595a1af2d091b6a0f2e8fc137460b92e7 Azure:

[jira] [Commented] (FLINK-25601) Update 'state.backend' in flink-conf.yaml

2022-01-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472503#comment-17472503 ] Yun Tang commented on FLINK-25601: -- [~ana4] Already assigned to you, please go ahead. > Update

[jira] [Assigned] (FLINK-25601) Update 'state.backend' in flink-conf.yaml

2022-01-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-25601: Assignee: Ada Wong > Update 'state.backend' in flink-conf.yaml >

[GitHub] [flink] flinkbot edited a comment on pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080 ## CI report: * d5dfa7d9c3bc5607e96b9ccfbeb6ce1a00bc13ca 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-10 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 493bad4a9158fd2e5e83b6a0eb416cc96633be05 Azure:

[jira] [Updated] (FLINK-24892) FLIP-187: Adaptive Batch Scheduler

2022-01-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-24892: Fix Version/s: 1.15.0 > FLIP-187: Adaptive Batch Scheduler > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #18320: [FLINK-25427] Decreased number of tests

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * cff02a6f62345d451348c8a9646850126f88d3b5 Azure:

[jira] [Updated] (FLINK-25584) Azure failed on install node and npm for Flink : Runtime web

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25584: Priority: Critical (was: Major) > Azure failed on install node and npm for Flink : Runtime web >

[jira] [Updated] (FLINK-25584) Azure failed on install node and npm for Flink : Runtime web

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25584: Affects Version/s: 1.14.2 > Azure failed on install node and npm for Flink : Runtime web >

[jira] [Updated] (FLINK-25498) FlinkKafkaProducerITCase. testRestoreToCheckpointAfterExceedingProducersPool failed on azure

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25498: Description: {code:java} 2021-12-31T08:14:15.9176809Z Dec 31 08:14:15 java.lang.AssertionError: Expected

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

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1007312371 ## CI report: * ac842b597501d4f7d53967fb3f12e5288ea65674 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 233d84facbe69347c2f66952024485c8a61492f4 Azure:

[jira] [Closed] (FLINK-25032) Allow to create execution vertices and execution edges lazily

2022-01-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-25032. --- Fix Version/s: 1.15.0 Resolution: Done master/1.15: d2bfe404e199f98115df419232399bcc11b59e5a

[GitHub] [flink] zhuzhurk closed pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

2022-01-10 Thread GitBox
zhuzhurk closed pull request #18023: URL: https://github.com/apache/flink/pull/18023 -- 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] gaoyunhaii commented on a change in pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
gaoyunhaii commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r781797292 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java ## @@ -0,0 +1,101 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18312: Update copyright year to 2022 for NOTICE files.

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18312: URL: https://github.com/apache/flink/pull/18312#issuecomment-1008686402 ## CI report: * 052f42bf3e600e915fc7ec97cdfe36686c07eca7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18312: Update copyright year to 2022 for NOTICE files.

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18312: URL: https://github.com/apache/flink/pull/18312#issuecomment-1008686402 ## CI report: * 47950aefbb787649083d9e6f496c6df9dd297169 Azure:

[jira] [Updated] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

2022-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25592: Priority: Major (was: Minor) > Improvement of parser, optimizer and execution for Flink Batch SQL >

[jira] [Updated] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

2022-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25592: Component/s: Table SQL / API Table SQL / Planner Table SQL / Runtime >

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

2022-01-10 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472489#comment-17472489 ] RocMarshal commented on FLINK-25420: [~MartijnVisser] IMO, It would be better if a new FLIP to do

[jira] [Commented] (FLINK-25584) Azure failed on install node and npm for Flink : Runtime web

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472486#comment-17472486 ] Yun Gao commented on FLINK-25584: -

[jira] [Created] (FLINK-25602) make the BlobServer use aws s3

2022-01-10 Thread lupan (Jira)
lupan created FLINK-25602: - Summary: make the BlobServer use aws s3 Key: FLINK-25602 URL: https://issues.apache.org/jira/browse/FLINK-25602 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-25603) make the BlobServer use aws s3

2022-01-10 Thread lupan (Jira)
lupan created FLINK-25603: - Summary: make the BlobServer use aws s3 Key: FLINK-25603 URL: https://issues.apache.org/jira/browse/FLINK-25603 Project: Flink Issue Type: Improvement

[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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

[GitHub] [flink] imaffe commented on a change in pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2022-01-10 Thread GitBox
imaffe commented on a change in pull request #17937: URL: https://github.com/apache/flink/pull/17937#discussion_r781787236 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java

[GitHub] [flink] flinkbot edited a comment on pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 48c44601bb0c15a3975d8ad41249231f06cbced2 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-10 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * f75205b826071098291c54e42f612d2954ed0f0f Azure:

[jira] [Commented] (FLINK-25209) SQLClientSchemaRegistryITCase#testReading is broken

2022-01-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472483#comment-17472483 ] Jingsong Lee commented on FLINK-25209: -- [~renqs] will take this. CC: [~dwysakowicz]   >

[jira] [Assigned] (FLINK-25209) SQLClientSchemaRegistryITCase#testReading is broken

2022-01-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25209: Assignee: Qingsheng Ren (was: Jingsong Lee) > SQLClientSchemaRegistryITCase#testReading

[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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 48c44601bb0c15a3975d8ad41249231f06cbced2 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-10 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * f75205b826071098291c54e42f612d2954ed0f0f Azure:

[GitHub] [flink] imaffe commented on a change in pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2022-01-10 Thread GitBox
imaffe commented on a change in pull request #17937: URL: https://github.com/apache/flink/pull/17937#discussion_r781784568 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java

[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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

[GitHub] [flink] imaffe commented on a change in pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2022-01-10 Thread GitBox
imaffe commented on a change in pull request #17937: URL: https://github.com/apache/flink/pull/17937#discussion_r781783619 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java

[GitHub] [flink] imaffe commented on a change in pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2022-01-10 Thread GitBox
imaffe commented on a change in pull request #17937: URL: https://github.com/apache/flink/pull/17937#discussion_r781783619 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java

[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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

[jira] [Commented] (FLINK-25209) SQLClientSchemaRegistryITCase#testReading is broken

2022-01-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472476#comment-17472476 ] Jingsong Lee commented on FLINK-25209: -- [~renqs] What do you think? Should we cherry-pick these

[GitHub] [flink] wenlong88 commented on pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

2022-01-10 Thread GitBox
wenlong88 commented on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1009625701 hi, @twalthr thanks for the review, I have update the pr addressing your comment and created FLINK-25600 as a following up subtask. It is almost done in my local repo

[jira] [Commented] (FLINK-25209) SQLClientSchemaRegistryITCase#testReading is broken

2022-01-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472475#comment-17472475 ] Jingsong Lee commented on FLINK-25209: -- Hi [~trohrmann]  I think this may be related to FLINK-22198

[GitHub] [flink] flinkbot edited a comment on pull request #18320: [FLINK-25427] Decreased number of tests

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * 621ef761cb61fb61f15b8d6a80cd7add7fd2d648 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18320: [FLINK-25427] Decreased number of tests

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * 621ef761cb61fb61f15b8d6a80cd7add7fd2d648 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

[GitHub] [flink] wenlong88 commented on a change in pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

2022-01-10 Thread GitBox
wenlong88 commented on a change in pull request #18215: URL: https://github.com/apache/flink/pull/18215#discussion_r781777506 ## File path:

[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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

[jira] [Updated] (FLINK-25589) Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread Yuhao Bi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuhao Bi updated FLINK-25589: - Attachment: en_datastream_elasticsearch.png en_table_elasticsearch.png

[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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

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

2022-01-10 Thread GitBox
zjureel commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1009612368 Thanks @KarmaGYZ , I have done it according to your advice and updated this PR -- This is an automated message from the Apache Git Service. To respond to the message, please

[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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 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-10 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * be139b8d4fbc8be2c6129e15d7cb77bcf58f66f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18322: [FLINK-25589][docs][connectors] Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18322: URL: https://github.com/apache/flink/pull/18322#issuecomment-1009605866 ## CI report: * 310b62a595a1af2d091b6a0f2e8fc137460b92e7 Azure:

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

2022-01-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472459#comment-17472459 ] Martijn Visser commented on FLINK-25374: [~trohrmann] The Alibaba CIs have stabilized a lot,

[GitHub] [flink] flinkbot commented on pull request #18322: [FLINK-25589][docs][connectors] Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread GitBox
flinkbot commented on pull request #18322: URL: https://github.com/apache/flink/pull/18322#issuecomment-1009605866 ## CI report: * 310b62a595a1af2d091b6a0f2e8fc137460b92e7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18322: [FLINK-25589][docs][connectors] Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread GitBox
flinkbot commented on pull request #18322: URL: https://github.com/apache/flink/pull/18322#issuecomment-1009604792 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-25589) Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25589: --- Labels: pull-request-available (was: ) > Update Chinese version of Elasticsearch connector

[GitHub] [flink] biyuhao opened a new pull request #18322: [FLINK-25589][docs][connectors] Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread GitBox
biyuhao opened a new pull request #18322: URL: https://github.com/apache/flink/pull/18322 ## What is the purpose of the change Update Chinese version document of Elasticsearch sink interface related to [FLINK-24326](https://issues.apache.org/jira/browse/FLINK-24326) (#17930)

[GitHub] [flink] flinkbot edited a comment on pull request #18037: [FLINK-25179] Add document for composite types support for parquet

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18037: URL: https://github.com/apache/flink/pull/18037#issuecomment-987689691 ## CI report: * 057e4a5a2b14921bea57d27b86fd9bc83b1df5ce Azure:

[jira] [Updated] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

2022-01-10 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-14998: - Fix Version/s: (was: 1.14.3) > Remove FileUtils#deletePathIfEmpty >

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

2022-01-10 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-13910: - Fix Version/s: (was: 1.14.3) > Many serializable classes have no explicit

[jira] [Updated] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

2022-01-10 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-13400: - Fix Version/s: (was: 1.14.3) > Remove Hive and Hadoop dependencies from SQL Client >

[GitHub] [flink] flinkbot edited a comment on pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080 ## CI report: * 5a46cd66a5392fa16690cd23a8978c5e3de3b380 Azure:

  1   2   3   4   5   6   >