[GitHub] [flink] wuchong opened a new pull request #9326: [FLINK-13543][table-planner-blink] Enable reuse forks for integration tests in blink planner

wuchong opened a new pull request #9326: [FLINK-13543][table-planner-blink] Enable reuse forks for integration tests in blink planner URL: https://github.com/apache/flink/pull/9326 ## What is the purpose of the change Enable reuse forks for integration tests in blink

[GitHub] [flink] flinkbot edited a comment on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value

flinkbot edited a comment on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value. URL: https://github.com/apache/flink/pull/9285#issuecomment-516712727 ## CI report: * bb70e45a98e

[GitHub] [flink] flinkbot edited a comment on issue #9277: [FLINK-13494][table-planner-blink] Only use env parallelism for sql job

flinkbot edited a comment on issue #9277: [FLINK-13494][table-planner-blink] Only use env parallelism for sql job URL: https://github.com/apache/flink/pull/9277#issuecomment-516388088 ## CI report: * 7bebdd65247ac172a23f9b0a91873b01b554cd71 : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#issuecomment-517175361 ## CI report: * bf81288dc40cf5a3bee5ece840d21821ea903135 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] Myasuka commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

Myasuka commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r309962573 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/e

[GitHub] [flink] lirui-apache commented on issue #9254: [FLINK-13427][hive] HiveCatalog's createFunction fails when function …

lirui-apache commented on issue #9254: [FLINK-13427][hive] HiveCatalog's createFunction fails when function … URL: https://github.com/apache/flink/pull/9254#issuecomment-517522620 The latest CI succeeded. @wuchong would you mind help review and merge this PR? Thanks. ---

[jira] [Created] (FLINK-13543) Enable reuse forks for integration tests in blink planner

Jark Wu created FLINK-13543: --- Summary: Enable reuse forks for integration tests in blink planner Key: FLINK-13543 URL: https://issues.apache.org/jira/browse/FLINK-13543 Project: Flink Issue Type: S

[jira] [Updated] (FLINK-13331) Add TestMiniClusters to maintain cache share cluster between Tests

