[GitHub] [flink] fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

2019-07-25 Thread GitBox
fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r307321086 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ##

[GitHub] [flink] fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

2019-07-25 Thread GitBox
fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r307362783 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ##

[GitHub] [flink] fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

2019-07-25 Thread GitBox
fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r307340861 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ##

[GitHub] [flink] fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

2019-07-25 Thread GitBox
fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r307360847 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ##

[GitHub] [flink] fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

2019-07-25 Thread GitBox
fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r307369899 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ##

[GitHub] [flink] fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

2019-07-25 Thread GitBox
fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r307359363 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ##

[GitHub] [flink] fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

2019-07-25 Thread GitBox
fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r307365416 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ##

[GitHub] [flink] fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

2019-07-25 Thread GitBox
fhueske commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r307368830 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ##

[jira] [Updated] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13421: - Fix Version/s: 1.9.0 > Unexpected ConcurrentModificationException when RM notifies JM about > a

[jira] [Resolved] (FLINK-13367) Make ClosureCleaner detect writeReplace serialization override

2019-07-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-13367. Resolution: Fixed Assignee: David Moravek Fix Version/s: 1.9.0

[GitHub] [flink] asfgit closed pull request #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner.

2019-07-25 Thread GitBox
asfgit closed pull request #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner. URL: https://github.com/apache/flink/pull/9201 This is an automated message from the Apache Git Service. To respond to th

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

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

[GitHub] [flink] mxm commented on issue #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner.

2019-07-25 Thread GitBox
mxm commented on issue #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner. URL: https://github.com/apache/flink/pull/9201#issuecomment-515099957 Cool. Tests are green. @dmvk I'll adjust the commit description before merging this. --

[GitHub] [flink] sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-25 Thread GitBox
sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r307369349 ## File path: flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype

[GitHub] [flink] azagrebin commented on a change in pull request #9175: [FLINK-12038] [test] fix YARNITCase random fail

2019-07-25 Thread GitBox
azagrebin commented on a change in pull request #9175: [FLINK-12038] [test] fix YARNITCase random fail URL: https://github.com/apache/flink/pull/9175#discussion_r307368991 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -573,6 +5

[GitHub] [flink] azagrebin commented on a change in pull request #9175: [FLINK-12038] [test] fix YARNITCase random fail

2019-07-25 Thread GitBox
azagrebin commented on a change in pull request #9175: [FLINK-12038] [test] fix YARNITCase random fail URL: https://github.com/apache/flink/pull/9175#discussion_r307368911 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -573,6 +5

[GitHub] [flink] azagrebin commented on a change in pull request #9175: [FLINK-12038] [test] fix YARNITCase random fail

2019-07-25 Thread GitBox
azagrebin commented on a change in pull request #9175: [FLINK-12038] [test] fix YARNITCase random fail URL: https://github.com/apache/flink/pull/9175#discussion_r307368278 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java ## @@ -117,17 +122

[GitHub] [flink] azagrebin commented on a change in pull request #9175: [FLINK-12038] [test] fix YARNITCase random fail

2019-07-25 Thread GitBox
azagrebin commented on a change in pull request #9175: [FLINK-12038] [test] fix YARNITCase random fail URL: https://github.com/apache/flink/pull/9175#discussion_r307365773 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -163,7 +1

[GitHub] [flink] flinkbot commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org

2019-07-25 Thread GitBox
flinkbot commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org URL: https://github.com/apache/flink/pull/9230#issuecomment-515092299 ## CI report: * 465011b7a8f0ae4774f8c9c47ec03e8f58edaa2b : PENDING [Build](https://tr

[GitHub] [flink] wuchong commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org

2019-07-25 Thread GitBox
wuchong commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org URL: https://github.com/apache/flink/pull/9230#issuecomment-515091153 I setup a CRON job on my testing branch to test the email setting: https://travis-ci.org/wuch

[GitHub] [flink] flinkbot commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org

2019-07-25 Thread GitBox
flinkbot commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org URL: https://github.com/apache/flink/pull/9230#issuecomment-515090400 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help th

[jira] [Updated] (FLINK-13430) Configure sending travis build notifications to bui...@flink.apache.org

2019-07-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13430: --- Labels: pull-request-available (was: ) > Configure sending travis build notifications to bu

