[jira] [Commented] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

2020-04-29 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096232#comment-17096232 ] Wenlong Lyu commented on FLINK-17386: - [~rongr] I have verified the patch, it works.

[jira] [Updated] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode

2020-04-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-17472: --- Attachment: demo.png > StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode > --

[jira] [Updated] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode

2020-04-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-17472: --- Attachment: (was: demo.png) > StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode >

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096226#comment-17096226 ] Robert Metzger commented on FLINK-17260: Another case: https://dev.azure.com/ap

[jira] [Updated] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17260: --- Affects Version/s: 1.11.0 > StreamingKafkaITCase failure on Azure >

[GitHub] [flink] rmetzger commented on pull request #11950: [Flink-17030] Add primary key syntax to DDL

2020-04-29 Thread GitBox
rmetzger commented on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621648842 I reported the unrelated CI failure here: https://issues.apache.org/jira/browse/FLINK-17260 This is an automat

[jira] [Updated] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode

2020-04-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-17472: --- Attachment: demo.png > StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode > --

[jira] [Updated] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode

2020-04-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-17472: --- Attachment: (was: demo.png) > StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode >

[jira] [Comment Edited] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

2020-04-29 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096221#comment-17096221 ] ranqiqiang edited comment on FLINK-17459 at 4/30/20, 6:51 AM:

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

2020-04-29 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096221#comment-17096221 ] ranqiqiang commented on FLINK-17459: Thanks , Maybe I did wrong ! use JDBCUpsertTabl

[jira] [Reopened] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-17315: The timeout increase does not seem to solve the issue: https://dev.azure.com/apache-flink/apa

[jira] [Updated] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17315: --- Affects Version/s: 1.11.0 > UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassiv

[jira] [Updated] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode

2020-04-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-17472: --- Attachment: demo.png > StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode > --

[jira] [Created] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode

2020-04-29 Thread RocMarshal (Jira)
RocMarshal created FLINK-17472: -- Summary: StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode Key: FLINK-17472 URL: https://issues.apache.org/jira/browse/FLINK-17472 Project: Flink

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-04-29 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096213#comment-17096213 ] Yun Tang commented on FLINK-16850: -- [~NicoK] Thanks for you suggestion. However, after

[jira] [Commented] (FLINK-17086) Flink sql client not able to read parquet hive table because `HiveMapredSplitReader` not supports name mapping reading for parquet format.

2020-04-29 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096214#comment-17096214 ] Rui Li commented on FLINK-17086: [~leiwangouc], the latest code by default uses vectoriz

[GitHub] [flink] flinkbot edited a comment on pull request #11944: [FLINK-17461][formats][json] Support JSON serialization and deseriazation schema for RowData type

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11944: URL: https://github.com/apache/flink/pull/11944#issuecomment-621136570 ## CI report: * 8afc7b3913e499329d7b71a540c04eb03a42027c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162741908) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11955: [FLINK-17255][python] Add HBase connector descriptor support in PyFlink.

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11955: URL: https://github.com/apache/flink/pull/11955#issuecomment-621638743 ## CI report: * 66b16932c3d2e8b9914151f90afb704501b2a4c1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * b327e090361356ccaeb0b2ec4101f3e87152f597 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162875470) Azure: [PENDING](htt

[GitHub] [flink] rmetzger commented on pull request #11697: [hotfix][docs] fix some typos in elasticsearch connector

2020-04-29 Thread GitBox
rmetzger commented on pull request #11697: URL: https://github.com/apache/flink/pull/11697#issuecomment-621642005 Merged to master in https://github.com/apache/flink/commit/774132a4a5e7789eba3257c284dc899ef16e4e01 This is an

[GitHub] [flink] wuchong commented on a change in pull request #11944: [FLINK-17461][formats][json] Support JSON serialization and deseriazation schema for RowData type

2020-04-29 Thread GitBox
wuchong commented on a change in pull request #11944: URL: https://github.com/apache/flink/pull/11944#discussion_r417785164 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java ## @@ -0,0 +1,322 @@ +/* + * Licen

[GitHub] [flink] rmetzger edited a comment on pull request #11697: [hotfix][docs] fix some typos in elasticsearch connector

2020-04-29 Thread GitBox
rmetzger edited a comment on pull request #11697: URL: https://github.com/apache/flink/pull/11697#issuecomment-621640808 Thanks a lot for this fix. Merging. The example in the docs is indeed wrong: https://github.com/apache/flink/blob/release-1.10/flink-connectors/flink-connector-ela

