[jira] [Assigned] (FLINK-10032) Flink SQL DATE_FORMAT Function throws Exception in SQL CLI

2018-08-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-10032: Assignee: Timo Walther > Flink SQL DATE_FORMAT Function throws Exception in SQL CLI >

[jira] [Commented] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567839#comment-16567839 ] Timo Walther commented on FLINK-10036: -- [~wind_ljy] FLINK-9964 will only provide

[jira] [Commented] (FLINK-10039) FlinkKafkaProducer - Serializer Error

2018-08-03 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567834#comment-16567834 ] buptljy commented on FLINK-10039: - I think only ByteArrayDeserializer is supported according to 

[jira] [Updated] (FLINK-10032) Flink SQL DATE_FORMAT Function throws Exception in SQL CLI

2018-08-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10032: - Description: As Follows, but it works in sql program, and input string is expected result.  

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207456451 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -894,17 +900,21 @@

[jira] [Updated] (FLINK-10032) Rework SQL DATE_FORMAT function

2018-08-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10032: - Description: As Follows, but it works in sql program, and input string is expected result.  

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207461474 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -894,17 +900,21 @@

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207461514 ## File path: flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java ## @@

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567875#comment-16567875 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567880#comment-16567880 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

[jira] [Commented] (FLINK-8478) Add support for time-bounded joins in DataStream API

2018-08-03 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567894#comment-16567894 ] David Anderson commented on FLINK-8478: --- Are FLINK-8479 and FLINK-8480 part of Flink 1.6? If so, it

[jira] [Created] (FLINK-10040) Decompose RocksDBKeyedStateBackend

2018-08-03 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10040: -- Summary: Decompose RocksDBKeyedStateBackend Key: FLINK-10040 URL: https://issues.apache.org/jira/browse/FLINK-10040 Project: Flink Issue Type:

[jira] [Created] (FLINK-10043) Refactor object construction/inititlization/restore code

2018-08-03 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10043: -- Summary: Refactor object construction/inititlization/restore code Key: FLINK-10043 URL: https://issues.apache.org/jira/browse/FLINK-10043 Project: Flink

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-08-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567972#comment-16567972 ] Till Rohrmann commented on FLINK-9920: -- Another instance:

[GitHub] suez1224 opened a new pull request #6484: [FLINK-9134][Table API & SQL] upgrade Calcite dependency to 1.17

2018-08-03 Thread GitBox
suez1224 opened a new pull request #6484: [FLINK-9134][Table API & SQL] upgrade Calcite dependency to 1.17 URL: https://github.com/apache/flink/pull/6484 ## What is the purpose of the change upgrade Calcite dependency to 1.17 ## Brief change log - incoporate calcite

[jira] [Commented] (FLINK-9969) Unreasonable memory requirements to complete examples/batch/WordCount

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567865#comment-16567865 ] ASF GitHub Bot commented on FLINK-9969: --- tillrohrmann commented on a change in pull request #6479:

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207463112 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -734,8

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567852#comment-16567852 ] ASF GitHub Bot commented on FLINK-9134: --- suez1224 opened a new pull request #6484:

[GitHub] tillrohrmann commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger

2018-08-03 Thread GitBox
tillrohrmann commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger URL: https://github.com/apache/flink/pull/6479#discussion_r207459523 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger

2018-08-03 Thread GitBox
tillrohrmann commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger URL: https://github.com/apache/flink/pull/6479#discussion_r207459350 ## File path:

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207461579 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -278,22

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567876#comment-16567876 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567874#comment-16567874 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207462105 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -734,8 +734,14 @@

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567873#comment-16567873 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

[GitHub] zentol commented on a change in pull request #6409: [FLINK-9899][Kinesis Connector] Add comprehensive per-shard metrics to ShardConsumer

2018-08-03 Thread GitBox
zentol commented on a change in pull request #6409: [FLINK-9899][Kinesis Connector] Add comprehensive per-shard metrics to ShardConsumer URL: https://github.com/apache/flink/pull/6409#discussion_r207484326 ## File path:

[jira] [Created] (FLINK-10046) .bat script to start a Flink service as a console application

2018-08-03 Thread Pavel Shvetsov (JIRA)
Pavel Shvetsov created FLINK-10046: -- Summary: .bat script to start a Flink service as a console application Key: FLINK-10046 URL: https://issues.apache.org/jira/browse/FLINK-10046 Project: Flink

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568002#comment-16568002 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull request #6464:

