[GitHub] [flink] Myasuka commented on a change in pull request #16183: [FLINK-22974][dist] Add execution checkpointing related configs in flink-conf.yaml

2021-06-20 Thread GitBox
Myasuka commented on a change in pull request #16183: URL: https://github.com/apache/flink/pull/16183#discussion_r655118982 ## File path: flink-dist/src/main/resources/flink-conf.yaml ## @@ -107,7 +107,18 @@ parallelism.default: 1 #=

[GitHub] [flink] Myasuka commented on a change in pull request #16183: [FLINK-22974][dist] Add execution checkpointing related configs in flink-conf.yaml

2021-06-20 Thread GitBox
Myasuka commented on a change in pull request #16183: URL: https://github.com/apache/flink/pull/16183#discussion_r655118982 ## File path: flink-dist/src/main/resources/flink-conf.yaml ## @@ -107,7 +107,18 @@ parallelism.default: 1 #=

[GitHub] [flink] cmick commented on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

2021-06-20 Thread GitBox
cmick commented on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-864777485 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific co

[GitHub] [flink] cmick removed a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

2021-06-20 Thread GitBox
cmick removed a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-864622842 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spe

[GitHub] [flink] Airblader commented on a change in pull request #16214: [FLINK-23040][table-common] Consider ConfigOption fallback keys in FactoryUtil

2021-06-20 Thread GitBox
Airblader commented on a change in pull request #16214: URL: https://github.com/apache/flink/pull/16214#discussion_r655109173 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java ## @@ -578,15 +621,27 @@ public void valid

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2021-06-20 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366411#comment-17366411 ] Ada Wong commented on FLINK-14902: -- [~michael ran] DataSource (HikariCP and Druid) is p

[jira] [Commented] (FLINK-23053) Translate "DataSet Transformations" pages into Chinese

2021-06-20 Thread Zhiliang Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366410#comment-17366410 ] Zhiliang Zhang commented on FLINK-23053: Hello,[~jark] , I found that this page

[GitHub] [flink] flinkbot edited a comment on pull request #16213: [FLINK-22788][table-planner-blink] Support equalisers for many fields

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16213: URL: https://github.com/apache/flink/pull/16213#issuecomment-864752975 ## CI report: * ee281e295dc81c541ceaca85c215fc81408886fe Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16211: [FLINK-16952][Connectors/Parquet] Parquet file format support filter push down.

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16211: URL: https://github.com/apache/flink/pull/16211#issuecomment-864689257 ## CI report: * 33aec918ba974f8c0a0ccfd4ed3ceb9a91a6fdb5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16179: [TESTING] Try to reproduce FLINK-22891

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16179: URL: https://github.com/apache/flink/pull/16179#issuecomment-863055916 ## CI report: * 7e7b0c0d820d70a132c4c2f78d955bb1693c0ff8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-21195) LimitableBulkFormat is invalid when format is orc

2021-06-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-21195. Fix Version/s: 1.14.0 Resolution: Fixed Fixed via: master: d8c19ba2e94648000c1fd463da350a4

[jira] [Updated] (FLINK-23053) Translate "DataSet Transformations" pages into Chinese

2021-06-20 Thread Zhiliang Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhiliang Zhang updated FLINK-23053: --- Labels: auto-unassigned (was: ) > Translate "DataSet Transformations" pages into Chinese >

[jira] [Updated] (FLINK-23053) Translate "DataSet Transformations" pages into Chinese

2021-06-20 Thread Zhiliang Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhiliang Zhang updated FLINK-23053: --- Component/s: Documentation > Translate "DataSet Transformations" pages into Chinese > --

[jira] [Updated] (FLINK-23053) Translate "DataSet Transformations" pages into Chinese

2021-06-20 Thread Zhiliang Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhiliang Zhang updated FLINK-23053: --- Component/s: (was: API / DataSet) chinese-translation > Translate "Data

[jira] [Updated] (FLINK-21195) LimitableBulkFormat is invalid when format is orc

2021-06-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-21195: - Priority: Major (was: Minor) > LimitableBulkFormat is invalid when format is orc >

[jira] [Created] (FLINK-23053) Translate "DataSet Transformations" pages into Chinese

2021-06-20 Thread Zhiliang Zhang (Jira)
Zhiliang Zhang created FLINK-23053: -- Summary: Translate "DataSet Transformations" pages into Chinese Key: FLINK-23053 URL: https://issues.apache.org/jira/browse/FLINK-23053 Project: Flink Is

