[jira] [Updated] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3864: -- Description: {{YarnTestBase.runWithArgs(...)}} provides a parameter for strings which mu

[jira] [Updated] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3864: -- Summary: Yarn tests don't check for prohibited strings in log output (was: Yarn per-job

[jira] [Updated] (FLINK-3864) Yarn per-job cluster sets parallelism to 1 instead of #taskmanagers * #slots

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3864: -- Description: {{YarnTestBase.runWithArgs(...)}} provides a parameter for strings which mu

[jira] [Updated] (FLINK-3864) Yarn per-job cluster sets parallelism to 1 instead of #taskmanagers * #slots

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3864: -- Summary: Yarn per-job cluster sets parallelism to 1 instead of #taskmanagers * #slots (

[jira] [Created] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

Maximilian Michels created FLINK-3864: - Summary: Yarn tests don't check for prohibited strings in log output Key: FLINK-3864 URL: https://issues.apache.org/jira/browse/FLINK-3864 Project: Flink

[jira] [Created] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently

Maximilian Michels created FLINK-3863: - Summary: Yarn Cluster shutdown may fail if leader changed recently Key: FLINK-3863 URL: https://issues.apache.org/jira/browse/FLINK-3863 Project: Flink

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268708#comment-15268708 ] Maximilian Michels commented on FLINK-2821: --- Sure, go ahead! > Change Akka conf

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268379#comment-15268379 ] Maximilian Michels commented on FLINK-1984: --- Great news :) > Integrate Flink wi

[jira] [Resolved] (FLINK-3601) JobManagerTest times out on StopSignal test

