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

2022-01-03 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468415#comment-17468415 ] liwei li commented on FLINK-25421: -- I'm interested in this. May I have this ticket? >

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

2022-01-03 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468414#comment-17468414 ] Fabian Paul commented on FLINK-25484: - [~lichang] do you want to work on this? > Ta

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

2022-01-03 Thread GitBox
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

2022-01-03 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468413#comment-17468413 ] Yuan Mei commented on FLINK-25261: -- Upon offline discussion, there are two more questio

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

2022-01-03 Thread GitBox
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 o

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18173: URL: https://github.com/apache/flink/pull/18173#issuecomment-999423914 ## CI report: * 7efa7f2b51b85110e69aaaeb665b6b61362bc92a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #17765: URL: https://github.com/apache/flink/pull/17765#issuecomment-966280320 ## CI report: * ca72f9e9bd95ad8a5368089d7bc0367256339b8b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

2022-01-03 Thread GitBox
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

2022-01-03 Thread GitBox
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 above

[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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

2022-01-03 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468408#comment-17468408 ] Martijn Visser commented on FLINK-25507: CC [~alexanderpreuss] > ElasticsearchW

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18253: URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117 ## CI report: * 66f768ea5217495183e172cc03baf3597de7cf47 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * 6edd01b3572d27fc1b1d9fd80a0330ae3386026a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468407#comment-17468407 ] Martijn Visser commented on FLINK-25508: [~todd5167] I think this question is be

[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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1002929103 ## CI report: * de39b113cf71271b2e852e89cba70d361db0be92 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18253: URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117 ## CI report: * 66f768ea5217495183e172cc03baf3597de7cf47 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 84bed62ead87da8df67cb89fba4d9e5029cba40f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread Martijn Visser (Jira)
[ 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 Kafk

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

2022-01-03 Thread Martijn Visser (Jira)
[ 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 bas

[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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

2022-01-03 Thread Yun Gao (Jira)
[ 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

2022-01-03 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468402#comment-17468402 ] Yun Gao commented on FLINK-25473: - Yes, currently it seems this issue should be related

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

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

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

2022-01-03 Thread Martijn Visser (Jira)
[ 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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-999323746 ## CI report: * ff52a985d72be2eb1a375394d730499364e73d6d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[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

2022-01-03 Thread GitBox
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 und

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7a72e223401279fa7b5b023ff03b78e1a21ed3ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

2022-01-03 Thread GitBox
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 o

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

2022-01-03 Thread Martijn Visser (Jira)
[ 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: FL

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * ddb6ceb16475ab704502fd6803b47872a33e91e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1002929103 ## CI report: * de301309ab7fab5aa23807025116e88d778b256e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18225: URL: https://github.com/apache/flink/pull/18225#issuecomment-1002403111 ## CI report: * 03b3834c5d1760b2039960d21439bc3154255d13 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7a72e223401279fa7b5b023ff03b78e1a21ed3ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * bc10ad566ca7f6de7e02a54e787f396005fe UNKNOWN * 3cd820e18ba771ce3e1bd9a06c2312409e34a463 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18246: URL: https://github.com/apache/flink/pull/18246#issuecomment-1002929103 ## CI report: * de301309ab7fab5aa23807025116e88d778b256e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
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 `statefun-sdk

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

2022-01-03 Thread Zongwen Li (Jira)
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: Improvem

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

2022-01-03 Thread GitBox
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: https://github.com/apache/flink-statefun

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

2022-01-03 Thread Dong Lin (Jira)
[ 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 https://cwiki.apache.org/confluence/display/FLINK/FLIP-208%3A+Update+KafkaS

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

2022-01-03 Thread Dong Lin (Jira)
[ 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

2022-01-03 Thread Dong Lin (Jira)
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.

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

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

2022-01-03 Thread GitBox
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 resp

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080 ## CI report: * 0971f71de77ac86a0857d69ba6c367f4b5e7b006 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468387#comment-17468387 ] Yao Zhang commented on FLINK-25471: --- Hi [~zhangzihan] , I reproduced this issue with

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread Yuhao Bi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468382#comment-17468382 ] Yuhao Bi commented on FLINK-25507: -- This test case requires a docker environment and al

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
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, plea

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
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: issues-unsubsc

[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

2022-01-03 Thread GitBox
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 th

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

2022-01-03 Thread Zongwen Li (Jira)
[ 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 …

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread Zongwen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468379#comment-17468379 ] Zongwen Li commented on FLINK-25503: [~ruanhang1993] Thanks for reminding, I will cl

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

2022-01-03 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:13 AM:

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

2022-01-03 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:13 AM:

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * ddb6ceb16475ab704502fd6803b47872a33e91e1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:11 AM:

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

2022-01-03 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:09 AM:

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18260: URL: https://github.com/apache/flink/pull/18260#issuecomment-1004487229 ## CI report: * ddb6ceb16475ab704502fd6803b47872a33e91e1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:04 AM:

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468375#comment-17468375 ] chenqizhu edited comment on FLINK-25296 at 1/4/22, 6:03 AM:

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

2022-01-03 Thread Hang Ruan (Jira)
[ 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 ~ > Kafk

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

2022-01-03 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468376#comment-17468376 ] Hang Ruan commented on FLINK-25503: --- it's a duplicate of https://issues.apache.org/jir

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

2022-01-03 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468375#comment-17468375 ] chenqizhu commented on FLINK-25296: --- Hi [~pnowojski] You are right. i mean adding -Dst

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread chenqizhu (Jira)
[ 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 command

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

2022-01-03 Thread chenqizhu (Jira)
[ 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 command

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

2022-01-03 Thread GitBox
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 clas

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18253: URL: https://github.com/apache/flink/pull/18253#issuecomment-1003855117 ## CI report: * 66f768ea5217495183e172cc03baf3597de7cf47 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
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 me

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

2022-01-03 Thread GitBox
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 startAppMaster

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

2022-01-03 Thread GitBox
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 Excep

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
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 Apac

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

2022-01-03 Thread GitBox
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 Apache

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

2022-01-03 Thread GitBox
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 startAppMaster

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
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 startAppMaster

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
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 Apac

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18259: URL: https://github.com/apache/flink/pull/18259#issuecomment-1004447591 ## CI report: * 50700e3d25e2358c09eca9e4692fe1b2db8f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 14c76d43a6711ce906f6f03a9e0e93afca9d871a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 14c76d43a6711ce906f6f03a9e0e93afca9d871a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002437326 ## CI report: * 14c76d43a6711ce906f6f03a9e0e93afca9d871a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-03 Thread GitBox
flinkbot edited a comment on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080 ## CI report: * bf622cc8bec7b7d00a94bb48ff09cbe8e93c23df Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

  1   2   3   4   5   >