[GitHub] [flink] hequn8128 commented on issue #11350: [FLINK-16241][ml] Remove the license and notice file in flink-ml-lib module on release-1.10 branch

hequn8128 commented on issue #11350: [FLINK-16241][ml] Remove the license and notice file in flink-ml-lib module on release-1.10 branch URL: https://github.com/apache/flink/pull/11350#issuecomment-596344595 CC @zentol @walterddr @carp84

[GitHub] [flink] flinkbot commented on issue #11350: [FLINK-16241][ml] Remove the license and notice file in flink-ml-lib module on release-1.10 branch

flinkbot commented on issue #11350: [FLINK-16241][ml] Remove the license and notice file in flink-ml-lib module on release-1.10 branch URL: https://github.com/apache/flink/pull/11350#issuecomment-596344041 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] flinkbot edited a comment on issue #11349: [FLINK-16025][k8s] Parse BlobServer port from Configuration instead f using constant

flinkbot edited a comment on issue #11349: [FLINK-16025][k8s] Parse BlobServer port from Configuration instead f using constant URL: https://github.com/apache/flink/pull/11349#issuecomment-596340025 ## CI report: * 86c04349d7b5c2b2f14c58f3eb066c9fd8fa0e0c Travis:

[GitHub] [flink] hequn8128 opened a new pull request #11350: [FLINK-16241][ml] Remove the license and notice file in flink-ml-lib module on release-1.10 branch

hequn8128 opened a new pull request #11350: [FLINK-16241][ml] Remove the license and notice file in flink-ml-lib module on release-1.10 branch URL: https://github.com/apache/flink/pull/11350 ## What is the purpose of the change The jar of flink-ml-lib should not contain the

[GitHub] [flink] flinkbot edited a comment on issue #11336: [FLINK-16471][jdbc] develop PostgresJDBCCatalog

flinkbot edited a comment on issue #11336: [FLINK-16471][jdbc] develop PostgresJDBCCatalog URL: https://github.com/apache/flink/pull/11336#issuecomment-595991436 ## CI report: * 7825f1a2049defb7c15de4f2fb688799c108d01e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

flinkbot edited a comment on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE URL: https://github.com/apache/flink/pull/11346#issuecomment-596310166 ## CI report: *

[jira] [Updated] (FLINK-16241) Remove the license and notice file in flink-ml-lib module on release-1.10 branch

