[GitHub] [flink] flinkbot edited a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906#issuecomment-519474213 ## CI report: * bea9f0b86c27d30c763e8578edc5ef46a7d76e9e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows URL: https://github.com/apache/flink/pull/9349#issuecomment-517912973 ## CI report: *

[GitHub] [flink] lirui-apache commented on a change in pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data…

2019-08-08 Thread GitBox
lirui-apache commented on a change in pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data… URL: https://github.com/apache/flink/pull/9399#discussion_r312335044 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors URL: https://github.com/apache/flink/pull/9342#issuecomment-517770642 ## CI report: * 76704f271662b57cbe36679d3d249bcdd7fdf66a : FAILURE

[jira] [Commented] (FLINK-6962) Add a create table SQL DDL

2019-08-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903577#comment-16903577 ] Jark Wu commented on FLINK-6962: Yes [~twalthr], I just created an issue to track this effort:

[jira] [Created] (FLINK-13661) Add a stream specific CREATE TABLE SQL DDL

2019-08-08 Thread Jark Wu (JIRA)
Jark Wu created FLINK-13661: --- Summary: Add a stream specific CREATE TABLE SQL DDL Key: FLINK-13661 URL: https://issues.apache.org/jira/browse/FLINK-13661 Project: Flink Issue Type: Sub-task

[GitHub] [flink] TsReaper commented on a change in pull request #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors

2019-08-08 Thread GitBox
TsReaper commented on a change in pull request #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors URL: https://github.com/apache/flink/pull/9342#discussion_r312330806 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518265997 ## CI report: * 1fe6c332279c34546ec3db24a574dfd53500d20b : SUCCESS

[GitHub] [flink] bowenli86 commented on a change in pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data…

2019-08-08 Thread GitBox
bowenli86 commented on a change in pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data… URL: https://github.com/apache/flink/pull/9399#discussion_r312327916 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data…

2019-08-08 Thread GitBox
bowenli86 commented on a change in pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data… URL: https://github.com/apache/flink/pull/9399#discussion_r312327896 ## File path:

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

2019-08-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903554#comment-16903554 ] Jark Wu commented on FLINK-13405: - Did you send email to dev-subsr...@flink.apache.org to subscribe this

[GitHub] [flink] flinkbot commented on issue #9400: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner (release-1.9)

2019-08-08 Thread GitBox
flinkbot commented on issue #9400: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner (release-1.9) URL: https://github.com/apache/flink/pull/9400#issuecomment-519772402 ## CI report: * 2fef590f19082d27f35d60a1dc87e802f673d777 :

[GitHub] [flink] flinkbot commented on issue #9400: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner (release-1.9)

2019-08-08 Thread GitBox
flinkbot commented on issue #9400: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner (release-1.9) URL: https://github.com/apache/flink/pull/9400#issuecomment-519771498 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] wuchong opened a new pull request #9400: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner (release-1.9)

2019-08-08 Thread GitBox
wuchong opened a new pull request #9400: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner (release-1.9) URL: https://github.com/apache/flink/pull/9400 This is a cherry pick from master to run travis.

[GitHub] [flink] flinkbot edited a comment on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9394#issuecomment-519467299 ## CI report: * 861d120d83964d267c95d024993b82186b1e6e7a : FAILURE

[jira] [Updated] (FLINK-13473) Add GroupWindowed FlatAggregate support to stream Table API(blink planner), i.e, align with flink planner

2019-08-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13473: Component/s: (was: Table SQL / API) Table SQL / Planner > Add GroupWindowed

[GitHub] [flink] wuchong commented on issue #9396: [FLINK-13473][table] Add stream Windowed FlatAggregate support for blink planner

2019-08-08 Thread GitBox
wuchong commented on issue #9396: [FLINK-13473][table] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519769654 I would suggest to modify the component name in commit message a bit. How about:

[jira] [Commented] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-08-08 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903548#comment-16903548 ] Biao Liu commented on FLINK-12481: -- Hi [~1u0], thanks for feedback. :) > Make processing time timer

[GitHub] [flink] flinkbot commented on issue #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data…

2019-08-08 Thread GitBox
flinkbot commented on issue #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data… URL: https://github.com/apache/flink/pull/9399#issuecomment-519768509 ## CI report: * 3fbe05bd67589e1f46d05df3e6db7cc79281b450 : PENDING

[GitHub] [flink] wuchong commented on a change in pull request #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows

