[GitHub] tzulitai commented on issue #6078: [FLINK-9438] Add documentation for AvroDeserializationSchema

2018-08-07 Thread GitBox
tzulitai commented on issue #6078: [FLINK-9438] Add documentation for AvroDeserializationSchema URL: https://github.com/apache/flink/pull/6078#issuecomment-411288894 +1, LGTM This is an automated message from the Apache Git

[jira] [Created] (FLINK-10082) Initialize StringBuilder in Slf4jReporter with estimated size

2018-08-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10082: Summary: Initialize StringBuilder in Slf4jReporter with estimated size Key: FLINK-10082 URL: https://issues.apache.org/jira/browse/FLINK-10082 Project: Flink

[jira] [Updated] (FLINK-9432) Support extract epoch, decade, millisecond, microsecond

2018-08-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9432: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-9134) > Support extract

[jira] [Assigned] (FLINK-9791) Outdated savepoint compatibility table

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9791: --- Assignee: Chesnay Schepler > Outdated savepoint compatibility table >

[GitHub] StefanRRichter commented on issue #6493: [FLINK-10058] Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment

2018-08-07 Thread GitBox
StefanRRichter commented on issue #6493: [FLINK-10058] Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment URL: https://github.com/apache/flink/pull/6493#issuecomment-410988875 @yanghua Thanks! Alright, let me take a look at #6475 later and see what I can do to

[jira] [Commented] (FLINK-10058) Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571309#comment-16571309 ] ASF GitHub Bot commented on FLINK-10058: StefanRRichter commented on issue #6493: [FLINK-10058]

[jira] [Created] (FLINK-10086) Update CEPMigrationTest

2018-08-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10086: Summary: Update CEPMigrationTest Key: FLINK-10086 URL: https://issues.apache.org/jira/browse/FLINK-10086 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-10086) Update CEPMigrationTest

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10086. Resolution: Invalid > Update CEPMigrationTest > --- > >

[jira] [Updated] (FLINK-10084) Migration tests weren't updated for 1.5

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10084: - Summary: Migration tests weren't updated for 1.5 (was: Migration tests weren't updated

[GitHub] rickhofstede commented on a change in pull request #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern"

2018-08-07 Thread GitBox
rickhofstede commented on a change in pull request #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern" URL: https://github.com/apache/flink/pull/6503#discussion_r208112215 ## File path: docs/dev/stream/state/broadcast_state.md ## @@

[GitHub] yanghua commented on a change in pull request #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern"

2018-08-07 Thread GitBox
yanghua commented on a change in pull request #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern" URL: https://github.com/apache/flink/pull/6503#discussion_r208116129 ## File path: docs/dev/stream/state/broadcast_state.md ## @@

[jira] [Updated] (FLINK-10079) Automatically resolve and register sink table from external catalogs

