[jira] [Closed] (FLINK-16189) Remove testing logic from FlinkDistribution

[ https://issues.apache.org/jira/browse/FLINK-16189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16189. Resolution: Fixed master: 1924f82512e17a43f874b8c86492d9ce6c8d7dd1 > Remove testing

[jira] [Comment Edited] (FLINK-16172) Add baseline set of allowed unused dependencies

[ https://issues.apache.org/jira/browse/FLINK-16172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052232#comment-17052232 ] Chesnay Schepler edited comment on FLINK-16172 at 3/5/20, 3:11 PM: ---

[jira] [Closed] (FLINK-16172) Add baseline set of allowed unused dependencies

[ https://issues.apache.org/jira/browse/FLINK-16172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16172. Resolution: Fixed master: 8587ce8dacb2b6c9fae1d3d3fd923ee0a32b7ee4

[jira] [Closed] (FLINK-16173) Reduce noise for used undeclared dependencies

[ https://issues.apache.org/jira/browse/FLINK-16173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16173. Resolution: Fixed master: a762e76c0fa270367a6cf6cebca807ba80e124ae > Reduce noise for

[GitHub] [flink] zentol merged pull request #11140: [FLINK-16172][build] Add baseline set of allowed unused dependencies

zentol merged pull request #11140: [FLINK-16172][build] Add baseline set of allowed unused dependencies URL: https://github.com/apache/flink/pull/11140 This is an automated message from the Apache Git Service. To respond to

[jira] [Closed] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6537. --- > Umbrella issue for fixes to incremental snapshots > -

[jira] [Resolved] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6537. - Resolution: Fixed All subtasks are closed. > Umbrella issue for fixes to incremental snapshots

[jira] [Closed] (FLINK-6540) Add more thorough tests for RocksDB and incremental checkpointing

[ https://issues.apache.org/jira/browse/FLINK-6540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6540. --- Resolution: Abandoned > Add more thorough tests for RocksDB and incremental checkpointing >

[jira] [Closed] (FLINK-6599) Communicate last committed checkpoint through trigger checkpoint message

[ https://issues.apache.org/jira/browse/FLINK-6599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6599. --- Resolution: Abandoned > Communicate last committed checkpoint through trigger checkpoint message >

[GitHub] [flink] zentol edited a comment on issue #11305: [FLINK-16410][e2e][build] Add explicit flink-runtime dependency

zentol edited a comment on issue #11305: [FLINK-16410][e2e][build] Add explicit flink-runtime dependency URL: https://github.com/apache/flink/pull/11305#issuecomment-595277009 > Would every test now need to know about this mechanism and need to manually promote the transitive runtime

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11123: [FLINK-16014][s3] Force usage of SAXParserFactory over XMLReaderFactory in aws-java-sdk-s3.

flinkbot edited a comment on issue #11123: [FLINK-16014][s3] Force usage of SAXParserFactory over XMLReaderFactory in aws-java-sdk-s3. URL: https://github.com/apache/flink/pull/11123#issuecomment-587468233 ## CI report: * 3d28892370884e69d1dfa550c69fd664d0053fdd Travis:

[jira] [Closed] (FLINK-16410) PrometheusReporterEndToEndITCase fails with ClassNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-16410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16410. Fix Version/s: 1.11.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #11305: [FLINK-16410][e2e][build] Add explicit flink-runtime dependency

zentol merged pull request #11305: [FLINK-16410][e2e][build] Add explicit flink-runtime dependency URL: https://github.com/apache/flink/pull/11305 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] zentol commented on issue #11305: [FLINK-16410][e2e][build] Add explicit flink-runtime dependency

zentol commented on issue #11305: [FLINK-16410][e2e][build] Add explicit flink-runtime dependency URL: https://github.com/apache/flink/pull/11305#issuecomment-595277009 > Would every test now need to know about this mechanism and need to manually promote the transitive runtime dependency?

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388340028 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388346850 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388310058 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388347812 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388346247 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388344724 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388312499 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388310406 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388313102 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388344253 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

AHeise commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r388348348 ## File path:

[jira] [Resolved] (FLINK-16177) Integrate Operator Coordinators with Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-16177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-16177. -- Resolution: Fixed Implemented in 1.11.0 via 963974f99d18d6a9f36fa78b792dcc2bc9e53de5 >

[jira] [Closed] (FLINK-16177) Integrate Operator Coordinators with Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-16177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-16177. > Integrate Operator Coordinators with Checkpoints >

[GitHub] [flink] asfgit closed pull request #11274: [FLINK-16177][checkpointing] Integrate OperatorCoordinator checkpoint triggering and committing

asfgit closed pull request #11274: [FLINK-16177][checkpointing] Integrate OperatorCoordinator checkpoint triggering and committing URL: https://github.com/apache/flink/pull/11274 This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner

flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * 2e0fb83e0784cd3b3315856e51e0fece5eedd0ed

[GitHub] [flink] flinkbot edited a comment on issue #11123: [FLINK-16014][s3] Force usage of SAXParserFactory over XMLReaderFactory in aws-java-sdk-s3.

flinkbot edited a comment on issue #11123: [FLINK-16014][s3] Force usage of SAXParserFactory over XMLReaderFactory in aws-java-sdk-s3. URL: https://github.com/apache/flink/pull/11123#issuecomment-587468233 ## CI report: * 3d28892370884e69d1dfa550c69fd664d0053fdd Travis:

[GitHub] [flink] flinkbot commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595263117 Thanks a lot for your contribution to the Apache Flink project. I'm

[jira] [Updated] (FLINK-16439) Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

[ https://issues.apache.org/jira/browse/FLINK-16439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16439: --- Labels: pull-request-available (was: ) > Make KubernetesResourceManager starts workers

[GitHub] [flink] xintongsong opened a new pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong opened a new pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323 ## What is the purpose of the change This PR is one step of FLINK-14106,

[GitHub] [flink] flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner

flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 2a005b9c7d287b338a5a4c0795816d61e8f09312 Travis:

[jira] [Commented] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics

[ https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052173#comment-17052173 ] Stephan Ewen commented on FLINK-16444: -- +1 for this feature, users have asked about more insights

[jira] [Commented] (FLINK-16313) flink-state-processor-api: surefire execution unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-16313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052168#comment-17052168 ] Robert Metzger commented on FLINK-16313: The jvm is writing a {{.dumpstream}} file with the

[jira] [Commented] (FLINK-16422) Cannot use [catalog].[db].table with Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-16422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052163#comment-17052163 ] Gyula Fora commented on FLINK-16422: Thanks [~Leonard Xu] for the nicer writeup :) > Cannot use

[jira] [Created] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics

Yun Tang created FLINK-16444: Summary: Count the read/write/seek/next latency of RocksDB as metrics Key: FLINK-16444 URL: https://issues.apache.org/jira/browse/FLINK-16444 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

flinkbot edited a comment on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322#issuecomment-595233010 ## CI report: * 497c65724ea2499cd2a5b82a7ce4ffd2f8807502 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11320: [FLINK-16437] Make SlotManager allocate resource from ResourceManager at the worker granularity.

flinkbot edited a comment on issue #11320: [FLINK-16437] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-595174225 ## CI report: * b46d3159b0b1fe2a7f5f3210185c50b5e7252cc0 Travis:

[jira] [Created] (FLINK-16443) Fix wrong fix for user-code CheckpointExceptions

Stephan Ewen created FLINK-16443: Summary: Fix wrong fix for user-code CheckpointExceptions Key: FLINK-16443 URL: https://issues.apache.org/jira/browse/FLINK-16443 Project: Flink Issue Type:

[GitHub] [flink] AHeise commented on a change in pull request #11303: [FLINK-16245] Decoupling user classloader from context classloader.

AHeise commented on a change in pull request #11303: [FLINK-16245] Decoupling user classloader from context classloader. URL: https://github.com/apache/flink/pull/11303#discussion_r388301548 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11303: [FLINK-16245] Decoupling user classloader from context classloader.

AHeise commented on a change in pull request #11303: [FLINK-16245] Decoupling user classloader from context classloader. URL: https://github.com/apache/flink/pull/11303#discussion_r388299382 ## File path:

[jira] [Commented] (FLINK-16434) Add document to explain how to pack hive with their own hive dependencies

[ https://issues.apache.org/jira/browse/FLINK-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052143#comment-17052143 ] Leonard Xu commented on FLINK-16434: +1 for this document, hive has many versions and each version

[GitHub] [flink] flinkbot commented on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

flinkbot commented on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322#issuecomment-595233010 ## CI report: * 497c65724ea2499cd2a5b82a7ce4ffd2f8807502 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11318: [FLINK-16435][python] Fix ide static check

flinkbot edited a comment on issue #11318: [FLINK-16435][python] Fix ide static check URL: https://github.com/apache/flink/pull/11318#issuecomment-595145846 ## CI report: * 380588ed7bcda11a5a6358b9c45a50d1af2caa28 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader

flinkbot edited a comment on issue #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader URL: https://github.com/apache/flink/pull/10922#issuecomment-577180180 ## CI report: * 37cb28b6b3238516df476318cb28d30114689442 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment

flinkbot edited a comment on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment URL: https://github.com/apache/flink/pull/11296#issuecomment-59383 ## CI report: * 42befb8bcb61fcb1d8c2551affe9da273f978295 Travis:

[GitHub] [flink] WeiZhong94 commented on a change in pull request #11238: [FLINK-16304][python] Remove python packages bundled in the flink-python jar.

WeiZhong94 commented on a change in pull request #11238: [FLINK-16304][python] Remove python packages bundled in the flink-python jar. URL: https://github.com/apache/flink/pull/11238#discussion_r388291429 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 2a005b9c7d287b338a5a4c0795816d61e8f09312 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11123: [FLINK-16014][s3] Force usage of SAXParserFactory over XMLReaderFactory in aws-java-sdk-s3.

flinkbot edited a comment on issue #11123: [FLINK-16014][s3] Force usage of SAXParserFactory over XMLReaderFactory in aws-java-sdk-s3. URL: https://github.com/apache/flink/pull/11123#issuecomment-587468233 ## CI report: * 95e457e1d10f8c7b0de7e52fef42f6ac029912a6 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment

flinkbot edited a comment on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment URL: https://github.com/apache/flink/pull/11296#issuecomment-59383 ## CI report: * 42befb8bcb61fcb1d8c2551affe9da273f978295 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader

flinkbot edited a comment on issue #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader URL: https://github.com/apache/flink/pull/10922#issuecomment-577180180 ## CI report: * 37cb28b6b3238516df476318cb28d30114689442 Travis:

[GitHub] [flink] flinkbot commented on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

flinkbot commented on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322#issuecomment-595223763 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] jiasheng55 opened a new pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

jiasheng55 opened a new pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322 …ectory. ## What is the purpose of the change Currently, the Yarn application directory of Flink is

[jira] [Comment Edited] (FLINK-16427) Remove directly throw ProgramInvocationExceptions in RemoteStreamEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052111#comment-17052111 ] Zili Chen edited comment on FLINK-16427 at 3/5/20, 1:00 PM: Because

[jira] [Commented] (FLINK-16427) Remove directly throw ProgramInvocationExceptions in RemoteStreamEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052111#comment-17052111 ] Zili Chen commented on FLINK-16427: --- Because ProgramInvocationExceptions is in flink-client while

[GitHub] [flink] JingsongLi commented on a change in pull request #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader

JingsongLi commented on a change in pull request #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader URL: https://github.com/apache/flink/pull/10922#discussion_r388277823 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

flinkbot edited a comment on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 2a005b9c7d287b338a5a4c0795816d61e8f09312 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11274: [FLINK-16177][checkpointing] Integrate OperatorCoordinator checkpoint triggering and committing

flinkbot edited a comment on issue #11274: [FLINK-16177][checkpointing] Integrate OperatorCoordinator checkpoint triggering and committing URL: https://github.com/apache/flink/pull/11274#issuecomment-593164504 ## CI report: * 94b8db822437a30b7342f83cea116023af131c53 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11318: [FLINK-16435][python] Fix ide static check

flinkbot edited a comment on issue #11318: [FLINK-16435][python] Fix ide static check URL: https://github.com/apache/flink/pull/11318#issuecomment-595145846 ## CI report: * 380588ed7bcda11a5a6358b9c45a50d1af2caa28 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11123: [FLINK-16014][s3] Force usage of SAXParserFactory over XMLReaderFactory in aws-java-sdk-s3.

flinkbot edited a comment on issue #11123: [FLINK-16014][s3] Force usage of SAXParserFactory over XMLReaderFactory in aws-java-sdk-s3. URL: https://github.com/apache/flink/pull/11123#issuecomment-587468233 ## CI report: * 95e457e1d10f8c7b0de7e52fef42f6ac029912a6 Travis:

[jira] [Commented] (FLINK-16427) Remove directly throw ProgramInvocationExceptions in RemoteStreamEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052107#comment-17052107 ] Aljoscha Krettek commented on FLINK-16427: -- Why is this a prerequisite of FLINK-15090? >

[GitHub] [flink] jiasheng55 closed pull request #11319: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

jiasheng55 closed pull request #11319: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11319 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-16425) Add rate limiting feature for kafka table source

[ https://issues.apache.org/jira/browse/FLINK-16425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052104#comment-17052104 ] Zou commented on FLINK-16425: - [~jark] I find that there is also no rate limiting in FlinkKafkaConsumer,

[jira] [Comment Edited] (FLINK-16422) Cannot use [catalog].[db].table with Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-16422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052103#comment-17052103 ] Leonard Xu edited comment on FLINK-16422 at 3/5/20, 12:54 PM: -- [~gyfora] 

[jira] [Commented] (FLINK-16422) Cannot use [catalog].[db].table with Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-16422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052103#comment-17052103 ] Leonard Xu commented on FLINK-16422: [~gyfora]  I got it, SQL CLI should return :   {code:java}

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052101#comment-17052101 ] Stephan Ewen commented on FLINK-14807: -- Nice to see this lively discussion. I agree that we should

[GitHub] [flink] lirui-apache commented on a change in pull request #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader

lirui-apache commented on a change in pull request #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader URL: https://github.com/apache/flink/pull/10922#discussion_r388246126 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader

lirui-apache commented on a change in pull request #10922: [FLINK-11899][parquet] Introduce parquet ColumnarRow split reader URL: https://github.com/apache/flink/pull/10922#discussion_r388249255 ## File path:

[jira] [Commented] (FLINK-16357) Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore".

[ https://issues.apache.org/jira/browse/FLINK-16357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052090#comment-17052090 ] Zhu Zhu commented on FLINK-16357: - I see. Yes, I think we can achieve it by adding a param like

[GitHub] [flink] flinkbot commented on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

flinkbot commented on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595208662 ## CI report: * 2a005b9c7d287b338a5a4c0795816d61e8f09312 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build

flinkbot edited a comment on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build URL: https://github.com/apache/flink/pull/11316#issuecomment-595136134 ## CI report: * 0e09cc2806e813a52f53f58b9ec4228465639668 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner

flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11274: [FLINK-16177][checkpointing] Integrate OperatorCoordinator checkpoint triggering and committing

flinkbot edited a comment on issue #11274: [FLINK-16177][checkpointing] Integrate OperatorCoordinator checkpoint triggering and committing URL: https://github.com/apache/flink/pull/11274#issuecomment-593164504 ## CI report: * 94b8db822437a30b7342f83cea116023af131c53 Travis:

[GitHub] [flink] dianfu commented on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner

dianfu commented on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner URL: https://github.com/apache/flink/pull/11252#issuecomment-595204458 @hequn8128 Thanks a lot for your great review and

[GitHub] [flink] flinkbot commented on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

flinkbot commented on issue #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321#issuecomment-595203896 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-15585) Improve function identifier string in plan digest

[ https://issues.apache.org/jira/browse/FLINK-15585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15585: --- Labels: pull-request-available (was: ) > Improve function identifier string in plan digest

[GitHub] [flink] godfreyhe opened a new pull request #11321: [FLINK-15585] [table] Improve function identifier string in plan digest

godfreyhe opened a new pull request #11321: [FLINK-15585] [table] Improve function identifier string in plan digest URL: https://github.com/apache/flink/pull/11321 ## What is the purpose of the change *Currently, we use UserDefinedFunction#functionIdentifier as the identifier

[GitHub] [flink] flinkbot edited a comment on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build

flinkbot edited a comment on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build URL: https://github.com/apache/flink/pull/11316#issuecomment-595136134 ## CI report: * 0e09cc2806e813a52f53f58b9ec4228465639668 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear…

flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear… URL: https://github.com/apache/flink/pull/11317#issuecomment-595145709 ## CI report: * 9c6d3fcae177e05bba552a967d0cf75587412693 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11319: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

flinkbot edited a comment on issue #11319: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11319#issuecomment-595166037 ## CI report: * c2f13248b87d59271f7fd14b2c5a1f9dc6c72a89 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner

flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

flinkbot edited a comment on issue #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#issuecomment-591333787 ## CI report: * bc6799fbd1e26ba48a902527d870b95d796aab10 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

flinkbot edited a comment on issue #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version URL: https://github.com/apache/flink/pull/11245#issuecomment-592002512 ## CI report: * f1d4f9163a2cd60daa02fe6b7af5a459cee9660c UNKNOWN *

[jira] [Commented] (FLINK-15791) Don't use ForkJoinPool#commonPool() for executing asynchronous operations in Fabric8FlinkKubeClient

[ https://issues.apache.org/jira/browse/FLINK-15791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052067#comment-17052067 ] Zili Chen commented on FLINK-15791: --- [~fly_in_gis] Yes it is the case. > Don't use

[jira] [Comment Edited] (FLINK-15791) Don't use ForkJoinPool#commonPool() for executing asynchronous operations in Fabric8FlinkKubeClient

[ https://issues.apache.org/jira/browse/FLINK-15791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052057#comment-17052057 ] Yang Wang edited comment on FLINK-15791 at 3/5/20, 12:01 PM: - [~trohrmann],

[GitHub] [flink] wangyang0918 closed pull request #10971: [FLINK-15791][k8s] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

wangyang0918 closed pull request #10971: [FLINK-15791][k8s] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971 This is an automated message from

[jira] [Comment Edited] (FLINK-15791) Don't use ForkJoinPool#commonPool() for executing asynchronous operations in Fabric8FlinkKubeClient

[ https://issues.apache.org/jira/browse/FLINK-15791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052057#comment-17052057 ] Yang Wang edited comment on FLINK-15791 at 3/5/20, 11:58 AM: - [~trohrmann],

[jira] [Commented] (FLINK-15791) Don't use ForkJoinPool#commonPool() for executing asynchronous operations in Fabric8FlinkKubeClient

[ https://issues.apache.org/jira/browse/FLINK-15791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052057#comment-17052057 ] Yang Wang commented on FLINK-15791: --- [~trohrmann], since the #FLINK-16194(Refactor the Kubernetes

[GitHub] [flink] wangyang0918 commented on issue #10971: [FLINK-15791][k8s] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

wangyang0918 commented on issue #10971: [FLINK-15791][k8s] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-595192579 @tillrohrmann @TisonKun Thanks a lot for your suggestion. Since the

[GitHub] [flink] godfreyhe commented on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment

godfreyhe commented on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment URL: https://github.com/apache/flink/pull/11296#issuecomment-595191381 @flinkbot run travis

[jira] [Resolved] (FLINK-16108) StreamSQLExample is failed if running in blink planner

[ https://issues.apache.org/jira/browse/FLINK-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16108. - Resolution: Fixed Fixed in - mater(1.11.0): 377024ba85058e3ba5fa092aaf5c92be33d7ae09 - 1.10.1:

[jira] [Resolved] (FLINK-16269) Generic type can not be matched when convert table to stream.

[ https://issues.apache.org/jira/browse/FLINK-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16269. - Resolution: Fixed Fixed in - mater(1.11.0): 377024ba85058e3ba5fa092aaf5c92be33d7ae09 - 1.10.1:

[GitHub] [flink] wuchong merged pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is requested

wuchong merged pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is requested URL: https://github.com/apache/flink/pull/11236 This is

[jira] [Updated] (FLINK-16400) HdfsKindTest.testS3Kind fails in Hadoop 2.4.1 nightly test

[ https://issues.apache.org/jira/browse/FLINK-16400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16400: --- Release Note: `org.apache.flink.core.fs.FileSystem#getKind` method has been formally

[jira] [Closed] (FLINK-16400) HdfsKindTest.testS3Kind fails in Hadoop 2.4.1 nightly test

[ https://issues.apache.org/jira/browse/FLINK-16400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16400. -- Fix Version/s: 1.11.0 Release Note: `org.apache.flink.core.fs.FileSystem#getKind` method

<    1   2   3   4   5   >