[jira] [Commented] (FLINK-14577) Hortonworks schema registry support for avro deserialization

2019-10-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963706#comment-16963706 ] Gyula Fora commented on FLINK-14577: Thanks for bringing up the discussion. We have

[jira] [Commented] (FLINK-14556) Correct the package of cloud pickle

2019-10-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963701#comment-16963701 ] Hequn Cheng commented on FLINK-14556: - Fix in 1.10.0 via 6c6ada5b36577490fde74fc8d34

[jira] [Closed] (FLINK-14556) Correct the package of cloud pickle

2019-10-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14556. --- Resolution: Fixed > Correct the package of cloud pickle > --- > >

[GitHub] [flink] flinkbot edited a comment on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056#issuecomment-548232338 ## CI report: * caa585061e20672b3ca16298101dbd49230854e8 : PENDING [Bu

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

2019-10-30 Thread GitBox
zhijiangW 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_r340980280 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/r

[GitHub] [flink] hequn8128 closed pull request #10046: [FLINK-14556][python] Correct the package of cloudpickle

2019-10-30 Thread GitBox
hequn8128 closed pull request #10046: [FLINK-14556][python] Correct the package of cloudpickle URL: https://github.com/apache/flink/pull/10046 This is an automated message from the Apache Git Service. To respond to the messa

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

2019-10-30 Thread GitBox
zhijiangW 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_r340980280 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/r

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE

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

2019-10-30 Thread GitBox
zhijiangW 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_r340978662 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/Availab

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

2019-10-30 Thread GitBox
JingsongLi 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-548235482 > adding these methods long getEpochMilliSecond(int idx), int getNano

[GitHub] [flink] JingsongLi edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
JingsongLi edited a comment 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-548235482 > adding these methods long getEpochMilliSecond(int idx), int

[GitHub] [flink] KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340977059 ## File path: flink-table/flink-table-runt

[GitHub] [flink] KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340976335 ## File path: flink-table/flink-table-runt

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

2019-10-30 Thread GitBox
wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-548232682 Many thanks to @zhijiangW and @pnowojski for the review. I have updated the PR. --

[GitHub] [flink] flinkbot commented on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

2019-10-30 Thread GitBox
flinkbot commented on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056#issuecomment-548232338 ## CI report: * caa585061e20672b3ca16298101dbd49230854e8 : UNKNOWN

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340974658 ## File path: flink-table/flink-table-run

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340973836 ## File path: flink-table/flink-table-runtime

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340973836 ## File path: flink-table/flink-table-runtime

