[GitHub] [flink] zhuzhurk commented on issue #10043: [FLINK-14439][runtime] Enable RestartPipelinedRegionStrategy to leverage JM tracked partition availability in DefaultScheduler

2019-10-30 Thread GitBox
zhuzhurk commented on issue #10043: [FLINK-14439][runtime] Enable RestartPipelinedRegionStrategy to leverage JM tracked partition availability in DefaultScheduler URL: https://github.com/apache/flink/pull/10043#issuecomment-547921785 @flinkbot run travis

[GitHub] [flink] azagrebin commented on issue #9997: [FLINK-14522] Introduce JavaGcCleanerWrapper to find Java GC Cleaner depending on JVM version

2019-10-30 Thread GitBox
azagrebin commented on issue #9997: [FLINK-14522] Introduce JavaGcCleanerWrapper to find Java GC Cleaner depending on JVM version URL: https://github.com/apache/flink/pull/9997#issuecomment-547919692 Thanks for the reviews @tillrohrmann @GJL I addressed comments, will merge when the CI

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

2019-10-30 Thread GitBox
flinkbot commented on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation URL: https://github.com/apache/flink/pull/10049#issuecomment-547915608 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] hequn8128 commented on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

2019-10-30 Thread GitBox
hequn8128 commented on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-547915229 @HuangXingBo Thanks a lot for the update. And thanks for the review and suggestions from

[GitHub] [flink] flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-547898353 ## CI report: * 4f4e1f0ab95e451357fc3b20c8087dad16168596 : PENDING

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963031#comment-16963031 ] Dawid Wysakowicz commented on FLINK-13702: -- I agree with [~jark]. If we ever keep the

[jira] [Updated] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14544: --- Labels: pull-request-available test-stability (was: test-stability) > Resuming

[GitHub] [flink] flinkbot edited a comment on issue #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it URL: https://github.com/apache/flink/pull/10044#issuecomment-547851694 ## CI report: * d928f88f00d374a538ae10f3097a3a605a5b9f32 : SUCCESS

[GitHub] [flink] AHeise opened a new pull request #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

2019-10-30 Thread GitBox
AHeise opened a new pull request #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation URL: https://github.com/apache/flink/pull/10049 when closing mailbox / enqueuing poison letter. Added a convenience method to TaskMailbox to run code under the internal

[GitHub] [flink] flinkbot edited a comment on issue #10045: [FLINK-14558][python] Fix ClassNotFoundException of PythonScalarFunctionOperator

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10045: [FLINK-14558][python] Fix ClassNotFoundException of PythonScalarFunctionOperator URL: https://github.com/apache/flink/pull/10045#issuecomment-547862731 ## CI report: * f90b1dcdd113aa43f99a1a8e1c4e9b30afe88009 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-546907883 ## CI report: * 0af01dfef17a8ebcafd92137f87a96023258e124 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[GitHub] [flink] tillrohrmann commented on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-30 Thread GitBox
tillrohrmann commented on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#issuecomment-547909607 Thanks for your review @GJL, @wangyang0918 and @buptljy. I've addressed most of your comments and

[GitHub] [flink] tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340619246 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340618306 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340616674 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340615715 ## File path:

[GitHub] [flink] gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

2019-10-30 Thread GitBox
gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-547905052 @wuchong thanks for your instructions, I have finish the suggestion you provide. please take a look.

[GitHub] [flink] tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340614409 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE

[GitHub] [flink] liupc commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-30 Thread GitBox
liupc commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r340611921 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340611899 ## File path:

[jira] [Created] (FLINK-14574) flink-s3-fs-hadoop doesn't work with plugins mechanism

2019-10-30 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-14574: -- Summary: flink-s3-fs-hadoop doesn't work with plugins mechanism Key: FLINK-14574 URL: https://issues.apache.org/jira/browse/FLINK-14574 Project: Flink

[GitHub] [flink] flinkbot commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread GitBox
flinkbot commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-547898353 ## CI report: * 4f4e1f0ab95e451357fc3b20c8087dad16168596 : UNKNOWN

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340606099 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10043: [FLINK-14439][runtime] Enable RestartPipelinedRegionStrategy to leverage JM tracked partition availability in DefaultScheduler

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10043: [FLINK-14439][runtime] Enable RestartPipelinedRegionStrategy to leverage JM tracked partition availability in DefaultScheduler URL: https://github.com/apache/flink/pull/10043#issuecomment-547839920 ## CI report: *

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340606099 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread GitBox
zhuzhurk commented on a change in pull request #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#discussion_r340603599 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread GitBox
zhuzhurk commented on a change in pull request #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#discussion_r340603599 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread GitBox
zhuzhurk commented on a change in pull request #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#discussion_r340595904 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[GitHub] [flink] wuchong commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
wuchong commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-547894303 I'm sorry for joining the reviewing late. But I'm confused why we need

