[GitHub] [flink] rmetzger commented on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable

2019-08-16 Thread GitBox
rmetzger commented on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable URL: https://github.com/apache/flink/pull/9462#issuecomment-521969040 I will test this change with my sample job.

[GitHub] [flink] flinkbot edited a comment on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable URL: https://github.com/apache/flink/pull/9462#issuecomment-521948849 ## CI report: * 01c5d282d80106ec89eb594ab7ba92f28ad857b0 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9460: [FLINK-13747][hive] Remove some TODOs in Hive connector

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9460: [FLINK-13747][hive] Remove some TODOs in Hive connector URL: https://github.com/apache/flink/pull/9460#issuecomment-521923251 ## CI report: * 0e8bb81aa0a13dd2836ed2ed9b3effe5552fd5e2 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/7751#issuecomment-517135258 ## CI report: * 82afc481b4eb377bbcec2b9bac53d013a1ba1666 : SUCCESS

[GitHub] [flink] Lemonjing commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

2019-08-16 Thread GitBox
Lemonjing commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/6411#issuecomment-521981874 @rmetzger I noticed that the problem is still unresolved, can u help to review it?

[jira] [Commented] (FLINK-4463) FLIP-3: Restructure Documentation

2019-08-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909017#comment-16909017 ] Robert Metzger commented on FLINK-4463: --- I would propose to close all subtasks as Invalid with a

[GitHub] [flink] tillrohrmann closed pull request #9461: [FLINK-9900][tests] Harden ZooKeeperHighAvailabilityITCase

2019-08-16 Thread GitBox
tillrohrmann closed pull request #9461: [FLINK-9900][tests] Harden ZooKeeperHighAvailabilityITCase URL: https://github.com/apache/flink/pull/9461 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] xuyang1706 opened a new pull request #9464: [FLINK-13751][ml] Add Built-in vector types

2019-08-16 Thread GitBox
xuyang1706 opened a new pull request #9464: [FLINK-13751][ml] Add Built-in vector types URL: https://github.com/apache/flink/pull/9464 ## What is the purpose of the change Built-in vector types is the TypeInformation of Vector, DenseVector and SparseVector. The class

[jira] [Updated] (FLINK-13751) Add Built-in vector types

2019-08-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13751: --- Labels: pull-request-available (was: ) > Add Built-in vector types >

[GitHub] [flink] flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-518524777 ## CI report: * f99e66ffb4356f8132b48d352b27686a6ad958f5 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9465: [FLINK-13737][flink-dist][bp-1.9] Added examples-table to flink-dist dependencies

2019-08-16 Thread GitBox
flinkbot commented on issue #9465: [FLINK-13737][flink-dist][bp-1.9] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9465#issuecomment-522028577 ## CI report: * 095ba0a98f00367052feb9472c83a292a72fa98a : PENDING

[GitHub] [flink] flinkbot commented on issue #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies

2019-08-16 Thread GitBox
flinkbot commented on issue #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9466#issuecomment-522028628 ## CI report: * aec1d92adaaf5fd75eb673d23c51c570c2425587 : PENDING

[GitHub] [flink] tzulitai commented on issue #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies

2019-08-16 Thread GitBox
tzulitai commented on issue #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9466#issuecomment-522031403 Have verified that this works  +1 to merge (as well as the backport) Thanks @dawidwys!

[jira] [Updated] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

2019-08-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13056: - Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-4256) >

[jira] [Commented] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

2019-08-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908955#comment-16908955 ] Chesnay Schepler commented on FLINK-13056: -- I'm removing this as a subtask of FLINK-4256 so we

[jira] [Closed] (FLINK-4256) Fine-grained recovery

2019-08-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4256. --- Resolution: Fixed Fix Version/s: 1.9.0 > Fine-grained recovery >

[GitHub] [flink] zjuwangg commented on issue #9447: [FLINK-13643][docs]Document the workaround for users with a different minor Hive version

2019-08-16 Thread GitBox
zjuwangg commented on issue #9447: [FLINK-13643][docs]Document the workaround for users with a different minor Hive version URL: https://github.com/apache/flink/pull/9447#issuecomment-521968239 Update according to comments. cc @bowenli86 @lirui-apache

[GitHub] [flink] flinkbot commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