[GitHub] [flink] rmetzger commented on pull request #11697: [hotfix][docs] fix some typos in elasticsearch connector

2020-04-29 Thread GitBox
rmetzger commented on pull request #11697: URL: https://github.com/apache/flink/pull/11697#issuecomment-621640808 Thanks a lot for this fix. Merging. The example in the docs is indeed wrong: https://github.com/apache/flink/blob/c93205b4abe643d6dd798c3180d68ab8d02eded5/flink-connector

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

2020-04-29 Thread GitBox
KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r417782697 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/ResourceInformationReflector.java ## @@ -0,0 +1,99 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [flink] rmetzger commented on pull request #11923: [FLINK-17401] Add Labels to the mesos task info

2020-04-29 Thread GitBox
rmetzger commented on pull request #11923: URL: https://github.com/apache/flink/pull/11923#issuecomment-621639318 It would be nice if you could add a test that ensures configured labels are properly forwarded / set in Mesos. If there's no good test in the java codebase, you could consider

[GitHub] [flink] zhengcanbin commented on pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
zhengcanbin commented on pull request #11949: URL: https://github.com/apache/flink/pull/11949#issuecomment-621638969 cc @TisonKun. Could you help review this PR? Thanks a lot! This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #11955: [FLINK-17255][python] Add HBase connector descriptor support in PyFlink.

2020-04-29 Thread GitBox
flinkbot commented on pull request #11955: URL: https://github.com/apache/flink/pull/11955#issuecomment-621638743 ## CI report: * 66b16932c3d2e8b9914151f90afb704501b2a4c1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #11951: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11951: URL: https://github.com/apache/flink/pull/11951#issuecomment-621585351 ## CI report: * 38b17d3e6bb0dff3d2a383ed066f23bc3c2dce4f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862304) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * 5ad770fdd8fba58add55a62ed89e99ff6b9a14cf Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162863899) Azure: [PENDING](htt

[GitHub] [flink] flinkbot edited a comment on pull request #11950: [Flink-17030] Add primary key syntax to DDL

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621585318 ## CI report: * c6ff889b90a10f70a7429597a2473468de2a0cce Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862286) Azure: [FAILURE](http

[jira] [Commented] (FLINK-17401) Add Labels to Mesos TM taskinfo object

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096185#comment-17096185 ] Robert Metzger commented on FLINK-17401: Thanks for this contribution. I assigne

[jira] [Updated] (FLINK-17401) Add Labels to Mesos TM taskinfo object

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17401: --- Issue Type: Improvement (was: Bug) > Add Labels to Mesos TM taskinfo object >

[GitHub] [flink] rmetzger commented on pull request #11923: [FLINK-17401] Add Labels to the mesos task info

2020-04-29 Thread GitBox
rmetzger commented on pull request #11923: URL: https://github.com/apache/flink/pull/11923#issuecomment-621637411 Thanks a lot for this contribution. Our CI system found one issue with the docs ``` Option mesos.resourcemanager.tasks.labels in class org.apache.flink.m

[jira] [Assigned] (FLINK-17401) Add Labels to Mesos TM taskinfo object

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17401: -- Assignee: chaganti spurthi > Add Labels to Mesos TM taskinfo object > --

[GitHub] [flink] flinkbot commented on pull request #11955: [FLINK-17255][python] Add HBase connector descriptor support in PyFlink.

2020-04-29 Thread GitBox
flinkbot commented on pull request #11955: URL: https://github.com/apache/flink/pull/11955#issuecomment-621636760 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-17255) Add HBase connector descriptor support in PyFlink

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17255: --- Labels: beginners pull-request-available (was: beginners) > Add HBase connector descriptor

[GitHub] [flink] shuiqiangchen opened a new pull request #11955: [FLINK-17255][python] Add HBase connector descriptor support in PyFlink.

2020-04-29 Thread GitBox
shuiqiangchen opened a new pull request #11955: URL: https://github.com/apache/flink/pull/11955 ## What is the purpose of the change HBase connector descriptor is already supported since 1.10.0 at Java side. We should also support it in PyFlink. ## Brief change log

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096171#comment-17096171 ] Robert Metzger commented on FLINK-17471: In my opinion, I would move the apache

