[GitHub] [flink] flinkbot edited a comment on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE`

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE` URL: https://github.com/apache/flink/pull/9469#issuecomment-522203394 ## CI report: * 6a793ee313851c7e8afc09f4b77534f00e23017c : CANCELED [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE`

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE` URL: https://github.com/apache/flink/pull/9469#issuecomment-522203394 ## CI report: * 6a793ee313851c7e8afc09f4b77534f00e23017c : CANCELED [Build](https://t

[GitHub] [flink] flinkbot commented on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE`

2019-08-16 Thread GitBox
flinkbot commented on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE` URL: https://github.com/apache/flink/pull/9469#issuecomment-522203394 ## CI report: * 6a793ee313851c7e8afc09f4b77534f00e23017c : PENDING [Build](https://travis-ci

[GitHub] [flink] hehuiyuan opened a new pull request #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE`

2019-08-16 Thread GitBox
hehuiyuan opened a new pull request #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE` URL: https://github.com/apache/flink/pull/9469 ## What is the purpose of the change ![image](https://user-images.githubusercontent.com/18002496/63

[jira] [Updated] (FLINK-13757) Document error for `logical functions`

2019-08-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13757: --- Labels: pull-request-available (was: ) > Document error for `logical functions` >

[GitHub] [flink] flinkbot commented on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE`

2019-08-16 Thread GitBox
flinkbot commented on issue #9469: [FLINK-13757][Docs]update logical fucntions for this expression `boolean IS NOT TRUE` URL: https://github.com/apache/flink/pull/9469#issuecomment-522202884 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[jira] [Updated] (FLINK-13757) Document error for `logical functions`

2019-08-16 Thread hehuiyuan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-13757: -- Description: [https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/table/functions.html#log

[jira] [Created] (FLINK-13757) Document error for `logical functions`

2019-08-16 Thread hehuiyuan (JIRA)
hehuiyuan created FLINK-13757: - Summary: Document error for `logical functions` Key: FLINK-13757 URL: https://issues.apache.org/jira/browse/FLINK-13757 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-13756) Modify Code Annotations for findAndCreateTableSource in TableFactoryUtil

2019-08-16 Thread hehuiyuan (JIRA)
hehuiyuan created FLINK-13756: - Summary: Modify Code Annotations for findAndCreateTableSource in TableFactoryUtil Key: FLINK-13756 URL: https://issues.apache.org/jira/browse/FLINK-13756 Project: Flink

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Description: Unlike UDFs that are persisted in Hive Metastore, Hive builtin functions are registered in

[jira] [Commented] (FLINK-13749) Make Flink client respect classloading policy

2019-08-16 Thread Paul Lin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909547#comment-16909547 ] Paul Lin commented on FLINK-13749: -- Please assign this issue to me. Thanks! > Make Fli

[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-522194254 > @zjuwangg Thanks for updating. I think we should make the following points clear to users:

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-08-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909531#comment-16909531 ] vinoyang commented on FLINK-13025: -- [~victorvilladev] Thanks for your opinion. If [~alj

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Description: Unlike UDFs that are persisted in Hive Metastore, Hive builtin functions are registered in

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Description: Unlike UDFs that are persisted in Hive Metastore, Hive builtin functions are registered in

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Attachment: hive builtin functions that are missing in flink.txt > support Hive built-in functions in Fl

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Attachment: (was: hive builtin functions that are missing in flink.txt) > support Hive built-in func

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Description: Unlike UDFs that are persisted in Hive Metastore, Hive builtin functions are registered in

[GitHub] [flink] flinkbot edited a comment on issue #9457: [FLINK-13741][table] "SHOW FUNCTIONS" should include Flink built-in functions' names

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9457: [FLINK-13741][table] "SHOW FUNCTIONS" should include Flink built-in functions' names URL: https://github.com/apache/flink/pull/9457#issuecomment-521829752 ## CI report: * 55c0e5843e029f022ff59fe14a9e6c1d2c5ac69e : FAILURE [Build](https://tra

[GitHub] [flink] YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese

2019-08-16 Thread GitBox
YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/7751#discussion_r314920585 ## File path: docs/tutorials/local_setup.zh.md ## @@ -0,0 +1,288 @@ +--

[GitHub] [flink] YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese

2019-08-16 Thread GitBox
YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/7751#discussion_r314919768 ## File path: docs/tutorials/local_setup.zh.md ## @@ -0,0 +1,288 @@ +--

[GitHub] [flink] YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese

2019-08-16 Thread GitBox
YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/7751#discussion_r314919426 ## File path: docs/tutorials/local_setup.zh.md ## @@ -0,0 +1,288 @@ +--

[GitHub] [flink] YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese

2019-08-16 Thread GitBox
YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/7751#discussion_r313786797 ## File path: docs/tutorials/local_setup.zh.md ## @@ -0,0 +1,288 @@ +--

[GitHub] [flink] YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese

2019-08-16 Thread GitBox
YngwieWang commented on a change in pull request #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/7751#discussion_r314919093 ## File path: docs/tutorials/local_setup.zh.md ## @@ -0,0 +1,288 @@ +--

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Attachment: common builtin functions is flink and hive.txt hive builtin functions that ar

[jira] [Created] (FLINK-13755) support Hive built-in functions in Flink

2019-08-16 Thread Bowen Li (JIRA)
Bowen Li created FLINK-13755: Summary: support Hive built-in functions in Flink Key: FLINK-13755 URL: https://issues.apache.org/jira/browse/FLINK-13755 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on issue #9457: [FLINK-13741][table] "SHOW FUNCTIONS" should include Flink built-in functions' names

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9457: [FLINK-13741][table] "SHOW FUNCTIONS" should include Flink built-in functions' names URL: https://github.com/apache/flink/pull/9457#issuecomment-521829752 ## CI report: * 55c0e5843e029f022ff59fe14a9e6c1d2c5ac69e : FAILURE [Build](https://tra

[jira] [Closed] (FLINK-13747) Remove some TODOs in Hive connector

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13747. Resolution: Fixed merged in 1.10.0: a6571bb61f41a65b47ec250231a32e14b1390069 > Remove some TODOs in Hive

[GitHub] [flink] asfgit closed pull request #9460: [FLINK-13747][hive] Remove some TODOs in Hive connector

2019-08-16 Thread GitBox
asfgit closed pull request #9460: [FLINK-13747][hive] Remove some TODOs in Hive connector URL: https://github.com/apache/flink/pull/9460 This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Updated] (FLINK-13711) Hive array values not properly displayed in SQL CLI

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13711: - Fix Version/s: 1.9.1 > Hive array values not properly displayed in SQL CLI > ---

[jira] [Updated] (FLINK-13711) Hive array values not properly displayed in SQL CLI

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13711: - Affects Version/s: 1.9.0 > Hive array values not properly displayed in SQL CLI > ---

[jira] [Assigned] (FLINK-13711) Hive array values not properly displayed in SQL CLI

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13711: Assignee: Rui Li > Hive array values not properly displayed in SQL CLI >

[GitHub] [flink] bowenli86 commented on issue #9450: [FLINK-13711][sql-client] Hive array values not properly displayed in…

2019-08-16 Thread GitBox
bowenli86 commented on issue #9450: [FLINK-13711][sql-client] Hive array values not properly displayed in… URL: https://github.com/apache/flink/pull/9450#issuecomment-522159565 @twalthr given this is a bug, I think we can merge it into 1.9.1, what do you think? ---

[jira] [Updated] (FLINK-13747) Remove some TODOs in Hive connector

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13747: - Issue Type: Improvement (was: Bug) > Remove some TODOs in Hive connector >

[jira] [Updated] (FLINK-13747) Remove some TODOs in Hive connector

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13747: - Fix Version/s: 1.10.0 > Remove some TODOs in Hive connector > --- > >

[jira] [Updated] (FLINK-13747) Remove some TODOs in Hive connector

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13747: - Affects Version/s: 1.9.0 > Remove some TODOs in Hive connector > --- > >

[jira] [Assigned] (FLINK-13747) Remove some TODOs in Hive connector

2019-08-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13747: Assignee: Rui Li > Remove some TODOs in Hive connector > --- > >

[GitHub] [flink] asfgit closed pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink

2019-08-16 Thread GitBox
asfgit closed pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink URL: https://github.com/apache/flink/pull/9217 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] bowenli86 commented on issue #9446: [hotfix][hive][doc] refine Hive related documentations

2019-08-16 Thread GitBox
bowenli86 commented on issue #9446: [hotfix][hive][doc] refine Hive related documentations URL: https://github.com/apache/flink/pull/9446#issuecomment-522150808 merged in master and release-1.9 This is an automated message fr

[GitHub] [flink] bowenli86 closed pull request #9446: [hotfix][hive][doc] refine Hive related documentations

2019-08-16 Thread GitBox
bowenli86 closed pull request #9446: [hotfix][hive][doc] refine Hive related documentations URL: https://github.com/apache/flink/pull/9446 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : SUCCESS [Buil

[GitHub] [flink] flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#issuecomment-514437706 ## CI report: * 5eb979da047c442c0205464c92b5bd9ee3a740dc : FAILURE [Build](https://travis-ci.com/flink

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-08-16 Thread Victor (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909329#comment-16909329 ] Victor commented on FLINK-13025: Hi [~aljoscha], I was looking for an ES 7.X connector a

[GitHub] [flink] flinkbot commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

2019-08-16 Thread GitBox
flinkbot commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : PENDING [Build](https

[jira] [Commented] (FLINK-13689) Rest High Level Client for Elasticsearch6.x connector leaks threads if no connection could be established

2019-08-16 Thread Rishindra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909313#comment-16909313 ] Rishindra Kumar commented on FLINK-13689: - Hi [~fhueske], I created pull reques

[GitHub] [flink] flinkbot commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

2019-08-16 Thread GitBox
flinkbot commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522103874 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I he

[jira] [Updated] (FLINK-13689) Rest High Level Client for Elasticsearch6.x connector leaks threads if no connection could be established

2019-08-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13689: --- Labels: pull-request-available (was: ) > Rest High Level Client for Elasticsearch6.x connec

[GitHub] [flink] Rishi55 opened a new pull request #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

2019-08-16 Thread GitBox
Rishi55 opened a new pull request #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468 **(The sections below can be removed for hotfixes of typos)** --> ## What is the purpose of th

[GitHub] [flink] flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#issuecomment-514437706 ## CI report: * 5eb979da047c442c0205464c92b5bd9ee3a740dc : FAILURE [Build](https://travis-ci.com/flink

[jira] [Created] (FLINK-13754) Decouple OperatorChain from StreamStatusMaintainer

2019-08-16 Thread zhijiang (JIRA)
zhijiang created FLINK-13754: Summary: Decouple OperatorChain from StreamStatusMaintainer Key: FLINK-13754 URL: https://issues.apache.org/jira/browse/FLINK-13754 Project: Flink Issue Type: Sub-ta

[GitHub] [flink] Johnlon commented on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

2019-08-16 Thread GitBox
Johnlon commented on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-522091063 Will look over the weekend. This is an autom

[GitHub] [flink] Johnlon 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
Johnlon 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_r314819650 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime

[GitHub] [flink] Johnlon 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
Johnlon 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_r314818982 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime

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

2019-08-16 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909252#comment-16909252 ] Xuefu Zhang commented on FLINK-13741: - Re: Once FunctionCatalog has been integrated

[GitHub] [flink] flinkbot edited a comment on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-521825874 ## CI report: * 1242679f7bd5ec3f7c1115006e978267abafc84b : CANCELED [Build](https://travis-ci.

[jira] [Updated] (FLINK-13753) Integrate new Source Operator with Mailbox Model in StreamTask

2019-08-16 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13753: - Description: This is the umbrella issue for integrating new source operator with mailbox model in Strea

[jira] [Updated] (FLINK-13753) Integrate new Source Operator with Mailbox Model in StreamTask

2019-08-16 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13753: - Description: This is the umbrella issue for integrating new source operator with mailbox model in Strea

[jira] [Created] (FLINK-13753) Integrate new Source Operator with Mailbox Model in StreamTask

2019-08-16 Thread zhijiang (JIRA)
zhijiang created FLINK-13753: Summary: Integrate new Source Operator with Mailbox Model in StreamTask Key: FLINK-13753 URL: https://issues.apache.org/jira/browse/FLINK-13753 Project: Flink Issue

[jira] [Updated] (FLINK-13753) Integrate new Source Operator with Mailbox Model in StreamTask

2019-08-16 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13753: - Description: This is the umbrella issue for integrating new source operator with mailbox model in Strea

[GitHub] [flink] flinkbot edited a comment on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-521825874 ## CI report: * 1242679f7bd5ec3f7c1115006e978267abafc84b : CANCELED [Build](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

2019-08-16 Thread GitBox
flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#issuecomment-514437706 ## CI report: * 5eb979da047c442c0205464c92b5bd9ee3a740dc : FAILURE [Build](https://travis-ci.com/flink

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

2019-08-16 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16909226#comment-16909226 ] Xuefu Zhang commented on FLINK-13741: - Thanks all for the inputs. I think we are pre

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

2019-08-16 Thread GitBox
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

2019-08-16 Thread GitBox
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

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

2019-08-16 Thread Yun Gao (JIRA)
[ 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

2019-08-16 Thread Yun Gao (JIRA)
[ 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] [Created] (FLINK-13752) TaskDeploymentDescriptor cannot be recycled by GC due to referenced by an anonymous function

2019-08-16 Thread Yun Gao (JIRA)
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] [Commented] (FLINK-4256) Fine-grained recovery

2019-08-16 Thread Thomas Weise (JIRA)
[ 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

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

2019-08-16 Thread GitBox
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] [Closed] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

2019-08-16 Thread Dawid Wysakowicz (JIRA)
[ 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

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

2019-08-16 Thread Dawid Wysakowicz (JIRA)
[ 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

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

2019-08-16 Thread GitBox
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

2019-08-16 Thread Dawid Wysakowicz (JIRA)
[ 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 #9465: [FLINK-13737][flink-dist][bp-1.9] Added examples-table to flink-dist dependencies

2019-08-16 Thread GitBox
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

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

2019-08-16 Thread GitBox
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] Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

2019-08-16 Thread GitBox
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 commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

2019-08-16 Thread GitBox
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 closed pull request #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

2019-08-16 Thread GitBox
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

2019-08-16 Thread GitBox
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

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-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] Lemonjing opened a new pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

2019-08-16 Thread GitBox
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] 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 [Build](http

[jira] [Comment Edited] (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&focusedCommentId=16909096#comment-16909096 ] Zhu Zhu edited comment on FLINK-13056 at 8/16/19 2:45 PM: -- The

[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&focusedCommentId=16909096#comment-16909096 ] Zhu Zhu commented on FLINK-13056: - The diff can be found at  [https://github.com/zhuzhur

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

[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&focusedCommentId=16909089#comment-16909089 ] vinoyang commented on FLINK-12514: -- [~pnowojski] I will give a more detailed descriptio

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

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

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

2019-08-16 Thread GitBox
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

2019-08-16 Thread GitBox
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

2019-08-16 Thread GitBox
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

[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&focusedCommentId=16909086#comment-16909086 ] 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

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 r

[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&focusedCommentId=16909084#comment-16909084 ] vinoyang commented on FLINK-13143: -- [~pnowojski] you are right. The {{CheckpointExcepti

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

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

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

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

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

2019-08-16 Thread GitBox
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

  1   2   3   4   >