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

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

[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=16963661#comment-16963661 ] Hequn Cheng commented on FLINK-14547: - Fixed in 1.9.2 via 4368f1da8598f993523dd18edef4b90f88eab4a1

[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

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

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

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

[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

[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 #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: *

[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=16963630#comment-16963630 ] zhijiang commented on FLINK-14536: -- For the chained operators, the final aggregated cpu resource chose

[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

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

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

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

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

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

[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=16963605#comment-16963605 ] Jark Wu commented on FLINK-14535: - Fixed in 1.9.2: 640b11ee9454e8d210c0185a3b0001f063ac8649 1.10.0:

[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

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

[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=16963600#comment-16963600 ] Jingsong Lee edited comment on FLINK-13702 at 10/31/19 3:25 AM: Thanks

[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=16963600#comment-16963600 ] Jingsong Lee commented on FLINK-13702: -- Thanks [~jark] 's input. It's true that there are multiple

[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=16963598#comment-16963598 ] hehuiyuan commented on FLINK-14550: --- Hi,[~jark] ,  # Flink version 1.8.1 # use 

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

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

[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

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

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

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

[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

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

[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

[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

[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

[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

[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

[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

[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

[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

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

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

[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=16962953#comment-16962953 ] Jark Wu edited comment on FLINK-13702 at 10/31/19 2:05 AM: --- Hi [~dwysakowicz],

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

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

[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

[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=16963560#comment-16963560 ] Congxian Qiu(klion26) commented on FLINK-13969: --- Hi, [~trohrmann], from the log I think

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

[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=16963549#comment-16963549 ] fa zheng commented on FLINK-14560: -- [~trohrmann], sure, i want to have a try. > The value of

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

[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

[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

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

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

[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

[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

[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

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

2019-10-30 Thread GitBox
bowenli86 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-548152941 @dawidwys @xuefuz @lirui-apache @zjuwangg

[GitHub] [flink] bowenli86 opened a new pull request #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-30 Thread GitBox
bowenli86 opened a new pull request #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054 ## What is the purpose of the change Support dropping temp functions in FunctionCatalog. ## Brief

[jira] [Updated] (FLINK-14221) support drop temp system functions and temp catalog functions

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

[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-548151743 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] bowenli86 opened a new pull request #10053: [FLINK-14578][table] load/unloadModule() should throw RuntimeException rather than checked exception

2019-10-30 Thread GitBox
bowenli86 opened a new pull request #10053: [FLINK-14578][table] load/unloadModule() should throw RuntimeException rather than checked exception URL: https://github.com/apache/flink/pull/10053 #9808 What is the purpose of the change To adhere to FLIP to make load/unloadModule() API

[jira] [Updated] (FLINK-14578) load/unloadModule() should throw RuntimeException rather than checked exception

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

[GitHub] [flink] bowenli86 edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

2019-10-30 Thread GitBox
bowenli86 edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-548000546 @JingsongLi Thanks a lot for the PR! I wonder if exposing catalog

[jira] [Created] (FLINK-14578) load/unloadModule() should throw RuntimeException rather than checked exception

2019-10-30 Thread Bowen Li (Jira)
Bowen Li created FLINK-14578: Summary: load/unloadModule() should throw RuntimeException rather than checked exception Key: FLINK-14578 URL: https://issues.apache.org/jira/browse/FLINK-14578 Project:

[jira] [Closed] (FLINK-14219) support ambiguous function reference

2019-10-30 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14219. Release Note: support ambiguous function reference in Flink SQL Resolution: Fixed master:

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

2019-10-30 Thread Nikita Ryanov (Jira)
Nikita Ryanov created FLINK-14577: - Summary: Hortonworks schema registry support for avro deserialization Key: FLINK-14577 URL: https://issues.apache.org/jira/browse/FLINK-14577 Project: Flink

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

2019-10-30 Thread Nikita Ryanov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikita Ryanov updated FLINK-14577: -- Priority: Minor (was: Major) > Hortonworks schema registry support for avro deserialization

[GitHub] [flink] asfgit closed pull request #10052: [FLINK-14219][table] support ambiguous function reference

2019-10-30 Thread GitBox
asfgit closed pull request #10052: [FLINK-14219][table] support ambiguous function reference URL: https://github.com/apache/flink/pull/10052 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] bowenli86 commented on issue #10052: [FLINK-14219][table] support ambiguous function reference

2019-10-30 Thread GitBox
bowenli86 commented on issue #10052: [FLINK-14219][table] support ambiguous function reference URL: https://github.com/apache/flink/pull/10052#issuecomment-548146370 @xuefuz thanks for your review! Merging This is an

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

2019-10-30 Thread GitBox
bowenli86 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_r340846801 ## File path:

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

2019-10-30 Thread GitBox
bowenli86 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_r340846801 ## File path:

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

2019-10-30 Thread GitBox
kl0u commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-548105070 @TisonKun thanks for integrating the comments, I will have a look tomorrow first thing in the morning.

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

2019-10-30 Thread GitBox
bowenli86 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_r340847504 ## File path:

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

2019-10-30 Thread GitBox
bowenli86 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_r340846801 ## File path:

[GitHub] [flink] bowenli86 commented on issue #10052: [FLINK-14219][table] support ambiguous function reference

2019-10-30 Thread GitBox
bowenli86 commented on issue #10052: [FLINK-14219][table] support ambiguous function reference URL: https://github.com/apache/flink/pull/10052#issuecomment-54810 @xuefuz @lirui-apache @zjuwangg This is an automated

[GitHub] [flink] ChengzhiZhao edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

2019-10-30 Thread GitBox
ChengzhiZhao edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-548095242 @kl0u, In your comment `add a connector parameter`, do you mean add an additional parameter, for

[GitHub] [flink] ChengzhiZhao commented on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

2019-10-30 Thread GitBox
ChengzhiZhao commented on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-548095242 @kl0u, In your comment `add a connector parameter`, do you mean add an additional parameter, for example

[jira] [Closed] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph

2019-10-30 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-12526. Resolution: Fixed 1.10: ffe3a61a7ed2aa856288ecd293550bdead70119d > Remove STATE_UPDATER in

[jira] [Updated] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph

2019-10-30 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-12526: - Fix Version/s: 1.10.0 > Remove STATE_UPDATER in ExecutionGraph > --

  1   2   3   4   5   6   7   >