[jira] [Updated] (FLINK-13463) SQL VALUES might fail for Blink planner

2019-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-13463: - Fix Version/s: 1.9.0 > SQL VALUES might fail for Blink planner > ---

[jira] [Created] (FLINK-13463) SQL VALUES might fail for Blink planner

2019-07-29 Thread Timo Walther (JIRA)
Timo Walther created FLINK-13463: Summary: SQL VALUES might fail for Blink planner Key: FLINK-13463 URL: https://issues.apache.org/jira/browse/FLINK-13463 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one URL: https://github.com/apache/flink/pull/9252#issuecomment-515825469 ## CI report: * c884b9ebd4ac020c4ecf6bdff2e4c7c003471395 : FAILURE [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #8823: [FLINK-12514] Refactor the failure checkpoint counting mechanism with ordered checkpoint id

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #8823: [FLINK-12514] Refactor the failure checkpoint counting mechanism with ordered checkpoint id URL: https://github.com/apache/flink/pull/8823#issuecomment-515877210 ## CI report: * 36108f9c214493466f1dbad1b098dba7328c359a : FAILURE [Build](http

[GitHub] [flink] flinkbot commented on issue #9259: [MINOR][docs] Doc fix for cluster_setup.md

2019-07-29 Thread GitBox
flinkbot commented on issue #9259: [MINOR][docs] Doc fix for cluster_setup.md URL: https://github.com/apache/flink/pull/9259#issuecomment-515911382 ## CI report: * dff9da131a8f2c888d82777dabf632ea269ab4c0 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/121030997) -

[GitHub] [flink] flinkbot edited a comment on issue #8679: [FLINK-9465] Specify a separate savepoint timeout option via CLI

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #8679: [FLINK-9465] Specify a separate savepoint timeout option via CLI URL: https://github.com/apache/flink/pull/8679#issuecomment-515882872 ## CI report: * ea6ead342d82d234d48f822b7919d93a7807b04b : FAILURE [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot commented on issue #9259: [MINOR][docs] Doc fix for cluster_setup.md

2019-07-29 Thread GitBox
flinkbot commented on issue #9259: [MINOR][docs] Doc fix for cluster_setup.md URL: https://github.com/apache/flink/pull/9259#issuecomment-515910109 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 will

[GitHub] [flink] zjffdu opened a new pull request #9259: [MINOR][docs] Doc fix for cluster_setup.md

2019-07-29 Thread GitBox
zjffdu opened a new pull request #9259: [MINOR][docs] Doc fix for cluster_setup.md URL: https://github.com/apache/flink/pull/9259 ## What is the purpose of the change This is a trivial PR to update the doc `cluster_setup.md` ## Brief change log IIUC, `parallelism.de

[GitHub] [flink] flinkbot edited a comment on issue #8679: [FLINK-9465] Specify a separate savepoint timeout option via CLI

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #8679: [FLINK-9465] Specify a separate savepoint timeout option via CLI URL: https://github.com/apache/flink/pull/8679#issuecomment-515882872 ## CI report: * ea6ead342d82d234d48f822b7919d93a7807b04b : PENDING [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot edited a comment on issue #8871: [FLINK-12976] Bump Kafka client version to 2.3.0 for universal Kafka connector

2019-07-29 Thread GitBox
flinkbot edited a comment 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-515875442 ## CI report: * 4deb818b520abd9d839824bbb800a1a9c9deb841 : FAILURE [Build](https://travis-ci

[jira] [Commented] (FLINK-12164) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable

2019-07-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895073#comment-16895073 ] Till Rohrmann commented on FLINK-12164: --- Another instance: https://api.travis-ci.c

[jira] [Created] (FLINK-13462) Add table api examples into flink-quickstart

2019-07-29 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13462: -- Summary: Add table api examples into flink-quickstart Key: FLINK-13462 URL: https://issues.apache.org/jira/browse/FLINK-13462 Project: Flink Issue Type: Improvem

