[GitHub] [flink] flinkbot edited a comment on pull request #14568: Update the Row.toString method

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

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2021-01-06 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * fd8cbf90a807292b0db7b85bda26f1e717b8

[GitHub] [flink] flinkbot edited a comment on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

2021-01-06 Thread GitBox
flinkbot edited a comment on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN * cc139e03f2d64dafa7607271ec1df2c3180a2f9e Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14562: [FLINK-20738][table-planner-blink] Separate the implementation of batch group aggregate nodes

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

[GitHub] [flink] flinkbot edited a comment on pull request #14567: [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an a…

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

[GitHub] [flink] dawidwys commented on a change in pull request #14568: Update the Row.toString method

2021-01-06 Thread GitBox
dawidwys commented on a change in pull request #14568: URL: https://github.com/apache/flink/pull/14568#discussion_r552652925 ## File path: flink-core/src/main/java/org/apache/flink/types/RowUtils.java ## @@ -74,6 +74,8 @@ public static boolean compareRows(List l1, List l2, boo

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

2021-01-06 Thread Steve Loughran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259767#comment-17259767 ] Steve Loughran commented on FLINK-19589: the filesystem createFile(Path path) AP

[GitHub] [flink] flinkbot edited a comment on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

2021-01-06 Thread GitBox
flinkbot edited a comment on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN * f1c012ecf5d3d91f13bb9bfa24ea7c31c775c9c7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14562: [FLINK-20738][table-planner-blink] Separate the implementation of batch group aggregate nodes

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

[GitHub] [flink] flinkbot edited a comment on pull request #14567: [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an a…

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

[GitHub] [flink] Jerome2268 closed pull request #14564: [minor] Fix type error

2021-01-06 Thread GitBox
Jerome2268 closed pull request #14564: URL: https://github.com/apache/flink/pull/14564 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

[GitHub] [flink] yuruguo commented on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

2021-01-06 Thread GitBox
yuruguo commented on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-755350173 @tillrohrmann Could you review code for this PR, thx! This is an automated message from the Apache Git Service.

[GitHub] [flink] wenlong88 commented on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

2021-01-06 Thread GitBox
wenlong88 commented on pull request #14502: URL: https://github.com/apache/flink/pull/14502#issuecomment-755351907 thanks @godfreyhe for the review, I have address you last comment and squash the commits. This is an automate

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

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

[GitHub] [flink] flinkbot edited a comment on pull request #14562: [FLINK-20738][table-planner-blink] Separate the implementation of batch group aggregate nodes

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

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

2021-01-06 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259803#comment-17259803 ] Aljoscha Krettek commented on FLINK-19589: -- I don't really have an opinion on t

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

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

[GitHub] [flink] flinkbot edited a comment on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

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

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

2021-01-06 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259827#comment-17259827 ] Robert Metzger commented on FLINK-20632: There's actually another option: We can

[GitHub] [flink] flinkbot edited a comment on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

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

[jira] [Comment Edited] (FLINK-20632) Missing docker images for 1.12 release

2021-01-06 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259827#comment-17259827 ] Robert Metzger edited comment on FLINK-20632 at 1/6/21, 4:02 PM: -

[GitHub] [flink] cvasii commented on a change in pull request #13994: [FLINK-20054][formats] Fix ParquetInputFormat 3 level List handling

2021-01-06 Thread GitBox
cvasii commented on a change in pull request #13994: URL: https://github.com/apache/flink/pull/13994#discussion_r552749908 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchemaConverter.java ## @@ -306,6 +295,18 @@ public

[jira] [Commented] (FLINK-20861) Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-06 Thread Q Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259839#comment-17259839 ] Q Kang commented on FLINK-20861: All right, let's stick to `json.encode.decimal-as-plain

[jira] [Created] (FLINK-20867) support ship files from local/remote path to k8s pod

2021-01-06 Thread Ruguo Yu (Jira)
Ruguo Yu created FLINK-20867: Summary: support ship files from local/remote path to k8s pod Key: FLINK-20867 URL: https://issues.apache.org/jira/browse/FLINK-20867 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-20867) Support ship files from local/remote path to k8s pod

