[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564842#comment-16564842 ] ASF GitHub Bot commented on FLINK-10005: kl0u commented on issue #6466: [FLINK-1

[GitHub] kl0u commented on issue #6466: [FLINK-10005][DataStream API] StreamingFileSink: sets initialPartCounter=maxUsed in new Buckets

2018-07-31 Thread GitBox
kl0u commented on issue #6466: [FLINK-10005][DataStream API] StreamingFileSink: sets initialPartCounter=maxUsed in new Buckets URL: https://github.com/apache/flink/pull/6466#issuecomment-409468865 Because this will close the previous AND open a new part file, meaning all buckets, active an

[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564836#comment-16564836 ] ASF GitHub Bot commented on FLINK-10005: zentol commented on issue #6466: [FLINK

[GitHub] zentol commented on issue #6466: [FLINK-10005][DataStream API] StreamingFileSink: sets initialPartCounter=maxUsed in new Buckets

2018-07-31 Thread GitBox
zentol commented on issue #6466: [FLINK-10005][DataStream API] StreamingFileSink: sets initialPartCounter=maxUsed in new Buckets URL: https://github.com/apache/flink/pull/6466#issuecomment-409468434 no. instead of ``` if (info != null && rollingPolicy.shouldRollOnProcessingTim

[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564834#comment-16564834 ] ASF GitHub Bot commented on FLINK-10005: kl0u commented on issue #6466: [FLINK-1

[GitHub] kl0u commented on issue #6466: [FLINK-10005][DataStream API] StreamingFileSink: sets initialPartCounter=maxUsed in new Buckets

2018-07-31 Thread GitBox
kl0u commented on issue #6466: [FLINK-10005][DataStream API] StreamingFileSink: sets initialPartCounter=maxUsed in new Buckets URL: https://github.com/apache/flink/pull/6466#issuecomment-409468035 You mean without checking what the `rollingPolicy` says?

[jira] [Commented] (FLINK-9979) Support a custom FlinkKafkaPartitioner for a Kafka table sink factory

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564819#comment-16564819 ] ASF GitHub Bot commented on FLINK-9979: --- tzulitai commented on a change in pull req

[jira] [Commented] (FLINK-9979) Support a custom FlinkKafkaPartitioner for a Kafka table sink factory

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564820#comment-16564820 ] ASF GitHub Bot commented on FLINK-9979: --- tzulitai commented on a change in pull req

[jira] [Commented] (FLINK-9979) Support a custom FlinkKafkaPartitioner for a Kafka table sink factory

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564817#comment-16564817 ] ASF GitHub Bot commented on FLINK-9979: --- tzulitai commented on a change in pull req

[jira] [Commented] (FLINK-9979) Support a custom FlinkKafkaPartitioner for a Kafka table sink factory

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564815#comment-16564815 ] ASF GitHub Bot commented on FLINK-9979: --- tzulitai commented on a change in pull req

[jira] [Commented] (FLINK-9979) Support a custom FlinkKafkaPartitioner for a Kafka table sink factory

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564816#comment-16564816 ] ASF GitHub Bot commented on FLINK-9979: --- tzulitai commented on a change in pull req

[jira] [Commented] (FLINK-9979) Support a custom FlinkKafkaPartitioner for a Kafka table sink factory

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564821#comment-16564821 ] ASF GitHub Bot commented on FLINK-9979: --- tzulitai commented on a change in pull req

[jira] [Commented] (FLINK-9979) Support a custom FlinkKafkaPartitioner for a Kafka table sink factory

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564818#comment-16564818 ] ASF GitHub Bot commented on FLINK-9979: --- tzulitai commented on a change in pull req

[GitHub] tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory URL: https://github.com/apache/flink/pull/6440#discussion_r206767191 ## File path: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/a

[GitHub] tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory URL: https://github.com/apache/flink/pull/6440#discussion_r206767543 ## File path: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/ap

[GitHub] tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory URL: https://github.com/apache/flink/pull/6440#discussion_r206768231 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/a

[GitHub] tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory URL: https://github.com/apache/flink/pull/6440#discussion_r206470040 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/a

[GitHub] tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory URL: https://github.com/apache/flink/pull/6440#discussion_r206767510 ## File path: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/ap

[GitHub] tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory URL: https://github.com/apache/flink/pull/6440#discussion_r206468958 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/a

[GitHub] tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6440: [FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory URL: https://github.com/apache/flink/pull/6440#discussion_r206466943 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/a

[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564801#comment-16564801 ] ASF GitHub Bot commented on FLINK-10005: kl0u opened a new pull request #6466: [

[GitHub] kl0u opened a new pull request #6466: [FLINK-10005][DataStream API] StreamingFileSink: sets initialPartCounter=maxUsed in new Buckets

2018-07-31 Thread GitBox
kl0u opened a new pull request #6466: [FLINK-10005][DataStream API] StreamingFileSink: sets initialPartCounter=maxUsed in new Buckets URL: https://github.com/apache/flink/pull/6466 ## What is the purpose of the change In the `StreamingFileSink` whenever a new bucket is created, we pr

[jira] [Updated] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10005: --- Labels: pull-request-available (was: ) > StreamingFileSink ignores checkpoint/processing ti

[GitHub] tzulitai commented on issue #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x

2018-07-31 Thread GitBox
tzulitai commented on issue #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x URL: https://github.com/apache/flink/pull/6391#issuecomment-409463372 @twalthr I've addressed your latest comments. Could you have another pass? -

[jira] [Commented] (FLINK-9885) End-to-end test: Elasticsearch 6.x connector

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564794#comment-16564794 ] ASF GitHub Bot commented on FLINK-9885: --- tzulitai commented on issue #6391: [FLINK-

[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564784#comment-16564784 ] Kostas Kloudas commented on FLINK-10005: Nevermind, I found it and opened a PR.

[jira] [Assigned] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-10005: -- Assignee: Kostas Kloudas (was: Chesnay Schepler) > StreamingFileSink ignores checkpo

[jira] [Commented] (FLINK-9885) End-to-end test: Elasticsearch 6.x connector

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564773#comment-16564773 ] ASF GitHub Bot commented on FLINK-9885: --- tzulitai commented on a change in pull req

[GitHub] tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x URL: https://github.com/apache/flink/pull/6391#discussion_r206761263 ## File path: docs/dev/connectors/elasticsearch.md ## @@ -198,10 +198,6 @@ List httpHost = new Ar

[jira] [Commented] (FLINK-9885) End-to-end test: Elasticsearch 6.x connector

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564768#comment-16564768 ] ASF GitHub Bot commented on FLINK-9885: --- tzulitai commented on a change in pull req

[GitHub] tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x URL: https://github.com/apache/flink/pull/6391#discussion_r206760736 ## File path: flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/con

[jira] [Commented] (FLINK-9885) End-to-end test: Elasticsearch 6.x connector

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564765#comment-16564765 ] ASF GitHub Bot commented on FLINK-9885: --- tzulitai commented on a change in pull req

[GitHub] tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x

2018-07-31 Thread GitBox
tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x URL: https://github.com/apache/flink/pull/6391#discussion_r206760543 ## File path: flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/con

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564761#comment-16564761 ] ASF GitHub Bot commented on FLINK-7205: --- buptljy commented on a change in pull requ

[GitHub] buptljy commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-07-31 Thread GitBox
buptljy commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r206759487 ## File path: docs/dev/table/tableApi.md ## @@ -2311,6 +2311,17 @@ randInteger(seed integer

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-07-31 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564753#comment-16564753 ] Zhenqiu Huang commented on FLINK-7243: -- [~najman] I am adding some ITTest tonight. W

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564742#comment-16564742 ] ASF GitHub Bot commented on FLINK-7205: --- yanghua commented on a change in pull requ

[GitHub] yanghua commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-07-31 Thread GitBox
yanghua commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r206756114 ## File path: docs/dev/table/tableApi.md ## @@ -2311,6 +2311,17 @@ randInteger(seed integer

[jira] [Comment Edited] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564741#comment-16564741 ] Kostas Kloudas edited comment on FLINK-10005 at 8/1/18 5:03 AM: --

[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564741#comment-16564741 ] Kostas Kloudas commented on FLINK-10005: Is it that the `RollingPolicyTest.testR

[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

2018-07-31 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564738#comment-16564738 ] Kostas Kloudas commented on FLINK-10005: [~Zentol] Do you have an example of tha

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564735#comment-16564735 ] ASF GitHub Bot commented on FLINK-7205: --- buptljy commented on issue #6381: [FLINK-7

[GitHub] buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-07-31 Thread GitBox
buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#issuecomment-409449274 @yanghua fix. This is an automated message from the Apache Gi

[jira] [Commented] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564727#comment-16564727 ] ASF GitHub Bot commented on FLINK-10008: Xpray opened a new pull request #6465:

[jira] [Updated] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10008: --- Labels: pull-request-available (was: ) > Improve the LOG function in Table to support bases

[GitHub] Xpray opened a new pull request #6465: [FLINK-10008][TableAPI & SQL]Improve the LOG function in Table to support bases less than 1

2018-07-31 Thread GitBox
Xpray opened a new pull request #6465: [FLINK-10008][TableAPI & SQL]Improve the LOG function in Table to support bases less than 1 URL: https://github.com/apache/flink/pull/6465 ## What is the purpose of the change Improve the LOG function in Table to support bases less than 1

[jira] [Created] (FLINK-10012) Support setStreamTimeCharacteristic for Python API

2018-07-31 Thread vinoyang (JIRA)
vinoyang created FLINK-10012: Summary: Support setStreamTimeCharacteristic for Python API Key: FLINK-10012 URL: https://issues.apache.org/jira/browse/FLINK-10012 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564659#comment-16564659 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on a change in pull requ

[GitHub] yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-07-31 Thread GitBox
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r206741741 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/Func

[jira] [Commented] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564626#comment-16564626 ] ASF GitHub Bot commented on FLINK-1: Clark commented on issue #6463: [FL

[GitHub] Clarkkkkk commented on issue #6463: [FLINK-10000][streaming]Fix the example of CoGroupedStreams

2018-07-31 Thread GitBox
Clark commented on issue #6463: [FLINK-1][streaming]Fix the example of CoGroupedStreams URL: https://github.com/apache/flink/pull/6463#issuecomment-409424518 It's just kind of misleading, I was tried to correlate the keyselector with the input stream, which didn't mean two selector

[jira] [Assigned] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

2018-07-31 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li reassigned FLINK-10008: -- Assignee: Ruidong Li > Improve the LOG function in Table to support bases less than 1 > -

[jira] [Assigned] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

2018-07-31 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li reassigned FLINK-10009: -- Assignee: Ruidong Li > Fix the casting problem for function TIMESTAMPADD in Table > -

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

2018-07-31 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564573#comment-16564573 ] Elias Levy commented on FLINK-10011: [~trohrm...@apache.org] what do you think? > O

[jira] [Comment Edited] (FLINK-10011) Old job resurrected during HA failover

2018-07-31 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564569#comment-16564569 ] Elias Levy edited comment on FLINK-10011 at 8/1/18 12:48 AM: -

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

2018-07-31 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564569#comment-16564569 ] Elias Levy commented on FLINK-10011: It appears that it may not be necessary to repl

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564503#comment-16564503 ] ASF GitHub Bot commented on FLINK-9970: --- suez1224 commented on a change in pull req

[GitHub] suez1224 commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-07-31 Thread GitBox
suez1224 commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r206716042 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/Fun

[jira] [Created] (FLINK-10011) Old job resurrected during HA failover

2018-07-31 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10011: -- Summary: Old job resurrected during HA failover Key: FLINK-10011 URL: https://issues.apache.org/jira/browse/FLINK-10011 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-07-31 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564337#comment-16564337 ] Bowen Li commented on FLINK-9962: - [~fhueske] Sounds good Besides, after reading code, i

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564307#comment-16564307 ] ASF GitHub Bot commented on FLINK-9936: --- GJL opened a new pull request #6464: [FLIN

[GitHub] GJL opened a new pull request #6464: [FLINK-9936][mesos] WIP

2018-07-31 Thread GitBox
GJL opened a new pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464 WIP cc: @tillrohrmann This is an automated message from the Apache Git Service. To respond to the message

[jira] [Commented] (FLINK-9833) End-to-end test: SQL Client with unified source/sink/format

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564150#comment-16564150 ] ASF GitHub Bot commented on FLINK-9833: --- zentol commented on a change in pull reque

[GitHub] zentol commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format

2018-07-31 Thread GitBox
zentol commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format URL: https://github.com/apache/flink/pull/6422#discussion_r206637758 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client.sh

[jira] [Closed] (FLINK-9986) Remove unnecessary information from .version.properties file

2018-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9986. --- Resolution: Fixed Fix Version/s: 1.5.3 master: 6b262cb32abd6f44dd6554ba0a413f4d82c9fa1

[GitHub] zentol closed pull request #6443: [FLINK-9986][build] Only include commit info in .version.properties file

2018-07-31 Thread GitBox
zentol closed pull request #6443: [FLINK-9986][build] Only include commit info in .version.properties file URL: https://github.com/apache/flink/pull/6443 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of prove

[jira] [Commented] (FLINK-9986) Remove unnecessary information from .version.properties file

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16564122#comment-16564122 ] ASF GitHub Bot commented on FLINK-9986: --- zentol closed pull request #6443: [FLINK-

[jira] [Created] (FLINK-10010) Deprecate unused BaseAlignedWindowAssigner related components

2018-07-31 Thread Rong Rong (JIRA)
Rong Rong created FLINK-10010: - Summary: Deprecate unused BaseAlignedWindowAssigner related components Key: FLINK-10010 URL: https://issues.apache.org/jira/browse/FLINK-10010 Project: Flink Issu

[jira] [Commented] (FLINK-9905) ClassCastException: org.apache.flink.streaming.runtime.streamrecord.LatencyMarker

2018-07-31 Thread Gregory Fee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563901#comment-16563901 ] Gregory Fee commented on FLINK-9905: Thanks, Aljoscha! Yes, since I moved around the

[jira] [Updated] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

2018-07-31 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-10008: Description: Currently, the {{LOG}} function in SQL/Table API restricts the base to be greater tha

[jira] [Created] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

2018-07-31 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10009: --- Summary: Fix the casting problem for function TIMESTAMPADD in Table Key: FLINK-10009 URL: https://issues.apache.org/jira/browse/FLINK-10009 Project: Flink Issu

[jira] [Created] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

2018-07-31 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10008: --- Summary: Improve the LOG function in Table to support bases less than 1 Key: FLINK-10008 URL: https://issues.apache.org/jira/browse/FLINK-10008 Project: Flink

[jira] [Comment Edited] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

2018-07-31 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563827#comment-16563827 ] Hequn Cheng edited comment on FLINK-1 at 7/31/18 3:21 PM:

[jira] [Commented] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

2018-07-31 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563827#comment-16563827 ] Hequn Cheng commented on FLINK-1: - Coool, 1. Thanks for [~dangdangdang].

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563825#comment-16563825 ] ASF GitHub Bot commented on FLINK-7205: --- yanghua commented on issue #6381: [FLINK-7

[GitHub] yanghua commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-07-31 Thread GitBox
yanghua commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#issuecomment-409259529 @buptljy conflicts, please update and rebase this PR~ This is

[jira] [Commented] (FLINK-9664) FlinkML Quickstart Loading Data section example doesn't work as described

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563816#comment-16563816 ] ASF GitHub Bot commented on FLINK-9664: --- yanghua commented on issue #6425: [FLINK-9

[GitHub] yanghua commented on issue #6425: [FLINK-9664][Doc] fixing documentation in ML quick start

2018-07-31 Thread GitBox
yanghua commented on issue #6425: [FLINK-9664][Doc] fixing documentation in ML quick start URL: https://github.com/apache/flink/pull/6425#issuecomment-409258317 +1 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-9975) Netty dependency of Hadoop >= 2.7 is not relocated

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563811#comment-16563811 ] ASF GitHub Bot commented on FLINK-9975: --- yanghua commented on issue #6461: [FLINK-9

[GitHub] yanghua commented on issue #6461: [FLINK-9975][hadoop] also shade Hadoop's io.netty dependency

2018-07-31 Thread GitBox
yanghua commented on issue #6461: [FLINK-9975][hadoop] also shade Hadoop's io.netty dependency URL: https://github.com/apache/flink/pull/6461#issuecomment-409256918 +1 This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-31 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563807#comment-16563807 ] Fabian Hueske commented on FLINK-5315: -- Good points! I agree. Let's go with {code}

[GitHub] xccui commented on issue #6003: [FLINK-9289][Dataset] Parallelism of generated operators should have max parallelism of input

2018-07-31 Thread GitBox
xccui commented on issue #6003: [FLINK-9289][Dataset] Parallelism of generated operators should have max parallelism of input URL: https://github.com/apache/flink/pull/6003#issuecomment-409256314 Hi @fhueske, I wonder if you could take a look at this PR when it's convenient for you. Thanks

[jira] [Commented] (FLINK-9289) Parallelism of generated operators should have max parallism of input

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563806#comment-16563806 ] ASF GitHub Bot commented on FLINK-9289: --- xccui commented on issue #6003: [FLINK-928

[jira] [Assigned] (FLINK-9948) JSON format does not convert timestamps correctly

2018-07-31 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9948: - Assignee: (was: Renjie Liu) > JSON format does not convert timestamps correctly > --

[jira] [Assigned] (FLINK-9948) JSON format does not convert timestamps correctly

2018-07-31 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9948: - Assignee: Renjie Liu > JSON format does not convert timestamps correctly > -

[jira] [Assigned] (FLINK-9740) Support group windows over intervals of months

2018-07-31 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9740: - Assignee: Renjie Liu > Support group windows over intervals of months > ---

[jira] [Assigned] (FLINK-8865) Add CLI query code completion in SQL Client

2018-07-31 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8865: - Assignee: (was: Renjie Liu) > Add CLI query code completion in SQL Client >

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-31 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563766#comment-16563766 ] Rong Rong commented on FLINK-5315: -- Actually I agree with [~hequn8128] that these are tw

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-31 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563758#comment-16563758 ] Hequn Cheng commented on FLINK-5315: Hi [~fhueske] hmm, I think these are two kinds o

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563752#comment-16563752 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563751#comment-16563751 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563749#comment-16563749 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563753#comment-16563753 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563748#comment-16563748 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull requ

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

2018-07-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563750#comment-16563750 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull requ

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

2018-07-31 Thread GitBox
fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206546769 ## File path: docs/dev/table/sourceSinks.md ## @@ -1,5 +1,5 @@ --- -title: "Table Sou

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

2018-07-31 Thread GitBox
fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206536297 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect to

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

2018-07-31 Thread GitBox
fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206546032 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect to

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

2018-07-31 Thread GitBox
fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206535155 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect to

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

2018-07-31 Thread GitBox
fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206534039 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect to

  1   2   3   4   >