2019-08-08 Thread GitBox
wuchong commented on a change in pull request #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows URL: https://github.com/apache/flink/pull/9349#discussion_r312321622 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column

2019-08-08 Thread GitBox
lirui-apache commented on a change in pull request #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column URL: https://github.com/apache/flink/pull/9390#discussion_r312321615 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9347: [FLINK-13563] [table-planner-blink] TumblingGroupWindow should implement toString method to explain more info

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9347: [FLINK-13563] [table-planner-blink] TumblingGroupWindow should implement toString method to explain more info URL: https://github.com/apache/flink/pull/9347#issuecomment-517895998 ## CI report: * 212cd6c24fdb696aa13bed1cfff875f9bfc01d09 :

[GitHub] [flink] wuchong commented on a change in pull request #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner

2019-08-08 Thread GitBox
wuchong commented on a change in pull request #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9394#discussion_r312319794 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner

2019-08-08 Thread GitBox
wuchong commented on a change in pull request #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9394#discussion_r312318835 ## File path:

[GitHub] [flink] lirui-apache commented on issue #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data…

2019-08-08 Thread GitBox
lirui-apache commented on issue #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data… URL: https://github.com/apache/flink/pull/9399#issuecomment-519767241 @xuefuz @bowenli86 @zjuwangg please have a look. I suppose it's trivial change.

[GitHub] [flink] flinkbot commented on issue #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data…

2019-08-08 Thread GitBox
flinkbot commented on issue #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data… URL: https://github.com/apache/flink/pull/9399#issuecomment-519767122 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Created] (FLINK-13660) Cannot submit job on Flink session cluster on kubernetes with multiple JM pods (zk HA) through web frontend

2019-08-08 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-13660: -- Summary: Cannot submit job on Flink session cluster on kubernetes with multiple JM pods (zk HA) through web frontend Key: FLINK-13660 URL:

[GitHub] [flink] lirui-apache opened a new pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data…

2019-08-08 Thread GitBox
lirui-apache opened a new pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data… URL: https://github.com/apache/flink/pull/9399 …base crashes sql-client ## What is the purpose of the change Avoid crashing sql-client when switching

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

2019-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13526: --- Labels: pull-request-available (was: ) > Switching to a non existing catalog or database

[GitHub] [flink] flinkbot edited a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906#issuecomment-519474213 ## CI report: * bea9f0b86c27d30c763e8578edc5ef46a7d76e9e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518265997 ## CI report: * 1fe6c332279c34546ec3db24a574dfd53500d20b : SUCCESS

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

