[jira] [Commented] (FLINK-10696) Add APIs to ExternalCatalog for views and UDFs

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669654#comment-16669654 ] ASF GitHub Bot commented on FLINK-10696: bowenli86 commented on issue #6970: [FLINK-10696][Table

[jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6944: --- Fix Version/s: (was: 1.7.0) > Introduce DefaultTypeSerializerConfigSnapshot as a

[jira] [Closed] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9608. -- Resolution: Fixed Assignee: Igal Shilman (was: Tzu-Li (Gordon) Tai)

[jira] [Assigned] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-6944: -- Assignee: (was: Tzu-Li (Gordon) Tai) > Introduce

[jira] [Closed] (FLINK-9808) Implement state conversion procedure in state backends

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9808. -- Resolution: Fixed Merged for 1.7.0: 70f4141369850dcc16efe3ddfe71618ea8cda304 >

[GitHub] bowenli86 commented on issue #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-10-30 Thread GitBox
bowenli86 commented on issue #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs URL: https://github.com/apache/flink/pull/6970#issuecomment-434570473 @xuefuz @twalthr can you please take a look?

[jira] [Closed] (FLINK-10605) Upgrade AvroSerializer snapshot to implement new TypeSerializerSnapshot interface

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10605. --- Resolution: Fixed Merged for 1.7.0: b0b10edca7cf776defb83a739c9db2b8b55e5f70 >

[jira] [Closed] (FLINK-10679) Let TypeSerializerSchemaCompatibility.resolveSchemaCompatibility() be the entry point for compatibility checks in framework code

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10679. --- Resolution: Fixed Fix Version/s: 1.7.0 Merged for 1.7.0: 

[jira] [Closed] (FLINK-10708) Implement a SerializerMigrationTestBase

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10708. --- Resolution: Fixed Fix Version/s: 1.7.0 Merged for 1.7.0:

[jira] [Closed] (FLINK-10709) Remove NS generic parameter from TypeSerializerSchemaCompatibility

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10709. --- Resolution: Fixed Fix Version/s: 1.7.0 Merged for 1.7.0:

[jira] [Closed] (FLINK-10716) Upgrade ListSerializer / ArrayListSerializer for state evolution

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10716. --- Resolution: Fixed Fix Version/s: 1.7.0 Merged for 1.7.0: 

[jira] [Closed] (FLINK-10710) Implement new CompositeSerializerSnapshot

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10710. --- Resolution: Fixed Fix Version/s: 1.7.0 Merged for 1.7.0:

[jira] [Closed] (FLINK-10717) Introduce SimpleSerializerSnapshot as replacement for ParameterlessTypeSerializerConfig

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10717. --- Resolution: Fixed Fix Version/s: 1.7.0 Merged for 1.7.0: 

[jira] [Closed] (FLINK-10723) Upgrade MapSerializer for state evolution

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10723. --- > Upgrade MapSerializer for state evolution > -

[jira] [Resolved] (FLINK-10723) Upgrade MapSerializer for state evolution

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-10723. - Resolution: Fixed Fix Version/s: 1.7.0 Merged for 1.7.0: 

[jira] [Updated] (FLINK-9376) Allow upgrading to incompatible state serializers (state schema evolution)

2018-10-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9376: --- Fix Version/s: (was: 1.7.0) > Allow upgrading to incompatible state serializers

[jira] [Commented] (FLINK-10556) Integration with Apache Hive

2018-10-30 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669607#comment-16669607 ] Bowen Li commented on FLINK-10556: -- sorry that I put the wrong jira number in one of my PRs and got

[jira] [Commented] (FLINK-10696) Add APIs to ExternalCatalog for views and UDFs

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669584#comment-16669584 ] ASF GitHub Bot commented on FLINK-10696: bowenli86 opened a new pull request #6970:

[GitHub] bowenli86 commented on issue #6969: [Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-10-30 Thread GitBox
bowenli86 commented on issue #6969: [Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs URL: https://github.com/apache/flink/pull/6969#issuecomment-434557089 put the wrong jira ticket number

[jira] [Updated] (FLINK-10696) Add APIs to ExternalCatalog for views and UDFs

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10696: --- Labels: pull-request-available (was: ) > Add APIs to ExternalCatalog for views and UDFs >

[GitHub] bowenli86 opened a new pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-10-30 Thread GitBox
bowenli86 opened a new pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs URL: https://github.com/apache/flink/pull/6970 ## What is the purpose of the change Currently Flink's

[jira] [Commented] (FLINK-10556) Integration with Apache Hive

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669582#comment-16669582 ] ASF GitHub Bot commented on FLINK-10556: bowenli86 closed pull request #6969:

[GitHub] bowenli86 closed pull request #6969: [FLINK-10556][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-10-30 Thread GitBox
bowenli86 closed pull request #6969: [FLINK-10556][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs URL: https://github.com/apache/flink/pull/6969 This is a PR merged from a forked repository. As GitHub hides the

[jira] [Updated] (FLINK-10556) Integration with Apache Hive

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10556: --- Labels: pull-request-available (was: ) > Integration with Apache Hive >

[jira] [Commented] (FLINK-10556) Integration with Apache Hive

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669576#comment-16669576 ] ASF GitHub Bot commented on FLINK-10556: bowenli86 opened a new pull request #6969:

[GitHub] bowenli86 opened a new pull request #6969: [FLINK-10556][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-10-30 Thread GitBox
bowenli86 opened a new pull request #6969: [FLINK-10556][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs URL: https://github.com/apache/flink/pull/6969 ## What is the purpose of the change Currently Flink's

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

2018-10-30 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669566#comment-16669566 ] Thomas Weise commented on FLINK-5697: - The latest related discussion:

[jira] [Commented] (FLINK-7342) Add support for Regular Expression Operators (RLIKE)

2018-10-30 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669563#comment-16669563 ] Rong Rong commented on FLINK-7342: -- Seems like {{SIMILAR TO}} was already supported in Flink, should we

[jira] [Assigned] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

2018-10-30 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-5697: --- Assignee: Thomas Weise > Add per-shard watermarks for FlinkKinesisConsumer >

[jira] [Comment Edited] (FLINK-10231) Add a view SQL DDL

2018-10-30 Thread winifredtang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668093#comment-16668093 ] winifredtang edited comment on FLINK-10231 at 10/31/18 2:50 AM:

[jira] [Assigned] (FLINK-10729) Create a Hive a connector to access Hive data

2018-10-30 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-10729: - Assignee: Zhenqiu Huang > Create a Hive a connector to access Hive data >

[jira] [Commented] (FLINK-10729) Create a Hive a connector to access Hive data

2018-10-30 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669528#comment-16669528 ] Zhenqiu Huang commented on FLINK-10729: --- Hi Xuefu, I am interested with this Task, Would you

[jira] [Comment Edited] (FLINK-10231) Add a view SQL DDL

2018-10-30 Thread winifredtang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668093#comment-16668093 ] winifredtang edited comment on FLINK-10231 at 10/31/18 2:47 AM: Fabian

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669517#comment-16669517 ] ASF GitHub Bot commented on FLINK-10600: yanghua edited a comment on issue #6924: [FLINK-10600]

[GitHub] yanghua edited a comment on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread GitBox
yanghua edited a comment on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-434539461 @pnowojski I can give you more details : added `set -x` and `set -e`: ``` +

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669516#comment-16669516 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on issue #6924: [FLINK-10600] Provide

[GitHub] yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread GitBox
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-434539461 @pnowojski I can give you more details : added `set -x` and `set -e`: ``` + stop_kafka_cluster

[jira] [Commented] (FLINK-2028) Download pages must not link to snapshots

2018-10-30 Thread Sebb (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669506#comment-16669506 ] Sebb commented on FLINK-2028: - SNAPSHOT builds should only be advertised to Flink developers, so should only

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

2018-10-30 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669502#comment-16669502 ] Ankur Goenka commented on FLINK-10672: -- Investigation notes: * Pipeline seems to be waiting on

[jira] [Commented] (FLINK-10728) Unexpected items on ASF mirrors

2018-10-30 Thread Sebb (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669497#comment-16669497 ] Sebb commented on FLINK-10728: -- I don't understand what you mean by "Flink itself is the only intended

[jira] [Updated] (FLINK-9953) Active Kubernetes integration

2018-10-30 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-9953: --- Description: This is the umbrella issue tracking Flink's active Kubernetes integration. Active means in

[jira] [Created] (FLINK-10729) Create a Hive a connector to access Hive data

2018-10-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-10729: --- Summary: Create a Hive a connector to access Hive data Key: FLINK-10729 URL: https://issues.apache.org/jira/browse/FLINK-10729 Project: Flink Issue Type:

[jira] [Updated] (FLINK-10556) Integration with Apache Hive

2018-10-30 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10556: Attachment: (was: Flink-Hive Metastore Connectivity Design.pdf) > Integration with Apache

[jira] [Updated] (FLINK-10556) Integration with Apache Hive

2018-10-30 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10556: Attachment: Flink-Hive Metastore Connectivity Design.pdf > Integration with Apache Hive >

[jira] [Assigned] (FLINK-10699) Create a catalog implementation for persistent Flink meta objects using Hive metastore as a registry

2018-10-30 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-10699: Assignee: Bowen Li > Create a catalog implementation for persistent Flink meta objects using

[GitHub] yxu-valleytider opened a new pull request #6968: Consuming data from DynamoDB streams to flink

2018-10-30 Thread GitBox
yxu-valleytider opened a new pull request #6968: Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968 ## What is the purpose of the change This PR introduces a new Flink source to consume directly from [dynamodb

[jira] [Commented] (FLINK-10166) Dependency problems when executing SQL query in sql-client

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669365#comment-16669365 ] ASF GitHub Bot commented on FLINK-10166: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-10166) Dependency problems when executing SQL query in sql-client

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669363#comment-16669363 ] ASF GitHub Bot commented on FLINK-10166: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-10166) Dependency problems when executing SQL query in sql-client

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669364#comment-16669364 ] ASF GitHub Bot commented on FLINK-10166: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-9752) Add an S3 RecoverableWriter

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669362#comment-16669362 ] ASF GitHub Bot commented on FLINK-9752: --- addisonj edited a comment on issue #6795:

[GitHub] igalshilman commented on a change in pull request #6966: [FLINK-10166] [table] Reduce dependencies by removing org.apache.commons

2018-10-30 Thread GitBox
igalshilman commented on a change in pull request #6966: [FLINK-10166] [table] Reduce dependencies by removing org.apache.commons URL: https://github.com/apache/flink/pull/6966#discussion_r229481767 ## File path:

[GitHub] addisonj edited a comment on issue #6795: [FLINK-9752][s3-fs-connector] Add s3 recoverable writer.

2018-10-30 Thread GitBox
addisonj edited a comment on issue #6795: [FLINK-9752][s3-fs-connector] Add s3 recoverable writer. URL: https://github.com/apache/flink/pull/6795#issuecomment-434477664 @kl0u the jira issue (https://issues.apache.org/jira/browse/FLINK-9752) says this is fixed in 1.6.2, but it doesn't

[GitHub] igalshilman commented on a change in pull request #6966: [FLINK-10166] [table] Reduce dependencies by removing org.apache.commons

2018-10-30 Thread GitBox
igalshilman commented on a change in pull request #6966: [FLINK-10166] [table] Reduce dependencies by removing org.apache.commons URL: https://github.com/apache/flink/pull/6966#discussion_r229473954 ## File path:

[GitHub] igalshilman commented on a change in pull request #6966: [FLINK-10166] [table] Reduce dependencies by removing org.apache.commons

2018-10-30 Thread GitBox
igalshilman commented on a change in pull request #6966: [FLINK-10166] [table] Reduce dependencies by removing org.apache.commons URL: https://github.com/apache/flink/pull/6966#discussion_r229487810 ## File path:

[GitHub] addisonj commented on issue #6795: [FLINK-9752][s3-fs-connector] Add s3 recoverable writer.

2018-10-30 Thread GitBox
addisonj commented on issue #6795: [FLINK-9752][s3-fs-connector] Add s3 recoverable writer. URL: https://github.com/apache/flink/pull/6795#issuecomment-434477664 @kl0u the jira issue (https://issues.apache.org/jira/browse/FLINK-10383) says this is fixed in 1.6.2, but it doesn't appear

[jira] [Commented] (FLINK-9752) Add an S3 RecoverableWriter

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669358#comment-16669358 ] ASF GitHub Bot commented on FLINK-9752: --- addisonj commented on issue #6795:

[jira] [Commented] (FLINK-10728) Unexpected items on ASF mirrors

2018-10-30 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669236#comment-16669236 ] Chesnay Schepler commented on FLINK-10728: -- I simply forgot to send out the announcement mails.

[jira] [Assigned] (FLINK-10728) Unexpected items on ASF mirrors

2018-10-30 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-10728: Assignee: Chesnay Schepler > Unexpected items on ASF mirrors >

[jira] [Commented] (FLINK-2028) Download pages must not link to snapshots

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669219#comment-16669219 ] ASF GitHub Bot commented on FLINK-2028: --- zentol opened a new pull request #131: [FLINK-2028] Remove

[jira] [Updated] (FLINK-2028) Download pages must not link to snapshots

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-2028: -- Labels: pull-request-available (was: ) > Download pages must not link to snapshots >

[jira] [Commented] (FLINK-2028) Download pages must not link to snapshots

2018-10-30 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669215#comment-16669215 ] Chesnay Schepler commented on FLINK-2028: - [~s...@apache.org] Is it allowed to link to said

[jira] [Created] (FLINK-10728) Unexpected items on ASF mirrors

2018-10-30 Thread Sebb (JIRA)
Sebb created FLINK-10728: Summary: Unexpected items on ASF mirrors Key: FLINK-10728 URL: https://issues.apache.org/jira/browse/FLINK-10728 Project: Flink Issue Type: Bug Environment:

[jira] [Commented] (FLINK-10628) Add end-to-end test for REST communication encryption

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669173#comment-16669173 ] ASF GitHub Bot commented on FLINK-10628: azagrebin opened a new pull request #6967:

[jira] [Updated] (FLINK-10628) Add end-to-end test for REST communication encryption

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10628: --- Labels: pull-request-available (was: ) > Add end-to-end test for REST communication

[GitHub] azagrebin opened a new pull request #6967: [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests

2018-10-30 Thread GitBox
azagrebin opened a new pull request #6967: [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests URL: https://github.com/apache/flink/pull/6967 ## What is the purpose of the change This PR enables mutual SSL authentication in batch all around and streaming file sink

[jira] [Commented] (FLINK-10556) Integration with Apache Hive

2018-10-30 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669164#comment-16669164 ] Xuefu Zhang commented on FLINK-10556: - I have attached the design doc on Hive metastore integration.

[jira] [Updated] (FLINK-10556) Integration with Apache Hive

2018-10-30 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10556: Attachment: Flink-Hive Metastore Connectivity Design.pdf > Integration with Apache Hive >

[jira] [Reopened] (FLINK-2028) Download pages must not link to snapshots

2018-10-30 Thread Sebb (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebb reopened FLINK-2028: - The download page contains a link to a SNAPSHOT. This is not allowed on a public download page. Please remove the

[GitHub] kl0u commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

2018-10-30 Thread GitBox
kl0u commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream URL: https://github.com/apache/flink/pull/6608#issuecomment-434409845 Hi Artsem, you are correct that it is not used but I already have a branch for it and

[jira] [Commented] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669135#comment-16669135 ] ASF GitHub Bot commented on FLINK-10203: kl0u commented on issue #6608: [FLINK-10203]Support

[jira] [Closed] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9635. - Resolution: Fixed Merged in: master: c8a6471a58 > Local recovery scheduling can cause spread

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669099#comment-16669099 ] ASF GitHub Bot commented on FLINK-9635: --- asfgit closed pull request #6961: [FLINK-9635] Fix

[GitHub] asfgit closed pull request #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
asfgit closed pull request #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961 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] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669061#comment-16669061 ] ASF GitHub Bot commented on FLINK-9635: --- StefanRRichter commented on issue #6961: [FLINK-9635] Fix

[GitHub] StefanRRichter commented on issue #6961: [FLINK-9635] Fix scheduling for local recovery

2018-10-30 Thread GitBox
StefanRRichter commented on issue #6961: [FLINK-9635] Fix scheduling for local recovery URL: https://github.com/apache/flink/pull/6961#issuecomment-434388623 Thanks for the review @tillrohrmann! Travis looks good, proceeding with the merge.

[jira] [Assigned] (FLINK-10166) Dependency problems when executing SQL query in sql-client

2018-10-30 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-10166: Assignee: Timo Walther > Dependency problems when executing SQL query in sql-client >

[jira] [Commented] (FLINK-10166) Dependency problems when executing SQL query in sql-client

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669014#comment-16669014 ] ASF GitHub Bot commented on FLINK-10166: twalthr opened a new pull request #6966: [FLINK-10166]

[GitHub] twalthr opened a new pull request #6966: [FLINK-10166] [table] Reduce dependencies by removing org.apache.commons

2018-10-30 Thread GitBox
twalthr opened a new pull request #6966: [FLINK-10166] [table] Reduce dependencies by removing org.apache.commons URL: https://github.com/apache/flink/pull/6966 ## What is the purpose of the change This PR removes all dependencies to `org.apache.commons` libraries. In the past we

[jira] [Commented] (FLINK-10726) Streaming SQL end-to-end test fails due to recent flink-table-common changes

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668994#comment-16668994 ] ASF GitHub Bot commented on FLINK-10726: asfgit closed pull request #6964: [FLINK-10726] [table]

[GitHub] asfgit closed pull request #6964: [FLINK-10726] [table] Include flink-table-common in flink-table jar

2018-10-30 Thread GitBox
asfgit closed pull request #6964: [FLINK-10726] [table] Include flink-table-common in flink-table jar URL: https://github.com/apache/flink/pull/6964 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:

[GitHub] yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread GitBox
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-434372198 @pnowojski I just tested again, added `set -x` on the top of `kafka-common.sh`, `test_streaming_kafka_common.sh`

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668992#comment-16668992 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on issue #6924: [FLINK-10600] Provide

[jira] [Resolved] (FLINK-10726) Streaming SQL end-to-end test fails due to recent flink-table-common changes

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Comment Edited] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

2018-10-30 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668964#comment-16668964 ] Yun Tang edited comment on FLINK-10712 at 10/30/18 4:18 PM: We have already

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10632) Run general purpose test job with failures in per-job mode

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

[jira] [Commented] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

2018-10-30 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668964#comment-16668964 ] Yun Tang commented on FLINK-10712: -- We have refactored _FailoverRegion.java_ to support fail-over with

[GitHub] tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode URL: https://github.com/apache/flink/pull/6943#discussion_r229376944 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode URL: https://github.com/apache/flink/pull/6943#discussion_r229344187 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode URL: https://github.com/apache/flink/pull/6943#discussion_r229353357 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode URL: https://github.com/apache/flink/pull/6943#discussion_r229343747 ## File path: flink-end-to-end-tests/test-scripts/test_ha_dataset.sh

[GitHub] tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode

2018-10-30 Thread GitBox
tillrohrmann commented on a change in pull request #6943: [FLINK-10632][e2e] Running general purpose testing job with failure in per-job mode URL: https://github.com/apache/flink/pull/6943#discussion_r229353456 ## File path:

  1   2   3   >