2018-08-07 Thread Jun Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Zhang updated FLINK-10079: -- Summary: Automatically resolve and register sink table from external catalogs (was: Automatically

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

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

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

2018-08-07 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-410967246 @hequn8128 Good idea! it's added now. This is an automated

[GitHub] tragicjun opened a new pull request #6508: [Flink-10079] [table] Automatically register sink table from external catalogs

2018-08-07 Thread GitBox
tragicjun opened a new pull request #6508: [Flink-10079] [table] Automatically register sink table from external catalogs URL: https://github.com/apache/flink/pull/6508 ## What is the purpose of the change In the documentation, there is a description: > Once registered in a

[jira] [Commented] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

2018-08-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571227#comment-16571227 ] Till Rohrmann commented on FLINK-5789: -- Yes exactly [~mingleizhang]. > Make Bucketing Sink

[jira] [Commented] (FLINK-10051) SQL client E2E test is missing dependencies

2018-08-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571226#comment-16571226 ] Till Rohrmann commented on FLINK-10051: --- In order to correct the fixVersion and then I forgot to

[jira] [Resolved] (FLINK-10051) SQL client E2E test is missing dependencies

2018-08-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10051. --- Resolution: Fixed > SQL client E2E test is missing dependencies >

[jira] [Commented] (FLINK-10072) Syntax and consistency issues in "The Broadcast State Pattern"

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

[jira] [Commented] (FLINK-10072) Syntax and consistency issues in "The Broadcast State Pattern"

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

[jira] [Created] (FLINK-10079) Automatically resolve and register sink table name from external catalogs

2018-08-07 Thread Jun Zhang (JIRA)
Jun Zhang created FLINK-10079: - Summary: Automatically resolve and register sink table name from external catalogs Key: FLINK-10079 URL: https://issues.apache.org/jira/browse/FLINK-10079 Project: Flink

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-08-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 8/7/18 10:33 PM: In

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-07 Thread xymaqingxiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572626#comment-16572626 ] xymaqingxiang commented on FLINK-8290: -- Hi, *all*   [group.id|http://group.id/] is a concept of

[jira] [Updated] (FLINK-9824) Support IPv6 literal

2018-08-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9824: -- Description: Currently we use colon as separator when parsing host and port. We should support the usage of

[GitHub] tragicjun commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs

2018-08-07 Thread GitBox
tragicjun commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs URL: https://github.com/apache/flink/pull/6508#issuecomment-411243850 @zentol already fixed, thanks. This is

[jira] [Updated] (FLINK-10099) Rework YarnResourceManagerTest

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10099: --- Labels: pull-request-available (was: ) > Rework YarnResourceManagerTest >

[jira] [Commented] (FLINK-10099) Rework YarnResourceManagerTest

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572620#comment-16572620 ] ASF GitHub Bot commented on FLINK-10099: TisonKun commented on issue #6499: [FLINK-10099] [test]

[GitHub] TisonKun commented on issue #6499: [FLINK-10099] [test] Rework YarnResourceManagerTest

2018-08-07 Thread GitBox
TisonKun commented on issue #6499: [FLINK-10099] [test] Rework YarnResourceManagerTest URL: https://github.com/apache/flink/pull/6499#issuecomment-411273545 @tillrohrmann @GJL thanks for your reviews! I revert the change replacing mocks, but gather them so that we can replace it once

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

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

[GitHub] maqingxiang commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-07 Thread GitBox
maqingxiang commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 URL: https://github.com/apache/flink/pull/5304#discussion_r208448741 ## File path:

[jira] [Created] (FLINK-10099) Rework YarnResourceManagerTest

2018-08-07 Thread JIRA
陈梓立 created FLINK-10099: --- Summary: Rework YarnResourceManagerTest Key: FLINK-10099 URL: https://issues.apache.org/jira/browse/FLINK-10099 Project: Flink Issue Type: Improvement Components:

[GitHub] maqingxiang commented on issue #6303: [hotfix][JobManageOptions]modify annotation of EXECUTION_FAILOVER_STRATEGY in JobManageOptions

2018-08-07 Thread GitBox
maqingxiang commented on issue #6303: [hotfix][JobManageOptions]modify annotation of EXECUTION_FAILOVER_STRATEGY in JobManageOptions URL: https://github.com/apache/flink/pull/6303#issuecomment-411270804 I'm very sorry for the late reply. Thank you @zentol and @dawidwys

[jira] [Comment Edited] (FLINK-7243) Add ParquetInputFormat

2018-08-07 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567824#comment-16567824 ] Zhenqiu Huang edited comment on FLINK-7243 at 8/7/18 7:45 PM: -- [~najman]

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

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

[GitHub] walterddr opened a new pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

2018-08-07 Thread GitBox
walterddr opened a new pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521 ## What is the purpose of the change * Adding `distinct` aggregation support for Table API. Example usages

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

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5315: -- Labels: pull-request-available (was: ) > Support distinct aggregations in table api >

[GitHub] suez1224 commented on issue #6483: [Flink-7243][flink-formats] Add parquet input format

2018-08-07 Thread GitBox
suez1224 commented on issue #6483: [Flink-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-411180238 Thanks a lot for the PR. Please fix the minor check-style issue first. I'll take a look in the next few days.

[jira] [Created] (FLINK-10098) Programmatically select timer storage backend

2018-08-07 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10098: -- Summary: Programmatically select timer storage backend Key: FLINK-10098 URL: https://issues.apache.org/jira/browse/FLINK-10098 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9438) Add documentation for (Registry)AvroDeserializationSchema

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572696#comment-16572696 ] ASF GitHub Bot commented on FLINK-9438: --- tzulitai commented on issue #6078: [FLINK-9438] Add

[jira] [Closed] (FLINK-10055) incorrect in-progress file suffix in BucketingSink's java doc

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

[GitHub] zentol closed pull request #6488: [FLINK-10055] incorrect in-progress file suffix in BucketingSink's java doc

2018-08-07 Thread GitBox
zentol closed pull request #6488: [FLINK-10055] incorrect in-progress file suffix in BucketingSink's java doc URL: https://github.com/apache/flink/pull/6488 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

[jira] [Commented] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

2018-08-07 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571483#comment-16571483 ] zhangminglei commented on FLINK-5789: - Thank you [~till.rohrmann] > Make Bucketing Sink independent

[jira] [Commented] (FLINK-10055) incorrect in-progress file suffix in BucketingSink's java doc

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571484#comment-16571484 ] ASF GitHub Bot commented on FLINK-10055: zentol closed pull request #6488: [FLINK-10055]

[GitHub] zentol opened a new pull request #6516: [FLINK-10092][tests] Update StatefulJobSavepointMigrationITCase for 1.5

2018-08-07 Thread GitBox
zentol opened a new pull request #6516: [FLINK-10092][tests] Update StatefulJobSavepointMigrationITCase for 1.5 URL: https://github.com/apache/flink/pull/6516 ## What is the purpose of the change This PR extends the `StatefulJobSavepointMigrationITCase` also cover migration from

[jira] [Closed] (FLINK-10086) Update CEPMigrationTest

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10086. Resolution: Invalid > Update CEPMigrationTest > --- > >

[GitHub] StefanRRichter commented on a change in pull request #6510: [State TTL] Swap serialization order in TTL value: first timestamp then user value

2018-08-07 Thread GitBox
StefanRRichter commented on a change in pull request #6510: [State TTL] Swap serialization order in TTL value: first timestamp then user value URL: https://github.com/apache/flink/pull/6510#discussion_r208201293 ## File path:

[GitHub] StefanRRichter commented on issue #6510: [State TTL] Swap serialization order in TTL value: first timestamp then user value

2018-08-07 Thread GitBox
StefanRRichter commented on issue #6510: [State TTL] Swap serialization order in TTL value: first timestamp then user value URL: https://github.com/apache/flink/pull/6510#issuecomment-411030792 Just one minor comment. Otherwise LGTM 

[GitHub] StefanRRichter commented on a change in pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-07 Thread GitBox
StefanRRichter commented on a change in pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517#discussion_r208209791 ## File path: docs/ops/upgrading.md ## @@ -227,15 +229,25 @@ Savepoints are

[GitHub] GJL commented on a change in pull request #6510: [State TTL] Swap serialization order in TTL value: first timestamp then user value

2018-08-07 Thread GitBox
GJL commented on a change in pull request #6510: [State TTL] Swap serialization order in TTL value: first timestamp then user value URL: https://github.com/apache/flink/pull/6510#discussion_r208210641 ## File path:

[GitHub] dawidwys removed a comment on issue #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-07 Thread GitBox
dawidwys removed a comment on issue #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517#issuecomment-411040756 +1 from side This is an automated message from

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571585#comment-16571585 ] ASF GitHub Bot commented on FLINK-9446: --- dawidwys removed a comment on issue #6517:

[GitHub] dawidwys commented on issue #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-07 Thread GitBox
dawidwys commented on issue #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517#issuecomment-411040756 +1 from side This is an automated message from the

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571582#comment-16571582 ] ASF GitHub Bot commented on FLINK-9446: --- dawidwys commented on issue #6517: [FLINK-9446][docs]

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

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

[GitHub] zentol commented on a change in pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-07 Thread GitBox
zentol commented on a change in pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517#discussion_r208215354 ## File path: docs/ops/upgrading.md ## @@ -227,15 +229,25 @@ Savepoints are compatible

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

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

[GitHub] dawidwys commented on a change in pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-07 Thread GitBox
dawidwys commented on a change in pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517#discussion_r208216233 ## File path: docs/ops/upgrading.md ## @@ -227,15 +229,25 @@ Savepoints are

[GitHub] yanghua commented on issue #6506: [FLINK-10073] [sql-client] Allow setting a restart strategy in SQL Client

2018-08-07 Thread GitBox
yanghua commented on issue #6506: [FLINK-10073] [sql-client] Allow setting a restart strategy in SQL Client URL: https://github.com/apache/flink/pull/6506#issuecomment-410953097 @twalthr conflicts and sql client test failure.

[jira] [Commented] (FLINK-10073) Allow setting a restart strategy in SQL Client

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

[jira] [Updated] (FLINK-10091) Update WindowOperatorMigrationTest

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

[jira] [Created] (FLINK-10093) Update StatefulJobWBroadcastStateMigrationITCase

2018-08-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10093: Summary: Update StatefulJobWBroadcastStateMigrationITCase Key: FLINK-10093 URL: https://issues.apache.org/jira/browse/FLINK-10093 Project: Flink

[jira] [Assigned] (FLINK-6437) Move history server configuration to a separate file

2018-08-07 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-6437: --- Assignee: vinoyang > Move history server configuration to a separate file >

[jira] [Updated] (FLINK-10092) Update StatefulJobSavepointMigrationITCase

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

[jira] [Commented] (FLINK-10092) Update StatefulJobSavepointMigrationITCase

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

[jira] [Commented] (FLINK-9791) Outdated savepoint compatibility table

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571514#comment-16571514 ] Chesnay Schepler commented on FLINK-9791: - The release guide has been updated to include the

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571544#comment-16571544 ] ASF GitHub Bot commented on FLINK-9446: --- zentol opened a new pull request #6517: [FLINK-9446][docs]

[jira] [Updated] (FLINK-9446) Compatibility table not up-to-date

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9446: -- Labels: pull-request-available (was: ) > Compatibility table not up-to-date >

[jira] [Commented] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors

2018-08-07 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571552#comment-16571552 ] vinoyang commented on FLINK-10067: -- hi [~aljoscha] and [~elevy] there is a issue track kafka 2.0

[jira] [Assigned] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

2018-08-07 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-8482: -- Assignee: Florian Schmidt > Implement and expose option to use min / max / left /

[GitHub] StefanRRichter commented on a change in pull request #6510: [State TTL] Swap serialization order in TTL value: first timestamp then user value

2018-08-07 Thread GitBox
StefanRRichter commented on a change in pull request #6510: [State TTL] Swap serialization order in TTL value: first timestamp then user value URL: https://github.com/apache/flink/pull/6510#discussion_r208211009 ## File path:

[jira] [Created] (FLINK-10094) Always backup default config for end-to-end tests

2018-08-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10094: Summary: Always backup default config for end-to-end tests Key: FLINK-10094 URL: https://issues.apache.org/jira/browse/FLINK-10094 Project: Flink

[jira] [Updated] (FLINK-10094) Always backup default config for end-to-end tests

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10094: --- Labels: pull-request-available (was: ) > Always backup default config for end-to-end tests

[jira] [Commented] (FLINK-10060) Add RTRIM supported in Table API and SQL

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571595#comment-16571595 ] ASF GitHub Bot commented on FLINK-10060: yanghua commented on issue #6509: [FLINK-10060] [table]

[jira] [Commented] (FLINK-10094) Always backup default config for end-to-end tests

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

[GitHub] zentol opened a new pull request #6518: [FLINK-10094][tests] Always backup config before running test

2018-08-07 Thread GitBox
zentol opened a new pull request #6518: [FLINK-10094][tests] Always backup config before running test URL: https://github.com/apache/flink/pull/6518 ## What is the purpose of the change With this PR the test runner is responsible for backing up `flink-conf.yaml` and not individual

[GitHub] yanghua commented on issue #6509: [FLINK-10060] [table] Add RTRIM supported in Table API and SQL

2018-08-07 Thread GitBox
yanghua commented on issue #6509: [FLINK-10060] [table] Add RTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6509#issuecomment-411041926 @suez1224 @hequn8128 @xccui This is an automated message

[jira] [Commented] (FLINK-10094) Always backup default config for end-to-end tests

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571614#comment-16571614 ] ASF GitHub Bot commented on FLINK-10094: zentol commented on issue #6518: [FLINK-10094][tests]

[jira] [Commented] (FLINK-10094) Always backup default config for end-to-end tests

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571619#comment-16571619 ] ASF GitHub Bot commented on FLINK-10094: florianschmidt1994 commented on issue #6518:

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

2018-08-07 Thread GitBox
hequn8128 edited a comment on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#issuecomment-410680365 @buptljy Ok, you are right. Thanks for pointing it out. How about add a test in `CalcITCase` in package of

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

2018-08-07 Thread GitBox
hequn8128 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_r208223441 ## File path:

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

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

[jira] [Closed] (FLINK-10093) Update StatefulJobWBroadcastStateMigrationITCase

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10093. Resolution: Invalid Fix Version/s: (was: 1.6.1) (was:

[jira] [Updated] (FLINK-10086) Update CEPMigrationTest

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10086: - Fix Version/s: (was: 1.6.1) (was: 1.7.0) > Update

[jira] [Reopened] (FLINK-10086) Update CEPMigrationTest

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-10086: -- > Update CEPMigrationTest > --- > > Key: FLINK-10086

[jira] [Updated] (FLINK-10088) error when trying to run flink-sql-client on windows

2018-08-07 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10088: - Component/s: (was: Client) Table API & SQL > error when trying to run

[GitHub] zentol opened a new pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-07 Thread GitBox
zentol opened a new pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517 ## What is the purpose of the change This PR updates the savepoint compatibility table for 1.4. In FLINK-7461 we removed

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

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

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

2018-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571572#comment-16571572 ] ASF GitHub Bot commented on FLINK-9446: --- StefanRRichter commented on issue #6517:

[GitHub] StefanRRichter commented on issue #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-07 Thread GitBox
StefanRRichter commented on issue #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517#issuecomment-411038757 Update looks good from my side. This is an

[GitHub] zentol commented on issue #6518: [FLINK-10094][tests] Always backup config before running test

2018-08-07 Thread GitBox
zentol commented on issue #6518: [FLINK-10094][tests] Always backup config before running test URL: https://github.com/apache/flink/pull/6518#issuecomment-411045645 I believe we do always revert it. ``` # from test-runner-common.sh function cleanup_proc { shutdown_all

[GitHub] florianschmidt1994 commented on issue #6518: [FLINK-10094][tests] Always backup config before running test

2018-08-07 Thread GitBox
florianschmidt1994 commented on issue #6518: [FLINK-10094][tests] Always backup config before running test URL: https://github.com/apache/flink/pull/6518#issuecomment-411046104 Ah, I missed that! Probably makes sense to remove that at some point

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-08-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571618#comment-16571618 ] Till Rohrmann commented on FLINK-10074: --- [~yanghua] what is the scope of the initial

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-08-07 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571634#comment-16571634 ] Thomas Weise commented on FLINK-10074: -- It could potentially also be specified as maximum time

[GitHub] twalthr commented on a change in pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-07 Thread GitBox
twalthr commented on a change in pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517#discussion_r208223075 ## File path: docs/ops/upgrading.md ## @@ -227,15 +229,25 @@ Savepoints are compatible

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

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

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

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

[jira] [Updated] (FLINK-10084) Migration tests weren't updated for 1.5

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10084: - Component/s: (was: Streaming Connectors) (was: Streaming)

[jira] [Created] (FLINK-10092) Update StatefulJobSavepointMigrationITCase

2018-08-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10092: Summary: Update StatefulJobSavepointMigrationITCase Key: FLINK-10092 URL: https://issues.apache.org/jira/browse/FLINK-10092 Project: Flink Issue

[jira] [Commented] (FLINK-9997) Improve Expression Reduce

2018-08-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571512#comment-16571512 ] Fabian Hueske commented on FLINK-9997: -- Hi [~RuidongLi], thanks for opening this issue. You are of

[jira] [Closed] (FLINK-9791) Outdated savepoint compatibility table

2018-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9791. --- Resolution: Duplicate > Outdated savepoint compatibility table >

  1   2   3   4   >