2021-01-06 Thread Ruguo Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruguo Yu updated FLINK-20867: - Summary: Support ship files from local/remote path to k8s pod (was: support ship files from local/remot

[GitHub] [flink-web] rmetzger commented on a change in pull request #408: Add security page for Flink

2021-01-06 Thread GitBox
rmetzger commented on a change in pull request #408: URL: https://github.com/apache/flink-web/pull/408#discussion_r552769968 ## File path: _includes/navbar.html ## @@ -177,7 +177,9 @@ https://www.apache.org/licenses/"; target="_blank">License -

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2021-01-06 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259851#comment-17259851 ] Seth Wiesman commented on FLINK-13414: -- [~aljoscha] Agreed. I'm mostly just putting

[jira] [Created] (FLINK-20868) Pause the idle/back pressure timers during processing mailbox actions

2021-01-06 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-20868: -- Summary: Pause the idle/back pressure timers during processing mailbox actions Key: FLINK-20868 URL: https://issues.apache.org/jira/browse/FLINK-20868 Project: Fl

[jira] [Commented] (FLINK-20867) Support ship files from local/remote path to k8s pod

2021-01-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259909#comment-17259909 ] Zhenqiu Huang commented on FLINK-20867: --- [~jiang7chengzitc] I think this task is r

[GitHub] [flink] flinkbot edited a comment on pull request #14569: [FLINK-20856][table-planner-blink] Separate the implementation of stream window aggregate nodes

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

[jira] [Created] (FLINK-20869) Support TIMESTAMP WITH TIME ZONE

2021-01-06 Thread Timo Walther (Jira)
Timo Walther created FLINK-20869: Summary: Support TIMESTAMP WITH TIME ZONE Key: FLINK-20869 URL: https://issues.apache.org/jira/browse/FLINK-20869 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

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

[GitHub] [flink] zentol commented on a change in pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2021-01-06 Thread GitBox
zentol commented on a change in pull request #14510: URL: https://github.com/apache/flink/pull/14510#discussion_r551249823 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java ## @@ -107,6 +108,8 @@ /** Flag indicating

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2021-01-06 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * fd8cbf90a807292b0db7b85bda26f1e717b8

[GitHub] [flink] flinkbot edited a comment on pull request #14570: [FLINK-20798][k8s] Use namespaced kubernetes client when creating FlinkKubeClient

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

[GitHub] [flink] flinkbot edited a comment on pull request #14568: Update the Row.toString method

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

[GitHub] [flink] rmetzger commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-06 Thread GitBox
rmetzger commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-755516473 The benefit of sticking to the same PR (by (force) pushing changes is that we keep track of the history of changes). I'm closing the other PR. Please push your changes he

[GitHub] [flink] rmetzger commented on pull request #14529: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-06 Thread GitBox
rmetzger commented on pull request #14529: URL: https://github.com/apache/flink/pull/14529#issuecomment-755516798 Closing as this is a duplicate of https://github.com/apache/flink/pull/14512 This is an automated message from

[GitHub] [flink] flinkbot edited a comment on pull request #14567: [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an a…

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

[GitHub] [flink] blublinsky commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-06 Thread GitBox
blublinsky commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-755541392 Sorry guys, how do I force the same PR. Unfortunately not a GIT guru This is an automated message from the Ap

[GitHub] [flink] flinkbot edited a comment on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

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

[GitHub] [flink-web] zentol commented on a change in pull request #408: Add security page for Flink

2021-01-06 Thread GitBox
zentol commented on a change in pull request #408: URL: https://github.com/apache/flink-web/pull/408#discussion_r553053323 ## File path: _includes/navbar.html ## @@ -177,7 +177,9 @@ https://www.apache.org/licenses/"; target="_blank">License - h

[GitHub] [flink] becketqin commented on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

2021-01-06 Thread GitBox
becketqin commented on pull request #14557: URL: https://github.com/apache/flink/pull/14557#issuecomment-755830677 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

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

[jira] [Created] (FLINK-20870) FlinkKafkaSink

2021-01-06 Thread xx chai (Jira)
xx chai created FLINK-20870: --- Summary: FlinkKafkaSink Key: FLINK-20870 URL: https://issues.apache.org/jira/browse/FLINK-20870 Project: Flink Issue Type: Improvement Components: API / Data

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

2021-01-06 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Issue Type: Bug (was: Improvement) > FlinkKafkaSink > -- > > Key: FLINK-20870

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

2021-01-06 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260156#comment-17260156 ] Danny Chen commented on FLINK-18027: Fixed in https://issues.apache.org/jira/browse/

[jira] [Created] (FLINK-20871) Make DataStream#executeAndCollectWithClient public

2021-01-06 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-20871: -- Summary: Make DataStream#executeAndCollectWithClient public Key: FLINK-20871 URL: https://issues.apache.org/jira/browse/FLINK-20871 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

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

[jira] [Updated] (FLINK-20871) Make DataStream#executeAndCollectWithClient() public

2021-01-06 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-20871: --- Summary: Make DataStream#executeAndCollectWithClient() public (was: Make DataStream#execute

[jira] [Updated] (FLINK-20871) Make DataStream#executeAndCollectWithClient() public

2021-01-06 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-20871: --- Description: Right now, `DataStreamUtils#collectWithClient` is marked as deprecated in favor

[jira] [Created] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

2021-01-06 Thread Liu (Jira)
Liu created FLINK-20872: --- Summary: Job resume from history savepoint when failover if checkpoint is disabled Key: FLINK-20872 URL: https://issues.apache.org/jira/browse/FLINK-20872 Project: Flink Issu

[GitHub] [flink] stevenzwu opened a new pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

2021-01-06 Thread GitBox
stevenzwu opened a new pull request #14571: URL: https://github.com/apache/flink/pull/14571 …ient() public This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Commented] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

2021-01-06 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260165#comment-17260165 ] zoucao commented on FLINK-20795: hi [~jark], if we want two functions integrated in one

[jira] [Updated] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

2021-01-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-20872: Affects Version/s: (was: 1.11.0) 1.10.0 > Job resume from history savepoint when failov

[jira] [Updated] (FLINK-20871) Make DataStream#executeAndCollectWithClient() public

2021-01-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20871: --- Labels: pull-request-available (was: ) > Make DataStream#executeAndCollectWithClient() publ

[GitHub] [flink] flinkbot commented on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

2021-01-06 Thread GitBox
flinkbot commented on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755840587 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-20861) Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260168#comment-17260168 ] Jark Wu commented on FLINK-20861: - Feel free to open pull request. > Provide an option

