[jira] [Updated] (FLINK-13386) Frictions in the new default Web Frontend

2019-09-05 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13386: - Fix Version/s: 1.9.1 1.10.0 > Frictions in the new default Web Fronte

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-09-05 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923109#comment-16923109 ] TisonKun commented on FLINK-10333: -- Thanks for your information [~till.rohrmann]. I thi

[GitHub] [flink] KurtYoung commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem

2019-09-05 Thread GitBox
KurtYoung commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem URL: https://github.com/apache/flink/pull/8468#issuecomment-528232044 Another possible and simple solution might be: 1. we add some more docu

[jira] [Updated] (FLINK-13591) 'Completed Job List' in Flink web doesn't display right when job name is very long

2019-09-05 Thread Yadong Xie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yadong Xie updated FLINK-13591: --- Fix Version/s: 1.10.0 > 'Completed Job List' in Flink web doesn't display right when job name is ver

[jira] [Created] (FLINK-13966) Jar sorting in collect_license_files.sh is locale dependent

2019-09-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-13966: Summary: Jar sorting in collect_license_files.sh is locale dependent Key: FLINK-13966 URL: https://issues.apache.org/jira/browse/FLINK-13966 Project: Flink

[GitHub] [flink] zentol opened a new pull request #9623: [FLINK-13966][licensing] Pin locale for deterministic sort order

2019-09-05 Thread GitBox
zentol opened a new pull request #9623: [FLINK-13966][licensing] Pin locale for deterministic sort order URL: https://github.com/apache/flink/pull/9623 Pins the locale during the sort operation in `collect_license_files.sh` to `C`, which appears to be the one we've been using so far.

[GitHub] [flink] JingsongLi commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem

2019-09-05 Thread GitBox
JingsongLi commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem URL: https://github.com/apache/flink/pull/8468#issuecomment-528234933 Minor: another source is PartitionableTableSource? -

[jira] [Updated] (FLINK-13966) Jar sorting in collect_license_files.sh is locale dependent

2019-09-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13966: --- Labels: pull-request-available (was: ) > Jar sorting in collect_license_files.sh is locale

[GitHub] [flink] flinkbot commented on issue #9623: [FLINK-13966][licensing] Pin locale for deterministic sort order

2019-09-05 Thread GitBox
flinkbot commented on issue #9623: [FLINK-13966][licensing] Pin locale for deterministic sort order URL: https://github.com/apache/flink/pull/9623#issuecomment-528235206 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review you

[jira] [Created] (FLINK-13967) Generate full binary licensing via collect_license_files.sh

2019-09-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-13967: Summary: Generate full binary licensing via collect_license_files.sh Key: FLINK-13967 URL: https://issues.apache.org/jira/browse/FLINK-13967 Project: Flink

[GitHub] [flink] dawidwys commented on issue #9209: [FLINK-13388][web][docs] Updated screenshots to ones taken from the new UI

2019-09-05 Thread GitBox
dawidwys commented on issue #9209: [FLINK-13388][web][docs] Updated screenshots to ones taken from the new UI URL: https://github.com/apache/flink/pull/9209#issuecomment-528236656 @zentol sorry I missed your first comment. I updated the mentioned picture. If you are fine with it, I'

[GitHub] [flink] yanghua commented on issue #7435: [FLINK-11226] Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream

2019-09-05 Thread GitBox
yanghua commented on issue #7435: [FLINK-11226] Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream URL: https://github.com/apache/flink/pull/7435#issuecomment-528237240 @aljoscha Can you review this PR. It stayed so long time. --

[GitHub] [flink] yanghua edited a comment on issue #7435: [FLINK-11226] Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream

2019-09-05 Thread GitBox
yanghua edited a comment on issue #7435: [FLINK-11226] Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream URL: https://github.com/apache/flink/pull/7435#issuecomment-528237240 @aljoscha or @tillrohrmann Can you review this PR. It stayed so long time. -

[GitHub] [flink] zentol opened a new pull request #9624: [FLINK-13967][licensing] Fully generate binary licensing

