[GitHub] [flink] zhijiangW merged pull request #10617: [FLINK-15021][network] Remove the setting of netty channel watermark in NettyServer

zhijiangW merged pull request #10617: [FLINK-15021][network] Remove the setting of netty channel watermark in NettyServer URL: https://github.com/apache/flink/pull/10617 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773#issuecomment-571035373 ## CI report: * 93322f33658ab3c8dabedcb8b3d31bb71ed7e7e5 Travis:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10666: [FLINK-15214] Introduce multiple submission e2e test

KarmaGYZ commented on a change in pull request #10666: [FLINK-15214] Introduce multiple submission e2e test URL: https://github.com/apache/flink/pull/10666#discussion_r363564488 ## File path: flink-end-to-end-tests/test-scripts/docker-mesos-cluster/docker-compose.yml ##

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15493: Description:

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15493: Description:

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009287#comment-17009287 ] Dian Fu commented on FLINK-15493: - cc [~becket_qin] >

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-15493: Affects Version/s: (was: 1.10.0) >

[GitHub] [flink] wangyang0918 commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

wangyang0918 commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#discussion_r363562329 ## File path:

[jira] [Closed] (FLINK-15436) Add a hook of deserialized for pojo state object.

[ https://issues.apache.org/jira/browse/FLINK-15436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiemeilong closed FLINK-15436. -- Resolution: Won't Do > Add a hook of deserialized for pojo state object. >

[jira] [Created] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

Dian Fu created FLINK-15493: --- Summary: FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis Key: FLINK-15493 URL:

[jira] [Commented] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009272#comment-17009272 ] Jingsong Lee commented on FLINK-15290: -- Hi [~aljoscha] , actually we can not pass through options

[GitHub] [flink] JingsongLi commented on issue #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type

JingsongLi commented on issue #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type URL: https://github.com/apache/flink/pull/10775#issuecomment-571385097 LGTM This is an automated message from the

[GitHub] [flink] JingsongLi commented on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved.

JingsongLi commented on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved. URL: https://github.com/apache/flink/pull/10774#issuecomment-571384697 I think we can check them as much as possible. Feel free to open a jira.

[jira] [Closed] (FLINK-15070) Supplement cases of blocking partition with compression for benchmark

[ https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun closed FLINK-15070. - > Supplement cases of blocking partition with compression for benchmark >

[jira] [Resolved] (FLINK-15070) Supplement cases of blocking partition with compression for benchmark

[ https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun resolved FLINK-15070. --- Resolution: Fixed > Supplement cases of blocking partition with compression for benchmark >

[jira] [Commented] (FLINK-15070) Supplement cases of blocking partition with compression for benchmark

[ https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009245#comment-17009245 ] Haibo Sun commented on FLINK-15070: --- Hotfix PR:

[GitHub] [flink] flinkbot edited a comment on issue #10724: [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with ...

flinkbot edited a comment on issue #10724: [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with ... URL: https://github.com/apache/flink/pull/10724#issuecomment-569709525 ## CI report: * 8eaf5ae81f096affd74e87e00cbd71023cd255fd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-564535655 ## CI report: * 252fe96f7a6254a18341f78cdb1bcbd24ae25a1c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

flinkbot edited a comment on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781#issuecomment-571250359 ## CI report: * 85dc4bd6420b9354e6cf3f2fd9387077ed631894 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions

flinkbot edited a comment on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions URL: https://github.com/apache/flink/pull/10780#issuecomment-571250322 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins.

flinkbot edited a comment on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins. URL: https://github.com/apache/flink/pull/10778#issuecomment-571130919 ## CI report: * ecbfc13822f74653cdd3f6ea76906e4933a5f11b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins.

flinkbot edited a comment on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins. URL: https://github.com/apache/flink/pull/10778#issuecomment-571130919 ## CI report: * ecbfc13822f74653cdd3f6ea76906e4933a5f11b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10724: [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with ...

flinkbot edited a comment on issue #10724: [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with ... URL: https://github.com/apache/flink/pull/10724#issuecomment-569709525 ## CI report: * 8eaf5ae81f096affd74e87e00cbd71023cd255fd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-564535655 ## CI report: * 252fe96f7a6254a18341f78cdb1bcbd24ae25a1c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

flinkbot edited a comment on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781#issuecomment-571250359 ## CI report: * 85dc4bd6420b9354e6cf3f2fd9387077ed631894 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions

flinkbot edited a comment on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions URL: https://github.com/apache/flink/pull/10780#issuecomment-571250322 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10724: [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with ...

flinkbot edited a comment on issue #10724: [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with ... URL: https://github.com/apache/flink/pull/10724#issuecomment-569709525 ## CI report: * 8eaf5ae81f096affd74e87e00cbd71023cd255fd Travis:

[jira] [Created] (FLINK-15492) flink-clients test failing on Red Hat 7.6 PowerPC Linux

Ronald O. Edmark created FLINK-15492: Summary: flink-clients test failing on Red Hat 7.6 PowerPC Linux Key: FLINK-15492 URL: https://issues.apache.org/jira/browse/FLINK-15492 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-564535655 ## CI report: * 252fe96f7a6254a18341f78cdb1bcbd24ae25a1c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions

flinkbot edited a comment on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions URL: https://github.com/apache/flink/pull/10780#issuecomment-571250322 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

flinkbot edited a comment on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781#issuecomment-571250359 ## CI report: * 85dc4bd6420b9354e6cf3f2fd9387077ed631894 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10724: [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with ...

flinkbot edited a comment on issue #10724: [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with ... URL: https://github.com/apache/flink/pull/10724#issuecomment-569709525 ## CI report: * 8eaf5ae81f096affd74e87e00cbd71023cd255fd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10617: [FLINK-15021][network] Remove setting of netty channel watermark and logic of writability changed

flinkbot edited a comment on issue #10617: [FLINK-15021][network] Remove setting of netty channel watermark and logic of writability changed URL: https://github.com/apache/flink/pull/10617#issuecomment-566861496 ## CI report: * 6e5bf2f53eb76820e08f0ed5f823c2b0f2670da7 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9576: [FLINK-13915][ml] Add several base classes of summarizer.

flinkbot edited a comment on issue #9576: [FLINK-13915][ml] Add several base classes of summarizer. URL: https://github.com/apache/flink/pull/9576#issuecomment-526650772 ## CI report: * 4fdf72f3ec019e4c90c5ab8e0d71f82c7365c26c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-564535655 ## CI report: * 252fe96f7a6254a18341f78cdb1bcbd24ae25a1c Travis:

[GitHub] [flink] flinkbot commented on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions

flinkbot commented on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions URL: https://github.com/apache/flink/pull/10780#issuecomment-571250322 ## CI report: * e3d428ff8c7933e9c16518db836eddcc401995df

[GitHub] [flink] flinkbot commented on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

flinkbot commented on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot commented on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

flinkbot commented on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781#issuecomment-571250359 ## CI report: * 85dc4bd6420b9354e6cf3f2fd9387077ed631894 UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type

flinkbot edited a comment on issue #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type URL: https://github.com/apache/flink/pull/10775#issuecomment-571103452 ## CI report: * 230118fe22abdfa2adae7fabcd4ce6577c92bceb Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10777: [FLINK-10939][doc] Add documents for running Flink cluster natively on Kubernetes

flinkbot edited a comment on issue #10777: [FLINK-10939][doc] Add documents for running Flink cluster natively on Kubernetes URL: https://github.com/apache/flink/pull/10777#issuecomment-571130861 ## CI report: * 3fec823e216b198f33fa5fb5eac129d8849a03e8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins.

flinkbot edited a comment on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins. URL: https://github.com/apache/flink/pull/10778#issuecomment-571130919 ## CI report: * ecbfc13822f74653cdd3f6ea76906e4933a5f11b Travis:

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r363407465 ## File path:

[jira] [Comment Edited] (FLINK-15491) Fix incorrect path while missing trailing slash of high-availability.zookeeper.path.running-registry parameter.

[ https://issues.apache.org/jira/browse/FLINK-15491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009034#comment-17009034 ] Yun Tang edited comment on FLINK-15491 at 1/6/20 5:32 PM: -- This is because the

[jira] [Commented] (FLINK-15491) Fix incorrect path while missing trailing slash of high-availability.zookeeper.path.running-registry parameter.

[ https://issues.apache.org/jira/browse/FLINK-15491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009034#comment-17009034 ] Yun Tang commented on FLINK-15491: -- This is because the zk path is only created by append two string

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r363393198 ## File path:

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r363390451 ## File path:

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r363390451 ## File path:

[GitHub] [flink] flinkbot commented on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

flinkbot commented on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781#issuecomment-571203038 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-15434) testResourceManagerConnectionAfterRegainingLeadership test fail when run azure

[ https://issues.apache.org/jira/browse/FLINK-15434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-15434: Priority: Critical (was: Major) > testResourceManagerConnectionAfterRegainingLeadership

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r363367102 ## File path:

[jira] [Updated] (FLINK-15281) Map Flink's TypeInference to Calcite's interfaces

[ https://issues.apache.org/jira/browse/FLINK-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15281: --- Labels: pull-request-available (was: ) > Map Flink's TypeInference to Calcite's interfaces

[GitHub] [flink] AHeise commented on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins.

AHeise commented on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins. URL: https://github.com/apache/flink/pull/10778#issuecomment-571202534 @flinkbot run travis This is an automated message from

[GitHub] [flink] twalthr opened a new pull request #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

twalthr opened a new pull request #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781 ## What is the purpose of the change This PR connects Flink's new type inference to Calcite's type

[GitHub] [flink] AHeise commented on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins.

AHeise commented on issue #10778: [Flink-15355][plugins] Added parent first patterns for plugins. URL: https://github.com/apache/flink/pull/10778#issuecomment-571202261 @flinkbot run azure This is an automated message from

[jira] [Updated] (FLINK-15258) HiveModuleFactory should be able to distinguish hive-version as property

[ https://issues.apache.org/jira/browse/FLINK-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15258: - Fix Version/s: (was: 1.11.0) > HiveModuleFactory should be able to distinguish hive-version as

[jira] [Updated] (FLINK-15322) Parquet test fails with Hive versions prior to 1.2.0

[ https://issues.apache.org/jira/browse/FLINK-15322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15322: - Fix Version/s: (was: 1.11.0) > Parquet test fails with Hive versions prior to 1.2.0 >

[jira] [Updated] (FLINK-14796) Add document about limitations of different Hive versions

[ https://issues.apache.org/jira/browse/FLINK-14796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14796: - Fix Version/s: (was: 1.11.0) > Add document about limitations of different Hive versions >

[jira] [Updated] (FLINK-15361) ParquetTableSource should pass predicate in projectFields

[ https://issues.apache.org/jira/browse/FLINK-15361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15361: - Fix Version/s: (was: 1.11.0) > ParquetTableSource should pass predicate in projectFields >

[jira] [Updated] (FLINK-15342) Verify querying Hive view

[ https://issues.apache.org/jira/browse/FLINK-15342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15342: - Fix Version/s: (was: 1.11.0) > Verify querying Hive view > - > >

[jira] [Updated] (FLINK-15348) Fix orc optimization for version less than 2.3 by introducing orc shim

[ https://issues.apache.org/jira/browse/FLINK-15348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15348: - Fix Version/s: (was: 1.11.0) > Fix orc optimization for version less than 2.3 by introducing orc

[jira] [Updated] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15262: - Fix Version/s: (was: 1.11.0) > kafka connector doesn't read from beginning immediately when >

[jira] [Updated] (FLINK-15287) ack flink-hadoop-compatibility and flink-orc into flink-hive

[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15287: - Fix Version/s: (was: 1.11.0) > ack flink-hadoop-compatibility and flink-orc into flink-hive >

[jira] [Updated] (FLINK-15344) Update limitations in hive udf document

[ https://issues.apache.org/jira/browse/FLINK-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15344: - Fix Version/s: (was: 1.11.0) > Update limitations in hive udf document >

[jira] [Updated] (FLINK-15189) Add documentation for hive view

[ https://issues.apache.org/jira/browse/FLINK-15189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15189: - Fix Version/s: (was: 1.11.0) > Add documentation for hive view > --- >

[jira] [Updated] (FLINK-14849) Fix documentation about Hive dependencies

[ https://issues.apache.org/jira/browse/FLINK-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14849: - Fix Version/s: (was: 1.11.0) > Fix documentation about Hive dependencies >

[jira] [Updated] (FLINK-14980) add documentation and example for function DDL

[ https://issues.apache.org/jira/browse/FLINK-14980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14980: - Fix Version/s: (was: 1.11.0) > add documentation and example for function DDL >

[jira] [Updated] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15259: - Fix Version/s: (was: 1.11.0) > HiveInspector.toInspectors() should convert Flink constant to Hive

[jira] [Updated] (FLINK-15429) HiveObjectConversion implementations need to handle null values

[ https://issues.apache.org/jira/browse/FLINK-15429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15429: - Fix Version/s: (was: 1.11.0) > HiveObjectConversion implementations need to handle null values >

[jira] [Updated] (FLINK-15468) INSERT OVERWRITE not supported from SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15468: - Fix Version/s: (was: 1.11.0) > INSERT OVERWRITE not supported from SQL CLI >

[jira] [Updated] (FLINK-15380) Unable to set number of TM and number of Slot for MiniCluster in Scala shell

[ https://issues.apache.org/jira/browse/FLINK-15380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15380: - Fix Version/s: (was: 1.11.0) > Unable to set number of TM and number of Slot for MiniCluster in

[jira] [Updated] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15290: - Fix Version/s: (was: 1.11.0) > Need a way to turn off vectorized orc reader for SQL CLI >

[jira] [Updated] (FLINK-15453) Remove unneeded HiveShim methods

[ https://issues.apache.org/jira/browse/FLINK-15453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15453: - Fix Version/s: (was: 1.11.0) > Remove unneeded HiveShim methods >

[jira] [Updated] (FLINK-15437) Start session with property of "-Dtaskmanager.memory.process.size" not work

[ https://issues.apache.org/jira/browse/FLINK-15437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15437: - Fix Version/s: (was: 1.11.0) > Start session with property of "-Dtaskmanager.memory.process.size"

[jira] [Commented] (FLINK-15489) Cannot update jobmanager/taskmanager logs

[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008967#comment-17008967 ] Gary Yao commented on FLINK-15489: -- [~vthinkxie], [~lining] Do you want to take a look? > Cannot

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008965#comment-17008965 ] Andrey Zagrebin commented on FLINK-14163: - Thanks for analysis [~zhuzh]. Indeed, this is a

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008965#comment-17008965 ] Andrey Zagrebin edited comment on FLINK-14163 at 1/6/20 4:00 PM: - Thanks

[jira] [Commented] (FLINK-15489) Cannot update jobmanager/taskmanager logs

[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008962#comment-17008962 ] Dawid Wysakowicz commented on FLINK-15489: -- I did not mark it as a blocker, because I suspect

[GitHub] [flink] tillrohrmann commented on a change in pull request #10742: [FLINK-15442] Harden the Avro Confluent Schema Registry nightly end-to-end test

tillrohrmann commented on a change in pull request #10742: [FLINK-15442] Harden the Avro Confluent Schema Registry nightly end-to-end test URL: https://github.com/apache/flink/pull/10742#discussion_r363351912 ## File path: flink-end-to-end-tests/test-scripts/common.sh ##

[GitHub] [flink] tillrohrmann commented on a change in pull request #10742: [FLINK-15442] Harden the Avro Confluent Schema Registry nightly end-to-end test

tillrohrmann commented on a change in pull request #10742: [FLINK-15442] Harden the Avro Confluent Schema Registry nightly end-to-end test URL: https://github.com/apache/flink/pull/10742#discussion_r363354663 ## File path: flink-end-to-end-tests/test-scripts/kafka-common.sh

[jira] [Commented] (FLINK-15489) Cannot update jobmanager/taskmanager logs

[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008955#comment-17008955 ] Gary Yao commented on FLINK-15489: -- I promoted this to Blocker. > Cannot update jobmanager/taskmanager

[jira] [Updated] (FLINK-15489) Cannot update jobmanager/taskmanager logs

[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15489: - Priority: Blocker (was: Critical) > Cannot update jobmanager/taskmanager logs >

[jira] [Assigned] (FLINK-15490) KafkaITCase.testOneSourceMultiplePartitions fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-15490: Assignee: Jiangjie Qin > KafkaITCase.testOneSourceMultiplePartitions fails on Travis >

[jira] [Commented] (FLINK-15490) KafkaITCase.testOneSourceMultiplePartitions fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008946#comment-17008946 ] Jiangjie Qin commented on FLINK-15490: -- [~trohrmann] I did not see this failure before. But from

[jira] [Commented] (FLINK-15065) RocksDB configurable options doc description error

[ https://issues.apache.org/jira/browse/FLINK-15065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008939#comment-17008939 ] Gary Yao commented on FLINK-15065: -- Please do not set fixVersion to both 1.10.0 and 1.11.0 since 1.10.0

[jira] [Updated] (FLINK-15065) RocksDB configurable options doc description error

[ https://issues.apache.org/jira/browse/FLINK-15065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15065: - Fix Version/s: (was: 1.11.0) > RocksDB configurable options doc description error >

[GitHub] [flink] pnowojski commented on a change in pull request #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

pnowojski commented on a change in pull request #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#discussion_r363332658 ## File path:

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008929#comment-17008929 ] Gary Yao edited comment on FLINK-14163 at 1/6/20 2:58 PM: -- Since there is no

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008929#comment-17008929 ] Gary Yao commented on FLINK-14163: -- Since there is no issue when using the NettyShuffleMaster (the only

[jira] [Commented] (FLINK-15406) RocksDB savepoints with heap timers cannot be restored by non-process functions

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008917#comment-17008917 ] Seth Wiesman commented on FLINK-15406: -- [~lintingbin] You are correct, I've opened a PR that fixes

[GitHub] [flink] flinkbot commented on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions

flinkbot commented on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions URL: https://github.com/apache/flink/pull/10780#issuecomment-571163863 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] sjwiesman commented on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions

sjwiesman commented on issue #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions URL: https://github.com/apache/flink/pull/10780#issuecomment-571163796 @aljoscha if you have bandwidth this bug fix is small and self

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10666: [FLINK-15214] Introduce multiple submission e2e test

KarmaGYZ commented on a change in pull request #10666: [FLINK-15214] Introduce multiple submission e2e test URL: https://github.com/apache/flink/pull/10666#discussion_r363321661 ## File path: flink-end-to-end-tests/test-scripts/test_mesos_multiple_submissions.sh ## @@

[jira] [Updated] (FLINK-15406) RocksDB savepoints with heap timers cannot be restored by non-process functions

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15406: --- Labels: pull-request-available (was: ) > RocksDB savepoints with heap timers cannot be

[GitHub] [flink] sjwiesman opened a new pull request #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions

sjwiesman opened a new pull request #10780: [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions URL: https://github.com/apache/flink/pull/10780 ## What is the purpose of the change The keyed bootstrap operator creates an

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10666: [FLINK-15214] Introduce multiple submission e2e test

KarmaGYZ commented on a change in pull request #10666: [FLINK-15214] Introduce multiple submission e2e test URL: https://github.com/apache/flink/pull/10666#discussion_r363319026 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -456,14 +456,21 @@ function

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10666: [FLINK-15214] Introduce multiple submission e2e test

KarmaGYZ commented on a change in pull request #10666: [FLINK-15214] Introduce multiple submission e2e test URL: https://github.com/apache/flink/pull/10666#discussion_r363318382 ## File path: tools/travis/splits/split_container.sh ## @@ -51,6 +51,7 @@ run_test "Run

[GitHub] [flink] tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#discussion_r363317346 ## File path:

[GitHub] [flink] wangxlong edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

wangxlong edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-571039643 > Hi @wangxlong , What I mean: > > 1. If we fix it in `JDBCTableSource`, it should be in 1.10 and 1.9.

[jira] [Commented] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException

[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008911#comment-17008911 ] Arvid Heise commented on FLINK-15327: - Hi [~rmetzger] , this is independent of legacy source and

<    1   2   3   4   5   >