[GitHub] [flink] flinkbot commented on pull request #15793: [FLINK-19449][table-planner] LEAD/LAG cannot work correctly in streaming mode

flinkbot commented on pull request #15793: URL: https://github.com/apache/flink/pull/15793#issuecomment-828195864 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] [Reopened] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-19449: -- re-open for 1.13 > LEAD/LAG cannot work correctly in streaming mode > ---

[GitHub] [flink] JingsongLi opened a new pull request #15793: [FLINK-19449][table-planner] LEAD/LAG cannot work correctly in streaming mode

JingsongLi opened a new pull request #15793: URL: https://github.com/apache/flink/pull/15793 Cherry-pick https://github.com/apache/flink/pull/15747 ## What is the purpose of the change Fix "LEAD/LAG cannot work correctly in streaming mode". `LeadLagAggFunction` is only w

[jira] [Updated] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19449: - Fix Version/s: (was: 1.14.0) 1.13.0 > LEAD/LAG cannot work correctly in s

[GitHub] [flink] flinkbot edited a comment on pull request #15783: [hotfix][python][docs] Fix python.archives docs

flinkbot edited a comment on pull request #15783: URL: https://github.com/apache/flink/pull/15783#issuecomment-827482345 ## CI report: * f913eb003f86af890e05edfcddb00c2c65b2aca1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15764: [FLINK-22471][flink-table][flink-connectors] Improvements to ConfigOption descriptions

flinkbot edited a comment on pull request #15764: URL: https://github.com/apache/flink/pull/15764#issuecomment-826589841 ## CI report: * f0ec66c153d735ef2766164aef8dac76444ef870 UNKNOWN * 99b5a1bdb1cb456489f9c85fbb0b0cd5953877b7 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * 9e7da4cae78b1e44abaf51805fa0f89f3c81fe2d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] XComp commented on pull request #15131: [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster

XComp commented on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-828183451 > @XComp Thanks for your reply. > Docs is updated and latest commit is uploaded. And this commit has made the following changes compared to the last one. > > 1. Update th

[jira] [Assigned] (FLINK-21341) Update state reader to return InputFormat

