[jira] [Updated] (FLINK-13963) Consolidate Hadoop file systems usage and Hadoop integration docs

2019-09-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13963: --- Labels: pull-request-available (was: ) > Consolidate Hadoop file systems usage and Hadoop

[jira] [Updated] (FLINK-13927) Add note about hadoop dependencies for local debug

2019-09-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13927: --- Labels: pull-request-available (was: ) > Add note about hadoop dependencies for local

[GitHub] [flink] flinkbot edited a comment on issue #9616: [FLINK-13957] [flink-yarn] Log dynamic properties on job submission

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9616: [FLINK-13957] [flink-yarn] Log dynamic properties on job submission URL: https://github.com/apache/flink/pull/9616#issuecomment-527924104 ## CI report: * b9114df609d2f21117e431ed36ae647a9f3a93a5 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs

2019-09-04 Thread GitBox
flinkbot commented on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs URL: https://github.com/apache/flink/pull/9617#issuecomment-527968624 ## CI report: * ecf3897b7c61bca5a65d3ecc66a009d6ab91c596 : UNKNOWN

[GitHub] [flink] azagrebin commented on issue #9556: [FLINK-13895] client does not exit when application has failed

2019-09-04 Thread GitBox
azagrebin commented on issue #9556: [FLINK-13895] client does not exit when application has failed URL: https://github.com/apache/flink/pull/9556#issuecomment-527986688 @gentlewangyu Could you firstly describe your approach about how to solve the problem in JIRA issue? Usually we

[GitHub] [flink] flinkbot edited a comment on issue #9619: [docs][hotfix] Api concepts docs: fix typos

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9619: [docs][hotfix] Api concepts docs: fix typos URL: https://github.com/apache/flink/pull/9619#issuecomment-527994934 ## CI report: * cecb5923b67c2df5e7ed094d1954c2f70d8fb3dd : PENDING

[jira] [Updated] (FLINK-7151) Add a function SQL DDL

2019-09-04 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7151: Description: Based on create function and table.we can register a udf,udaf,udtf use sql: {code} CREATE

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

2019-09-04 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922755#comment-16922755 ] Bowen Li commented on FLINK-7151: - Hi [~ZhenqiuHuang], as we discussed offline, we can just focus on

[GitHub] [flink] flinkbot edited a comment on issue #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#issuecomment-527790327 ## CI report: * 0c2c5cdcc1267a49ef8df775e0e2ee46a5249487 : SUCCESS

[jira] [Updated] (FLINK-13927) Add note about hadoop dependencies for local debug

2019-09-04 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-13927: Description: Currently if user tries to run the job locally (e.g. from IDE) and uses

[GitHub] [flink] flinkbot commented on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs

2019-09-04 Thread GitBox
flinkbot commented on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs URL: https://github.com/apache/flink/pull/9617#issuecomment-527967715 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot commented on issue #9618: [FLINK-13927] Add note about hadoop dependencies for local debug

2019-09-04 Thread GitBox
flinkbot commented on issue #9618: [FLINK-13927] Add note about hadoop dependencies for local debug URL: https://github.com/apache/flink/pull/9618#issuecomment-527976084 ## CI report: * c7d82ef4b724590ee0ca099071f6dd66673305bc : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9619: [docs][hotfix] Api concepts docs: fix typos

2019-09-04 Thread GitBox
flinkbot commented on issue #9619: [docs][hotfix] Api concepts docs: fix typos URL: https://github.com/apache/flink/pull/9619#issuecomment-527991302 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

[GitHub] [flink] kl0u commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
kl0u commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320887417 ## File path: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java

[GitHub] [flink] kl0u commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
kl0u commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320889696 ## File path: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java

[GitHub] [flink] flinkbot edited a comment on issue #9586: [hotfix] fix typos

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9586: [hotfix] fix typos URL: https://github.com/apache/flink/pull/9586#issuecomment-526869421 ## CI report: * 7e3ec397d6462766f56ffb42875beebe5db58528 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/125333511) *

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-09-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922710#comment-16922710 ] Nico Kruber commented on FLINK-12122: - [~anton_ryabtsev] true, memory could become an issue in

