[jira] [Commented] (FLINK-1685) Document how to read gzip/compressed files with Flink

[ https://issues.apache.org/jira/browse/FLINK-1685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14356736#comment-14356736 ] Robert Metzger commented on FLINK-1685: --- the task probably boils down to putting

[jira] [Comment Edited] (FLINK-1525) Provide utils to pass -D parameters to UDFs

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14355904#comment-14355904 ] Robert Metzger edited comment on FLINK-1525 at 3/11/15 9:01 AM:

[jira] [Created] (FLINK-1679) Document how degree of parallelism / parallelism / slots are connected to each other

Robert Metzger created FLINK-1679: - Summary: Document how degree of parallelism / parallelism / slots are connected to each other Key: FLINK-1679 URL: https://issues.apache.org/jira/browse/FLINK-1679

[jira] [Reopened] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-1650: --- I'm reopening the issue because the exceptions still occur in the current master. The

[jira] [Updated] (FLINK-82) (Hash) Aggregators (fold style)

[ https://issues.apache.org/jira/browse/FLINK-82?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-82: Component/s: Local Runtime (Hash) Aggregators (fold style) ---

[jira] [Created] (FLINK-1700) Include Google Analytics in Javadocs

Robert Metzger created FLINK-1700: - Summary: Include Google Analytics in Javadocs Key: FLINK-1700 URL: https://issues.apache.org/jira/browse/FLINK-1700 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360287#comment-14360287 ] Robert Metzger commented on FLINK-1650: --- Right now, we only shade away Hadoop's

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14355904#comment-14355904 ] Robert Metzger commented on FLINK-1525: --- Hi, great. We're always happy about new

[jira] [Commented] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

[ https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377847#comment-14377847 ] Robert Metzger commented on FLINK-1769: --- I manually deployed to the snapshot

[jira] [Commented] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom

[ https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379859#comment-14379859 ] Robert Metzger commented on FLINK-1783: --- To my understanding the new quickstarts are

[jira] [Assigned] (FLINK-1781) Quickstarts broken due to Scala Version Variables

[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1781: - Assignee: Robert Metzger Quickstarts broken due to Scala Version Variables

[jira] [Commented] (FLINK-1781) Quickstarts broken due to Scala Version Variables

[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379866#comment-14379866 ] Robert Metzger commented on FLINK-1781: --- I'll look into this. Quickstarts broken

[jira] [Closed] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1787. - Resolution: Duplicate Remove commons Validate calls with Guava checkArgument() calls.

[jira] [Updated] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1787: -- Issue Type: Task (was: Bug) Remove commons Validate calls with Guava checkArgument() calls.

[jira] [Created] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

Robert Metzger created FLINK-1787: - Summary: Remove commons Validate calls with Guava checkArgument() calls. Key: FLINK-1787 URL: https://issues.apache.org/jira/browse/FLINK-1787 Project: Flink

[jira] [Commented] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls.

[ https://issues.apache.org/jira/browse/FLINK-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14381645#comment-14381645 ] Robert Metzger commented on FLINK-1787: --- oh, you are right. I'll close this one

[jira] [Created] (FLINK-1804) flink-quickstart-scala tests fail on scala-2.11 build profile on travis

Robert Metzger created FLINK-1804: - Summary: flink-quickstart-scala tests fail on scala-2.11 build profile on travis Key: FLINK-1804 URL: https://issues.apache.org/jira/browse/FLINK-1804 Project:

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14386792#comment-14386792 ] Robert Metzger commented on FLINK-1650: --- I'm going to set the Akka version back to

[jira] [Resolved] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1771. --- Resolution: Fixed Fix Version/s: 0.9 Implemented in

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Assignee: (was: Robert Metzger) Access to stdout and log information of Taskmanagers from

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Component/s: Webfrontend Access to stdout and log information of Taskmanagers from the web

[jira] [Assigned] (FLINK-1800) Add a Beta badge in the documentation to components in flink-staging

[ https://issues.apache.org/jira/browse/FLINK-1800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1800: - Assignee: Robert Metzger Add a Beta badge in the documentation to components in

[jira] [Updated] (FLINK-1800) Add a Beta badge in the documentation to components in flink-staging

[ https://issues.apache.org/jira/browse/FLINK-1800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1800: -- Component/s: Documentation Add a Beta badge in the documentation to components in

[jira] [Created] (FLINK-1811) Allow users to pass custom buffer sizes and timeouts to PersistentKafkaSource

Robert Metzger created FLINK-1811: - Summary: Allow users to pass custom buffer sizes and timeouts to PersistentKafkaSource Key: FLINK-1811 URL: https://issues.apache.org/jira/browse/FLINK-1811

[jira] [Resolved] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

[ https://issues.apache.org/jira/browse/FLINK-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1501. --- Resolution: Fixed Fix Version/s: (was: pre-apache) 0.9 Resolved

[jira] [Created] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

Robert Metzger created FLINK-1792: - Summary: Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only Key: FLINK-1792 URL: https://issues.apache.org/jira/browse/FLINK-1792

[jira] [Updated] (FLINK-1781) Quickstarts broken due to Scala Version Variables

[ https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1781: -- Assignee: Stephan Ewen (was: Robert Metzger) Quickstarts broken due to Scala Version

[jira] [Updated] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1771: -- Summary: Add support for submitting single jobs to a detached YARN session (was: Add support

[jira] [Commented] (FLINK-1744) Change the reference of slaves to workers to match the description of the system

[ https://issues.apache.org/jira/browse/FLINK-1744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14376033#comment-14376033 ] Robert Metzger commented on FLINK-1744: --- Oh ... sorry. I didn't want to ask you to

[jira] [Created] (FLINK-1771) Add tests for setting the processing slots for the YARN client

Robert Metzger created FLINK-1771: - Summary: Add tests for setting the processing slots for the YARN client Key: FLINK-1771 URL: https://issues.apache.org/jira/browse/FLINK-1771 Project: Flink

[jira] [Updated] (FLINK-1771) Add tests for setting the processing slots for the YARN client

[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1771: -- Affects Version/s: 0.9 Add tests for setting the processing slots for the YARN client

[jira] [Commented] (FLINK-1577) Misleading error messages when cancelling tasks

[ https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345300#comment-14345300 ] Robert Metzger commented on FLINK-1577: --- Thank you! Misleading error messages when

[jira] [Resolved] (FLINK-1555) Add utility to log the serializers of composite types

[ https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1555. --- Resolution: Fixed Fix Version/s: 0.9 This has been resolved in

[jira] [Commented] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn

[ https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14343545#comment-14343545 ] Robert Metzger commented on FLINK-1414: --- I've started working on this by committing

[jira] [Commented] (FLINK-1613) Cannost submit to remote ExecutionEnvironment from IDE

[ https://issues.apache.org/jira/browse/FLINK-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14339918#comment-14339918 ] Robert Metzger commented on FLINK-1613: --- How about removing the

[jira] [Updated] (FLINK-1637) Flink uberjar does not work with Java 6

[ https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1637: -- Component/s: Build System Flink uberjar does not work with Java 6

[jira] [Closed] (FLINK-1162) Cannot serialize Scala classes with Avro serializer

[ https://issues.apache.org/jira/browse/FLINK-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1162. - Resolution: Fixed Fix Version/s: 0.9 Fixed with Kryo. I suspect there is no test for it.

[jira] [Created] (FLINK-1646) Add name of required configuration value into the Insufficient number of network buffers exception

Robert Metzger created FLINK-1646: - Summary: Add name of required configuration value into the Insufficient number of network buffers exception Key: FLINK-1646 URL:

[jira] [Commented] (FLINK-1370) Build website automatically

[ https://issues.apache.org/jira/browse/FLINK-1370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14342290#comment-14342290 ] Robert Metzger commented on FLINK-1370: --- Great! Thank you for implementing this.

[jira] [Created] (FLINK-1614) JM Webfrontend doesn't always show the correct state of Tasks

Robert Metzger created FLINK-1614: - Summary: JM Webfrontend doesn't always show the correct state of Tasks Key: FLINK-1614 URL: https://issues.apache.org/jira/browse/FLINK-1614 Project: Flink

[jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

[ https://issues.apache.org/jira/browse/FLINK-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348585#comment-14348585 ] Robert Metzger commented on FLINK-1166: --- TODO: add a check which checks out a

[jira] [Commented] (FLINK-1572) Output directories are created before input paths are checked

[ https://issues.apache.org/jira/browse/FLINK-1572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348807#comment-14348807 ] Robert Metzger commented on FLINK-1572: --- How about removing the files of a failed

[jira] [Resolved] (FLINK-1642) Flakey YARNSessionCapacitySchedulerITCase

[ https://issues.apache.org/jira/browse/FLINK-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1642. --- Resolution: Invalid Flakey YARNSessionCapacitySchedulerITCase

[jira] [Commented] (FLINK-1642) Flakey YARNSessionCapacitySchedulerITCase

[ https://issues.apache.org/jira/browse/FLINK-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348714#comment-14348714 ] Robert Metzger commented on FLINK-1642: --- As per offline discussion with

[jira] [Commented] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348707#comment-14348707 ] Robert Metzger commented on FLINK-1601: --- The errors reported by Till in the

[jira] [Commented] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn

[ https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14348723#comment-14348723 ] Robert Metzger commented on FLINK-1414: --- I think the best approach here is to lazily

[jira] [Created] (FLINK-1637) Flink uberjar does not work with Java 6

Robert Metzger created FLINK-1637: - Summary: Flink uberjar does not work with Java 6 Key: FLINK-1637 URL: https://issues.apache.org/jira/browse/FLINK-1637 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6

[ https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14344918#comment-14344918 ] Robert Metzger commented on FLINK-1637: --- The issue is that Java 6 can not load jar

[jira] [Commented] (FLINK-1577) Misleading error messages when cancelling tasks

[ https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345169#comment-14345169 ] Robert Metzger commented on FLINK-1577: --- Another user was affected by this. Would be

[jira] [Assigned] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1342: - Assignee: Robert Metzger Quickstart's assembly can possibly filter out user's code

[jira] [Resolved] (FLINK-1308) Flink logo in documentation does not link to website home

[ https://issues.apache.org/jira/browse/FLINK-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1308. --- Resolution: Fixed The issue has been resolved in

[jira] [Updated] (FLINK-1590) Log environment information also in YARN mode

[ https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1590: -- Component/s: YARN Client Log environment information also in YARN mode

[jira] [Updated] (FLINK-1590) Log environment information also in YARN mode

[ https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1590: -- Affects Version/s: 0.9 Log environment information also in YARN mode

[jira] [Updated] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag

[ https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1521: -- Priority: Minor (was: Major) Some Chained Drivers do not respect object-reuse/non-reuse flag

[jira] [Resolved] (FLINK-1289) Broken links to k-means examples in website

[ https://issues.apache.org/jira/browse/FLINK-1289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1289. --- Resolution: Fixed Fix Version/s: 0.8.1 The links are working in the current

[jira] [Assigned] (FLINK-1590) Log environment information also in YARN mode

[ https://issues.apache.org/jira/browse/FLINK-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1590: - Assignee: Robert Metzger Log environment information also in YARN mode

[jira] [Commented] (FLINK-1582) SocketStream gets stuck when socket closes

[ https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14333096#comment-14333096 ] Robert Metzger commented on FLINK-1582: --- I've assigned [~qmlmoon] to the issue,

[jira] [Updated] (FLINK-1582) SocketStream gets stuck when socket closes

[ https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1582: -- Assignee: Mingliang Qi SocketStream gets stuck when socket closes

[jira] [Commented] (FLINK-1162) Cannot serialize Scala classes with Avro serializer

[ https://issues.apache.org/jira/browse/FLINK-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14333101#comment-14333101 ] Robert Metzger commented on FLINK-1162: --- I guess we can close this issue because we

[jira] [Closed] (FLINK-567) Yarn Application Master throws no exception when it has no write permission to HDFS

[ https://issues.apache.org/jira/browse/FLINK-567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-567. Resolution: Invalid The issue is very old. The current YARN client is reporting that the YARN

[jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN

[ https://issues.apache.org/jira/browse/FLINK-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14334722#comment-14334722 ] Robert Metzger commented on FLINK-1602: --- Yes, I think its a good idea to link the

[jira] [Created] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts

Robert Metzger created FLINK-1605: - Summary: Create a shaded Hadoop fat jar to resolve library version conflicts Key: FLINK-1605 URL: https://issues.apache.org/jira/browse/FLINK-1605 Project: Flink

[jira] [Updated] (FLINK-1596) FileIOChannel introduces space in temp file name

[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Fix Version/s: 0.9 FileIOChannel introduces space in temp file name

[jira] [Updated] (FLINK-1596) FileIOChannel introduces space in temp file name

[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Fix Version/s: 0.8.2 FileIOChannel introduces space in temp file name

[jira] [Updated] (FLINK-1596) FileIOChannel introduces space in temp file name

[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Affects Version/s: (was: 0.8) 0.8.1 FileIOChannel introduces space

[jira] [Commented] (FLINK-1596) FileIOChannel introduces space in temp file name

[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14330438#comment-14330438 ] Robert Metzger commented on FLINK-1596: --- I've added that the issue also affects

[jira] [Updated] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1342: -- Fix Version/s: (was: 0.8.1) 0.8.2 Quickstart's assembly can possibly

[jira] [Updated] (FLINK-1596) FileIOChannel introduces space in temp file name

[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Affects Version/s: 0.8 FileIOChannel introduces space in temp file name

[jira] [Resolved] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1650. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/c9d29f26

[jira] [Created] (FLINK-1753) Add more tests for Kafka Connectors

Robert Metzger created FLINK-1753: - Summary: Add more tests for Kafka Connectors Key: FLINK-1753 URL: https://issues.apache.org/jira/browse/FLINK-1753 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Description: The current {{KafkaITCase}} is only doing a single test. We need to refactor that

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14382015#comment-14382015 ] Robert Metzger commented on FLINK-1789: --- You can just add the path to the regular

[jira] [Updated] (FLINK-1433) Add HADOOP_CLASSPATH to start scripts

[ https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1433: -- Fix Version/s: 0.8.1 Add HADOOP_CLASSPATH to start scripts

[jira] [Commented] (FLINK-1452) Add flink-contrib maven module and README.md with the rules

[ https://issues.apache.org/jira/browse/FLINK-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14298498#comment-14298498 ] Robert Metzger commented on FLINK-1452: --- Okay, so we rename {{flink-addons}} to

[jira] [Created] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

Robert Metzger created FLINK-1769: - Summary: Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile) Key: FLINK-1769 URL: https://issues.apache.org/jira/browse/FLINK-1769

[jira] [Commented] (FLINK-1765) Reducer grouping is skippted when parallelism is one

[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375573#comment-14375573 ] Robert Metzger commented on FLINK-1765: --- Can we add a test for this fix? Reducer

[jira] [Reopened] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window

[ https://issues.apache.org/jira/browse/FLINK-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-1757: --- java.lang.ClassCastException is thrown while summing Short values on window

[jira] [Resolved] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window

[ https://issues.apache.org/jira/browse/FLINK-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1757. --- Resolution: Fixed Fix Version/s: 0.9 java.lang.ClassCastException is thrown while

[jira] [Updated] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

[ https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1769: -- Component/s: Build System Maven deploy is broken (build artifacts are cleaned in

[jira] [Updated] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc

[ https://issues.apache.org/jira/browse/FLINK-1720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1720: -- Component/s: Build System Integrate ScalaDoc in Scala sources into overall JavaDoc

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375668#comment-14375668 ] Robert Metzger commented on FLINK-1650: --- I got a response from the Akka mailing

[jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1725: -- Assignee: Anis Nasir New Partitioner for better load balancing for skewed data

[jira] [Commented] (FLINK-1744) Change the reference of slaves to workers to match the description of the system

[ https://issues.apache.org/jira/browse/FLINK-1744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375621#comment-14375621 ] Robert Metzger commented on FLINK-1744: --- I'm not sure if I'm understanding why you

[jira] [Commented] (FLINK-1765) Reducer grouping is skippted when parallelism is one

[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375664#comment-14375664 ] Robert Metzger commented on FLINK-1765: --- Ah, great. Thank you! Reducer grouping is

[jira] [Commented] (FLINK-1774) Remove the redundant code in try{} block

[ https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14376407#comment-14376407 ] Robert Metzger commented on FLINK-1774: --- Hi [~matadorhong], I gave you Contributor

[jira] [Updated] (FLINK-1774) Remove the redundant code in try{} block

[ https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1774: -- Assignee: Sibao Hong Remove the redundant code in try{} block

[jira] [Updated] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1773: -- Assignee: Gyula Fora Add interface for grouped policies to broadcast information to other

[jira] [Updated] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1773: -- Affects Version/s: 0.9 Add interface for grouped policies to broadcast information to other

[jira] [Updated] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1773: -- Component/s: Streaming Add interface for grouped policies to broadcast information to other

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Description: The current {{KafkaITCase}} is only doing a single test. We need to refactor that

[jira] [Resolved] (FLINK-1589) Add option to pass Configuration to LocalExecutor

[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1589. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Updated] (FLINK-1589) Add option to pass Configuration to LocalExecutor

[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1589: -- Component/s: Scala API Java API Add option to pass Configuration to

[jira] [Commented] (FLINK-1753) Add more tests for Kafka Connectors

[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14392357#comment-14392357 ] Robert Metzger commented on FLINK-1753: --- First tests merged in

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Assignee: Gábor Hermann Add more tests for Kafka Connectors

[jira] [Resolved] (FLINK-1777) Update Java 8 Lambdas with Eclipse documentation

[ https://issues.apache.org/jira/browse/FLINK-1777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1777. --- Resolution: Fixed Fix Version/s: 0.9 Merged in

[jira] [Updated] (FLINK-1822) Update Community page on website with a Getting Help section

[ https://issues.apache.org/jira/browse/FLINK-1822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1822: -- Attachment: update_community.patch Update Community page on website with a Getting Help

[jira] [Updated] (FLINK-1821) simplify coding

[ https://issues.apache.org/jira/browse/FLINK-1821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1821: -- Assignee: Liu Jiongzhou simplify coding Key: FLINK-1821

[jira] [Created] (FLINK-1822) Update Community page on website with a Getting Help section

Robert Metzger created FLINK-1822: - Summary: Update Community page on website with a Getting Help section Key: FLINK-1822 URL: https://issues.apache.org/jira/browse/FLINK-1822 Project: Flink

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492927#comment-14492927 ] Robert Metzger commented on FLINK-1829: --- The dependency tree doesn't contain any

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492926#comment-14492926 ] Robert Metzger commented on FLINK-1829: --- The dependency tree doesn't contain any

<    1   2   3   4   5   6   7   8   9   10   >