[ https://issues.apache.org/jira/browse/FLINK-13331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13331: Fix Version/s: (was: 1.9.0) > Add TestMiniClusters to maintain cache share cluster between Tests > ---

[GitHub] [flink] flinkbot edited a comment on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

flinkbot edited a comment on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#issuecomment-511183558 ## CI report: * 25fc95f30720209e19bd010cdd517ff5e3c685d8 : SUCCESS [Build](https://travis-c

[GitHub] [flink] danny0405 commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

danny0405 commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#discussion_r309960001 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/Fli

[jira] [Resolved] (FLINK-13290) HBaseITCase bug using blink-runner: SinkCodeGenerator should not compare row type field names

[ https://issues.apache.org/jira/browse/FLINK-13290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13290. - Resolution: Fixed Fix Version/s: 1.10.0 [FLINK-13290][table-api] Add method to check LogicalType

[GitHub] [flink] danny0405 commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

danny0405 commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#discussion_r309959336 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ##

[GitHub] [flink] danny0405 commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

danny0405 commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#discussion_r309959336 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ##

[GitHub] [flink] asfgit closed pull request #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case

asfgit closed pull request #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275

[GitHub] [flink] flinkbot edited a comment on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children

flinkbot edited a comment on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children URL: https://github.com/apache/flink/pull/9288#issuecomment-516728840 ## CI report: * 09b5fe381383979e6d7726d5ba54898d1e34282e : FAILURE [Build](ht

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898470#comment-16898470 ] TisonKun commented on FLINK-13417: -- [~StephanEwen] I'm glad to help. Let me see what I

[GitHub] [flink] flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#issuecomment-517175361 ## CI report: * bf81288dc40cf5a3bee5ece840d21821ea903135 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[jira] [Assigned] (FLINK-13541) State Processor Api sets the wrong key selector when writing savepoints

[ https://issues.apache.org/jira/browse/FLINK-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-13541: --- Assignee: Tzu-Li (Gordon) Tai > State Processor Api sets the wrong key sele

[jira] [Assigned] (FLINK-13541) State Processor Api sets the wrong key selector when writing savepoints

[ https://issues.apache.org/jira/browse/FLINK-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-13541: --- Assignee: Seth Wiesman (was: Tzu-Li (Gordon) Tai) > State Processor Api se

[GitHub] [flink] flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT cas

flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275#issuecomment-516364194 ## CI report: * 821ab87a6c7e

[jira] [Commented] (FLINK-11605) Translate the "Dataflow Programming Model" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898461#comment-16898461 ] WangHengWei commented on FLINK-11605: - Hi [~jark], I can do the job, please assign i

[jira] [Updated] (FLINK-13541) State Processor Api sets the wrong key selector when writing savepoints

[ https://issues.apache.org/jira/browse/FLINK-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13541: Fix Version/s: (was: 1.10.0) > State Processor Api sets the wrong key selector

[jira] [Updated] (FLINK-13541) State Processor Api sets the wrong key selector when writing savepoints

[ https://issues.apache.org/jira/browse/FLINK-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13541: Priority: Blocker (was: Major) > State Processor Api sets the wrong key selector

[GitHub] [flink] flinkbot edited a comment on issue #9296: [FLINK-13476][coordination] Release pipelined partitions on vertex restart / job failure

flinkbot edited a comment on issue #9296: [FLINK-13476][coordination] Release pipelined partitions on vertex restart / job failure URL: https://github.com/apache/flink/pull/9296#issuecomment-516833551 ## CI report: * 53b55b57bf8f8359987bc775b91e650661924b7a : FAILURE [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner)

flinkbot edited a comment on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner) URL: https://github.com/apache/flink/pull/9322#issuecomment-517273321 ## CI report: * e3d5e780a11ddd27ab6721772925db730d95c75c : SUCCESS [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions

flinkbot edited a comment on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions URL: https://github.com/apache/flink/pull/9250#issuecomment-515772917 ## CI report: * 4e15048a256b338df18ad8f9d89e0a576ae06a27 : FAILURE [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #9310: [FLINK-13190]add test to verify partition pruning for HiveTableSource

flinkbot edited a comment on issue #9310: [FLINK-13190]add test to verify partition pruning for HiveTableSource URL: https://github.com/apache/flink/pull/9310#issuecomment-517106716 ## CI report: * fc57b4955bfaad92fb17ce6b90cd1e8955368c08 : FAILURE [Build](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

flinkbot edited a comment on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239#issuecomment-515435805 ## CI report: * bb0663ddbb6eeda06b756c4ffc7094e64dbdb5b9 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/buil

[GitHub] [flink] zjuwangg commented on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

zjuwangg commented on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239#issuecomment-517496333 Hi, @twalthr ~ Thanks for your detailed review and valuable comments. I have just updated my code and please have a look when

[GitHub] [flink] zjuwangg commented on issue #9310: [FLINK-13190]add test to verify partition pruning for HiveTableSource

zjuwangg commented on issue #9310: [FLINK-13190]add test to verify partition pruning for HiveTableSource URL: https://github.com/apache/flink/pull/9310#issuecomment-517496162 rebase code to fix conflicts. This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

flinkbot edited a comment on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239#issuecomment-515435805 ## CI report: * bb0663ddbb6eeda06b756c4ffc7094e64dbdb5b9 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/buil

[GitHub] [flink] zjuwangg commented on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

zjuwangg commented on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239#issuecomment-517494752 Hi, @twalthr ~ Thanks for your detailed review and valuable comments. I have just updated my code and please have a look when

[GitHub] [flink] zjuwangg commented on a change in pull request #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

zjuwangg commented on a change in pull request #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239#discussion_r309935735 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/ut

[jira] [Closed] (FLINK-13424) HiveCatalog should add hive version in conf

[ https://issues.apache.org/jira/browse/FLINK-13424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13424. Resolution: Fixed merged in master: b20ac47258228aed51be0d0e6fc958ac303ce4a1 1.9.0: 4b8d35c7f9eb6573e3b0

[jira] [Updated] (FLINK-13424) HiveCatalog should add hive version in conf

[ https://issues.apache.org/jira/browse/FLINK-13424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13424: - Fix Version/s: 1.10.0 > HiveCatalog should add hive version in conf > --

[GitHub] [flink] asfgit closed pull request #9232: [FLINK-13424][hive] HiveCatalog should add hive version in conf

asfgit closed pull request #9232: [FLINK-13424][hive] HiveCatalog should add hive version in conf URL: https://github.com/apache/flink/pull/9232 This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] flinkbot edited a comment on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the …

flinkbot edited a comment on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the … URL: https://github.com/apache/flink/pull/9321#issuecomment-517266286 ## CI report: * 8738fc7248be508edcf3e1c0dcea6578f7b35a7e : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

flinkbot edited a comment on issue #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#issuecomment-515055909 ## CI report: * f3f92f7d9e74ae453502900b8efa80014f8dfc6f : FAILURE [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot edited a comment on issue #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : FAILURE [Build](https://travis-ci.co

[jira] [Closed] (FLINK-12966) finalize package name of Hive table source/sink

[ https://issues.apache.org/jira/browse/FLINK-12966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12966. Resolution: Fixed Fix Version/s: 1.10.0 merged in master: b83a2531641a0e39e0e1c37a78f355eec636de79

[GitHub] [flink] bowenli86 removed a comment on issue #9232: [FLINK-13424][hive] HiveCatalog should add hive version in conf

bowenli86 removed a comment on issue #9232: [FLINK-13424][hive] HiveCatalog should add hive version in conf URL: https://github.com/apache/flink/pull/9232#issuecomment-517477017 Hi @lirui-apache there's another failure ``` [ERROR] Tests run: 1, Failures: 0, Errors: 1, Skipped: 0,

[GitHub] [flink] asfgit closed pull request #9290: [FLINK-12966][hive] finalize package name of Hive table source/sink

asfgit closed pull request #9290: [FLINK-12966][hive] finalize package name of Hive table source/sink URL: https://github.com/apache/flink/pull/9290 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema

flinkbot commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema URL: https://github.com/apache/flink/pull/8371#issuecomment-517485163 ## CI report: * 6258756f25cfcd1fc1cc10e3b05a4ef3d612fd81 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/121682948) -

[GitHub] [flink] flinkbot edited a comment on issue #9320: [FLINK-13531] Do not print log and call 'release' if no requests should be evicted from the shared slot

flinkbot edited a comment on issue #9320: [FLINK-13531] Do not print log and call 'release' if no requests should be evicted from the shared slot URL: https://github.com/apache/flink/pull/9320#issuecomment-517239112 ## CI report: * 187030df57d4fc62a2d121ddda3a4047a390f576 : SUCCESS

[GitHub] [flink] Wosin commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema

Wosin commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema URL: https://github.com/apache/flink/pull/8371#issuecomment-517482623 @aljoscha Sorry It took so long I have made the rebase & squash. This is

[GitHub] [flink] flinkbot commented on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the…

flinkbot commented on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the… URL: https://github.com/apache/flink/pull/9325#issuecomment-517481903 ## CI report: * 166fa42707dd620d54756c1f28103f85649f7941 : PENDING [Build](https://travis-ci.com/flink-ci/f

[GitHub] [flink] flinkbot commented on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the…

flinkbot commented on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the… URL: https://github.com/apache/flink/pull/9325#issuecomment-517479994 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Updated] (FLINK-13542) Flink Datadog metrics reporter sends empty series if there is no metrics

[ https://issues.apache.org/jira/browse/FLINK-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13542: --- Labels: datadog metrics pull-request-available (was: datadog metrics) > Flink Datadog metri

[GitHub] [flink] mans2singh opened a new pull request #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the…

mans2singh opened a new pull request #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the… URL: https://github.com/apache/flink/pull/9325 … metrics are available ## What is the purpose of the change * Update datadog metrics reporter to only post metrics

[GitHub] [flink] flinkbot edited a comment on issue #9319: [FLINK-13518][hive] Disable tests on Java 11

flinkbot edited a comment on issue #9319: [FLINK-13518][hive] Disable tests on Java 11 URL: https://github.com/apache/flink/pull/9319#issuecomment-517236571 ## CI report: * 87de473b5b0661df166f1068ecb56dbf852ef601 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/1215668

[GitHub] [flink] bowenli86 commented on issue #9232: [FLINK-13424][hive] HiveCatalog should add hive version in conf

bowenli86 commented on issue #9232: [FLINK-13424][hive] HiveCatalog should add hive version in conf URL: https://github.com/apache/flink/pull/9232#issuecomment-517477017 Hi @lirui-apache there's another failure ``` [ERROR] Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time ela

[jira] [Created] (FLINK-13542) Flink Datadog metrics reporter sends empty series if there is no metrics

Mans Singh created FLINK-13542: -- Summary: Flink Datadog metrics reporter sends empty series if there is no metrics Key: FLINK-13542 URL: https://issues.apache.org/jira/browse/FLINK-13542 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9313: [FLINK-13504][table] Fixed shading issues in table modules.

flinkbot edited a comment on issue #9313: [FLINK-13504][table] Fixed shading issues in table modules. URL: https://github.com/apache/flink/pull/9313#issuecomment-517206630 ## CI report: * 8f5327afea7e343ed0effb541050ebfdc6f443e4 : SUCCESS [Build](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot edited a comment on issue #9318: [FLINK-13044][s3][fs] Fix handling of relocated amazon classes

flinkbot edited a comment on issue #9318: [FLINK-13044][s3][fs] Fix handling of relocated amazon classes URL: https://github.com/apache/flink/pull/9318#issuecomment-517234057 ## CI report: * bb10597bd4b28c0567bea08e525daa6fa2344791 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #9277: [FLINK-13494][table-planner-blink] Only use env parallelism for sql job

flinkbot edited a comment on issue #9277: [FLINK-13494][table-planner-blink] Only use env parallelism for sql job URL: https://github.com/apache/flink/pull/9277#issuecomment-516388088 ## CI report: * 7bebdd65247ac172a23f9b0a91873b01b554cd71 : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner.

flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner. URL: https://github.com/apache/flink/pull/9314#issuecomment-517209689 ## CI report: * 7c2920eb071c70714b53d12355019ae97c0b080b : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot commented on issue #9324: [FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints

flinkbot commented on issue #9324: [FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints URL: https://github.com/apache/flink/pull/9324#issuecomment-517449414 ## CI report: * 75ce1d9c9c2daa0140befe909dcc80217c797f89 : PENDING [Bui

[GitHub] [flink] flinkbot edited a comment on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

flinkbot edited a comment on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#issuecomment-511183558 ## CI report: * 25fc95f30720209e19bd010cdd517ff5e3c685d8 : SUCCESS [Build](https://travis-c

[GitHub] [flink] sjwiesman commented on issue #9324: [FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints

sjwiesman commented on issue #9324: [FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints URL: https://github.com/apache/flink/pull/9324#issuecomment-517445533 @flinkbot attention @tzulitai --

[GitHub] [flink] flinkbot commented on issue #9324: [FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints

flinkbot commented on issue #9324: [FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints URL: https://github.com/apache/flink/pull/9324#issuecomment-517445379 Thanks a lot for your contribution to the Apache Flink project. I'm the @flink

[jira] [Updated] (FLINK-13541) State Processor Api sets the wrong key selector when writing savepoints

[ https://issues.apache.org/jira/browse/FLINK-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13541: --- Labels: pull-request-available (was: ) > State Processor Api sets the wrong key selector wh

[GitHub] [flink] sjwiesman opened a new pull request #9324: [FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints

sjwiesman opened a new pull request #9324: [FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints URL: https://github.com/apache/flink/pull/9324 ## What is the purpose of the change The state processor api is setting the wrong key s

[jira] [Created] (FLINK-13541) State Processor Api sets the wrong key selector when writing savepoints

Seth Wiesman created FLINK-13541: Summary: State Processor Api sets the wrong key selector when writing savepoints Key: FLINK-13541 URL: https://issues.apache.org/jira/browse/FLINK-13541 Project: Flin

[GitHub] [flink] flinkbot edited a comment on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value

flinkbot edited a comment on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value. URL: https://github.com/apache/flink/pull/9285#issuecomment-516712727 ## CI report: * bb70e45a98e

[GitHub] [flink] flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT cas

flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275#issuecomment-516364194 ## CI report: * 821ab87a6c7e

[GitHub] [flink] flinkbot edited a comment on issue #9315: [FLINK-13374][scala][build] Set -Xss2m when compiling scala

flinkbot edited a comment on issue #9315: [FLINK-13374][scala][build] Set -Xss2m when compiling scala URL: https://github.com/apache/flink/pull/9315#issuecomment-517223633 ## CI report: * cc907a6797f49e0cd66cf781604221fd537ce0be : FAILURE [Build](https://travis-ci.com/flink-ci/flink

[GitHub] [flink] flinkbot edited a comment on issue #9317: [FLINK-13530][qs][tests] Increase port range size

flinkbot edited a comment on issue #9317: [FLINK-13530][qs][tests] Increase port range size URL: https://github.com/apache/flink/pull/9317#issuecomment-517223655 ## CI report: * 9d613db13beb207f940c03c4826230ba389f8537 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12

[GitHub] [flink] flinkbot edited a comment on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions

flinkbot edited a comment on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions URL: https://github.com/apache/flink/pull/9250#issuecomment-515772917 ## CI report: * 4e15048a256b338df18ad8f9d89e0a576ae06a27 : FAILURE [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #9296: [FLINK-13476][coordination] Release pipelined partitions on vertex restart / job failure

flinkbot edited a comment on issue #9296: [FLINK-13476][coordination] Release pipelined partitions on vertex restart / job failure URL: https://github.com/apache/flink/pull/9296#issuecomment-516833551 ## CI report: * 53b55b57bf8f8359987bc775b91e650661924b7a : FAILURE [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #9310: [FLINK-13190]add test to verify partition pruning for HiveTableSource

flinkbot edited a comment on issue #9310: [FLINK-13190]add test to verify partition pruning for HiveTableSource URL: https://github.com/apache/flink/pull/9310#issuecomment-517106716 ## CI report: * fc57b4955bfaad92fb17ce6b90cd1e8955368c08 : FAILURE [Build](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner.

flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner. URL: https://github.com/apache/flink/pull/9314#issuecomment-517209689 ## CI report: * 7c2920eb071c70714b53d12355019ae97c0b080b : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r309813136 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/or

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r309813441 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/or

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r309814628 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/or

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r309811602 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/or

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r309814358 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/or

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r309810137 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/or

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r309809840 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/or

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r309814040 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/or

[GitHub] [flink] TsReaper commented on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

TsReaper commented on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#issuecomment-517385410 Travis passed: https://travis-ci.com/TsReaper/flink/builds/121605193 -

[GitHub] [flink] flinkbot edited a comment on issue #9253: [Flink-12164][tests] Harden JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout

flinkbot edited a comment on issue #9253: [Flink-12164][tests] Harden JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout URL: https://github.com/apache/flink/pull/9253#issuecomment-515843418 ## CI report: * ee881273027480bd8901c2a06cc4f082f1c0604c : FAILURE [Build](https:/

[jira] [Commented] (FLINK-13532) Broken links in documentation

[ https://issues.apache.org/jira/browse/FLINK-13532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898209#comment-16898209 ] Xuefu Zhang commented on FLINK-13532: - cc [~sjwiesman] for visibility. > Broken lin

[GitHub] [flink] flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner.

flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner. URL: https://github.com/apache/flink/pull/9314#issuecomment-517209689 ## CI report: * 7c2920eb071c70714b53d12355019ae97c0b080b : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner.

flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner. URL: https://github.com/apache/flink/pull/9314#issuecomment-517209689 ## CI report: * 7c2920eb071c70714b53d12355019ae97c0b080b : FAILURE [Build](https://travis-ci.com/fli

[jira] [Comment Edited] (FLINK-13477) Containerized TaskManager killed because of lack of memory overhead

[ https://issues.apache.org/jira/browse/FLINK-13477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898187#comment-16898187 ] Benoit Hanotte edited comment on FLINK-13477 at 8/1/19 4:38 PM: --

[jira] [Commented] (FLINK-13477) Containerized TaskManager killed because of lack of memory overhead

[ https://issues.apache.org/jira/browse/FLINK-13477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898187#comment-16898187 ] Benoit Hanotte commented on FLINK-13477: Hello [~xintongsong], thanks for your r

[jira] [Updated] (FLINK-13317) Merge NetUtils and ClientUtils

[ https://issues.apache.org/jira/browse/FLINK-13317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Xu updated FLINK-13317: --- Fix Version/s: 1.9.0 > Merge NetUtils and ClientUtils > -- > >

[GitHub] [flink] twalthr commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

twalthr commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#discussion_r309779118 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/Flink

[GitHub] [flink] twalthr commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

twalthr commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#discussion_r309778088 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/Flink

[GitHub] [flink] GJL commented on issue #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

GJL commented on issue #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-517350857 Imo using ``` Thread.currentThread().setContextClassLoader(userCodeClassLoader) ``` doesn't ma

[GitHub] [flink] flinkbot edited a comment on issue #9316: [FLINK-13529][table-planner-blink] Verify and correct agg function's semantic for Blink planner

flinkbot edited a comment on issue #9316: [FLINK-13529][table-planner-blink] Verify and correct agg function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9316#issuecomment-517223639 ## CI report: * 6d6d1ea77cdbe56560d60483e3cf9d14aec6223c : FAILURE [Build](

[jira] [Resolved] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9900. -- Resolution: Fixed Hardened the test against failures introduced by FLINK-13497. 1.10.0: 51582b

[GitHub] [flink] flinkbot edited a comment on issue #9304: [FLINK-13434][e2e] Add stop-with-savepoint end-to-end tests.

flinkbot edited a comment on issue #9304: [FLINK-13434][e2e] Add stop-with-savepoint end-to-end tests. URL: https://github.com/apache/flink/pull/9304#issuecomment-516863417 ## CI report: * feb7953f619a2b134318d114a113fa4d7a2d6572 : SUCCESS [Build](https://travis-ci.com/flink-ci/flin

[jira] [Created] (FLINK-13540) DDL do not support key of properties contains number or "-"

Jingsong Lee created FLINK-13540: Summary: DDL do not support key of properties contains number or "-" Key: FLINK-13540 URL: https://issues.apache.org/jira/browse/FLINK-13540 Project: Flink

[jira] [Created] (FLINK-13539) DDL do not support CSV tableFactory because CSV require format.fields

Jingsong Lee created FLINK-13539: Summary: DDL do not support CSV tableFactory because CSV require format.fields Key: FLINK-13539 URL: https://issues.apache.org/jira/browse/FLINK-13539 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner.

flinkbot edited a comment on issue #9314: [FLINK-12704][python] Enable the configuration of using blink planner. URL: https://github.com/apache/flink/pull/9314#issuecomment-517209689 ## CI report: * 7c2920eb071c70714b53d12355019ae97c0b080b : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] twalthr commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

twalthr commented on a change in pull request #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#discussion_r309753253 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl

[GitHub] [flink] flinkbot edited a comment on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions

flinkbot edited a comment on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions URL: https://github.com/apache/flink/pull/9250#issuecomment-515772917 ## CI report: * 4e15048a256b338df18ad8f9d89e0a576ae06a27 : FAILURE [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] twalthr commented on a change in pull request #9313: [FLINK-13504][table] Fixed shading issues in table modules.

twalthr commented on a change in pull request #9313: [FLINK-13504][table] Fixed shading issues in table modules. URL: https://github.com/apache/flink/pull/9313#discussion_r309748868 ## File path: flink-table/flink-table-uber/pom.xml ## @@ -96,8 +95,8 @@ under the License

[GitHub] [flink] twalthr commented on a change in pull request #9313: [FLINK-13504][table] Fixed shading issues in table modules.

twalthr commented on a change in pull request #9313: [FLINK-13504][table] Fixed shading issues in table modules. URL: https://github.com/apache/flink/pull/9313#discussion_r309745351 ## File path: flink-end-to-end-tests/run-pre-commit-tests.sh ## @@ -60,6 +60,7 @@ run_tes

<    1   2   3   4   5   6   7   >