[GitHub] [flink] azagrebin commented on a change in pull request #9558: [FLINK-13892][hs] Harden HistoryServerTest

2019-09-04 Thread GitBox
azagrebin commented on a change in pull request #9558: [FLINK-13892][hs] Harden HistoryServerTest URL: https://github.com/apache/flink/pull/9558#discussion_r320715182 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java

[GitHub] [flink] flinkbot edited a comment on issue #9564: [FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox for timer triggers, checkpoints and AsyncWaitOperator

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9564: [FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox for timer triggers, checkpoints and AsyncWaitOperator URL: https://github.com/apache/flink/pull/9564#issuecomment-526487220 ## CI report: *

[jira] [Commented] (FLINK-13957) Redact passwords from dynamic properties on job submission

2019-09-04 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922434#comment-16922434 ] Matyas Orhidi commented on FLINK-13957: --- Sure, we can reuse the logic implemented in

[GitHub] [flink] zentol commented on a change in pull request #9558: [FLINK-13892][hs] Harden HistoryServerTest

2019-09-04 Thread GitBox
zentol commented on a change in pull request #9558: [FLINK-13892][hs] Harden HistoryServerTest URL: https://github.com/apache/flink/pull/9558#discussion_r320730108 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java

[GitHub] [flink] flinkbot commented on issue #9614: [FLINK-13623][Tests] Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

2019-09-04 Thread GitBox
flinkbot commented on issue #9614: [FLINK-13623][Tests] Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9614#issuecomment-527879001 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] lirui-apache opened a new pull request #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor…

2019-09-04 Thread GitBox
lirui-apache opened a new pull request #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor… URL: https://github.com/apache/flink/pull/9615 …k with OverwritableTableSink ## What is the purpose of the change To support insert overwrite

[GitHub] [flink] flinkbot edited a comment on issue #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side URL: https://github.com/apache/flink/pull/9609#issuecomment-527816485 ## CI report: * a658808b883045ccb7d6c5124be2130de8a79fbd : SUCCESS

[GitHub] [flink] tillrohrmann commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
tillrohrmann commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320768594 ## File path:

[GitHub] [flink] flinkbot commented on issue #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor…

2019-09-04 Thread GitBox
flinkbot commented on issue #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor… URL: https://github.com/apache/flink/pull/9615#issuecomment-527909466 ## CI report: * b9cf01cfcebcc894450a7dd9d8c013108faccd6c : UNKNOWN

[GitHub] [flink] tillrohrmann closed pull request #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side

2019-09-04 Thread GitBox
tillrohrmann closed pull request #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side URL: https://github.com/apache/flink/pull/9609 This is an automated message from the

[jira] [Resolved] (FLINK-13750) Separate HA services between client-/ and server-side

2019-09-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13750. --- Fix Version/s: 1.10.0 Release Note: The `HighAvailabilityServices` have been split up

[GitHub] [flink] TisonKun commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
TisonKun commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320792153 ## File path: flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java

[jira] [Created] (FLINK-13961) Remove obsolete abstraction JobExecutor(Service)

2019-09-04 Thread TisonKun (Jira)
TisonKun created FLINK-13961: Summary: Remove obsolete abstraction JobExecutor(Service) Key: FLINK-13961 URL: https://issues.apache.org/jira/browse/FLINK-13961 Project: Flink Issue Type:

[jira] [Created] (FLINK-13962) Execution#taskRestore leaks if task fails before deploying

2019-09-04 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-13962: --- Summary: Execution#taskRestore leaks if task fails before deploying Key: FLINK-13962 URL: https://issues.apache.org/jira/browse/FLINK-13962 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13958) Job class loader may not be reused after batch job recovery

2019-09-04 Thread David Moravek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922554#comment-16922554 ] David Moravek commented on FLINK-13958: --- [~1u0] It's unrelated issue. The behavior you are

[GitHub] [flink] TisonKun commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
TisonKun commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320792694 ## File path: flink-java/src/main/java/org/apache/flink/api/java/LocalEnvironment.java

[GitHub] [flink] kl0u commented on issue #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
kl0u commented on issue #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#issuecomment-527872635 Hi @TisonKun ! Thanks for the review. I integrated your comments. Please have a look and let me know what you think.

[jira] [Issue Comment Deleted] (FLINK-13957) Log dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-13957: --- Comment: was deleted (was: The issue fortunately did not make it to the upstream

[jira] [Updated] (FLINK-13957) Log dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-13957: --- Description: This would let users understand their job submissions better, expected output

[jira] [Reopened] (FLINK-13957) Log dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reopened FLINK-13957: > Log dynamic properties on job submission > > >

[GitHub] [flink] lirui-apache commented on issue #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor…

2019-09-04 Thread GitBox
lirui-apache commented on issue #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor… URL: https://github.com/apache/flink/pull/9615#issuecomment-527908571 cc @JingsongLi @bowenli86 @zjuwangg @xuefuz

[GitHub] [flink] TisonKun commented on issue #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side

2019-09-04 Thread GitBox
TisonKun commented on issue #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side URL: https://github.com/apache/flink/pull/9609#issuecomment-527917668 Thanks for your review @tillrohrmann!

[GitHub] [flink] flinkbot edited a comment on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper URL: https://github.com/apache/flink/pull/9409#issuecomment-519961173 ## CI report: * 9b5e1620eb70dd95996ec3e8b7bebe1f38ac89a5 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper URL: https://github.com/apache/flink/pull/9411#issuecomment-519965855 ## CI report: * 4af38a946a55d1d6b68d7d249f87a65239c947f7 : FAILURE

[jira] [Comment Edited] (FLINK-13958) Job class loader may not be reused after batch job recovery

2019-09-04 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922545#comment-16922545 ] Alex edited comment on FLINK-13958 at 9/4/19 2:35 PM: -- I think this has the same

[jira] [Created] (FLINK-13964) Remove usage of deprecated methods from MiniCluster

2019-09-04 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-13964: - Summary: Remove usage of deprecated methods from MiniCluster Key: FLINK-13964 URL: https://issues.apache.org/jira/browse/FLINK-13964 Project: Flink Issue

[jira] [Commented] (FLINK-13957) Redact passwords from dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922423#comment-16922423 ] Márton Balassi commented on FLINK-13957: Thanks for reporting the issue, [~morhidi]. I am aware

[jira] [Updated] (FLINK-13957) Redact passwords from dynamic properties logged on job submission

2019-09-04 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-13957: -- Summary: Redact passwords from dynamic properties logged on job submission (was: Redact

[jira] [Updated] (FLINK-13955) Integrate ContinuousFileReaderOperator with StreamTask mailbox execution model

2019-09-04 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13955: - Description: The {{ContinuousFileReaderOperator}} spawns an additional ({{reader}}) thread and coordinates

[jira] [Comment Edited] (FLINK-13382) Port DecimalITCase to unit tests

2019-09-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922478#comment-16922478 ] Leonard Xu edited comment on FLINK-13382 at 9/4/19 1:24 PM: [~jark] I am

[jira] [Commented] (FLINK-13382) Port DecimalITCase to unit tests

2019-09-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922478#comment-16922478 ] Leonard Xu commented on FLINK-13382: [~jark]I am glad to fix this > Port DecimalITCase to unit

[GitHub] [flink] flinkbot edited a comment on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper URL: https://github.com/apache/flink/pull/9412#issuecomment-519965864 ## CI report: * e9ff64826d561117cbd984df4201d15e0523b091 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper URL: https://github.com/apache/flink/pull/9407#issuecomment-51995 ## CI report: * bf69f9f25f8a62a494f530e7cba75879ac002412 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper URL: https://github.com/apache/flink/pull/9410#issuecomment-519963431 ## CI report: * 06b26ce69e490794f3bcda79766f8edc9d6e48ce : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper URL: https://github.com/apache/flink/pull/9409#issuecomment-519961173 ## CI report: * 9b5e1620eb70dd95996ec3e8b7bebe1f38ac89a5 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#issuecomment-519968250 ## CI report: * a585d0f8fef391d4da791b0cd1506e4f8b1acdc1 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper URL: https://github.com/apache/flink/pull/9408#issuecomment-519961164 ## CI report: * fbf9704fe2812d28d7a6b9ca6272a260e91089b3 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper URL: https://github.com/apache/flink/pull/9411#issuecomment-519965855 ## CI report: * 4af38a946a55d1d6b68d7d249f87a65239c947f7 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper URL: https://github.com/apache/flink/pull/9406#issuecomment-519954683 ## CI report: * eb27a4f02fee6d3d96a102ef7b4734d06442596a : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS

[GitHub] [flink] kl0u commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
kl0u commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320722937 ## File path: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java

[GitHub] [flink] flinkbot commented on issue #9614: [FLINK-13623][Tests] Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

2019-09-04 Thread GitBox
flinkbot commented on issue #9614: [FLINK-13623][Tests] Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9614#issuecomment-527883601 ## CI report: * e96c273e30e6a6fa2a55541668b5dd5cda5a34a0 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#issuecomment-527790327 ## CI report: * 0c2c5cdcc1267a49ef8df775e0e2ee46a5249487 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9610: [FLINK-13936][licensing] Update NOTICE-binary

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9610: [FLINK-13936][licensing] Update NOTICE-binary URL: https://github.com/apache/flink/pull/9610#issuecomment-527838177 ## CI report: * 755a869c93208b7d95a85d3fe4f0027ca55eff2e : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9614: [FLINK-13623][Tests] Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9614: [FLINK-13623][Tests] Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9614#issuecomment-527883601 ## CI report: * e96c273e30e6a6fa2a55541668b5dd5cda5a34a0 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201 ## CI report: * c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper URL: https://github.com/apache/flink/pull/9406#issuecomment-519954683 ## CI report: * eb27a4f02fee6d3d96a102ef7b4734d06442596a : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201 ## CI report: * c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper URL: https://github.com/apache/flink/pull/9406#issuecomment-519954683 ## CI report: * eb27a4f02fee6d3d96a102ef7b4734d06442596a : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper URL: https://github.com/apache/flink/pull/9407#issuecomment-51995 ## CI report: * bf69f9f25f8a62a494f530e7cba75879ac002412 : FAILURE

[jira] [Commented] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

2019-09-04 Thread David Moravek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922555#comment-16922555 ] David Moravek commented on FLINK-11402: --- This is a [JVM

[GitHub] [flink] flinkbot edited a comment on issue #9616: [FLINK-13957] [flink-yarn] Log dynamic properties on job submission

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9616: [FLINK-13957] [flink-yarn] Log dynamic properties on job submission URL: https://github.com/apache/flink/pull/9616#issuecomment-527924104 ## CI report: * b9114df609d2f21117e431ed36ae647a9f3a93a5 : PENDING

[jira] [Closed] (FLINK-13919) Remove 1.6.4 from downloads page and SVN

2019-09-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13919. Resolution: Fixed asf-site: a00510f26e1065b4f0c05524caf735ce8dba372a > Remove 1.6.4 from

[GitHub] [flink] Aitozi commented on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

2019-09-04 Thread GitBox
Aitozi commented on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file URL: https://github.com/apache/flink/pull/8479#issuecomment-527940974 Hi @azagrebin , I have done the fix following your comments, please help

[jira] [Commented] (FLINK-13838) Support -yta(--yarnshipArchives) arguments in flink run command line

2019-09-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922401#comment-16922401 ] Chesnay Schepler commented on FLINK-13838: -- My bad, I made a slight error in my question, so

[GitHub] [flink] flinkbot edited a comment on issue #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side URL: https://github.com/apache/flink/pull/9609#issuecomment-527816485 ## CI report: * a658808b883045ccb7d6c5124be2130de8a79fbd : SUCCESS

[GitHub] [flink] TisonKun commented on a change in pull request #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side

2019-09-04 Thread GitBox
TisonKun commented on a change in pull request #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side URL: https://github.com/apache/flink/pull/9609#discussion_r320714302 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side

2019-09-04 Thread GitBox
TisonKun commented on a change in pull request #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side URL: https://github.com/apache/flink/pull/9609#discussion_r320714465 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side

2019-09-04 Thread GitBox
TisonKun commented on a change in pull request #9609: [FLINK-13750][client][coordination] Separate HA services between client-side and server-side URL: https://github.com/apache/flink/pull/9609#discussion_r320717651 ## File path:

[jira] [Created] (FLINK-13958) Job class loader may not be reused after batch job recovery

2019-09-04 Thread David Moravek (Jira)
David Moravek created FLINK-13958: - Summary: Job class loader may not be reused after batch job recovery Key: FLINK-13958 URL: https://issues.apache.org/jira/browse/FLINK-13958 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9612: [FLINK-13622][Tests] Update WindowOperatorMigrationTest to restore from 1.9 savepoint

2019-09-04 Thread GitBox
flinkbot commented on issue #9612: [FLINK-13622][Tests] Update WindowOperatorMigrationTest to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9612#issuecomment-527871941 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] kl0u commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
kl0u commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320722263 ## File path: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java

[jira] [Closed] (FLINK-13609) StreamingFileSink - reset part counter on bucket change

2019-09-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-13609. -- Assignee: Kostas Kloudas Resolution: Won't Fix > StreamingFileSink - reset part counter

[GitHub] [flink] flinkbot edited a comment on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper URL: https://github.com/apache/flink/pull/9407#issuecomment-51995 ## CI report: * bf69f9f25f8a62a494f530e7cba75879ac002412 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper URL: https://github.com/apache/flink/pull/9408#issuecomment-519961164 ## CI report: * fbf9704fe2812d28d7a6b9ca6272a260e91089b3 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper URL: https://github.com/apache/flink/pull/9411#issuecomment-519965855 ## CI report: * 4af38a946a55d1d6b68d7d249f87a65239c947f7 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper URL: https://github.com/apache/flink/pull/9409#issuecomment-519961173 ## CI report: * 9b5e1620eb70dd95996ec3e8b7bebe1f38ac89a5 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper URL: https://github.com/apache/flink/pull/9412#issuecomment-519965864 ## CI report: * e9ff64826d561117cbd984df4201d15e0523b091 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper URL: https://github.com/apache/flink/pull/9410#issuecomment-519963431 ## CI report: * 06b26ce69e490794f3bcda79766f8edc9d6e48ce : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#issuecomment-519968250 ## CI report: * a585d0f8fef391d4da791b0cd1506e4f8b1acdc1 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper

2019-09-04 Thread GitBox
flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201 ## CI report: * c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : FAILURE

[jira] [Updated] (FLINK-13957) Log dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-13957: --- Summary: Log dynamic properties on job submission (was: Redact passwords from dynamic

[GitHub] [flink] flinkbot commented on issue #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor…

2019-09-04 Thread GitBox
flinkbot commented on issue #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor… URL: https://github.com/apache/flink/pull/9615#issuecomment-527902937 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320773696 ## File path: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java

[GitHub] [flink] aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320775256 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320773446 ## File path: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java

[GitHub] [flink] aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320774791 ## File path: flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java

[GitHub] [flink] aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
aljoscha commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320774343 ## File path: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java

[jira] [Commented] (FLINK-13958) Job class loader may not be reused after batch job recovery

2019-09-04 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922545#comment-16922545 ] Alex commented on FLINK-13958: -- I think this has the the same root cause as FLINK-11402. Specifically, that

[GitHub] [flink] TisonKun commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment

2019-09-04 Thread GitBox
TisonKun commented on a change in pull request #9607: [FLINK-13946] Remove job session related code from ExecutionEnvironment URL: https://github.com/apache/flink/pull/9607#discussion_r320787256 ## File path: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java

[jira] [Created] (FLINK-13963) Consolidate Hadoop file systems usage and Hadoop integration docs

2019-09-04 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-13963: --- Summary: Consolidate Hadoop file systems usage and Hadoop integration docs Key: FLINK-13963 URL: https://issues.apache.org/jira/browse/FLINK-13963 Project:

<    1   2   3   4   >