[jira] [Commented] (FLINK-9969) Unreasonable memory requirements to complete examples/batch/WordCount

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567861#comment-16567861 ] ASF GitHub Bot commented on FLINK-9969: --- tillrohrmann commented on a change in pull request #6479:

[jira] [Commented] (FLINK-9969) Unreasonable memory requirements to complete examples/batch/WordCount

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567862#comment-16567862 ] ASF GitHub Bot commented on FLINK-9969: --- tillrohrmann commented on a change in pull request #6479:

[GitHub] tillrohrmann commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger

2018-08-03 Thread GitBox
tillrohrmann commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger URL: https://github.com/apache/flink/pull/6479#discussion_r207459818 ## File path:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567897#comment-16567897 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull request #6464:

[GitHub] TisonKun commented on issue #6485: [hotfix] [test] Wait CompletableFuture complete

2018-08-03 Thread GitBox
TisonKun commented on issue #6485: [hotfix] [test] Wait CompletableFuture complete URL: https://github.com/apache/flink/pull/6485#issuecomment-410171708 cc @tillrohrmann @zentol This is an automated message from the Apache

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207463934 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -894,17

[GitHub] TisonKun opened a new pull request #6485: [hotfix] [test] Wait CompletableFuture complete

2018-08-03 Thread GitBox
TisonKun opened a new pull request #6485: [hotfix] [test] Wait CompletableFuture complete URL: https://github.com/apache/flink/pull/6485 ## What is the purpose of the change harden existing tests ## Brief change log wait CompletableFuture complete in JobMasterTest,

[jira] [Created] (FLINK-10044) Check proper RIA style and introduce it where missing

2018-08-03 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10044: -- Summary: Check proper RIA style and introduce it where missing Key: FLINK-10044 URL: https://issues.apache.org/jira/browse/FLINK-10044 Project: Flink

[jira] [Commented] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568009#comment-16568009 ] ASF GitHub Bot commented on FLINK-6846: --- asfgit closed pull request #6188: [FLINK-6846] [table] Add

[jira] [Updated] (FLINK-10047) Checkpointing takes much longer with credit base flow control.

2018-08-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10047: --- Description: As reported by an user, in some scenario it looks like checkpointing takes 

[jira] [Updated] (FLINK-10047) Checkpointing takes much longer with credit base flow control.

2018-08-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10047: --- Description: As reported by an user, in some scenario it looks like checkpointing takes 

[jira] [Updated] (FLINK-10032) Rework SQL DATE_FORMAT function