[jira] [Comment Edited] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096171#comment-17096171 ] Robert Metzger edited comment on FLINK-17471 at 4/30/20, 6:16 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #11951: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11951: URL: https://github.com/apache/flink/pull/11951#issuecomment-621585351 ## CI report: * 38b17d3e6bb0dff3d2a383ed066f23bc3c2dce4f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862304) Azure: [PENDING](http

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 7f9ea6e4f4a506644e8c79d54eea8cad98b0a6a3 UNKNOWN * 75f0fcc317aa9a1f27a44f321cf4c9428c615017 UNKNOWN * 749e3afe1611507463f2a34492de8d8f3c65

[GitHub] [flink] wangyang0918 commented on a change in pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-29 Thread GitBox
wangyang0918 commented on a change in pull request #11903: URL: https://github.com/apache/flink/pull/11903#discussion_r417760141 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnDeploymentTargetNames.java ## @@ -0,0 +1,44 @@ +/* + * Licensed to the A

[jira] [Comment Edited] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096161#comment-17096161 ] Wei Zhong edited comment on FLINK-17471 at 4/30/20, 6:01 AM: -

[jira] [Comment Edited] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096161#comment-17096161 ] Wei Zhong edited comment on FLINK-17471 at 4/30/20, 6:00 AM: -

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096161#comment-17096161 ] Wei Zhong commented on FLINK-17471: --- Hi [~chesnay]  [~rmetzger], in current structure

[jira] [Updated] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17471: -- Attachment: image-2020-04-30-13-57-28-072.png > Move LICENSE and NOTICE files to root directory of pyt

[GitHub] [flink] flinkbot edited a comment on pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11949: URL: https://github.com/apache/flink/pull/11949#issuecomment-621570408 ## CI report: * 95dba088b53d2af086a56ccc04ad890c959f9a4b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162857048) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11950: [Flink-17030] Add primary key syntax to DDL

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621585318 ## CI report: * c6ff889b90a10f70a7429597a2473468de2a0cce Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862286) Azure: [PENDING](http

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 7f9ea6e4f4a506644e8c79d54eea8cad98b0a6a3 UNKNOWN * 75f0fcc317aa9a1f27a44f321cf4c9428c615017 UNKNOWN * 749e3afe1611507463f2a34492de8d8f3c65

[GitHub] [flink] flinkbot edited a comment on pull request #9097: [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #9097: URL: https://github.com/apache/flink/pull/9097#issuecomment-621619875 ## CI report: * a4cd0df8a0e827e7839ac00652d56193797846d5 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162877152) Bot commands

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-04-29 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096144#comment-17096144 ] Nico Kruber commented on FLINK-16850: - The first commit needs to go into the Apache

[GitHub] [flink] wangyang0918 commented on a change in pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-29 Thread GitBox
wangyang0918 commented on a change in pull request #11903: URL: https://github.com/apache/flink/pull/11903#discussion_r417759683 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnDeploymentTargetNames.java ## @@ -0,0 +1,44 @@ +/* + * Licensed to the A

[GitHub] [flink] flinkbot edited a comment on pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11590: URL: https://github.com/apache/flink/pull/11590#issuecomment-607068581 ## CI report: * d50723d3a6ed9239e26ec37cb421db586c99 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862172) Azure: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * 5ad770fdd8fba58add55a62ed89e99ff6b9a14cf Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162863899) Azure: [PENDING](htt

[GitHub] [flink] flinkbot edited a comment on pull request #11844: [FLINK-17125][python][doc] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11844: URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959 ## CI report: * 9406a47d278c766f5f7f868d4f07226761b06690 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162858624) Bot comman

[GitHub] [flink] flinkbot edited a comment on pull request #11954: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11954: URL: https://github.com/apache/flink/pull/11954#issuecomment-621615631 ## CI report: * 6a37ff126c35f1d7b35fb50ccff89f200967b2da Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162875532) Bot comman

[GitHub] [flink] flinkbot commented on pull request #9097: [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

2020-04-29 Thread GitBox
flinkbot commented on pull request #9097: URL: https://github.com/apache/flink/pull/9097#issuecomment-621619875 ## CI report: * a4cd0df8a0e827e7839ac00652d56193797846d5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] XBaith commented on pull request #11937: [FLINK-16097][docs-zh] Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-29 Thread GitBox
XBaith commented on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-621619105 Hi,@klion26.Please review this if you are free.Thank you This is an automated message from the Apache Git Service