[GitHub] [flink] JingsongLi merged pull request #16122: [FLINK-21195][Connectors/FileSystem]LimitableBulkFormat is invalid wh…

2021-06-20 Thread GitBox
JingsongLi merged pull request #16122: URL: https://github.com/apache/flink/pull/16122 -- 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. For queries about this service, ple

[GitHub] [flink] cshuo commented on pull request #16096: [FLINK-22901][table] Introduce getUpsertKeys in FlinkRelMetadataQuery

2021-06-20 Thread GitBox
cshuo commented on pull request #16096: URL: https://github.com/apache/flink/pull/16096#issuecomment-864768113 Looks good from my side. -- 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 specif

[GitHub] [flink] flinkbot commented on pull request #16214: [FLINK-23040][table-common] Consider ConfigOption fallback keys in FactoryUtil

2021-06-20 Thread GitBox
flinkbot commented on pull request #16214: URL: https://github.com/apache/flink/pull/16214#issuecomment-864767855 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 pro

[jira] [Updated] (FLINK-22993) CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId

2021-06-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22993: - Fix Version/s: 1.13.2 > CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpoin

[jira] [Closed] (FLINK-22993) CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId

2021-06-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22993. Resolution: Fixed Fixed via: master: 046d9b683e04c77671fe96e0a5fb20b31ed4436e release-1.13: d815

[GitHub] [flink] JingsongLi merged pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though the inputs

2021-06-20 Thread GitBox
JingsongLi merged pull request #16161: URL: https://github.com/apache/flink/pull/16161 -- 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. For queries about this service, ple

[jira] [Updated] (FLINK-23040) Consider ConfigOption fallback keys in FactoryUtil

2021-06-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23040: --- Labels: pull-request-available (was: ) > Consider ConfigOption fallback keys in FactoryUtil

[GitHub] [flink] twalthr opened a new pull request #16214: [FLINK-23040][table-common] Consider ConfigOption fallback keys in FactoryUtil

2021-06-20 Thread GitBox
twalthr opened a new pull request #16214: URL: https://github.com/apache/flink/pull/16214 ## What is the purpose of the change Adds support for fallback keys (incl. deprecated keys) to FactoryUtil. Deprecated keys are highlighted in error messages. ## Brief change log -

[GitHub] [flink] JingsongLi commented on a change in pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-06-20 Thread GitBox
JingsongLi commented on a change in pull request #16163: URL: https://github.com/apache/flink/pull/16163#discussion_r655092182 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/BridgingFunctionGenUtil.scala ## @@ -1

[GitHub] [flink] curcur removed a comment on pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

2021-06-20 Thread GitBox
curcur removed a comment on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-864750211 Mark: For recovery: Sync offline: did not see non-materialized part applied to the delegated state backend. Double confirm -- This is an automated message from

[GitHub] [flink] flinkbot commented on pull request #16213: [FLINK-22788][table-planner-blink] Support equalisers for many fields

2021-06-20 Thread GitBox
flinkbot commented on pull request #16213: URL: https://github.com/apache/flink/pull/16213#issuecomment-864752975 ## CI report: * ee281e295dc81c541ceaca85c215fc81408886fe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16179: [TESTING] Try to reproduce FLINK-22891

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16179: URL: https://github.com/apache/flink/pull/16179#issuecomment-863055916 ## CI report: * 7e7b0c0d820d70a132c4c2f78d955bb1693c0ff8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16141: [FLINK-22970][docs] The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16141: URL: https://github.com/apache/flink/pull/16141#issuecomment-859291183 ## CI report: * 07736d279cca52434c2f4ee87f508231eaa33e6c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur edited a comment on pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

2021-06-20 Thread GitBox
curcur edited a comment on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-864750211 Mark: For recovery: Sync offline: did not see non-materialized part applied to the delegated state backend. Double confirm -- This is an automated message from t

[GitHub] [flink] curcur edited a comment on pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

2021-06-20 Thread GitBox
curcur edited a comment on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-864750211 Mark: For recovery: Sync offline: did not see non-materialized part be applied to the delegated state backend. Double confirm -- This is an automated message fro

[GitHub] [flink] curcur commented on pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

2021-06-20 Thread GitBox
curcur commented on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-864750211 Mark: Sync offline: did not see non-materialized part be applied to the delegated state backend. Double confirm -- This is an automated message from the Apache Git Serv