2018-08-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10032: - Summary: Rework SQL DATE_FORMAT function (was: Flink SQL DATE_FORMAT Function throws Exception

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567872#comment-16567872 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207461505 ## File path: flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java ## @@

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207461551 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -345,15

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207461541 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -345,15

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207461579 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -278,22

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567871#comment-16567871 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567889#comment-16567889 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull request #6464:

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207464729 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -391,13

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207464729 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -391,13

[jira] [Commented] (FLINK-9444) Add full SQL support for Avro formats

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567919#comment-16567919 ] ASF GitHub Bot commented on FLINK-9444: --- tragicjun commented on issue #6082: [FLINK-9444][table]

[GitHub] tragicjun commented on issue #6082: [FLINK-9444][table] KafkaAvroTableSource failed to work for map and array fields

2018-08-03 Thread GitBox
tragicjun commented on issue #6082: [FLINK-9444][table] KafkaAvroTableSource failed to work for map and array fields URL: https://github.com/apache/flink/pull/6082#issuecomment-410175862 @twalthr it solves my issue as well, good job!

[jira] [Created] (FLINK-10041) Extract all different iterators (inner or static inner classes) into full classes

2018-08-03 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10041: -- Summary: Extract all different iterators (inner or static inner classes) into full classes Key: FLINK-10041 URL: https://issues.apache.org/jira/browse/FLINK-10041

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567982#comment-16567982 ] ASF GitHub Bot commented on FLINK-9899: --- zentol commented on a change in pull request #6409:

[jira] [Commented] (FLINK-7812) Log system resources as metrics

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568073#comment-16568073 ] ASF GitHub Bot commented on FLINK-7812: --- pnowojski commented on a change in pull request #4801:

[GitHub] pnowojski commented on a change in pull request #4801: [FLINK-7812] Log system resources metrics

2018-08-03 Thread GitBox
pnowojski commented on a change in pull request #4801: [FLINK-7812] Log system resources metrics URL: https://github.com/apache/flink/pull/4801#discussion_r207506533 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/taskexecutor/SystemResourcesMetricsITCase.java

[GitHub] pnowojski commented on a change in pull request #4801: [FLINK-7812] Log system resources metrics

2018-08-03 Thread GitBox
pnowojski commented on a change in pull request #4801: [FLINK-7812] Log system resources metrics URL: https://github.com/apache/flink/pull/4801#discussion_r207506533 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/taskexecutor/SystemResourcesMetricsITCase.java

[GitHub] twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17

2018-08-03 Thread GitBox
twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17 URL: https://github.com/apache/flink/pull/6484#discussion_r207498310 ## File path:

[GitHub] twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17

2018-08-03 Thread GitBox
twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17 URL: https://github.com/apache/flink/pull/6484#discussion_r207506616 ## File path:

[GitHub] twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17

2018-08-03 Thread GitBox
twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17 URL: https://github.com/apache/flink/pull/6484#discussion_r207497521 ## File path:

[GitHub] twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17

2018-08-03 Thread GitBox
twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17 URL: https://github.com/apache/flink/pull/6484#discussion_r207497685 ## File path:

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568076#comment-16568076 ] ASF GitHub Bot commented on FLINK-9134: --- twalthr commented on a change in pull request #6484:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567850#comment-16567850 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

[jira] [Updated] (FLINK-9134) Update Calcite dependency to 1.17

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9134: -- Labels: pull-request-available (was: ) > Update Calcite dependency to 1.17 >

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567885#comment-16567885 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull request #6464:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567879#comment-16567879 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-03 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207462086 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567900#comment-16567900 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567899#comment-16567899 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

[jira] [Created] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

2018-08-03 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10042: -- Summary: Extract snapshot algorithms from inner classes into full classes Key: FLINK-10042 URL: https://issues.apache.org/jira/browse/FLINK-10042 Project: Flink

[jira] [Created] (FLINK-10045) .bat script to start/stop Flink daemon

2018-08-03 Thread Pavel Shvetsov (JIRA)
Pavel Shvetsov created FLINK-10045: -- Summary: .bat script to start/stop Flink daemon Key: FLINK-10045 URL: https://issues.apache.org/jira/browse/FLINK-10045 Project: Flink Issue Type:

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] Mesos resource manager unable to connect to master after failover

2018-08-03 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] Mesos resource manager unable to connect to master after failover URL: https://github.com/apache/flink/pull/6464#discussion_r207491799 ## File path:

[jira] [Resolved] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI

2018-08-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6846. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.7.0:

[GitHub] asfgit closed pull request #6188: [FLINK-6846] [table] Add timestampAdd tableApi

2018-08-03 Thread GitBox
asfgit closed pull request #6188: [FLINK-6846] [table] Add timestampAdd tableApi URL: https://github.com/apache/flink/pull/6188 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 provenance: As this is a foreign

[jira] [Created] (FLINK-10047) Checkpointing takes much longer with credit base flow control.

2018-08-03 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-10047: -- Summary: Checkpointing takes much longer with credit base flow control. Key: FLINK-10047 URL: https://issues.apache.org/jira/browse/FLINK-10047 Project: Flink

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568077#comment-16568077 ] ASF GitHub Bot commented on FLINK-9134: --- twalthr commented on a change in pull request #6484:

[jira] [Commented] (FLINK-7812) Log system resources as metrics

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568074#comment-16568074 ] ASF GitHub Bot commented on FLINK-7812: --- pnowojski commented on a change in pull request #4801:

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568079#comment-16568079 ] ASF GitHub Bot commented on FLINK-9134: --- twalthr commented on a change in pull request #6484:

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568078#comment-16568078 ] ASF GitHub Bot commented on FLINK-9134: --- twalthr commented on a change in pull request #6484:

[jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568075#comment-16568075 ] ASF GitHub Bot commented on FLINK-9134: --- twalthr commented on a change in pull request #6484:

[GitHub] twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17

2018-08-03 Thread GitBox
twalthr commented on a change in pull request #6484: [FLINK-9134] [table] upgrade Calcite dependency to 1.17 URL: https://github.com/apache/flink/pull/6484#discussion_r207504462 ## File path:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568121#comment-16568121 ] ASF GitHub Bot commented on FLINK-7205: --- hequn8128 commented on issue #6381: [FLINK-7205] [table]

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] Mesos resource manager unable to connect to master after failover

2018-08-03 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] Mesos resource manager unable to connect to master after failover URL: https://github.com/apache/flink/pull/6464#discussion_r207522805 ## File path:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568133#comment-16568133 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6464:

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568132#comment-16568132 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on issue #6464: [FLINK-9936][mesos] Mesos

