[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353698841 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10376: [FLINK-14907] [filesystem] Make Azure Storage Key configurable via Environment Variable

flinkbot edited a comment on issue #10376: [FLINK-14907] [filesystem] Make Azure Storage Key configurable via Environment Variable URL: https://github.com/apache/flink/pull/10376#issuecomment-560269221 ## CI report: * ab1dcfbe1fac150e4be884dba92e29f0e345847b : FAILURE

[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353596503 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : SUCCESS

[GitHub] [flink] StephanEwen commented on issue #10405: [FLINK-15044][e2e tests] Clean up TpcdsResultComparator

StephanEwen commented on issue #10405: [FLINK-15044][e2e tests] Clean up TpcdsResultComparator URL: https://github.com/apache/flink/pull/10405#issuecomment-561535934 I am getting an error at the moment that the log files / out files are non empty, which is strange, since nothing in the

[GitHub] [flink] zjuwangg commented on issue #10394: [FLINK-14663]Distinguish catalogColumnStats' unknown value and real values

zjuwangg commented on issue #10394: [FLINK-14663]Distinguish catalogColumnStats' unknown value and real values URL: https://github.com/apache/flink/pull/10394#issuecomment-561546525 @flinkbot run travis This is an automated

[GitHub] [flink] dawidwys commented on issue #10417: [FLINK-14910][datastream] Checking for auto generated uids only for PhysicalStreamTransformations

dawidwys commented on issue #10417: [FLINK-14910][datastream] Checking for auto generated uids only for PhysicalStreamTransformations URL: https://github.com/apache/flink/pull/10417#issuecomment-561551448 Could you have a look @aljoscha when you have time?

[GitHub] [flink] zhuzhurk commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

zhuzhurk commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353634356 ## File path:

[jira] [Commented] (FLINK-15047) YarnDistributedCacheITCase is unstable

[ https://issues.apache.org/jira/browse/FLINK-15047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987684#comment-16987684 ] Gary Yao commented on FLINK-15047: -- Running this test locally failed 10 out of 10 times. I am promoting

[GitHub] [flink] KurtYoung commented on issue #10405: [FLINK-15044][e2e tests] Clean up TpcdsResultComparator

KurtYoung commented on issue #10405: [FLINK-15044][e2e tests] Clean up TpcdsResultComparator URL: https://github.com/apache/flink/pull/10405#issuecomment-561555801 No, what's in the out files? This is an automated message

[jira] [Updated] (FLINK-15047) YarnDistributedCacheITCase is unstable

[ https://issues.apache.org/jira/browse/FLINK-15047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15047: - Priority: Blocker (was: Critical) > YarnDistributedCacheITCase is unstable >

[GitHub] [flink] docete commented on a change in pull request #10399: [FLINK-14959][table-planner-blink] Support precision of LocalZonedTimestampType in blink planner

docete commented on a change in pull request #10399: [FLINK-14959][table-planner-blink] Support precision of LocalZonedTimestampType in blink planner URL: https://github.com/apache/flink/pull/10399#discussion_r353643575 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10399: [FLINK-14959][table-planner-blink] Support precision of LocalZonedTimestampType in blink planner

docete commented on a change in pull request #10399: [FLINK-14959][table-planner-blink] Support precision of LocalZonedTimestampType in blink planner URL: https://github.com/apache/flink/pull/10399#discussion_r353644061 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#issuecomment-555375223 ## CI report: * 71f8401be1cb214e56f94e486c495ef7c800cfc4 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor…

flinkbot commented on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor… URL: https://github.com/apache/flink/pull/10418#issuecomment-561567846 ## CI report: * 6951e77dff9c9c4fb1945d79ef4253e5ea2c0f0f : UNKNOWN Bot commands The

[GitHub] [flink] zhuzhurk commented on issue #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

zhuzhurk commented on issue #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#issuecomment-561567847 Thanks for addressing all the comments @GJL . The change looks good to me now. +1 to merge it.

[GitHub] [flink] flinkbot commented on issue #10417: [FLINK-14910][datastream] Checking for auto generated uids only for PhysicalStreamTransformations

flinkbot commented on issue #10417: [FLINK-14910][datastream] Checking for auto generated uids only for PhysicalStreamTransformations URL: https://github.com/apache/flink/pull/10417#issuecomment-561567788 ## CI report: * 64b24f882e32caebd6489f890ca477305acf31cc : UNKNOWN

[GitHub] [flink] docete commented on a change in pull request #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor…

docete commented on a change in pull request #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor… URL: https://github.com/apache/flink/pull/10418#discussion_r353661204 ## File path:

[jira] [Commented] (FLINK-15036) Container startup error will be handled out side of the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987719#comment-16987719 ] Hequn Cheng commented on FLINK-15036: - [~trohrmann] [~fly_in_gis] OK, let's make the fix in 1.8.3.

[GitHub] [flink] flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties

flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties URL: https://github.com/apache/flink/pull/10403#issuecomment-561208418 ## CI report: * 038052c833940fbaef3111ed92525216f13edee2 :

[GitHub] [flink] flinkbot edited a comment on issue #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

flinkbot edited a comment on issue #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#issuecomment-561380440 ## CI report: * 0effd7f6b294b7f2da91c7681aa6e8ae51390efc : UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #10407: [FLINK-15036][yarn] Container startup error should be handled inside …

flinkbot edited a comment on issue #10407: [FLINK-15036][yarn] Container startup error should be handled inside … URL: https://github.com/apache/flink/pull/10407#issuecomment-561438459 ## CI report: * b2b3c2ee9ab0fcd6e1be873949f8f04ed0ef6baf : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10410: [FLINK-14692][table]support rename/alter table in tableEnvironment in both flink/blink planner

flinkbot edited a comment on issue #10410: [FLINK-14692][table]support rename/alter table in tableEnvironment in both flink/blink planner URL: https://github.com/apache/flink/pull/10410#issuecomment-561453526 ## CI report: * de0b3736069c62629a17afb60190abaa251ba33e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10408: [FLINK-14992][client] Add job listener to execution environments

flinkbot edited a comment on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-561446399 ## CI report: * 26dba18b2fd51c8df67cc33eace890b5ca34e182 : CANCELED

[GitHub] [flink] flinkbot commented on issue #10419: [FLINK-15026][SQL-CLIENT]Support create/drop/alter database in sql client

flinkbot commented on issue #10419: [FLINK-15026][SQL-CLIENT]Support create/drop/alter database in sql client URL: https://github.com/apache/flink/pull/10419#issuecomment-561585485 ## CI report: * 043379493823c0ac38c05d355471079d6808d16a : UNKNOWN Bot commands

[GitHub] [flink] docete commented on a change in pull request #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor…

docete commented on a change in pull request #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor… URL: https://github.com/apache/flink/pull/10418#discussion_r353677719 ## File path:

[GitHub] [flink] shuttie commented on issue #10358: [FLINK-14346] [serialization] faster implementation of StringValue writeString and readString

shuttie commented on issue #10358: [FLINK-14346] [serialization] faster implementation of StringValue writeString and readString URL: https://github.com/apache/flink/pull/10358#issuecomment-561599467 @StephanEwen yes, most of the difference comes from multiple single-byte read operations.

[GitHub] [flink] StephanEwen commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

StephanEwen commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#discussion_r353683739 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10358: [FLINK-14346] [serialization] faster implementation of StringValue writeString and readString

flinkbot edited a comment on issue #10358: [FLINK-14346] [serialization] faster implementation of StringValue writeString and readString URL: https://github.com/apache/flink/pull/10358#issuecomment-559765475 ## CI report: * b106e8b0327fb78ebac1894a8f8fa51718b3bbba : SUCCESS

[jira] [Comment Edited] (FLINK-14346) Performance issue with StringSerializer

[ https://issues.apache.org/jira/browse/FLINK-14346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987752#comment-16987752 ] Roman Grebennikov edited comment on FLINK-14346 at 12/4/19 11:27 AM: -

[GitHub] [flink] lirui-apache commented on issue #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog

lirui-apache commented on issue #10325: [FLINK-14512][table] Introduce listPartitionsByFilter to Catalog URL: https://github.com/apache/flink/pull/10325#issuecomment-561615012 Thanks @JingsongLi for the update. It seems the failed test is related?

[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353704816 ## File path:

[GitHub] [flink] HuangXingBo commented on a change in pull request #10086: [FLINK-14584][python] Support complex data types in Python user-defined functions

HuangXingBo commented on a change in pull request #10086: [FLINK-14584][python] Support complex data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10086#discussion_r353703904 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : SUCCESS

[GitHub] [flink] GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353609672 ## File path:

[jira] [Commented] (FLINK-15050) DataFormatConverters should support any TIMESTAMP WITHOUT TIME ZONE types

[ https://issues.apache.org/jira/browse/FLINK-15050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987671#comment-16987671 ] Zhenghua Gao commented on FLINK-15050: -- User may pass any TIMESTAMP WITHOUT TIME ZONE in, e.g.:

[jira] [Updated] (FLINK-14910) disableAutoGeneratedUIDs fails on keyBy

[ https://issues.apache.org/jira/browse/FLINK-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14910: - Fix Version/s: 1.9.2 1.10.0 > disableAutoGeneratedUIDs fails on

[GitHub] [flink] GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353620416 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10394: [FLINK-14663]Distinguish catalogColumnStats' unknown value and real values

flinkbot edited a comment on issue #10394: [FLINK-14663]Distinguish catalogColumnStats' unknown value and real values URL: https://github.com/apache/flink/pull/10394#issuecomment-561095403 ## CI report: * 68e77528300eadcbeaa62372d676b01e268c39a8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10399: [FLINK-14959][table-planner-blink] Support precision of LocalZonedTimestampType in blink planner

flinkbot edited a comment on issue #10399: [FLINK-14959][table-planner-blink] Support precision of LocalZonedTimestampType in blink planner URL: https://github.com/apache/flink/pull/10399#issuecomment-561147932 ## CI report: * 526d1701763e74c12064e6b7f48b8f41f4857bd8 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10417: [FLINK-14910][datastream] Checking for auto generated uids only for PhysicalStreamTransformations

flinkbot commented on issue #10417: [FLINK-14910][datastream] Checking for auto generated uids only for PhysicalStreamTransformations URL: https://github.com/apache/flink/pull/10417#issuecomment-561552116 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353628288 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager

flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager URL: https://github.com/apache/flink/pull/10388#issuecomment-560948011 ## CI report: * bd56213c9d550b0815cea7467929ae853a86c68b : SUCCESS

[jira] [Commented] (FLINK-15040) Open function is not called in UDF AggregateFunction

[ https://issues.apache.org/jira/browse/FLINK-15040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987694#comment-16987694 ] LI Guobao commented on FLINK-15040: --- Hi [~jark], thanks for the quick response. In fact, I am using a

[GitHub] [flink] flinkbot commented on issue #10419: [FLINK-15026][SQL-CLIENT]Support create/drop/alter database in sql client

flinkbot commented on issue #10419: [FLINK-15026][SQL-CLIENT]Support create/drop/alter database in sql client URL: https://github.com/apache/flink/pull/10419#issuecomment-561571731 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Assigned] (FLINK-15036) Container startup error will be handled out side of the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15036: - Assignee: Yang Wang > Container startup error will be handled out side of the

[GitHub] [flink] flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager

flinkbot edited a comment on issue #10388: [FLINK-14912][Table] create, drop catalog functions through catalog manager URL: https://github.com/apache/flink/pull/10388#issuecomment-560948011 ## CI report: * bd56213c9d550b0815cea7467929ae853a86c68b : SUCCESS

[GitHub] [flink] StephanEwen commented on a change in pull request #10384: [FLINK-13373][docs] Remove Tutorials and Examples sections from Getting Started

StephanEwen commented on a change in pull request #10384: [FLINK-13373][docs] Remove Tutorials and Examples sections from Getting Started URL: https://github.com/apache/flink/pull/10384#discussion_r353666924 ## File path: docs/ops/deployment/local.md ## @@ -0,0 +1,178 @@

[GitHub] [flink] flinkbot edited a comment on issue #10402: [FLINK-15034] Bump FRocksDB version for memory control

flinkbot edited a comment on issue #10402: [FLINK-15034] Bump FRocksDB version for memory control URL: https://github.com/apache/flink/pull/10402#issuecomment-561192090 ## CI report: * 95cbeaca2fe81774a19a20080089a4ead28bb238 : SUCCESS

[GitHub] [flink] StephanEwen commented on issue #10384: [FLINK-13373][docs] Remove Tutorials and Examples sections from Getting Started

StephanEwen commented on issue #10384: [FLINK-13373][docs] Remove Tutorials and Examples sections from Getting Started URL: https://github.com/apache/flink/pull/10384#issuecomment-561584312 Looks pretty good, thanks! One minor comment, otherwise good to merge from my side.

[GitHub] [flink] zentol merged pull request #10374: [Doc] 'Connect to External Systems' links to an error URL in Table API & SQL page

zentol merged pull request #10374: [Doc] 'Connect to External Systems' links to an error URL in Table API & SQL page URL: https://github.com/apache/flink/pull/10374 This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on issue #10419: [FLINK-15026][SQL-CLIENT]Support create/drop/alter database in sql client

flinkbot edited a comment on issue #10419: [FLINK-15026][SQL-CLIENT]Support create/drop/alter database in sql client URL: https://github.com/apache/flink/pull/10419#issuecomment-561585485 ## CI report: * 043379493823c0ac38c05d355471079d6808d16a : PENDING

[GitHub] [flink] StephanEwen opened a new pull request #10420: [FLINK-15051][state-backends] Fix typo in RocksDBStateBackend.getNumberOfTransferingThreads

StephanEwen opened a new pull request #10420: [FLINK-15051][state-backends] Fix typo in RocksDBStateBackend.getNumberOfTransferingThreads URL: https://github.com/apache/flink/pull/10420 ## What is the purpose of the change This fixes a simple typo in the

[jira] [Updated] (FLINK-15051) Typo in RocksDBStateBackend getNumberOfTransferingThread

[ https://issues.apache.org/jira/browse/FLINK-15051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15051: --- Labels: pull-request-available (was: ) > Typo in RocksDBStateBackend

[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353700832 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353700890 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353709213 ## File path:

[jira] [Created] (FLINK-15052) sql client doesn't clear previous job graph

Kurt Young created FLINK-15052: -- Summary: sql client doesn't clear previous job graph Key: FLINK-15052 URL: https://issues.apache.org/jira/browse/FLINK-15052 Project: Flink Issue Type: Bug

[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353709213 ## File path:

[GitHub] [flink] TisonKun commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments

TisonKun commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-561522851 @zjffdu I've integrated your comments. It would be quite helpful if you try out this patch in Zeppelin use case so

[GitHub] [flink] Myasuka opened a new pull request #10416: [FLINK-14484] Enable to control memory usage of RocksDB via Cache and WriteBufferManager

Myasuka opened a new pull request #10416: [FLINK-14484] Enable to control memory usage of RocksDB via Cache and WriteBufferManager URL: https://github.com/apache/flink/pull/10416 ## What is the purpose of the change Enable to control memory usage of RocksDB via Cache and

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

[ https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987637#comment-16987637 ] Timo Walther commented on FLINK-14567: -- In general, I think the key information should come from

[jira] [Updated] (FLINK-14484) Modify RocksDB backend to bound total memory via Cache with WriteBufferManager

[ https://issues.apache.org/jira/browse/FLINK-14484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14484: --- Labels: pull-request-available (was: ) > Modify RocksDB backend to bound total memory via

[jira] [Commented] (FLINK-14346) Performance issue with StringSerializer

[ https://issues.apache.org/jira/browse/FLINK-14346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987643#comment-16987643 ] Roman Grebennikov commented on FLINK-14346: --- Benchmarks for larger strings are also constantly

[jira] [Comment Edited] (FLINK-14572) BlobsCleanupITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987642#comment-16987642 ] Yun Gao edited comment on FLINK-14572 at 12/4/19 8:20 AM: -- Hi all [~zhuzh]

[jira] [Commented] (FLINK-14572) BlobsCleanupITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987642#comment-16987642 ] Yun Gao commented on FLINK-14572: - Hi all [~zhuzh] [~gjy] [~trohrmann] Could you still find the detail

[GitHub] [flink] GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353605735 ## File path:

[GitHub] [flink] zhijiangW commented on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-561534031 Thanks for the suggestions @pnowojski , i would create tickets for supplementing the

[GitHub] [flink] KurtYoung commented on issue #10405: [FLINK-15044][e2e tests] Clean up TpcdsResultComparator

KurtYoung commented on issue #10405: [FLINK-15044][e2e tests] Clean up TpcdsResultComparator URL: https://github.com/apache/flink/pull/10405#issuecomment-561534222 BTW I've ran this locally and the results looks good to me.

[GitHub] [flink] wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353615757 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r353615760 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10401: [FLINK-15020][hive] Support timestamp type in hive

lirui-apache commented on a change in pull request #10401: [FLINK-15020][hive] Support timestamp type in hive URL: https://github.com/apache/flink/pull/10401#discussion_r353619390 ## File path:

[jira] [Updated] (FLINK-14847) Support retrieving Hive PK constraints

[ https://issues.apache.org/jira/browse/FLINK-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14847: - Fix Version/s: 1.10.0 > Support retrieving Hive PK constraints >

[jira] [Updated] (FLINK-15050) DataFormatConverters should support any TIMESTAMP WITHOUT TIME ZONE types

[ https://issues.apache.org/jira/browse/FLINK-15050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-15050: - Summary: DataFormatConverters should support any TIMESTAMP WITHOUT TIME ZONE types (was:

[GitHub] [flink] flinkbot edited a comment on issue #10416: [FLINK-14484] Enable to control memory usage of RocksDB via Cache and WriteBufferManager

flinkbot edited a comment on issue #10416: [FLINK-14484] Enable to control memory usage of RocksDB via Cache and WriteBufferManager URL: https://github.com/apache/flink/pull/10416#issuecomment-561539660 ## CI report: * 32d4ffce9d515f19045ff5a13a9602f0b52d3196 : PENDING

[GitHub] [flink] TisonKun commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments

TisonKun commented on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-561553419 @aljoscha I rewrite `doClose` as described above & see also [this

[jira] [Updated] (FLINK-15047) YarnDistributedCacheITCase is unstable

[ https://issues.apache.org/jira/browse/FLINK-15047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15047: - Priority: Critical (was: Major) > YarnDistributedCacheITCase is unstable >

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

[ https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987697#comment-16987697 ] Jark Wu commented on FLINK-14567: - [~ykt836], could we just use the key constraint in

[GitHub] [flink] GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353648962 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353648524 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353648524 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

GJL commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353648809 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10402: [FLINK-15034] Bump FRocksDB version for memory control

flinkbot edited a comment on issue #10402: [FLINK-15034] Bump FRocksDB version for memory control URL: https://github.com/apache/flink/pull/10402#issuecomment-561192090 ## CI report: * 95cbeaca2fe81774a19a20080089a4ead28bb238 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

flinkbot edited a comment on issue #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#issuecomment-561380440 ## CI report: * 0effd7f6b294b7f2da91c7681aa6e8ae51390efc : UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #10408: [FLINK-14992][client] Add job listener to execution environments

flinkbot edited a comment on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-561446399 ## CI report: * 26dba18b2fd51c8df67cc33eace890b5ca34e182 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10405: [FLINK-15044][e2e tests] Clean up TpcdsResultComparator

flinkbot edited a comment on issue #10405: [FLINK-15044][e2e tests] Clean up TpcdsResultComparator URL: https://github.com/apache/flink/pull/10405#issuecomment-561357224 ## CI report: * 64e540fceb0db97c160528fef909066332c30ae1 : FAILURE

[GitHub] [flink] zhuzhurk commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode

zhuzhurk commented on a change in pull request #10406: [FLINK-15045][runtime] Only log RestartStrategy in legacy scheduling mode URL: https://github.com/apache/flink/pull/10406#discussion_r353649449 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties

flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties URL: https://github.com/apache/flink/pull/10403#issuecomment-561208418 ## CI report: * 038052c833940fbaef3111ed92525216f13edee2 :

[GitHub] [flink] flinkbot edited a comment on issue #10407: [FLINK-15036][yarn] Container startup error should be handled inside …

flinkbot edited a comment on issue #10407: [FLINK-15036][yarn] Container startup error should be handled inside … URL: https://github.com/apache/flink/pull/10407#issuecomment-561438459 ## CI report: * b2b3c2ee9ab0fcd6e1be873949f8f04ed0ef6baf : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10395: [FLINK-15030][runtime] Fix deadlock problem of blocking ResultPartition with minimum required buffers.

flinkbot edited a comment on issue #10395: [FLINK-15030][runtime] Fix deadlock problem of blocking ResultPartition with minimum required buffers. URL: https://github.com/apache/flink/pull/10395#issuecomment-561110807 ## CI report: * 65ed75c84a94219f748a5ea0fbdfddbfbddf2bed :

[GitHub] [flink] shuttie commented on issue #10358: [FLINK-14346] [serialization] faster implementation of StringValue writeString and readString

shuttie commented on issue #10358: [FLINK-14346] [serialization] faster implementation of StringValue writeString and readString URL: https://github.com/apache/flink/pull/10358#issuecomment-561581868 @pnowojski as for large strings, this implementation is also looking quite nice: ```

[GitHub] [flink] StephanEwen commented on issue #10383: [FLINK-14997] Avoid to call unnecessary delete within RocksDBState's mergeNamespaces implementation

StephanEwen commented on issue #10383: [FLINK-14997] Avoid to call unnecessary delete within RocksDBState's mergeNamespaces implementation URL: https://github.com/apache/flink/pull/10383#issuecomment-561586106 Looks good to me, thanks for that patch! Merging this...

[GitHub] [flink] StephanEwen commented on issue #10383: [FLINK-14997] Avoid to call unnecessary delete within RocksDBState's mergeNamespaces implementation

StephanEwen commented on issue #10383: [FLINK-14997] Avoid to call unnecessary delete within RocksDBState's mergeNamespaces implementation URL: https://github.com/apache/flink/pull/10383#issuecomment-561585998 @flinkbot approve all

[GitHub] [flink] zentol merged pull request #10373: [hotfix][typo] Fix location typo in FsCompletedCheckpointStorageLocation

zentol merged pull request #10373: [hotfix][typo] Fix location typo in FsCompletedCheckpointStorageLocation URL: https://github.com/apache/flink/pull/10373 This is an automated message from the Apache Git Service. To

[GitHub] [flink] StephanEwen commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

StephanEwen commented on a change in pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#discussion_r353681336 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time

flinkbot edited a comment on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time URL: https://github.com/apache/flink/pull/8746#issuecomment-528887595 ## CI report: * ed381a566a61e9d5e0677cc0b68e1eee4a4bf46d : SUCCESS

[jira] [Commented] (FLINK-14346) Performance issue with StringSerializer

[ https://issues.apache.org/jira/browse/FLINK-14346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987752#comment-16987752 ] Roman Grebennikov commented on FLINK-14346: --- [~arvid heise] current progress: # I've modified

[GitHub] [flink] flinkbot edited a comment on issue #10394: [FLINK-14663]Distinguish catalogColumnStats' unknown value and real values

flinkbot edited a comment on issue #10394: [FLINK-14663]Distinguish catalogColumnStats' unknown value and real values URL: https://github.com/apache/flink/pull/10394#issuecomment-561095403 ## CI report: * 68e77528300eadcbeaa62372d676b01e268c39a8 : SUCCESS

[jira] [Assigned] (FLINK-15047) YarnDistributedCacheITCase is unstable

[ https://issues.apache.org/jira/browse/FLINK-15047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-15047: --- Assignee: Xintong Song (was: Andrey Zagrebin) > YarnDistributedCacheITCase is

[GitHub] [flink] zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

zhijiangW commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r353594652 ## File path:

<    1   2   3   4   5   6   7   8   9   10   >