[jira] [Assigned] (FLINK-13242) StandaloneResourceManagerTest fails on travis

2019-07-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13242: - Assignee: Xintong Song (was: Andrey Zagrebin) > StandaloneResourceManagerTest fails on

[GitHub] [flink] flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480 ## CI report: * de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] flinkbot edited a comment on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest URL: https://github.com/apache/flink/pull/9235#issuecomment-515369449 ## CI report: * 1c65be3d563223e62a7479339abc8ecd6d935bab : FAILURE [Build](https://travis-ci.com/flink

[jira] [Commented] (FLINK-13226) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails on Travis

2019-07-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895051#comment-16895051 ] Till Rohrmann commented on FLINK-13226: --- [~pnowojski] please help reviewing. > Ka

[jira] [Assigned] (FLINK-13452) Pipelined region failover strategy does not recover Job if checkpoint cannot be read

2019-07-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13452: - Assignee: Yun Tang > Pipelined region failover strategy does not recover Job if checkpo

[jira] [Updated] (FLINK-13350) Mark useCatalog & useDatabase as Experimental for 1.9 release

2019-07-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13350: - Issue Type: Sub-task (was: Bug) Parent: FLINK-13461 > Mark useCatalog & useData

[GitHub] [flink] StephanEwen commented on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest

2019-07-29 Thread GitBox
StephanEwen commented on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest URL: https://github.com/apache/flink/pull/9235#issuecomment-515896190 Looks good, thanks. Merging this... This is a

[jira] [Assigned] (FLINK-13441) Add batch E2E test which runs with fewer slots than parallelism

2019-07-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13441: - Assignee: Alex > Add batch E2E test which runs with fewer slots than parallelism >

[jira] [Updated] (FLINK-13350) Mark useCatalog & useDatabase as Experimental for 1.9 release