[jira] [Updated] (FLINK-20861) Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20861: Fix Version/s: 1.13.0 > Provide an option for serializing DECIMALs in JSON as plain number instead of > s

[jira] [Created] (FLINK-20873) Upgrade Calcite version to 1.27

2021-01-06 Thread Jark Wu (Jira)
Jark Wu created FLINK-20873: --- Summary: Upgrade Calcite version to 1.27 Key: FLINK-20873 URL: https://issues.apache.org/jira/browse/FLINK-20873 Project: Flink Issue Type: Improvement Compo

[jira] [Created] (FLINK-20874) Python DataStreamTests.test_key_by_on_connect_stream test failed with "ArrayIndexOutOfBoundsException"

2021-01-06 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20874: Summary: Python DataStreamTests.test_key_by_on_connect_stream test failed with "ArrayIndexOutOfBoundsException" Key: FLINK-20874 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

2021-01-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260169#comment-17260169 ] Jark Wu commented on FLINK-18027: - Thanks [~danny0405] for the work! I created FLINK-208

[GitHub] [flink] wangyang0918 commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-06 Thread GitBox
wangyang0918 commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-755844471 @blublinsky First, address the comments and update the source codes locally. Then refine the commit message via `git commit --amend` or `git rebase -i master`. Last, force

[jira] [Commented] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

2021-01-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260176#comment-17260176 ] Huang Xingbo commented on FLINK-20781: -- [https://dev.azure.com/apache-flink/apache-

[GitHub] [flink] flinkbot commented on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

2021-01-06 Thread GitBox
flinkbot commented on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755845385 ## CI report: * 54088a5e88bc0f7ab29c21b754a6733c45d1a8bc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

2021-01-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260178#comment-17260178 ] Jark Wu edited comment on FLINK-20795 at 1/7/21, 2:37 AM: -- If w

[jira] [Commented] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

2021-01-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260178#comment-17260178 ] Jark Wu commented on FLINK-20795: - If we want to refactor this configuration. I would su

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

2021-01-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260178#comment-17260178 ] Jark Wu edited comment on FLINK-20795 at 1/7/21, 2:38 AM: -- If w

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

2021-01-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260178#comment-17260178 ] Jark Wu edited comment on FLINK-20795 at 1/7/21, 2:38 AM: -- If w

[GitHub] [flink] blublinsky commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-06 Thread GitBox
blublinsky commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-755848208 Oh, my problem is that I am working from the local fork, that I updated to get the latest version. So my previous fork is gone, thats why it created a new commit. So now from

[jira] [Created] (FLINK-20875) Could patch CVE-2020-17518 to version 1.10

2021-01-06 Thread Wong Mulan (Jira)
Wong Mulan created FLINK-20875: -- Summary: Could patch CVE-2020-17518 to version 1.10 Key: FLINK-20875 URL: https://issues.apache.org/jira/browse/FLINK-20875 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

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