[GitHub] [flink] XBaith edited a comment on pull request #11937: [FLINK-16097][docs-zh] Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-29 Thread GitBox
XBaith edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-621619105 Hi, @klion26 .Please review this if you are free.Thank you This is an automated message from the Apache Gi

[GitHub] [flink] XBaith commented on pull request #9097: [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

2020-04-29 Thread GitBox
XBaith commented on pull request #9097: URL: https://github.com/apache/flink/pull/9097#issuecomment-621618293 You need update your pull request. More information, see: https://www.bilibili.com/video/BV1kK411577L?from=search&seid=16883785088266459960 -

[GitHub] [flink] XBaith commented on a change in pull request #9097: [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

2020-04-29 Thread GitBox
XBaith commented on a change in pull request #9097: URL: https://github.com/apache/flink/pull/9097#discussion_r417755148 ## File path: docs/getting-started/tutorials/datastream_api.zh.md ## @@ -203,26 +178,20 @@ DataStream> result = keyedEdits }); {% endhighlight %} -Th

[GitHub] [flink] flinkbot edited a comment on pull request #11953: [FLINK-16975][doc] Add docs for FileSystem connector

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11953: URL: https://github.com/apache/flink/pull/11953#issuecomment-621608702 ## CI report: * c50145cf1802b4265bde068a812c9abce18be5e1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #11954: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot commented on pull request #11954: URL: https://github.com/apache/flink/pull/11954#issuecomment-621615631 ## CI report: * 6a37ff126c35f1d7b35fb50ccff89f200967b2da UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * 06e24237fde5862fa1c667eea53800920db37147 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161590556) Azure: [FAILURE](http

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096135#comment-17096135 ] Yu Li commented on FLINK-17471: --- Thanks for the quick response [~dian.fu]! > Move LICENSE

[GitHub] [flink] flinkbot edited a comment on pull request #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #9782: URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * 0f20a7952d54037d7505d5517556c25fd7ba7e32 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096133#comment-17096133 ] Dian Fu commented on FLINK-17471: - [~liyu] Thanks for filing this ticket. I will take a

[jira] [Updated] (FLINK-17359) Entropy key is not resolved if flink-s3-fs-hadoop is added as a plugin

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17359: -- Fix Version/s: (was: 1.10.2) 1.10.1 Change the fix version to 1.10.1 since we will have

[jira] [Comment Edited] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096132#comment-17096132 ] Yu Li edited comment on FLINK-17308 at 4/30/20, 5:03 AM: - Thanks

[jira] [Updated] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17308: -- Fix Version/s: (was: 1.10.2) 1.10.1 Change the fix version back to 1.10.1 since we will

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096131#comment-17096131 ] Yu Li commented on FLINK-17471: --- [~jincheng] [~hequn8128] [~dianfu] could you take a look

[jira] [Created] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Yu Li (Jira)
Yu Li created FLINK-17471: - Summary: Move LICENSE and NOTICE files to root directory of python distribution Key: FLINK-17471 URL: https://issues.apache.org/jira/browse/FLINK-17471 Project: Flink Iss

[GitHub] [flink] flinkbot commented on pull request #11954: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot commented on pull request #11954: URL: https://github.com/apache/flink/pull/11954#issuecomment-621611564 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] leonardBang opened a new pull request #11954: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
leonardBang opened a new pull request #11954: URL: https://github.com/apache/flink/pull/11954 ## What is the purpose of the change *This pull request fix `byPosition` mode judgement in FieldInfoUtils to support reorder and reorder field properly.* ## Brief change l

[GitHub] [flink] flinkbot edited a comment on pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11949: URL: https://github.com/apache/flink/pull/11949#issuecomment-621570408 ## CI report: * 95dba088b53d2af086a56ccc04ad890c959f9a4b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162857048) Azure: [PENDING](http

[GitHub] [flink] flinkbot commented on pull request #11953: [FLINK-16975][doc] Add docs for FileSystem connector

2020-04-29 Thread GitBox
flinkbot commented on pull request #11953: URL: https://github.com/apache/flink/pull/11953#issuecomment-621608702 ## CI report: * c50145cf1802b4265bde068a812c9abce18be5e1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] HuangXingBo commented on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
HuangXingBo commented on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-621607982 Thanks a lot for @sjwiesman review. Before you help review, I made relatively large changes to the content of this document, I put these in the fix commit. Then based on you

[jira] [Commented] (FLINK-17086) Flink sql client not able to read parquet hive table because `HiveMapredSplitReader` not supports name mapping reading for parquet format.

