[jira] [Commented] (FLINK-16492) Flink SQL can not read decimal in hive parquet

2020-03-15 Thread xingoo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059991#comment-17059991 ] xingoo commented on FLINK-16492: I use the jars in hive version 1.2.2(replace the versio

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392800869 ## File path: docs/ops/memory/mem_tuning.zh.md ## @@ -22,66 +22,55 @@ speci

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392801162 ## File path: docs/ops/memory/mem_tuning.zh.md ## @@ -22,66 +22,55 @@ speci

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392805878 ## File path: docs/ops/memory/mem_migration.zh.md ## @@ -121,116 +117,105 @

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392803707 ## File path: docs/ops/memory/mem_trouble.zh.md ## @@ -27,48 +27,43 @@ unde

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392801817 ## File path: docs/ops/memory/mem_trouble.zh.md ## @@ -27,48 +27,43 @@ unde

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392803428 ## File path: docs/ops/memory/mem_trouble.zh.md ## @@ -27,48 +27,43 @@ unde

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392811503 ## File path: docs/ops/memory/mem_migration.zh.md ## @@ -121,116 +117,105 @

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392800746 ## File path: docs/ops/memory/mem_tuning.zh.md ## @@ -22,66 +22,55 @@ speci

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392805918 ## File path: docs/ops/memory/mem_migration.zh.md ## @@ -121,116 +117,105 @

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392810899 ## File path: docs/ops/memory/mem_migration.zh.md ## @@ -121,116 +117,105 @

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392804787 ## File path: docs/ops/memory/mem_migration.zh.md ## @@ -22,67 +22,63 @@ sp

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392803199 ## File path: docs/ops/memory/mem_trouble.zh.md ## @@ -27,48 +27,43 @@ unde

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese.

2020-03-15 Thread GitBox
KarmaGYZ commented on a change in pull request #11401: [FLINK-15991][doc][zh] Translate memory configuration docs into Chinese. URL: https://github.com/apache/flink/pull/11401#discussion_r392809260 ## File path: docs/ops/memory/mem_migration.zh.md ## @@ -121,116 +117,105 @

[jira] [Assigned] (FLINK-16603) statefun-quickstart generates invalid pom.xml

2020-03-15 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-16603: --- Assignee: Tzu-Li (Gordon) Tai > statefun-quickstart generates invalid pom.x

[jira] [Closed] (FLINK-16254) Support -p/--parallelism option for StatefulFunctionsClusterEntryPoint

2020-03-15 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16254. --- Fix Version/s: statefun-1.1 Resolution: Fixed Merged for master via 05888397d

[GitHub] [flink-statefun] tzulitai closed pull request #58: [FLINK-16254] Support -p / --parallelism command option

2020-03-15 Thread GitBox
tzulitai closed pull request #58: [FLINK-16254] Support -p / --parallelism command option URL: https://github.com/apache/flink-statefun/pull/58 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink-statefun] tzulitai commented on issue #58: [FLINK-16254] Support -p / --parallelism command option

2020-03-15 Thread GitBox
tzulitai commented on issue #58: [FLINK-16254] Support -p / --parallelism command option URL: https://github.com/apache/flink-statefun/pull/58#issuecomment-599369577 Thanks for the review Igal! Merging ... This is an autom

[GitHub] [flink] flinkbot commented on issue #11413: [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information

2020-03-15 Thread GitBox
flinkbot commented on issue #11413: [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information URL: https://github.com/apache/flink/pull/11413#issuecomment-599369458 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the comm

[GitHub] [flink] dianfu opened a new pull request #11413: [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information

2020-03-15 Thread GitBox
dianfu opened a new pull request #11413: [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information URL: https://github.com/apache/flink/pull/11413 ## What is the purpose of the change *Currently the following information is missing in flink-fn-execution

[jira] [Updated] (FLINK-16607) Update flink-fn-execution.proto adding more schema information

