[jira] [Commented] (FLINK-6962) Add a table SQL DDL

2018-11-01 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16672624#comment-16672624 ] Shuyi Chen commented on FLINK-6962: --- Design doc is attached. > Add a table SQL DDL > -

[jira] [Assigned] (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:all-tabpanel ] Timo Walther reassigned FLINK-10711: Assignee: Timo Walther (was: Hequn Cheng) > flink-end-to-end-tests can fail silently > -

[jira] [Commented] (FLINK-10232) Add a SQL DDL

2018-11-01 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16672623#comment-16672623 ] Shuyi Chen commented on FLINK-10232: Design doc is attached. > Add a SQL DDL >

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

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

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10757: --- Labels: pull-request-available (was: ) > TaskManagerProcessFailureStreamingRecoveryITCase f

[GitHub] TisonKun opened a new pull request #6998: [FLINK-10757] [tests] Avoid port conflicts in AbstractTaskManagerProc…

2018-11-01 Thread GitBox
TisonKun opened a new pull request #6998: [FLINK-10757] [tests] Avoid port conflicts in AbstractTaskManagerProc… URL: https://github.com/apache/flink/pull/6998 …essFailureRecoveryTest ## What is the purpose of the change Harden `AbstractTaskManagerProcessFailureRecoveryTest` b

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

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