[GitHub] [flink] wuchong opened a new pull request #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org

2019-07-25 Thread GitBox
wuchong opened a new pull request #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org URL: https://github.com/apache/flink/pull/9230 ## What is the purpose of the change Send travis build notifications the bui...@flink.a

[jira] [Created] (FLINK-13430) Configure sending travis build notifications to bui...@flink.apache.org

2019-07-25 Thread Jark Wu (JIRA)
Jark Wu created FLINK-13430: --- Summary: Configure sending travis build notifications to bui...@flink.apache.org Key: FLINK-13430 URL: https://issues.apache.org/jira/browse/FLINK-13430 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

2019-07-25 Thread GitBox
flinkbot commented on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229#issuecomment-515087495 ## CI report: * 63d15eb2051a523b13ca094d6d100764366462e8 : PENDING [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot commented on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

2019-07-25 Thread GitBox
flinkbot commented on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229#issuecomment-515084950 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to rev

[GitHub] [flink] dawidwys commented on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

2019-07-25 Thread GitBox
dawidwys commented on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229#issuecomment-515084002 Could you have a look at this PR @twalthr? This

[GitHub] [flink] dawidwys opened a new pull request #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

2019-07-25 Thread GitBox
dawidwys opened a new pull request #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229 ## What is the purpose of the change This PR fixes the problem that sink registered automatically via sql-client is not ac

[GitHub] [flink] flinkbot edited a comment on issue #9223: [FLINK-13352][hive] Using hive connector with hive-1.2.1 needs libfb3…

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9223: [FLINK-13352][hive] Using hive connector with hive-1.2.1 needs libfb3… URL: https://github.com/apache/flink/pull/9223#issuecomment-514873847 ## CI report: * 3ac1a7e5322324b5ce2fd0aaf14cfbecc4793670 : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] aljoscha closed pull request #9214: [FLINK-13397] Remove RollingSink

2019-07-25 Thread GitBox
aljoscha closed pull request #9214: [FLINK-13397] Remove RollingSink URL: https://github.com/apache/flink/pull/9214 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] aljoscha commented on issue #9214: [FLINK-13397] Remove RollingSink

2019-07-25 Thread GitBox
aljoscha commented on issue #9214: [FLINK-13397] Remove RollingSink URL: https://github.com/apache/flink/pull/9214#issuecomment-515082451 Thanks for the review! I merged This is an automated message from the Apache Git Service

[GitHub] [flink] aljoscha commented on issue #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner.

2019-07-25 Thread GitBox
aljoscha commented on issue #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner. URL: https://github.com/apache/flink/pull/9201#issuecomment-515080297 Also looks good from my side! 👌 Only the commit title "Add support for writeReplace in nested ClosureCleaner." threw

[GitHub] [flink] wuchong commented on a change in pull request #9195: [FLINK-13289][table-planner-blink] Blink-planner should setKeyFields to upsert table sink

2019-07-25 Thread GitBox
wuchong commented on a change in pull request #9195: [FLINK-13289][table-planner-blink] Blink-planner should setKeyFields to upsert table sink URL: https://github.com/apache/flink/pull/9195#discussion_r307338916 ## File path: flink-table/flink-table-planner-blink/src/main/scala/or

[GitHub] [flink] wuchong commented on a change in pull request #9195: [FLINK-13289][table-planner-blink] Blink-planner should setKeyFields to upsert table sink

2019-07-25 Thread GitBox
wuchong commented on a change in pull request #9195: [FLINK-13289][table-planner-blink] Blink-planner should setKeyFields to upsert table sink URL: https://github.com/apache/flink/pull/9195#discussion_r307337834 ## File path: flink-table/flink-table-planner-blink/src/test/scala/or

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

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

[jira] [Updated] (FLINK-13429) SQL Client end-to-end test fails

2019-07-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-13429: - Summary: SQL Client end-to-end test fails (was: SQL Client end-to-end test fails on Travis) >

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

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

[GitHub] [flink] wuchong commented on issue #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

2019-07-25 Thread GitBox
wuchong commented on issue #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#issuecomment-515056823 Hi @zm12397 , do you have time to update this pull request? -

[jira] [Updated] (FLINK-13428) StreamingFileSink allow part file name to be configurable