[ https://issues.apache.org/jira/browse/FLINK-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16241: --- Labels: pull-request-available (was: ) > Remove the license and notice file in

[GitHub] [flink] flinkbot edited a comment on issue #11336: [FLINK-16471][jdbc] develop PostgresJDBCCatalog

flinkbot edited a comment on issue #11336: [FLINK-16471][jdbc] develop PostgresJDBCCatalog URL: https://github.com/apache/flink/pull/11336#issuecomment-595991436 ## CI report: * 7825f1a2049defb7c15de4f2fb688799c108d01e Travis:

[GitHub] [flink] flinkbot commented on issue #11349: [FLINK-16025][k8s] Parse BlobServer port from Configuration instead f using constant

flinkbot commented on issue #11349: [FLINK-16025][k8s] Parse BlobServer port from Configuration instead f using constant URL: https://github.com/apache/flink/pull/11349#issuecomment-596340025 ## CI report: * 86c04349d7b5c2b2f14c58f3eb066c9fd8fa0e0c UNKNOWN Bot

[GitHub] [flink] flinkbot commented on issue #11349: [FLINK-16025][k8s] Parse BlobServer port from Configuration instead f using constant

flinkbot commented on issue #11349: [FLINK-16025][k8s] Parse BlobServer port from Configuration instead f using constant URL: https://github.com/apache/flink/pull/11349#issuecomment-596336640 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413 ## CI report: * d5078d3b1229c6391cdfe2394538ef810e9e01d4 Travis:

[jira] [Updated] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16025: --- Labels: pull-request-available (was: ) > Service could expose blob server port mismatched

[GitHub] [flink] zhengcanbin opened a new pull request #11349: [FLINK-16025][k8s] Parse BlobServer port from Configuration instead f using constant

zhengcanbin opened a new pull request #11349: [FLINK-16025][k8s] Parse BlobServer port from Configuration instead f using constant URL: https://github.com/apache/flink/pull/11349 ## What is the purpose of the change Fix bug reported by

[jira] [Commented] (FLINK-16095) Translate "Modules" page of "Table API & SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054675#comment-17054675 ] super.lee commented on FLINK-16095: --- [~jark] I can help translate this one.  > Translate "Modules"

[jira] [Updated] (FLINK-16489) User flink on yarn，RM restart AM，but the flink job is not restart from the saved checkpoint.

[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangji updated FLINK-16489: Summary: User flink on yarn，RM restart AM，but the flink job is not restart from the saved checkpoint.

[jira] [Updated] (FLINK-16489) Use flink on yarn，RM restart AM，but the flink job is not restart from the saved checkpoint.

[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangji updated FLINK-16489: Summary: Use flink on yarn，RM restart AM，but the flink job is not restart from the saved checkpoint.

[jira] [Updated] (FLINK-16489) User flink on yarn，RM restart AM，没有从失败的am保存的chk来重启

[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangji updated FLINK-16489: Summary: User flink on yarn，RM restart AM，没有从失败的am保存的chk来重启 (was: flink on

[jira] [Updated] (FLINK-16489) flink on yarn模式下，rm重启am，没有从失败的am保存的chk来重启

[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangji updated FLINK-16489: Description: 1. Environment a. flink-1.9.0 b. yarn version Hadoop 2.6.0-cdh5.5.0 Subversion 

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r389463393 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r389462959 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r389462914 ## File path:

[jira] [Reopened] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng reopened FLINK-16025: -- Backport the fix to 1.10.1 > Service could expose blob server port mismatched with JM Container

[jira] [Commented] (FLINK-15396) Support to ignore parse errors for JSON format

[ https://issues.apache.org/jira/browse/FLINK-15396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054670#comment-17054670 ] sunfulin commented on FLINK-15396: -- Hi, [~FrankZou] Is there any target version for this feature? We

[GitHub] [flink] flinkbot edited a comment on issue #11348: [FLINK-16467][core] Fix MemorySizeTest#testToHumanReadableString locale problem.

flinkbot edited a comment on issue #11348: [FLINK-16467][core] Fix MemorySizeTest#testToHumanReadableString locale problem. URL: https://github.com/apache/flink/pull/11348#issuecomment-596326491 ## CI report: * 8bbd20a5a81a2b01dd7d3ee5aa95d7d0e5563a1a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

flinkbot edited a comment on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE URL: https://github.com/apache/flink/pull/11346#issuecomment-596310166 ## CI report: *

[jira] [Commented] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054668#comment-17054668 ] Yun Gao commented on FLINK-9407: Since now _{{BucketingSink}}_ has been evolved to

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r389460599 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r389460526 ## File path:

[jira] [Commented] (FLINK-16489) flink on yarn模式下，rm重启am，没有从失败的am保存的chk来重启

[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054663#comment-17054663 ] liangji commented on FLINK-16489: - hi Xintong Song, Thanks for your reply.Additional information is as

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r389459934 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r389459880 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r389459908 ## File path:

[jira] [Commented] (FLINK-11395) Support for Avro StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054660#comment-17054660 ] Yun Gao commented on FLINK-11395: - I also think that {{_RowFormat_}} is not enough for Avro writer since

[GitHub] [flink] flinkbot commented on issue #11348: [FLINK-16467][core] Fix MemorySizeTest#testToHumanReadableString locale problem.

flinkbot commented on issue #11348: [FLINK-16467][core] Fix MemorySizeTest#testToHumanReadableString locale problem. URL: https://github.com/apache/flink/pull/11348#issuecomment-596326491 ## CI report: * 8bbd20a5a81a2b01dd7d3ee5aa95d7d0e5563a1a UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11336: [FLINK-16471][jdbc] develop PostgresJDBCCatalog

flinkbot edited a comment on issue #11336: [FLINK-16471][jdbc] develop PostgresJDBCCatalog URL: https://github.com/apache/flink/pull/11336#issuecomment-595991436 ## CI report: * 7f8e8521f5e342d9d8495ba7930d323d27e7ed3f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413 ## CI report: * d5078d3b1229c6391cdfe2394538ef810e9e01d4 Travis:

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14971: - Description: Currently the ACK and declined message handling are executed in IO thread. This is the

[jira] [Commented] (FLINK-16467) MemorySizeTest#testToHumanReadableString() is not portable

[ https://issues.apache.org/jira/browse/FLINK-16467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054658#comment-17054658 ] Xintong Song commented on FLINK-16467: -- [~zhuzh], thanks for assigning me, I've opened a PR. Please

[GitHub] [flink] flinkbot commented on issue #11348: [FLINK-16467][core] Fix MemorySizeTest#testToHumanReadableString locale problem.

flinkbot commented on issue #11348: [FLINK-16467][core] Fix MemorySizeTest#testToHumanReadableString locale problem. URL: https://github.com/apache/flink/pull/11348#issuecomment-596324358 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] xintongsong opened a new pull request #11348: [FLINK-16467][core] Fix MemorySizeTest#testToHumanReadableString locale problem.

xintongsong opened a new pull request #11348: [FLINK-16467][core] Fix MemorySizeTest#testToHumanReadableString locale problem. URL: https://github.com/apache/flink/pull/11348 ## What is the purpose of the change This PR fix the problem that `MemorySize#toHumanReadableString`

[jira] [Updated] (FLINK-16467) MemorySizeTest#testToHumanReadableString() is not portable

[ https://issues.apache.org/jira/browse/FLINK-16467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16467: --- Labels: pull-request-available (was: ) > MemorySizeTest#testToHumanReadableString() is not

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN *

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14971: - Description: Currently the ACK and declined message handling are executed in IO thread. This is the

[GitHub] [flink] flinkbot commented on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

flinkbot commented on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413 ## CI report: * d5078d3b1229c6391cdfe2394538ef810e9e01d4 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11345: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

flinkbot edited a comment on issue #11345: [FLINK-16491][formats] Add compression support for ParquetAvroWriters URL: https://github.com/apache/flink/pull/11345#issuecomment-596220156 ## CI report: * 63da09b1ce552af7a17b76c1025800638fbb21ae Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11336: [FLINK-16471][jdbc] develop PostgresJDBCCatalog

flinkbot edited a comment on issue #11336: [FLINK-16471][jdbc] develop PostgresJDBCCatalog URL: https://github.com/apache/flink/pull/11336#issuecomment-595991436 ## CI report: * 7f8e8521f5e342d9d8495ba7930d323d27e7ed3f Travis:

[jira] [Updated] (FLINK-16467) MemorySizeTest#testToHumanReadableString() is not portable

[ https://issues.apache.org/jira/browse/FLINK-16467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16467: - Fix Version/s: 1.11.0 1.10.1 > MemorySizeTest#testToHumanReadableString() is

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r389455647 ## File path:

[GitHub] [flink] flinkbot commented on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

flinkbot commented on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596322115 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Resolved] (FLINK-16450) Integrate parquet columnar row reader to hive

[ https://issues.apache.org/jira/browse/FLINK-16450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16450. -- Resolution: Fixed Master: a68f5fde472de8a351726239a936ca2acf8073a3 > Integrate parquet

[jira] [Updated] (FLINK-14971) Move ACK and declined message handling in the same thread with triggering

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14971: --- Labels: pull-request-available (was: ) > Move ACK and declined message handling in the

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

ifndef-SleePy opened a new pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347 ## What is the purpose of the change * This is the last part of refactoring threading

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-14971: - Summary: Make all the non-IO operations in CheckpointCoordinator single-threaded (was: Move ACK and

[GitHub] [flink] JingsongLi merged pull request #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

JingsongLi merged pull request #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327 This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15352: - Summary: develop MySQLCatalog to connect Flink with MySQL tables and ecosystem (was: develop

[jira] [Updated] (FLINK-16474) develop OracleCatalog to connect Flink with Oracle databases and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-16474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16474: - Summary: develop OracleCatalog to connect Flink with Oracle databases and ecosystem (was: develop

[jira] [Updated] (FLINK-15351) develop PostgresCatalog to connect Flink with Postgres tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15351: - Summary: develop PostgresCatalog to connect Flink with Postgres tables and ecosystem (was: develop

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r389454700 ## File path:

[jira] [Created] (FLINK-16498) make Postgres table work end-2-end in Flink SQL with PostgresJDBCCatalog

Bowen Li created FLINK-16498: Summary: make Postgres table work end-2-end in Flink SQL with PostgresJDBCCatalog Key: FLINK-16498 URL: https://issues.apache.org/jira/browse/FLINK-16498 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327#issuecomment-595580274 ## CI report: * 36e589c681957f4c13d33ac2d8e82d18dc57697a Travis:

[jira] [Commented] (FLINK-16467) MemorySizeTest#testToHumanReadableString() is not portable

[ https://issues.apache.org/jira/browse/FLINK-16467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054647#comment-17054647 ] Zhu Zhu commented on FLINK-16467: - Thanks [~michael-o] for reporting the issue. And thanks

[jira] [Assigned] (FLINK-16467) MemorySizeTest#testToHumanReadableString() is not portable

[ https://issues.apache.org/jira/browse/FLINK-16467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-16467: --- Assignee: Xintong Song > MemorySizeTest#testToHumanReadableString() is not portable >

[jira] [Commented] (FLINK-16467) MemorySizeTest#testToHumanReadableString() is not portable

[ https://issues.apache.org/jira/browse/FLINK-16467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054644#comment-17054644 ] Xintong Song commented on FLINK-16467: -- [~michael-o] Thanks for reporting this issue. I think this

[jira] [Created] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

Jark Wu created FLINK-16497: --- Summary: Improve default flush strategy for JDBC sink to make it work out-of-box Key: FLINK-16497 URL: https://issues.apache.org/jira/browse/FLINK-16497 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

flinkbot edited a comment on issue #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink URL: https://github.com/apache/flink/pull/11326#issuecomment-595547530 ## CI report: * efb8d8a1f81768d07cf099baceffa8e871ea91bd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN *

[jira] [Created] (FLINK-16496) Improve default flush strategy for HBase sink to make it work out-of-box

Jark Wu created FLINK-16496: --- Summary: Improve default flush strategy for HBase sink to make it work out-of-box Key: FLINK-16496 URL: https://issues.apache.org/jira/browse/FLINK-16496 Project: Flink

[jira] [Commented] (FLINK-16489) flink on yarn模式下，rm重启am，没有从失败的am保存的chk来重启

[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054641#comment-17054641 ] Xintong Song commented on FLINK-16489: -- Hi [~liangji], Thanks for reporting this bug. Could you

[jira] [Updated] (FLINK-16495) Improve default flush strategy for Elasticsearch sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16495: Labels: usability (was: ) > Improve default flush strategy for Elasticsearch sink to make it work >

[jira] [Commented] (FLINK-16495) Improve default flush strategy for Elasticsearch sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054640#comment-17054640 ] Jark Wu commented on FLINK-16495: - The bulk flush interval should be discussed, and should have a

[jira] [Created] (FLINK-16495) Improve default flush strategy for Elasticsearch sink to make it work out-of-box

Jark Wu created FLINK-16495: --- Summary: Improve default flush strategy for Elasticsearch sink to make it work out-of-box Key: FLINK-16495 URL: https://issues.apache.org/jira/browse/FLINK-16495 Project:

[jira] [Commented] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054637#comment-17054637 ] Yang Wang commented on FLINK-16025: --- I agree to backport the fix to 1.10. > Service could expose blob

[jira] [Commented] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054636#comment-17054636 ] Canbin Zheng commented on FLINK-16025: -- Thanks for the reminder [~fly_in_gis]. 1.10.1 is not

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

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

[GitHub] [flink] flinkbot edited a comment on issue #11345: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

flinkbot edited a comment on issue #11345: [FLINK-16491][formats] Add compression support for ParquetAvroWriters URL: https://github.com/apache/flink/pull/11345#issuecomment-596220156 ## CI report: * 63da09b1ce552af7a17b76c1025800638fbb21ae Travis:

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054634#comment-17054634 ] Yang Wang commented on FLINK-16478: --- Do you mean to support dynamic logging level? If it is, i think

[GitHub] [flink] flinkbot edited a comment on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

flinkbot edited a comment on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE URL: https://github.com/apache/flink/pull/11346#issuecomment-596310166 ## CI report: *

[jira] [Commented] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054632#comment-17054632 ] Yang Wang commented on FLINK-16025: --- I am afraid we should remove the {{1.10.1}} from the fixed

[jira] [Updated] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-16025: -- Fix Version/s: (was: 1.10.1) > Service could expose blob server port mismatched with JM Container

[GitHub] [flink] zhengcanbin commented on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

zhengcanbin commented on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE URL: https://github.com/apache/flink/pull/11346#issuecomment-596311156 > Thanks for your contribution @zhengcanbin ! > > One thing to

[GitHub] [flink] flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327#issuecomment-595580274 ## CI report: * 36e589c681957f4c13d33ac2d8e82d18dc57697a Travis:

[GitHub] [flink] flinkbot commented on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

flinkbot commented on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE URL: https://github.com/apache/flink/pull/11346#issuecomment-596310166 ## CI report: * f48f981af0a4984aaa4159080505f925744e6c29

[jira] [Assigned] (FLINK-16494) Use enum type instead of string type for KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

[ https://issues.apache.org/jira/browse/FLINK-16494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-16494: - Assignee: Canbin Zheng > Use enum type instead of string type for >

[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=17054621#comment-17054621 ] Caizhi Weng commented on FLINK-14807: - Hi [~sewen] What I'm worrying about is not the stress on the

[jira] [Updated] (FLINK-16494) Use enum type instead of string type for KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

[ https://issues.apache.org/jira/browse/FLINK-16494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16494: - Description: At the moment the value of

[jira] [Created] (FLINK-16494) Use enum type instead of string type for KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

Canbin Zheng created FLINK-16494: Summary: Use enum type instead of string type for KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY Key: FLINK-16494 URL: https://issues.apache.org/jira/browse/FLINK-16494

[jira] [Commented] (FLINK-16476) SelectivityEstimatorTest logs LinkageErrors

[ https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054619#comment-17054619 ] Jark Wu commented on FLINK-16476: - cc [~godfreyhe], can {{@PowerMockIgnore("javax.management.*")}}

[GitHub] [flink] flinkbot commented on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

flinkbot commented on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE URL: https://github.com/apache/flink/pull/11346#issuecomment-596306981 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Assigned] (FLINK-16493) Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

[ https://issues.apache.org/jira/browse/FLINK-16493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-16493: - Assignee: Canbin Zheng (was: Zili Chen) > Use enum type instead of string type for >

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

flinkbot edited a comment on issue #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink URL: https://github.com/apache/flink/pull/11326#issuecomment-595547530 ## CI report: * efb8d8a1f81768d07cf099baceffa8e871ea91bd Travis:

[jira] [Updated] (FLINK-16493) Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

[ https://issues.apache.org/jira/browse/FLINK-16493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16493: --- Labels: pull-request-available (was: ) > Use enum type instead of string type for >

[GitHub] [flink] zhengcanbin opened a new pull request #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

zhengcanbin opened a new pull request #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE URL: https://github.com/apache/flink/pull/11346 ## What is the purpose of the change At the moment the value of

[jira] [Commented] (FLINK-16479) TableUtilsStreamingITCase crashes

[ https://issues.apache.org/jira/browse/FLINK-16479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054618#comment-17054618 ] Jark Wu commented on FLINK-16479: - I guess it's due to the unstable environment. Let's keep watching on

[jira] [Commented] (FLINK-16319) Pubsub-/Broadcast implementation

[ https://issues.apache.org/jira/browse/FLINK-16319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054617#comment-17054617 ] Tzu-Li (Gordon) Tai commented on FLINK-16319: - Hi [~danp11]! Would like to take a step back

[jira] [Updated] (FLINK-16481) Improved FlinkkafkaConnector support for dynamically increasing capacity

[ https://issues.apache.org/jira/browse/FLINK-16481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16481: Component/s: (was: API / Core) Connectors / Kafka > Improved FlinkkafkaConnector

[jira] [Commented] (FLINK-16090) Translate "Table API" page of "Table API & SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054616#comment-17054616 ] Jark Wu commented on FLINK-16090: - Hi [~super.lee], I'm glad to help. If you are first time contributor,

[GitHub] [flink] TisonKun commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

TisonKun commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r389440058 ## File path:

  1   2   >