[jira] [Created] (FLINK-12240) Support view related operations in GenericHiveMetastoreCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12240: Summary: Support view related operations in GenericHiveMetastoreCatalog Key: FLINK-12240 URL: https://issues.apache.org/jira/browse/FLINK-12240 Project: Flink

[jira] [Created] (FLINK-12239) Support table related operations in GenericHiveMetastoreCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12239: Summary: Support table related operations in GenericHiveMetastoreCatalog Key: FLINK-12239 URL: https://issues.apache.org/jira/browse/FLINK-12239 Project: Flink

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

2019-04-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820414#comment-16820414 ] Stephan Ewen commented on FLINK-12070: -- [~Ryantaocer] Can you explain this comment a bit more:

[jira] [Created] (FLINK-12238) Support database related operations in GenericHiveMetastoreCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12238: Summary: Support database related operations in GenericHiveMetastoreCatalog Key: FLINK-12238 URL: https://issues.apache.org/jira/browse/FLINK-12238 Project: Flink

[jira] [Created] (FLINK-12237) Support table stats related operations in HiveCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12237: Summary: Support table stats related operations in HiveCatalog Key: FLINK-12237 URL: https://issues.apache.org/jira/browse/FLINK-12237 Project: Flink Issue Type:

[jira] [Created] (FLINK-12234) Support viewrelated operations in HiveCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12234: Summary: Support viewrelated operations in HiveCatalog Key: FLINK-12234 URL: https://issues.apache.org/jira/browse/FLINK-12234 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12235) Support partition related operations in HiveCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12235: Summary: Support partition related operations in HiveCatalog Key: FLINK-12235 URL: https://issues.apache.org/jira/browse/FLINK-12235 Project: Flink Issue Type:

[jira] [Created] (FLINK-12236) Support function related operations in HiveCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12236: Summary: Support function related operations in HiveCatalog Key: FLINK-12236 URL: https://issues.apache.org/jira/browse/FLINK-12236 Project: Flink Issue Type:

[jira] [Created] (FLINK-12233) Support table related operations in HiveCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12233: Summary: Support table related operations in HiveCatalog Key: FLINK-12233 URL: https://issues.apache.org/jira/browse/FLINK-12233 Project: Flink Issue Type: Sub-task

[GitHub] [flink] zentol commented on a change in pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder

2019-04-17 Thread GitBox
zentol commented on a change in pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder URL: https://github.com/apache/flink/pull/8199#discussion_r276358266 ## File path: flink-dist/pom.xml ## @@ -140,19 +140,54 @@ under the License.

[jira] [Created] (FLINK-12243) Support table stats related operations in GenericHiveMetastoreCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12243: Summary: Support table stats related operations in GenericHiveMetastoreCatalog Key: FLINK-12243 URL: https://issues.apache.org/jira/browse/FLINK-12243 Project: Flink

[jira] [Created] (FLINK-12242) Support partition related operations in GenericHiveMetastoreCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12242: Summary: Support partition related operations in GenericHiveMetastoreCatalog Key: FLINK-12242 URL: https://issues.apache.org/jira/browse/FLINK-12242 Project: Flink

[jira] [Updated] (FLINK-12232) Support database related operations in HiveCatalog

2019-04-17 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12232: - Description: Support database related operations in HiveCatalog, which implements

[jira] [Created] (FLINK-12232) Support database related operations in HiveCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12232: Summary: Support database related operations in HiveCatalog Key: FLINK-12232 URL: https://issues.apache.org/jira/browse/FLINK-12232 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11482) Implement GenericHiveMetastoreCatalog

2019-04-17 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-11482: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-11275) > Implement

[GitHub] [flink] zentol commented on a change in pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder

2019-04-17 Thread GitBox
zentol commented on a change in pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder URL: https://github.com/apache/flink/pull/8199#discussion_r276358266 ## File path: flink-dist/pom.xml ## @@ -140,19 +140,54 @@ under the License.

