[GitHub] [flink] flinkbot edited a comment on issue #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common URL: https://github.com/apache/flink/pull/7642#issuecomment-459762314 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Commented] (FLINK-11803) Improve FlinkTypeFactory for Blink

2019-03-04 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783121#comment-16783121 ] Jingsong Lee commented on FLINK-11803: -- I think we should use InternalType in table interaction

[GitHub] [flink] KurtYoung commented on issue #7881: [FLINK-11795][table-planner-blink] Introduce DataStream nodes and converter rules for batch and stream

2019-03-04 Thread GitBox
KurtYoung commented on issue #7881: [FLINK-11795][table-planner-blink] Introduce DataStream nodes and converter rules for batch and stream URL: https://github.com/apache/flink/pull/7881#issuecomment-469173549 @twalthr I think you can have a quick look at this, it contains the building

[GitHub] [flink] wuchong commented on issue #7886: [FLINK-11801] [table-common] Port SqlParserException to flink-table-common

2019-03-04 Thread GitBox
wuchong commented on issue #7886: [FLINK-11801] [table-common] Port SqlParserException to flink-table-common URL: https://github.com/apache/flink/pull/7886#issuecomment-469186088 @twalthr that makes sense to me. Will move it to `flink-table-api-java`.

[GitHub] [flink] wuchong commented on issue #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java

2019-03-04 Thread GitBox
wuchong commented on issue #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java URL: https://github.com/apache/flink/pull/7888#issuecomment-469191172 Thanks @twalthr . I accidentally pushed the wrong branch to apache/flink, so I have to create a new

[GitHub] [flink] KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261983787 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261988395 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261985554 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261982598 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r262002568 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r262003015 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] twalthr commented on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats

2019-03-04 Thread GitBox
twalthr commented on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats URL: https://github.com/apache/flink/pull/7838#issuecomment-469208512 #7642 has been merged. One comment about the package location of `TableStats` and `ColumnStats`: Once we expose those

[GitHub] [flink] flinkbot edited a comment on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7838: [FLINK-11711][table-planner-blink] Add table and column stats URL: https://github.com/apache/flink/pull/7838#issuecomment-467405536 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Assigned] (FLINK-11659) Implement HadoopMapFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11659: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopMapFunctionITCase for new

[jira] [Assigned] (FLINK-11660) Implement HadoopReduceFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11660: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopReduceFunctionITCase for new

[jira] [Assigned] (FLINK-11661) Implement HadoopReduceCombineFunctionITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11661: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopReduceCombineFunctionITCase

[jira] [Assigned] (FLINK-11658) Implement HadoopMapreduceITCase for new Hadoop API

2019-03-04 Thread TANG Wen-hui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TANG Wen-hui reassigned FLINK-11658: Assignee: TANG Wen-hui (was: vinoyang) > Implement HadoopMapreduceITCase for new Hadoop

[jira] [Issue Comment Deleted] (FLINK-11439) INSERT INTO flink_sql SELECT * FROM blink_sql

2019-03-04 Thread hery168 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hery168 updated FLINK-11439: Comment: was deleted (was: 留名) > INSERT INTO flink_sql SELECT * FROM blink_sql >

[GitHub] [flink] JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r262001647 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#discussion_r262008151 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#discussion_r262008151 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
tillrohrmann commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#issuecomment-469213347 `#closeAndCleanupAllData` should only be called by the `ClusterEntrypoint` which transitions the

[jira] [Updated] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11665: --- Labels: pull-request-available (was: ) > Flink fails to remove JobGraph from ZK even

[jira] [Closed] (FLINK-11791) Describe how to build Flink with Hadoop in build guide

2019-03-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11791. Resolution: Fixed Merged on release-1.8 in dfac0e236f0479001c3f65e5d9cbfbe329316444

[GitHub] [flink] dianfu commented on issue #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common

2019-03-04 Thread GitBox
dianfu commented on issue #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common URL: https://github.com/apache/flink/pull/7642#issuecomment-469190736 @twalthr @godfreyhe Thanks a lot for the review and commit.

[GitHub] [flink] flinkbot edited a comment on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#issuecomment-468714635 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261996563 ## File path:

[jira] [Updated] (FLINK-11801) Port SqlParserException to flink-table-api-java