2019-08-16 Thread GitBox
flinkbot commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/6411#issuecomment-521980643 ## CI report: * 95a9b60b1ece7d248755d92868e682c4ee0fd334 : PENDING

[GitHub] [flink] zentol commented on a change in pull request #9386: [FLINK-13601][tests] Harden RegionFailoverITCase by recording info when checkpoint just completed

2019-08-16 Thread GitBox
zentol commented on a change in pull request #9386: [FLINK-13601][tests] Harden RegionFailoverITCase by recording info when checkpoint just completed URL: https://github.com/apache/flink/pull/9386#discussion_r314685717 ## File path:

[GitHub] [flink] Lemonjing commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

2019-08-16 Thread GitBox
Lemonjing commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/6411#issuecomment-521980729 @aljoscha u are original author of this class. mind help to review it?

[jira] [Commented] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

2019-08-16 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909001#comment-16909001 ] Zhu Zhu commented on FLINK-13056: - [~till.rohrmann] we tried to optimize it, at the cost of more data

[jira] [Commented] (FLINK-13406) MetricConfig.getInteger() always returns null

2019-08-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909002#comment-16909002 ] Chesnay Schepler commented on FLINK-13406: -- Not necessarily. So let's go through all

[jira] [Commented] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2019-08-16 Thread Ryan Tao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909010#comment-16909010 ] Ryan Tao commented on FLINK-9941: - maybe mistake, i reopen it. [~rmetzger] > Flush in

[jira] [Reopened] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2019-08-16 Thread Ryan Tao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Tao reopened FLINK-9941: - reopen it. > Flush in ScalaCsvOutputFormat before close method >

[jira] [Updated] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2019-08-16 Thread Ryan Tao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Tao updated FLINK-9941: Affects Version/s: 1.8.1 > Flush in ScalaCsvOutputFormat before close method >

[jira] [Commented] (FLINK-13741) "SHOW FUNCTIONS" should include Flink built-in functions' names

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909015#comment-16909015 ] Bowen Li commented on FLINK-13741: -- Thanks [~Terry1897] for the summary of existing systems! Hi

[GitHub] [flink] pnowojski commented on a change in pull request #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

2019-08-16 Thread GitBox
pnowojski commented on a change in pull request #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager URL: https://github.com/apache/flink/pull/8471#discussion_r314710622 ## File path:

[GitHub] [flink] pnowojski commented on issue #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

2019-08-16 Thread GitBox
pnowojski commented on issue #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager URL: https://github.com/apache/flink/pull/8471#issuecomment-522006514 One more note, please also try to include better descriptions

[GitHub] [flink] wuchong commented on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
wuchong commented on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-522009012 Please also add DDL tabs for the formats. This is an

[jira] [Updated] (FLINK-13359) Add documentation for DDL introduction

2019-08-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13359: --- Labels: pull-request-available (was: ) > Add documentation for DDL introduction >

[GitHub] [flink] danny0405 closed pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 closed pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] rmetzger commented on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable

2019-08-16 Thread GitBox
rmetzger commented on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable URL: https://github.com/apache/flink/pull/9462#issuecomment-521978638 my testing job doesn't fail anymore with this PR applied. I can't say whether this fix is

[GitHub] [flink] lirui-apache commented on issue #9460: [FLINK-13747][hive] Remove some TODOs in Hive connector

2019-08-16 Thread GitBox
lirui-apache commented on issue #9460: [FLINK-13747][hive] Remove some TODOs in Hive connector URL: https://github.com/apache/flink/pull/9460#issuecomment-521979323 The test failures are related. Just updated to fix them.

[jira] [Closed] (FLINK-13131) add a custom directory for storing configuration files and jar files for user jobs

2019-08-16 Thread Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-13131. Resolution: Won't Fix > add a custom directory for storing configuration files and jar files for

[jira] [Commented] (FLINK-13131) add a custom directory for storing configuration files and jar files for user jobs

2019-08-16 Thread Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908993#comment-16908993 ] Xintong Song commented on FLINK-13131: -- Hi [~zhangbinzaifendou], thanks for reporting this issue.

[jira] [Comment Edited] (FLINK-13406) MetricConfig.getInteger() always returns null

2019-08-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909019#comment-16909019 ] Till Rohrmann edited comment on FLINK-13406 at 8/16/19 12:33 PM: - I