[jira] [Assigned] (FLINK-14249) Rework table partition support

2019-10-30 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14249: -- Assignee: Jingsong Lee > Rework table partition support > -- > >

[jira] [Closed] (FLINK-14253) Add hash distribution and sort grouping only when dynamic partition insert

2019-10-30 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14253. -- Resolution: Fixed merged: ef0dc509a42a36d22286c64751ea760d538404ec > Add hash distribution and sort

[GitHub] [flink] KurtYoung merged pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

2019-10-30 Thread GitBox
KurtYoung merged pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796 This is an automated message

[GitHub] [flink] flinkbot edited a comment on issue #5866: [FLINK-8047] [http connector] Add HTTP Sink to allow sending output to HTTP server

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #5866: [FLINK-8047] [http connector] Add HTTP Sink to allow sending output to HTTP server URL: https://github.com/apache/flink/pull/5866#issuecomment-547855236 ## CI report: * 6e7c2a3e14cb9599088413973346d550bb4dae99 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#issuecomment-518664724 ## CI report: * 74b7a4a269fa0a56425e8a1176267ad0e1edb02c : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#issuecomment-547497114 ## CI report: * d162b69fa12ca127b422d68e79e222415347c24d : FAILURE

[GitHub] [flink] wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340591586 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: * db25eacc6c332f35ea23e583b5363717c0f599da : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread GitBox
flinkbot commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-547883527 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[jira] [Updated] (FLINK-14462) Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14462: --- Labels: pull-request-available (was: ) > Remove JobGraph#allowQueuedScheduling flag

[GitHub] [flink] TisonKun commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread GitBox
TisonKun commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-547882654 There are several places in tests where `false` is passed but these places `true` or

[GitHub] [flink] TisonKun opened a new pull request #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread GitBox
TisonKun opened a new pull request #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048 ## What is the purpose of the change Remove JobGraph#allowQueuedScheduling flag because it is

[GitHub] [flink] wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340589404 ## File path:

[jira] [Issue Comment Deleted] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

2019-10-30 Thread shengjk1 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-7289: Comment: was deleted (was: Thanks [~yunta] and [~mikekap]. I have solved it. As Mike Kaplinskiy said, i

[GitHub] [flink] pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

2019-10-30 Thread GitBox
pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340576311 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

2019-10-30 Thread GitBox
pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340575529 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

2019-10-30 Thread GitBox
pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340581946 ## File path:

[GitHub] [flink] TisonKun commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-30 Thread GitBox
TisonKun commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-547879127 @kl0u Updated. Please give it another pass :-) I reimplement the logic by just extract the action into utilities.

[jira] [Commented] (FLINK-14570) KeyedStateBootstrapFunction missed onTimer callback method to fire timer

2019-10-30 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962981#comment-16962981 ] vinoyang commented on FLINK-14570: -- [~sjwiesman] OK, I just see the {{TImerService}} and comments, so

[jira] [Commented] (FLINK-12527) Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

2019-10-30 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962982#comment-16962982 ] Gary Yao commented on FLINK-12527: -- Ok > Remove GLOBAL_VERSION_UPDATER in ExecutionGraph >

[GitHub] [flink] flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

[GitHub] [flink] tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r340537281 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r340552855 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r340541055 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r340536894 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r340555175 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r340544660 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r340534122 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r340551678 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#issuecomment-518664724 ## CI report: * 74b7a4a269fa0a56425e8a1176267ad0e1edb02c : FAILURE

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

2019-10-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13869: Affects Version/s: (was: 1.9.0) > Hive functions can not work in blink planner stream mode >

[jira] [Commented] (FLINK-13869) Hive functions can not work in blink planner stream mode

2019-10-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962976#comment-16962976 ] Jark Wu commented on FLINK-13869: - I tried it in current 1.9 branch, and it doesn't have this problem.

[GitHub] [flink] WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-30 Thread GitBox
WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-547874682 @hequn8128 Thanks you for the the notification! This failure did not

[GitHub] [flink] xuyang1706 commented on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
xuyang1706 commented on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#issuecomment-547874123 > Thanks for the contribution @xuyang1706 and sorry for the late review. > > Overall the utility looks good and to me

