[jira] [Created] (FLINK-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker

Stephan Ewen created FLINK-4697: --- Summary: Gather more detailed checkpoint stats in CheckpointStatsTracker Key: FLINK-4697 URL: https://issues.apache.org/jira/browse/FLINK-4697 Project: Flink

[jira] [Closed] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4696. --- > Limit the number of Akka Dispatcher Threads in LocalMiniCluster > --

[jira] [Closed] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime

[ https://issues.apache.org/jira/browse/FLINK-4685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4685. --- > Gather operator checkpoint durations data sizes from the runtime > -

[jira] [Resolved] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime

[ https://issues.apache.org/jira/browse/FLINK-4685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4685. - Resolution: Implemented Implemented in b1642e32c2f69c60c2b212260c3479feb66a9165 > Gather operator

[jira] [Created] (FLINK-4698) Visualize additional checkpoint information

Stephan Ewen created FLINK-4698: --- Summary: Visualize additional checkpoint information Key: FLINK-4698 URL: https://issues.apache.org/jira/browse/FLINK-4698 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4560) enforcer java version as 1.7

[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4560. --- > enforcer java version as 1.7 > > > Key: FLINK-4560 >

[jira] [Resolved] (FLINK-4560) enforcer java version as 1.7

[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4560. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via b928935b8c5be02b23dd2cb87144ae1ea001278c

[jira] [Resolved] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

[ https://issues.apache.org/jira/browse/FLINK-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4543. - Resolution: Fixed Fixed via 90902914ac4b11f9554b67ad49e0d697a0d02f93 > Race Deadlock in SpilledSu

[jira] [Closed] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

[ https://issues.apache.org/jira/browse/FLINK-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4543. --- > Race Deadlock in SpilledSubpartitionViewTest > > >

[jira] [Commented] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()

[ https://issues.apache.org/jira/browse/FLINK-4675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527122#comment-15527122 ] Stephan Ewen commented on FLINK-4675: - It would be okay to break it now (from what we

[jira] [Created] (FLINK-4702) Kafka consumer must commit offsets asynchronously

Stephan Ewen created FLINK-4702: --- Summary: Kafka consumer must commit offsets asynchronously Key: FLINK-4702 URL: https://issues.apache.org/jira/browse/FLINK-4702 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4701) Unprotected access to cancelables in StreamTask

[ https://issues.apache.org/jira/browse/FLINK-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15529571#comment-15529571 ] Stephan Ewen commented on FLINK-4701: - I don't understand this. The constructor does n

[jira] [Commented] (FLINK-4701) Unprotected access to cancelables in StreamTask

[ https://issues.apache.org/jira/browse/FLINK-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15530460#comment-15530460 ] Stephan Ewen commented on FLINK-4701: - Every actual modification to "cancelables" is l

[jira] [Commented] (FLINK-4707) Including flink-connector-filesystem as dependency fails build

[ https://issues.apache.org/jira/browse/FLINK-4707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1553#comment-1553 ] Stephan Ewen commented on FLINK-4707: - I think the root cause of the recently added mi

[jira] [Created] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies

Stephan Ewen created FLINK-4708: --- Summary: Scope Mini Kerberos Cluster dependencies as test dependencies Key: FLINK-4708 URL: https://issues.apache.org/jira/browse/FLINK-4708 Project: Flink Is

[jira] [Commented] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream

[ https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532237#comment-15532237 ] Stephan Ewen commented on FLINK-4709: - Good catch. Do you want to open a pull request

[jira] [Created] (FLINK-4710) Remove transitive Guice dependency from Hadoop

Stephan Ewen created FLINK-4710: --- Summary: Remove transitive Guice dependency from Hadoop Key: FLINK-4710 URL: https://issues.apache.org/jira/browse/FLINK-4710 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies

[ https://issues.apache.org/jira/browse/FLINK-4708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4708. --- > Scope Mini Kerberos Cluster dependencies as test dependencies >

[jira] [Resolved] (FLINK-4710) Remove transitive Guice dependency from Hadoop

[ https://issues.apache.org/jira/browse/FLINK-4710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4710. - Resolution: Fixed Fixed via 84af0b90ec81bbe2af73a56cc0483166314a492a > Remove transitive Guice de

[jira] [Resolved] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies

[ https://issues.apache.org/jira/browse/FLINK-4708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4708. - Resolution: Fixed Fixed via 8243138c3ffb0849a7150d3c2df56eaffccd8d75 > Scope Mini Kerberos Cluste

[jira] [Closed] (FLINK-4710) Remove transitive Guice dependency from Hadoop

[ https://issues.apache.org/jira/browse/FLINK-4710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4710. --- > Remove transitive Guice dependency from Hadoop > -- > >

[jira] [Commented] (FLINK-4706) Is there a way to load user classes first?

[ https://issues.apache.org/jira/browse/FLINK-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532710#comment-15532710 ] Stephan Ewen commented on FLINK-4706: - You can try and put the user JAR into the "lib"

[jira] [Commented] (FLINK-4706) Is there a way to load user classes first?

[ https://issues.apache.org/jira/browse/FLINK-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532711#comment-15532711 ] Stephan Ewen commented on FLINK-4706: - What dependencies are clashing for you? > Is t

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535462#comment-15535462 ] Stephan Ewen commented on FLINK-4315: - I think we can merge this only for Flink 2.0, s

[jira] [Resolved] (FLINK-4702) Kafka consumer must commit offsets asynchronously

[ https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4702. - Resolution: Fixed Fixed in - 1.2.0 via 92f4539afc714f7dbd293c3ad677b3b5807c6911 - 1.1.3 via 90

[jira] [Resolved] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4573. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 2afc092461cf68cf0f3c26a3ab4c58a7bd68cf71

[jira] [Closed] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4573. --- > Potential resource leak due to unclosed RandomAccessFile in > TaskManagerLogHandler > -

[jira] [Resolved] (FLINK-4379) Add Rescalable Non-Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4379. - Resolution: Implemented Fix Version/s: 1.2.0 Implemented in 53ed6adac8cbe6b5dcb692dc9b94970

[jira] [Closed] (FLINK-4379) Add Rescalable Non-Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4379. --- > Add Rescalable Non-Partitioned State > > > Key: FLI

[jira] [Created] (FLINK-4737) Add more compression algorithms to FileInputFormat

Stephan Ewen created FLINK-4737: --- Summary: Add more compression algorithms to FileInputFormat Key: FLINK-4737 URL: https://issues.apache.org/jira/browse/FLINK-4737 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-4747) Instability due to pending processing timers on operator close

Stephan Ewen created FLINK-4747: --- Summary: Instability due to pending processing timers on operator close Key: FLINK-4747 URL: https://issues.apache.org/jira/browse/FLINK-4747 Project: Flink I

[jira] [Created] (FLINK-4748) Fix shutdown of automatic watermark context

Stephan Ewen created FLINK-4748: --- Summary: Fix shutdown of automatic watermark context Key: FLINK-4748 URL: https://issues.apache.org/jira/browse/FLINK-4748 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4749) Remove redundant processing time timers and futures in the window operator

Stephan Ewen created FLINK-4749: --- Summary: Remove redundant processing time timers and futures in the window operator Key: FLINK-4749 URL: https://issues.apache.org/jira/browse/FLINK-4749 Project: Flink

[jira] [Commented] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown

[ https://issues.apache.org/jira/browse/FLINK-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548824#comment-15548824 ] Stephan Ewen commented on FLINK-4742: - This was just fixed concurrently. It is a "race

[jira] [Created] (FLINK-4750) Ensure that active processing time triggers complete before closing operators

Stephan Ewen created FLINK-4750: --- Summary: Ensure that active processing time triggers complete before closing operators Key: FLINK-4750 URL: https://issues.apache.org/jira/browse/FLINK-4750 Project: Fl

[jira] [Commented] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown

[ https://issues.apache.org/jira/browse/FLINK-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548827#comment-15548827 ] Stephan Ewen commented on FLINK-4742: - CI verification is pending for FLINK-4747, shou

[jira] [Resolved] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown

[ https://issues.apache.org/jira/browse/FLINK-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4742. - Resolution: Duplicate Duplicate of FLINK-4747 > NPE in WindowOperator.trigger() on shutdown > ---

[jira] [Closed] (FLINK-4744) Introduce usercode class loader to deserialize partitionable operator state

[ https://issues.apache.org/jira/browse/FLINK-4744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4744. --- > Introduce usercode class loader to deserialize partitionable operator state > --

[jira] [Resolved] (FLINK-4744) Introduce usercode class loader to deserialize partitionable operator state

[ https://issues.apache.org/jira/browse/FLINK-4744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4744. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 56cba7ee9e00ef4b2493845558b614816b837d1b Mi

[jira] [Closed] (FLINK-4750) Ensure that active processing time triggers complete before closing operators

[ https://issues.apache.org/jira/browse/FLINK-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4750. --- > Ensure that active processing time triggers complete before closing operators >

[jira] [Resolved] (FLINK-4750) Ensure that active processing time triggers complete before closing operators

[ https://issues.apache.org/jira/browse/FLINK-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4750. - Resolution: Fixed Fixed in 8aea8c8f427f5511c6064abbc4b85a3ef106743a > Ensure that active processi

[jira] [Resolved] (FLINK-4700) Harden the TimeProvider test

[ https://issues.apache.org/jira/browse/FLINK-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4700. - Resolution: Fixed Assignee: Stephan Ewen (was: Kostas Kloudas) Fix Version/s: 1.2.

[jira] [Resolved] (FLINK-4749) Remove redundant processing time timers and futures in the window operator

[ https://issues.apache.org/jira/browse/FLINK-4749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4749. - Resolution: Fixed Fixed via 47e4977442f7045baf29ce7dc772b7f7aff65343 > Remove redundant processin

[jira] [Closed] (FLINK-4700) Harden the TimeProvider test

[ https://issues.apache.org/jira/browse/FLINK-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4700. --- > Harden the TimeProvider test > > > Key: FLINK-4700 >

[jira] [Resolved] (FLINK-4748) Fix shutdown of automatic watermark context

[ https://issues.apache.org/jira/browse/FLINK-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4748. - Resolution: Fixed Fixed via dd3416fde7b934584d4e18bc54d79ed7858556c2 > Fix shutdown of automatic

[jira] [Closed] (FLINK-4749) Remove redundant processing time timers and futures in the window operator

[ https://issues.apache.org/jira/browse/FLINK-4749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4749. --- > Remove redundant processing time timers and futures in the window operator > ---

[jira] [Resolved] (FLINK-4747) Instability due to pending processing timers on operator close

[ https://issues.apache.org/jira/browse/FLINK-4747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4747. - Resolution: Fixed Fixed via resolution of subtasks > Instability due to pending processing timers

[jira] [Closed] (FLINK-4747) Instability due to pending processing timers on operator close

[ https://issues.apache.org/jira/browse/FLINK-4747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4747. --- > Instability due to pending processing timers on operator close > ---

[jira] [Closed] (FLINK-4748) Fix shutdown of automatic watermark context

[ https://issues.apache.org/jira/browse/FLINK-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4748. --- > Fix shutdown of automatic watermark context > --- > >

[jira] [Resolved] (FLINK-4739) Adding packaging details for the Elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4739. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via beb31fc1c5a6f5db060e5a4e1d64eacb70632900

[jira] [Resolved] (FLINK-4718) Confusing label in Parallel Streams Diagram

[ https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4718. - Resolution: Fixed Fix Version/s: (was: 1.1.2) 1.2.0 Fixed via 8000b6

[jira] [Resolved] (FLINK-4737) Add more compression algorithms to FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4737. - Resolution: Fixed Fixed in 81aec4109adc18f4bd4d1ddb91892faed10f4f14 Minor addition in 7a76328d4ec9

[jira] [Closed] (FLINK-4718) Confusing label in Parallel Streams Diagram

[ https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4718. --- > Confusing label in Parallel Streams Diagram > --- > >

[jira] [Closed] (FLINK-4737) Add more compression algorithms to FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4737. --- > Add more compression algorithms to FileInputFormat > --

[jira] [Resolved] (FLINK-4329) Fix Streaming File Source Timestamps/Watermarks Handling

[ https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4329. - Resolution: Fixed Fixed in - 1.2.0 via 8ff451bec58e9f5800eb77c74c1d7457b776cc94 - 1.1.3 via ba

[jira] [Resolved] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream

[ https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4709. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 28b37ef97d803855e884900d1a983813ea2ac99d

[jira] [Closed] (FLINK-4329) Fix Streaming File Source Timestamps/Watermarks Handling

[ https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4329. --- > Fix Streaming File Source Timestamps/Watermarks Handling > -

[jira] [Closed] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream

[ https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4709. --- > InputStreamFSInputWrapper does not close wrapped stream > --

[jira] [Closed] (FLINK-4728) Replace reference equality with object equality

[ https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4728. --- > Replace reference equality with object equality > --- > >

[jira] [Resolved] (FLINK-4728) Replace reference equality with object equality

[ https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4728. - Resolution: Fixed Fixed via 9206b483b68bb41195bdf2da4f0b9c2de517c031 > Replace reference equality

[jira] [Commented] (FLINK-4755) Create ContainerID; Rename ResourceID into ProcessID and InstanceID into RegistrationID

[ https://issues.apache.org/jira/browse/FLINK-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15552184#comment-15552184 ] Stephan Ewen commented on FLINK-4755: - I order to keep {{flip-6}} close to master, we

[jira] [Created] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"

Stephan Ewen created FLINK-4757: --- Summary: Unify "GlobalJobParameters" and "Configuration" Key: FLINK-4757 URL: https://issues.apache.org/jira/browse/FLINK-4757 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-4758) Remove IOReadableWritable from classes where not needed

Stephan Ewen created FLINK-4758: --- Summary: Remove IOReadableWritable from classes where not needed Key: FLINK-4758 URL: https://issues.apache.org/jira/browse/FLINK-4758 Project: Flink Issue Typ

[jira] [Commented] (FLINK-4759) Unclosed DataOutputViewStream in JavaSerializer

[ https://issues.apache.org/jira/browse/FLINK-4759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15554849#comment-15554849 ] Stephan Ewen commented on FLINK-4759: - I think that should not be changed. The `DataOu

[jira] [Created] (FLINK-4765) Migrate ConfigConstants to ConfigOptions

Stephan Ewen created FLINK-4765: --- Summary: Migrate ConfigConstants to ConfigOptions Key: FLINK-4765 URL: https://issues.apache.org/jira/browse/FLINK-4765 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4764) Introduce config options

Stephan Ewen created FLINK-4764: --- Summary: Introduce config options Key: FLINK-4764 URL: https://issues.apache.org/jira/browse/FLINK-4764 Project: Flink Issue Type: Improvement Compon

[jira] [Created] (FLINK-4768) Migrate High Availability configuration options

Stephan Ewen created FLINK-4768: --- Summary: Migrate High Availability configuration options Key: FLINK-4768 URL: https://issues.apache.org/jira/browse/FLINK-4768 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-4766) Migrate TaskManager configuration options

Stephan Ewen created FLINK-4766: --- Summary: Migrate TaskManager configuration options Key: FLINK-4766 URL: https://issues.apache.org/jira/browse/FLINK-4766 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4767) Migrate JobManager configuration options

Stephan Ewen created FLINK-4767: --- Summary: Migrate JobManager configuration options Key: FLINK-4767 URL: https://issues.apache.org/jira/browse/FLINK-4767 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4770) Migrate Job Execution configuration options

Stephan Ewen created FLINK-4770: --- Summary: Migrate Job Execution configuration options Key: FLINK-4770 URL: https://issues.apache.org/jira/browse/FLINK-4770 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4769) Migrate Metrics configuration options

Stephan Ewen created FLINK-4769: --- Summary: Migrate Metrics configuration options Key: FLINK-4769 URL: https://issues.apache.org/jira/browse/FLINK-4769 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4776) Move ExecutionGraph initialization into a dedicated class

Stephan Ewen created FLINK-4776: --- Summary: Move ExecutionGraph initialization into a dedicated class Key: FLINK-4776 URL: https://issues.apache.org/jira/browse/FLINK-4776 Project: Flink Issue T

[jira] [Resolved] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job

[ https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2228. - Resolution: Done Validated fixed by [~heytitle] Thanks for checking this out! > Web frontend use

[jira] [Closed] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job

[ https://issues.apache.org/jira/browse/FLINK-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2228. --- > Web frontend uses two different timezones when reporting the time for job >

[jira] [Commented] (FLINK-4765) Migrate ConfigConstants to ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-4765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1782#comment-1782 ] Stephan Ewen commented on FLINK-4765: - Have a look at this pull request, which illustr

[jira] [Commented] (FLINK-4760) Kafka 09 Consumer failed to initialize state because of corrupted operator state and not able to recover

[ https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1890#comment-1890 ] Stephan Ewen commented on FLINK-4760: - I think this is fixed in the latest version of

[jira] [Commented] (FLINK-4760) Kafka 09 Consumer failed to initialize state because of corrupted operator state and not able to recover

[ https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15556655#comment-15556655 ] Stephan Ewen commented on FLINK-4760: - I cannot find commit {{f3d7fa7}} in the Flink g

[jira] [Resolved] (FLINK-4776) Move ExecutionGraph initialization into a dedicated class

[ https://issues.apache.org/jira/browse/FLINK-4776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4776. - Resolution: Done Done in ed96cb53bfcbe96dd36248839ec4f2bffe60971b > Move ExecutionGraph initializ

[jira] [Closed] (FLINK-4786) BarrierBufferTest test instability

[ https://issues.apache.org/jira/browse/FLINK-4786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4786. --- > BarrierBufferTest test instability > -- > > Key: FLINK-4

[jira] [Closed] (FLINK-4776) Move ExecutionGraph initialization into a dedicated class

[ https://issues.apache.org/jira/browse/FLINK-4776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4776. --- > Move ExecutionGraph initialization into a dedicated class >

[jira] [Resolved] (FLINK-4786) BarrierBufferTest test instability

[ https://issues.apache.org/jira/browse/FLINK-4786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4786. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 1.2.0 Fixed in 14e5ecb46c1

[jira] [Updated] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4788: Fix Version/s: 1.1.3 1.2.0 > State backend class cannot be loaded, because fully

[jira] [Commented] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562134#comment-15562134 ] Stephan Ewen commented on FLINK-4788: - Will look into this... > State backend class c

[jira] [Assigned] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4788: --- Assignee: Stephan Ewen > State backend class cannot be loaded, because fully qualified name c

[jira] [Commented] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562226#comment-15562226 ] Stephan Ewen commented on FLINK-4788: - 1.1.3 fix in d619f51ac8f922c0cf1d1e789c51410761

[jira] [Closed] (FLINK-4764) Introduce config options

[ https://issues.apache.org/jira/browse/FLINK-4764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4764. --- > Introduce config options > > > Key: FLINK-4764 >

[jira] [Resolved] (FLINK-4764) Introduce config options

[ https://issues.apache.org/jira/browse/FLINK-4764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4764. - Resolution: Implemented Implemented in cdebb0ef100179e810f6e110b974632bd49c653f > Introduce confi

[jira] [Resolved] (FLINK-4768) Migrate High Availability configuration options

[ https://issues.apache.org/jira/browse/FLINK-4768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4768. - Resolution: Done Assignee: Stephan Ewen Fix Version/s: 1.2.0 Done in abc1657bac83c

[jira] [Closed] (FLINK-4768) Migrate High Availability configuration options

[ https://issues.apache.org/jira/browse/FLINK-4768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4768. --- > Migrate High Availability configuration options > --- > >

[jira] [Resolved] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4788. - Resolution: Fixed Fixed in - 1.1.3 via d619f51ac8f922c0cf1d1e789c5141076128f04e - 1.2.0 via 9e

[jira] [Closed] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4788. --- > State backend class cannot be loaded, because fully qualified name converted > to lower-case >

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

[ https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15564935#comment-15564935 ] Stephan Ewen commented on FLINK-4793: - What version is affected by this bug? This look

[jira] [Commented] (FLINK-1497) No documentation on MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15564939#comment-15564939 ] Stephan Ewen commented on FLINK-1497: - Still a valid issue, as far as I can tell. > N

[jira] [Commented] (FLINK-4803) Job Cancel can hang forever waiting for OutputFormat.close()

[ https://issues.apache.org/jira/browse/FLINK-4803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15568076#comment-15568076 ] Stephan Ewen commented on FLINK-4803: - The task thread is actually interrupted. Immedi

[jira] [Created] (FLINK-4808) Allow skipping failed checkpoints

Stephan Ewen created FLINK-4808: --- Summary: Allow skipping failed checkpoints Key: FLINK-4808 URL: https://issues.apache.org/jira/browse/FLINK-4808 Project: Flink Issue Type: New Feature Aff

[jira] [Created] (FLINK-4809) Operators should tolerate checkpoint failures

Stephan Ewen created FLINK-4809: --- Summary: Operators should tolerate checkpoint failures Key: FLINK-4809 URL: https://issues.apache.org/jira/browse/FLINK-4809 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

Stephan Ewen created FLINK-4810: --- Summary: Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints Key: FLINK-4810 URL: https://issues.apache.org/jira/browse/FLINK-4810 Proj

[jira] [Created] (FLINK-4811) Checkpoint Overview should list failed checkpoints

Stephan Ewen created FLINK-4811: --- Summary: Checkpoint Overview should list failed checkpoints Key: FLINK-4811 URL: https://issues.apache.org/jira/browse/FLINK-4811 Project: Flink Issue Type: Su

[jira] [Commented] (FLINK-4813) Having flink-test-utils as a dependency outside Flink fails the build

[ https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15568803#comment-15568803 ] Stephan Ewen commented on FLINK-4813: - +1 > Having flink-test-utils as a dependency o

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15568819#comment-15568819 ] Stephan Ewen commented on FLINK-4283: - Is this issue still relevant, or has this insta

<    4   5   6   7   8   9   10   11   12   13   >