[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468415#comment-17468415 ] liwei li commented on FLINK-25421: -- I'm interested in this. May I have this ticket? > Port JDBC Sink

[jira] [Commented] (FLINK-25484) TableRollingPolicy do not support inactivityInterval config which is supported in datastream api

[ https://issues.apache.org/jira/browse/FLINK-25484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468414#comment-17468414 ] Fabian Paul commented on FLINK-25484: - [~lichang] do you want to work on this? > TableRollingPolicy

[GitHub] [flink] LadyForest commented on pull request #18236: [FLINK-25176][table] Introduce "ALTER TABLE ... COMPACT" syntax

LadyForest commented on pull request #18236: URL: https://github.com/apache/flink/pull/18236#issuecomment-1004593235 Hi @JingsongLi, I've addressed your comments. Would you mind taking another look? -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-25261) Changelog not truncated on materialization

[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468413#comment-17468413 ] Yuan Mei commented on FLINK-25261: -- Upon offline discussion, there are two more questions/problems

[GitHub] [flink] hililiwei commented on pull request #17612: [FLINK-24247][TableAPI/SQL] Uniformly limit the value of ABS(offset) …

hililiwei commented on pull request #17612: URL: https://github.com/apache/flink/pull/17612#issuecomment-1004592706 > Thanks for the PR. @hililiwei It looks good on the whole. Maybe we should add some revevant test or ITest cases for coverage on the change. Please let me know what's your

[GitHub] [flink] flinkbot edited a comment on pull request #18173: [FLINK-25407][network] Fix the issues caused by FLINK-24035

flinkbot edited a comment on pull request #18173: URL: https://github.com/apache/flink/pull/18173#issuecomment-999423914 ## CI report: * 7efa7f2b51b85110e69aaaeb665b6b61362bc92a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

flinkbot edited a comment on pull request #17765: URL: https://github.com/apache/flink/pull/17765#issuecomment-966280320 ## CI report: * ca72f9e9bd95ad8a5368089d7bc0367256339b8b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure:

[GitHub] [flink] hililiwei commented on a change in pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

hililiwei commented on a change in pull request #17765: URL: https://github.com/apache/flink/pull/17765#discussion_r777878246 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java ## @@ -355,6

[GitHub] [flink] gaoyunhaii commented on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

gaoyunhaii commented on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-1004586722 I will merge after the azure get green -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure:

[jira] [Commented] (FLINK-25507) ElasticsearchWriterITCase#testWriteOnBulkFlush test failed

[ https://issues.apache.org/jira/browse/FLINK-25507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468408#comment-17468408 ] Martijn Visser commented on FLINK-25507: CC [~alexanderpreuss] >

[GitHub] [flink] flinkbot edited a comment on pull request #18253: FLINK-24900

flinkbot edited a comment on pull request #18253: URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117 ## CI report: * 66f768ea5217495183e172cc03baf3597de7cf47 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * 6edd01b3572d27fc1b1d9fd80a0330ae3386026a Azure:

[jira] [Commented] (FLINK-25508) Flink Batch mode, cluster shutdown early.

[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468407#comment-17468407 ] Martijn Visser commented on FLINK-25508: [~todd5167] I think this question is better suited to

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

flinkbot edited a comment on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1002929103 ## CI report: * de39b113cf71271b2e852e89cba70d361db0be92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18253: FLINK-24900

flinkbot edited a comment on pull request #18253: URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117 ## CI report: * 66f768ea5217495183e172cc03baf3597de7cf47 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][hive] Fix typo in name for HiveParserQBSubQuery.java

flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 84bed62ead87da8df67cb89fba4d9e5029cba40f Azure:

[jira] [Updated] (FLINK-25509) FLIP-208: Update KafkaSource to detect EOF based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25509: --- Component/s: Connectors / Common Connectors / Kafka > FLIP-208: Update

[jira] [Updated] (FLINK-25509) FLIP-208: Update KafkaSource to detect EOF based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25509: --- Issue Type: New Feature (was: Improvement) > FLIP-208: Update KafkaSource to detect EOF

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure:

[jira] [Closed] (FLINK-25473) Azure pipeline failed due to stopped hearing from agent Azure Pipelines 11

[ https://issues.apache.org/jira/browse/FLINK-25473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25473. --- Resolution: Duplicate > Azure pipeline failed due to stopped hearing from agent Azure Pipelines 11 >

[jira] [Commented] (FLINK-25473) Azure pipeline failed due to stopped hearing from agent Azure Pipelines 11

[ https://issues.apache.org/jira/browse/FLINK-25473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468402#comment-17468402 ] Yun Gao commented on FLINK-25473: - Yes, currently it seems this issue should be related to the  

[jira] [Commented] (FLINK-25510) Add test cases for KafkaPartitionSplitReader

[ https://issues.apache.org/jira/browse/FLINK-25510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468401#comment-17468401 ] Martijn Visser commented on FLINK-25510: [~Ashulin] I've assigned it to you (CC [~fpaul]) > Add

[jira] [Assigned] (FLINK-25510) Add test cases for KafkaPartitionSplitReader

[ https://issues.apache.org/jira/browse/FLINK-25510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25510: -- Assignee: Zongwen Li > Add test cases for KafkaPartitionSplitReader >

[GitHub] [flink] flinkbot edited a comment on pull request #18172: [hotfix][docs] Fix incorrect Python tableEnvironment attribute reference

flinkbot edited a comment on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-999323746 ## CI report: * ff52a985d72be2eb1a375394d730499364e73d6d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure:

[GitHub] [flink] hapihu commented on a change in pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

hapihu commented on a change in pull request #16889: URL: https://github.com/apache/flink/pull/16889#discussion_r777870323 ## File path: docs/content.zh/docs/dev/datastream/operators/overview.md ## @@ -24,18 +24,21 @@ specific language governing permissions and limitations

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7a72e223401279fa7b5b023ff03b78e1a21ed3ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure:

[GitHub] [flink-web] gaoyunhaii commented on pull request #493: Add flink-ml 2.0.0

gaoyunhaii commented on pull request #493: URL: https://github.com/apache/flink-web/pull/493#issuecomment-1004578968 Very thanks @tillrohrmann for the review! I add the rebuild commit now~ -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Closed] (FLINK-9966) Add a ORC table factory

[ https://issues.apache.org/jira/browse/FLINK-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-9966. - Resolution: Fixed > Add a ORC table factory > --- > > Key:

[GitHub] [flink] flinkbot edited a comment on pull request #18260: [DO NOT MERGE] Trigger the CI for FLINK-25085

flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * ddb6ceb16475ab704502fd6803b47872a33e91e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

flinkbot edited a comment on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1002929103 ## CI report: * de301309ab7fab5aa23807025116e88d778b256e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18225: [hotfix] [javadocs] Fix typo in org.apache.flink.sql.parser.ddl.SqlCreateTable

flinkbot edited a comment on pull request #18225: URL: https://github.com/apache/flink/pull/18225#issuecomment-1002403111 ## CI report: * 03b3834c5d1760b2039960d21439bc3154255d13 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7a72e223401279fa7b5b023ff03b78e1a21ed3ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

flinkbot edited a comment on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1002929103 ## CI report: * de301309ab7fab5aa23807025116e88d778b256e Azure:

[GitHub] [flink-web] gaoyunhaii commented on a change in pull request #493: Add flink-ml 2.0.0

gaoyunhaii commented on a change in pull request #493: URL: https://github.com/apache/flink-web/pull/493#discussion_r777866138 ## File path: downloads.md ## @@ -200,6 +200,24 @@ You can add the following dependencies to your `pom.xml` to include Apache Flink The

[jira] [Created] (FLINK-25510) Add test cases for KafkaPartitionSplitReader

Zongwen Li created FLINK-25510: -- Summary: Add test cases for KafkaPartitionSplitReader Key: FLINK-25510 URL: https://issues.apache.org/jira/browse/FLINK-25510 Project: Flink Issue Type:

[GitHub] [flink-web] gaoyunhaii commented on a change in pull request #493: Add flink-ml 2.0.0

gaoyunhaii commented on a change in pull request #493: URL: https://github.com/apache/flink-web/pull/493#discussion_r777864691 ## File path: _config.yml ## @@ -23,6 +23,12 @@ FLINK_STATEFUN_STABLE_SHORT: "3.1" FLINK_STATEFUN_GITHUB_URL:

[jira] [Updated] (FLINK-25509) FLIP-208: Update KafkaSource to detect EOF based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-25509: - Description: Please checkout

[jira] [Updated] (FLINK-25509) FLIP-208: Update KafkaSource to detect EOF based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-25509: - Issue Type: Improvement (was: Bug) > FLIP-208: Update KafkaSource to detect EOF based on de-serialized

[jira] [Created] (FLINK-25509) FLIP-208: Update KafkaSource to detect EOF based on de-serialized records

Dong Lin created FLINK-25509: Summary: FLIP-208: Update KafkaSource to detect EOF based on de-serialized records Key: FLINK-25509 URL: https://issues.apache.org/jira/browse/FLINK-25509 Project: Flink

[jira] [Commented] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468394#comment-17468394 ] Yingjie Cao commented on FLINK-25441: - I guess for batch jobs, we should not throw

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

ruanhang1993 commented on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-1004565845 @fapaul Could you help to review this PR? By the way, please assign this ticket to me in the JIRA. -- This is an automated message from the Apache Git Service. To

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

flinkbot edited a comment on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080 ## CI report: * 0971f71de77ac86a0857d69ba6c367f4b5e7b006 Azure:

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468387#comment-17468387 ] Yao Zhang commented on FLINK-25471: --- Hi [~zhangzihan] , I reproduced this issue with Flink 1.14.2. I

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[jira] [Commented] (FLINK-25507) ElasticsearchWriterITCase#testWriteOnBulkFlush test failed

[ https://issues.apache.org/jira/browse/FLINK-25507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468382#comment-17468382 ] Yuhao Bi commented on FLINK-25507: -- This test case requires a docker environment and also a stable

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] liyubin117 commented on pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database

liyubin117 commented on pull request #18146: URL: https://github.com/apache/flink/pull/18146#issuecomment-1004559229 @Airblader Is there anything else to do with this? please have a look, Thanks! -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] ashulin closed pull request #18256: [FLINK-25503][Connectors / Kafka] The group-offset startup mode allows to set the "auto.offset.reset" properties

ashulin closed pull request #18256: URL: https://github.com/apache/flink/pull/18256 -- 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] ashulin commented on pull request #18256: [FLINK-25503][Connectors / Kafka] The group-offset startup mode allows to set the "auto.offset.reset" properties

ashulin commented on pull request #18256: URL: https://github.com/apache/flink/pull/18256#issuecomment-1004556166 Since this is a duplicate issue, I'll close this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Closed] (FLINK-25503) KafkaDynamicSource: can't use group-offsets startup mode directly

[ https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zongwen Li closed FLINK-25503. -- Resolution: Duplicate > KafkaDynamicSource: can't use group-offsets startup mode directly >

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[jira] [Commented] (FLINK-25503) KafkaDynamicSource: can't use group-offsets startup mode directly

[ https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468379#comment-17468379 ] Zongwen Li commented on FLINK-25503: [~ruanhang1993] Thanks for reminding, I will close this ISSUE

[jira] [Comment Edited] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:13 AM: Hi [~pnowojski]

[jira] [Comment Edited] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:13 AM: Hi [~pnowojski]

[GitHub] [flink] flinkbot edited a comment on pull request #18260: [DO NOT MERGE] Trigger the CI for FLINK-25085

flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * ddb6ceb16475ab704502fd6803b47872a33e91e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[jira] [Comment Edited] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:11 AM: Hi [~pnowojski]

[jira] [Comment Edited] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:09 AM: Hi [~pnowojski]

[GitHub] [flink] flinkbot edited a comment on pull request #18260: [DO NOT MERGE] Trigger the CI for FLINK-25085

flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * ddb6ceb16475ab704502fd6803b47872a33e91e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[jira] [Comment Edited] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:04 AM: Hi [~pnowojski]

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[jira] [Comment Edited] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:03 AM: Hi [~pnowojski]

[jira] (FLINK-25503) KafkaDynamicSource: can't use group-offsets startup mode directly

[ https://issues.apache.org/jira/browse/FLINK-25503 ] Hang Ruan deleted comment on FLINK-25503: --- was (Author: ruanhang1993): it's a duplicate of https://issues.apache.org/jira/browse/FLINK-24697. Maybe you can help to review it? Thanks ~ >

[jira] [Commented] (FLINK-25503) KafkaDynamicSource: can't use group-offsets startup mode directly

[ https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468376#comment-17468376 ] Hang Ruan commented on FLINK-25503: --- it's a duplicate of

[jira] [Commented] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468375#comment-17468375 ] chenqizhu commented on FLINK-25296: --- Hi [~pnowojski] You are right. i mean adding

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[jira] [Updated] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenqizhu updated FLINK-25296: -- Description: The configration is valid only when I add -Dstate.checkpoints.num-retained=n via

[jira] [Updated] (FLINK-25296) [state.checkpoints.num-retained ]The default value does not take effect

[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenqizhu updated FLINK-25296: -- Description: The configration is valid only when I add -Dstate.checkpoints.num-retained=n via

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1004544574 @tillrohrmann Thanks for your review. Reworked again. I introduce the class of `YarnClusterClientProvider` and `ApplicationReportProviderImpl` to avoid too many anonymous

[GitHub] [flink] flinkbot edited a comment on pull request #18253: FLINK-24900

flinkbot edited a comment on pull request #18253: URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117 ## CI report: * 66f768ea5217495183e172cc03baf3597de7cf47 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

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

jelly-1203 commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-1004543740 Hi,@wenlong88 could you please ping @godfreyhe again? There is no progress on this issue -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r777839182 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1195,9 +1184,22 @@ private ApplicationReport

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r777838682 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java ## @@ -133,6 +140,38 @@ public void testPerJobWithArchive() throws

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r777837645 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/AsyncClusterClientProvider.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r777837406 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnAsyncClusterClientProviderFactory.java ## @@ -0,0 +1,49 @@ +/* + * Licensed to the

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r777837339 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1195,9 +1184,22 @@ private ApplicationReport

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r777837238 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1240,8 +1247,17 @@ private ApplicationReport

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r777836101 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/AsyncClusterClientProvider.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #18259: [hotfix][javadoc] Minor correction to javadoc

flinkbot edited a comment on pull request #18259: URL: https://github.com/apache/flink/pull/18259#issuecomment-1004447591 ## CI report: * 50700e3d25e2358c09eca9e4692fe1b2db8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][hive] Fix typo in name for HiveParserQBSubQuery.java

flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 14c76d43a6711ce906f6f03a9e0e93afca9d871a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][hive] Fix typo in name for HiveParserQBSubQuery.java

flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 14c76d43a6711ce906f6f03a9e0e93afca9d871a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][hive] Fix typo in name for HiveParserQBSubQuery.java

flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 14c76d43a6711ce906f6f03a9e0e93afca9d871a Azure:

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

flinkbot edited a comment on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080 ## CI report: * bf622cc8bec7b7d00a94bb48ff09cbe8e93c23df Azure:

  1   2   3   4   5   >