[jira] [Closed] (FLINK-10759) Adapt SQL-client configuration file to specify external catalogs and default catalog

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-10759. Resolution: Duplicate Duplicate of FLINK-9172. > Adapt SQL-client configuration file to specify

[jira] [Updated] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9172: Component/s: SQL Client > Support external catalog factory that comes default with SQL-Client >

[jira] [Updated] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9172: Issue Type: Sub-task (was: New Feature) Parent: FLINK-10744 > Support external catalog

[jira] [Updated] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9172: Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-7594) > Support external

[jira] [Updated] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9172: Description: It doesn't seem that the configuration (YAML) file allows specifications of external

[jira] [Resolved] (FLINK-8831) Create SQL Client dependencies

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8831. - Resolution: Fixed All subtasks have been implemented. We will create new issues for new

[jira] [Resolved] (FLINK-9248) Create a SQL Client Avro format fat-jar

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-9248. - Resolution: Fixed Fixed in FLINK-9444. > Create a SQL Client Avro format fat-jar >

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672594#comment-16672594 ] Timo Walther commented on FLINK-10689: -- Thanks for splitting the issue [~phoenixjiangnan]. Yes,

[jira] [Commented] (FLINK-10727) Remove unnecessary synchronization in SingleInputGate#requestPartitions()

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672581#comment-16672581 ] ASF GitHub Bot commented on FLINK-10727: zhijiangW commented on issue #6974:

[GitHub] zhijiangW commented on issue #6974: [FLINK-10727][network] remove unnecessary synchronization in SingleInputGate#requestPartitions()

2018-11-01 Thread GitBox
zhijiangW commented on issue #6974: [FLINK-10727][network] remove unnecessary synchronization in SingleInputGate#requestPartitions() URL: https://github.com/apache/flink/pull/6974#issuecomment-435274230 Thanks till for these guiding suggestions! It is my careless to review so small

[jira] [Created] (FLINK-10760) Create a command line tool to migrate meta objects specified in SQL client configuration

2018-11-01 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-10760: --- Summary: Create a command line tool to migrate meta objects specified in SQL client configuration Key: FLINK-10760 URL: https://issues.apache.org/jira/browse/FLINK-10760

[jira] [Created] (FLINK-10759) Adapt SQL-client configuration file to specify external catalogs and default catalog

2018-11-01 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-10759: --- Summary: Adapt SQL-client configuration file to specify external catalogs and default catalog Key: FLINK-10759 URL: https://issues.apache.org/jira/browse/FLINK-10759

[jira] [Updated] (FLINK-10697) Create an in-memory catalog that stores Flink's meta objects

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10697: --- Labels: pull-request-available (was: ) > Create an in-memory catalog that stores Flink's

[jira] [Commented] (FLINK-10697) Create an in-memory catalog that stores Flink's meta objects

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

[GitHub] bowenli86 opened a new pull request #6997: [FLINK-10697] Create an in-memory catalog that stores Flink's meta objects

2018-11-01 Thread GitBox
bowenli86 opened a new pull request #6997: [FLINK-10697] Create an in-memory catalog that stores Flink's meta objects URL: https://github.com/apache/flink/pull/6997 ## What is the purpose of the change Currently all Flink meta objects (currently tables only) are temporarily stored

[jira] [Created] (FLINK-10758) Refactor TableEnvironment so that all registration calls delegate to CatalogManager

2018-11-01 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-10758: --- Summary: Refactor TableEnvironment so that all registration calls delegate to CatalogManager Key: FLINK-10758 URL: https://issues.apache.org/jira/browse/FLINK-10758

[jira] [Commented] (FLINK-10729) Create a Hive connector for Hive data access in Flink

2018-11-01 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672530#comment-16672530 ] Zhenqiu Huang commented on FLINK-10729: --- [~xuefuz] Agree. If you want to use native formats in

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2018-11-01 Thread lingqi.lpf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672526#comment-16672526 ] lingqi.lpf commented on FLINK-10473: Hi, does this issue have detailed description? > State TTL

[jira] [Assigned] (FLINK-10729) Create a Hive connector for Hive data access in Flink

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

[jira] [Commented] (FLINK-10729) Create a Hive connector for Hive data access in Flink

2018-11-01 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672525#comment-16672525 ] Xuefu Zhang commented on FLINK-10729: - Hi [~ZhenqiuHuang], I did some initial research and found

[jira] [Commented] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

2018-11-01 Thread Yun Gao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672521#comment-16672521 ] Yun Gao commented on FLINK-10742: - Hi Nico, I just assigned this Jira to myself temporarily, and I will

[jira] [Assigned] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

2018-11-01 Thread Yun Gao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-10742: --- Assignee: Yun Gao > Let Netty use Flink's buffers directly in credit-based mode >

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672512#comment-16672512 ] ASF GitHub Bot commented on FLINK-10205: wenlong88 commented on a change in pull request #6684:

[GitHub] wenlong88 commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

2018-11-01 Thread GitBox
wenlong88 commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r230257155 ## File path:

[jira] [Commented] (FLINK-10711) flink-end-to-end-tests can fail silently

2018-11-01 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672495#comment-16672495 ] Hequn Cheng commented on FLINK-10711: - [~twalthr] Hi, I haven't started yet. Take it as you wish.

[jira] [Commented] (FLINK-10507) Set target parallelism to maximum when using the standalone job cluster mode

2018-11-01 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672445#comment-16672445 ] vinoyang commented on FLINK-10507: -- [~mikemintz2] This is just a plan. But for now (1.7.0 no longer

[GitHub] isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

2018-11-01 Thread GitBox
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#issuecomment-435235888 Thanks @tillrohrmann and @StefanRRichter. I pushed the implementation of ```return InputSplits to the

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672420#comment-16672420 ] ASF GitHub Bot commented on FLINK-10205: isunjin commented on issue #6684: [FLINK-10205]

[jira] [Updated] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10756: - Affects Version/s: 1.6.2 > TaskManagerProcessFailureBatchRecoveryITCase did not finish on time >

[jira] [Updated] (FLINK-10757) TaskManagerProcessFailureStreamingRecoveryITCase failed to initialize the cluster entrypoint StandaloneSessionClusterEntrypoint.

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10757: - Component/s: Tests > TaskManagerProcessFailureStreamingRecoveryITCase failed to initialize the >

[jira] [Created] (FLINK-10757) TaskManagerProcessFailureStreamingRecoveryITCase failed to initialize the cluster entrypoint StandaloneSessionClusterEntrypoint.

2018-11-01 Thread Bowen Li (JIRA)
Bowen Li created FLINK-10757: Summary: TaskManagerProcessFailureStreamingRecoveryITCase failed to initialize the cluster entrypoint StandaloneSessionClusterEntrypoint. Key: FLINK-10757 URL:

[jira] [Created] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time

2018-11-01 Thread Bowen Li (JIRA)
Bowen Li created FLINK-10756: Summary: TaskManagerProcessFailureBatchRecoveryITCase did not finish on time Key: FLINK-10756 URL: https://issues.apache.org/jira/browse/FLINK-10756 Project: Flink

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672359#comment-16672359 ] Bowen Li commented on FLINK-10689: -- Thanks [~twalthr] ! I read the code and your comment makes sense.

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672295#comment-16672295 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on issue #6980: [FLINK-5697] [kinesis]

[GitHub] tweise commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

2018-11-01 Thread GitBox
tweise commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#issuecomment-435206371 @EronWright that's correct and I will make sure to document this. Even our planned follow-up work won't be able to address

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

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

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

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

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

2018-11-01 Thread GitBox
bowenli86 commented on a change in 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#discussion_r230216165 ## File path:

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

2018-11-01 Thread GitBox
bowenli86 commented on a change in 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#discussion_r230216165 ## File path:

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672285#comment-16672285 ] ASF GitHub Bot commented on FLINK-5697: --- EronWright commented on issue #6980: [FLINK-5697]

[GitHub] EronWright commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

2018-11-01 Thread GitBox
EronWright commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#issuecomment-435202809 There is a caveat with this implementation that the docs should perhaps mention. The caveat is that it may produce

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672248#comment-16672248 ] ASF GitHub Bot commented on FLINK-5697: --- tweise closed pull request #6980: [FLINK-5697] [kinesis]

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672249#comment-16672249 ] ASF GitHub Bot commented on FLINK-5697: --- tweise opened a new pull request #6980: [FLINK-5697]

[GitHub] tweise opened a new pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

2018-11-01 Thread GitBox
tweise opened a new pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980 ## What is the purpose of the change Adds support for periodic per-shard watermarks to the Kinesis consumer. This

[GitHub] tweise closed pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

2018-11-01 Thread GitBox
tweise closed pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980 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