2019-07-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13350: - Summary: Mark useCatalog & useDatabase as Experimental for 1.9 release (was: Distinguis

[jira] [Commented] (FLINK-13350) Distinguish between temporary tables and persisted tables

2019-07-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895047#comment-16895047 ] Dawid Wysakowicz commented on FLINK-13350: -- The conclusion for 1.9 release was

[jira] [Reopened] (FLINK-13267) Making it possible to have both flink planner and blink planner in classpath

2019-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-13267: -- I will reopen this issue because two subtasks are still open. > Making it possible to have both f

[jira] [Updated] (FLINK-13461) Distinguish between temporary tables and persisted tables

2019-07-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13461: - Fix Version/s: (was: 1.9.0) 1.10.0 > Distinguish between temporar

[jira] [Updated] (FLINK-13461) Distinguish between temporary tables and persisted tables

2019-07-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13461: - Issue Type: Improvement (was: Bug) > Distinguish between temporary tables and persisted

[jira] [Created] (FLINK-13461) Distinguish between temporary tables and persisted tables

2019-07-29 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-13461: Summary: Distinguish between temporary tables and persisted tables Key: FLINK-13461 URL: https://issues.apache.org/jira/browse/FLINK-13461 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass()

2019-07-29 Thread GitBox
flinkbot commented on issue #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass() URL: https://github.com/apache/flink/pull/9258#issuecomment-515893123 ## CI report: * 650ce60b70c7ee65844109247b0b4808b7a16a00 : PENDING [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9249: [FLINK-13447][table-api] Change default planner to legacy planner instead of any one

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #9249: [FLINK-13447][table-api] Change default planner to legacy planner instead of any one URL: https://github.com/apache/flink/pull/9249#issuecomment-515691656 ## CI report: * be35c02b78c6116a023cfba8a09ba0c2e5c4fda6 : FAILURE [Build](https://tra

[GitHub] [flink] carp84 commented on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest

2019-07-29 Thread GitBox
carp84 commented on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest URL: https://github.com/apache/flink/pull/9235#issuecomment-515892824 Thanks for the reminder @StephanEwen , I thought it might be useful to log the exception out at debug level but yes we

[jira] [Commented] (FLINK-13458) ThreadLocalCache clashes for Blink planner

2019-07-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895044#comment-16895044 ] Dawid Wysakowicz commented on FLINK-13458: -- I will have a look at it. > Thread

[jira] [Closed] (FLINK-13387) Can not download taskmanger & jobmanager's logs in the old UI

2019-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13387. Resolution: Fixed master: 12118b9589606deddc4e5bd60f39ebb04f2568c7 1.9: 5077f186c5fc0644f

[GitHub] [flink] flinkbot commented on issue #9257: [FLINK-13458][table] ThreadLocalCache clashes for Blink planner

2019-07-29 Thread GitBox
flinkbot commented on issue #9257: [FLINK-13458][table] ThreadLocalCache clashes for Blink planner URL: https://github.com/apache/flink/pull/9257#issuecomment-515891016 ## CI report: * d5cd4995003de982038ecf1bdfc0f2cab570c79e : PENDING [Build](https://travis-ci.com/flink-ci/flink/bu

[GitHub] [flink] zentol merged pull request #9238: [FLINK-13387][WebUI] Fix log download for old UI

2019-07-29 Thread GitBox
zentol merged pull request #9238: [FLINK-13387][WebUI] Fix log download for old UI URL: https://github.com/apache/flink/pull/9238 This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] flinkbot commented on issue #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass()

2019-07-29 Thread GitBox
flinkbot commented on issue #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass() URL: https://github.com/apache/flink/pull/9258#issuecomment-515890716 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communi

[jira] [Updated] (FLINK-13460) Rework SerializedThrowableTest to not use Unsafe.defineClass()

2019-07-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13460: --- Labels: pull-request-available (was: ) > Rework SerializedThrowableTest to not use Unsafe.d

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

2019-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-13429. -- Resolution: Fixed Fixed in 1.10.0: b670b11f303657aa8175ec933ee29b377cb9e087 Fixed in 1.9.0: 02

[GitHub] [flink] zentol opened a new pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass()

2019-07-29 Thread GitBox
zentol opened a new pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass() URL: https://github.com/apache/flink/pull/9258 Follow-up to #9251. Uses the same mechanism to migrate away from `Unsafe#defineClass` used in #9251. Extends it

[GitHub] [flink] hequn8128 commented on a change in pull request #9248: [FLINK-13446][table-runtime-blink] Fix assign logic for row count sliding window

2019-07-29 Thread GitBox
hequn8128 commented on a change in pull request #9248: [FLINK-13446][table-runtime-blink] Fix assign logic for row count sliding window URL: https://github.com/apache/flink/pull/9248#discussion_r308100033 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/

[GitHub] [flink] asfgit closed pull request #9241: [FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps watermark strategy

2019-07-29 Thread GitBox
asfgit closed pull request #9241: [FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps watermark strategy URL: https://github.com/apache/flink/pull/9241 This is an automated message from the Apache Git Service. To res

[jira] [Commented] (FLINK-5833) Support for Hive GenericUDF

2019-07-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895035#comment-16895035 ] Fabian Hueske commented on FLINK-5833: -- Hi, the corresponding PR was closed half a y

[jira] [Assigned] (FLINK-5833) Support for Hive GenericUDF

2019-07-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-5833: Assignee: MJ Deng (was: Zhuoluo Yang) > Support for Hive GenericUDF > ---

[GitHub] [flink] flinkbot commented on issue #9257: [FLINK-13458][table] ThreadLocalCache clashes for Blink planner

2019-07-29 Thread GitBox
flinkbot commented on issue #9257: [FLINK-13458][table] ThreadLocalCache clashes for Blink planner URL: https://github.com/apache/flink/pull/9257#issuecomment-515888208 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-13458) ThreadLocalCache clashes for Blink planner

2019-07-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13458: --- Labels: pull-request-available (was: ) > ThreadLocalCache clashes for Blink planner > -

[GitHub] [flink] wuchong commented on a change in pull request #9219: [FLINK-13404] [table] Port csv factories and descriptors to flink-csv

2019-07-29 Thread GitBox
wuchong commented on a change in pull request #9219: [FLINK-13404] [table] Port csv factories and descriptors to flink-csv URL: https://github.com/apache/flink/pull/9219#discussion_r308097586 ## File path: flink-formats/flink-csv/pom.xml ## @@ -58,31 +58,24 @@ under the Li

[GitHub] [flink] twalthr opened a new pull request #9257: [FLINK-13458][table] ThreadLocalCache clashes for Blink planner

2019-07-29 Thread GitBox
twalthr opened a new pull request #9257: [FLINK-13458][table] ThreadLocalCache clashes for Blink planner URL: https://github.com/apache/flink/pull/9257 ## What is the purpose of the change Fixes a class clash between planners. ## Brief change log Class moves to flink-ta

[GitHub] [flink] wuchong commented on a change in pull request #9219: [FLINK-13404] [table] Port csv factories and descriptors to flink-csv

2019-07-29 Thread GitBox
wuchong commented on a change in pull request #9219: [FLINK-13404] [table] Port csv factories and descriptors to flink-csv URL: https://github.com/apache/flink/pull/9219#discussion_r308096834 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/table/descriptors/Old

[GitHub] [flink] wuchong commented on a change in pull request #9219: [FLINK-13404] [table] Port csv factories and descriptors to flink-csv

2019-07-29 Thread GitBox
wuchong commented on a change in pull request #9219: [FLINK-13404] [table] Port csv factories and descriptors to flink-csv URL: https://github.com/apache/flink/pull/9219#discussion_r308097586 ## File path: flink-formats/flink-csv/pom.xml ## @@ -58,31 +58,24 @@ under the Li

[GitHub] [flink] flinkbot edited a comment on issue #9244: [FLINK-13396] Deprecate the BucketingSink.

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#issuecomment-515493269 ## CI report: * 8e3b712c5c2e003747737d2fb77752a3e10a3279 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/120873450

[jira] [Created] (FLINK-13460) Rework SerializedThrowableTest to not use Unsafe.defineClass()

2019-07-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-13460: Summary: Rework SerializedThrowableTest to not use Unsafe.defineClass() Key: FLINK-13460 URL: https://issues.apache.org/jira/browse/FLINK-13460 Project: Flink

[GitHub] [flink] xintongsong commented on issue #9022: [FLINK-13127] Fix --yarnship classpath

2019-07-29 Thread GitBox
xintongsong commented on issue #9022: [FLINK-13127] Fix --yarnship classpath URL: https://github.com/apache/flink/pull/9022#issuecomment-515885981 @dmvk Thanks for addressing the comments, the PR looks good to me. @tillrohrmann Could you take a final check on this? --

[GitHub] [flink] hequn8128 commented on a change in pull request #9248: [FLINK-13446][table-runtime-blink] Fix assign logic for row count sliding window

2019-07-29 Thread GitBox
hequn8128 commented on a change in pull request #9248: [FLINK-13446][table-runtime-blink] Fix assign logic for row count sliding window URL: https://github.com/apache/flink/pull/9248#discussion_r308095686 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/

[GitHub] [flink] kl0u commented on issue #9244: [FLINK-13396] Deprecate the BucketingSink.

2019-07-29 Thread GitBox
kl0u commented on issue #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#issuecomment-515885084 Thanks for the review @wuchong ! I integrated your comment @zentol . Let me know what you think. --

[GitHub] [flink] kl0u commented on a change in pull request #9244: [FLINK-13396] Deprecate the BucketingSink.

2019-07-29 Thread GitBox
kl0u commented on a change in pull request #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#discussion_r308082050 ## File path: docs/dev/connectors/filesystem_sink.md ## @@ -23,6 +23,10 @@ specific language governing permissi

[GitHub] [flink] kl0u commented on a change in pull request #9244: [FLINK-13396] Deprecate the BucketingSink.

2019-07-29 Thread GitBox
kl0u commented on a change in pull request #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#discussion_r308094781 ## File path: docs/dev/connectors/filesystem_sink.md ## @@ -23,6 +23,10 @@ specific language governing permissi

[GitHub] [flink] flinkbot edited a comment on issue #9249: [FLINK-13447][table-api] Change default planner to legacy planner instead of any one

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #9249: [FLINK-13447][table-api] Change default planner to legacy planner instead of any one URL: https://github.com/apache/flink/pull/9249#issuecomment-515691656 ## CI report: * be35c02b78c6116a023cfba8a09ba0c2e5c4fda6 : FAILURE [Build](https://tra

[jira] [Assigned] (FLINK-13436) Add TPC-H queries as E2E tests

2019-07-29 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13436: --- Assignee: Yu Li > Add TPC-H queries as E2E tests > -- > >

[GitHub] [flink] flinkbot commented on issue #8679: [FLINK-9465] Specify a separate savepoint timeout option via CLI

2019-07-29 Thread GitBox
flinkbot commented on issue #8679: [FLINK-9465] Specify a separate savepoint timeout option via CLI URL: https://github.com/apache/flink/pull/8679#issuecomment-515882872 ## CI report: * ea6ead342d82d234d48f822b7919d93a7807b04b : PENDING [Build](https://travis-ci.com/flink-ci/flink/b

[jira] [Commented] (FLINK-13438) Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support

2019-07-29 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895025#comment-16895025 ] Jark Wu commented on FLINK-13438: - Hi [~lirui], will you help to fix this issue? If yes,

[jira] [Commented] (FLINK-5832) Support for simple hive UDF

2019-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895024#comment-16895024 ] Timo Walther commented on FLINK-5832: - Hi [~miaoever], support for Hive UDFs is alrea

[jira] [Created] (FLINK-13459) Violation of the order queue messages from RabbitMQ.

2019-07-29 Thread Dmitry Kharlashko (JIRA)
Dmitry Kharlashko created FLINK-13459: - Summary: Violation of the order queue messages from RabbitMQ. Key: FLINK-13459 URL: https://issues.apache.org/jira/browse/FLINK-13459 Project: Flink

[jira] [Updated] (FLINK-13451) Rework CommonTestUtils.createClassNotInClassPath() to not use Unsafe.defineClass()

2019-07-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13451: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-10725 > Rework CommonTest

[GitHub] [flink] xintongsong commented on issue #9242: [FLINK-13408][runtime] Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired

2019-07-29 Thread GitBox
xintongsong commented on issue #9242: [FLINK-13408][runtime] Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired URL: https://github.com/apache/flink/pull/9242#issuecomment-515880026 @tillrohrmann PR is updated and passed [travis](https:/

[GitHub] [flink] xintongsong commented on issue #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

2019-07-29 Thread GitBox
xintongsong commented on issue #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105#issuecomment-515879788 @tillrohrmann PR is updated and passed [travis](https://tr

[GitHub] [flink] StephanEwen commented on issue #9132: [FLINK-13245][network] Fix the bug of resource leak while releasing partition and view reader

2019-07-29 Thread GitBox
StephanEwen commented on issue #9132: [FLINK-13245][network] Fix the bug of resource leak while releasing partition and view reader URL: https://github.com/apache/flink/pull/9132#issuecomment-515878948 Thanks, looks good. Merging this... -

[jira] [Resolved] (FLINK-13451) Rework CommonTestUtils.createClassNotInClassPath() to not use Unsafe.defineClass()

2019-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13451. -- Resolution: Fixed Fixed in c5b133e6b13ea468763730e45f872b2370c2a206 > Rework CommonTestUtils.

[jira] [Closed] (FLINK-13451) Rework CommonTestUtils.createClassNotInClassPath() to not use Unsafe.defineClass()

2019-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13451. > Rework CommonTestUtils.createClassNotInClassPath() to not use > Unsafe.defineClass() >

[GitHub] [flink] asfgit closed pull request #9251: [FLINK-13451][tests] Remove use of Unsafe.defineClass() from CommonTestUtils

2019-07-29 Thread GitBox
asfgit closed pull request #9251: [FLINK-13451][tests] Remove use of Unsafe.defineClass() from CommonTestUtils URL: https://github.com/apache/flink/pull/9251 This is an automated message from the Apache Git Service. To respo

[jira] [Resolved] (FLINK-13012) Handle default partition name of Hive table

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

[GitHub] [flink] flinkbot commented on issue #8823: [FLINK-12514] Refactor the failure checkpoint counting mechanism with ordered checkpoint id

2019-07-29 Thread GitBox
flinkbot commented on issue #8823: [FLINK-12514] Refactor the failure checkpoint counting mechanism with ordered checkpoint id URL: https://github.com/apache/flink/pull/8823#issuecomment-515877210 ## CI report: * 36108f9c214493466f1dbad1b098dba7328c359a : PENDING [Build](https://tra

[GitHub] [flink] StephanEwen commented on issue #9251: [FLINK-13451][tests] Remove use of Unsafe.defineClass() from CommonTestUtils

2019-07-29 Thread GitBox
StephanEwen commented on issue #9251: [FLINK-13451][tests] Remove use of Unsafe.defineClass() from CommonTestUtils URL: https://github.com/apache/flink/pull/9251#issuecomment-515877158 Thanks, merging this... This is an autom

[jira] [Commented] (FLINK-13273) Allow switching planners in SQL Client

2019-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895010#comment-16895010 ] Timo Walther commented on FLINK-13273: -- I would not block another RC because of Tab

[GitHub] [flink] twalthr commented on issue #9241: [FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps watermark strategy

2019-07-29 Thread GitBox
twalthr commented on issue #9241: [FLINK-13429][table-common] Fix BoundedOutOfOrderTimestamps watermark strategy URL: https://github.com/apache/flink/pull/9241#issuecomment-515876418 Thanks @dawidwys. Merging... This is an au

[GitHub] [flink] Myasuka commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

2019-07-29 Thread GitBox
Myasuka commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515875997 @flinkbot attention @aljoscha @wuchong as I also changed the `MapView`. --

[GitHub] [flink] ThunderSuuuuu closed pull request #9256: Release 1.8

2019-07-29 Thread GitBox
ThunderSu closed pull request #9256: Release 1.8 URL: https://github.com/apache/flink/pull/9256 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] ThunderSuuuuu opened a new pull request #9256: Release 1.8

2019-07-29 Thread GitBox
ThunderSu opened a new pull request #9256: Release 1.8 URL: https://github.com/apache/flink/pull/9256 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-tran

[jira] [Comment Edited] (FLINK-12818) Improve stability of twoInputMapSink benchmark

2019-07-29 Thread Haibo Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894906#comment-16894906 ] Haibo Sun edited comment on FLINK-12818 at 7/29/19 7:19 AM:

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

2019-07-29 Thread GitBox
flinkbot 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-515875442 ## CI report: * 4deb818b520abd9d839824bbb800a1a9c9deb841 : PENDING [Build](https://travis-ci.com/fl

[jira] [Updated] (FLINK-13458) ThreadLocalCache clashes for Blink planner

2019-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-13458: - Fix Version/s: 1.9.0 > ThreadLocalCache clashes for Blink planner >

[jira] [Updated] (FLINK-13458) ThreadLocalCache clashes for Blink planner

2019-07-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-13458: - Priority: Blocker (was: Major) > ThreadLocalCache clashes for Blink planner > -

[GitHub] [flink] yanghua commented on issue #8823: [FLINK-12514] Refactor the failure checkpoint counting mechanism with ordered checkpoint id

2019-07-29 Thread GitBox
yanghua commented on issue #8823: [FLINK-12514] Refactor the failure checkpoint counting mechanism with ordered checkpoint id URL: https://github.com/apache/flink/pull/8823#issuecomment-515875165 @pnowojski Can you review this PR if you have time? Thanks. --

[jira] [Commented] (FLINK-12836) Allow retained checkpoints to be persisted on success

2019-07-29 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895008#comment-16895008 ] vinoyang commented on FLINK-12836: -- [~till.rohrmann] WDYT? > Allow retained checkpoint

[jira] [Commented] (FLINK-13405) Translate "Basic API Concepts" page into Chinese

2019-07-29 Thread WangHengWei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895007#comment-16895007 ] WangHengWei commented on FLINK-13405: - 我也认为e.g.更为合理,是否可以在邮件列表发起一个讨论,明确一下英文文档的意思,有必要的

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

2019-07-29 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-515874382 Thanks @wuchong for help with the merge! This is an

[GitHub] [flink] asfgit closed pull request #9088: [FLINK-13012][hive] Handle default partition name of Hive table

2019-07-29 Thread GitBox
asfgit closed pull request #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088 This is an automated message from the Apache Git Service. To respond to the mes

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

2019-07-29 Thread GitBox
yanghua 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-515873701 @aljoscha and @pnowojski when you are released from 1.9, shall we discuss this issue?

[GitHub] [flink] ifndef-SleePy commented on issue #9253: [Flink-12164][tests] Harden JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout

2019-07-29 Thread GitBox
ifndef-SleePy commented on issue #9253: [Flink-12164][tests] Harden JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout URL: https://github.com/apache/flink/pull/9253#issuecomment-515873485 The Travis building fails due to a known unstable case, see https://issues.apache.org/jira/

[jira] [Commented] (FLINK-13242) StandaloneResourceManagerTest fails on travis

2019-07-29 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895003#comment-16895003 ] Biao Liu commented on FLINK-13242: -- Another instance, [https://travis-ci.com/flink-ci/f

[GitHub] [flink] kl0u commented on a change in pull request #9244: [FLINK-13396] Deprecate the BucketingSink.

2019-07-29 Thread GitBox
kl0u commented on a change in pull request #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#discussion_r308082050 ## File path: docs/dev/connectors/filesystem_sink.md ## @@ -23,6 +23,10 @@ specific language governing permissi

[jira] [Commented] (FLINK-13456) Bump lombok to 1.16.22

2019-07-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895002#comment-16895002 ] Stephan Ewen commented on FLINK-13456: -- Can we possibly drop lombok? I have never

[jira] [Created] (FLINK-13458) ThreadLocalCache clashes for Blink planner

2019-07-29 Thread Timo Walther (JIRA)
Timo Walther created FLINK-13458: Summary: ThreadLocalCache clashes for Blink planner Key: FLINK-13458 URL: https://issues.apache.org/jira/browse/FLINK-13458 Project: Flink Issue Type: Sub-ta

[GitHub] [flink] flinkbot edited a comment on issue #9254: [FLINK-13427][hive] HiveCatalog's createFunction fails when function …

2019-07-29 Thread GitBox
flinkbot edited a comment on issue #9254: [FLINK-13427][hive] HiveCatalog's createFunction fails when function … URL: https://github.com/apache/flink/pull/9254#issuecomment-515852651 ## CI report: * 9ab2841490d5dd93cfb4fec046240dcb43df19bc : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

2019-07-29 Thread GitBox
flinkbot commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480 ## CI report: * de863750b7262d091d2e7dd82767b8f9b2e2c52a : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/1210158

<    1   2   3   4   5