[jira] [Created] (FLINK-10048) Migrate module flink-gelly-examples to flink-examples and rename it

2018-08-03 Thread vinoyang (JIRA)
vinoyang created FLINK-10048: Summary: Migrate module flink-gelly-examples to flink-examples and rename it Key: FLINK-10048 URL: https://issues.apache.org/jira/browse/FLINK-10048 Project: Flink

[GitHub] azagrebin commented on a change in pull request #6379: [FLINK-9637] Add public user documentation for state TTL feature

2018-08-03 Thread GitBox
azagrebin commented on a change in pull request #6379: [FLINK-9637] Add public user documentation for state TTL feature URL: https://github.com/apache/flink/pull/6379#discussion_r207536863 ## File path: docs/dev/stream/state/state.md ## @@ -266,6 +266,92 @@ a

[GitHub] xueyumusic commented on issue #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support

2018-08-03 Thread GitBox
xueyumusic commented on issue #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support URL: https://github.com/apache/flink/pull/6282#issuecomment-410224157 Thanks, @twalthr , I will update this PR this weekend.

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

2018-08-03 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568153#comment-16568153 ] Hequn Cheng commented on FLINK-5315: Hi [~walterddr] Distinct of Table is not a modifier. It is an

[GitHub] zentol closed pull request #6478: [FLINK-9861][tests] Add StreamingFileSink E2E test

2018-08-03 Thread GitBox
zentol closed pull request #6478: [FLINK-9861][tests] Add StreamingFileSink E2E test URL: https://github.com/apache/flink/pull/6478 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 provenance: As this is a

[jira] [Commented] (FLINK-9861) Add end-to-end test for reworked BucketingSink

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568168#comment-16568168 ] ASF GitHub Bot commented on FLINK-9861: --- zentol closed pull request #6478: [FLINK-9861][tests] Add

[jira] [Commented] (FLINK-9637) Add public user documentation for TTL feature

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568177#comment-16568177 ] ASF GitHub Bot commented on FLINK-9637: --- azagrebin commented on a change in pull request #6379:

[GitHub] azagrebin commented on issue #6379: [FLINK-9637] Add public user documentation for state TTL feature

2018-08-03 Thread GitBox
azagrebin commented on issue #6379: [FLINK-9637] Add public user documentation for state TTL feature URL: https://github.com/apache/flink/pull/6379#issuecomment-410246921 Thanks for review guys! I updated the PR. This is an

[jira] [Commented] (FLINK-9637) Add public user documentation for TTL feature

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568178#comment-16568178 ] ASF GitHub Bot commented on FLINK-9637: --- azagrebin commented on issue #6379: [FLINK-9637] Add

[GitHub] twalthr commented on issue #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support

2018-08-03 Thread GitBox
twalthr commented on issue #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support URL: https://github.com/apache/flink/pull/6282#issuecomment-410216112 @xueyumusic I merged FLINK-6846. Could you update this PR and use `-` arithmetic for the Table API?

[jira] [Commented] (FLINK-6847) Add TIMESTAMPDIFF supported in TableAPI

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568087#comment-16568087 ] ASF GitHub Bot commented on FLINK-6847: --- twalthr commented on issue #6282: [FLINK-6847][FLINK-6813]

[jira] [Commented] (FLINK-6847) Add TIMESTAMPDIFF supported in TableAPI

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568110#comment-16568110 ] ASF GitHub Bot commented on FLINK-6847: --- xueyumusic commented on issue #6282:

[GitHub] GJL commented on issue #6464: [FLINK-9936][mesos] Mesos resource manager unable to connect to master after failover

2018-08-03 Thread GitBox
GJL commented on issue #6464: [FLINK-9936][mesos] Mesos resource manager unable to connect to master after failover URL: https://github.com/apache/flink/pull/6464#issuecomment-410232380 @liurenjie1024 Do you also want to have final look? The fix works in my cluster tests.

[GitHub] yanghua commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-03 Thread GitBox
yanghua commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API URL: https://github.com/apache/flink/pull/6475#issuecomment-410232217 @zentol can you review this, so that I can start other issues and reuse the test file? thanks~

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568130#comment-16568130 ] ASF GitHub Bot commented on FLINK-10012: yanghua commented on issue #6475: [FLINK-10012] Add

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

2018-08-03 Thread GitBox
hequn8128 commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#issuecomment-410228083 @buptljy I don't agree. Without a test, we don't know whether the bug has been fixed. As a choice you can use

  1   2   3   >