[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_r340973400 ## File path: flink-runtime/src/main/java/org/apache/flink/r

[GitHub] [flink] flinkbot commented on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

2019-10-30 Thread GitBox
flinkbot commented on issue #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056#issuecomment-548229030 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I hel

[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_r340971659 ## File path: flink-runtime/src/main/java/org/apache/flink/r

[jira] [Updated] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14565: --- Labels: pull-request-available (was: ) > Shutdown SystemResourcesCounter on (JM|TM)MetricGr

[GitHub] [flink] TisonKun opened a new pull request #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak

2019-10-30 Thread GitBox
TisonKun opened a new pull request #10056: [FLINK-14565][metric] Shut down SystemResourcesCounter on Metric closed to prevent thread leak URL: https://github.com/apache/flink/pull/10056 ## What is the purpose of the change Solve potentially thread leak described in [FLINK-14565](htt

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340970100 ## File path: flink-table/flink-table-runtime

[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 [Build](https://t

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

2019-10-30 Thread GitBox
zhuzhurk 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-548226349 > @zhuzhurk I think it is a test scope problem that we now waiting for a long time bef

[jira] [Closed] (FLINK-14547) UDF cannot be in the join condition in blink planner

2019-10-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14547. --- Resolution: Fixed > UDF cannot be in the join condition in blink planner > -

[jira] [Commented] (FLINK-14547) UDF cannot be in the join condition in blink planner

2019-10-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963661#comment-16963661 ] Hequn Cheng commented on FLINK-14547: - Fixed in 1.9.2 via 4368f1da8598f993523dd18ede

[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 : FAILURE [

[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 [Build](https://t

[GitHub] [flink] liyafan82 commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

2019-10-30 Thread GitBox
liyafan82 commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#discussion_r340957185 ## File path: flink-core/src/test/java/org/apache/flink/core/m

[GitHub] [flink] liyafan82 commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

2019-10-30 Thread GitBox
liyafan82 commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#discussion_r340957100 ## File path: flink-core/src/test/java/org/apache/flink/core/m

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

2019-10-30 Thread GitBox
zhijiangW 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_r340956723 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network

[GitHub] [flink] flinkbot edited a comment on issue #10055: [FLINK-14573][python] Support time data types in Python user-defined functions

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10055: [FLINK-14573][python] Support time data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10055#issuecomment-548197077 ## CI report: * 34cac913e7be2946b0a28360d6f1beac72e9fdd5 : SUCCESS [Build](https://tra

[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 [Build](https://t

[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] 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: * 56534bf9aca399adfe814d

[jira] [Commented] (FLINK-14536) Make clear the way to aggregate specified cpuCores resources

2019-10-30 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963630#comment-16963630 ] zhijiang commented on FLINK-14536: -- For the chained operators, the final aggregated cpu

[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 : FAILURE [

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

2019-10-30 Thread GitBox
wuchong edited a comment 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-548206092 > We always need the milli part in computing. For this re

[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-548206092 > We always need the milli part in computing. For this requirment, I

[GitHub] [flink] KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340950384 ## File path: flink-table/flink-table-runt

[GitHub] [flink] KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
KurtYoung commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340950384 ## File path: flink-table/flink-table-runt

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340948653 ## File path: flink-table/flink-table-run

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340948232 ## File path: flink-table/flink-table-run

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16963605#comment-16963605 ] Jark Wu commented on FLINK-14535: - Fixed in 1.9.2: 640b11ee9454e8d210c0185a3b0001f063ac8

[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: Fix Version/s: 1.9.2 > Cast exception is thrown when count distinct on decimal fields > --

[GitHub] [flink] flinkbot edited a comment on issue #10055: [FLINK-14573][python] Support time data types in Python user-defined functions

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10055: [FLINK-14573][python] Support time data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10055#issuecomment-548197077 ## CI report: * 34cac913e7be2946b0a28360d6f1beac72e9fdd5 : PENDING [Build](https://tra

[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 : FAILURE [

[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] 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: * 56534bf9aca399adfe814d

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

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963600#comment-16963600 ] Jingsong Lee edited comment on FLINK-13702 at 10/31/19 3:25 AM: --

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

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963600#comment-16963600 ] Jingsong Lee commented on FLINK-13702: -- Thanks [~jark] 's input. It's true that the

[jira] [Commented] (FLINK-14550) can't use proctime attribute when register datastream for table and exist nested fields

2019-10-30 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963598#comment-16963598 ] hehuiyuan commented on FLINK-14550: --- Hi，[~jark] ，  # Flink version 1.8.1 # use type_

[GitHub] [flink] lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-30 Thread GitBox
lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#discussion_r340945230 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink

[jira] [Assigned] (FLINK-14573) Support time data types in Python user-defined functions

2019-10-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14573: --- Assignee: Huang Xingbo > Support time data types in Python user-defined functions > ---

[GitHub] [flink] lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-30 Thread GitBox
lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#discussion_r340944373 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink

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

2019-10-30 Thread GitBox
JingsongLi 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-548199016 > Hi @JingsongLi , @docete , so why not use `Instant`. It is as light

[GitHub] [flink] lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-30 Thread GitBox
lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#discussion_r340942338 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink

[GitHub] [flink] lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-30 Thread GitBox
lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#discussion_r340943437 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink

[GitHub] [flink] lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-30 Thread GitBox
lirui-apache commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#discussion_r340941385 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink

[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-548198516 @zhuzhurk I think it is a test scope problem that we now waiting for a long time befor

[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-548198591 BTW, I disable the test to verify whether we fail in other tests.

[GitHub] [flink] flinkbot commented on issue #10055: [FLINK-14573][python] Support time data types in Python user-defined functions

2019-10-30 Thread GitBox
flinkbot commented on issue #10055: [FLINK-14573][python] Support time data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10055#issuecomment-548197077 ## CI report: * 34cac913e7be2946b0a28360d6f1beac72e9fdd5 : UNKNOWN Bot commands

[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] 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: * 56534bf9aca399adfe814d

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

2019-10-30 Thread GitBox
docete 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-548196541 > Hi @JingsongLi , @docete , so why not using `Instant`. It is as lightw

[GitHub] [flink] docete edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
docete edited a comment 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-548196541 > Hi @JingsongLi , @docete , so why not using `Instant`. It is as

[GitHub] [flink] flinkbot commented on issue #10055: [FLINK-14573][python] Support time data types in Python user-defined functions

2019-10-30 Thread GitBox
flinkbot commented on issue #10055: [FLINK-14573][python] Support time data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10055#issuecomment-548194208 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[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-548194225 Yes @zhuzhurk , I am looking into it now.

[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-548194090 Hi @JingsongLi , @docete , so why not using `Instant`. It is as lightwei

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

2019-10-30 Thread GitBox
wuchong edited a comment 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-548194090 Hi @JingsongLi , @docete , so why not use `Instant`. It is as lig

[jira] [Updated] (FLINK-14547) UDF cannot be in the join condition in blink planner

2019-10-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14547: Fix Version/s: 1.9.2 1.10.0 > UDF cannot be in the join condition in blink plan

[jira] [Updated] (FLINK-14573) Support time data types in Python user-defined functions

2019-10-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14573: --- Labels: pull-request-available (was: ) > Support time data types in Python user-defined fun

[GitHub] [flink] HuangXingBo opened a new pull request #10055: [FLINK-14573][python] Support time data types in Python user-defined functions

2019-10-30 Thread GitBox
HuangXingBo opened a new pull request #10055: [FLINK-14573][python] Support time data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10055 ## What is the purpose of the change *This pr supports TimeType and TimestampType In Python UDF.* ##

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

2019-10-30 Thread GitBox
JingsongLi 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-548192721 Hi @wuchong , this class is not only for TIMESTAMP_WITHOUT_TIME_ZONE,

[GitHub] [flink] JingsongLi edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-30 Thread GitBox
JingsongLi edited a comment 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-548192721 Hi @wuchong , as docete said, this class is not only for TIME

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

2019-10-30 Thread GitBox
docete 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-548191373 Hi @wuchong , we introduce this class for performance reasons. The Local

[jira] [Comment Edited] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

2019-10-30 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963560#comment-16963560 ] Congxian Qiu(klion26) edited comment on FLINK-13969 at 10/31/19 2:26 AM: -

[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-548189633 Rebased onto master ---

[GitHub] [flink] zhuzhurk commented on issue #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it

2019-10-30 Thread GitBox
zhuzhurk commented on issue #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it URL: https://github.com/apache/flink/pull/10044#issuecomment-548189655 Rebased onto master

[GitHub] [flink] buptljy 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
buptljy 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_r340935939 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/

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

2019-10-30 Thread GitBox
zhuzhurk 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-548188694 The case `ExecutionGraphRestartTest#testRestartWithSlotSharingAndNotEnoughResources` i

[jira] [Comment Edited] (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&focusedCommentId=16962953#comment-16962953 ] Jark Wu edited comment on FLINK-13702 at 10/31/19 2:05 AM: --- Hi

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

2019-10-30 Thread GitBox
wuchong 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_r340933268 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSch

[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_r340931825 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableS

[GitHub] [flink] hequn8128 closed pull request #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot in the join condition in blink planner for Table API

2019-10-30 Thread GitBox
hequn8128 closed pull request #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot in the join condition in blink planner for Table API URL: https://github.com/apache/flink/pull/10016 This is an automated message from t

[jira] [Commented] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

2019-10-30 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963560#comment-16963560 ] Congxian Qiu(klion26) commented on FLINK-13969: --- Hi, [~trohrmann], from th

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

[jira] [Commented] (FLINK-14560) The value of taskmanager.memory.size in flink-conf.yaml is set to zero will cause taskmanager not to work

2019-10-30 Thread fa zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963549#comment-16963549 ] fa zheng commented on FLINK-14560: -- [~trohrmann], sure, i want to have a try. > The va

[GitHub] [flink] flinkbot edited a comment on issue #10053: [FLINK-14578][table] load/unloadModule() should throw RuntimeException rather than checked exception

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10053: [FLINK-14578][table] load/unloadModule() should throw RuntimeException rather than checked exception URL: https://github.com/apache/flink/pull/10053#issuecomment-548157512 ## CI report: * 64e1df1cf04686053e67d20573f76bdf60e5 : SUCCES

[GitHub] [flink] flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#issuecomment-548157564 ## CI report: * d17fd17d0eff661875109372c6c02ed19d7deba8 : SUCCESS [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#issuecomment-548157564 ## CI report: * d17fd17d0eff661875109372c6c02ed19d7deba8 : PENDING [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10053: [FLINK-14578][table] load/unloadModule() should throw RuntimeException rather than checked exception

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10053: [FLINK-14578][table] load/unloadModule() should throw RuntimeException rather than checked exception URL: https://github.com/apache/flink/pull/10053#issuecomment-548157512 ## CI report: * 64e1df1cf04686053e67d20573f76bdf60e5 : PENDIN

[jira] [Created] (FLINK-14579) enable SQL CLI to configure modules via yaml config

2019-10-30 Thread Bowen Li (Jira)
Bowen Li created FLINK-14579: Summary: enable SQL CLI to configure modules via yaml config Key: FLINK-14579 URL: https://issues.apache.org/jira/browse/FLINK-14579 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-14580) add HiveModuleFactory, HiveModuleDescriptor, and HiveModuleValidator

2019-10-30 Thread Bowen Li (Jira)
Bowen Li created FLINK-14580: Summary: add HiveModuleFactory, HiveModuleDescriptor, and HiveModuleValidator Key: FLINK-14580 URL: https://issues.apache.org/jira/browse/FLINK-14580 Project: Flink

[jira] [Updated] (FLINK-14419) Add ModuleFactory, ModuleDescriptor, ModuleValidator for factory discovery service

2019-10-30 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14419: - Summary: Add ModuleFactory, ModuleDescriptor, ModuleValidator for factory discovery service (was: Add y

[GitHub] [flink] flinkbot commented on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-30 Thread GitBox
flinkbot commented on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#issuecomment-548157564 ## CI report: * d17fd17d0eff661875109372c6c02ed19d7deba8 : UNKNOWN Bot commands

[GitHub] [flink] flinkbot commented on issue #10053: [FLINK-14578][table] load/unloadModule() should throw RuntimeException rather than checked exception

2019-10-30 Thread GitBox
flinkbot commented on issue #10053: [FLINK-14578][table] load/unloadModule() should throw RuntimeException rather than checked exception URL: https://github.com/apache/flink/pull/10053#issuecomment-548157512 ## CI report: * 64e1df1cf04686053e67d20573f76bdf60e5 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-30 Thread GitBox
flinkbot commented on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#issuecomment-548152994 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commun

  1   2   3   4   5   6   7   >