2020-04-29 Thread Lei Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096121#comment-17096121 ] Lei Wang commented on FLINK-17086: -- Hi [~lirui], I build package from the latest code f

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

2020-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096120#comment-17096120 ] Jark Wu commented on FLINK-17459: - {code:java} sink.setIsAppendOnly(true); sink.setKeyF

[GitHub] [flink] flinkbot commented on pull request #11953: [FLINK-16975][doc] Add docs for FileSystem connector

2020-04-29 Thread GitBox
flinkbot commented on pull request #11953: URL: https://github.com/apache/flink/pull/11953#issuecomment-621605543 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] HuangXingBo commented on a change in pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
HuangXingBo commented on a change in pull request #11878: URL: https://github.com/apache/flink/pull/11878#discussion_r417746331 ## File path: docs/dev/table/python/usage_notes.md ## @@ -0,0 +1,120 @@ +--- +title: "Usage Notes" +nav-parent_id: python_tableapi +nav-pos: 140 +---

[jira] [Closed] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

2020-04-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15591. -- Resolution: Fixed master: dca4a774ff75cb6d79d0c825311a56e151357027 > make up for feature parity by su

[GitHub] [flink] HuangXingBo commented on a change in pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
HuangXingBo commented on a change in pull request #11878: URL: https://github.com/apache/flink/pull/11878#discussion_r417746202 ## File path: docs/dev/table/python/usage_notes.md ## @@ -0,0 +1,120 @@ +--- +title: "Usage Notes" Review comment: Yes. Make sense. --

[jira] [Updated] (FLINK-16975) Add docs for FileSystem connector

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16975: --- Labels: pull-request-available (was: ) > Add docs for FileSystem connector > --

[GitHub] [flink] JingsongLi opened a new pull request #11953: [FLINK-16975][doc] Add docs for FileSystem connector

2020-04-29 Thread GitBox
JingsongLi opened a new pull request #11953: URL: https://github.com/apache/flink/pull/11953 ## What is the purpose of the change Add docs for the new file system connector ## Brief change log - Add docs for the new file system connector - Remove old filesystem do

[jira] [Updated] (FLINK-16975) Add docs for FileSystem connector

2020-04-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16975: - Summary: Add docs for FileSystem connector (was: Add docs for FileSystem connector and hive con

[jira] [Assigned] (FLINK-16975) Add docs for FileSystem connector and hive connector

2020-04-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16975: Assignee: Jingsong Lee > Add docs for FileSystem connector and hive connector > -

[GitHub] [flink] KurtYoung commented on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

2020-04-29 Thread GitBox
KurtYoung commented on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-621603904 run mvn verify locally and passed This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * e2f1b05a35fa8d43aa04cafbecc0333680b09a37 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11932: [FLINK-17423][python] Support Python UDTF in blink planner under batch mode

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11932: URL: https://github.com/apache/flink/pull/11932#issuecomment-620543031 ## CI report: * a90b4df7b90946f2bd365ab8dc867958b2779047 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162636684) Azure: [SUCCESS](http

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096108#comment-17096108 ] chun11 commented on FLINK-17447: [~aljoscha] I think the static code  for create

[GitHub] [flink] flinkbot edited a comment on pull request #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #9782: URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * fda598e2a49de6d1d89ce6e3d9ec5ff2a1d2da7c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160824816) Azure: [FAILURE](https:

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096093#comment-17096093 ] chun11 commented on FLINK-17447: in the job, one datastream math with five CEP P

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * 06e24237fde5862fa1c667eea53800920db37147 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161590556) Azure: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * e2f1b05a35fa8d43aa04cafbecc0333680b09a37 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096087#comment-17096087 ] chun11 commented on FLINK-17447: TwoStagePatternedRule is a enum :   public en

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096085#comment-17096085 ] chun11 commented on FLINK-17447:   import java.util.ArrayList; import java.util.

[GitHub] [flink] flinkbot edited a comment on pull request #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #9782: URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * fda598e2a49de6d1d89ce6e3d9ec5ff2a1d2da7c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160824816) Azure: [FAILURE](https:

[jira] [Updated] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chun11 updated FLINK-17447: --- Attachment: image-2020-04-30-11-37-20-411.png > Flink CEPOperator StateException > -

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-04-29 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096083#comment-17096083 ] Yun Tang commented on FLINK-16850: -- [~pnowojski], I found I cannot fork or create PR to

  1   2   3   4   >