[jira] [Issue Comment Deleted] (FLINK-10686) Introduce a flink-table-common module

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10686: - Comment: was deleted (was: How about parallelize the subtasks of FLINK-10688 and FLINK-10689? Given

[jira] [Updated] (FLINK-10755) Port external catalogs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10755: - Fix Version/s: 1.8.0 > Port external catalogs in Table API extension points to flink-table-common >

[jira] [Updated] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10689: - Fix Version/s: 1.8.0 > Port UDFs in Table API extension points to flink-table-common >

[jira] [Updated] (FLINK-10686) Introduce a flink-table-common module

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10686: - Fix Version/s: (was: 1.7.0) 1.8.0 > Introduce a flink-table-common module >

[jira] [Updated] (FLINK-10755) Port external catalogs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10755: - Description: After FLINK-10687 and FLINK-10688 have been resolved, we should also port the remaining

[jira] [Assigned] (FLINK-10755) Port external catalogs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-10755: Assignee: Bowen Li > Port external catalogs in Table API extension points to flink-table-common

[jira] [Assigned] (FLINK-10755) Port external catalogs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-10755: Assignee: (was: xueyu) > Port external catalogs in Table API extension points to

[jira] [Created] (FLINK-10755) Port external catalogs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
Bowen Li created FLINK-10755: Summary: Port external catalogs in Table API extension points to flink-table-common Key: FLINK-10755 URL: https://issues.apache.org/jira/browse/FLINK-10755 Project: Flink

[jira] [Updated] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10689: - Description: After FLINK-10687 and FLINK-10688 have been resolved, we should also port the remaining

[jira] [Updated] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

2018-11-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10689: - Summary: Port UDFs in Table API extension points to flink-table-common (was: Port Table API extension

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672058#comment-16672058 ] ASF GitHub Bot commented on FLINK-10696: xuefuz commented on a change in pull request #6970:

[GitHub] xuefuz commented on a change in pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-11-01 Thread GitBox
xuefuz commented on a change in 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#discussion_r230161785 ## File path:

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672037#comment-16672037 ] ASF GitHub Bot commented on FLINK-10696: xuefuz commented on a change in pull request #6970:

[GitHub] xuefuz commented on a change in pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-11-01 Thread GitBox
xuefuz commented on a change in 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#discussion_r230161785 ## File path:

[jira] [Commented] (FLINK-10507) Set target parallelism to maximum when using the standalone job cluster mode

2018-11-01 Thread Mike Mintz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672027#comment-16672027 ] Mike Mintz commented on FLINK-10507: This ticket is marked for "Fix Version: 1.7.0" but I didn't see

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672018#comment-16672018 ] ASF GitHub Bot commented on FLINK-10696: xuefuz commented on a change in pull request #6970:

[GitHub] xuefuz commented on a change in pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-11-01 Thread GitBox
xuefuz commented on a change in 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#discussion_r230159488 ## File path:

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672016#comment-16672016 ] ASF GitHub Bot commented on FLINK-10696: xuefuz commented on a change in pull request #6970:

[GitHub] xuefuz commented on a change in pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

2018-11-01 Thread GitBox
xuefuz commented on a change in 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#discussion_r230159003 ## File path:

[jira] [Assigned] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10490: - Assignee: Stefan Richter > OperatorSnapshotUtil should probably use

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

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

[GitHub] zentol commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-01 Thread GitBox
zentol commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994#discussion_r230128699 ## File path: flink-end-to-end-tests/test-scripts/test_heavy_deployment.sh ## @@

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

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

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

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

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

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

[GitHub] zentol commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-01 Thread GitBox
zentol commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994#discussion_r230126767 ## File path: flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml

[GitHub] zentol commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-01 Thread GitBox
zentol commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994#discussion_r230126606 ## File path: flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml

[GitHub] zentol commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-01 Thread GitBox
zentol commented on a change in pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994#discussion_r230126550 ## File path: flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml

[jira] [Commented] (FLINK-10631) Update jepsen tests to run with multiple slots

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671906#comment-16671906 ] ASF GitHub Bot commented on FLINK-10631: tillrohrmann closed pull request #6978: [FLINK-10631]

[jira] [Resolved] (FLINK-10631) Update jepsen tests to run with multiple slots

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10631. --- Resolution: Fixed Fixed via

[GitHub] tillrohrmann closed pull request #6978: [FLINK-10631] Set number of slots per TM to 3 for Jepsen tests

2018-11-01 Thread GitBox
tillrohrmann closed pull request #6978: [FLINK-10631] Set number of slots per TM to 3 for Jepsen tests URL: https://github.com/apache/flink/pull/6978 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-10631) Update jepsen tests to run with multiple slots

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671905#comment-16671905 ] ASF GitHub Bot commented on FLINK-10631: tillrohrmann commented on issue #6978: [FLINK-10631]

[GitHub] tillrohrmann commented on issue #6978: [FLINK-10631] Set number of slots per TM to 3 for Jepsen tests

2018-11-01 Thread GitBox
tillrohrmann commented on issue #6978: [FLINK-10631] Set number of slots per TM to 3 for Jepsen tests URL: https://github.com/apache/flink/pull/6978#issuecomment-435117292 Thanks for your review @igalshilman. Merging this PR.

[jira] [Commented] (FLINK-10631) Update jepsen tests to run with multiple slots

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

[GitHub] tillrohrmann commented on a change in pull request #6978: [FLINK-10631] Set number of slots per TM to 3 for Jepsen tests

2018-11-01 Thread GitBox
tillrohrmann commented on a change in pull request #6978: [FLINK-10631] Set number of slots per TM to 3 for Jepsen tests URL: https://github.com/apache/flink/pull/6978#discussion_r230124525 ## File path: flink-jepsen/src/jepsen/flink/db.clj ## @@ -293,7 +293,6 @@

[jira] [Commented] (FLINK-10685) Support history server on YARN

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671885#comment-16671885 ] Till Rohrmann commented on FLINK-10685: --- What exactly is the scope of this issue [~yanghua]? >

[jira] [Commented] (FLINK-10703) Race condition in YarnResourceManager

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671881#comment-16671881 ] Till Rohrmann commented on FLINK-10703: --- I think all accesses to {{numPendingContainerRequests}}

[jira] [Commented] (FLINK-10629) FlinkKafkaProducerITCase.testFlinkKafkaProducer10FailTransactionCoordinatorBeforeNotify failed on Travis

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

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

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671867#comment-16671867 ] Till Rohrmann commented on FLINK-10712: --- Thanks a lot for contributing [~yunta]. [~aljoscha] I

[jira] [Commented] (FLINK-10713) RestartIndividualStrategy does not restore state

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671865#comment-16671865 ] Till Rohrmann commented on FLINK-10713: --- I would not say so because this restart strategy has been

[jira] [Commented] (FLINK-10711) flink-end-to-end-tests can fail silently

2018-11-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671863#comment-16671863 ] Timo Walther commented on FLINK-10711: -- [~hequn8128] have you started already? I would take a look

[jira] [Updated] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10721: -- Fix Version/s: 1.7.0 1.6.3 > kafkaFetcher runFetchLoop throw exception

[jira] [Commented] (FLINK-10734) Temporal joins on heavily filtered tables might fail in planning

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671862#comment-16671862 ] Till Rohrmann commented on FLINK-10734: --- Do we want to fix this for {{1.7.0}} [~pnowojski]? >

[jira] [Commented] (FLINK-10735) flink on yarn close container exception

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671861#comment-16671861 ] Till Rohrmann commented on FLINK-10735: --- Thanks for reporting this issue [~ffjl1985]. Could you

[jira] [Updated] (FLINK-10751) Checkpoints should be retained when job reaches suspended state

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10751: -- Fix Version/s: 1.8.0 > Checkpoints should be retained when job reaches suspended state >

[jira] [Updated] (FLINK-10751) Checkpoints should be retained when job reaches suspended state

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10751: -- Fix Version/s: (was: 1.8.0) 1.7.0 > Checkpoints should be retained

[jira] [Updated] (FLINK-10743) Use 0 processExitCode for ApplicationStatus.CANCELED

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10743: -- Fix Version/s: 1.7.0 > Use 0 processExitCode for ApplicationStatus.CANCELED >

[jira] [Updated] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10742: -- Fix Version/s: 1.8.0 > Let Netty use Flink's buffers directly in credit-based mode >

[jira] [Updated] (FLINK-10743) Use 0 processExitCode for ApplicationStatus.CANCELED

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10743: -- Affects Version/s: 1.7.0 > Use 0 processExitCode for ApplicationStatus.CANCELED >

[jira] [Commented] (FLINK-10746) Need to replace transfer.sh for Travis log upload because it shuts down

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671851#comment-16671851 ] Till Rohrmann commented on FLINK-10746: --- We can make this two subtasks if that is better. > Need

[jira] [Updated] (FLINK-10751) Checkpoints should be retained when job reaches suspended state

2018-11-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10751: -- Affects Version/s: 1.7.0 > Checkpoints should be retained when job reaches suspended state >

[jira] [Commented] (FLINK-10631) Update jepsen tests to run with multiple slots

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

[GitHub] igalshilman commented on a change in pull request #6978: [FLINK-10631] Set number of slots per TM to 3 for Jepsen tests

2018-11-01 Thread GitBox
igalshilman commented on a change in pull request #6978: [FLINK-10631] Set number of slots per TM to 3 for Jepsen tests URL: https://github.com/apache/flink/pull/6978#discussion_r230108857 ## File path: flink-jepsen/src/jepsen/flink/db.clj ## @@ -293,7 +293,6 @@

[jira] [Commented] (FLINK-10711) flink-end-to-end-tests can fail silently

2018-11-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671824#comment-16671824 ] Dawid Wysakowicz commented on FLINK-10711: -- I am afraid it is not always as easy as setting

[jira] [Commented] (FLINK-10715) E2e tests fail with ConcurrentModificationException in MetricRegistryImpl

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671819#comment-16671819 ] ASF GitHub Bot commented on FLINK-10715: igalshilman opened a new pull request #6996:

  1   2   3   4   >