[GitHub] [flink] wangyang0918 commented on a change in pull request #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod

wangyang0918 commented on a change in pull request #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod URL: https://github.com/apache/flink/pull/11606#discussion_r407348177 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/

[GitHub] [flink] wangyang0918 commented on issue #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod

wangyang0918 commented on issue #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod URL: https://github.com/apache/flink/pull/11606#issuecomment-612783189 @TisonKun Thanks for your review. I have integrated your comments and force pushed the PR. Please h

[GitHub] [flink] KurtYoung commented on a change in pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

KurtYoung commented on a change in pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#discussion_r407349672 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] KurtYoung commented on a change in pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

KurtYoung commented on a change in pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#discussion_r407348957 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] KurtYoung commented on a change in pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

KurtYoung commented on a change in pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#discussion_r407348519 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] KurtYoung commented on a change in pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

KurtYoung commented on a change in pull request #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#discussion_r407351865 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 59ab8cedf26f3b55602b448951fa18e8e7997bb5 Travis: [FAI

[jira] [Created] (FLINK-17109) FlinkPipelineTranslationUtil#getJobGraph doesn't consider Jars and Classpaths in configuration.

Wenlong Lyu created FLINK-17109: --- Summary: FlinkPipelineTranslationUtil#getJobGraph doesn't consider Jars and Classpaths in configuration. Key: FLINK-17109 URL: https://issues.apache.org/jira/browse/FLINK-17109

[GitHub] [flink] flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode()

flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode() URL: https://github.com/apache/flink/pull/11713#issuecomment-612778431 ## CI report: * 91cf77c457ee

[GitHub] [flink] flinkbot edited a comment on issue #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

flinkbot edited a comment on issue #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#issuecomment-612758431 ## CI report: * bffb4b07100999b88c67103a1c77d0609c524de9 Travis: [FAILURE](https://travis-ci.c

[jira] [Created] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects configuration

Wenlong Lyu created FLINK-17110: --- Summary: Make StreamExecutionEnvironment#configure also affects configuration Key: FLINK-17110 URL: https://issues.apache.org/jira/browse/FLINK-17110 Project: Flink

[jira] [Created] (FLINK-17111) Support SHOW VIEWS in Flink SQL

Zhenghua Gao created FLINK-17111: Summary: Support SHOW VIEWS in Flink SQL Key: FLINK-17111 URL: https://issues.apache.org/jira/browse/FLINK-17111 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17112) Support DESCRIBE VIEW view_name in Flink SQL

Zhenghua Gao created FLINK-17112: Summary: Support DESCRIBE VIEW view_name in Flink SQL Key: FLINK-17112 URL: https://issues.apache.org/jira/browse/FLINK-17112 Project: Flink Issue Type: Sub-

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN * ad481f5d846621032fe

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode()

flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode() URL: https://github.com/apache/flink/pull/11713#issuecomment-612778431 ## CI report: * 91cf77c457ee

[GitHub] [flink] flinkbot edited a comment on issue #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod

flinkbot edited a comment on issue #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod URL: https://github.com/apache/flink/pull/11606#issuecomment-607319028 ## CI report: * 80f0b20a896d00ce168ee5be49398d6969614d9a Travis: [SUCCESS](https://tr

[jira] [Created] (FLINK-17113) Refactor view support in SQL Client

Zhenghua Gao created FLINK-17113: Summary: Refactor view support in SQL Client Key: FLINK-17113 URL: https://issues.apache.org/jira/browse/FLINK-17113 Project: Flink Issue Type: Sub-task

[GitHub] [flink] xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args URL: https://github.com/apache/flink/pull/11675#discussion_r407351155 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnC

[GitHub] [flink] xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args URL: https://github.com/apache/flink/pull/11675#discussion_r407348935 ## File path: flink-clients/src/main/java/org/apache/flink/client/

[GitHub] [flink] xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args URL: https://github.com/apache/flink/pull/11675#discussion_r407346335 ## File path: flink-clients/src/main/java/org/apache/flink/client/

[GitHub] [flink] xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args URL: https://github.com/apache/flink/pull/11675#discussion_r407356875 ## File path: docs/ops/memory/mem_migration.zh.md ## @@ -

[GitHub] [flink] zhijiangW commented on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-612792024 Considering another possible option to implement the input recovery, I thought th

[GitHub] [flink] KurtYoung commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

KurtYoung commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r407362506 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/o

[GitHub] [flink] KurtYoung commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

KurtYoung commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r407360539 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/c

[GitHub] [flink] KurtYoung commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

KurtYoung commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r407355268 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/a

[GitHub] [flink] KurtYoung commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