[GitHub] [flink] flinkbot edited a comment on issue #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig URL: https://github.com/apache/flink/pull/9797#issuecomment-536255105 ## CI report: * 17be7faf6d9c7dd26408c0649491c9401e65f866 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10046: [FLINK-14556][python] Correct the package of cloudpickle

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10046: [FLINK-14556][python] Correct the package of cloudpickle URL: https://github.com/apache/flink/pull/10046#issuecomment-547862798 ## CI report: * 97ce3c4cd785aaa45176e71f8b6cfbaccd2dcb11 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10045: [FLINK-14558][python] Fix ClassNotFoundException of PythonScalarFunctionOperator

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10045: [FLINK-14558][python] Fix ClassNotFoundException of PythonScalarFunctionOperator URL: https://github.com/apache/flink/pull/10045#issuecomment-547862731 ## CI report: * f90b1dcdd113aa43f99a1a8e1c4e9b30afe88009 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10047: [FLINK-14557][python] Cleanup the py4j package

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10047: [FLINK-14557][python] Cleanup the py4j package URL: https://github.com/apache/flink/pull/10047#issuecomment-547862827 ## CI report: * cb60e4dbc6ee91996e3c3b10e5b83c266efa20d3 : PENDING

[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r340578705 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#issuecomment-534832110 ## CI report: * 936857429eb4fa0e47440e142a688ac1505d85ec : FAILURE

[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r340577970 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340578198 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-546907883 ## CI report: * 0af01dfef17a8ebcafd92137f87a96023258e124 : SUCCESS

[jira] [Resolved] (FLINK-13869) Hive functions can not work in blink planner stream mode

2019-10-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13869. - Resolution: Fixed 1.10.0: 1da3055338e5f23a3ec4a54152dbf6b4e35e3862 > Hive functions can not work in

[GitHub] [flink] wuchong merged pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

2019-10-30 Thread GitBox
wuchong merged pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013 This is an automated message from the

[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r340577350 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor URL: https://github.com/apache/flink/pull/10003#issuecomment-546599805 ## CI report: * f51cd353402817c2a22946c857fe80cf6954fda3 : FAILURE

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-10-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962971#comment-16962971 ] Dawid Wysakowicz commented on FLINK-13740: -- Yes, I can take this as well. Even though this is

[jira] [Updated] (FLINK-14535) Cast exception is thrown when count distinct on decimal fields

2019-10-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14535: Summary: Cast exception is thrown when count distinct on decimal fields (was: Fix distinct key type for

[jira] [Resolved] (FLINK-14535) Cast exception is thrown when count distinct on decimal fields

2019-10-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14535. - Resolution: Fixed Fixed in 1.10.0: 11eb7c413bc71e05a0f15b7aa1cf06a7e8e41c59 > Cast exception is thrown

[jira] [Assigned] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-10-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-13740: Assignee: Dawid Wysakowicz > TableAggregateITCase.testNonkeyedFlatAggregate

[jira] [Commented] (FLINK-14488) Update python table API with temporary tables & views methods

2019-10-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962968#comment-16962968 ] Dian Fu commented on FLINK-14488: - Thanks for the discussion. I will take over this JIRA and provide a

[GitHub] [flink] wuchong closed pull request #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

2019-10-30 Thread GitBox
wuchong closed pull request #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001 This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-10-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962963#comment-16962963 ] Jark Wu commented on FLINK-13740: - [~lzljs3620320], Let's keep the discussion in FLINK-13702 and figure

[GitHub] [flink] flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #5866: [FLINK-8047] [http connector] Add HTTP Sink to allow sending output to HTTP server

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #5866: [FLINK-8047] [http connector] Add HTTP Sink to allow sending output to HTTP server URL: https://github.com/apache/flink/pull/5866#issuecomment-547855236 ## CI report: * 6e7c2a3e14cb9599088413973346d550bb4dae99 : PENDING

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962956#comment-16962956 ] Jark Wu commented on FLINK-13702: - Sorry didn't notice the discussion above. Hi [~lzljs3620320], I

[GitHub] [flink] flinkbot edited a comment on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#issuecomment-518664724 ## CI report: * 74b7a4a269fa0a56425e8a1176267ad0e1edb02c : FAILURE

[jira] [Updated] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

2019-10-30 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14164: Description: Previously Flink uses restart all strategy to recover jobs from failures. And the metric

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962952#comment-16962952 ] Jingsong Lee commented on FLINK-13740: -- Hi [~dwysakowicz] , are you interested in fixing it? We all

[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r340568390 ## File path:

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962953#comment-16962953 ] Jark Wu commented on FLINK-13702: - Hi [~dwysakowicz], thanks for looking into this. However, I think

[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r340568347 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r340568237 ## File path:

<    1   2   3   4   5   6   7   >