[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 e

[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 fac

[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 c

[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 dependen

[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&focusedCommentId=16672594#comment-16672594 ] Timo Walther commented on FLINK-10689: -- Thanks for splitting the issue [~phoenixjia

[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&focusedCommentId=16672581#comment-16672581 ] ASF GitHub Bot commented on FLINK-10727: zhijiangW commented on issue #6974: [FL

[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 c

[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 Pr

[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 me

[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&focusedCommentId=16672563#comment-16672563 ] ASF GitHub Bot commented on FLINK-10697: bowenli86 opened a new pull request #69

[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 i

[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 Pr

[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&focusedCommentId=16672530#comment-16672530 ] Zhenqiu Huang commented on FLINK-10729: --- [~xuefuz] Agree. If you want to use nati

[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&focusedCommentId=16672526#comment-16672526 ] lingqi.lpf commented on FLINK-10473: Hi, does this issue have detailed description?

[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&focusedCommentId=16672525#comment-16672525 ] Xuefu Zhang commented on FLINK-10729: - Hi [~ZhenqiuHuang], I did some initial resear

[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&focusedCommentId=16672521#comment-16672521 ] Yun Gao commented on FLINK-10742: - Hi Nico, I just assigned this Jira to myself temporar

[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&focusedCommentId=16672512#comment-16672512 ] ASF GitHub Bot commented on FLINK-10205: wenlong88 commented on a change in pull

[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: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execu

[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&focusedCommentId=16672495#comment-16672495 ] Hequn Cheng commented on FLINK-10711: - [~twalthr] Hi, I haven't started yet. Take it

[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&focusedCommentId=16672445#comment-16672445 ] vinoyang commented on FLINK-10507: -- [~mikemintz2] This is just a plan. But for now (1.7

[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 InputSplitAss

[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&focusedCommentId=16672420#comment-16672420 ] ASF GitHub Bot commented on FLINK-10205: isunjin commented on issue #6684: [

[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 > cluste

[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: https://issues.apache.org/j

[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&focusedCommentId=16672359#comment-16672359 ] Bowen Li commented on FLINK-10689: -- Thanks [~twalthr] ! I read the code and your commen

[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&focusedCommentId=16672295#comment-16672295 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on issue #6980: [FLINK-56

[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&focusedCommentId=16672290#comment-16672290 ] ASF GitHub Bot commented on FLINK-10696: bowenli86 commented on a change in pull

[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&focusedCommentId=16672289#comment-16672289 ] ASF GitHub Bot commented on FLINK-10696: bowenli86 commented on a change in pull

[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: flink-librari

[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: flink-librari

[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&focusedCommentId=16672285#comment-16672285 ] ASF GitHub Bot commented on FLINK-5697: --- EronWright commented on issue #6980: [FLIN

[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 spu

[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&focusedCommentId=16672248#comment-16672248 ] ASF GitHub Bot commented on FLINK-5697: --- tweise closed pull request #6980: [FLINK-5

[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&focusedCommentId=16672249#comment-16672249 ] ASF GitHub Bot commented on FLINK-5697: --- tweise opened a new pull request #6980: [F

[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 functional

[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 tha

[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 ex

[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 flink-table-

[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 ex

[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 p

[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&focusedCommentId=16672058#comment-16672058 ] ASF GitHub Bot commented on FLINK-10696: xuefuz commented on a change in pull re

[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: flink-libraries/

[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&focusedCommentId=16672037#comment-16672037 ] ASF GitHub Bot commented on FLINK-10696: xuefuz commented on a change in pull re

[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: flink-libraries/

[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&focusedCommentId=16672027#comment-16672027 ] Mike Mintz commented on FLINK-10507: This ticket is marked for "Fix Version: 1.7.0"

[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&focusedCommentId=16672018#comment-16672018 ] ASF GitHub Bot commented on FLINK-10696: xuefuz commented on a change in pull re

[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: flink-libraries/

[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&focusedCommentId=16672016#comment-16672016 ] ASF GitHub Bot commented on FLINK-10696: xuefuz commented on a change in pull re

[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: flink-libraries/

[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 SavepointV2Serializ

[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&focusedCommentId=16671914#comment-16671914 ] ASF GitHub Bot commented on FLINK-10720: zentol commented on a change in pull re

[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&focusedCommentId=16671910#comment-16671910 ] ASF GitHub Bot commented on FLINK-10720: zentol commented on a change in pull re

[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&focusedCommentId=16671909#comment-16671909 ] ASF GitHub Bot commented on FLINK-10720: zentol commented on a change in pull re

[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&focusedCommentId=16671908#comment-16671908 ] ASF GitHub Bot commented on FLINK-10720: zentol commented on a change in pull re

[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&focusedCommentId=16671906#comment-16671906 ] ASF GitHub Bot commented on FLINK-10631: tillrohrmann closed pull request #6978:

[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 https://github.com/apache/flink/commit/6047321cd26904ea323cb8c2

[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 provenance:

[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&focusedCommentId=16671905#comment-16671905 ] ASF GitHub Bot commented on FLINK-10631: tillrohrmann commented on issue #6978:

[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&focusedCommentId=16671899#comment-16671899 ] ASF GitHub Bot commented on FLINK-10631: tillrohrmann commented on a change in p

[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&focusedCommentId=16671885#comment-16671885 ] Till Rohrmann commented on FLINK-10685: --- What exactly is the scope of this issue [

[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&focusedCommentId=16671881#comment-16671881 ] Till Rohrmann commented on FLINK-10703: --- I think all accesses to {{numPendingConta

[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&focusedCommentId=16671878#comment-16671878 ] Till Rohrmann commented on FLINK-10629: --- Another instance: https://api.travis-ci.o

[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&focusedCommentId=16671867#comment-16671867 ] Till Rohrmann commented on FLINK-10712: --- Thanks a lot for contributing [~yunta].

[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&focusedCommentId=16671865#comment-16671865 ] Till Rohrmann commented on FLINK-10713: --- I would not say so because this restart s

[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&focusedCommentId=16671863#comment-16671863 ] Timo Walther commented on FLINK-10711: -- [~hequn8128] have you started already? I wo

[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 will

[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&focusedCommentId=16671862#comment-16671862 ] Till Rohrmann commented on FLINK-10734: --- Do we want to fix this for {{1.7.0}} [~pn

[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&focusedCommentId=16671861#comment-16671861 ] Till Rohrmann commented on FLINK-10735: --- Thanks for reporting this issue [~ffjl198

[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 when

[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 > -

  1   2   3   4   >