[GitHub] [flink] beyond1920 commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-04-28 Thread GitBox
beyond1920 commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#issuecomment-487457504 @KurtYoung , after discussed with @hequn8128 offline, final

[GitHub] [flink] bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-28 Thread GitBox
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-487447400 @flinkbot attention @zentol

[GitHub] [flink] flinkbot commented on issue #8308: [FLINK-12361][Runtime/Operators]remove useless expression from runtim…

2019-04-28 Thread GitBox
flinkbot commented on issue #8308: [FLINK-12361][Runtime/Operators]remove useless expression from runtim… URL: https://github.com/apache/flink/pull/8308#issuecomment-487442905 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] WeiZhong94 commented on issue #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

2019-04-28 Thread GitBox
WeiZhong94 commented on issue #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#issuecomment-487442930 @sunjincheng121 thanks for your review! I have rebased this PR and

[jira] [Updated] (FLINK-12361) Remove useless expression from runtime scheduler

2019-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12361: --- Labels: pull-request-available (was: ) > Remove useless expression from runtime scheduler

[GitHub] [flink] liyafan82 opened a new pull request #8308: [FLINK-12361][Runtime/Operators]remove useless expression from runtim…

2019-04-28 Thread GitBox
liyafan82 opened a new pull request #8308: [FLINK-12361][Runtime/Operators]remove useless expression from runtim… URL: https://github.com/apache/flink/pull/8308 …e scheduler ## What is the purpose of the change Remove useless expression forceExternalLocation from

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

2019-04-28 Thread GitBox
WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r279230381 ## File path:

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

2019-04-28 Thread GitBox
WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r279230371 ## File path:

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

2019-04-28 Thread GitBox
WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r279230215 ## File path:

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

2019-04-28 Thread GitBox
WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r279230115 ## File path:

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

2019-04-28 Thread GitBox
WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r279230110 ## File path: docs/dev/table/tableApi.md

[jira] [Created] (FLINK-12361) Remove useless expression from runtime scheduler

2019-04-28 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12361: Summary: Remove useless expression from runtime scheduler Key: FLINK-12361 URL: https://issues.apache.org/jira/browse/FLINK-12361 Project: Flink Issue Type:

[GitHub] [flink] lamber-ken commented on a change in pull request #8268: [FLINK-12246][runtime] Fix can't get max_attempts_history_size value when create ExecutionVertex

2019-04-28 Thread GitBox
lamber-ken commented on a change in pull request #8268: [FLINK-12246][runtime] Fix can't get max_attempts_history_size value when create ExecutionVertex URL: https://github.com/apache/flink/pull/8268#discussion_r279229762 ## File path:

[jira] [Updated] (FLINK-12360) Translate "Jobs and Scheduling" Page into Chinese