[jira] [Updated] (FLINK-11479) Implement HiveCatalog

2019-04-17 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-11479: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-11275) > Implement HiveCatalog

[jira] [Created] (FLINK-12241) Support function related operations in GenericHiveMetastoreCatalog

2019-04-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12241: Summary: Support function related operations in GenericHiveMetastoreCatalog Key: FLINK-12241 URL: https://issues.apache.org/jira/browse/FLINK-12241 Project: Flink

[jira] [Updated] (FLINK-12239) Support table related operations in GenericHiveMetastoreCatalog

2019-04-17 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12239: - Description: Support table related operations in GenericHiveMetastoreCatalog, which implements

[jira] [Updated] (FLINK-12238) Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-17 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12238: - Summary: Support database related operations in GenericHiveMetastoreCatalog and setup

[GitHub] [flink] sunjincheng121 commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-04-17 Thread GitBox
sunjincheng121 commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-484305219 Mergint... This is an automated

[GitHub] [flink] sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface

2019-04-17 Thread GitBox
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface URL: https://github.com/apache/flink/pull/8124#discussion_r276487477 ## File path:

[jira] [Updated] (FLINK-12214) Add JobListener (hook) in flink job lifecycle

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Summary: Add JobListener (hook) in flink job lifecycle (was: Add JobListener (hook) to in job

[jira] [Updated] (FLINK-12214) Add JobListener(hook) in flink job lifecycle

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Summary: Add JobListener(hook) in flink job lifecycle (was: Add JobListener (hook) in flink job

[jira] [Updated] (FLINK-12214) Add JobListener (hook) to in job lifecycle

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Summary: Add JobListener (hook) to in job lifecycle (was: Add JobListener to capture job

[GitHub] [flink] flinkbot commented on issue #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime

2019-04-17 Thread GitBox
flinkbot commented on issue #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime URL: https://github.com/apache/flink/pull/8202#issuecomment-484351023 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12133) Support unbounded aggregate in streaming table runtime

2019-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12133: --- Labels: pull-request-available (was: ) > Support unbounded aggregate in streaming table

[jira] [Updated] (FLINK-12208) Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-17 Thread Jing Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-12208: --- Summary: Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to

[jira] [Updated] (FLINK-12208) Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-17 Thread Jing Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-12208: --- Description: Introduce Sort / TemporalSort / SortLimit/ Limit operators for blink streaming

[GitHub] [flink] an0 commented on a change in pull request #8106: [FLINK-12092] [docs]Clarify when `onTimer(...)` is called

2019-04-17 Thread GitBox
an0 commented on a change in pull request #8106: [FLINK-12092] [docs]Clarify when `onTimer(...)` is called URL: https://github.com/apache/flink/pull/8106#discussion_r276471748 ## File path: docs/dev/stream/operators/process_function.md ## @@ -44,8 +44,8 @@ For

[GitHub] [flink] sunhaibotb commented on issue #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface

2019-04-17 Thread GitBox
sunhaibotb commented on issue #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface URL: https://github.com/apache/flink/pull/8124#issuecomment-484327998 > Please also squash/split commits so that we have three separate commits: > Interfaces

[jira] [Created] (FLINK-12244) SynchronousCheckpointITCase hang up

2019-04-17 Thread vinoyang (JIRA)
vinoyang created FLINK-12244: Summary: SynchronousCheckpointITCase hang up Key: FLINK-12244 URL: https://issues.apache.org/jira/browse/FLINK-12244 Project: Flink Issue Type: Test

[jira] [Updated] (FLINK-12208) Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-17 Thread Jing Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-12208: --- Description: Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to

[GitHub] [flink] zhijiangW commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes

2019-04-17 Thread GitBox
zhijiangW commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes URL: https://github.com/apache/flink/pull/8181#issuecomment-484364445 @zentol @azagrebin The codes are already updated for addressing above comments.

[GitHub] [flink] yanghua commented on a change in pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder

2019-04-17 Thread GitBox
yanghua commented on a change in pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder URL: https://github.com/apache/flink/pull/8199#discussion_r276472293 ## File path: flink-dist/pom.xml ## @@ -140,19 +140,54 @@ under the License.

[GitHub] [flink] godfreyhe commented on a change in pull request #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate

2019-04-17 Thread GitBox
godfreyhe commented on a change in pull request #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate URL: https://github.com/apache/flink/pull/8176#discussion_r276493412 ## File path:

[GitHub] [flink] JingsongLi commented on issue #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch

2019-04-17 Thread GitBox
JingsongLi commented on issue #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch URL: https://github.com/apache/flink/pull/8184#issuecomment-484346031 > > #8165 make CalcITCase.testTimestampCompareWithDateString fail. Some bug in #8165 . > > The bug is in

[jira] [Commented] (FLINK-9904) Allow users to control MaxDirectMemorySize

2019-04-17 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820720#comment-16820720 ] Ji Liu commented on FLINK-9904: --- Hi [~hroongta] are you still working on this issue? If not, i would like

[GitHub] [flink] zzchun opened a new pull request #8204: [hotfix][docs] fix typo in best_practices doc

2019-04-17 Thread GitBox
zzchun opened a new pull request #8204: [hotfix][docs] fix typo in best_practices doc URL: https://github.com/apache/flink/pull/8204 ## What is the purpose of the change Fix typo in best_practices.md ## Verifying this change This change is a trivial rework / code

[jira] [Updated] (FLINK-12208) Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-17 Thread Jing Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-12208: --- Description: Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to

[GitHub] [flink] flinkbot commented on issue #8204: [hotfix][docs] fix typo in best_practices doc

2019-04-17 Thread GitBox
flinkbot commented on issue #8204: [hotfix][docs] fix typo in best_practices doc URL: https://github.com/apache/flink/pull/8204#issuecomment-484362418 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

[jira] [Commented] (FLINK-11614) Translate the "Configuring Dependencies" page into Chinese

2019-04-17 Thread YangFei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820627#comment-16820627 ] YangFei commented on FLINK-11614: - Hi,Jark Wu,I had finished the issue ,  waiting to reviews.  thanks! 

[jira] [Assigned] (FLINK-11476) Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema

2019-04-17 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-11476: Assignee: Bowen Li (was: Xuefu Zhang) > Create CatalogManager to manage multiple catalogs and

[jira] [Closed] (FLINK-11474) Add ReadableCatalog, ReadableWritableCatalog, and other related interfaces

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

[GitHub] [flink] wuchong opened a new pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime

2019-04-17 Thread GitBox
wuchong opened a new pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime URL: https://github.com/apache/flink/pull/8202 ## What is the purpose of the change This ticket is aiming to support unbounded aggregate in blink

[jira] [Created] (FLINK-12245) Transient slot allocation failure on job recovery

2019-04-17 Thread Hwanju Kim (JIRA)
Hwanju Kim created FLINK-12245: -- Summary: Transient slot allocation failure on job recovery Key: FLINK-12245 URL: https://issues.apache.org/jira/browse/FLINK-12245 Project: Flink Issue Type:

[GitHub] [flink] beyond1920 opened a new pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-17 Thread GitBox
beyond1920 opened a new pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203 ## What is the purpose of the change Introduce Sort /

[GitHub] [flink] flinkbot commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-17 Thread GitBox
flinkbot commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#issuecomment-484360424 Thanks a lot for your contribution to the Apache

[GitHub] [flink] yanghua commented on a change in pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder

2019-04-17 Thread GitBox
yanghua commented on a change in pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder URL: https://github.com/apache/flink/pull/8199#discussion_r276472293 ## File path: flink-dist/pom.xml ## @@ -140,19 +140,54 @@ under the License.

[GitHub] [flink] sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface

2019-04-17 Thread GitBox
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface URL: https://github.com/apache/flink/pull/8124#discussion_r276490132 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

2019-04-17 Thread GitBox
hequn8128 commented on a change in pull request #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#discussion_r276503761 ## File path:

[GitHub] [flink] asfgit closed pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-04-17 Thread GitBox
asfgit closed pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007 This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-12174) Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences

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

[GitHub] [flink] flinkbot edited a comment on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-04-17 Thread GitBox
flinkbot edited a comment on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-474185108 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

2019-04-17 Thread Yingjie Cao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819778#comment-16819778 ] Yingjie Cao commented on FLINK-12070: - I'd like to perform a test to compare the performance of old

[jira] [Created] (FLINK-12219) Yarn application can't stop when flink job failed in per-job yarn cluste mode

2019-04-17 Thread lamber-ken (JIRA)
lamber-ken created FLINK-12219: -- Summary: Yarn application can't stop when flink job failed in per-job yarn cluste mode Key: FLINK-12219 URL: https://issues.apache.org/jira/browse/FLINK-12219 Project:

[GitHub] [flink] dawidwys merged pull request #8162: [FLINK-12174][table] Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences

2019-04-17 Thread GitBox
dawidwys merged pull request #8162: [FLINK-12174][table] Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences URL: https://github.com/apache/flink/pull/8162 This is an automated message from the

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

2019-04-17 Thread BoWang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819782#comment-16819782 ] BoWang commented on FLINK-12070: Thanks [~kevin.cyj] for the evaluation. Some small questions: # Shall 

[GitHub] [flink] sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface

2019-04-17 Thread GitBox
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface URL: https://github.com/apache/flink/pull/8124#discussion_r276090295 ## File path:

[jira] [Assigned] (FLINK-12068) Backtrack fail over regions if intermediate results are unavailable

2019-04-17 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-12068: --- Assignee: Zhu Zhu > Backtrack fail over regions if intermediate results are unavailable >

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

2019-04-17 Thread BoWang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819774#comment-16819774 ] BoWang commented on FLINK-10644: Thanks [~greghogan] for the comments. 1) we use several rules to judge

[GitHub] [flink] zhijiangW edited a comment on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes

2019-04-17 Thread GitBox
zhijiangW edited a comment on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes URL: https://github.com/apache/flink/pull/8181#issuecomment-483946313 After further thinking through this issue, the current created local/remote

[jira] [Updated] (FLINK-11309) Make SpillableSubpartition repeatably read to enable

2019-04-17 Thread BoWang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang updated FLINK-11309: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-10644 > Make SpillableSubpartition repeatably read

[jira] [Created] (FLINK-12220) Speculatively schedule execution for long tail task

2019-04-17 Thread BoWang (JIRA)
BoWang created FLINK-12220: -- Summary: Speculatively schedule execution for long tail task Key: FLINK-12220 URL: https://issues.apache.org/jira/browse/FLINK-12220 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

2019-04-17 Thread GitBox
flinkbot edited a comment on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve() URL: https://github.com/apache/flink/pull/8192#issuecomment-483933291 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Commented] (FLINK-12068) Backtrack fail over regions if intermediate results are unavailable

2019-04-17 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819761#comment-16819761 ] Zhu Zhu commented on FLINK-12068: - Per discussion with [~Zentol], I will work on the implementation and

[GitHub] [flink] dawidwys commented on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

2019-04-17 Thread GitBox
dawidwys commented on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve() URL: https://github.com/apache/flink/pull/8192#issuecomment-483952144 @flinkbot approve all This

[GitHub] [flink] flinkbot commented on issue #8193: [hotfix] load globalConfiguration from configurationDir

2019-04-17 Thread GitBox
flinkbot commented on issue #8193: [hotfix] load globalConfiguration from configurationDir URL: https://github.com/apache/flink/pull/8193#issuecomment-483957340 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] Tom-Goong opened a new pull request #8193: [hotfix] load globalConfiguration from configurationDir

2019-04-17 Thread GitBox
Tom-Goong opened a new pull request #8193: [hotfix] load globalConfiguration from configurationDir URL: https://github.com/apache/flink/pull/8193 ## What is the purpose of the change the configuration and the configDir may dismatch ## Brief change log load globalConfiguration

[jira] [Comment Edited] (FLINK-10644) Batch Job: Speculative execution

2019-04-17 Thread BoWang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819774#comment-16819774 ] BoWang edited comment on FLINK-10644 at 4/17/19 6:49 AM: - Thanks [~greghogan]

[jira] [Assigned] (FLINK-12198) Flink JDBC Connector: Update existing JDBCInputFormat to support setting auto-commit mode of DB connection

2019-04-17 Thread Konstantinos Papadopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantinos Papadopoulos reassigned FLINK-12198: - Assignee: Konstantinos Papadopoulos > Flink JDBC Connector:

[jira] [Assigned] (FLINK-10644) Batch Job: Speculative execution

2019-04-17 Thread BoWang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang reassigned FLINK-10644: -- Assignee: BoWang (was: ryantaocer) > Batch Job: Speculative execution >

[jira] [Created] (FLINK-12218) Report more record information in IOMetrics for Speculative Schedule

2019-04-17 Thread BoWang (JIRA)
BoWang created FLINK-12218: -- Summary: Report more record information in IOMetrics for Speculative Schedule Key: FLINK-12218 URL: https://issues.apache.org/jira/browse/FLINK-12218 Project: Flink

[GitHub] [flink] sunjincheng121 commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

2019-04-17 Thread GitBox
sunjincheng121 commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-483952943 @xuefuz thanks for the update! +1 to merged. @flinkbot approve all Best,

[GitHub] [flink] flinkbot edited a comment on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

2019-04-17 Thread GitBox
flinkbot edited a comment on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve() URL: https://github.com/apache/flink/pull/8192#issuecomment-483933291 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] liyafan82 opened a new pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input paramete…

2019-04-17 Thread GitBox
liyafan82 opened a new pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input paramete… URL: https://github.com/apache/flink/pull/8194 …rs in HybridMemorySegment ## What is the purpose of the change Fix some bugs in class HybridMemorySegment.

[GitHub] [flink] kpapadopoul commented on issue #8186: [FLINK-12198] Flink JDBC Connector: Update existing JDBCInputFormat t…

2019-04-17 Thread GitBox
kpapadopoul commented on issue #8186: [FLINK-12198] Flink JDBC Connector: Update existing JDBCInputFormat t… URL: https://github.com/apache/flink/pull/8186#issuecomment-483957756 I agree with you, @walterddr. I tried to be compliant with the 'setFetchSize' implementation. I will fix it

[jira] [Updated] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment

2019-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12216: --- Labels: pull-request-available (was: ) > Respect the number of bytes from input parameters

[GitHub] [flink] flinkbot commented on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input paramete…

2019-04-17 Thread GitBox
flinkbot commented on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input paramete… URL: https://github.com/apache/flink/pull/8194#issuecomment-483957785 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Created] (FLINK-12221) Distinguish long tail task based on IOMetrics

2019-04-17 Thread BoWang (JIRA)
BoWang created FLINK-12221: -- Summary: Distinguish long tail task based on IOMetrics Key: FLINK-12221 URL: https://issues.apache.org/jira/browse/FLINK-12221 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-12217) OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

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

[GitHub] [flink] azagrebin commented on issue #8189: [FLINK-12195] [YARN] Incorrect resource time setting causes flink to fail to submit

2019-04-17 Thread GitBox
azagrebin commented on issue #8189: [FLINK-12195] [YARN] Incorrect resource time setting causes flink to fail to submit URL: https://github.com/apache/flink/pull/8189#issuecomment-483973687 @shuiqiangchen could you close this PR before we have an agreement about a solution for all cases

[GitHub] [flink] zhijiangW commented on a change in pull request #8133: [FLINK-12146][network] Remove unregister task from NetworkEnvironment to simplify the interface of ShuffleService

2019-04-17 Thread GitBox
zhijiangW commented on a change in pull request #8133: [FLINK-12146][network] Remove unregister task from NetworkEnvironment to simplify the interface of ShuffleService URL: https://github.com/apache/flink/pull/8133#discussion_r276114525 ## File path:

[jira] [Assigned] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-1: -- Assignee: Jeff Zhang > No way to ship custom jars to yarn cluster in scala-shell >

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Component/s: Deployment / YARN > No way to ship custom jars to yarn cluster in scala-shell >

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Affects Version/s: 1.8.0 > No way to ship custom jars to yarn cluster in scala-shell >

[jira] [Updated] (FLINK-12065) E2E tests fail due to illegal-access warning on Java 9

2019-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12065: --- Labels: pull-request-available (was: ) > E2E tests fail due to illegal-access warning on

[GitHub] [flink] zentol opened a new pull request #8196: [FLINK-12065][e2e] Ignore reflection access warnings

2019-04-17 Thread GitBox
zentol opened a new pull request #8196: [FLINK-12065][e2e] Ignore reflection access warnings URL: https://github.com/apache/flink/pull/8196 ## What is the purpose of the change For several of our end-to-end tests we verify that the .out files are empty at the end of the test. When

[GitHub] [flink] flinkbot commented on issue #8196: [FLINK-12065][e2e] Ignore reflection access warnings

2019-04-17 Thread GitBox
flinkbot commented on issue #8196: [FLINK-12065][e2e] Ignore reflection access warnings URL: https://github.com/apache/flink/pull/8196#issuecomment-483978850 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Commented] (FLINK-7391) Normalize release entries

2019-04-17 Thread Wang Geng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819824#comment-16819824 ] Wang Geng commented on FLINK-7391: -- Hi [~dawidwys], If nobody is working on this ticket. I can work on

[jira] [Updated] (FLINK-12222) `start-scala-shell -a ` doesn't ship jars to yarn container

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Summary: `start-scala-shell -a ` doesn't ship jars to yarn container (was: No way to ship custom

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Description: If user use `flink run` to submit flink jars, he could build uber jar to include all

[jira] [Updated] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell

2019-04-17 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-1: --- Issue Type: Bug (was: New Feature) > No way to ship custom jars to yarn cluster in scala-shell >

[GitHub] [flink] StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

2019-04-17 Thread GitBox
StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276134032 ## File path:

[jira] [Updated] (FLINK-12223) HeapMemorySegment.getArray should return null after being freed

2019-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12223: --- Labels: pull-request-available (was: ) > HeapMemorySegment.getArray should return null

[GitHub] [flink] liyafan82 opened a new pull request #8197: [FLINK-12223][Runtime]HeapMemorySegment.getArray should return null a…

2019-04-17 Thread GitBox
liyafan82 opened a new pull request #8197: [FLINK-12223][Runtime]HeapMemorySegment.getArray should return null a… URL: https://github.com/apache/flink/pull/8197 …rs in HybridMemorySegment ## What is the purpose of the change Fix a bug in class HeapMemorySegment. The

[GitHub] [flink] flinkbot commented on issue #8197: [FLINK-12223][Runtime]HeapMemorySegment.getArray should return null a…

2019-04-17 Thread GitBox
flinkbot commented on issue #8197: [FLINK-12223][Runtime]HeapMemorySegment.getArray should return null a… URL: https://github.com/apache/flink/pull/8197#issuecomment-483997869 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] zhijiangW commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes

2019-04-17 Thread GitBox
zhijiangW commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes URL: https://github.com/apache/flink/pull/8181#issuecomment-484001811 Thanks for replies @azagrebin . Yes, we should confirm there only exists one

[GitHub] [flink] StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

2019-04-17 Thread GitBox
StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276155223 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

2019-04-17 Thread GitBox
StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276155223 ## File path:

  1   2   3   4   >