[jira] [Commented] (FLINK-13406) MetricConfig.getInteger() always returns null

2019-08-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909019#comment-16909019 ] Till Rohrmann commented on FLINK-13406: --- I think there would be a 3. option: Only store

[jira] [Commented] (FLINK-13707) Make max parallelism configurable

2019-08-16 Thread xuekang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909020#comment-16909020 ] xuekang commented on FLINK-13707: - ok, thanks for the comments.  I will upload a patch soon. > Make

[GitHub] [flink] xuyang1706 closed pull request #9463: Add Built-in vector types

2019-08-16 Thread GitBox
xuyang1706 closed pull request #9463: Add Built-in vector types URL: https://github.com/apache/flink/pull/9463 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

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

2019-08-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9900. -- Resolution: Fixed Fixed via 1.10.0: 3e0e030b41ba7dfcc4d85b7c776ae9627a51f838 1.9.1:

[GitHub] [flink] xuyang1706 opened a new pull request #9463: Add Built-in vector types

2019-08-16 Thread GitBox
xuyang1706 opened a new pull request #9463: Add Built-in vector types URL: https://github.com/apache/flink/pull/9463 ## What is the purpose of the change Built-in vector types is the TypeInformation of Vector, DenseVector and SparseVector. The class contains the mapping of

[jira] [Closed] (FLINK-12529) Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

2019-08-16 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-12529. -- Resolution: Fixed Fix Version/s: 1.10.0 Merged as  7ed0df0 into apache:master >

[jira] [Updated] (FLINK-12529) Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

2019-08-16 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-12529: --- Affects Version/s: 1.9.0 > Release record-deserializer buffers timely to improve the

[jira] [Comment Edited] (FLINK-13143) Refactor CheckpointExceptionHandler relevant classes

2019-08-16 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909081#comment-16909081 ] Piotr Nowojski edited comment on FLINK-13143 at 8/16/19 2:15 PM: - I

[jira] [Commented] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

2019-08-16 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909096#comment-16909096 ] Zhu Zhu commented on FLINK-13056: - The diff can be found at 

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314663434 ## File path: docs/dev/table/connect.md ## @@ -652,6 +686,34 @@ connector: path:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314664862 ## File path: docs/dev/table/connect.md ## @@ -900,6 +1026,78 @@ connector:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314663166 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314664613 ## File path: docs/dev/table/connect.md ## @@ -753,6 +815,70 @@ connector:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314664413 ## File path: docs/dev/table/connect.md ## @@ -652,6 +686,34 @@ connector: path:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314664520 ## File path: docs/dev/table/connect.md ## @@ -753,6 +815,70 @@ connector:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314666452 ## File path: docs/dev/table/ddl.md ## @@ -0,0 +1,119 @@ +--- +title: "DDL"

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314664808 ## File path: docs/dev/table/connect.md ## @@ -900,6 +1026,78 @@ connector:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314664985 ## File path: docs/dev/table/ddl.md ## @@ -0,0 +1,119 @@ +--- +title: "DDL"

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314662314 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type:

[GitHub] [flink] flinkbot edited a comment on issue #9450: [FLINK-13711][sql-client] Hive array values not properly displayed in…

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9450: [FLINK-13711][sql-client] Hive array values not properly displayed in… URL: https://github.com/apache/flink/pull/9450#issuecomment-521552936 ## CI report: * c9d99f2866f281298f4217e9ce7543732bece2f8 : SUCCESS

[GitHub] [flink] rmetzger commented on issue #9100: [hotfix] Update `findAndCreateTableSource` method's annotation in TableFactoryUtil class

2019-08-16 Thread GitBox
rmetzger commented on issue #9100: [hotfix] Update `findAndCreateTableSource` method's annotation in TableFactoryUtil class URL: https://github.com/apache/flink/pull/9100#issuecomment-521988465 Please carefully read the contribution guide I linked earlier. There is still something wrong

[GitHub] [flink] flinkbot commented on issue #9464: [FLINK-13751][ml] Add Built-in vector types

2019-08-16 Thread GitBox
flinkbot commented on issue #9464: [FLINK-13751][ml] Add Built-in vector types URL: https://github.com/apache/flink/pull/9464#issuecomment-521998582 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We

