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

[ https://issues.apache.org/jira/browse/FLINK-13751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Yang updated FLINK-13751: Description: Built-in vector types is the TypeInformation of Vector, DenseVector and SparseVector. The cl

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

[ https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909024#comment-16909024 ] Chesnay Schepler commented on FLINK-13406: -- This is not really a new option, I

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

[ https://issues.apache.org/jira/browse/FLINK-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909025#comment-16909025 ] Till Rohrmann commented on FLINK-13472: --- This could be a good improvement. However

[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.

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 [Buil

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

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 u

[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 Fixed via 1.10.0: 3e0e030b41ba7dfcc4d85b7c776ae9627a51f838 1.9.1: fc7aeffd83

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

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 th

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

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 me

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

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 contain

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

[ 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

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 [Build](https://travis-ci.com/flink-ci/flink/

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

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 wil

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

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: flink-streaming-java/src/test/java/org/apache/flink/streaming/ru

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

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: flink-streaming-java/src/main/java/org/apache/flink/streaming/ru

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

[ https://issues.apache.org/jira/browse/FLINK-13751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Yang updated FLINK-13751: Description: Built-in vector types is the TypeInformation of Vector, DenseVector and SparseVector. * Add

[GitHub] [flink] ifndef-SleePy commented on issue #9461: [FLINK-9900][tests] Harden ZooKeeperHighAvailabilityITCase

ifndef-SleePy commented on issue #9461: [FLINK-9900][tests] Harden ZooKeeperHighAvailabilityITCase URL: https://github.com/apache/flink/pull/9461#issuecomment-521999465 @tillrohrmann , thanks for reviewing. I agree with you that it's a bit complicated. There are too many checking in onc

[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.

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 [Buil

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

flinkbot commented on issue #9464: [FLINK-13751][ml] Add Built-in vector types URL: https://github.com/apache/flink/pull/9464#issuecomment-52160 ## CI report: * 2d53d67c87d99ebff93d37a732dd50fc100a166e : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/123506707)

[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.

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: flink-ml-parent/flink-ml-lib/src/main/java/o

[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.

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: flink-ml-parent/flink-ml-lib/src/main/java/o

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

[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909034#comment-16909034 ] Yun Tang commented on FLINK-13418: -- [~Zentol], the comparison of these two different co

[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.

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: flink-ml-parent/flink-ml-lib/src/main/java/o

[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

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: flink-streaming-java/s

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

flinkbot edited a comment 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-521502416 ## CI report: * c61485ac4074bbc3a7688a5795432e6d5664bb22 : SUCCESS [Build](https:/

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

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 [Build](https://travis-ci.com/flink-ci/flink/builds/1235067

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

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 [Build](https://travis-ci.com/flink-ci

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

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 automat

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

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 i

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

[ 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 efficie

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

[ 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 > Releas

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

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_r314717941 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type: VAR

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

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_r314718253 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type: VAR

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

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 [Build](http

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

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 messa

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

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 automated

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

[ 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] wuchong commented on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

wuchong commented on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-522009328 OH, why this pull request is closed..? This is an automated

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

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

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 automated

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

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 [Build](https://travis-ci.com/flink-ci/flink/builds/1235067

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

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_r314721859 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type: VAR

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

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_r314722168 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type: VAR

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

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" +nav-parent_id:

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

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" +nav-parent_id

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

[ https://issues.apache.org/jira/browse/FLINK-13707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909053#comment-16909053 ] Jark Wu commented on FLINK-13707: - Thanks [~stukid], I assigned this issue to you. > Ma

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

[ https://issues.apache.org/jira/browse/FLINK-13707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13707: --- Assignee: xuekang > Make max parallelism configurable > -- > >

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

wuchong 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_r314726159 ## File path: docs/dev/table/connect.md ## @@ -276,6 +276,40 @@ tables: type: VARCH

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

[ https://issues.apache.org/jira/browse/FLINK-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909071#comment-16909071 ] David Judd commented on FLINK-13500: Ok, that's good to know. Thanks for the followu

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

[ 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 c

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

[ https://issues.apache.org/jira/browse/FLINK-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909072#comment-16909072 ] Piotr Nowojski commented on FLINK-12514: I've briefly checked your PR and it's a

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

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] [Closed] (FLINK-13384) The back pressure monitoring does not work for StreamSources

[ https://issues.apache.org/jira/browse/FLINK-13384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-13384. -- > The back pressure monitoring does not work for StreamSources > -

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

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] JingsongLi edited a comment on issue #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable

JingsongLi edited a comment 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 @TsReaper to review --

[GitHub] [flink] JingsongLi edited a comment on issue #9455: [FLINK-13739][table-blink] JDK String to bytes should specify UTF-8 encoding

JingsongLi edited a comment on issue #9455: [FLINK-13739][table-blink] JDK String to bytes should specify UTF-8 encoding URL: https://github.com/apache/flink/pull/9455#issuecomment-522023124 Thanks @rmetzger for verification, ping @wuchong to review

[GitHub] [flink] JingsongLi commented on issue #9455: [FLINK-13739][table-blink] JDK String to bytes should specify UTF-8 encoding

JingsongLi commented on issue #9455: [FLINK-13739][table-blink] JDK String to bytes should specify UTF-8 encoding URL: https://github.com/apache/flink/pull/9455#issuecomment-522023124 Thanks @rmetzger for verification, ping @wuchong @TsReaper to review

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

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 [Build](https://travis-ci.com/flink-ci/flink/bui

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

[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13143: --- Affects Version/s: 1.9.0 > Refactor CheckpointExceptionHandler relevant classes > --

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

[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909081#comment-16909081 ] Piotr Nowojski commented on FLINK-13143: I think [~yanghua] might be right. Defi

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

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

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

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

[jira] [Updated] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

[ https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13737: --- Labels: pull-request-available (was: ) > flink-dist should add provided dependency on flink

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

dawidwys commented on issue #9465: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9465#issuecomment-522025623 @tzulitai Could you have a look? This is an au

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

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 https://issues.apache.or

[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.

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 [Buil

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

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 au

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

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 community

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

[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909084#comment-16909084 ] vinoyang commented on FLINK-13143: -- [~pnowojski] you are right. The {{CheckpointExcepti

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

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 r

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

[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909086#comment-16909086 ] vinoyang commented on FLINK-13143: -- [~pnowojski] you are right. The {{CheckpointExcepti

[GitHub] [flink] 1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314741224 ## File path: flink-streaming-java/src/main/java/org/apache/flink

[GitHub] [flink] 1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314741672 ## File path: flink-streaming-java/src/main/java/org/apache/flink

[GitHub] [flink] 1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314742243 ## File path: flink-streaming-java/src/main/java/org/apache/flink

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

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 [Build](https://travis-ci.com

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

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 [Build](https://travis-ci.com/flink-c

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

[ 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 {{Checkpo

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

[ https://issues.apache.org/jira/browse/FLINK-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909089#comment-16909089 ] vinoyang commented on FLINK-12514: -- [~pnowojski] I will give a more detailed descriptio

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

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] [Commented] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909096#comment-16909096 ] Zhu Zhu commented on FLINK-13056: - The diff can be found at  [https://github.com/zhuzhur

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

[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909096#comment-16909096 ] Zhu Zhu edited comment on FLINK-13056 at 8/16/19 2:45 PM: -- The

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

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 [Build](http

[GitHub] [flink] Lemonjing opened a new pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing opened a new pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467 ## What is the purpose of the change This pull request update scala api `ScalaCsvOutputFormat` to add flush method before c

[GitHub] [flink] Lemonjing closed pull request #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing closed pull request #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/6411 This is an automated message from the Apache Git Service. To respond to th

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

flinkbot commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522052035 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

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

Lemonjing commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/6411#issuecomment-522052052 because this pr code is too late from master (fork a year go, flink 1.5) , it can't pass ci. So I pull the latest fli

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

flinkbot commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : PENDING [Build](https://travis-ci.com/flink-ci/flink/

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

Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522054960 @flinkbot attention @yanghua @buptljy This is an aut

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

flinkbot edited a comment 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 : SUCCESS [Build](https://travis

[GitHub] [flink] dawidwys merged pull request #9465: [FLINK-13737][flink-dist][bp-1.9] Added examples-table to flink-dist dependencies

dawidwys merged pull request #9465: [FLINK-13737][flink-dist][bp-1.9] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9465 This is an automated message from the Apache Git Service. T

[jira] [Updated] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

[ https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13737: - Fix Version/s: (was: 1.9.1) (was: 1.10.0) 1

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

dawidwys merged pull request #9466: [FLINK-13737][flink-dist] Added examples-table to flink-dist dependencies URL: https://github.com/apache/flink/pull/9466 This is an automated message from the Apache Git Service. To respon

[jira] [Updated] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

[ https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13737: - Issue Type: Bug (was: Improvement) > flink-dist should add provided dependency on flink

[jira] [Closed] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

[ https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-13737. Resolution: Fixed Fixed: master: 95e3f88f08b652d01583410f9a8bb73b0d891602 1.9: e598d76418d

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

flinkbot edited a comment 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 : CANCELED [Build](https://travis-ci.com

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

[ https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909157#comment-16909157 ] Thomas Weise commented on FLINK-4256: - I'm surprised to see this closed when there is

[jira] [Created] (FLINK-13752) TaskDeploymentDescriptor cannot be recycled by GC due to referenced by an anonymous function

Yun Gao created FLINK-13752: --- Summary: TaskDeploymentDescriptor cannot be recycled by GC due to referenced by an anonymous function Key: FLINK-13752 URL: https://issues.apache.org/jira/browse/FLINK-13752 Pr

[jira] [Updated] (FLINK-13752) TaskDeploymentDescriptor cannot be recycled by GC due to referenced by an anonymous function

[ https://issues.apache.org/jira/browse/FLINK-13752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-13752: Description: When comparing the 1.8 and 1.9.0-rc2 on a test streaming job, we found that the performance

[jira] [Updated] (FLINK-13752) TaskDeploymentDescriptor cannot be recycled by GC due to referenced by an anonymous function

[ https://issues.apache.org/jira/browse/FLINK-13752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-13752: Description: When comparing the 1.8 and 1.9.0-rc2 on a test streaming job, we found that the performance

[GitHub] [flink] sjwiesman commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

sjwiesman commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r314805990 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0 +1,

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

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS [Build](https://travis-ci.com/flink-ci

<    1   2   3   4   >