[jira] [Updated] (FLINK-20832) flink.apache.org site Typography exception

2021-01-06 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20832: --- Component/s: API / Core > flink.apache.org site Typography exception > -- >

[GitHub] [flink] xintongsong commented on a change in pull request #14561: [FLINK-20836] Register TaskManager with total and default slot resource profile in SlotManager

2021-01-06 Thread GitBox
xintongsong commented on a change in pull request #14561: URL: https://github.com/apache/flink/pull/14561#discussion_r553079447 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java ## @@ -275,7 +275,10 @@ pu

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

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

[GitHub] [flink] wenlong88 commented on a change in pull request #14569: [FLINK-20856][table-planner-blink] Separate the implementation of stream window aggregate nodes

2021-01-06 Thread GitBox
wenlong88 commented on a change in pull request #14569: URL: https://github.com/apache/flink/pull/14569#discussion_r553085276 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupWindowAggregate.java ###

[jira] [Created] (FLINK-20876) Separate the implementation of StreamExecTemporalJoin

2021-01-06 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-20876: --- Summary: Separate the implementation of StreamExecTemporalJoin Key: FLINK-20876 URL: https://issues.apache.org/jira/browse/FLINK-20876 Project: Flink Issue Typ

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

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

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

2021-01-06 Thread GitBox
maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r553093799 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbSchemaValidator.java ## @@ -0,0 +1,148 @@ +/* + * Licensed

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

2021-01-06 Thread GitBox
maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r553094997 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbSchemaValidator.java ## @@ -0,0 +1,148 @@ +/* + * Licensed

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

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

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

2021-01-06 Thread GitBox
maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r553095717 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbSchemaValidator.java ## @@ -0,0 +1,148 @@ +/* + * Licensed

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

2021-01-06 Thread GitBox
maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r553095975 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/deserialize/PbCodegenSimpleDeserializer.java ## @@ -0,0 +1,53

[GitHub] [flink] stevenzwu commented on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

2021-01-06 Thread GitBox
stevenzwu commented on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755867853 @flinkbot run azure re-run the last Azure build This is an automated message from the Apache Git Service. To r

[GitHub] [flink] flinkbot edited a comment on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

2021-01-06 Thread GitBox
flinkbot edited a comment on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755845385 ## CI report: * Unknown: [CANCELED](TBD) * 34d88a71b61f62f2775a41eb291c017c6d76b8ab UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] godfreyhe closed pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

2021-01-06 Thread GitBox
godfreyhe closed pull request #14502: URL: https://github.com/apache/flink/pull/14502 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 t

[jira] [Closed] (FLINK-20766) Separate the implementation of sort nodes

2021-01-06 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20766. -- Resolution: Fixed Fixed in 1.13.0: 6c75072f..7668e4e3 > Separate the implementation of sort nodes > -

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

2021-01-06 Thread GitBox
maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r553102794 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbSchemaValidator.java ## @@ -0,0 +1,148 @@ +/* + * Licensed

[GitHub] [flink] godfreyhe commented on a change in pull request #14562: [FLINK-20738][table-planner-blink] Separate the implementation of batch group aggregate nodes

2021-01-06 Thread GitBox
godfreyhe commented on a change in pull request #14562: URL: https://github.com/apache/flink/pull/14562#discussion_r552627854 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/ExecNodeUtil.java ## @@ -35,6 +3

[GitHub] [flink] godfreyhe commented on a change in pull request #14562: [FLINK-20738][table-planner-blink] Separate the implementation of batch group aggregate nodes

2021-01-06 Thread GitBox
godfreyhe commented on a change in pull request #14562: URL: https://github.com/apache/flink/pull/14562#discussion_r552627854 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/ExecNodeUtil.java ## @@ -35,6 +3

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

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

[GitHub] [flink] flinkbot edited a comment on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

2021-01-06 Thread GitBox
flinkbot edited a comment on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755845385 ## CI report: * Unknown: [CANCELED](TBD) * 34d88a71b61f62f2775a41eb291c017c6d76b8ab Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

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

[GitHub] [flink] flinkbot edited a comment on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

2021-01-06 Thread GitBox
flinkbot edited a comment on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN * f1c012ecf5d3d91f13bb9bfa24ea7c31c775c9c7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

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

[jira] [Closed] (FLINK-20854) Introduce BytesMultiMap to support buffering records

2021-01-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20854. --- Resolution: Fixed Fixed in master: facd51fcf5c78c5f733c203c38e3a093ba8a5218 > Introduce BytesMultiMap to su

<    1   2   3   >