[ https://issues.apache.org/jira/browse/FLINK-21341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin reassigned FLINK-21341: --- Assignee: Jun Qin > Update state reader to return InputFormat > ---

[jira] [Assigned] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration

[ https://issues.apache.org/jira/browse/FLINK-21336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin reassigned FLINK-21336: --- Assignee: Jun Qin > Activate bloom filter in RocksDB State Backend via Flink configuration > --

[jira] [Closed] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ?

[ https://issues.apache.org/jira/browse/FLINK-22499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-22499. - Resolution: Implemented > JDBC sink table-api support "sink.parallelism" ? > -

[GitHub] [flink] Airblader commented on pull request #15764: [FLINK-22471][flink-table][flink-connectors] Improvements to ConfigOption descriptions

Airblader commented on pull request #15764: URL: https://github.com/apache/flink/pull/15764#issuecomment-828173347 @twalthr Thanks, I've updated the PR! -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #15753: [FLINK-22428][docs][table] Translate timezone page into Chinese

flinkbot edited a comment on pull request #15753: URL: https://github.com/apache/flink/pull/15753#issuecomment-826339948 ## CI report: * ef16adf7941acfdf56818b000c9e7b2763138564 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ?

[ https://issues.apache.org/jira/browse/FLINK-22499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334473#comment-17334473 ] Shengkai Fang commented on FLINK-22499: --- Please refer to the doc[1]   [1]https:/

[GitHub] [flink] wsz94 commented on pull request #15573: [hotfix][docs] Fix the consumer committed destination in Kafka doc

wsz94 commented on pull request #15573: URL: https://github.com/apache/flink/pull/15573#issuecomment-828169806 Hi, @dawidwys , could you please help me review this PR? thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Updated] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20950: --- Affects Version/s: 1.12.2 > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test f

[GitHub] [flink] flinkbot edited a comment on pull request #15790: [hotfix][python][docs] add bundling udfs section

flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 57608d10dc311491f674c9e0c1f350d127b49c4c UNKNOWN * 1c2dd4a9e8e93256e53daec1825a8c30a199e0e7 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15788: [FLINK_22408]Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

flinkbot edited a comment on pull request #15788: URL: https://github.com/apache/flink/pull/15788#issuecomment-827674618 ## CI report: * a7918f2545747f468780b682c54e9c909c298f21 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15753: [FLINK-22428][docs][table] Translate timezone page into Chinese

flinkbot edited a comment on pull request #15753: URL: https://github.com/apache/flink/pull/15753#issuecomment-826339948 ## CI report: * ef16adf7941acfdf56818b000c9e7b2763138564 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] hackergin commented on pull request #15785: [hotfix][doc] Fix invalid sql comments and words in timezone.md

hackergin commented on pull request #15785: URL: https://github.com/apache/flink/pull/15785#issuecomment-828149161 move changes to https://github.com/apache/flink/pull/15753 and close this pr. -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] hackergin closed pull request #15785: [hotfix][doc] Fix invalid sql comments and words in timezone.md

hackergin closed pull request #15785: URL: https://github.com/apache/flink/pull/15785 -- 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, plea

[GitHub] [flink] flinkbot edited a comment on pull request #15788: [FLINK_22408]Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

flinkbot edited a comment on pull request #15788: URL: https://github.com/apache/flink/pull/15788#issuecomment-827674618 ## CI report: * a7918f2545747f468780b682c54e9c909c298f21 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [WIP][FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * a0ae769663e7b237021fbad03ebc309928dd2445 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] todd5167 commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

todd5167 commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r621814045 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -144,6 +149,11

[GitHub] [flink] flinkbot edited a comment on pull request #15788: [FLINK_22408]Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

flinkbot edited a comment on pull request #15788: URL: https://github.com/apache/flink/pull/15788#issuecomment-827674618 ## CI report: * a7918f2545747f468780b682c54e9c909c298f21 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15792: [hotfix][cep] Add some missing parameterization in cep module

flinkbot edited a comment on pull request #15792: URL: https://github.com/apache/flink/pull/15792#issuecomment-828132718 ## CI report: * d3defe13239c7d38525a45fd1958786f37c52314 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * 1d43ce7ad5aa1b1a53be0e304b1d5b9ed477c3b7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] todd5167 commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

todd5167 commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r621808605 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -144,6 +149,11

[GitHub] [flink] githubMJ commented on pull request #15788: [FLINK_22408]Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

githubMJ commented on pull request #15788: URL: https://github.com/apache/flink/pull/15788#issuecomment-828138782 @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

[GitHub] [flink] flinkbot commented on pull request #15792: [hotfix][cep] Add some missing parameterization in cep module

flinkbot commented on pull request #15792: URL: https://github.com/apache/flink/pull/15792#issuecomment-828132718 ## CI report: * d3defe13239c7d38525a45fd1958786f37c52314 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15791: [FLINK-22438][metrics] Add numRecordsOut metric for Async IO

flinkbot edited a comment on pull request #15791: URL: https://github.com/apache/flink/pull/15791#issuecomment-828125920 ## CI report: * 7a0f4e1a3c40f295b100a94c4772ba238929f4b0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15790: [hotfix][python][docs] add bundling udfs section

flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 57608d10dc311491f674c9e0c1f350d127b49c4c UNKNOWN * 86c54e97d3657b5e572988c8987979f39983590d Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * 1d43ce7ad5aa1b1a53be0e304b1d5b9ed477c3b7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15753: [FLINK-22428][docs][table] Translate timezone page into Chinese

flinkbot edited a comment on pull request #15753: URL: https://github.com/apache/flink/pull/15753#issuecomment-826339948 ## CI report: * 254a78439e2e3128167c760cab0dcdfb363a91cd Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22406) Unstable test ReactiveModeITCase.testScaleDownOnTaskManagerLoss()

[ https://issues.apache.org/jira/browse/FLINK-22406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334439#comment-17334439 ] Guowei Ma commented on FLINK-22406: --- another case https://dev.azure.com/apache-flink/a

[GitHub] [flink] flinkbot commented on pull request #15792: [hotfix][cep] Add some missing parameterization in cep module

flinkbot commented on pull request #15792: URL: https://github.com/apache/flink/pull/15792#issuecomment-828127793 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

[GitHub] [flink] dengziming opened a new pull request #15792: [hotfix][cep] Add some missing parameterization in cep module

dengziming opened a new pull request #15792: URL: https://github.com/apache/flink/pull/15792 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Commented] (FLINK-22498) cast the primary key for source table that has a decimal primary key as string, and then insert into a kudu table that has a string primary key throw the exception : U

[ https://issues.apache.org/jira/browse/FLINK-22498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334438#comment-17334438 ] Jark Wu commented on FLINK-22498: - This is a problem on Kudu sink, the Kudu sink impleme

[jira] [Closed] (FLINK-22498) cast the primary key for source table that has a decimal primary key as string, and then insert into a kudu table that has a string primary key throw the exception : Upse

[ https://issues.apache.org/jira/browse/FLINK-22498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22498. --- Resolution: Not A Problem > cast the primary key for source table that has a decimal primary key as > strin

[GitHub] [flink] flinkbot commented on pull request #15791: [FLINK-22438][metrics] Add numRecordsOut metric for Async IO

flinkbot commented on pull request #15791: URL: https://github.com/apache/flink/pull/15791#issuecomment-828125920 ## CI report: * 7a0f4e1a3c40f295b100a94c4772ba238929f4b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15753: [FLINK-22428][docs][table] Translate timezone page into Chinese

flinkbot edited a comment on pull request #15753: URL: https://github.com/apache/flink/pull/15753#issuecomment-826339948 ## CI report: * 254a78439e2e3128167c760cab0dcdfb363a91cd Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * e3f953d91778ef96ad5fe222dd9da229dc2c

[jira] [Created] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ?

ranqiqiang created FLINK-22499: -- Summary: JDBC sink table-api support "sink.parallelism" ? Key: FLINK-22499 URL: https://issues.apache.org/jira/browse/FLINK-22499 Project: Flink Issue Type: Ne

[GitHub] [flink] flinkbot edited a comment on pull request #15790: [hotfix][python][docs] add bundling udfs section

flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 40ff67a835fa6304cf3fe72e642e4ac6a3af76a8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15791: [FLINK-22438][metrics] Add numRecordsOut metric for Async IO

flinkbot commented on pull request #15791: URL: https://github.com/apache/flink/pull/15791#issuecomment-828119027 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

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[jira] [Created] (FLINK-22498) cast the primary key for source table that has a decimal primary key as string, and then insert into a kudu table that has a string primary key throw the exception : Ups

Carl created FLINK-22498: Summary: cast the primary key for source table that has a decimal primary key as string, and then insert into a kudu table that has a string primary key throw the exception : UpsertStreamTableSink requires that Table has a full

[jira] [Updated] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed

[ https://issues.apache.org/jira/browse/FLINK-22497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-22497: --- Attachment: (was: 企业微信截图_43e36204-0a2f-4acd-ae17-56aa4d7661e4.png) > When using DefaultRollingPo

[jira] [Updated] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed

[ https://issues.apache.org/jira/browse/FLINK-22497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-22497: --- Attachment: 1.png > When using DefaultRollingPolicy in StreamingFileSink, the file will be > finish

[jira] [Updated] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed

[ https://issues.apache.org/jira/browse/FLINK-22497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-22497: --- Attachment: 企业微信截图_43e36204-0a2f-4acd-ae17-56aa4d7661e4.png > When using DefaultRollingPolicy in Str

[jira] [Comment Edited] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334427#comment-17334427 ] wangwj edited comment on FLINK-10644 at 4/28/21, 3:31 AM: -- [~tr

[jira] [Created] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed

ChangjiGuo created FLINK-22497: -- Summary: When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed Key: FLINK-22497 URL: https://issues.apache.org/jira/browse/FLINK-22497 P

[jira] [Updated] (FLINK-22438) add numRecordsOut metric for Async IO

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22438: --- Labels: pull-request-available (was: ) > add numRecordsOut metric for Async IO > --

[GitHub] [flink] onyourhead opened a new pull request #15791: [FLINK-22438][metrics] Add numRecordsOut metric for Async IO

onyourhead opened a new pull request #15791: URL: https://github.com/apache/flink/pull/15791 ## What is the purpose of the change *In Flink WebUI,there is no numRecordsOut metric in Async IO operator while other operator have, this makes it difficult to monitor Async IO operator and

[jira] [Comment Edited] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334427#comment-17334427 ] wangwj edited comment on FLINK-10644 at 4/28/21, 3:21 AM: -- [~tr

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

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * bd27dabd13c11fd65b98423595e9d9323453

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

maosuhan commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-828109372 @sv3ndk Sorry for late reply. We had a discussion offline and we think that the rules that you proposed are more strict but introduce many different cases. We plan to deliver

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334427#comment-17334427 ] wangwj commented on FLINK-10644: [~trohrmann] Hi Till. I am come from the search and re

[GitHub] [flink-web] xintongsong commented on a change in pull request #436: Add Apache Flink release 1.13.0

xintongsong commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r621776893 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,483 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[GitHub] [flink] flinkbot edited a comment on pull request #15790: [hotfix][python][docs] add bundling udfs section

flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 40ff67a835fa6304cf3fe72e642e4ac6a3af76a8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * 588bfb357b6bb193b446af68f1ff48f10252da1d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334423#comment-17334423 ] Guowei Ma commented on FLINK-20950: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Assigned] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-20950: - Assignee: Guowei Ma > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed wit

[jira] [Updated] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20950: -- Labels: test-stability (was: auto-unassigned test-stability) > SinkITCase.writerAndGlobalCommitterExe

[GitHub] [flink] YikSanChan commented on pull request #15790: [hotfix][python][docs] add bundling udfs section

YikSanChan commented on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828105045 @dianfu thanks for pointing out, fixed -- 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-web] xintongsong commented on a change in pull request #436: Add Apache Flink release 1.13.0

xintongsong commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r621774146 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,483 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[GitHub] [flink] dianfu commented on a change in pull request #15790: [hotfix][python][docs] add bundling udfs section

dianfu commented on a change in pull request #15790: URL: https://github.com/apache/flink/pull/15790#discussion_r621771601 ## File path: docs/content.zh/docs/dev/python/table/udfs/python_udfs.md ## @@ -554,3 +554,11 @@ class ListViewConcatTableAggregateFunction(TableAggregateF

[jira] [Commented] (FLINK-19028) Translate the "application_parameters.zh.md" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334419#comment-17334419 ] jjiey commented on FLINK-19028: --- hi, [~jark], I am willing to do it. Can you assign it to

[GitHub] [flink] flinkbot edited a comment on pull request #15790: [hotfix][python][docs] add bundling udfs section

flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 40ff67a835fa6304cf3fe72e642e4ac6a3af76a8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-22496) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed

Guowei Ma created FLINK-22496: - Summary: ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed Key: FLINK-22496 URL: https://issues.apache.org/jira/browse/FLINK-22496 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * 588bfb357b6bb193b446af68f1ff48f10252da1d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Reopened] (FLINK-21121) TaggedOperatorSubtaskState is missing when creating a new savepoint using state processor api

[ https://issues.apache.org/jira/browse/FLINK-21121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] binguo reopened FLINK-21121: We are not sure whether adding the state-processor-api to the job running the manipulated savepoint is someth

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334413#comment-17334413 ] Guowei Ma commented on FLINK-17274: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22438) add numRecordsOut metric for Async IO

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334412#comment-17334412 ] Zhengqi Zhang commented on FLINK-22438: --- Yes,I'll submit a PR later > add numReco

[jira] [Commented] (FLINK-18444) KafkaITCase failing with "Failed to send data to Kafka: This server does not host this topic-partition"

[ https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334411#comment-17334411 ] Guowei Ma commented on FLINK-18444: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-18444) KafkaITCase failing with "Failed to send data to Kafka: This server does not host this topic-partition"

[ https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-18444: -- Affects Version/s: (was: 1.11.0) 1.11.3 > KafkaITCase failing with "Failed

[jira] [Resolved] (FLINK-19879) Support "IF NOT EXISTS" in DDL for CREATE TABLE

[ https://issues.apache.org/jira/browse/FLINK-19879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-19879. Fix Version/s: 1.12.0 Resolution: Fixed > Support "IF NOT EXISTS" in DDL for CREATE TABLE >

[GitHub] [flink] YikSanChan commented on pull request #15790: [hotfix][python][docs] add bundling udfs section

YikSanChan commented on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828094763 @dianfu added zh docs as well -- 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

[GitHub] [flink] leonardBang removed a comment on pull request #15785: [hotfix][doc] Fix invalid sql comments and words in timezone.md

leonardBang removed a comment on pull request #15785: URL: https://github.com/apache/flink/pull/15785#issuecomment-828076672 Thanks @hackergin for the contribution, could we fix this one another translation PR? -- This is an automated message from the Apache Git Service. To respond to th

[GitHub] [flink] leonardBang commented on a change in pull request #15753: [FLINK-22428][docs][table] Translate timezone page into Chinese

leonardBang commented on a change in pull request #15753: URL: https://github.com/apache/flink/pull/15753#discussion_r621757583 ## File path: docs/content.zh/docs/dev/table/concepts/timezone.md ## @@ -23,29 +23,29 @@ specific language governing permissions and limitations unde

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334405#comment-17334405 ] Jark Wu commented on FLINK-22318: - [~todd5167] 1. The {{SqlValidatorException}} may be

[GitHub] [flink] flinkbot edited a comment on pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on pull request #11786: URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * f5b89a2a4df3cb5c31ac5297359dddbb5d32282b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] YikSanChan commented on pull request #15790: [hotfix][python][docs] add bundling udfs section

YikSanChan commented on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828090279 @dianfu Resolved -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-22380) Pub/Sub Lite Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-22380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evan Palmer updated FLINK-22380: Component/s: Connectors / Common > Pub/Sub Lite Connector for Flink >

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] dianfu commented on a change in pull request #15790: [hotfix][python][docs] add bundling udfs section

dianfu commented on a change in pull request #15790: URL: https://github.com/apache/flink/pull/15790#discussion_r621750740 ## File path: docs/content/docs/dev/python/table/udfs/python_udfs.md ## @@ -30,6 +30,10 @@ User-defined functions are important features, because they sig

[GitHub] [flink] cshuo commented on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

cshuo commented on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-828081952 The failed test is python docs, which is already fixed. I will rebase and trigger test again. -- This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Closed] (FLINK-18952) Add 10 minutes to DataStream API documentation

[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18952. --- Fix Version/s: 1.12.4 Resolution: Fixed Merged to - master via 981bed0706005e1c02975733141da69a7260f5

[jira] [Updated] (FLINK-18952) Add 10 minutes to DataStream API documentation

[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18952: Fix Version/s: (was: 1.14.0) 1.13.0 > Add 10 minutes to DataStream API documentatio

[GitHub] [flink] leonardBang commented on a change in pull request #15753: [FLINK-22428][docs][table] Translate timezone page into Chinese

leonardBang commented on a change in pull request #15753: URL: https://github.com/apache/flink/pull/15753#discussion_r621748251 ## File path: docs/content.zh/docs/dev/table/concepts/timezone.md ## @@ -528,7 +527,7 @@ Flink SQL> SET table.local-time-zone=Asia/Shanghai; Flink SQ

[GitHub] [flink] leonardBang commented on pull request #15785: [hotfix][doc] Fix invalid sql comments and words in timezone.md

leonardBang commented on pull request #15785: URL: https://github.com/apache/flink/pull/15785#issuecomment-828076672 Thanks @hackergin for the contribution, could we fix this one another translation PR? -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on pull request #15790: [hotfix][python][docs] add bundling udfs section

flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 40ff67a835fa6304cf3fe72e642e4ac6a3af76a8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15783: [hotfix][python][docs] Fix python.archives docs

flinkbot edited a comment on pull request #15783: URL: https://github.com/apache/flink/pull/15783#issuecomment-827482345 ## CI report: * 4db5f1c0dce58bd0ee5aaa1d8fca4d60635e90c8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] YikSanChan opened a new pull request #15790: [hotfix][python][docs] add bundling udfs section

YikSanChan opened a new pull request #15790: URL: https://github.com/apache/flink/pull/15790 ## What is the purpose of the change Remind people that they need to include their udf definition in python.files config option. Follow up to http://apache-flink-user-mailing-list-ar

[jira] [Commented] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334369#comment-17334369 ] Dan Hill commented on FLINK-10954: -- [~yunta]- thanks Yun! > Hardlink from files of pre

[jira] [Assigned] (FLINK-6605) Allow users to specify a default name for processing time in Table API

[ https://issues.apache.org/jira/browse/FLINK-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-6605: - Assignee: (was: Haohui Mai) > Allow users to specify a default name for processing t

[jira] [Assigned] (FLINK-7016) Move inputFormat to InputFormatVertex from TaskConfig

[ https://issues.apache.org/jira/browse/FLINK-7016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7016: - Assignee: (was: Xu Pingyong) > Move inputFormat to InputFormatVertex from TaskConfig

[jira] [Assigned] (FLINK-6477) The first time to click Taskmanager cannot get the actual data

[ https://issues.apache.org/jira/browse/FLINK-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-6477: - Assignee: (was: zhihao chen) > The first time to click Taskmanager cannot get the ac

[jira] [Commented] (FLINK-22344) KafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue times out

[ https://issues.apache.org/jira/browse/FLINK-22344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334361#comment-17334361 ] Flink Jira Bot commented on FLINK-22344: This critical issue is unassigned and i

[jira] [Commented] (FLINK-19705) Avro Confluent Schema Registry nightly end-to-end test: curl: (56) Recv failure: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334356#comment-17334356 ] Flink Jira Bot commented on FLINK-19705: This major issue is unassigned and itse

  1   2   3   4   5   6   7   8   9   10   >