[ https://issues.apache.org/jira/browse/FLINK-3601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3601. --- Resolution: Fixed Fix Version/s: 1.1.0 Thanks for the reminder! Had a fix alrea

[jira] [Closed] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode

[ https://issues.apache.org/jira/browse/FLINK-3824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3824. - Resolution: Fixed Fixed with 7ec1300a740e9b8e1eb595bc15e752a167592e00. > ResourceManager

[jira] [Created] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode

Maximilian Michels created FLINK-3824: - Summary: ResourceManager may repeatedly connect to outdated JobManager in HA mode Key: FLINK-3824 URL: https://issues.apache.org/jira/browse/FLINK-3824 Proj

[jira] [Updated] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3701: -- Fix Version/s: 1.1.0 > Cant call execute after first execution > ---

[jira] [Updated] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3701: -- Affects Version/s: 1.1.0 > Cant call execute after first execution > ---

[jira] [Created] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods

Maximilian Michels created FLINK-3796: - Summary: FileSourceFunction doesn't respect InputFormat's life cycle methods Key: FLINK-3796 URL: https://issues.apache.org/jira/browse/FLINK-3796 Project:

[jira] [Commented] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247644#comment-15247644 ] Maximilian Michels commented on FLINK-3701: --- The issue is that the serializer li

[jira] [Assigned] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3701: - Assignee: Maximilian Michels > Cant call execute after first execution >

[jira] [Closed] (FLINK-1427) Configuration through environment variables

[ https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-1427. - Resolution: Won't Fix Thanks, closing for now. > Configuration through environment variab

[jira] [Resolved] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell

[ https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2522. --- Resolution: Implemented Fix Version/s: 1.1.0 Implemented with d7948fad6a73fdefa

[jira] [Closed] (FLINK-3529) Add pull request template

[ https://issues.apache.org/jira/browse/FLINK-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3529. - Resolution: Implemented Merged with 24f89b7f1695ee095a2a161990bdcfd8c09283a5 > Add pull r

[jira] [Commented] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227912#comment-15227912 ] Maximilian Michels commented on FLINK-3689: --- Another follow-up fixed by 142912b0

[jira] [Comment Edited] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226474#comment-15226474 ] Maximilian Michels edited comment on FLINK-3655 at 4/5/16 3:37 PM: -

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226474#comment-15226474 ] Maximilian Michels commented on FLINK-3655: --- Sounds good. It is important to mai

[jira] [Closed] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3686. - Resolution: Duplicate Assignee: Maximilian Michels Thanks for reporting! The issue h

[jira] [Resolved] (FLINK-3638) Invalid default ports in documentation

[ https://issues.apache.org/jira/browse/FLINK-3638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3638. --- Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 1.0.0

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15223797#comment-15223797 ] Maximilian Michels commented on FLINK-3655: --- Hi! Great. Feel free to open a PR.

[jira] [Closed] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3689. - Resolution: Fixed Fixed in c2f2122c0ba0d0b16eb59aa3ad7958c72fb486b7 > JobManager blocks c

[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication

[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222084#comment-15222084 ] Maximilian Michels commented on FLINK-3667: --- The clients don't communicate direc

[jira] [Commented] (FLINK-3690) Create documentation on the new ResourceManager component

[ https://issues.apache.org/jira/browse/FLINK-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222073#comment-15222073 ] Maximilian Michels commented on FLINK-3690: --- The Resource Manager component is t

[jira] [Created] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager

Maximilian Michels created FLINK-3689: - Summary: JobManager blocks cluster shutdown when not connected to ResourceManager Key: FLINK-3689 URL: https://issues.apache.org/jira/browse/FLINK-3689 Proj

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221467#comment-15221467 ] Maximilian Michels commented on FLINK-2392: --- Ok great, then it's probably not du

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221397#comment-15221397 ] Maximilian Michels commented on FLINK-2392: --- Have you seen this one before? Migh

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216289#comment-15216289 ] Maximilian Michels commented on FLINK-3677: --- Linked FLINK-3655 which is related

[jira] [Created] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

Maximilian Michels created FLINK-3677: - Summary: FileInputFormat: Allow to specify include/exclude file name patterns Key: FLINK-3677 URL: https://issues.apache.org/jira/browse/FLINK-3677 Project:

[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication

[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216222#comment-15216222 ] Maximilian Michels commented on FLINK-3667: --- +1 Makes sense to convert the {{Cli

[jira] [Closed] (FLINK-3676) WebClient hasn't been removed from the docs

[ https://issues.apache.org/jira/browse/FLINK-3676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3676. - Resolution: Fixed master: 875cb448d7407687402eec15c77c24683c2d5c56 release-1.0: 875cb448d7

[jira] [Created] (FLINK-3676) WebClient hasn't been removed from the docs

Maximilian Michels created FLINK-3676: - Summary: WebClient hasn't been removed from the docs Key: FLINK-3676 URL: https://issues.apache.org/jira/browse/FLINK-3676 Project: Flink Issue Typ

[jira] [Closed] (FLINK-3545) ResourceManager: YARN integration

[ https://issues.apache.org/jira/browse/FLINK-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3545. - Resolution: Implemented Implemented in 4405235e5483d3e4ad94f4ba31627aa852580042. > Resour

[jira] [Closed] (FLINK-3544) ResourceManager runtime components

[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3544. - Resolution: Implemented Implemented in 92ff2b152cac3ad6a53373c0c022579306051133. > Resour

[jira] [Created] (FLINK-3670) Kerberos: Improving long-running streaming jobs

Maximilian Michels created FLINK-3670: - Summary: Kerberos: Improving long-running streaming jobs Key: FLINK-3670 URL: https://issues.apache.org/jira/browse/FLINK-3670 Project: Flink Issue

[jira] [Created] (FLINK-3667) Generalize client<->cluster communication

Maximilian Michels created FLINK-3667: - Summary: Generalize client<->cluster communication Key: FLINK-3667 URL: https://issues.apache.org/jira/browse/FLINK-3667 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2821: -- Fix Version/s: 1.1.0 > Change Akka configuration to allow accessing actors from differen

[jira] [Created] (FLINK-3661) Make Scala 2.11.x the default Scala version

Maximilian Michels created FLINK-3661: - Summary: Make Scala 2.11.x the default Scala version Key: FLINK-3661 URL: https://issues.apache.org/jira/browse/FLINK-3661 Project: Flink Issue Typ

[jira] [Created] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x

Maximilian Michels created FLINK-3662: - Summary: Bump Akka version to 2.4.x for Scala 2.11.x Key: FLINK-3662 URL: https://issues.apache.org/jira/browse/FLINK-3662 Project: Flink Issue Typ

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208366#comment-15208366 ] Maximilian Michels commented on FLINK-2821: --- +1 Sounds like a good way to procee

[jira] [Resolved] (FLINK-3652) Enable UnusedImports check for Scala checkstyle

[ https://issues.apache.org/jira/browse/FLINK-3652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3652. --- Resolution: Later Scalastyle doesn't support the unused import check yet... http://ww

[jira] [Created] (FLINK-3652) Enable UnusedImports check for Scala checkstyle

Maximilian Michels created FLINK-3652: - Summary: Enable UnusedImports check for Scala checkstyle Key: FLINK-3652 URL: https://issues.apache.org/jira/browse/FLINK-3652 Project: Flink Issue

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204553#comment-15204553 ] Maximilian Michels commented on FLINK-2821: --- It is now possible to separate the

[jira] [Assigned] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2821: - Assignee: Maximilian Michels > Change Akka configuration to allow accessing actor

[jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199249#comment-15199249 ] Maximilian Michels commented on FLINK-3239: --- +1 > Support for Kerberos enabled

[jira] [Commented] (FLINK-3614) Remove Non-Keyed Window Operator

[ https://issues.apache.org/jira/browse/FLINK-3614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15197076#comment-15197076 ] Maximilian Michels commented on FLINK-3614: --- +1 > Remove Non-Keyed Window Opera

[jira] [Commented] (FLINK-3607) Decrease default forkCount for tests

[ https://issues.apache.org/jira/browse/FLINK-3607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15191035#comment-15191035 ] Maximilian Michels commented on FLINK-3607: --- Just saw that the default in tools/

[jira] [Commented] (FLINK-3607) Decrease default forkCount for tests

[ https://issues.apache.org/jira/browse/FLINK-3607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15191031#comment-15191031 ] Maximilian Michels commented on FLINK-3607: --- Sure, you can set {{-Dflik.forkCoun

[jira] [Created] (FLINK-3607) Decrease default forkCount for tests

Maximilian Michels created FLINK-3607: - Summary: Decrease default forkCount for tests Key: FLINK-3607 URL: https://issues.apache.org/jira/browse/FLINK-3607 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-3601) JobManagerTest times out on StopSignal test

Maximilian Michels created FLINK-3601: - Summary: JobManagerTest times out on StopSignal test Key: FLINK-3601 URL: https://issues.apache.org/jira/browse/FLINK-3601 Project: Flink Issue Typ

[jira] [Closed] (FLINK-3561) ExecutionConfig's timestampsEnabled is unused

[ https://issues.apache.org/jira/browse/FLINK-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3561. - Resolution: Fixed f6e6924 [FLINK-3561] remove unused timestampsEnabled flag > ExecutionCo

[jira] [Reopened] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-2671: --- This test is still unstable and fails the master in almost every build. For example: http

[jira] [Commented] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type

[ https://issues.apache.org/jira/browse/FLINK-3444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15186975#comment-15186975 ] Maximilian Michels commented on FLINK-3444: --- +1 > env.fromElements relies on th

[jira] [Commented] (FLINK-3589) Allow setting Operator parallelism to default value

[ https://issues.apache.org/jira/browse/FLINK-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15186973#comment-15186973 ] Maximilian Michels commented on FLINK-3589: --- I guess the main issue is that the

[jira] [Commented] (FLINK-3429) Add histogram-based timestamp/watermark extractor

[ https://issues.apache.org/jira/browse/FLINK-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15184734#comment-15184734 ] Maximilian Michels commented on FLINK-3429: --- +1 very much needed. > Add histogr

[jira] [Closed] (FLINK-3383) Separate Maven deployment from CI testing

[ https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3383. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed in c413b23b8c8dd3323d4a3d82feed0abab2b

[jira] [Closed] (FLINK-3585) Deploy scripts don't support spaces in paths

[ https://issues.apache.org/jira/browse/FLINK-3585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3585. - Resolution: Fixed Fixed in master with d3808c7bc060e8837b5a35d6f1f305bd4c446384. > Deploy

[jira] [Created] (FLINK-3585) Deploy scripts don't support spaces in paths

Maximilian Michels created FLINK-3585: - Summary: Deploy scripts don't support spaces in paths Key: FLINK-3585 URL: https://issues.apache.org/jira/browse/FLINK-3585 Project: Flink Issue Ty

[jira] [Closed] (FLINK-3569) Test cases fail due to Maven Shade plugin

[ https://issues.apache.org/jira/browse/FLINK-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3569. - Resolution: Fixed master: bb62ab082f7e6157138d509e305e10510badc491 release-1.0: fd0830eadf

[jira] [Commented] (FLINK-3569) Test cases fail due to Maven Shade plugin

[ https://issues.apache.org/jira/browse/FLINK-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15178079#comment-15178079 ] Maximilian Michels commented on FLINK-3569: --- I'll open a new pull request once I

[jira] [Created] (FLINK-3569) Test cases fail due to Maven Shade plugin

Maximilian Michels created FLINK-3569: - Summary: Test cases fail due to Maven Shade plugin Key: FLINK-3569 URL: https://issues.apache.org/jira/browse/FLINK-3569 Project: Flink Issue Type:

[jira] [Updated] (FLINK-3562) Update docs in the course of EventTimeSourceFunction removal

[ https://issues.apache.org/jira/browse/FLINK-3562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3562: -- Assignee: (was: Maximilian Michels) > Update docs in the course of EventTimeSourceFu

[jira] [Commented] (FLINK-3565) FlinkKafkaConsumer does not work with Scala 2.11

[ https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176007#comment-15176007 ] Maximilian Michels commented on FLINK-3565: --- Thanks to [~till.rohrmann], I've co

[jira] [Commented] (FLINK-3565) FlinkKafkaConsumer does not work with Scala 2.11

[ https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175609#comment-15175609 ] Maximilian Michels commented on FLINK-3565: --- Problem: flink-parent contains the

[jira] [Assigned] (FLINK-3565) FlinkKafkaConsumer does not work with Scala 2.11

[ https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3565: - Assignee: Maximilian Michels > FlinkKafkaConsumer does not work with Scala 2.11

[jira] [Created] (FLINK-3562) Update docs in the course of EventTimeSourceFunction removal

Maximilian Michels created FLINK-3562: - Summary: Update docs in the course of EventTimeSourceFunction removal Key: FLINK-3562 URL: https://issues.apache.org/jira/browse/FLINK-3562 Project: Flink

[jira] [Created] (FLINK-3561) ExecutionConfig's timestampsEnabled is unused

Maximilian Michels created FLINK-3561: - Summary: ExecutionConfig's timestampsEnabled is unused Key: FLINK-3561 URL: https://issues.apache.org/jira/browse/FLINK-3561 Project: Flink Issue T

[jira] [Created] (FLINK-3545) ResourceManager: YARN integration

Maximilian Michels created FLINK-3545: - Summary: ResourceManager: YARN integration Key: FLINK-3545 URL: https://issues.apache.org/jira/browse/FLINK-3545 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-3544) ResourceManager runtime components

Maximilian Michels created FLINK-3544: - Summary: ResourceManager runtime components Key: FLINK-3544 URL: https://issues.apache.org/jira/browse/FLINK-3544 Project: Flink Issue Type: Sub-ta

[jira] [Updated] (FLINK-3543) Introduce ResourceManager component

[ https://issues.apache.org/jira/browse/FLINK-3543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3543: -- Attachment: ResourceManagerSketch.pdf An overview of the message flow. > Introduce Reso

[jira] [Created] (FLINK-3543) Introduce ResourceManager component

Maximilian Michels created FLINK-3543: - Summary: Introduce ResourceManager component Key: FLINK-3543 URL: https://issues.apache.org/jira/browse/FLINK-3543 Project: Flink Issue Type: New F

[jira] [Resolved] (FLINK-3485) The SerializedListAccumulator value doest seem to be right

[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3485. --- Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 1.0.0 Th

[jira] [Commented] (FLINK-3485) The SerializedListAccumulator value doest seem to be right

[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168139#comment-15168139 ] Maximilian Michels commented on FLINK-3485: --- You're right. The accumulator is pr

[jira] [Updated] (FLINK-3478) Flink serves arbitary files through the web interface

[ https://issues.apache.org/jira/browse/FLINK-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3478: -- Assignee: Ufuk Celebi (was: Maximilian Michels) > Flink serves arbitary files through t

[jira] [Created] (FLINK-3478) Flink serves arbitary files through the web interface

Maximilian Michels created FLINK-3478: - Summary: Flink serves arbitary files through the web interface Key: FLINK-3478 URL: https://issues.apache.org/jira/browse/FLINK-3478 Project: Flink

[jira] [Closed] (FLINK-3248) RMQSource does not provide a constructor for credentials or other options

[ https://issues.apache.org/jira/browse/FLINK-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3248. - Resolution: Fixed Fixed in 9bdee1b355c6113db35ba7476f65deffe5e39ea8. > RMQSource does not

[jira] [Created] (FLINK-3448) Move initialization of handlers to start() method

Maximilian Michels created FLINK-3448: - Summary: Move initialization of handlers to start() method Key: FLINK-3448 URL: https://issues.apache.org/jira/browse/FLINK-3448 Project: Flink Iss

[jira] [Updated] (FLINK-3448) WebRuntimeMonitor: Move initialization of handlers to start() method

[ https://issues.apache.org/jira/browse/FLINK-3448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3448: -- Summary: WebRuntimeMonitor: Move initialization of handlers to start() method (was: Mov

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150166#comment-15150166 ] Maximilian Michels commented on FLINK-1502: --- Hi [~eastcirclek]! In addition to w

[jira] [Created] (FLINK-3388) Expose task accumulators via JMX

Maximilian Michels created FLINK-3388: - Summary: Expose task accumulators via JMX Key: FLINK-3388 URL: https://issues.apache.org/jira/browse/FLINK-3388 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-3170) Expose task manager metrics via JMX

[ https://issues.apache.org/jira/browse/FLINK-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3170. - Resolution: Duplicate > Expose task manager metrics via JMX >

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142710#comment-15142710 ] Maximilian Michels commented on FLINK-1502: --- [~eastcirclek] Yes, I was working o

[jira] [Created] (FLINK-3383) Separate Maven deployment from CI testing

Maximilian Michels created FLINK-3383: - Summary: Separate Maven deployment from CI testing Key: FLINK-3383 URL: https://issues.apache.org/jira/browse/FLINK-3383 Project: Flink Issue Type:

[jira] [Created] (FLINK-3378) Consolidate TestingCluster and FokableFlinkMiniCluster

Maximilian Michels created FLINK-3378: - Summary: Consolidate TestingCluster and FokableFlinkMiniCluster Key: FLINK-3378 URL: https://issues.apache.org/jira/browse/FLINK-3378 Project: Flink

[jira] [Resolved] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation

[ https://issues.apache.org/jira/browse/FLINK-3348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3348. --- Resolution: Fixed Fix Version/s: 1.0.0 Fixed in af425b294e1abded30c0bac71cc3c6f

[jira] [Closed] (FLINK-3353) CSV-related tests may fail depending on locale

[ https://issues.apache.org/jira/browse/FLINK-3353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3353. - Resolution: Fixed Fixed in 20f8911b42f7bac5b177f37a627515b24837ddb7. Thanks! > CSV-relate

[jira] [Commented] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation

[ https://issues.apache.org/jira/browse/FLINK-3348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136831#comment-15136831 ] Maximilian Michels commented on FLINK-3348: --- When we wrote this, we assumed {{bc

[jira] [Assigned] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation

[ https://issues.apache.org/jira/browse/FLINK-3348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3348: - Assignee: Maximilian Michels > taskmanager.memory.off-heap missing bc documentati

[jira] [Comment Edited] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136704#comment-15136704 ] Maximilian Michels edited comment on FLINK-1502 at 2/8/16 8:37 AM: -

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136704#comment-15136704 ] Maximilian Michels commented on FLINK-1502: --- I was working on this in FLINK-3170

[jira] [Commented] (FLINK-2803) Add test case for Flink's memory allocation

[ https://issues.apache.org/jira/browse/FLINK-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130162#comment-15130162 ] Maximilian Michels commented on FLINK-2803: --- [~lravindr] As you wish. I think it

[jira] [Closed] (FLINK-3127) Measure backpressure in Flink jobs

[ https://issues.apache.org/jira/browse/FLINK-3127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3127. - Resolution: Duplicate Closing for newly created issue. > Measure backpressure in Flink jo

[jira] [Commented] (FLINK-3310) Add back pressure statistics to web frontend

[ https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130072#comment-15130072 ] Maximilian Michels commented on FLINK-3310: --- Closing the duplicated issue to mak

[jira] [Commented] (FLINK-3310) Add back pressure statistics to web frontend

[ https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128559#comment-15128559 ] Maximilian Michels commented on FLINK-3310: --- I also created an issue some time a

[jira] [Updated] (FLINK-3276) Move runtime parts of flink-streaming-java to flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3276: -- Priority: Major (was: Critical) > Move runtime parts of flink-streaming-java to flink-r

[jira] [Updated] (FLINK-3276) Move runtime parts of flink-streaming-java to flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-3276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3276: -- Issue Type: Improvement (was: Bug) > Move runtime parts of flink-streaming-java to flin

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