2019-04-28 Thread Armstrong Nova (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armstrong Nova updated FLINK-12360: --- Description: Translate the internal page

[GitHub] [flink] wuchong commented on issue #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-04-28 Thread GitBox
wuchong commented on issue #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#issuecomment-487433247 Hi @godfreyhe , I add the `JoinPushExpressionsRule.INSTANCE` rule into predicate pushdown stage to

[GitHub] [flink] wuchong edited a comment on issue #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-04-28 Thread GitBox
wuchong edited a comment on issue #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#issuecomment-487433247 Hi @godfreyhe , I add the `JoinPushExpressionsRule.INSTANCE` rule into predicate pushdown

[jira] [Created] (FLINK-12360) Translate "Jobs and Scheduling" Page to Chinese

2019-04-28 Thread Armstrong Nova (JIRA)
Armstrong Nova created FLINK-12360: -- Summary: Translate "Jobs and Scheduling" Page to Chinese Key: FLINK-12360 URL: https://issues.apache.org/jira/browse/FLINK-12360 Project: Flink Issue

[jira] [Updated] (FLINK-12360) Translate "Jobs and Scheduling" Page into Chinese

2019-04-28 Thread Armstrong Nova (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armstrong Nova updated FLINK-12360: --- Description: Translate the internal page

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API

2019-04-28 Thread GitBox
sunjincheng121 commented on a change in pull request #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8230#discussion_r279223257 ## File path:

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

2019-04-28 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828869#comment-16828869 ] Jark Wu commented on FLINK-12351: - Hi [~aitozi], I think fix the bug in AsyncWaitOperator and enable

[GitHub] [flink] flinkbot edited a comment on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-28 Thread GitBox
flinkbot edited a comment on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-484369983 Thanks a lot for your contribution to the Apache

[GitHub] [flink] bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-28 Thread GitBox
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-487431946 Synced with @zentol offline. We cannot depend on

[GitHub] [flink] bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-28 Thread GitBox
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-487431970 @flinkbot attention @KurtYoung

[jira] [Comment Edited] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

2019-04-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828843#comment-16828843 ] Chesnay Schepler edited comment on FLINK-12358 at 4/28/19 9:01 PM: --- I

[jira] [Commented] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

2019-04-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828843#comment-16828843 ] Chesnay Schepler commented on FLINK-12358: -- I doubt that a diff-based approach will work here

[jira] [Commented] (FLINK-12175) TypeExtractor.getMapReturnTypes produces different TypeInformation than createTypeInformation for classes with parameterized ancestors

2019-04-28 Thread Andrey Bulgakov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828822#comment-16828822 ] Andrey Bulgakov commented on FLINK-12175: - Yes I am working on this. I have found a solution and

[jira] [Commented] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828776#comment-16828776 ] lamber-ken commented on FLINK-12183: (y) > Job Cluster doesn't stop after cancel a running job in

[GitHub] [flink] flinkbot commented on issue #8307: [FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase

2019-04-28 Thread GitBox
flinkbot commented on issue #8307: [FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase URL: https://github.com/apache/flink/pull/8307#issuecomment-487392775 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-12359) SystemResourcesMetricsITCase unstable

2019-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12359: --- Labels: pull-request-available (was: ) > SystemResourcesMetricsITCase unstable >

[GitHub] [flink] zentol opened a new pull request #8307: [FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase

2019-04-28 Thread GitBox
zentol opened a new pull request #8307: [FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase URL: https://github.com/apache/flink/pull/8307 ## What is the purpose of the change Hardens the `SystemResourcesMetricsITCase` against * slow starts of a TaskManager, in

[jira] [Assigned] (FLINK-12139) Flink on mesos - Parameterize disk space needed.

2019-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-12139: - Assignee: Juan (was: Oleksandr Nitavskyi) > Flink on mesos - Parameterize disk space

[jira] [Resolved] (FLINK-12139) Flink on mesos - Parameterize disk space needed.

2019-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-12139. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed via

[GitHub] [flink] tillrohrmann closed pull request #8224: [FLINK-12139][Mesos] Add disk space parameter.

2019-04-28 Thread GitBox
tillrohrmann closed pull request #8224: [FLINK-12139][Mesos] Add disk space parameter. URL: https://github.com/apache/flink/pull/8224 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12342: --- Labels: pull-request-available (was: ) > Yarn Resource Manager Acquires Too Many

[GitHub] [flink] HuangZhenQiu opened a new pull request #8306: [FLINK-12342] Use total requested pending containers to bound the maximum containers to…

2019-04-28 Thread GitBox
HuangZhenQiu opened a new pull request #8306: [FLINK-12342] Use total requested pending containers to bound the maximum containers to… URL: https://github.com/apache/flink/pull/8306 ## What is the purpose of the change Fix the issue of requesting too many containers issue in

[GitHub] [flink] flinkbot commented on issue #8306: [FLINK-12342] Use total requested pending containers to bound the maximum containers to…

2019-04-28 Thread GitBox
flinkbot commented on issue #8306: [FLINK-12342] Use total requested pending containers to bound the maximum containers to… URL: https://github.com/apache/flink/pull/8306#issuecomment-487389322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Commented] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

2019-04-28 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828040#comment-16828040 ] Gyula Fora commented on FLINK-12141: [~yangfei] I havent started any work on this, so if you are

[jira] [Assigned] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

2019-04-28 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-12141: -- Assignee: YangFei > Allow @TypeInfo annotation on POJO field declarations >

[GitHub] [flink] flinkbot commented on issue #8305: [hotfix] regenerate rest-docs to latest code

2019-04-28 Thread GitBox
flinkbot commented on issue #8305: [hotfix] regenerate rest-docs to latest code URL: https://github.com/apache/flink/pull/8305#issuecomment-487389173 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] [Created] (FLINK-12359) SystemResourcesMetricsITCase unstable

2019-04-28 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12359: Summary: SystemResourcesMetricsITCase unstable Key: FLINK-12359 URL: https://issues.apache.org/jira/browse/FLINK-12359 Project: Flink Issue Type:

[GitHub] [flink] Myasuka opened a new pull request #8305: [hotfix] regenerate rest-docs to latest code

2019-04-28 Thread GitBox
Myasuka opened a new pull request #8305: [hotfix] regenerate rest-docs to latest code URL: https://github.com/apache/flink/pull/8305 ## What is the purpose of the change Regenerate rest-docs to latest code. I happen to notice this when I plan to implement

[jira] [Created] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

2019-04-28 Thread Yun Tang (JIRA)
Yun Tang created FLINK-12358: Summary: Verify whether rest documenation needs to be updated when building pull request Key: FLINK-12358 URL: https://issues.apache.org/jira/browse/FLINK-12358 Project:

[GitHub] [flink] flinkbot commented on issue #8304: [hotfix]Harden TextInputFormatTest to avoid failure by uncleaned files

2019-04-28 Thread GitBox
flinkbot commented on issue #8304: [hotfix]Harden TextInputFormatTest to avoid failure by uncleaned files URL: https://github.com/apache/flink/pull/8304#issuecomment-487386856 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] Aitozi commented on issue #8304: [hotfix]Harden TextInputFormatTest to avoid failure by uncleaned files

2019-04-28 Thread GitBox
Aitozi commented on issue #8304: [hotfix]Harden TextInputFormatTest to avoid failure by uncleaned files URL: https://github.com/apache/flink/pull/8304#issuecomment-487386975 And I see there are quite a lot other tests rely on `deleteOnExit` to do clean up. Should I do the fix for them,

[GitHub] [flink] Aitozi opened a new pull request #8304: [hotfix]Harden TextInputFormatTest to avoid failure by uncleaned files

2019-04-28 Thread GitBox
Aitozi opened a new pull request #8304: [hotfix]Harden TextInputFormatTest to avoid failure by uncleaned files URL: https://github.com/apache/flink/pull/8304 ## What is the purpose of the change When I run test locally, it happened to failed and with the uncleaned temp file leaving

[GitHub] [flink] klion26 commented on issue #8164: [FLINK-12184] history server compatible with old version

2019-04-28 Thread GitBox
klion26 commented on issue #8164: [FLINK-12184] history server compatible with old version URL: https://github.com/apache/flink/pull/8164#issuecomment-487385580 @yumengz5 thanks for your reply, I'll file a new pr for this issue.

[GitHub] [flink] HuangZhenQiu commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration

2019-04-28 Thread GitBox
HuangZhenQiu commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-487385194 @rmetzger @tillrohrmann Please have a look this PR when you have time.

[jira] [Updated] (FLINK-12343) Allow set file.replication in Yarn Configuration

2019-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12343: --- Labels: pull-request-available (was: ) > Allow set file.replication in Yarn Configuration

[GitHub] [flink] flinkbot commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration

2019-04-28 Thread GitBox
flinkbot commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-487385120 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] HuangZhenQiu opened a new pull request #8303: [FLINK-12343]add file replication config for yarn configuration

2019-04-28 Thread GitBox
HuangZhenQiu opened a new pull request #8303: [FLINK-12343]add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303 ## What is the purpose of the change This pull request add file replication config for Flink yarn configuration. This is helpful

[jira] [Updated] (FLINK-12343) Allow set file.replication in Yarn Configuration

2019-04-28 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12343: -- Summary: Allow set file.replication in Yarn Configuration (was: Allow set hdfs.replication

[GitHub] [flink] flinkbot commented on issue #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-04-28 Thread GitBox
flinkbot commented on issue #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#issuecomment-487382537 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12269) Support Temporal Table Join in blink planner

2019-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12269: --- Labels: pull-request-available (was: ) > Support Temporal Table Join in blink planner >

[GitHub] [flink] wuchong opened a new pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-04-28 Thread GitBox
wuchong opened a new pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302 ## What is the purpose of the change Support translate "FOR SYSTEM_TIME AS OF" query into temporal table

[jira] [Commented] (FLINK-12343) Allow set hdfs.replication in Yarn Configuration

2019-04-28 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827997#comment-16827997 ] Zhenqiu Huang commented on FLINK-12343: --- It can be set by in both way. Here is to set the bigger

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-28 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827993#comment-16827993 ] Zhenqiu Huang commented on FLINK-12342: --- [~till.rohrmann] The job that has the issue tries to

[jira] [Closed] (FLINK-12307) Support translation from StreamExecWindowJoin to StreamTransformation.

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

[GitHub] [flink] KurtYoung merged pull request #8261: [FLINK-12307][table-planner-blink] Support translation from StreamExecWindowJoin to StreamTransformation.

2019-04-28 Thread GitBox
KurtYoung merged pull request #8261: [FLINK-12307][table-planner-blink] Support translation from StreamExecWindowJoin to StreamTransformation. URL: https://github.com/apache/flink/pull/8261 This is an automated message from

[jira] [Commented] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread Yumeng Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827982#comment-16827982 ] Yumeng Zhang commented on FLINK-12183: -- lamber-ken, I agree with you. It's not a good idea to break

[GitHub] [flink] flinkbot commented on issue #8301: [FLINK-12357][api-java][hotfix] Remove useless code in TableConfig

2019-04-28 Thread GitBox
flinkbot commented on issue #8301: [FLINK-12357][api-java][hotfix] Remove useless code in TableConfig URL: https://github.com/apache/flink/pull/8301#issuecomment-487373286 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-12357) Remove useless code in TableConfig

2019-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12357: --- Labels: pull-request-available (was: ) > Remove useless code in TableConfig >

[GitHub] [flink] hequn8128 opened a new pull request #8301: [FLINK-12357][api-java][hotfix] Remove useless code in TableConfig

2019-04-28 Thread GitBox
hequn8128 opened a new pull request #8301: [FLINK-12357][api-java][hotfix] Remove useless code in TableConfig URL: https://github.com/apache/flink/pull/8301 ## What is the purpose of the change Remove useless code in TableConfig. It was added accidentally in

[GitHub] [flink] yumengz5 commented on issue #8164: [FLINK-12184] history server compatible with old version

2019-04-28 Thread GitBox
yumengz5 commented on issue #8164: [FLINK-12184] history server compatible with old version URL: https://github.com/apache/flink/pull/8164#issuecomment-487372370 @klion26 Sorry about the late reply. All right. You can take over it.

[jira] [Commented] (FLINK-12343) Allow set hdfs.replication in Yarn Configuration

2019-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827957#comment-16827957 ] Till Rohrmann commented on FLINK-12343: --- Isn't the replication factor an HDFS configuration you

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827956#comment-16827956 ] Till Rohrmann commented on FLINK-12342: --- Thanks for reporting this issue [~hpeter]. For my

[GitHub] [flink] link3280 closed pull request #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber)

2019-04-28 Thread GitBox
link3280 closed pull request #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber) URL: https://github.com/apache/flink/pull/8299 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-12346) Scala-suffix check broken on Travis

2019-04-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12346. Resolution: Fixed master: 8f02746ec7316ccdc6d25e915f3b58595438cc44 > Scala-suffix check

[GitHub] [flink] zentol merged pull request #8289: [FLINK-12346][travis][build] Account for timestampts in scala-suffix check

2019-04-28 Thread GitBox
zentol merged pull request #8289: [FLINK-12346][travis][build] Account for timestampts in scala-suffix check URL: https://github.com/apache/flink/pull/8289 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-12260) Slot allocation failure by taskmanager registration timeout and race

2019-04-28 Thread Xiaolei Jia (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827919#comment-16827919 ] Xiaolei Jia commented on FLINK-12260: - Hi, If this issue is still open, I'd like to fix this

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2019-04-28 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827912#comment-16827912 ] Dominik Wosiński commented on FLINK-10052: -- Hey, Sorry, somehow I have missed the issue. I

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

2019-04-28 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824919#comment-16824919 ] lamber-ken edited comment on FLINK-12219 at 4/28/19 10:41 AM: -- no, in

[jira] [Comment Edited] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827901#comment-16827901 ] lamber-ken edited comment on FLINK-12183 at 4/28/19 10:33 AM: -- [~Yumeng],

[jira] [Comment Edited] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827901#comment-16827901 ] lamber-ken edited comment on FLINK-12183 at 4/28/19 10:29 AM: -- [~Yumeng],

[jira] [Comment Edited] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827901#comment-16827901 ] lamber-ken edited comment on FLINK-12183 at 4/28/19 10:28 AM: -- [~Yumeng],

[jira] [Comment Edited] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827901#comment-16827901 ] lamber-ken edited comment on FLINK-12183 at 4/28/19 10:20 AM: -- [~Yumeng],

[jira] [Commented] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827901#comment-16827901 ] lamber-ken commented on FLINK-12183: [~Yumeng], hi, What a coincidence! We met the same problem. I'm

[jira] [Created] (FLINK-12357) Remove useless code in TableConfig

2019-04-28 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-12357: --- Summary: Remove useless code in TableConfig Key: FLINK-12357 URL: https://issues.apache.org/jira/browse/FLINK-12357 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-12175) TypeExtractor.getMapReturnTypes produces different TypeInformation than createTypeInformation for classes with parameterized ancestors

2019-04-28 Thread YangFei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827895#comment-16827895 ] YangFei commented on FLINK-12175: - [~andbul] are you working on this fix? Can I work on this ticket? >

[GitHub] [flink] wujinhu removed a comment on issue #7798: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

2019-04-28 Thread GitBox
wujinhu removed a comment on issue #7798: [FLINK-11388][fs] Add Aliyun OSS recoverable writer URL: https://github.com/apache/flink/pull/7798#issuecomment-471811588 @StefanRRichter would you please help review this PR? Thanks :)

[GitHub] [flink] wujinhu commented on issue #7798: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

2019-04-28 Thread GitBox
wujinhu commented on issue #7798: [FLINK-11388][fs] Add Aliyun OSS recoverable writer URL: https://github.com/apache/flink/pull/7798#issuecomment-487364585 Rebase master. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-11762) Update WindowOperatorMigrationTest for 1.8

2019-04-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827885#comment-16827885 ] vinoyang commented on FLINK-11762: -- [~yangfei] [https://github.com/apache/flink/pull/8168] > Update

[GitHub] [flink] flinkbot commented on issue #8300: [FLINK-11638] Translate Savepoints page into Chinese

2019-04-28 Thread GitBox
flinkbot commented on issue #8300: [FLINK-11638] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#issuecomment-487363436 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-11762) Update WindowOperatorMigrationTest for 1.8

2019-04-28 Thread YangFei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827883#comment-16827883 ] YangFei commented on FLINK-11762: - [~yanghua] can you tell me the  umbrella issue which contains all of

[jira] [Updated] (FLINK-11638) Translate "Savepoints" page into Chinese

2019-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11638: --- Labels: pull-request-available (was: ) > Translate "Savepoints" page into Chinese >

[jira] [Commented] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

2019-04-28 Thread YangFei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827882#comment-16827882 ] YangFei commented on FLINK-12141: - I am interesting in this issue . [~gyfora] are you woking on this

[GitHub] [flink] XuQianJin-Stars opened a new pull request #8300: [FLINK-11638] Translate Savepoints page into Chinese

2019-04-28 Thread GitBox
XuQianJin-Stars opened a new pull request #8300: [FLINK-11638] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300 ## What is the purpose of the change *(This pull request to Translate "Savepoints" page into Chinese.)* ## Brief change log

[GitHub] [flink] link3280 edited a comment on issue #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber)

2019-04-28 Thread GitBox
link3280 edited a comment on issue #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber) URL: https://github.com/apache/flink/pull/8299#issuecomment-487362995 Oops. It seems that these modules would be removed in the future.

[GitHub] [flink] link3280 commented on issue #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber)

2019-04-28 Thread GitBox
link3280 commented on issue #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber) URL: https://github.com/apache/flink/pull/8299#issuecomment-487362995 Oops. It seems that these modules would be removed in the future.

[jira] [Updated] (FLINK-12356) Optimise version experssion of flink-shaded-hadoop2(-uber)

2019-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12356: --- Labels: pull-request-available (was: ) > Optimise version experssion of

[GitHub] [flink] flinkbot commented on issue #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber)

2019-04-28 Thread GitBox
flinkbot commented on issue #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber) URL: https://github.com/apache/flink/pull/8299#issuecomment-487362574 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] link3280 opened a new pull request #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber)

2019-04-28 Thread GitBox
link3280 opened a new pull request #8299: [FLINK-12356][BuildSystem] Optimise version experssion of flink-shaded-hadoop2(-uber) URL: https://github.com/apache/flink/pull/8299 ## What is the purpose of the change Since the new version scheme for hadoop-based modules, we use version

[jira] [Closed] (FLINK-12347) flink-table-runtime-blink is missing scala suffix

2019-04-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12347. Resolution: Fixed master: 6bc25c2c3691d9bd2c12fcb0b3c123cf5ab70b7b >

[GitHub] [flink] zentol merged pull request #8293: [FLINK-12347][Table SQL/Runtime]add scala suffix for flink-table-runt…

2019-04-28 Thread GitBox
zentol merged pull request #8293: [FLINK-12347][Table SQL/Runtime]add scala suffix for flink-table-runt… URL: https://github.com/apache/flink/pull/8293 This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (FLINK-12356) Optimise version experssion of flink-shaded-hadoop2(-uber)

2019-04-28 Thread Paul Lin (JIRA)
Paul Lin created FLINK-12356: Summary: Optimise version experssion of flink-shaded-hadoop2(-uber) Key: FLINK-12356 URL: https://issues.apache.org/jira/browse/FLINK-12356 Project: Flink Issue

[GitHub] [flink] eaglewatcherwb closed pull request #8298: test

2019-04-28 Thread GitBox
eaglewatcherwb closed pull request #8298: test URL: https://github.com/apache/flink/pull/8298 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink] flinkbot commented on issue #8298: test

2019-04-28 Thread GitBox
flinkbot commented on issue #8298: test URL: https://github.com/apache/flink/pull/8298#issuecomment-487359619 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 track the

[GitHub] [flink] eaglewatcherwb opened a new pull request #8298: test

2019-04-28 Thread GitBox
eaglewatcherwb opened a new pull request #8298: test URL: https://github.com/apache/flink/pull/8298 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

2019-04-28 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827861#comment-16827861 ] aitozi commented on FLINK-12351: Hi, [~jark] I checked the objectuse config in other operator just now.

[jira] [Comment Edited] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread Yumeng Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827860#comment-16827860 ] Yumeng Zhang edited comment on FLINK-12183 at 4/28/19 8:41 AM: ---

[jira] [Commented] (FLINK-12183) Job Cluster doesn't stop after cancel a running job in per-job Yarn mode

2019-04-28 Thread Yumeng Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827860#comment-16827860 ] Yumeng Zhang commented on FLINK-12183: -- FLINK-12247 seems to fix this problem, but it looks too

  1   2   >