2019-08-08 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13526: --- Summary: Switching to a non existing catalog or database crashes sql-client (was: Switching to a non

[GitHub] [flink] flinkbot edited a comment on issue #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows URL: https://github.com/apache/flink/pull/9349#issuecomment-517912973 ## CI report: *

[jira] [Created] (FLINK-13659) Add method listDatabases(catalog) and listTables(catalog, database) in TableEnvironment

2019-08-08 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13659: -- Summary: Add method listDatabases(catalog) and listTables(catalog, database) in TableEnvironment Key: FLINK-13659 URL: https://issues.apache.org/jira/browse/FLINK-13659

[jira] [Commented] (FLINK-13523) Verify and correct arithmetic function's semantic for Blink planner

2019-08-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903530#comment-16903530 ] Jark Wu commented on FLINK-13523: - [table-planner-blink] Refactor AVG aggregate function to keep it

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518265997 ## CI report: * 1fe6c332279c34546ec3db24a574dfd53500d20b : SUCCESS

[GitHub] [flink] wuchong commented on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner

2019-08-08 Thread GitBox
wuchong commented on issue #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9331#issuecomment-519762758 Merged with 4d560df50d08f22b68e8b8c9a0e2086f45b5f4b4

[GitHub] [flink] wuchong closed pull request #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner

2019-08-08 Thread GitBox
wuchong closed pull request #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9331 This is an automated message from the

[GitHub] [flink] godfreyhe commented on issue #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows

2019-08-08 Thread GitBox
godfreyhe commented on issue #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows URL: https://github.com/apache/flink/pull/9349#issuecomment-519762649 thanks @wuchong, i have updated

[jira] [Commented] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

2019-08-08 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903527#comment-16903527 ] Rui Li commented on FLINK-13653: I thought we should just use the new type system for

[GitHub] [flink] godfreyhe commented on a change in pull request #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows

2019-08-08 Thread GitBox
godfreyhe commented on a change in pull request #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows URL: https://github.com/apache/flink/pull/9349#discussion_r312316102 ## File path:

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

2019-08-08 Thread WangHengWei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903515#comment-16903515 ] WangHengWei commented on FLINK-13405: - [~jark] [~xccui], thank you very much. I think "数据汇" is a

[jira] [Updated] (FLINK-13655) Caused by: java.io.IOException: Thread 'SortMerger spilling thread' terminated due to an exception

2019-08-08 Thread LiJun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiJun updated FLINK-13655: -- Labels: KryoSerializer (was: ) > Caused by: java.io.IOException: Thread 'SortMerger spilling thread' >

[jira] [Updated] (FLINK-13655) Caused by: java.io.IOException: Thread 'SortMerger spilling thread' terminated due to an exception

2019-08-08 Thread LiJun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiJun updated FLINK-13655: -- Description: Symptom: flink program can sucessfully read and process single ORC file from HDFS,whatever

[jira] [Updated] (FLINK-13655) Caused by: java.io.IOException: Thread 'SortMerger spilling thread' terminated due to an exception

2019-08-08 Thread LiJun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiJun updated FLINK-13655: -- Description: Symptom: flink program can sucessfully read and process single ORC file from HDFS,whatever

[GitHub] [flink] flinkbot edited a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906#issuecomment-519474213 ## CI report: * bea9f0b86c27d30c763e8578edc5ef46a7d76e9e : FAILURE

[GitHub] [flink] wangpeibin713 removed a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

2019-08-08 Thread GitBox
wangpeibin713 removed a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906#issuecomment-519753292 @flinkbot restart travis-ci This is an

[GitHub] [flink] wangpeibin713 commented on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

2019-08-08 Thread GitBox
wangpeibin713 commented on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906#issuecomment-519753292 @flinkbot restart travis-ci This is an

[jira] [Commented] (FLINK-13510) Show fail attemp for subtask in timelime

2019-08-08 Thread lining (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903507#comment-16903507 ] lining commented on FLINK-13510: [~till.rohrmann], Now failover will cancle all tasks. After failover,

[GitHub] [flink] flinkbot edited a comment on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9394#issuecomment-519467299 ## CI report: * 861d120d83964d267c95d024993b82186b1e6e7a : FAILURE

[GitHub] [flink] wangpeibin713 opened a new pull request #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

2019-08-08 Thread GitBox
wangpeibin713 opened a new pull request #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906 ## What is the purpose of the change - The goal is to fix the findbugs warning in AggregationsFunctio.scala

[GitHub] [flink] wangpeibin713 closed pull request #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

2019-08-08 Thread GitBox
wangpeibin713 closed pull request #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on issue #9347: [FLINK-13563] [table-planner-blink] TumblingGroupWindow should implement toString method to explain more info

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9347: [FLINK-13563] [table-planner-blink] TumblingGroupWindow should implement toString method to explain more info URL: https://github.com/apache/flink/pull/9347#issuecomment-517895998 ## CI report: * 212cd6c24fdb696aa13bed1cfff875f9bfc01d09 :

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518519629 ## CI report: * db9e30b162a1f8f7958a3e1a5ff61214f205de1c : SUCCESS

[jira] [Commented] (FLINK-13340) Add more Kafka topic option of flink-connector-kafka

2019-08-08 Thread DuBin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903496#comment-16903496 ] DuBin commented on FLINK-13340: --- hi [~twalthr], can you please help review this PR? > Add more Kafka

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518265997 ## CI report: * 1fe6c332279c34546ec3db24a574dfd53500d20b : SUCCESS

[GitHub] [flink] godfreyhe commented on a change in pull request #9346: [FLINK-13562] [table-planner-blink] fix incorrect input type for local stream group aggregate in FlinkRelMdColumnInterval

2019-08-08 Thread GitBox
godfreyhe commented on a change in pull request #9346: [FLINK-13562] [table-planner-blink] fix incorrect input type for local stream group aggregate in FlinkRelMdColumnInterval URL: https://github.com/apache/flink/pull/9346#discussion_r312306197 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9346: [FLINK-13562] [table-planner-blink] fix incorrect input type for local stream group aggregate in FlinkRelMdColumnInterval

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9346: [FLINK-13562] [table-planner-blink] fix incorrect input type for local stream group aggregate in FlinkRelMdColumnInterval URL: https://github.com/apache/flink/pull/9346#issuecomment-517895087 Thanks a lot for your contribution to the Apache Flink

[GitHub] [flink] godfreyhe commented on issue #9347: [FLINK-13563] [table-planner-blink] TumblingGroupWindow should implement toString method to explain more info

2019-08-08 Thread GitBox
godfreyhe commented on issue #9347: [FLINK-13563] [table-planner-blink] TumblingGroupWindow should implement toString method to explain more info URL: https://github.com/apache/flink/pull/9347#issuecomment-519748929 thanks for reminding @wuchong. rebased

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518263446 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9389: [FLINK-13645][table-planner] Error in code-gen when using blink planner in scala shell

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9389: [FLINK-13645][table-planner] Error in code-gen when using blink planner in scala shell URL: https://github.com/apache/flink/pull/9389#issuecomment-519351757 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] zjffdu commented on issue #9389: [FLINK-13645][table-planner] Error in code-gen when using blink planner in scala shell

2019-08-08 Thread GitBox
zjffdu commented on issue #9389: [FLINK-13645][table-planner] Error in code-gen when using blink planner in scala shell URL: https://github.com/apache/flink/pull/9389#issuecomment-519747709 @wuchong Could you help take a look at it ? Thanks

[GitHub] [flink] flinkbot edited a comment on issue #9389: [FLINK-13645][table-planner] Error in code-gen when using blink planner in scala shell

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9389: [FLINK-13645][table-planner] Error in code-gen when using blink planner in scala shell URL: https://github.com/apache/flink/pull/9389#issuecomment-519351757 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] danny0405 commented on a change in pull request #9389: [FLINK-13645][table-planner] Error in code-gen when using blink planner in scala shell

2019-08-08 Thread GitBox
danny0405 commented on a change in pull request #9389: [FLINK-13645][table-planner] Error in code-gen when using blink planner in scala shell URL: https://github.com/apache/flink/pull/9389#discussion_r312304638 ## File path:

[jira] [Updated] (FLINK-13655) Caused by: java.io.IOException: Thread 'SortMerger spilling thread' terminated due to an exception

2019-08-08 Thread LiJun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiJun updated FLINK-13655: -- Description: Symptom: There are two files (about 600MB) with ORC format in HDFS.My flink program can read

[jira] [Commented] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903441#comment-16903441 ] Rong Rong commented on FLINK-13603: --- to answer your questions [~jacky.du0...@gmail.com], any critical

[jira] [Commented] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903440#comment-16903440 ] Rong Rong commented on FLINK-13603: --- Based on what I saw. FLINK-12848 is labeled as improvement so I

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518519629 ## CI report: * db9e30b162a1f8f7958a3e1a5ff61214f205de1c : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518518670 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Commented] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-08 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903432#comment-16903432 ] Yu Du commented on FLINK-13603: --- hi, [~walterddr] Thanks for reply . yes,  I did a local flink-core

[GitHub] [flink] flinkbot commented on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement

2019-08-08 Thread GitBox
flinkbot commented on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement URL: https://github.com/apache/flink/pull/9398#issuecomment-519727123 ## CI report: * 08e406e0565f2f945437c4baeebbf0a6c4489ff3 : PENDING

[jira] [Commented] (FLINK-13479) Cassandra POJO Sink - Prepared Statement query does not have deterministic ordering of columns - causing prepared statement cache overflow

2019-08-08 Thread Ronak Thakrar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903417#comment-16903417 ] Ronak Thakrar commented on FLINK-13479: --- [~aljoscha] - I have created the pull request - can you

[GitHub] [flink] flinkbot commented on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement

2019-08-08 Thread GitBox
flinkbot commented on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement URL: https://github.com/apache/flink/pull/9398#issuecomment-519726006 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-13479) Cassandra POJO Sink - Prepared Statement query does not have deterministic ordering of columns - causing prepared statement cache overflow

2019-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13479: --- Labels: pull-request-available (was: ) > Cassandra POJO Sink - Prepared Statement query

[GitHub] [flink] ronakthakrar opened a new pull request #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement

2019-08-08 Thread GitBox
ronakthakrar opened a new pull request #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement URL: https://github.com/apache/flink/pull/9398 ## What is the purpose of the change This pull request fixes the issue with Cassandra Connector

[jira] [Commented] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-08 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903404#comment-16903404 ] Rong Rong commented on FLINK-13603: --- Hi [~jacky.du0...@gmail.com]. I wouldn't think they are

[GitHub] [flink] flinkbot edited a comment on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one URL: https://github.com/apache/flink/pull/9397#issuecomment-519695998 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] winitzki commented on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one

2019-08-08 Thread GitBox
winitzki commented on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one URL: https://github.com/apache/flink/pull/9397#issuecomment-519711728 The CI error is `21:38:13.853 [ERROR] Failed to execute goal org.apache.rat:apache-rat-plugin:0.12:check (default) on

[GitHub] [flink] flinkbot commented on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one

2019-08-08 Thread GitBox
flinkbot commented on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one URL: https://github.com/apache/flink/pull/9397#issuecomment-519697931 ## CI report: * 8c5feb16a2c3814e378dcc67245c554dd0b67eaa : FAILURE

[GitHub] [flink] flinkbot commented on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one

2019-08-08 Thread GitBox
flinkbot commented on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one URL: https://github.com/apache/flink/pull/9397#issuecomment-519695998 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-13658) Combine two triggers into one (for streaming windows)

2019-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13658: --- Labels: pull-request-available (was: ) > Combine two triggers into one (for streaming

[GitHub] [flink] winitzki opened a new pull request #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one

2019-08-08 Thread GitBox
winitzki opened a new pull request #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one URL: https://github.com/apache/flink/pull/9397 This is a new feature: combine two triggers into one. A new case class `TriggerOf[T, W]` provides this functionality. Sample

[jira] [Created] (FLINK-13658) Combine two triggers into one (for streaming windows)

2019-08-08 Thread Sergei Winitzki (JIRA)
Sergei Winitzki created FLINK-13658: --- Summary: Combine two triggers into one (for streaming windows) Key: FLINK-13658 URL: https://issues.apache.org/jira/browse/FLINK-13658 Project: Flink

[jira] [Commented] (FLINK-13658) Combine two triggers into one (for streaming windows)

2019-08-08 Thread Sergei Winitzki (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903350#comment-16903350 ] Sergei Winitzki commented on FLINK-13658: - {code:java} package

[jira] [Commented] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

2019-08-08 Thread John Lonergan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903278#comment-16903278 ] John Lonergan commented on FLINK-13588: --- Don't agree. If there is context then the code should

[GitHub] [flink] flinkbot edited a comment on issue #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column URL: https://github.com/apache/flink/pull/9390#issuecomment-519354933 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] xuefuz commented on a change in pull request #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column

2019-08-08 Thread GitBox
xuefuz commented on a change in pull request #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column URL: https://github.com/apache/flink/pull/9390#discussion_r312205426 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518265997 ## CI report: * 1fe6c332279c34546ec3db24a574dfd53500d20b : SUCCESS

[jira] [Commented] (FLINK-13603) Flink Table ApI not working with nested Json schema starting From 1.6.x

2019-08-08 Thread Yu Du (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903220#comment-16903220 ] Yu Du commented on FLINK-13603: --- This issue should be the same one as 

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518519629 ## CI report: * db9e30b162a1f8f7958a3e1a5ff61214f205de1c : SUCCESS

[jira] [Commented] (FLINK-12847) Update Kinesis Connectors to latest Apache licensed libraries

2019-08-08 Thread Steven Nelson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903172#comment-16903172 ] Steven Nelson commented on FLINK-12847: --- It would be nice to have the 2.0 version pulled in so we

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518265997 ## CI report: * 1fe6c332279c34546ec3db24a574dfd53500d20b : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518263446 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9396: [FLINK-13473][table] Add stream Windowed FlatAggregate support for blink planner

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9396: [FLINK-13473][table] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519562054 ## CI report: * 9a5651f1dee8a7d5da17bc4e54831af55d7002c4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9395: [hotfix][streaming] Fix the wrong word used in the comments in class KeyedStream

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9395: [hotfix][streaming] Fix the wrong word used in the comments in class KeyedStream URL: https://github.com/apache/flink/pull/9395#issuecomment-519551891 ## CI report: * 6a5450aa95ebeae0a2c011d64f23ec60fd858485 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#issuecomment-499077475 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

2019-08-08 Thread GitBox
walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r312132803 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518519629 ## CI report: * db9e30b162a1f8f7958a3e1a5ff61214f205de1c : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

2019-08-08 Thread GitBox
flinkbot edited a comment on issue #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364#issuecomment-518518670 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Commented] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-08-08 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903104#comment-16903104 ] Alex commented on FLINK-12481: -- Hi [~SleePy], I've temporally closed the original PR of moving timers to

  1   2   3   4   5   >