[jira] [Issue Comment Deleted] (FLINK-16095) Translate "Modules" page of "Table API & SQL" into Chinese

2021-06-20 Thread zhangzhl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzhl updated FLINK-16095: - Comment: was deleted (was: hi [~jark] I'm willing to translate this page. Could you assign it to me ?:D

[jira] [Issue Comment Deleted] (FLINK-16152) Translate "Operator/index" into Chinese

2021-06-20 Thread zhangzhl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzhl updated FLINK-16152: - Comment: was deleted (was: hi,[~jark], I'm willing to translate this page. Could you assign it to me ?:

[jira] [Closed] (FLINK-17647) Improve new connector options exception in old planner

2021-06-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-17647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk closed FLINK-17647. - Resolution: Won't Do I'll take the liberty to close this issue since the legacy planner has been remove

[jira] [Issue Comment Deleted] (FLINK-17647) Improve new connector options exception in old planner

2021-06-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-17647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-17647: -- Comment: was deleted (was: I'll take the liberty to close this issue since the legacy planner has bee

[jira] [Commented] (FLINK-17647) Improve new connector options exception in old planner

2021-06-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-17647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366387#comment-17366387 ] Ingo Bürk commented on FLINK-17647: --- I'll take the liberty to close this issue since t

[GitHub] [flink] flinkbot edited a comment on pull request #16141: [FLINK-22970][docs] The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16141: URL: https://github.com/apache/flink/pull/16141#issuecomment-859291183 ## CI report: * 07736d279cca52434c2f4ee87f508231eaa33e6c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16213: [FLINK-22788][table-planner-blink] Support equalisers for many fields

2021-06-20 Thread GitBox
flinkbot commented on pull request #16213: URL: https://github.com/apache/flink/pull/16213#issuecomment-864743785 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 pro

[jira] [Updated] (FLINK-22788) Code of equals method grows beyond 64 KB

2021-06-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22788: --- Labels: pull-request-available (was: ) > Code of equals method grows beyond 64 KB > ---

[GitHub] [flink] Airblader opened a new pull request #16213: [FLINK-22788][table-planner-blink] Support equalisers for many fields

2021-06-20 Thread GitBox
Airblader opened a new pull request #16213: URL: https://github.com/apache/flink/pull/16213 ## What is the purpose of the change When working with hundreds of fields, equalisers can fail to compile because the method body grows beyond 64kb. With this change, instead of generatin

[jira] [Closed] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue

2021-06-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23042. Resolution: Fixed Subsumed by #16162 > Flink Chinese docs Fraud Detection with the DataStream API

[GitHub] [flink] xintongsong closed pull request #16212: [FLINK-23042][docs-zh] Correct docs-zh picture fraud-transactions.svg…

2021-06-20 Thread GitBox
xintongsong closed pull request #16212: URL: https://github.com/apache/flink/pull/16212 -- 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. For queries about this service, pl

[GitHub] [flink] xintongsong commented on pull request #16212: [FLINK-23042][docs-zh] Correct docs-zh picture fraud-transactions.svg…

2021-06-20 Thread GitBox
xintongsong commented on pull request #16212: URL: https://github.com/apache/flink/pull/16212#issuecomment-864740564 Hi @RollsBean, thanks for preparing the PR. It seems another contributor has also noticed the problem and fixed it a couple hours ago. So this PR is no longer necessar

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN * 3fbfde5408130b93d98979dc2fcc4fa10563

[GitHub] [flink] flinkbot edited a comment on pull request #16212: [FLINK-23042][docs-zh] Correct docs-zh picture fraud-transactions.svg…

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16212: URL: https://github.com/apache/flink/pull/16212#issuecomment-864708536 ## CI report: * 3177431ef14291ae912b37f27983049d48158a02 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16210: [FLINK-23044] fix typos in docs

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16210: URL: https://github.com/apache/flink/pull/16210#issuecomment-864682204 ## CI report: * ac28fa57c35305feb56c9825f360bc32d0547db9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN * 3fbfde5408130b93d98979dc2fcc4fa10563

[GitHub] [flink] flinkbot edited a comment on pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16161: URL: https://github.com/apache/flink/pull/16161#issuecomment-861259205 ## CI report: * 742e4e8c3622802e1dcf7cf5fb020a5bd656a40d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16148: [FLINK-22617][Hive]Add log for hive source that use native or mapred reader

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16148: URL: https://github.com/apache/flink/pull/16148#issuecomment-859467607 ## CI report: * 86e49e125d78c43cdc415f15ee7056ffd770da54 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Myasuka commented on pull request #15410: [FLINK-22008][runtime/checkpointing] add commit logic for checkpoint

2021-06-20 Thread GitBox
Myasuka commented on pull request #15410: URL: https://github.com/apache/flink/pull/15410#issuecomment-864713425 @zhougit86 Shall we close this PR now and have more discussion in https://issues.apache.org/jira/browse/FLINK-17808 ? -- This is an automated message from the Apache Git Se

[GitHub] [flink] Myasuka commented on pull request #16210: [FLINK-23044] fix typos in docs

2021-06-20 Thread GitBox
Myasuka commented on pull request #16210: URL: https://github.com/apache/flink/pull/16210#issuecomment-864710557 > > Thanks for the contribution, I wonder only three lines in the documentation have typos? > > No, there are tons of typos. I don't have enough time to fix all of them.

[GitHub] [flink] flinkbot commented on pull request #16212: [FLINK-23042][docs-zh] Correct docs-zh picture fraud-transactions.svg…

2021-06-20 Thread GitBox
flinkbot commented on pull request #16212: URL: https://github.com/apache/flink/pull/16212#issuecomment-864708536 ## CI report: * 3177431ef14291ae912b37f27983049d48158a02 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16161: URL: https://github.com/apache/flink/pull/16161#issuecomment-861259205 ## CI report: * 742e4e8c3622802e1dcf7cf5fb020a5bd656a40d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 ## CI report: * 50b2100f9a62e662d6cb4a7ec111d3e73b9cd843 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16148: [FLINK-22617][Hive]Add log for hive source that use native or mapred reader

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16148: URL: https://github.com/apache/flink/pull/16148#issuecomment-859467607 ## CI report: * 86e49e125d78c43cdc415f15ee7056ffd770da54 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Myasuka commented on pull request #16162: [hotfix][docs] fix img links and previous docs link

2021-06-20 Thread GitBox
Myasuka commented on pull request #16162: URL: https://github.com/apache/flink/pull/16162#issuecomment-864707829 I have closed FLINK-23012 and also pick your PR to release-1.13 branch with removal of adding previous docs link in 3964761b80d2dce532d04704d1a3f4b097a8c5eb -- This is an auto

[GitHub] [flink] raywill commented on pull request #16210: [FLINK-23044] fix typos in docs

2021-06-20 Thread GitBox
raywill commented on pull request #16210: URL: https://github.com/apache/flink/pull/16210#issuecomment-864705138 > Thanks for the contribution, I wonder only three lines in the documentation have typos? No, there are tons of typos. I don't have enough time to fix all of them. you ca

[jira] [Resolved] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

2021-06-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23012. -- Resolution: Fixed > Add v1.13 docs link in "Pick Docs Version" for master branch > ---

[jira] [Updated] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

2021-06-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23012: - Fix Version/s: 1.14.0 > Add v1.13 docs link in "Pick Docs Version" for master branch > -

[jira] [Commented] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

2021-06-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366363#comment-17366363 ] Yun Tang commented on FLINK-23012: -- Fixed by a hotfix: 73b3d10613d95a399f60c982f94a740b

[jira] [Comment Edited] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue

2021-06-20 Thread kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366362#comment-17366362 ] kevin edited comment on FLINK-23042 at 6/21/21, 3:50 AM: - Thanks

[GitHub] [flink] tony810430 commented on pull request #16162: [hotfix][docs] fix img links and previous docs link

2021-06-20 Thread GitBox
tony810430 commented on pull request #16162: URL: https://github.com/apache/flink/pull/16162#issuecomment-864703592 Hi @Myasuka Thanks for the reviewing. I will remember to create a JIRA ticket next time. besides, I think [FLINK-23012](https://issues.apache.org/jira/browse/FLINK-

[GitHub] [flink] Myasuka merged pull request #16162: [hotfix][docs] fix img links and previous docs link

2021-06-20 Thread GitBox
Myasuka merged pull request #16162: URL: https://github.com/apache/flink/pull/16162 -- 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. For queries about this service, please

[jira] [Commented] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue

2021-06-20 Thread kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366362#comment-17366362 ] kevin commented on FLINK-23042: --- Thanks a lot [~xintongsong] > Flink Chinese docs Fraud D

[GitHub] [flink] flinkbot commented on pull request #16212: [FLINK-23042][docs-zh] Correct docs-zh picture fraud-transactions.svg…

2021-06-20 Thread GitBox
flinkbot commented on pull request #16212: URL: https://github.com/apache/flink/pull/16212#issuecomment-864702375 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 pro

[jira] [Updated] (FLINK-15024) System classloader memory leak after loading too many codegen classes.

2021-06-20 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-15024: Labels: (was: stale-major) > System classloader memory leak after loading too many codegen class

[jira] [Updated] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue

2021-06-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23042: --- Labels: docs documentation-update pull-request-available zh_CN (was: docs documentation-upd

[jira] [Updated] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

2021-06-20 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-21788: Labels: pull-request-available (was: pull-request-available stale-assigned) > Throw PartitionNotF

[GitHub] [flink] RollsBean opened a new pull request #16212: [FLINK-23042][docs-zh] Correct docs-zh picture fraud-transactions.svg…

2021-06-20 Thread GitBox
RollsBean opened a new pull request #16212: URL: https://github.com/apache/flink/pull/16212 … src ## What is the purpose of the change *(This pull request fix Flink Chinese doc [https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/learn-flink/datastream

[GitHub] [flink] flinkbot edited a comment on pull request #16211: [FLINK-16952][Connectors/Parquet] Parquet file format support filter push down.

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16211: URL: https://github.com/apache/flink/pull/16211#issuecomment-864689257 ## CI report: * 33aec918ba974f8c0a0ccfd4ed3ceb9a91a6fdb5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 ## CI report: * 50b2100f9a62e662d6cb4a7ec111d3e73b9cd843 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

2021-06-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366357#comment-17366357 ] Yun Gao edited comment on FLINK-22085 at 6/21/21, 3:38 AM: --- I

[GitHub] [flink] curcur commented on a change in pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

2021-06-20 Thread GitBox
curcur commented on a change in pull request #15420: URL: https://github.com/apache/flink/pull/15420#discussion_r654946468 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -114,

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

2021-06-20 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366359#comment-17366359 ] Dong Lin commented on FLINK-22085: -- [~gaoyunhaii] Thanks for the investigation. Previou

[GitHub] [flink] luoyuxia commented on pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though the inp

2021-06-20 Thread GitBox
luoyuxia commented on pull request #16161: URL: https://github.com/apache/flink/pull/16161#issuecomment-864698057 @JingsongLi Now, I have added test to check emiting EndCheckpoint with Long.MAX_VALUE when end of input in CompactFileWriterTest. -- This is an automated message from the Apa

[GitHub] [flink] hehuiyuan edited a comment on pull request #16148: [FLINK-22617][Hive]Add log for hive source that use native or mapred reader

2021-06-20 Thread GitBox
hehuiyuan edited a comment on pull request #16148: URL: https://github.com/apache/flink/pull/16148#issuecomment-864694544 > Thanks @hehuiyuan for working on this. Since a reader is created for every split, will it be more useful if we also print the split in the logs? Besides, maybe it's b

[GitHub] [flink] hehuiyuan commented on pull request #16148: [FLINK-22617][Hive]Add log for hive source that use native or mapred reader

2021-06-20 Thread GitBox
hehuiyuan commented on pull request #16148: URL: https://github.com/apache/flink/pull/16148#issuecomment-864694544 > Thanks @hehuiyuan for working on this. Since a reader is created for every split, will it be more useful if we also print the split in the logs? Besides, maybe it's better t

[jira] [Created] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

2021-06-20 Thread Xintong Song (Jira)
Xintong Song created FLINK-23052: Summary: cron_snapshot_deployment_maven unstable on maven Key: FLINK-23052 URL: https://issues.apache.org/jira/browse/FLINK-23052 Project: Flink Issue Type:

[jira] [Created] (FLINK-23051) Savepoint an application for source of cdc-kafka, then restart the application from the savepoint, offset not be recovered.

2021-06-20 Thread Carl (Jira)
Carl created FLINK-23051: Summary: Savepoint an application for source of cdc-kafka, then restart the application from the savepoint, offset not be recovered. Key: FLINK-23051 URL: https://issues.apache.org/jira/browse/

[GitHub] [flink] Zakelly commented on a change in pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

2021-06-20 Thread GitBox
Zakelly commented on a change in pull request #16153: URL: https://github.com/apache/flink/pull/16153#discussion_r655046921 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ## @@ -607,6 +612,53 @@ publi

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

2021-06-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366357#comment-17366357 ] Yun Gao commented on FLINK-22085: - I checked the last several cases, it seems they are a

[jira] [Assigned] (FLINK-23050) Add Chinese version of documentation of unaligned checkpoint

2021-06-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23050: Assignee: Han Yin > Add Chinese version of documentation of unaligned checkpoint > --

[GitHub] [flink] flinkbot commented on pull request #16211: [FLINK-16952][Connectors/Parquet] Parquet file format support filter push down.

2021-06-20 Thread GitBox
flinkbot commented on pull request #16211: URL: https://github.com/apache/flink/pull/16211#issuecomment-864689257 ## CI report: * 33aec918ba974f8c0a0ccfd4ed3ceb9a91a6fdb5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16210: [FLINK-23044] fix typos in docs

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16210: URL: https://github.com/apache/flink/pull/16210#issuecomment-864682204 ## CI report: * ac28fa57c35305feb56c9825f360bc32d0547db9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16179: [TESTING] Try to reproduce FLINK-22891

2021-06-20 Thread GitBox
flinkbot edited a comment on pull request #16179: URL: https://github.com/apache/flink/pull/16179#issuecomment-863055916 ## CI report: * 1fddc9fa74da8400c9869aeea87038bcec3257fe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23044) fix typos in docs

2021-06-20 Thread Huang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Yu updated FLINK-23044: - Description: using [codetypo|[https://www.github.com/raywill/codetypo]]  I found tons of typos in Flink

[jira] [Created] (FLINK-23050) Add Chinese version of documentation of unaligned checkpoint

2021-06-20 Thread Yun Tang (Jira)
Yun Tang created FLINK-23050: Summary: Add Chinese version of documentation of unaligned checkpoint Key: FLINK-23050 URL: https://issues.apache.org/jira/browse/FLINK-23050 Project: Flink Issue T

[jira] [Commented] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue

2021-06-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366353#comment-17366353 ] Xintong Song commented on FLINK-23042: -- Usually, you only need to open PRs on the m

[jira] [Updated] (FLINK-23018) State factories should handle extended state descriptors

2021-06-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23018: - Fix Version/s: 1.13.2 > State factories should handle extended state descriptors > -

[jira] [Resolved] (FLINK-23018) State factories should handle extended state descriptors

2021-06-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23018. -- Resolution: Fixed > State factories should handle extended state descriptors > ---

[jira] [Commented] (FLINK-23018) State factories should handle extended state descriptors

2021-06-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366351#comment-17366351 ] Yun Tang commented on FLINK-23018: -- Merged master: 73c103b6b117fe3996eedfb9d04e926f00c7

[jira] [Commented] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

2021-06-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366350#comment-17366350 ] Xintong Song commented on FLINK-22480: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2021-06-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366349#comment-17366349 ] Xintong Song commented on FLINK-18634: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-23049) UnalignedCheckpointCompatibilityITCase hangs on azure

2021-06-20 Thread Xintong Song (Jira)
Xintong Song created FLINK-23049: Summary: UnalignedCheckpointCompatibilityITCase hangs on azure Key: FLINK-23049 URL: https://issues.apache.org/jira/browse/FLINK-23049 Project: Flink Issue T

[jira] [Commented] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue

2021-06-20 Thread kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366347#comment-17366347 ] kevin commented on FLINK-23042: --- Hi [~xintongsong],    Both branch *release-1.13* and *m

[GitHub] [flink] Myasuka merged pull request #16178: [FLINK-23018][state] Enable TTL state factory to handle extended state descriptors

2021-06-20 Thread GitBox
Myasuka merged pull request #16178: URL: https://github.com/apache/flink/pull/16178 -- 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. For queries about this service, please

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

2021-06-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366346#comment-17366346 ] Xintong Song commented on FLINK-22085: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot commented on pull request #16211: [FLINK-16952][Connectors/Parquet] Parquet file format support filter push down.

2021-06-20 Thread GitBox
flinkbot commented on pull request #16211: URL: https://github.com/apache/flink/pull/16211#issuecomment-864684011 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 pro

[jira] [Commented] (FLINK-16952) Parquet file system format support filter pushdown

2021-06-20 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366345#comment-17366345 ] luoyuxia commented on FLINK-16952: -- [~lzljs3620320] Look forward your review. > Parqu

  1   2   3   >