[GitHub] [flink] tillrohrmann commented on a change in pull request #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

2019-08-16 Thread GitBox
tillrohrmann commented on a change in pull request #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#discussion_r314706590 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

2019-08-16 Thread GitBox
tillrohrmann commented on a change in pull request #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#discussion_r314705802 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314722591 ## File path: docs/dev/table/ddl.md ## @@ -0,0 +1,76 @@ +--- +title: "DDL"

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314722894 ## File path: docs/dev/table/ddl.md ## @@ -0,0 +1,119 @@ +--- +title: "DDL"

[GitHub] [flink] JingsongLi commented on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable

2019-08-16 Thread GitBox
JingsongLi commented on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable URL: https://github.com/apache/flink/pull/9462#issuecomment-522022698 Thanks @rmetzger for verification, ping @wuchong to review

[GitHub] [flink] flinkbot edited a comment on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #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#issuecomment-517015005 ## CI report: * 98f0cec3deff65ebe316b8d3c13b51470d079b65 : FAILURE

[GitHub] [flink] dawidwys commented on issue #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies

2019-08-16 Thread GitBox
dawidwys commented on issue #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9466#issuecomment-522026008 @tzulitai Could you have a look? This is an

[GitHub] [flink] dawidwys opened a new pull request #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies

2019-08-16 Thread GitBox
dawidwys opened a new pull request #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9466 ## What is the purpose of the change This PR adds examples-table to flink-dist dependencies. In

[GitHub] [flink] flinkbot commented on issue #9465: [FLINK-13737][flink-dist][bp-1.9] Added examples-table to flink-dist dependencies

2019-08-16 Thread GitBox
flinkbot commented on issue #9465: [FLINK-13737][flink-dist][bp-1.9] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9465#issuecomment-522026202 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] rmetzger commented on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1

2019-08-16 Thread GitBox
rmetzger commented on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1 URL: https://github.com/apache/flink/pull/9444#issuecomment-521968497 I've checked out your PR to test that the Docker setup still works. Are these build times faster than before? ```

[jira] [Closed] (FLINK-13585) Test TaskAsyncCallTest#testSetsUserCodeClassLoader() deadlocks

2019-08-16 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu closed FLINK-13585. > Test TaskAsyncCallTest#testSetsUserCodeClassLoader() deadlocks >

[GitHub] [flink] flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-521131546 ## CI report: * 22d047614613c293a7aca416268449b3cabcad6a : FAILURE

[jira] [Commented] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2019-08-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909006#comment-16909006 ] Robert Metzger commented on FLINK-9941: --- [~wind_ljy] why did you close the Jira ticket? > Flush in

[jira] [Updated] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2019-08-16 Thread Ryan Tao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Tao updated FLINK-9941: Affects Version/s: 1.6.4 1.7.2 > Flush in ScalaCsvOutputFormat before close method

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

2019-08-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909013#comment-16909013 ] Till Rohrmann commented on FLINK-9900: -- Great to hear [~SleePy]. I'll take a look at your PR. >

[jira] [Commented] (FLINK-13406) MetricConfig.getInteger() always returns null

2019-08-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909024#comment-16909024 ] Chesnay Schepler commented on FLINK-13406: -- This is not really a new option, I did cover

[jira] [Commented] (FLINK-13472) taskmanager.jvm-exit-on-oom doesn't work reliably with YARN

2019-08-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909025#comment-16909025 ] Till Rohrmann commented on FLINK-13472: --- This could be a good improvement. However there might

[GitHub] [flink] flinkbot edited a comment on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #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#issuecomment-517015005 ## CI report: * 98f0cec3deff65ebe316b8d3c13b51470d079b65 : FAILURE

[jira] [Commented] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

2019-08-16 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909034#comment-16909034 ] Yun Tang commented on FLINK-13418: -- [~Zentol], the comparison of these two different concepts is listed

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

2019-08-16 Thread GitBox
xuyang1706 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_r314709236 ## File path:

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

2019-08-16 Thread GitBox
xuyang1706 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_r314708905 ## File path:

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

2019-08-16 Thread GitBox
xuyang1706 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_r314709076 ## File path:

[GitHub] [flink] pnowojski merged pull request #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

2019-08-16 Thread GitBox
pnowojski merged pull request #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager URL: https://github.com/apache/flink/pull/8471 This is an