KurtYoung commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r407355643 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * ee3e10ccd76d55290ea7639b6808f108ce8311dc Travis: [FAILURE](https://travis-ci.com/github/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod

flinkbot edited a comment on issue #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod URL: https://github.com/apache/flink/pull/11606#issuecomment-607319028 ## CI report: * 80f0b20a896d00ce168ee5be49398d6969614d9a Travis: [SUCCESS](https://tr

[GitHub] [flink] wuchong commented on issue #11656: [FLINK-16983][python] Support RowType in vectorized Python UDF

wuchong commented on issue #11656: [FLINK-16983][python] Support RowType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11656#issuecomment-612795961 Nice to meet you @Jark :) This is an automated message

[GitHub] [flink] ThunderSuuuuu commented on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSink

ThunderSu commented on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSink URL: https://github.com/apache/flink/pull/11706#issuecomment-612797199 @flinkbot run travis --

[jira] [Created] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

Wei Zhong created FLINK-17114: - Summary: When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail. Key: FLINK-17114 URL: https://issues.apac

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082143#comment-17082143 ] Robert Metzger commented on FLINK-16636: Chesnay noticed in FLINK-16973 that the

[jira] [Created] (FLINK-17115) Support Cython Optimizing Python User Defined Function(FLIP-121)

Huang Xingbo created FLINK-17115: Summary: Support Cython Optimizing Python User Defined Function(FLIP-121) Key: FLINK-17115 URL: https://issues.apache.org/jira/browse/FLINK-17115 Project: Flink

[jira] [Assigned] (FLINK-17115) Support Cython Optimizing Python User Defined Function(FLIP-121)

[ https://issues.apache.org/jira/browse/FLINK-17115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17115: --- Assignee: Huang Xingbo > Support Cython Optimizing Python User Defined Function(FLIP-121) > ---

[jira] [Updated] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17114: Component/s: API / Python > When the pyflink job runs in local mode and the command "python" points to >

[jira] [Assigned] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17114: --- Assignee: Wei Zhong > When the pyflink job runs in local mode and the command "python" points to >

[jira] [Commented] (FLINK-17006) AggregateITCase.testDistinctGroupBy fails with FileNotFoundException (in Rocksdb)

[ https://issues.apache.org/jira/browse/FLINK-17006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082145#comment-17082145 ] Robert Metzger commented on FLINK-17006: This is most likely caused by the broke

[jira] [Commented] (FLINK-17094) OverWindowITCase#testRowTimeBoundedPartitionedRowsOver failed by FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-17094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082146#comment-17082146 ] Robert Metzger commented on FLINK-17094: Probably caused by FLINK-16770 > OverW

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * c8cd97141c2c718f45a49998193d2eb6fcf65340 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 59ab8cedf26f3b55602b448951fa18e8e7997bb5 Travis: [FAI

[GitHub] [flink] flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSin

flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSink URL: https://github.com/apache/flink/pull/11706#issuecomment-612330052 ## CI report: * 2fd082f

[GitHub] [flink] flinkbot edited a comment on issue #11712: [FLINK-17067][FLINK-17098][table] Refactor some interfaces of CatalogManager

flinkbot edited a comment on issue #11712: [FLINK-17067][FLINK-17098][table] Refactor some interfaces of CatalogManager URL: https://github.com/apache/flink/pull/11712#issuecomment-612769241 ## CI report: * bdb37a516fba1683dd7c925b6fa1d619dd7fa1fd Travis: [SUCCESS](https://travi

[GitHub] [flink] WeiZhong94 opened a new pull request #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the j

WeiZhong94 opened a new pull request #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is executed by LocalExecutor. URL: https://github.com/apache/flink/pull/11714 ## What is the purpose of

[jira] [Updated] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17114: --- Labels: pull-request-available (was: ) > When the pyflink job runs in local mode and the co

[GitHub] [flink] JingsongLi commented on a change in pull request #11653: [FLINK-16951][parquet] Integrate parquet to file system connector

JingsongLi commented on a change in pull request #11653: [FLINK-16951][parquet] Integrate parquet to file system connector URL: https://github.com/apache/flink/pull/11653#discussion_r407376024 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/

[GitHub] [flink] flinkbot commented on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is exe

flinkbot commented on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is executed by LocalExecutor. URL: https://github.com/apache/flink/pull/11714#issuecomment-612806248 Thanks a lot

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 27728b10f3e719b3f53fe199cf02e5b820ddfcd1 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

flinkbot edited a comment on issue #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#issuecomment-612758431 ## CI report: * bffb4b07100999b88c67103a1c77d0609c524de9 Travis: [FAILURE](https://travis-ci.c

[GitHub] [flink] flinkbot commented on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is exe

flinkbot commented on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is executed by LocalExecutor. URL: https://github.com/apache/flink/pull/11714#issuecomment-612809197 ## CI re

[GitHub] [flink] flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSin

flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSink URL: https://github.com/apache/flink/pull/11706#issuecomment-612330052 ## CI report: * 2fd082f

[jira] [Updated] (FLINK-14713) Show All Attempts For Vertex SubTask In Rest Api

[ https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14713: --- Description: Flink jobs could recovery by failover, but the user couldn't see any information about the job

[jira] [Updated] (FLINK-16598) Respect the rest port exposed by Service in Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-16598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16598: --- Labels: pull-request-available (was: ) > Respect the rest port exposed by Service in > Fab

[GitHub] [flink] zhengcanbin opened a new pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

zhengcanbin opened a new pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715 ## What is the purpose of the change Currently, we parse the `rest.port` from the Flink `Con

[GitHub] [flink] klion26 commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

klion26 commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-612811871 rebased master to resolve the conflicts.

[jira] [Updated] (FLINK-13510) Show fail attempt for subtask in timelime In Rest API

[ https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13510: --- Description: Now, user just can see subtask current attempt in timeline. If job failover, can not see some

[jira] [Updated] (FLINK-13510) Show fail attempt for subtask in timelime In Rest API

[ https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13510: --- Description: Now, a user just can see subtask current attempt in the timeline. If job failover, can not see

[GitHub] [flink] zhengcanbin commented on issue #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container

zhengcanbin commented on issue #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container URL: https://github.com/apache/flink/pull/11707#issuecomment-612812597 @TisonKun @tillrohrmann @wangyang0918 Could you help review this PR? I have left two open questions there and loo

[GitHub] [flink] flinkbot commented on issue #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

flinkbot commented on issue #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715#issuecomment-612812558 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] zhengcanbin commented on issue #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup

zhengcanbin commented on issue #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup URL: https://github.com/apache/flink/pull/11705#issuecomment-612813268 @TisonKun @tillrohrmann @wangyang0918 Could you help take a look at this PR? Thanks a lot i

[GitHub] [flink] zhengcanbin commented on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

zhengcanbin commented on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters URL: https://github.com/apache/flink/pull/11708#issuecomment-612813653 @TisonKun @tillrohrmann @wangyang0918 Could you help review this PR? Thanks a lot in

[jira] [Updated] (FLINK-13510) Show fail attempt for subtask in timelime In Rest API

[ https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13510: --- Description: Now, a user just can see subtask current attempt in the timeline. If job failover, can not see

[GitHub] [flink] Jark commented on issue #11656: [FLINK-16983][python] Support RowType in vectorized Python UDF

Jark commented on issue #11656: [FLINK-16983][python] Support RowType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11656#issuecomment-612814306 @dianfu no worries! @wuchong nice to meet you as well :) --

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * 1b4bd14611dba7f65185aef418b9b1abe855d112 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

flinkbot edited a comment on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11579#issuecomment-606537991 ## CI report: * 5febafb727b8a54a377c2352ff5d3de1afa99d1e Travis: [SUCCESS](https://travis-ci.com/github

[GitHub] [flink] flinkbot edited a comment on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job

flinkbot edited a comment on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is executed by LocalExecutor. URL: https://github.com/apache/flink/pull/11714#issuecomment-612809197 #

[GitHub] [flink] flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode()

flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode() URL: https://github.com/apache/flink/pull/11713#issuecomment-612778431 ## CI report: * 91cf77c457ee

[GitHub] [flink] flinkbot edited a comment on issue #11653: [FLINK-16951][parquet] Integrate parquet to file system connector

flinkbot edited a comment on issue #11653: [FLINK-16951][parquet] Integrate parquet to file system connector URL: https://github.com/apache/flink/pull/11653#issuecomment-610233812 ## CI report: * 24b9af733c519ceca287e189b2b290d3d6a0baf4 Travis: [SUCCESS](https://travis-ci.com/gi

[GitHub] [flink] flinkbot commented on issue #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

flinkbot commented on issue #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715#issuecomment-612818039 ## CI report: * 0d42d620980962950546b1c7090ed88e67a179c5 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

flinkbot edited a comment on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11579#issuecomment-606537991 ## CI report: * 5febafb727b8a54a377c2352ff5d3de1afa99d1e Travis: [SUCCESS](https://travis-ci.com/github

[GitHub] [flink] flinkbot edited a comment on issue #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod

flinkbot edited a comment on issue #11606: [FLINK-15639][k8s] Support to set tolerations for jobmanager and taskmanger pod URL: https://github.com/apache/flink/pull/11606#issuecomment-607319028 ## CI report: * f84d47161f3acc856adb5db49c40fc480b3f3166 Travis: [SUCCESS](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * 8c7c65f3c748812f9a007196adabe464861756c5 Travis: [PENDING](htt

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11653: [FLINK-16951][parquet] Integrate parquet to file system connector

flinkbot edited a comment on issue #11653: [FLINK-16951][parquet] Integrate parquet to file system connector URL: https://github.com/apache/flink/pull/11653#issuecomment-610233812 ## CI report: * 24b9af733c519ceca287e189b2b290d3d6a0baf4 Travis: [SUCCESS](https://travis-ci.com/gi

[GitHub] [flink] flinkbot edited a comment on issue #11712: [FLINK-17067][FLINK-17098][table] Refactor some interfaces of CatalogManager

flinkbot edited a comment on issue #11712: [FLINK-17067][FLINK-17098][table] Refactor some interfaces of CatalogManager URL: https://github.com/apache/flink/pull/11712#issuecomment-612769241 ## CI report: * bdb37a516fba1683dd7c925b6fa1d619dd7fa1fd Travis: [SUCCESS](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode()

flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode() URL: https://github.com/apache/flink/pull/11713#issuecomment-612778431 ## CI report: * 91cf77c457ee

[GitHub] [flink] flinkbot edited a comment on issue #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

flinkbot edited a comment on issue #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715#issuecomment-612818039 ## CI report: * 0d42d620980962950546b1c7090ed88e67a179c5 Travis: [P

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 27728b10f3e719b3f53fe199cf02e5b820ddfcd1 UNKNOWN *

[jira] [Created] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

Kai Chen created FLINK-17116: Summary: support UsernamePasswordCredentials for elasticsearch sink via SQL DDL Key: FLINK-17116 URL: https://issues.apache.org/jira/browse/FLINK-17116 Project: Flink

[jira] [Updated] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17116: --- Labels: pull-request-available (was: ) > support UsernamePasswordCredentials for elasticsea

[GitHub] [flink] yuchuanchen opened a new pull request #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink

yuchuanchen opened a new pull request #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink URL: https://github.com/apache/flink/pull/11716 ## What is the purpose of the change *(For example: This pull request makes task

[jira] [Commented] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082193#comment-17082193 ] Piotr Nowojski commented on FLINK-17068: Another issue: https://dev.azure.com/r

[jira] [Comment Edited] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082193#comment-17082193 ] Piotr Nowojski edited comment on FLINK-17068 at 4/13/20, 9:49 AM:

[jira] [Updated] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17068: --- Fix Version/s: 1.11.0 > ERROR at teardown of TableConfigTests.test_get_set_decimal_context >

[GitHub] [flink] JingsongLi commented on a change in pull request #11712: [FLINK-17067][FLINK-17098][table] Refactor some interfaces of CatalogManager

JingsongLi commented on a change in pull request #11712: [FLINK-17067][FLINK-17098][table] Refactor some interfaces of CatalogManager URL: https://github.com/apache/flink/pull/11712#discussion_r407405533 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/t

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * 8c7c65f3c748812f9a007196adabe464861756c5 Travis: [FAILURE](htt

[GitHub] [flink] flinkbot commented on issue #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink

flinkbot commented on issue #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink URL: https://github.com/apache/flink/pull/11716#issuecomment-612833748 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot

[jira] [Commented] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

[ https://issues.apache.org/jira/browse/FLINK-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082194#comment-17082194 ] Jeff Zhang commented on FLINK-17114: I think it depends what is the default python i

[GitHub] [flink] flinkbot edited a comment on issue #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

flinkbot edited a comment on issue #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715#issuecomment-612818039 ## CI report: * 0d42d620980962950546b1c7090ed88e67a179c5 Travis: [F

[GitHub] [flink] flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode()

flinkbot edited a comment on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode() URL: https://github.com/apache/flink/pull/11713#issuecomment-612778431 ## CI report: * 91cf77c457ee

[GitHub] [flink] flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSin

flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSink URL: https://github.com/apache/flink/pull/11706#issuecomment-612330052 ## CI report: * 3f18904

[GitHub] [flink] danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r407405012 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/c

[GitHub] [flink] danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r407406550 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r407405962 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/o

[jira] [Comment Edited] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082200#comment-17082200 ] Canbin Zheng edited comment on FLINK-17116 at 4/13/20, 10:02 AM: -

[jira] [Commented] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082200#comment-17082200 ] Canbin Zheng commented on FLINK-17116: -- Does it related to FLINK-16788 ? > support

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

[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16601: - Description: Currently, if one sets the type of the rest-service to {{NodePort}}, then the way

[GitHub] [flink] xintongsong commented on issue #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on issue #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#issuecomment-612838446 Thanks for updating the PR, @KarmaGYZ. I have left some comments. Please take a look. My main concern is regarding

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r407370953 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/Standalon

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r407396644 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanag

  1   2   3   4   5   >