[jira] [Commented] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

2019-10-14 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950912#comment-16950912 ] Alex commented on FLINK-14224: -- I couldn't reproduce on Travis too. The hypothesis with ru

[jira] [Commented] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

2019-10-10 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948404#comment-16948404 ] Alex commented on FLINK-14224: -- I have difficulties to reproduce it on my local machine, ne

[jira] [Commented] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

2019-09-27 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939533#comment-16939533 ] Alex commented on FLINK-14224: -- [~trohrmann], I want to look into those issues. My suspect

[jira] [Updated] (FLINK-12958) Integrate AsyncWaitOperator with mailbox

2019-09-20 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12958: - Fix Version/s: 1.10.0 > Integrate AsyncWaitOperator with mailbox > > >

[jira] [Updated] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-09-20 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12481: - Fix Version/s: 1.10.0 > Make processing time timer trigger run via the mailbox > ---

[jira] [Updated] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue

2019-09-20 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12482: - Fix Version/s: 1.10.0 > Make checkpoint trigger/notifyComplete run via the mailbox queue > -

[jira] [Updated] (FLINK-14156) Execute/run processing timer triggers taking into account operator level mailbox loops

2019-09-20 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-14156: - Description: With FLINK-12481, the timer triggers are executed by the mailbox thread and passed to the mailbox

[jira] [Created] (FLINK-14156) Execute/run processing timer triggers taking into account operator level mailbox loops

2019-09-20 Thread Alex (Jira)
Alex created FLINK-14156: Summary: Execute/run processing timer triggers taking into account operator level mailbox loops Key: FLINK-14156 URL: https://issues.apache.org/jira/browse/FLINK-14156 Project: Flink

[jira] [Created] (FLINK-14103) StreamTask refactoring: refine and improve exceptions passed to failExternally call

2019-09-17 Thread Alex (Jira)
Alex created FLINK-14103: Summary: StreamTask refactoring: refine and improve exceptions passed to failExternally call Key: FLINK-14103 URL: https://issues.apache.org/jira/browse/FLINK-14103 Project: Flink

[jira] [Created] (FLINK-14097) Optimize AsyncWaitOperator to process more than one element per mailbox letter

2019-09-17 Thread Alex (Jira)
Alex created FLINK-14097: Summary: Optimize AsyncWaitOperator to process more than one element per mailbox letter Key: FLINK-14097 URL: https://issues.apache.org/jira/browse/FLINK-14097 Project: Flink

[jira] [Closed] (FLINK-12958) Integrate AsyncWaitOperator with mailbox

2019-09-17 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex closed FLINK-12958. Resolution: Fixed > Integrate AsyncWaitOperator with mailbox > > >

[jira] [Commented] (FLINK-12958) Integrate AsyncWaitOperator with mailbox

2019-09-17 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931358#comment-16931358 ] Alex commented on FLINK-12958: -- PR: [https://github.com/apache/flink/pull/9564] > Integrat

[jira] [Closed] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue

2019-09-17 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex closed FLINK-12482. Resolution: Fixed > Make checkpoint trigger/notifyComplete run via the mailbox queue > ---

[jira] [Closed] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-09-17 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex closed FLINK-12481. Resolution: Fixed > Make processing time timer trigger run via the mailbox > -

[jira] [Commented] (FLINK-6958) Async I/O timeout not work

2019-09-11 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16927585#comment-16927585 ] Alex commented on FLINK-6958: - Hi, do you know if this issue is still actual? Is it fixed by

[jira] [Commented] (FLINK-14011) Make some fields final and initialize them during construction in AsyncWaitOperator

2019-09-09 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925509#comment-16925509 ] Alex commented on FLINK-14011: -- CC [~pnowojski]. > Make some fields final and initialize t

[jira] [Created] (FLINK-14011) Make some fields final and initialize them during construction in AsyncWaitOperator

2019-09-09 Thread Alex (Jira)
Alex created FLINK-14011: Summary: Make some fields final and initialize them during construction in AsyncWaitOperator Key: FLINK-14011 URL: https://issues.apache.org/jira/browse/FLINK-14011 Project: Flink

