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

2021-04-27 Thread Robert Metzger (Jira)
[ 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

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 57608d10dc311491f674c9e0c1f350d127b49c4c UNKNOWN * 1c2dd4a9e8e93256e53daec1825a8c30a199e0e7 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15788: URL: https://github.com/apache/flink/pull/15788#issuecomment-827674618 ## CI report: * a7918f2545747f468780b682c54e9c909c298f21 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15753: URL: https://github.com/apache/flink/pull/15753#issuecomment-826339948 ## CI report: * ef16adf7941acfdf56818b000c9e7b2763138564 Azure:

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

2021-04-27 Thread GitBox
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,

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

2021-04-27 Thread GitBox
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,

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15788: URL: https://github.com/apache/flink/pull/15788#issuecomment-827674618 ## CI report: * a7918f2545747f468780b682c54e9c909c298f21 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * a0ae769663e7b237021fbad03ebc309928dd2445 Azure:

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15788: URL: https://github.com/apache/flink/pull/15788#issuecomment-827674618 ## CI report: * a7918f2545747f468780b682c54e9c909c298f21 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15792: URL: https://github.com/apache/flink/pull/15792#issuecomment-828132718 ## CI report: * d3defe13239c7d38525a45fd1958786f37c52314 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * 1d43ce7ad5aa1b1a53be0e304b1d5b9ed477c3b7 Azure:

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15791: URL: https://github.com/apache/flink/pull/15791#issuecomment-828125920 ## CI report: * 7a0f4e1a3c40f295b100a94c4772ba238929f4b0 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 57608d10dc311491f674c9e0c1f350d127b49c4c UNKNOWN * 86c54e97d3657b5e572988c8987979f39983590d Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * 1d43ce7ad5aa1b1a53be0e304b1d5b9ed477c3b7 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15753: URL: https://github.com/apache/flink/pull/15753#issuecomment-826339948 ## CI report: * 254a78439e2e3128167c760cab0dcdfb363a91cd Azure:

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

2021-04-27 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334439#comment-17334439 ] Guowei Ma commented on FLINK-22406: --- another case

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
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

[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

2021-04-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334438#comment-17334438 ] Jark Wu commented on FLINK-22498: - This is a problem on Kudu sink, the Kudu sink implementation should

[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

2021-04-27 Thread Jark Wu (Jira)
[ 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 >

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15753: URL: https://github.com/apache/flink/pull/15753#issuecomment-826339948 ## CI report: * 254a78439e2e3128167c760cab0dcdfb363a91cd Azure:

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

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

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

2021-04-27 Thread ranqiqiang (Jira)
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:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 40ff67a835fa6304cf3fe72e642e4ac6a3af76a8 Azure:

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

2021-04-27 Thread GitBox
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

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

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

[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

2021-04-27 Thread Carl (Jira)
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

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

2021-04-27 Thread ChangjiGuo (Jira)
[ 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

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

2021-04-27 Thread ChangjiGuo (Jira)
[ 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 >

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

2021-04-27 Thread ChangjiGuo (Jira)
[ 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

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

2021-04-27 Thread wangwj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334427#comment-17334427 ] wangwj edited comment on FLINK-10644 at 4/28/21, 3:31 AM: -- [~trohrmann] Hi

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

2021-04-27 Thread ChangjiGuo (Jira)
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

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

2021-04-27 Thread ASF GitHub Bot (Jira)
[ 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

2021-04-27 Thread GitBox
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

2021-04-27 Thread wangwj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334427#comment-17334427 ] wangwj edited comment on FLINK-10644 at 4/28/21, 3:21 AM: -- [~trohrmann] Hi

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

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

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread wangwj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334427#comment-17334427 ] wangwj commented on FLINK-10644: [~trohrmann] Hi Till. I am come from the search and recommendation

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

2021-04-27 Thread GitBox
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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 40ff67a835fa6304cf3fe72e642e4ac6a3af76a8 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * 588bfb357b6bb193b446af68f1ff48f10252da1d Azure:

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

2021-04-27 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334423#comment-17334423 ] Guowei Ma commented on FLINK-20950: ---

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

2021-04-27 Thread Guowei Ma (Jira)
[ 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

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

2021-04-27 Thread Guowei Ma (Jira)
[ 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) >

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

2021-04-27 Thread GitBox
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

2021-04-27 Thread GitBox
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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread jjiey (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334419#comment-17334419 ] jjiey commented on FLINK-19028: --- hi, [~jark], I am willing to do it. Can you assign it to me? thank you.

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 40ff67a835fa6304cf3fe72e642e4ac6a3af76a8 Azure:

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

2021-04-27 Thread Guowei Ma (Jira)
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…

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * 588bfb357b6bb193b446af68f1ff48f10252da1d Azure:

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

2021-04-27 Thread binguo (Jira)
[ 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

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

2021-04-27 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334413#comment-17334413 ] Guowei Ma commented on FLINK-17274: ---

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

2021-04-27 Thread Zhengqi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334412#comment-17334412 ] Zhengqi Zhang commented on FLINK-22438: --- Yes,I'll submit a PR later > add numRecordsOut metric

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

2021-04-27 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334411#comment-17334411 ] Guowei Ma commented on FLINK-18444: ---

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

2021-04-27 Thread Guowei Ma (Jira)
[ 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

2021-04-27 Thread Leonard Xu (Jira)
[ 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

2021-04-27 Thread GitBox
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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334405#comment-17334405 ] Jark Wu commented on FLINK-22318: - [~todd5167] 1. The {{SqlValidatorException}} may be not because of

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #11786: URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * f5b89a2a4df3cb5c31ac5297359dddbb5d32282b Azure:

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

2021-04-27 Thread GitBox
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

2021-04-27 Thread Evan Palmer (Jira)
[ 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

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

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread Dian Fu (Jira)
[ 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

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

2021-04-27 Thread Dian Fu (Jira)
[ 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

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15790: URL: https://github.com/apache/flink/pull/15790#issuecomment-828062007 ## CI report: * 40ff67a835fa6304cf3fe72e642e4ac6a3af76a8 Azure:

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15783: URL: https://github.com/apache/flink/pull/15783#issuecomment-827482345 ## CI report: * 4db5f1c0dce58bd0ee5aaa1d8fca4d60635e90c8 Azure:

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

2021-04-27 Thread GitBox
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

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

2021-04-27 Thread Dan Hill (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334369#comment-17334369 ] Dan Hill commented on FLINK-10954: -- [~yunta]- thanks Yun! > Hardlink from files of previous local

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

2021-04-27 Thread Flink Jira Bot (Jira)
[ 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

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

2021-04-27 Thread Flink Jira Bot (Jira)
[ 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

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

2021-04-27 Thread Flink Jira Bot (Jira)
[ 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

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

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334361#comment-17334361 ] Flink Jira Bot commented on FLINK-22344: This critical issue is unassigned and itself and all of

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

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334356#comment-17334356 ] Flink Jira Bot commented on FLINK-19705: This major issue is unassigned and itself and all of

[jira] [Assigned] (FLINK-3857) Add reconnect attempt to Elasticsearch host

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-3857: - Assignee: (was: Subhobrata Dey) > Add reconnect attempt to Elasticsearch host >

[jira] [Commented] (FLINK-4045) Test AMQP connector using Apache ActiveMQ emebdded broker

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334320#comment-17334320 ] Flink Jira Bot commented on FLINK-4045: --- This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-21993) Remove LocalCollectionOutputFormat from code base

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334342#comment-17334342 ] Flink Jira Bot commented on FLINK-21993: This major issue is unassigned and itself and all of

[jira] [Updated] (FLINK-6346) Migrate from Java serialization for GenericWriteAheadSink's state

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6346: -- Labels: auto-unassigned (was: stale-assigned) > Migrate from Java serialization for

[jira] [Updated] (FLINK-6931) Support custom compression formats for checkpoints (+Upgrade/Compatibility)

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6931: -- Labels: auto-unassigned (was: stale-assigned) > Support custom compression formats for

[jira] [Commented] (FLINK-22355) Simple Task Manager Memory Model image does not show up

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334360#comment-17334360 ] Flink Jira Bot commented on FLINK-22355: This critical issue is unassigned and itself and all of

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

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334341#comment-17334341 ] Flink Jira Bot commented on FLINK-19879: This issue and all of its Sub-Tasks have not been

[jira] [Assigned] (FLINK-11170) Support DISTINCT aggregates in MATCH_RECOGNIZE

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11170: -- Assignee: (was: Hequn Cheng) > Support DISTINCT aggregates in MATCH_RECOGNIZE >

[jira] [Commented] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334226#comment-17334226 ] Flink Jira Bot commented on FLINK-7607: --- This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7373: -- Labels: auto-unassigned (was: stale-assigned) > Using URLClassLoader to load UDF triggers

[jira] [Commented] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334365#comment-17334365 ] Flink Jira Bot commented on FLINK-21025: This critical issue is unassigned and itself and all of

[jira] [Commented] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334238#comment-17334238 ] Flink Jira Bot commented on FLINK-7373: --- This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-5865) Throw original exception in states

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334282#comment-17334282 ] Flink Jira Bot commented on FLINK-5865: --- This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-6370) FileAlreadyExistsException on startup

2021-04-27 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-6370: - Assignee: (was: Chesnay Schepler) > FileAlreadyExistsException on startup >

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

2021-04-27 Thread GitBox
flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * a0ae769663e7b237021fbad03ebc309928dd2445 Azure:

  1   2   3   4   5   6   7   8   9   10   >