2019-07-25 Thread Joao Boto (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joao Boto updated FLINK-13428: -- Component/s: (was: Connectors / FileSystem) > StreamingFileSink allow part file name to be configu

[GitHub] [flink] flinkbot commented on issue #9228: [FLINK-13428] allow part file names to be configurable

2019-07-25 Thread GitBox
flinkbot commented on issue #9228: [FLINK-13428] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#issuecomment-515055909 ## CI report: * f3f92f7d9e74ae453502900b8efa80014f8dfc6f : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/1207

[jira] [Updated] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-25 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-13421: Description: When a TM lost and RM identified it first, it will notify JM about it through  JobMaster#noti

[GitHub] [flink] wuchong commented on issue #9203: [FLINK-13375][table-api] Improve config names in ExecutionConfigOptions and OptimizerConfigOptions

2019-07-25 Thread GitBox
wuchong commented on issue #9203: [FLINK-13375][table-api] Improve config names in ExecutionConfigOptions and OptimizerConfigOptions URL: https://github.com/apache/flink/pull/9203#issuecomment-515054911 Thanks @twalthr . I will adapt blink planner to the new config names then. ---

[jira] [Resolved] (FLINK-13116) Catalog statistic is not bridged to blink planner

2019-07-25 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13116. - Resolution: Fixed Fixed in 1.10.0: - 4817dd9df16c730e2e90f667f51f74ee40c3dd6c - 9cd95930bc89c2a4d4e8ee

[jira] [Commented] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-25 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892776#comment-16892776 ] Zhu Zhu commented on FLINK-13421: - I think I find the cause. ConcurrentModificationExce

[GitHub] [flink] asfgit closed pull request #9083: [FLINK-13116] [table-planner-blink] Fix Catalog statistics is not bridged to blink planner

2019-07-25 Thread GitBox
asfgit closed pull request #9083: [FLINK-13116] [table-planner-blink] Fix Catalog statistics is not bridged to blink planner URL: https://github.com/apache/flink/pull/9083 This is an automated message from the Apache Git Ser

[jira] [Updated] (FLINK-13428) StreamingFileSink allow part file name to be configurable

2019-07-25 Thread Joao Boto (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joao Boto updated FLINK-13428: -- Description: Allow that part file name could be configurable: * partPrefix and partSuffix can be pass

[GitHub] [flink] wuchong commented on issue #9083: [FLINK-13116] [table-planner-blink] Fix Catalog statistics is not bridged to blink planner

2019-07-25 Thread GitBox
wuchong commented on issue #9083: [FLINK-13116] [table-planner-blink] Fix Catalog statistics is not bridged to blink planner URL: https://github.com/apache/flink/pull/9083#issuecomment-515053549 I will modify this when merging. Thanks for the contribution @godfreyhe . -

[GitHub] [flink] flinkbot commented on issue #9228: [FLINK-13428] allow part file names to be configurable

2019-07-25 Thread GitBox
flinkbot commented on issue #9228: [FLINK-13428] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#issuecomment-515053089 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[GitHub] [flink] eskabetxe commented on issue #9228: [FLINK-13428] allow part file names to be configurable

2019-07-25 Thread GitBox
eskabetxe commented on issue #9228: [FLINK-13428] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#issuecomment-515052599 @kl0u could you check this This is an automated message from the

[jira] [Updated] (FLINK-13429) SQL Client end-to-end test fails on Travis

2019-07-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-13429: - Fix Version/s: 1.9.0 > SQL Client end-to-end test fails on Travis >

[jira] [Updated] (FLINK-13428) StreamingFileSink allow part file name to be configurable

2019-07-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13428: --- Labels: pull-request-available (was: ) > StreamingFileSink allow part file name to be confi

[jira] [Created] (FLINK-13429) SQL Client end-to-end test fails on Travis

2019-07-25 Thread Timo Walther (JIRA)
Timo Walther created FLINK-13429: Summary: SQL Client end-to-end test fails on Travis Key: FLINK-13429 URL: https://issues.apache.org/jira/browse/FLINK-13429 Project: Flink Issue Type: Bug

[GitHub] [flink] eskabetxe opened a new pull request #9228: [FLINK-13428] allow part file names to be configurable

2019-07-25 Thread GitBox
eskabetxe opened a new pull request #9228: [FLINK-13428] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228 ## What is the purpose of the change Allow part file name to be configurable ## Brief change log - Bucket have part name prefix a

[jira] [Closed] (FLINK-13155) SQL Client end-to-end test fails on Travis

2019-07-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-13155. Resolution: Fixed I will close this issue for now. Because it seemed that Kurt's commit fixed the

[GitHub] [flink] wuchong commented on issue #9203: [FLINK-13375][table-api] Improve config names in ExecutionConfigOptions and OptimizerConfigOptions

2019-07-25 Thread GitBox
wuchong commented on issue #9203: [FLINK-13375][table-api] Improve config names in ExecutionConfigOptions and OptimizerConfigOptions URL: https://github.com/apache/flink/pull/9203#issuecomment-515051523 Thanks for the reviewing @godfreyhe . I have updated the PR. @twalthr do you want to

[GitHub] [flink] NicoK commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

2019-07-25 Thread GitBox
NicoK commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r307306114 ## File path: flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-res

[GitHub] [flink] flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088#issuecomment-510484364 ## CI report: * eac5f74690ddb0b08cb41b029f5b8ac675e63565 : FAILURE [Build](https://travis-ci.com/flink-ci/f

[jira] [Commented] (FLINK-13399) Create two separate uber jars for each planner

2019-07-25 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892730#comment-16892730 ] Dawid Wysakowicz commented on FLINK-13399: -- It's fine with changing the default

[jira] [Commented] (FLINK-13374) flink-table-planner-blink compile failed for scala-2.12 on travis

2019-07-25 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892729#comment-16892729 ] Jark Wu commented on FLINK-13374: - Here is another instance: https://api.travis-ci.org/v

[jira] [Commented] (FLINK-13399) Create two separate uber jars for each planner

2019-07-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892706#comment-16892706 ] Timo Walther commented on FLINK-13399: -- Yes, I think we should do that. Do you agre

[jira] [Commented] (FLINK-13338) Sql conformance is hard to config in TableConfig

2019-07-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892704#comment-16892704 ] Timo Walther commented on FLINK-13338: -- Flink SQL should be the default conformance

[GitHub] [flink] flinkbot edited a comment on issue #9223: [FLINK-13352][hive] Using hive connector with hive-1.2.1 needs libfb3…

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9223: [FLINK-13352][hive] Using hive connector with hive-1.2.1 needs libfb3… URL: https://github.com/apache/flink/pull/9223#issuecomment-514873847 ## CI report: * 3ac1a7e5322324b5ce2fd0aaf14cfbecc4793670 : SUCCESS [Build](https://travis-ci.com/fli

[jira] [Commented] (FLINK-13427) HiveCatalog's createFunction not work when function name is upper

2019-07-25 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892685#comment-16892685 ] Jingsong Lee commented on FLINK-13427: -- CC: [~xuefuz] [~phoenixjiangnan]  > HiveCa

[jira] [Created] (FLINK-13428) StreamingFileSink allow part file name to be configurable

2019-07-25 Thread Joao Boto (JIRA)
Joao Boto created FLINK-13428: - Summary: StreamingFileSink allow part file name to be configurable Key: FLINK-13428 URL: https://issues.apache.org/jira/browse/FLINK-13428 Project: Flink Issue Typ

[jira] [Updated] (FLINK-13427) HiveCatalog's createFunction not work when function name is upper

2019-07-25 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13427: - Description:   {code:java} hiveCatalog.createFunction( new ObjectPath(HiveCatalog.DEFAULT_

[jira] [Created] (FLINK-13427) HiveCatalog's createFunction not work when function name is upper

2019-07-25 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-13427: Summary: HiveCatalog's createFunction not work when function name is upper Key: FLINK-13427 URL: https://issues.apache.org/jira/browse/FLINK-13427 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case URL: https://github.com/apache/flink/pull/9227#issuecomment-514968257 ## CI report: * 4e487895f4d05fff6e7f3f004245a3ee9d4c73d5 : SUCCESS [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088#issuecomment-510484364 ## CI report: * eac5f74690ddb0b08cb41b029f5b8ac675e63565 : FAILURE [Build](https://travis-ci.com/flink-ci/f

[GitHub] [flink] lirui-apache commented on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table

2019-07-25 Thread GitBox
lirui-apache commented on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088#issuecomment-515004870 PR rebased. @xuefuz @zjuwangg please take another look. Thanks. --

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

2019-07-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892654#comment-16892654 ] Chesnay Schepler edited comment on FLINK-13406 at 7/25/19 11:14 AM: --

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

2019-07-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892654#comment-16892654 ] Chesnay Schepler commented on FLINK-13406: -- This isn't quite incorrect. The {{M

[GitHub] [flink] flinkbot edited a comment on issue #9195: [FLINK-13289][table-planner-blink] Blink-planner should setKeyFields to upsert table sink

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9195: [FLINK-13289][table-planner-blink] Blink-planner should setKeyFields to upsert table sink URL: https://github.com/apache/flink/pull/9195#issuecomment-513690205 ## CI report: * 5a275f751d5b7e13cbf4ce2ecacaf923bc8ccaa8 : FAILURE [Build](https:

[jira] [Commented] (FLINK-13374) flink-table-planner-blink compile failed for scala-2.12 on travis

2019-07-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892652#comment-16892652 ] Chesnay Schepler commented on FLINK-13374: -- We've seen this issue before for 1.

[jira] [Updated] (FLINK-13374) flink-table-planner-blink compile failed for scala-2.12 on travis

2019-07-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13374: - Affects Version/s: (was: 1.10.0) 1.9.0 > flink-table-planner-

[jira] [Updated] (FLINK-13374) flink-table-planner-blink compile failed for scala-2.12 on travis

2019-07-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13374: - Fix Version/s: (was: 1.10.0) 1.9.0 > flink-table-planner-blink co

[GitHub] [flink] flinkbot edited a comment on issue #9226: [FLINK-13420][hive] Supported hive versions are hard coded

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9226: [FLINK-13420][hive] Supported hive versions are hard coded URL: https://github.com/apache/flink/pull/9226#issuecomment-514961850 ## CI report: * 8ae1d347c6439e42c0ad96a09794ddb4cfa0486d : FAILURE [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink URL: https://github.com/apache/flink/pull/9099#issuecomment-510762700 ## CI report: * fb347fe30a5e894e388837ed2de4f9b60513d7b1 : FAILURE [Build](https://travis-ci.com/

[jira] [Commented] (FLINK-13399) Create two separate uber jars for each planner

2019-07-25 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892623#comment-16892623 ] Jark Wu commented on FLINK-13399: - Sure [~twalthr]. I think we can change the default be

[jira] [Commented] (FLINK-10819) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure is unstable

2019-07-25 Thread Guowei Ma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892620#comment-16892620 ] Guowei Ma commented on FLINK-10819: --- I think we could add some status log in SlotManag

[jira] [Comment Edited] (FLINK-10819) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure is unstable

2019-07-25 Thread Guowei Ma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889486#comment-16889486 ] Guowei Ma edited comment on FLINK-10819 at 7/25/19 10:05 AM: -

[jira] [Comment Edited] (FLINK-13383) Customize the problem in the trigger

2019-07-25 Thread jinguishi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892611#comment-16892611 ] jinguishi edited comment on FLINK-13383 at 7/25/19 10:00 AM: -

[jira] [Commented] (FLINK-13383) Customize the problem in the trigger

2019-07-25 Thread jinguishi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892611#comment-16892611 ] jinguishi commented on FLINK-13383: --- all rights > Customize the problem in the trigge

[GitHub] [flink] flinkbot edited a comment on issue #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner.

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner. URL: https://github.com/apache/flink/pull/9201#issuecomment-513806066 ## CI report: * c7e40af7417b518a7d55773de8946ed6022cb5b7 : FAILURE [Build](https://travis-ci.com/flink

[jira] [Updated] (FLINK-13426) TaskExecutor uses the wrong Registrationid in the heartbeat with RM.

2019-07-25 Thread Guowei Ma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13426: -- Attachment: image-2019-07-25-17-57-03-537.png > TaskExecutor uses the wrong Registrationid in the hear

[jira] [Updated] (FLINK-13426) TaskExecutor uses the wrong Registrationid in the heartbeat with RM.

2019-07-25 Thread Guowei Ma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13426: -- Description: 1. First-time TaskExecutor register to rm successfully. If it fails to send SlotReport t

[jira] [Created] (FLINK-13426) TaskExecutor uses the wrong Registrationid in the heartbeat with RM.

2019-07-25 Thread Guowei Ma (JIRA)
Guowei Ma created FLINK-13426: - Summary: TaskExecutor uses the wrong Registrationid in the heartbeat with RM. Key: FLINK-13426 URL: https://issues.apache.org/jira/browse/FLINK-13426 Project: Flink

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

2019-07-25 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13418: - Summary: Avoid InfluxdbReporter to report unnecessary tags (was: Avoid InfluxdbReporter to report unces

[GitHub] [flink] flinkbot edited a comment on issue #9225: [FLINK-13387] Can not download taskmanger & jobmanagers logs in the old UI

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9225: [FLINK-13387] Can not download taskmanger & jobmanagers logs in the old UI URL: https://github.com/apache/flink/pull/9225#issuecomment-514945093 ## CI report: * 49a8e02de05d4c56e89d39bd099e9abd11fcac90 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] mxm commented on a change in pull request #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner.

2019-07-25 Thread GitBox
mxm commented on a change in pull request #9201: [FLINK-13367] Add support for writeReplace in nested ClosureCleaner. URL: https://github.com/apache/flink/pull/9201#discussion_r307203171 ## File path: flink-java/src/test/java/org/apache/flink/api/java/functions/ClosureCleanerTest.j

[jira] [Updated] (FLINK-13425) Table api sqlUpdate execute case when expression occur data error

2019-07-25 Thread pingle wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pingle wang updated FLINK-13425: Description: The flink job running in our online environment, from the beginning of the 1st to th

[GitHub] [flink] flinkbot commented on issue #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case

2019-07-25 Thread GitBox
flinkbot commented on issue #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case URL: https://github.com/apache/flink/pull/9227#issuecomment-514968257 ## CI report: * 4e487895f4d05fff6e7f3f004245a3ee9d4c73d5 : PENDING [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9195: [FLINK-13289][table-planner-blink] Blink-planner should setKeyFields to upsert table sink

2019-07-25 Thread GitBox
flinkbot edited a comment on issue #9195: [FLINK-13289][table-planner-blink] Blink-planner should setKeyFields to upsert table sink URL: https://github.com/apache/flink/pull/9195#issuecomment-513690205 ## CI report: * 5a275f751d5b7e13cbf4ce2ecacaf923bc8ccaa8 : FAILURE [Build](https:

[jira] [Commented] (FLINK-13422) git doc file's link not display correct

2019-07-25 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892575#comment-16892575 ] Yun Tang commented on FLINK-13422: -- [~yantianyu] This is not a problem, the appropriate

[GitHub] [flink] godfreyhe commented on issue #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case

2019-07-25 Thread GitBox
godfreyhe commented on issue #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case URL: https://github.com/apache/flink/pull/9227#issuecomment-514964625 cc @walterddr This is an automated me

[GitHub] [flink] flinkbot commented on issue #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case

2019-07-25 Thread GitBox
flinkbot commented on issue #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case URL: https://github.com/apache/flink/pull/9227#issuecomment-514964927 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Commented] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-25 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892573#comment-16892573 ] Zhu Zhu commented on FLINK-13421: - All job modification is happening in the main thread.

[GitHub] [flink] godfreyhe opened a new pull request #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case

2019-07-25 Thread GitBox
godfreyhe opened a new pull request #9227: [FLINK-13347] [table-planner] should handle SEMI/ANTI JoinRelType in switch case URL: https://github.com/apache/flink/pull/9227 ## What is the purpose of the change *should handle SEMI/ANTI JoinRelType in switch case* ## B

[jira] [Updated] (FLINK-13347) should handle new JoinRelType(SEMI/ANTI) in switch case

2019-07-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13347: --- Labels: pull-request-available (was: ) > should handle new JoinRelType(SEMI/ANTI) in switch

[jira] [Commented] (FLINK-13347) should handle new JoinRelType(SEMI/ANTI) in switch case

2019-07-25 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892569#comment-16892569 ] godfrey he commented on FLINK-13347: i will fix it > should handle new JoinRelType(

[jira] [Resolved] (FLINK-13353) Remove 2 args constructor in REPLACE expression

2019-07-25 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13353. - Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.10.0: 817da8a87b8d6171666b3cbfa5f2d68965765bb2

<    1   2   3   >