2019-03-04 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11801: Summary: Port SqlParserException to flink-table-api-java (was: Port SqlParserException to

[GitHub] [flink] azagrebin opened a new pull request #7889: [FLINK-11665] Wait for job termination before recovery in Dispatcher

2019-03-04 Thread GitBox
azagrebin opened a new pull request #7889: [FLINK-11665] Wait for job termination before recovery in Dispatcher URL: https://github.com/apache/flink/pull/7889 ## What is the purpose of the change This PR addresses a concurrency problem when dispatcher loses leadership and

[GitHub] [flink] TisonKun commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
TisonKun commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#issuecomment-469213864 Thanks for the explanation! This is an

[GitHub] [flink] wuchong closed pull request #7886: [FLINK-11801] [table-common] Port SqlParserException to flink-table-common

2019-03-04 Thread GitBox
wuchong closed pull request #7886: [FLINK-11801] [table-common] Port SqlParserException to flink-table-common URL: https://github.com/apache/flink/pull/7886 This is an automated message from the Apache Git Service. To

[GitHub] [flink] wuchong commented on issue #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java

2019-03-04 Thread GitBox
wuchong commented on issue #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java URL: https://github.com/apache/flink/pull/7888#issuecomment-469191574 Will merge this when travis green. This is an

[GitHub] [flink] tillrohrmann commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
tillrohrmann commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#discussion_r261990026 ## File path:

[jira] [Updated] (FLINK-11801) Port SqlParserException to flink-table-api-java

2019-03-04 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11801: Description: A more detailed description can be found in FLIP-32. SqlParserException is used in

[GitHub] [flink] KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261989486 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261984041 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r261997361 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r262002836 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] link3280 closed pull request #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

2019-03-04 Thread GitBox
link3280 closed pull request #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7294 This is an automated message from the Apache Git Service. To

