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

[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671163#comment-16671163 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#discussion_r229950857 ## File path: flink-examples/flink-examples-streaming/pom.xml ## @@ -60,6 +60,1

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

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671151#comment-16671151 ] 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

tweise commented on issue #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#issuecomment-434940116 R: @jgrier @aljoscha @tzulitai This is an automated mess

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

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5697: -- Labels: pull-request-available (was: ) > Add per-shard watermarks for FlinkKinesisConsumer > -

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

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671149#comment-16671149 ] 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

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

[jira] [Commented] (FLINK-10678) Add a switch to run_test to configure if logs should be checked for errors/excepions

[ https://issues.apache.org/jira/browse/FLINK-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671128#comment-16671128 ] ASF GitHub Bot commented on FLINK-10678: tzulitai commented on a change in pull

[GitHub] tzulitai commented on a change in pull request #6959: [FLINK-10678][e2e] Introduced switch to disable log checking in e2e tests

tzulitai commented on a change in pull request #6959: [FLINK-10678][e2e] Introduced switch to disable log checking in e2e tests URL: https://github.com/apache/flink/pull/6959#discussion_r229943007 ## File path: flink-end-to-end-tests/run-nightly-tests.sh ## @@ -41,19 +41,1

[jira] [Commented] (FLINK-10661) Initial credit should be configured in a separate parameter

[ https://issues.apache.org/jira/browse/FLINK-10661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671068#comment-16671068 ] zhijiang commented on FLINK-10661: -- [~NicoK], do you have any other suggestions for thi

[jira] [Updated] (FLINK-10168) Add FileFilter interface and FileModTimeFilter which sets a read start position for files by modification time

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10168: - Summary: Add FileFilter interface and FileModTimeFilter which sets a read start position for files by mo

[jira] [Updated] (FLINK-10168) support reading files whose modification time is after a given timestamp

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10168: --- Labels: pull-request-available (was: ) > support reading files whose modification time is a

[jira] [Commented] (FLINK-10168) support reading files whose modification time is after a given timestamp

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671066#comment-16671066 ] ASF GitHub Bot commented on FLINK-10168: bowenli86 opened a new pull request #69

[GitHub] bowenli86 opened a new pull request #6979: [FLINK-10168] Add FileFilter interface and FileModTimeFilter which sets a read start position for files by modification time

bowenli86 opened a new pull request #6979: [FLINK-10168] Add FileFilter interface and FileModTimeFilter which sets a read start position for files by modification time URL: https://github.com/apache/flink/pull/6979 ## What is the purpose of the change The motivation is 1. en

[jira] [Updated] (FLINK-10168) support reading files whose modification time is after a given timestamp

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10168: - Description: Update: The motivation is 1) enabling users to set a read start position for files, so the

[jira] [Commented] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate

[ https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671053#comment-16671053 ] ASF GitHub Bot commented on FLINK-10367: zhijiangW commented on issue #6829: [FL

[GitHub] zhijiangW commented on issue #6829: [FLINK-10367][network] Introduce NotificationResult for BufferListener to solve recursive stack overflow

zhijiangW commented on issue #6829: [FLINK-10367][network] Introduce NotificationResult for BufferListener to solve recursive stack overflow URL: https://github.com/apache/flink/pull/6829#issuecomment-434916161 @NicoK , do you think this pr is necessary to be covered in flink-1.7?

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

[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671052#comment-16671052 ] Yun Gao commented on FLINK-10742: - Hi Nico, we have also worked on this problem in recen

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

[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-10742: Attachment: (was: ZeroCopyNettyMessageDecoder.java) > Let Netty use Flink's buffers directly in credit

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

[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-10742: Attachment: ZeroCopyNettyMessageDecoder.java > Let Netty use Flink's buffers directly in credit-based mode

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

[ https://issues.apache.org/jira/browse/FLINK-10735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fei Feng updated FLINK-10735: - Labels: yarn (was: ) > flink on yarn close container exception > --

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

[ https://issues.apache.org/jira/browse/FLINK-10735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fei Feng updated FLINK-10735: - Description: flink on yarn with detached mode, when cancle flink job，yarn resource release very slow！

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

[ https://issues.apache.org/jira/browse/FLINK-10735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fei Feng updated FLINK-10735: - Environment: Hadoop 2.7 flink 1.6.2 Component/s: TaskManager ResourceManager > fl

[jira] [Updated] (FLINK-10744) Integrate Flink with Hive metastore

[ https://issues.apache.org/jira/browse/FLINK-10744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10744: Description: This JIRA keeps track of the effort of FLINK-10556 on Hive metastore integration. It

[jira] [Updated] (FLINK-10542) Implement an external catalog for Hive

[ https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10542: Description: Similar to FLINK-2167 but rather register Hive metastore as an external catalog in t

[jira] [Updated] (FLINK-10673) Table API / SQL UIDs not the only one

[ https://issues.apache.org/jira/browse/FLINK-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fan weiwen updated FLINK-10673: --- Description: a job  have two sql  source is kafka  sink is redis  or other sink  Asql  {code:java

[jira] [Updated] (FLINK-10673) Table API / SQL UIDs not the only one

[ https://issues.apache.org/jira/browse/FLINK-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fan weiwen updated FLINK-10673: --- Description: a job  have two sql  source is kafka  sink is redis  or other sink  Asql  {code:java

[jira] [Assigned] (FLINK-10733) Misleading clean_log_files() in common.sh

[ https://issues.apache.org/jira/browse/FLINK-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10733: Assignee: vinoyang > Misleading clean_log_files() in common.sh >

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

[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670609#comment-16670609 ] Xuefu Zhang edited comment on FLINK-10556 at 10/31/18 11:04 PM: --

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

[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670873#comment-16670873 ] Xuefu Zhang commented on FLINK-10556: - The Google doc for the proposal can be found

[jira] [Issue Comment Deleted] (FLINK-10556) Integration with Apache Hive

[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10556: Comment: was deleted (was: Google doc for the design can be found at https://docs.google.com/docu

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

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

[jira] [Updated] (FLINK-10698) Create CatalogManager class manages all external catalogs and temporary meta objects

[ https://issues.apache.org/jira/browse/FLINK-10698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10698: Issue Type: Sub-task (was: Bug) Parent: FLINK-10744 > Create CatalogManager class manages

[jira] [Updated] (FLINK-10698) Create CatalogManager class manages all external catalogs and temporary meta objects

[ https://issues.apache.org/jira/browse/FLINK-10698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10698: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-10556) > Create CatalogManager cl

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

[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670867#comment-16670867 ] Xuefu Zhang commented on FLINK-10729: - Hi [~ZhenqiuHuang], Sure. Thanks for your int

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

[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10729: Summary: Create a Hive connector to access Hive data (was: Create a Hive a connector to access Hi

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

[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10729: Summary: Create a Hive connector for Hive data access in Flink (was: Create a Hive connector to a

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

[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10729: Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-10556) > Create a Hive a

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

[ https://issues.apache.org/jira/browse/FLINK-10699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10699: Issue Type: Sub-task (was: Bug) Parent: FLINK-10744 > Create a catalog implementation for

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

[ https://issues.apache.org/jira/browse/FLINK-10699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10699: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-10556) > Create a catalog impleme

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

[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670861#comment-16670861 ] Xuefu Zhang commented on FLINK-10697: - This covers the in-memory implementation ment

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

[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10697: Issue Type: Sub-task (was: Bug) Parent: FLINK-10744 > Create an in-memory catalog that st

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

[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10697: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-10556) > Create an in-memory cata

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

[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10696: Issue Type: Sub-task (was: Bug) Parent: FLINK-10744 > Add APIs to ExternalCatalog for vie

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

[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10696: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-10556) > Add APIs to ExternalCata

[jira] [Updated] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10618: Description: This JIRA covers the 2nd aspect of Flink-Hive metastore integration. Besides meta ob

[jira] [Updated] (FLINK-10744) Integrate Flink with Hive metastore

[ https://issues.apache.org/jira/browse/FLINK-10744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10744: Description: This JIRA keeps track of the effort of FLINK-10556 on Hive metastore integration. It

[jira] [Updated] (FLINK-10744) Integrate Flink with Hive metastore

[ https://issues.apache.org/jira/browse/FLINK-10744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10744: Description: To be specified (was: This JIRA keeps track of the effort of FLINK-10556 on Hive met

[jira] [Updated] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10618: Issue Type: Sub-task (was: New Feature) Parent: FLINK-10744 > Introduce catalog for Flink

[jira] [Comment Edited] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670796#comment-16670796 ] Xuefu Zhang edited comment on FLINK-10618 at 10/31/18 10:21 PM: --

[jira] [Commented] (FLINK-10744) Integrate Flink with Hive metastore

[ https://issues.apache.org/jira/browse/FLINK-10744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670836#comment-16670836 ] Xuefu Zhang commented on FLINK-10744: - The design is available as a [Google doc|htt

[jira] [Updated] (FLINK-10542) Implement an external catalog for Hive

[ https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10542: Description: Similar to FLINK-2167 but rather register Hive metastore as an external catalog in t

[jira] [Updated] (FLINK-10542) Register Hive metastore as an external catalog in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10542: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-10556) > Register Hive metastore

[jira] [Updated] (FLINK-10542) Register Hive metastore as an external catalog in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10542: Issue Type: Sub-task (was: Bug) Parent: FLINK-10744 > Register Hive metastore as an exter

[jira] [Created] (FLINK-10744) Integrate Flink with Hive metastore

Xuefu Zhang created FLINK-10744: --- Summary: Integrate Flink with Hive metastore Key: FLINK-10744 URL: https://issues.apache.org/jira/browse/FLINK-10744 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670796#comment-16670796 ] Xuefu Zhang commented on FLINK-10618: - Here is the link to the design doc, which cov

[jira] [Updated] (FLINK-10698) Create CatalogManager class manages all external catalogs and temporary meta objects

[ https://issues.apache.org/jira/browse/FLINK-10698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10698: - Fix Version/s: 1.8.0 > Create CatalogManager class manages all external catalogs and temporary meta > o

[jira] [Commented] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670794#comment-16670794 ] Xuefu Zhang commented on FLINK-10618: - Hi [~dangdangdang] and [~twalthr], Thanks for

[jira] [Assigned] (FLINK-10698) Create CatalogManager class manages all external catalogs and temporary meta objects

[ https://issues.apache.org/jira/browse/FLINK-10698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-10698: Assignee: Bowen Li (was: winifredtang) > Create CatalogManager class manages all external catalo

[jira] [Commented] (FLINK-10698) Create CatalogManager class manages all external catalogs and temporary meta objects

[ https://issues.apache.org/jira/browse/FLINK-10698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670792#comment-16670792 ] Bowen Li commented on FLINK-10698: -- Hi [~winipanda], I'm working on this and will assig

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

Ufuk Celebi created FLINK-10743: --- Summary: Use 0 processExitCode for ApplicationStatus.CANCELED Key: FLINK-10743 URL: https://issues.apache.org/jira/browse/FLINK-10743 Project: Flink Issue Type

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

[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670683#comment-16670683 ] Bowen Li commented on FLINK-10556: -- I agree. It's not urgent to consider for now, and i

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

[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670609#comment-16670609 ] Xuefu Zhang commented on FLINK-10556: - [~phoenixjiangnan] Thanks for your feedback.

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

[ https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670598#comment-16670598 ] Bowen Li edited comment on FLINK-10686 at 10/31/18 7:19 PM:

[jira] [Comment Edited] (FLINK-10689) Port Table API extension points to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670596#comment-16670596 ] Bowen Li edited comment on FLINK-10689 at 10/31/18 7:18 PM:

[jira] [Comment Edited] (FLINK-10689) Port Table API extension points to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670596#comment-16670596 ] Bowen Li edited comment on FLINK-10689 at 10/31/18 7:17 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670598#comment-16670598 ] Bowen Li commented on FLINK-10686: -- How about parallelize the subtasks of FLINK-10688 a

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

[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670599#comment-16670599 ] Xuefu Zhang commented on FLINK-10556: - Google doc for the design can be found at ht

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

[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670596#comment-16670596 ] Bowen Li commented on FLINK-10689: -- How about reorder the subtasks? Given that FLINK-1

[jira] [Commented] (FLINK-10627) Extend test_streaming_file_sink to test S3 writer

[ https://issues.apache.org/jira/browse/FLINK-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670580#comment-16670580 ] ASF GitHub Bot commented on FLINK-10627: azagrebin commented on issue #6957: [FL

[GitHub] azagrebin commented on issue #6957: [FLINK-10627][E2E tests] Test s3 output for streaming file sink

azagrebin commented on issue #6957: [FLINK-10627][E2E tests] Test s3 output for streaming file sink URL: https://github.com/apache/flink/pull/6957#issuecomment-434810438 thanks @kl0u, I have rebased and addressed the issue Th

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

[ https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10696: - Fix Version/s: 1.8.0 > Add APIs to ExternalCatalog for views and UDFs >

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

[ https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10697: - Fix Version/s: 1.8.0 > Create an in-memory catalog that stores Flink's meta objects > --

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

[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10556: - Labels: (was: pull-request-available) > Integration with Apache Hive > >

[jira] [Commented] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA library installed

[ https://issues.apache.org/jira/browse/FLINK-10681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670425#comment-16670425 ] ASF GitHub Bot commented on FLINK-10681: tillrohrmann commented on a change in p

[GitHub] tillrohrmann commented on a change in pull request #6928: [FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library

tillrohrmann commented on a change in pull request #6928: [FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library URL: https://github.com/apache/flink/pull/6928#discussion_r229796033 ## File path: flink-connectors/flink-connector-elasticsearch6/pom.xml ## @@

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

Nico Kruber created FLINK-10742: --- Summary: Let Netty use Flink's buffers directly in credit-based mode Key: FLINK-10742 URL: https://issues.apache.org/jira/browse/FLINK-10742 Project: Flink Is

[jira] [Updated] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10356: Issue Type: Sub-task (was: Improvement) Parent: FLINK-3462 > Add sanity checks to Spillin

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

[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-10712: Assignee: Yun Tang > RestartPipelinedRegionStrategy does not restore state >

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

[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670361#comment-16670361 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#discussion_r229773839 ## File path: flink-examples/flink-examples-streaming/pom.xml ## @@ -60,6 +60,1

[jira] [Commented] (FLINK-10097) More tests to increase StreamingFileSink test coverage

[ https://issues.apache.org/jira/browse/FLINK-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670357#comment-16670357 ] ASF GitHub Bot commented on FLINK-10097: kl0u commented on issue #6520: [FLINK-1

[GitHub] kl0u commented on issue #6520: [FLINK-10097][DataStream API] Additional tests for StreamingFileSink

kl0u commented on issue #6520: [FLINK-10097][DataStream API] Additional tests for StreamingFileSink URL: https://github.com/apache/flink/pull/6520#issuecomment-434757251 I will wait for Travis to give green and then I will merge.

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670350#comment-16670350 ] Timo Walther commented on FLINK-10704: -- [~yanghua] you can simply print the origina

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670348#comment-16670348 ] ASF GitHub Bot commented on FLINK-10704: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6963: [FLINK-10704] Fix sql client end to end test failure

yanghua commented on a change in pull request #6963: [FLINK-10704] Fix sql client end to end test failure URL: https://github.com/apache/flink/pull/6963#discussion_r229771519 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -316,7 +316,7 @@ function check_

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670343#comment-16670343 ] vinoyang commented on FLINK-10704: -- [~twalthr] About [another error|https://issues.apa

[jira] [Created] (FLINK-10741) GraphOperationsITCase.testFilterOnVerticesSugar deadlocks on Travis

Till Rohrmann created FLINK-10741: - Summary: GraphOperationsITCase.testFilterOnVerticesSugar deadlocks on Travis Key: FLINK-10741 URL: https://issues.apache.org/jira/browse/FLINK-10741 Project: Flink

[jira] [Commented] (FLINK-10730) How to resume Flink SQL Job ?

[ https://issues.apache.org/jira/browse/FLINK-10730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670340#comment-16670340 ] xinzhang commented on FLINK-10730: -- Thanks for your reply. You  are right. It was quite

[jira] [Commented] (FLINK-10730) How to resume Flink SQL Job ?

[ https://issues.apache.org/jira/browse/FLINK-10730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670329#comment-16670329 ] xinzhang commented on FLINK-10730: -- No.It's wrong. > How to resume Flink SQL Job ? > -

[jira] [Created] (FLINK-10740) Refactor Source Interface

Aljoscha Krettek created FLINK-10740: Summary: Refactor Source Interface Key: FLINK-10740 URL: https://issues.apache.org/jira/browse/FLINK-10740 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-10581) YarnConfigurationITCase.testFlinkContainerMemory test instability

[ https://issues.apache.org/jira/browse/FLINK-10581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670308#comment-16670308 ] Dawid Wysakowicz commented on FLINK-10581: -- I do suspect it is because of how {

[jira] [Commented] (FLINK-10730) How to resume Flink SQL Job ?

[ https://issues.apache.org/jira/browse/FLINK-10730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670280#comment-16670280 ] Timo Walther commented on FLINK-10730: -- [~zhangxin0112zx] you should keep in mind t

[GitHub] kl0u commented on a change in pull request #6520: [FLINK-10097][DataStream API] Additional tests for StreamingFileSink

kl0u commented on a change in pull request #6520: [FLINK-10097][DataStream API] Additional tests for StreamingFileSink URL: https://github.com/apache/flink/pull/6520#discussion_r229754154 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink

[jira] [Commented] (FLINK-10097) More tests to increase StreamingFileSink test coverage

[ https://issues.apache.org/jira/browse/FLINK-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670276#comment-16670276 ] ASF GitHub Bot commented on FLINK-10097: kl0u commented on a change in pull requ

[jira] [Assigned] (FLINK-10581) YarnConfigurationITCase.testFlinkContainerMemory test instability

[ https://issues.apache.org/jira/browse/FLINK-10581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10581: Assignee: Dawid Wysakowicz > YarnConfigurationITCase.testFlinkContainerMemory tes

[GitHub] kl0u commented on a change in pull request #6520: [FLINK-10097][DataStream API] Additional tests for StreamingFileSink

kl0u commented on a change in pull request #6520: [FLINK-10097][DataStream API] Additional tests for StreamingFileSink URL: https://github.com/apache/flink/pull/6520#discussion_r229753716 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink

[jira] [Commented] (FLINK-10097) More tests to increase StreamingFileSink test coverage

[ https://issues.apache.org/jira/browse/FLINK-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670272#comment-16670272 ] ASF GitHub Bot commented on FLINK-10097: kl0u commented on a change in pull requ

[jira] [Commented] (FLINK-10730) How to resume Flink SQL Job ?

[ https://issues.apache.org/jira/browse/FLINK-10730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670270#comment-16670270 ] xinzhang commented on FLINK-10730: -- any way.I got solve the problem. Any one wants help

[jira] [Commented] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16670261#comment-16670261 ] Timo Walther commented on FLINK-10618: -- Yes, a design doc would be very helpful. It

  1   2   3   4   >