2019-09-05 Thread GitBox
zentol opened a new pull request #9624: [FLINK-13967][licensing] Fully generate binary licensing URL: https://github.com/apache/flink/pull/9624 Based on #9623 and #9623 so that the correctness of the generator can be verified. With this PR `collect_license_files.sh` generates the fu

[GitHub] [flink] flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex URL: https://github.com/apache/flink/pull/9601#issuecomment-527404637 ## CI report: * 13d895349390698404a375fb4362a41b736ab0c6 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl

[jira] [Updated] (FLINK-13967) Generate full binary licensing via collect_license_files.sh

2019-09-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13967: --- Labels: pull-request-available (was: ) > Generate full binary licensing via collect_license

[jira] [Created] (FLINK-13968) Add travis check for the correctness of the binary licensing

2019-09-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-13968: Summary: Add travis check for the correctness of the binary licensing Key: FLINK-13968 URL: https://issues.apache.org/jira/browse/FLINK-13968 Project: Flink

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

2019-09-05 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 [Build](https://travis-ci.com/flink-ci/flink/builds/12

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

2019-09-05 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 [Build](https://travis-ci.co

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

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9611: [FLINK-13936][licensing] Update NOTICE-binary URL: https://github.com/apache/flink/pull/9611#issuecomment-527838217 ## CI report: * 553d10ef60bd6fc9019d4fa54fdf202c519ef8b5 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/12

[GitHub] [flink] flinkbot commented on issue #9624: [FLINK-13967][licensing] Fully generate binary licensing

2019-09-05 Thread GitBox
flinkbot commented on issue #9624: [FLINK-13967][licensing] Fully generate binary licensing URL: https://github.com/apache/flink/pull/9624#issuecomment-528238497 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[GitHub] [flink] flinkbot commented on issue #9623: [FLINK-13966][licensing] Pin locale for deterministic sort order

2019-09-05 Thread GitBox
flinkbot commented on issue #9623: [FLINK-13966][licensing] Pin locale for deterministic sort order URL: https://github.com/apache/flink/pull/9623#issuecomment-528238928 ## CI report: * ce739c4adad8c60c632cc08870723509bb42fa9a : UNKNOWN --

[GitHub] [flink] tillrohrmann commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-09-05 Thread GitBox
tillrohrmann commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-528239153 Thanks for the general answers @carp84. 1. Ok, then I guess that `CopyOnWriteSkipListS

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-09-05 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r320714521 ## File path: flink-state-backends/flink-statebackend-heap-spillab

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-09-05 Thread GitBox
tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r320715982 ## File path: flink-state-backends/flink-statebackend-heap-spillab

[GitHub] [flink] zentol opened a new pull request #9625: [FLINK-13968][travis] Check correctness of binary licensing

2019-09-05 Thread GitBox
zentol opened a new pull request #9625: [FLINK-13968][travis] Check correctness of binary licensing URL: https://github.com/apache/flink/pull/9625 Based on #9624. Adds a check to Travis for verifying the correctness of the binary licensing (NOTICE-binary, licenses-binary). Th

[jira] [Updated] (FLINK-13968) Add travis check for the correctness of the binary licensing

2019-09-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13968: --- Labels: pull-request-available (was: ) > Add travis check for the correctness of the binary

[GitHub] [flink] flinkbot edited a comment on issue #9209: [FLINK-13388][web][docs] Updated screenshots to ones taken from the new UI

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9209: [FLINK-13388][web][docs] Updated screenshots to ones taken from the new UI URL: https://github.com/apache/flink/pull/9209#issuecomment-514247617 ## CI report: * 82371dc90bbd38238a9c66dbe61afbca5c167442 : FAILURE [Build](https://travis-ci

[GitHub] [flink] flinkbot commented on issue #9625: [FLINK-13968][travis] Check correctness of binary licensing

2019-09-05 Thread GitBox
flinkbot commented on issue #9625: [FLINK-13968][travis] Check correctness of binary licensing URL: https://github.com/apache/flink/pull/9625#issuecomment-528240716 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pul

[GitHub] [flink] zentol merged pull request #9558: [FLINK-13892][hs] Harden HistoryServerTest

2019-09-05 Thread GitBox
zentol merged pull request #9558: [FLINK-13892][hs] Harden HistoryServerTest URL: https://github.com/apache/flink/pull/9558 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Closed] (FLINK-13892) HistoryServerTest failed on Travis

2019-09-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13892. Fix Version/s: 1.9.1 1.10.0 1.8.2 Resolution:

[jira] [Updated] (FLINK-13892) HistoryServerTest failed on Travis

2019-09-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13892: - Affects Version/s: (was: 1.10.0) 1.8.0 > HistoryServerTest fa

[jira] [Commented] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

2019-09-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923145#comment-16923145 ] Gyula Fora commented on FLINK-13566: Let's wait until the discussion of FLIP-59  [ht

[GitHub] [flink] mbalassi commented on issue #9616: [FLINK-13957] [flink-yarn] Log dynamic properties on job submission

2019-09-05 Thread GitBox
mbalassi commented on issue #9616: [FLINK-13957] [flink-yarn] Log dynamic properties on job submission URL: https://github.com/apache/flink/pull/9616#issuecomment-528244195 Hi @morhidi! Thank you for your contribution. It is a simple logging improvement, which takes security into co

[GitHub] [flink] flinkbot commented on issue #7435: [FLINK-11226] Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream

2019-09-05 Thread GitBox
flinkbot commented on issue #7435: [FLINK-11226] Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream URL: https://github.com/apache/flink/pull/7435#issuecomment-528244346 ## CI report: * ea015e262ee2969378dbbfcfbae4a494162a6063 : UNKNOWN -

[GitHub] [flink] zentol commented on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11

2019-09-05 Thread GitBox
zentol commented on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11 URL: https://github.com/apache/flink/pull/9622#issuecomment-528245270 Have you verified that this works with all hadoop version we explicitly support? -

[jira] [Created] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

2019-09-05 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-13969: - Summary: Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis Key: FLINK-13969 URL: https://issues.apache.org/jira/browse/FLINK-1396

[GitHub] [flink] flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex URL: https://github.com/apache/flink/pull/9601#issuecomment-527404637 ## CI report: * 13d895349390698404a375fb4362a41b736ab0c6 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] jinglining commented on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex

2019-09-05 Thread GitBox
jinglining commented on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex URL: https://github.com/apache/flink/pull/9601#issuecomment-528246002 ![image](https://user-images.githubusercontent.com/3992588/64322504-4569a780-cff5-11e9-95da-b45f82151553.png) screenshot

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

2019-09-05 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_r321120752 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/util/FakeClusterClient.j

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

2019-09-05 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 [Build](https://travis-ci.com/flink-ci/flink/builds/12

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

2019-09-05 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 [Build](https://travis-ci.co

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

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9611: [FLINK-13936][licensing] Update NOTICE-binary URL: https://github.com/apache/flink/pull/9611#issuecomment-527838217 ## CI report: * 553d10ef60bd6fc9019d4fa54fdf202c519ef8b5 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/12

[GitHub] [flink] flinkbot edited a comment on issue #9620: [FLINK-13959] Consolidate DetachedEnvironment and ContextEnvironment

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9620: [FLINK-13959] Consolidate DetachedEnvironment and ContextEnvironment URL: https://github.com/apache/flink/pull/9620#issuecomment-528072659 ## CI report: * 873a4970f35c7b321f46bdc669f1a9bc2f08fd4f : SUCCESS [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot edited a comment on issue #9623: [FLINK-13966][licensing] Pin locale for deterministic sort order

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9623: [FLINK-13966][licensing] Pin locale for deterministic sort order URL: https://github.com/apache/flink/pull/9623#issuecomment-528238928 ## CI report: * ce739c4adad8c60c632cc08870723509bb42fa9a : PENDING [Build](https://travis-ci.com/flink

[GitHub] [flink] flinkbot commented on issue #9625: [FLINK-13968][travis] Check correctness of binary licensing

2019-09-05 Thread GitBox
flinkbot commented on issue #9625: [FLINK-13968][travis] Check correctness of binary licensing URL: https://github.com/apache/flink/pull/9625#issuecomment-528246792 ## CI report: * e56dd0731c3aa8932e69cf0383ca6205336d5ddc : UNKNOWN ---

[GitHub] [flink] flinkbot commented on issue #9624: [FLINK-13967][licensing] Fully generate binary licensing

2019-09-05 Thread GitBox
flinkbot commented on issue #9624: [FLINK-13967][licensing] Fully generate binary licensing URL: https://github.com/apache/flink/pull/9624#issuecomment-528246748 ## CI report: * 3c3290ae04fc1c8e732f50135c34563add5b82a8 : UNKNOWN --

[GitHub] [flink] flinkbot edited a comment on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11 URL: https://github.com/apache/flink/pull/9622#issuecomment-528213410 ## CI report: * a1b2919dd5dc515f7864df86fd736b90a5869dab : SUCCE

[GitHub] [flink] flinkbot edited a comment on issue #9209: [FLINK-13388][web][docs] Updated screenshots to ones taken from the new UI

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9209: [FLINK-13388][web][docs] Updated screenshots to ones taken from the new UI URL: https://github.com/apache/flink/pull/9209#issuecomment-514247617 ## CI report: * 82371dc90bbd38238a9c66dbe61afbca5c167442 : FAILURE [Build](https://travis-ci

[GitHub] [flink] zentol commented on issue #9209: [FLINK-13388][web][docs] Updated screenshots to ones taken from the new UI

2019-09-05 Thread GitBox
zentol commented on issue #9209: [FLINK-13388][web][docs] Updated screenshots to ones taken from the new UI URL: https://github.com/apache/flink/pull/9209#issuecomment-528247806 @dawidwys That's a lot better, thanks! This is

[jira] [Commented] (FLINK-12847) Update Kinesis Connectors to latest Apache licensed libraries

2019-09-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923155#comment-16923155 ] Chesnay Schepler commented on FLINK-12847: -- [~phoenixjiangnan] [~carp84] The re

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-09-05 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923156#comment-16923156 ] TisonKun commented on FLINK-10333: -- Hi [~till.rohrmann] [~xiaogang.shi] [~StephanEwen],

[GitHub] [flink] yanghua opened a new pull request #9626: [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread GitBox
yanghua opened a new pull request #9626: [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9626 ## What is the purpose of the change *This pull request updates StatefulJobWBroadcastSta

[jira] [Updated] (FLINK-13624) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13624: --- Labels: pull-request-available (was: ) > Update StatefulJobWBroadcastStateMigrationITCase t

[GitHub] [flink] flinkbot edited a comment on issue #7435: [FLINK-11226] Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #7435: [FLINK-11226] Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream URL: https://github.com/apache/flink/pull/7435#issuecomment-528244346 ## CI report: * ea015e262ee2969378dbbfcfbae4a494162a6063 : PENDING [Build](https:

[GitHub] [flink] flinkbot commented on issue #9626: [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

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

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

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923160#comment-16923160 ] Till Rohrmann commented on FLINK-13958: --- Thanks for reporting this issue [~davidmo

[jira] [Commented] (FLINK-13962) Task state handles leak if the task fails before deploying

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923162#comment-16923162 ] Till Rohrmann commented on FLINK-13962: --- The improvement proposal sounds good to m

[jira] [Updated] (FLINK-13934) HistoryServerStaticFileServerHandlerTest failed on Travis

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13934: -- Priority: Critical (was: Major) > HistoryServerStaticFileServerHandlerTest failed on Travis >

[jira] [Updated] (FLINK-13934) HistoryServerStaticFileServerHandlerTest failed on Travis

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13934: -- Labels: test-stability (was: ) > HistoryServerStaticFileServerHandlerTest failed on Travis >

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

2019-09-05 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 [Build](https://travis-ci.co

[jira] [Updated] (FLINK-13904) Avoid competition between different rounds of checkpoint triggering

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13904: -- Component/s: (was: Runtime / Coordination) Runtime / Checkpointing > Avoi

[jira] [Updated] (FLINK-13905) Separate checkpoint triggering into stages

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13905: -- Component/s: Runtime / Checkpointing > Separate checkpoint triggering into stages > --

[GitHub] [flink] flinkbot edited a comment on issue #9620: [FLINK-13959] Consolidate DetachedEnvironment and ContextEnvironment

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9620: [FLINK-13959] Consolidate DetachedEnvironment and ContextEnvironment URL: https://github.com/apache/flink/pull/9620#issuecomment-528072659 ## CI report: * 873a4970f35c7b321f46bdc669f1a9bc2f08fd4f : SUCCESS [Build](https://travis-ci.com/f

[GitHub] [flink] zentol commented on a change in pull request #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

2019-09-05 Thread GitBox
zentol commented on a change in pull request #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#discussion_r321128309 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexDetailsIn

[GitHub] [flink] zentol commented on a change in pull request #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

2019-09-05 Thread GitBox
zentol commented on a change in pull request #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#discussion_r321128378 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecuti

[GitHub] [flink] flinkbot edited a comment on issue #9624: [FLINK-13967][licensing] Fully generate binary licensing

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9624: [FLINK-13967][licensing] Fully generate binary licensing URL: https://github.com/apache/flink/pull/9624#issuecomment-528246748 ## CI report: * 3c3290ae04fc1c8e732f50135c34563add5b82a8 : PENDING [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#issuecomment-518729517 ## CI report: * c2adafa7ee87b18ba6af0b5f518251150a8da386 : FAILURE [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9625: [FLINK-13968][travis] Check correctness of binary licensing

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9625: [FLINK-13968][travis] Check correctness of binary licensing URL: https://github.com/apache/flink/pull/9625#issuecomment-528246792 ## CI report: * e56dd0731c3aa8932e69cf0383ca6205336d5ddc : PENDING [Build](https://travis-ci.com/flink-ci/f

[jira] [Updated] (FLINK-13905) Separate checkpoint triggering into stages

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13905: -- Component/s: (was: Runtime / Coordination) > Separate checkpoint triggering into stages >

[jira] [Resolved] (FLINK-13500) RestClusterClient requires S3 access when HA is configured

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13500. --- Resolution: Resolved > RestClusterClient requires S3 access when HA is configured >

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-09-05 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923170#comment-16923170 ] TisonKun commented on FLINK-10333: -- Details and implementation of {{LeaderServer}} is r

[jira] [Comment Edited] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2019-09-05 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923170#comment-16923170 ] TisonKun edited comment on FLINK-10333 at 9/5/19 8:17 AM: -- {{Le

[jira] [Commented] (FLINK-13965) Keep hasDeprecatedKeys in ConfigOption and mark it with @Deprecated annotation

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923175#comment-16923175 ] Till Rohrmann commented on FLINK-13965: --- I guess you are right [~yanghua] that it

[jira] [Updated] (FLINK-13965) Keep hasDeprecatedKeys in ConfigOption and mark it with @Deprecated annotation

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13965: -- Fix Version/s: 1.9.1 1.10.0 1.8.2 > Keep hasDeprecatedKe

[jira] [Commented] (FLINK-13962) Task state handles leak if the task fails before deploying

2019-09-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923181#comment-16923181 ] Zhu Zhu commented on FLINK-13962: - [~till.rohrmann], yes I can work on it. > Task state

[jira] [Assigned] (FLINK-13962) Task state handles leak if the task fails before deploying

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13962: - Assignee: Zhu Zhu > Task state handles leak if the task fails before deploying > --

[jira] [Commented] (FLINK-13962) Task state handles leak if the task fails before deploying

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923186#comment-16923186 ] Till Rohrmann commented on FLINK-13962: --- Then go ahead. I've assigned you. > Task

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

2019-09-05 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 [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#issuecomment-518729517 ## CI report: * c2adafa7ee87b18ba6af0b5f518251150a8da386 : FAILURE [Build](https://travis-c

[GitHub] [flink] flinkbot commented on issue #9626: [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread GitBox
flinkbot commented on issue #9626: [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9626#issuecomment-528259769 ## CI report: * a5ff25e4e723718969013896955bfd82421f5314 : UNKNOWN ---

[jira] [Commented] (FLINK-13965) Keep hasDeprecatedKeys in ConfigOption and mark it with @Deprecated annotation

2019-09-05 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923198#comment-16923198 ] vinoyang commented on FLINK-13965: -- [~till.rohrmann] Yes, I would like to do this work.

[jira] [Commented] (FLINK-13962) Task state handles leak if the task fails before deploying

2019-09-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923203#comment-16923203 ] Zhu Zhu commented on FLINK-13962: - Hi [~till.rohrmann], looks this is no more an issue w

[jira] [Closed] (FLINK-13962) Task state handles leak if the task fails before deploying

2019-09-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-13962. --- Resolution: Invalid Not an issue in late versions > Task state handles leak if the task fails before deploy

[GitHub] [flink] flinkbot edited a comment on issue #9626: [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9626: [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9626#issuecomment-528259769 ## CI report: * a5ff25e4e723718969013896955bfd82421f5314 : PENDING

[jira] [Updated] (FLINK-13624) Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.9 savepoint

2019-09-05 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13624: - Summary: Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.9 savepoint (was: Upd

[jira] [Updated] (FLINK-13624) Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.9 savepoint

2019-09-05 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13624: - Description: Update {{StatefulJobWBroadcastStateMigrationITCase.scala}} to restore from 1.9 savepoint.

[jira] [Updated] (FLINK-13625) Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13625: - Description: Update {{StatefulJobSavepointMigrationITCase}} to restore from 1.9 savepoint. (was: Update

[jira] [Updated] (FLINK-13625) Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13625: - Summary: Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint (was: Update Stateful

[jira] [Commented] (FLINK-13895) Client does not exit when bin/yarn-session.sh come fail

2019-09-05 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923213#comment-16923213 ] Andrey Zagrebin commented on FLINK-13895: - >From the logs, looks like the applic

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

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923214#comment-16923214 ] Till Rohrmann commented on FLINK-13964: --- Looking at this problem I realised that i

[jira] [Comment Edited] (FLINK-13895) Client does not exit when bin/yarn-session.sh come fail

2019-09-05 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923213#comment-16923213 ] Andrey Zagrebin edited comment on FLINK-13895 at 9/5/19 8:57 AM: -

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

2019-09-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923214#comment-16923214 ] Till Rohrmann edited comment on FLINK-13964 at 9/5/19 8:59 AM: ---

[GitHub] [flink] flinkbot edited a comment on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

2019-09-05 Thread GitBox
flinkbot edited a comment on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#issuecomment-526075111 ## CI report: * 64f02281954e69bcfbe858eb40b8f1846cfbe195 : FAILURE [Build](https://travis-ci.com/flink-ci

[jira] [Updated] (FLINK-13624) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.9 savepoint

2019-09-05 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13624: - Summary: Update StatefulJobSavepointMigrationITCase.scala to restore from 1.9 savepoint (was: Update St

[jira] [Updated] (FLINK-13625) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13625: - Summary: Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint (was: Update St

[jira] [Created] (FLINK-13970) Remove or move LifoSetQueue

2019-09-05 Thread TisonKun (Jira)
TisonKun created FLINK-13970: Summary: Remove or move LifoSetQueue Key: FLINK-13970 URL: https://issues.apache.org/jira/browse/FLINK-13970 Project: Flink Issue Type: Sub-task Components

[jira] [Updated] (FLINK-13624) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.9 savepoint

2019-09-05 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13624: - Description: Update {{StatefulJobSavepointMigrationITCase.scala}} to restore from 1.9 savepoint. (was:

[GitHub] [flink] yanghua opened a new pull request #9627: [FLINK-13625][Tests] Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread GitBox
yanghua opened a new pull request #9627: [FLINK-13625][Tests] Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9627 ## What is the purpose of the change *This pull request updates StatefulJobSavepointMigrationITCase to

[jira] [Updated] (FLINK-13625) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

2019-09-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13625: --- Labels: pull-request-available (was: ) > Update StatefulJobWBroadcastStateMigrationITCase t

  1   2   3   4   >