[GitHub] [flink] pnowojski commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2019-03-04 Thread GitBox
pnowojski commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-469230797 @gaoyunhaii Could you provide benchmark results (https://github.com/dataArtisans/flink-benchmarks/)

[jira] [Created] (FLINK-11806) Import shaded jetcd

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11806: -- Summary: Import shaded jetcd Key: FLINK-11806 URL: https://issues.apache.org/jira/browse/FLINK-11806 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-11804) Make sure the CloseableRegistry used in backend builder is registered with task

2019-03-04 Thread Yu Li (JIRA)
Yu Li created FLINK-11804: - Summary: Make sure the CloseableRegistry used in backend builder is registered with task Key: FLINK-11804 URL: https://issues.apache.org/jira/browse/FLINK-11804 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #7879: [FLINK-11791] Describe how to build Flink with Hadoop in build guide

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7879: [FLINK-11791] Describe how to build Flink with Hadoop in build guide URL: https://github.com/apache/flink/pull/7879#issuecomment-468697094 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] aljoscha merged pull request #7879: [FLINK-11791] Describe how to build Flink with Hadoop in build guide

2019-03-04 Thread GitBox
aljoscha merged pull request #7879: [FLINK-11791] Describe how to build Flink with Hadoop in build guide URL: https://github.com/apache/flink/pull/7879 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on issue #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#issuecomment-465643207 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java URL: https://github.com/apache/flink/pull/7888#issuecomment-469190012 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261995509 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
JingsongLi commented on a change in pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887#discussion_r261995451 ## File path:

[jira] [Closed] (FLINK-11516) Port and move some Descriptor classes to flink-table-common

2019-03-04 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11516. Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0:

[GitHub] [flink] asfgit closed pull request #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common

2019-03-04 Thread GitBox
asfgit closed pull request #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common URL: https://github.com/apache/flink/pull/7642 This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot commented on issue #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java

2019-03-04 Thread GitBox
flinkbot commented on issue #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java URL: https://github.com/apache/flink/pull/7888#issuecomment-469190012 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] wuchong opened a new pull request #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java

2019-03-04 Thread GitBox
wuchong opened a new pull request #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java URL: https://github.com/apache/flink/pull/7888 ## What is the purpose of the change Port `SqlParserException` to flink-table-api-java

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r261995328 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r261995487 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[GitHub] [flink] flinkbot edited a comment on issue #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#issuecomment-468623662 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262006927 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r261995376 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262005789 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r261997545 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r261997948 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r261996108 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#issuecomment-468420125 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot commented on issue #7889: [FLINK-11665] Wait for job termination before recovery in Dispatcher

2019-03-04 Thread GitBox
flinkbot commented on issue #7889: [FLINK-11665] Wait for job termination before recovery in Dispatcher URL: https://github.com/apache/flink/pull/7889#issuecomment-469214275 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] tillrohrmann commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData

2019-03-04 Thread GitBox
tillrohrmann commented on a change in pull request #7880: [FLINK-11336][zk] Delete ZNodes when ZooKeeperHaServices#closeAndCleanupAllData URL: https://github.com/apache/flink/pull/7880#discussion_r262018551 ## File path:

[jira] [Created] (FLINK-11805) A Common External Shuffle Service Framework

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11805: -- Summary: A Common External Shuffle Service Framework Key: FLINK-11805 URL: https://issues.apache.org/jira/browse/FLINK-11805 Project: Flink Issue Type:

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262044916 ## File path:

[jira] [Created] (FLINK-11809) Implement etcd based StateHandleStore

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11809: -- Summary: Implement etcd based StateHandleStore Key: FLINK-11809 URL: https://issues.apache.org/jira/browse/FLINK-11809 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11808) Implement etcd based SharedCount or sequencer

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders updated FLINK-11808: --- Description: Implement SharedCount or sequencer API using jetcd. CheckpointIDCounter is

[GitHub] [flink] flinkbot commented on issue #7891: WIP: Gcs filesystem

2019-03-04 Thread GitBox
flinkbot commented on issue #7891: WIP: Gcs filesystem URL: https://github.com/apache/flink/pull/7891#issuecomment-469250075 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to

[jira] [Updated] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders updated FLINK-11810: --- Description: Implement CheckpointRecoveryFactory using jetcd. A CheckpointRecoveryFactory

[jira] [Created] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11811: -- Summary: Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore Key: FLINK-11811 URL: https://issues.apache.org/jira/browse/FLINK-11811 Project:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262069510 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262072838 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #7747: [FLINK-11653][DataStream] Add configuration to enforce custom UID's o…

2019-03-04 Thread GitBox
flinkbot edited a comment on issue #7747: [FLINK-11653][DataStream] Add configuration to enforce custom UID's o… URL: https://github.com/apache/flink/pull/7747#issuecomment-464851132 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] Salatich opened a new pull request #7892: [FLINK-5080] [Connectors / Cassandra] Cassandra connector ignores saveAsync result onSuccess

2019-03-04 Thread GitBox
Salatich opened a new pull request #7892: [FLINK-5080] [Connectors / Cassandra] Cassandra connector ignores saveAsync result onSuccess URL: https://github.com/apache/flink/pull/7892 ## What is the purpose of the change Add possibility of passing a custom callback in

[GitHub] [flink] dawidwys merged pull request #7747: [FLINK-11653][DataStream] Add configuration to enforce custom UID's o…

2019-03-04 Thread GitBox
dawidwys merged pull request #7747: [FLINK-11653][DataStream] Add configuration to enforce custom UID's o… URL: https://github.com/apache/flink/pull/7747 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] dawidwys opened a new pull request #7894: [FLINK-11420][core] Fixed duplicate method of TraversableSerializer

2019-03-04 Thread GitBox
dawidwys opened a new pull request #7894: [FLINK-11420][core] Fixed duplicate method of TraversableSerializer URL: https://github.com/apache/flink/pull/7894 backport of #7872 See the description there. This is an automated

[jira] [Commented] (FLINK-11439) INSERT INTO flink_sql SELECT * FROM blink_sql

2019-03-04 Thread hery168 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783323#comment-16783323 ] hery168 commented on FLINK-11439: - 留名 > INSERT INTO flink_sql SELECT * FROM blink_sql >

[jira] [Commented] (FLINK-11782) Enhance TaskManager log visualization by listing all log files for Flink web UI

2019-03-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783339#comment-16783339 ] vinoyang commented on FLINK-11782: -- [~StephanEwen] [~till.rohrmann] and [~Zentol] If we don't pay

[jira] [Created] (FLINK-11808) etcd based SharedCount or sequencer

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11808: -- Summary: etcd based SharedCount or sequencer Key: FLINK-11808 URL: https://issues.apache.org/jira/browse/FLINK-11808 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #7890: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization

2019-03-04 Thread GitBox
flinkbot commented on issue #7890: [FLINK-9003][E2E] Add operators with input type that goes through custom, stateful serialization URL: https://github.com/apache/flink/pull/7890#issuecomment-469246128 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262052014 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262052077 ## File path:

[jira] [Closed] (FLINK-11802) Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11802. -- Resolution: Implemented Fix Version/s: 1.9.0 > Create TypeInfo and TypeSerializer for blink

[jira] [Commented] (FLINK-11802) Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783377#comment-16783377 ] Kurt Young commented on FLINK-11802: implemented in 76eb0397041915c867df57b7e2478caca3afd7bd >

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262062202 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262062202 ## File path:

[GitHub] [flink] KurtYoung closed pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format

2019-03-04 Thread GitBox
KurtYoung closed pull request #7887: [FLINK-11802][table-runtime-blink] Create TypeInfo and TypeSerializer for blink data format URL: https://github.com/apache/flink/pull/7887 This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on issue #7892: [FLINK-5080] [Connectors / Cassandra] Cassandra connector ignores saveAsync result onSuccess

2019-03-04 Thread GitBox
flinkbot commented on issue #7892: [FLINK-5080] [Connectors / Cassandra] Cassandra connector ignores saveAsync result onSuccess URL: https://github.com/apache/flink/pull/7892#issuecomment-469271492 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Updated] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess

2019-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5080: -- Labels: pull-request-available (was: ) > Cassandra connector ignores saveAsync result

[GitHub] [flink] leesf opened a new pull request #7893: [hotfix] Fix checkstyle violations and remove unnecessary symbol in IOManagerAsync

2019-03-04 Thread GitBox
leesf opened a new pull request #7893: [hotfix] Fix checkstyle violations and remove unnecessary symbol in IOManagerAsync URL: https://github.com/apache/flink/pull/7893 Fix checkstyle violations and remove unnecessary symbol in IOManagerAsync

[GitHub] [flink] asfgit closed pull request #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java

2019-03-04 Thread GitBox
asfgit closed pull request #7888: [FLINK-11801] [table-api] Port SqlParserException to flink-table-api-java URL: https://github.com/apache/flink/pull/7888 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
StefanRRichter commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262099480 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #7883: [FLINK-11781][yarn] Remove "DISABLED" as possible value for yarn.per-job-cluster.include-user-jar

2019-03-04 Thread GitBox
GJL commented on a change in pull request #7883: [FLINK-11781][yarn] Remove "DISABLED" as possible value for yarn.per-job-cluster.include-user-jar URL: https://github.com/apache/flink/pull/7883#discussion_r262099481 ## File path:

[jira] [Closed] (FLINK-11801) Port SqlParserException to flink-table-api-java

2019-03-04 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11801. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9: eb683e5db2f8eafc927f7c77579cf1109375479a >

[jira] [Created] (FLINK-11807) Implement etcd based LeaderElectionService and LeaderRetrievalService

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11807: -- Summary: Implement etcd based LeaderElectionService and LeaderRetrievalService Key: FLINK-11807 URL: https://issues.apache.org/jira/browse/FLINK-11807 Project:

[GitHub] [flink] carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-03-04 Thread GitBox
carp84 commented on a change in pull request #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#discussion_r262044190 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8

2019-03-04 Thread GitBox
aljoscha commented on a change in pull request #7876: [FLINK-11751] Extend release notes for Flink 1.8 URL: https://github.com/apache/flink/pull/7876#discussion_r262048964 ## File path: docs/release-notes/#flink-1.8.md# ## @@ -0,0 +1,174 @@ + Notes - Flink 1.8" +--- + + +

[jira] [Updated] (FLINK-11808) etcd based SharedCount or sequencer

2019-03-04 Thread MalcolmSanders (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MalcolmSanders updated FLINK-11808: --- Component/s: Runtime / Coordination > etcd based SharedCount or sequencer >

[jira] [Created] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11810: -- Summary: Implement etcd based CheckpointRecoveryFactory Key: FLINK-11810 URL: https://issues.apache.org/jira/browse/FLINK-11810 Project: Flink Issue

  1   2   3   >