2020-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16607: --- Labels: pull-request-available (was: ) > Update flink-fn-execution.proto adding more schema

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-15 Thread GitBox
ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r392803884 ## File path: flink-runtime/src/main/java/org/apac

[GitHub] [flink] zhule0601 commented on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
zhule0601 commented on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#issuecomment-599367348 @lirui-apache Hi lirui, I think your suggestion about the word `Catalog` is correct and I have pushed the code

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-15 Thread GitBox
ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r392801274 ## File path: flink-runtime/src/main/java/org/apac

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable

2020-03-15 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059974#comment-17059974 ] Zhijiang commented on FLINK-12030: -- Another failure instance  [https://dev.azure.com/rm

[GitHub] [flink] lirui-apache commented on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#issuecomment-599356484 @zhule0601 Thanks for updating. I think we can just use the English word for `Catalog`, no need to translate

[GitHub] [flink] flinkbot commented on issue #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

2020-03-15 Thread GitBox
flinkbot commented on issue #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11412#issuecomment-599352822 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] zhule0601 commented on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
zhule0601 commented on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#issuecomment-599352444 @lirui-apache Thank you for your review!I made some changes based on your suggestions.It would be great if you c

[jira] [Updated] (FLINK-16454) Update the copyright year in NOTICE files

2020-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16454: --- Labels: pull-request-available (was: ) > Update the copyright year in NOTICE files > --

[GitHub] [flink] zhijiangW opened a new pull request #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

2020-03-15 Thread GitBox
zhijiangW opened a new pull request #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11412 ## What is the purpose of the change The current copyright year is 2014-2019 in NOTICE files. We should change it

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-15 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392771442 ## File path: flink-table/flink-table-planner-blink/pom.xml ## @@ -149,20 +138,30 @@ un

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-15 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392771442 ## File path: flink-table/flink-table-planner-blink/pom.xml ## @@ -149,20 +138,30 @@ un

[jira] [Commented] (FLINK-15871) Support to start sidecar container

2020-03-15 Thread yan234280533 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059946#comment-17059946 ] yan234280533 commented on FLINK-15871: -- [~fly_in_gis]  Hi, yang. what tools and fea

[GitHub] [flink] zhengcanbin commented on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

2020-03-15 Thread GitBox
zhengcanbin commented on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406#issuecomment-599341155 @flinkbot run travis --

[jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI

2020-03-15 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16609: --- Description: The SQL-CLI now outputs the column name as the name that comes from the plan, which is

[jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI

2020-03-15 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16609: --- Description: The SQL-CLI now outputs the column name as the name that comes from the plan, which is

[jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI

2020-03-15 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16609: --- Description: The SQL-CLI now outputs the column name as the name that comes from the plan, which is

[jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI

2020-03-15 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16609: --- Description: The SQL-CLI now outputs the column name as the name that comes from the plan, which is

[GitHub] [flink] danny0405 commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-15 Thread GitBox
danny0405 commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-599339761 > > > Thanks @danny0405 so much for this huge work, I left some comments. I notice there are a lot of alias name in the pl

[GitHub] [flink] zhijiangW commented on a change in pull request #11400: [FLINK-16586][network] Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

2020-03-15 Thread GitBox
zhijiangW commented on a change in pull request #11400: [FLINK-16586][network] Build ResultSubpartitionInfo and InputChannelInfo in respective constructors URL: https://github.com/apache/flink/pull/11400#discussion_r39241 ## File path: flink-runtime/src/main/java/org/apache/fli

[jira] [Created] (FLINK-16609) Promotes the column name representation of SQL-CLI

2020-03-15 Thread Danny Chen (Jira)
Danny Chen created FLINK-16609: -- Summary: Promotes the column name representation of SQL-CLI Key: FLINK-16609 URL: https://issues.apache.org/jira/browse/FLINK-16609 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-16599) Throw Unknown identifier when having nested computed column

2020-03-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059940#comment-17059940 ] Jark Wu commented on FLINK-16599: - Under the hood, the computed columns can be thought a

[jira] [Closed] (FLINK-16599) Throw Unknown identifier when having nested computed column

2020-03-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16599. --- Resolution: Not A Problem > Throw Unknown identifier when having nested computed column > --

[jira] [Comment Edited] (FLINK-16599) Throw Unknown identifier when having nested computed column

2020-03-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059937#comment-17059937 ] Jark Wu edited comment on FLINK-16599 at 3/16/20, 4:20 AM: --- Th

[jira] [Commented] (FLINK-16599) Throw Unknown identifier when having nested computed column

2020-03-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059937#comment-17059937 ] Jark Wu commented on FLINK-16599: - This is not allowed by design, you can find the descr

[jira] [Updated] (FLINK-16600) Respect the rest.bind-port for the Kubernetes setup

2020-03-15 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16600: - Description: Our current logic only takes care of {{RestOptions.PORT}} but not {{RestOptions.BI

[jira] [Commented] (FLINK-16601) Corret the way to get Endpoint address for NodePort rest Service

2020-03-15 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059932#comment-17059932 ] Canbin Zheng commented on FLINK-16601: -- Hi [~fly_in_gis].  Internally we use the K

[GitHub] [flink] lirui-apache commented on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#issuecomment-599334595 @zhule0601 Thanks for working on this! I went through the PR and left some comments. ---

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392772383 ## File path: docs/dev/table/catalogs.zh.md ## @@ -299,12 +299,12 @@ catal

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392770135 ## File path: docs/dev/table/catalogs.zh.md ## @@ -22,44 +22,44 @@ specifi

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392768704 ## File path: docs/dev/table/catalogs.zh.md ## @@ -1,5 +1,5 @@ --- -title

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392771823 ## File path: docs/dev/table/catalogs.zh.md ## @@ -22,44 +22,44 @@ specifi

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392770476 ## File path: docs/dev/table/catalogs.zh.md ## @@ -22,44 +22,44 @@ specifi

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392771384 ## File path: docs/dev/table/catalogs.zh.md ## @@ -22,44 +22,44 @@ specifi

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392769647 ## File path: docs/dev/table/catalogs.zh.md ## @@ -22,44 +22,44 @@ specifi

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392772023 ## File path: docs/dev/table/catalogs.zh.md ## @@ -96,11 +96,11 @@ Flink S

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392769111 ## File path: docs/dev/table/catalogs.zh.md ## @@ -22,44 +22,44 @@ specifi

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392769913 ## File path: docs/dev/table/catalogs.zh.md ## @@ -22,44 +22,44 @@ specifi

[GitHub] [flink] lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

2020-03-15 Thread GitBox
lirui-apache commented on a change in pull request #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#discussion_r392768847 ## File path: docs/dev/table/catalogs.zh.md ## @@ -22,44 +22,44 @@ specifi

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-15 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392771627 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planne

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-15 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392771442 ## File path: flink-table/flink-table-planner-blink/pom.xml ## @@ -149,20 +138,30 @@ un

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-15 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392770922 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner

[GitHub] [flink] zhengcanbin opened a new pull request #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

2020-03-15 Thread GitBox
zhengcanbin opened a new pull request #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406 ## What is the purpose of the change Switch from string type to enum type for con

[GitHub] [flink] zhengcanbin closed pull request #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

2020-03-15 Thread GitBox
zhengcanbin closed pull request #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406 This is an automated messag

[GitHub] [flink] zhengcanbin commented on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod

2020-03-15 Thread GitBox
zhengcanbin commented on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod URL: https://github.com/apache/flink/pull/11360#issuecomment-599329666 > Thanks for your contribution @zhengcanbin ! It seems we should also include this improvement in 1.10, would

[jira] [Resolved] (FLINK-16541) Document of table.exec.shuffle-mode is incorrect

2020-03-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16541. -- Fix Version/s: 1.11.0 1.10.1 Resolution: Fixed master: 328193db25a08

[jira] [Commented] (FLINK-16602) Rework the Service design for Kubernetes deployment

2020-03-15 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059924#comment-17059924 ] Canbin Zheng commented on FLINK-16602: -- Hi, [~fly_in_gis]. Thanks for the reponse.

[jira] [Updated] (FLINK-16607) Update flink-fn-execution.proto adding more schema information

2020-03-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16607: Description: Currently the following information is missing in flink-fn-execution.proto: - the length for

[jira] [Comment Edited] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059919#comment-17059919 ] Yangze Guo edited comment on FLINK-16605 at 3/16/20, 3:06 AM:

[jira] [Created] (FLINK-16608) Support primitive data types for vectorized Python UDF

2020-03-15 Thread Dian Fu (Jira)
Dian Fu created FLINK-16608: --- Summary: Support primitive data types for vectorized Python UDF Key: FLINK-16608 URL: https://issues.apache.org/jira/browse/FLINK-16608 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059919#comment-17059919 ] Yangze Guo commented on FLINK-16605: Could some kindly assign this to me? I'd like t

[jira] [Created] (FLINK-16607) Update flink-fn-execution.proto adding more schema information

2020-03-15 Thread Dian Fu (Jira)
Dian Fu created FLINK-16607: --- Summary: Update flink-fn-execution.proto adding more schema information Key: FLINK-16607 URL: https://issues.apache.org/jira/browse/FLINK-16607 Project: Flink Issue T

[jira] [Updated] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16605: --- Description: As discussed in FLINK-15527 and FLINK-15959, we propose to add the max limit to the to

[jira] [Created] (FLINK-16606) Throw exceptions for the data types which are not currently supported

2020-03-15 Thread Dian Fu (Jira)
Dian Fu created FLINK-16606: --- Summary: Throw exceptions for the data types which are not currently supported Key: FLINK-16606 URL: https://issues.apache.org/jira/browse/FLINK-16606 Project: Flink

[jira] [Updated] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16605: --- Description: As discussed in FLINK-15527 and FLINK-15959, we propose to add the max limit to the to

[jira] [Updated] (FLINK-15959) Add min number of slots configuration to limit total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15959: --- Summary: Add min number of slots configuration to limit total number of slots (was: Add min/max num

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059911#comment-17059911 ] Yangze Guo commented on FLINK-15959: FYI: As there is no response for nearly two wee

[jira] [Created] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-16605: -- Summary: Add max limitation to the total number of slots Key: FLINK-16605 URL: https://issues.apache.org/jira/browse/FLINK-16605 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-16508) Name the ports exposed by the main Container in Pod

2020-03-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059904#comment-17059904 ] Zili Chen commented on FLINK-16508: --- master(1.11) via 3d119079288f3e9da7a19a32d68446ae

[GitHub] [flink] JingsongLi merged pull request #11386: [FLINK-16541][doc] Fix document of table.exec.shuffle-mode

2020-03-15 Thread GitBox
JingsongLi merged pull request #11386: [FLINK-16541][doc] Fix document of table.exec.shuffle-mode URL: https://github.com/apache/flink/pull/11386 This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [flink] TisonKun merged pull request #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod

2020-03-15 Thread GitBox
TisonKun merged pull request #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod URL: https://github.com/apache/flink/pull/11360 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] TisonKun commented on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod

2020-03-15 Thread GitBox
TisonKun commented on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod URL: https://github.com/apache/flink/pull/11360#issuecomment-599311569 Thanks for your contribution @zhengcanbin ! It seems we should also include this improvement in 1.10, would you

[jira] [Commented] (FLINK-16601) Corret the way to get Endpoint address for NodePort rest Service

2020-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059892#comment-17059892 ] Yang Wang commented on FLINK-16601: --- You are right. If deploying on a managed K8s clus

[GitHub] [flink] JingsongLi commented on a change in pull request #11405: [FLINK-16413]Reduce hive source parallelism when limit push down

2020-03-15 Thread GitBox
JingsongLi commented on a change in pull request #11405: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11405#discussion_r392748765 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connect

[GitHub] [flink] JingsongLi commented on a change in pull request #11405: [FLINK-16413]Reduce hive source parallelism when limit push down

2020-03-15 Thread GitBox
JingsongLi commented on a change in pull request #11405: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11405#discussion_r392751442 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connect

[GitHub] [flink] JingsongLi commented on a change in pull request #11405: [FLINK-16413]Reduce hive source parallelism when limit push down

2020-03-15 Thread GitBox
JingsongLi commented on a change in pull request #11405: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11405#discussion_r392751769 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connect

[GitHub] [flink] JingsongLi merged pull request #11399: [hotfix][docs] fix mistakes in Modules document

2020-03-15 Thread GitBox
JingsongLi merged pull request #11399: [hotfix][docs] fix mistakes in Modules document URL: https://github.com/apache/flink/pull/11399 This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] lukess edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

2020-03-15 Thread GitBox
lukess edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-599260370 thanks @aljoscha @zentol Because I'm using this reporter in our production I also add filter to control the cos

[GitHub] [flink] flinkbot commented on issue #11411: [hotfix] [docs] Fix typo in DataStream API walkthrough

2020-03-15 Thread GitBox
flinkbot commented on issue #11411: [hotfix] [docs] Fix typo in DataStream API walkthrough URL: https://github.com/apache/flink/pull/11411#issuecomment-599271922 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[GitHub] [flink] mattwelke opened a new pull request #11411: [hotfix] [docs] Fix typo in DataStream API walkthrough

2020-03-15 Thread GitBox
mattwelke opened a new pull request #11411: [hotfix] [docs] Fix typo in DataStream API walkthrough URL: https://github.com/apache/flink/pull/11411 ## Documentation - Does this pull request introduce a new feature? no

[GitHub] [flink] lukess commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

2020-03-15 Thread GitBox
lukess commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-599260370 thanks @aljoscha @zentol Because I'm using this reporter in our production I also add filter to control the cost. ---

[jira] [Updated] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16604: --- Priority: Minor (was: Major) > Column key in JM configuration is too narrow > -

[jira] [Commented] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059711#comment-17059711 ] Jeff Zhang commented on FLINK-16604: \cc [~vthinkxie] > Column key in JM configurat

[jira] [Commented] (FLINK-16602) Rework the Service design for Kubernetes deployment

2020-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059706#comment-17059706 ] Yang Wang commented on FLINK-16602: --- [~felixzheng] Thanks for creating this ticket and

[jira] [Updated] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16604: --- Attachment: (was: image-2020-03-15-22-21-17-369.png) > Column key in JM configuration is too nar

[jira] [Commented] (FLINK-14938) Flink elasticsearch failure handler re-add indexrequest causes ConcurrentModificationException

2020-03-15 Thread Shengnan YU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059695#comment-17059695 ] Shengnan YU commented on FLINK-14938: - The easiest way to solve this issue is to use

[jira] [Updated] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16604: --- Description: See the screenshot   !image-2020-03-15-22-22-01-696.png! was: See the screenshot

[jira] [Updated] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-16604: --- Attachment: image-2020-03-15-22-22-01-696.png > Column key in JM configuration is too narrow > -

[jira] [Created] (FLINK-16604) Column key in JM configuration is too narrow

2020-03-15 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-16604: -- Summary: Column key in JM configuration is too narrow Key: FLINK-16604 URL: https://issues.apache.org/jira/browse/FLINK-16604 Project: Flink Issue Type: Improvem

[GitHub] [flink] flinkbot commented on issue #11410: [FLINK-16567][Documentation] Get the API error of the StreamQueryConf…

2020-03-15 Thread GitBox
flinkbot commented on issue #11410: [FLINK-16567][Documentation] Get the API error of the StreamQueryConf… URL: https://github.com/apache/flink/pull/11410#issuecomment-599213146 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

  1   2   >