[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&focusedCommentId=16922545#comment-16922545 ] Alex edited comment on FLINK-13958 at 9/4/19 2:35 PM: -- I think this

[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&focusedCommentId=16922545#comment-16922545 ] Alex commented on FLINK-13958: -- I think this has the the same root cause as FLINK-11402. Sp

[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 acti

[jira] [Comment Edited] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-09-04 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16922372#comment-16922372 ] Alex edited comment on FLINK-12481 at 9/4/19 10:48 AM: --- PR: https:

[jira] [Commented] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-09-04 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16922372#comment-16922372 ] Alex commented on FLINK-12481: -- PR; https://github.com/apache/flink/pull/9564 > Make proce

[jira] [Commented] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue

2019-09-04 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16922371#comment-16922371 ] Alex commented on FLINK-12482: -- PR: [https://github.com/apache/flink/pull/9564] > Make che

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

2019-09-04 Thread Alex (Jira)
Alex created FLINK-13955: Summary: Integrate ContinuousFileReaderOperator with StreamTask mailbox execution model Key: FLINK-13955 URL: https://issues.apache.org/jira/browse/FLINK-13955 Project: Flink

[jira] [Commented] (FLINK-10478) Kafka Producer wrongly formats "%" for transaction ID

2019-08-28 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917709#comment-16917709 ] Alex commented on FLINK-10478: -- I think this ticket was superseded by FLINK-13789. > Kafka

[jira] [Updated] (FLINK-13871) Consolidate isRunning, canceled, isFinished fields in StreamTask and SourceStreamTask

2019-08-27 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13871: - Description: {{StreamTask}} has two {{volatile boolean}} fields ({{canceled}}, {{isFinished}}) and {{SourceStre

[jira] [Created] (FLINK-13871) Consolidate isRunning, canceled, isFinished fields in StreamTask and SourceStreamTask

2019-08-27 Thread Alex (Jira)
Alex created FLINK-13871: Summary: Consolidate isRunning, canceled, isFinished fields in StreamTask and SourceStreamTask Key: FLINK-13871 URL: https://issues.apache.org/jira/browse/FLINK-13871 Project: Flink

[jira] [Updated] (FLINK-13824) Code duplication in tools/travis_watchdog.sh to launch watchdog process

2019-08-23 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13824: - Summary: Code duplication in tools/travis_watchdog.sh to launch watchdog process (was: Code duplication in tool

[jira] [Updated] (FLINK-13824) Code duplication in tools/trawis_watchdog.sh to launch watchdog process

2019-08-23 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13824: - Description: {{travis_watchdog.sh}} scripts launches monitoring processes for Java processes (spawned by {{mvn

[jira] [Updated] (FLINK-13825) The original plugins dir is not restored after e2e test run

2019-08-23 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13825: - Description: Previously, the result of Flink distribution build didn't contain {{plugins}} dir. Instead, for so

[jira] [Created] (FLINK-13825) The original plugins dir is not restored after e2e test run

2019-08-23 Thread Alex (Jira)
Alex created FLINK-13825: Summary: The original plugins dir is not restored after e2e test run Key: FLINK-13825 URL: https://issues.apache.org/jira/browse/FLINK-13825 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13824) Code duplication in tools/trawis_watchdog.sh to launch watchdog process

2019-08-23 Thread Alex (Jira)
Alex created FLINK-13824: Summary: Code duplication in tools/trawis_watchdog.sh to launch watchdog process Key: FLINK-13824 URL: https://issues.apache.org/jira/browse/FLINK-13824 Project: Flink Issu

[jira] [Updated] (FLINK-13772) GroupWindowTableAggregateITCase tests fail on Travis

2019-08-22 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13772: - Summary: GroupWindowTableAggregateITCase tests fail on Travis (was: GroupWindowTableAggregateITCase.testEventTi

[jira] [Commented] (FLINK-13772) GroupWindowTableAggregateITCase.testEventTimeSlidingGroupWindowOverTimeNonOverlappingSplitPane

2019-08-22 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16913556#comment-16913556 ] Alex commented on FLINK-13772: -- Other tests failures of the same test class: 1. CI log: ht

[jira] [Created] (FLINK-13822) TableAggregateITCase.testGroupByFlatAggregate test failure: IllegalStateException: Concurrent access to KryoSerializer.

2019-08-22 Thread Alex (Jira)
Alex created FLINK-13822: Summary: TableAggregateITCase.testGroupByFlatAggregate test failure: IllegalStateException: Concurrent access to KryoSerializer. Key: FLINK-13822 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Commented] (FLINK-12034) KafkaITCase.testAllDeletes failed on Travis

2019-08-22 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16913359#comment-16913359 ] Alex commented on FLINK-12034: -- Another one: https://api.travis-ci.com/v3/job/227362744/log

[jira] [Updated] (FLINK-12958) Integrate AsyncWaitOperator with mailbox

2019-08-13 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12958: - Description: Currently, the {{AsyncWaitOperator::processElement()}} is running in the main task thread and bloc

[jira] [Commented] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-08-13 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16905930#comment-16905930 ] Alex commented on FLINK-12481: -- Blocked by FLINK-12958. > Make processing time timer trigg

[jira] [Commented] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue

2019-08-13 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16905929#comment-16905929 ] Alex commented on FLINK-12482: -- Blocked by FLINK-12958. > Make checkpoint trigger/notifyCo

[jira] [Commented] (FLINK-13663) SQL Client end-to-end test for modern Kafka failed on Travis

2019-08-12 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16905441#comment-16905441 ] Alex commented on FLINK-13663: -- FYI, the {{curl}} retries were added as an attempt to addre

[jira] [Commented] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-08-08 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16903104#comment-16903104 ] Alex commented on FLINK-12481: -- Hi [~SleePy], I've temporally closed the original PR of mov

[jira] [Updated] (FLINK-12998) Document Plugins mechanism

2019-08-01 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12998: - Fix Version/s: 1.10.0 > Document Plugins mechanism > -- > > Key: FLINK-1

[jira] [Updated] (FLINK-13377) Streaming SQL e2e test failed on travis

2019-07-31 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13377: - Description: This is an instance: [https://api.travis-ci.org/v3/job/562011491/log.txt] {code} =

[jira] [Updated] (FLINK-13441) Add batch sql E2E test which runs with fewer slots than parallelism

2019-07-31 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13441: - Summary: Add batch sql E2E test which runs with fewer slots than parallelism (was: Add batch E2E test which run

[jira] [Updated] (FLINK-13441) Add batch E2E test which runs with fewer slots than parallelism

2019-07-31 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13441: - Description: We should adapt the existing batch E2E test to use the newly introduced {{ScheduleMode#LAZY_FROM_S

[jira] [Commented] (FLINK-13504) NoSuchFieldError when executing DDL via tEnv.sqlUpdate in application project

2019-07-31 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896893#comment-16896893 ] Alex commented on FLINK-13504: -- I have the same issue on my local build. I think this is du

[jira] [Comment Edited] (FLINK-13384) The back pressure monitoring does not work for StreamSources

2019-07-24 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891700#comment-16891700 ] Alex edited comment on FLINK-13384 at 7/24/19 9:08 AM: --- > FLINK-12

[jira] [Commented] (FLINK-13384) The back pressure monitoring does not work for StreamSources

2019-07-24 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891700#comment-16891700 ] Alex commented on FLINK-13384: -- > FLINK-12483 introduced a separate thread for executing th

[jira] [Commented] (FLINK-12858) Potential distributed deadlock in case of synchronous savepoint failure

2019-07-16 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16886211#comment-16886211 ] Alex commented on FLINK-12858: -- I'm not sure, but failing the task (that originates the dis

[jira] [Commented] (FLINK-12858) Potential distributed deadlock in case of synchronous savepoint failure

2019-07-16 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16886197#comment-16886197 ] Alex commented on FLINK-12858: -- Some recap of discussions around this issue: the proposed w

[jira] [Commented] (FLINK-12858) Potentially not properly working Flink job in case of stop-with-savepoint failure

2019-07-11 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882826#comment-16882826 ] Alex commented on FLINK-12858: -- Hi [~guanghui], by non-source tasks I mean tasks that are n

[jira] [Assigned] (FLINK-12858) Potentially not properly working Flink job in case of stop-with-savepoint failure

2019-07-11 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12858: Assignee: Alex Affects Version/s: 1.9.0 Priority: Blocker (was: Minor) > Poten

[jira] [Commented] (FLINK-12998) Document Plugins mechanism

2019-07-11 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882779#comment-16882779 ] Alex commented on FLINK-12998: -- I'm trying to understand how batch job connectors relate to

[jira] [Created] (FLINK-13205) Checkpoints/savepoints injection has loose ordering properties when a stop-with-savepoint is triggered

2019-07-11 Thread Alex (JIRA)
Alex created FLINK-13205: Summary: Checkpoints/savepoints injection has loose ordering properties when a stop-with-savepoint is triggered Key: FLINK-13205 URL: https://issues.apache.org/jira/browse/FLINK-13205

[jira] [Updated] (FLINK-13102) Travis build optimization

2019-07-10 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13102: - Description: For some types of PRs, it's relatively easy to tell that the changes in a PR don't affect other pa

[jira] [Updated] (FLINK-13102) Travis build optimization

2019-07-10 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13102: - Description: For some types of PRs, it's relatively easy to tell that the changes in a PR don't affect other pa

[jira] [Updated] (FLINK-13102) Travis build optimization

2019-07-10 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13102: - Description: For some types of PRs, it's relatively easy to tell that the changes in a PR don't affect other pa

[jira] [Commented] (FLINK-13063) AsyncWaitOperator shouldn't be releasing checkpointingLock

2019-07-05 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879112#comment-16879112 ] Alex commented on FLINK-13063: -- I think the root cause is the same, that the {{AsyncWaitOpe

[jira] [Updated] (FLINK-13102) Travis build optimization

2019-07-04 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13102: - Description: For some types of PRs, it's relatively easy to tell that the changes in a PR don't affect other pa

[jira] [Created] (FLINK-13102) Travis build optimization

2019-07-04 Thread Alex (JIRA)
Alex created FLINK-13102: Summary: Travis build optimization Key: FLINK-13102 URL: https://issues.apache.org/jira/browse/FLINK-13102 Project: Flink Issue Type: Improvement Components: Travi

[jira] [Comment Edited] (FLINK-13063) AsyncWaitOperator shouldn't be releasing checkpointingLock

2019-07-04 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878497#comment-16878497 ] Alex edited comment on FLINK-13063 at 7/4/19 9:40 AM: -- I have encou

[jira] [Commented] (FLINK-13063) AsyncWaitOperator shouldn't be releasing checkpointingLock

2019-07-04 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878497#comment-16878497 ] Alex commented on FLINK-13063: -- I have encountered another issue with {{AsyncWaitOperator}}

[jira] [Commented] (FLINK-12773) Unstable kafka e2e test

2019-06-28 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16874749#comment-16874749 ] Alex commented on FLINK-12773: -- More recent failures: [https://api.travis-ci.org/v3/job/551

[jira] [Resolved] (FLINK-12925) Docker embedded job end-to-end test fails

2019-06-25 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex resolved FLINK-12925. -- Resolution: Fixed Should be fixed with commit {{58c0cbc194ee673c4eef93cade63e992dd6ff089}} ( https://github.c

[jira] [Commented] (FLINK-12752) Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

2019-06-21 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869378#comment-16869378 ] Alex commented on FLINK-12752: -- If a user have to specify --{{jobId-seed}} manually, wouldn

[jira] [Commented] (FLINK-12925) Docker embedded job end-to-end test fails

2019-06-21 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869347#comment-16869347 ] Alex commented on FLINK-12925: -- There is a fix embedded in [~knaufk]'s PR: https://github.

[jira] [Created] (FLINK-12925) Docker embedded job end-to-end test fails

2019-06-21 Thread Alex (JIRA)
Alex created FLINK-12925: Summary: Docker embedded job end-to-end test fails Key: FLINK-12925 URL: https://issues.apache.org/jira/browse/FLINK-12925 Project: Flink Issue Type: Bug Component

[jira] [Updated] (FLINK-12925) Docker embedded job end-to-end test fails

2019-06-21 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12925: - Description: The test fails at the one of the Docker image build steps: {code} Step 16/22 : ADD $job_artifacts/*

[jira] [Created] (FLINK-12858) Potentially not properly working Flink job in case of stop-with-savepoint failure

2019-06-15 Thread Alex (JIRA)
Alex created FLINK-12858: Summary: Potentially not properly working Flink job in case of stop-with-savepoint failure Key: FLINK-12858 URL: https://issues.apache.org/jira/browse/FLINK-12858 Project: Flink

[jira] [Comment Edited] (FLINK-12143) Mechanism to ship plugin jars in the cluster

2019-06-15 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864085#comment-16864085 ] Alex edited comment on FLINK-12143 at 6/15/19 11:01 AM: -The pro

[jira] [Comment Edited] (FLINK-12143) Mechanism to ship plugin jars in the cluster

2019-06-15 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864085#comment-16864085 ] Alex edited comment on FLINK-12143 at 6/15/19 11:00 AM: -The pro

[jira] [Commented] (FLINK-12773) Unstable kafka e2e test

2019-06-14 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864095#comment-16864095 ] Alex commented on FLINK-12773: -- Is it possible to download/prepare external dependencies on

[jira] [Commented] (FLINK-12143) Mechanism to ship plugin jars in the cluster

2019-06-14 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864085#comment-16864085 ] Alex commented on FLINK-12143: -- The problem is because * {{parentFirstLoaderPatterns}} con

[jira] [Updated] (FLINK-12513) Improve end-to-end (bash based) tests

2019-06-07 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12513: - Description: Tests in {{flink-end-to-end-tests/test-scripts}} directory are re-using the same Flink directory t

[jira] [Comment Edited] (FLINK-12773) Unstable kafka e2e test

2019-06-07 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858386#comment-16858386 ] Alex edited comment on FLINK-12773 at 6/7/19 8:16 AM: -- [~dawidwys],

[jira] [Commented] (FLINK-12773) Unstable kafka e2e test

2019-06-07 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858386#comment-16858386 ] Alex commented on FLINK-12773: -- [~dawidwys], FYI, I have encountered this too and have just

[jira] [Assigned] (FLINK-12313) SynchronousCheckpointITCase.taskCachedThreadPoolAllowsForSynchronousCheckpoints is unstable

2019-06-03 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12313: Assignee: Alex > SynchronousCheckpointITCase.taskCachedThreadPoolAllowsForSynchronousCheckpoints > is un

[jira] [Comment Edited] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue

2019-05-29 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850703#comment-16850703 ] Alex edited comment on FLINK-12482 at 5/29/19 9:42 AM: --- Some techn

[jira] [Commented] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue

2019-05-29 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850703#comment-16850703 ] Alex commented on FLINK-12482: -- Some technical notes/details of the possible approach (disc

[jira] [Assigned] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue

2019-05-27 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12482: Assignee: Alex (was: Stefan Richter) > Make checkpoint trigger/notifyComplete run via the mailbox queue

[jira] [Assigned] (FLINK-12481) Make processing time timer trigger run via the mailbox

2019-05-22 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12481: Assignee: Alex > Make processing time timer trigger run via the mailbox > ---

[jira] [Assigned] (FLINK-12477) Change threading-model in StreamTask to a mailbox-based approach

2019-05-22 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12477: Assignee: (was: Alex) > Change threading-model in StreamTask to a mailbox-based approach > --

[jira] [Assigned] (FLINK-12477) Change threading-model in StreamTask to a mailbox-based approach

2019-05-22 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12477: Assignee: Alex > Change threading-model in StreamTask to a mailbox-based approach > -

[jira] [Assigned] (FLINK-12521) Use minio as AWS S3 alternative in end-to-end tests

2019-05-20 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-12521: Assignee: (was: Alex) > Use minio as AWS S3 alternative in end-to-end tests > ---

[jira] [Updated] (FLINK-12521) Use minio as AWS S3 alternative in end-to-end tests

2019-05-20 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12521: - Fix Version/s: (was: 1.9.0) > Use minio as AWS S3 alternative in end-to-end tests >

[jira] [Created] (FLINK-12556) Extend some end-to-end tests to run with custom (input) File System implementation

2019-05-20 Thread Alex (JIRA)
Alex created FLINK-12556: Summary: Extend some end-to-end tests to run with custom (input) File System implementation Key: FLINK-12556 URL: https://issues.apache.org/jira/browse/FLINK-12556 Project: Flink

[jira] [Updated] (FLINK-12521) Use minio as AWS S3 alternative in end-to-end tests

2019-05-15 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-12521: - Description: Some end-to-end tests (located in {{flink-end-to-end-tests/test-scripts}}) are using S3 storage fo

[jira] [Created] (FLINK-12521) Use minio as AWS S3 alternative in end-to-end tests

2019-05-15 Thread Alex (JIRA)
Alex created FLINK-12521: Summary: Use minio as AWS S3 alternative in end-to-end tests Key: FLINK-12521 URL: https://issues.apache.org/jira/browse/FLINK-12521 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12513) Improve end-to-end (bash based) tests

2019-05-15 Thread Alex (JIRA)
Alex created FLINK-12513: Summary: Improve end-to-end (bash based) tests Key: FLINK-12513 URL: https://issues.apache.org/jira/browse/FLINK-12513 Project: Flink Issue Type: Improvement Compo

[jira] [Commented] (FLINK-11798) Incorrect Kubernetes Documentation

2019-03-07 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787142#comment-16787142 ] Alex commented on FLINK-11798: -- [~pritesh-patel], unfortunately the docker entry point for

[jira] [Assigned] (FLINK-11798) Incorrect Kubernetes Documentation

2019-03-07 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-11798: Assignee: Alex > Incorrect Kubernetes Documentation > -- > >

[jira] [Created] (FLINK-11787) Add web ui metrics reporting workaround into Flink Kubernetes resource definitions (Flink 1.7)

2019-02-28 Thread Alex (JIRA)
Alex created FLINK-11787: Summary: Add web ui metrics reporting workaround into Flink Kubernetes resource definitions (Flink 1.7) Key: FLINK-11787 URL: https://issues.apache.org/jira/browse/FLINK-11787 Projec

[jira] [Updated] (FLINK-11716) Introduce Task Manager configuration option to customize address binding mechanism

2019-02-22 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-11716: - Description: Proposed configuration (in {{flink-config.yaml}}): {code:java} taskmanager.network.bind-policy: nam

[jira] [Updated] (FLINK-11716) Introduce Task Manager configuration option to customize address binding mechanism

2019-02-22 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-11716: - Description: Proposed configuration (in {{flink-config.yaml}}): {code:java} network.taskmanager.bind-policy: nam

[jira] [Created] (FLINK-11716) Introduce Task Manager configuration option to customize address binding mechanism

2019-02-21 Thread Alex (JIRA)
Alex created FLINK-11716: Summary: Introduce Task Manager configuration option to customize address binding mechanism Key: FLINK-11716 URL: https://issues.apache.org/jira/browse/FLINK-11716 Project: Flink

[jira] [Commented] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

2019-02-21 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16774031#comment-16774031 ] Alex commented on FLINK-11632: -- [~uce], [~till.rohrmann], because of risk of being not bac

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

2019-02-21 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773917#comment-16773917 ] Alex commented on FLINK-11127: -- [~spoganshev], [~ray365], there is a simpler method to set

[jira] [Commented] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

2019-02-18 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16771163#comment-16771163 ] Alex commented on FLINK-11632: -- [~Salatich], I've prepared a change set some time ago and j

[jira] [Created] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

2019-02-15 Thread Alex (JIRA)
Alex created FLINK-11632: Summary: Make TaskManager automatic bind address picking more explicit (by default) and more configurable Key: FLINK-11632 URL: https://issues.apache.org/jira/browse/FLINK-11632 Proj

[jira] [Created] (FLINK-11438) Config for submitted job path

2019-01-28 Thread Alex (JIRA)
Alex created FLINK-11438: Summary: Config for submitted job path Key: FLINK-11438 URL: https://issues.apache.org/jira/browse/FLINK-11438 Project: Flink Issue Type: Improvement Reporter: A

  1   2   >