[GitHub] [flink] flinkbot edited a comment on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/6411#issuecomment-521980643 ## CI report: * 95a9b60b1ece7d248755d92868e682c4ee0fd334 : FAILURE

[GitHub] [flink] danny0405 opened a new pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 opened a new pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366 ## What is the purpose of the change Add doc for all the supported DDLs ## Brief change log - Add ddl.md in table dir.

[GitHub] [flink] danny0405 commented on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-522010412 OOps, i mis-clicked, sorry for that ... This is an

[GitHub] [flink] flinkbot edited a comment on issue #9464: [FLINK-13751][ml] Add Built-in vector types

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9464: [FLINK-13751][ml] Add Built-in vector types URL: https://github.com/apache/flink/pull/9464#issuecomment-52160 ## CI report: * 2d53d67c87d99ebff93d37a732dd50fc100a166e : CANCELED

[jira] [Commented] (FLINK-13500) RestClusterClient requires S3 access when HA is configured

2019-08-16 Thread David Judd (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909071#comment-16909071 ] David Judd commented on FLINK-13500: Ok, that's good to know. Thanks for the followup! This isn't a

[jira] [Updated] (FLINK-12514) Refactor the failure checkpoint counting mechanism with ordered checkpoint id

2019-08-16 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-12514: --- Affects Version/s: 1.9.0 > Refactor the failure checkpoint counting mechanism with ordered

[jira] [Commented] (FLINK-12514) Refactor the failure checkpoint counting mechanism with ordered checkpoint id

2019-08-16 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909072#comment-16909072 ] Piotr Nowojski commented on FLINK-12514: I've briefly checked your PR and it's adding even more

[GitHub] [flink] pnowojski commented on issue #8871: [FLINK-12976] Bump Kafka client version to 2.3.0 for universal Kafka connector

2019-08-16 Thread GitBox
pnowojski commented on issue #8871: [FLINK-12976] Bump Kafka client version to 2.3.0 for universal Kafka connector URL: https://github.com/apache/flink/pull/8871#issuecomment-522019662 I would suggest to ask @becketqin about this as I'm unfortunately busy with runtime features :(

[jira] [Commented] (FLINK-13143) Refactor CheckpointExceptionHandler relevant classes

2019-08-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909086#comment-16909086 ] vinoyang commented on FLINK-13143: -- [~pnowojski] you are right. The {{CheckpointExceptionHandler}} and

[jira] [Commented] (FLINK-13143) Refactor CheckpointExceptionHandler relevant classes

2019-08-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909084#comment-16909084 ] vinoyang commented on FLINK-13143: -- [~pnowojski] you are right. The {{CheckpointExceptionHandler}} and

[GitHub] [flink] flinkbot commented on issue #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies

2019-08-16 Thread GitBox
flinkbot commented on issue #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9466#issuecomment-522026797 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Issue Comment Deleted] (FLINK-13143) Refactor CheckpointExceptionHandler relevant classes

2019-08-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13143: - Comment: was deleted (was: [~pnowojski] you are right. The {{CheckpointExceptionHandler}} and

[jira] [Commented] (FLINK-12514) Refactor the failure checkpoint counting mechanism with ordered checkpoint id

2019-08-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909089#comment-16909089 ] vinoyang commented on FLINK-12514: -- [~pnowojski] I will give a more detailed description. I said this

[GitHub] [flink] flinkbot edited a comment on issue #9072: [FLINK-11630] Wait for the termination of all running Tasks when shutting down TaskExecutor

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9072: [FLINK-11630] Wait for the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/9072#issuecomment-512425985 ## CI report: * cd5ad8d23046c1025f7f9865e60fc3d048fd1f85 : FAILURE

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314662058 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314664840 ## File path: docs/dev/table/connect.md ## @@ -900,6 +1026,78 @@ connector:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314664109 ## File path: docs/dev/table/connect.md ## @@ -652,6 +686,34 @@ connector: path:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314662011 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type:

[GitHub] [flink] danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction

2019-08-16 Thread GitBox
danny0405 commented on a change in pull request #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#discussion_r314669687 ## File path: docs/dev/table/ddl.md ## @@ -0,0 +1,119 @@ +--- +title: "DDL"

  1   2   3   4   >