[jira] [Commented] (FLINK-8010) Bump remaining flink-shaded dependencies

[ https://issues.apache.org/jira/browse/FLINK-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242175#comment-16242175 ] ASF GitHub Bot commented on FLINK-8010: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-7998) Make case classes in TPCHQuery3.java public to allow dynamic instantiation

[ https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242166#comment-16242166 ] Vetriselvan commented on FLINK-7998: - https://github.com/apache/flink/pull/4959 > Make case classes

[jira] [Created] (FLINK-8011) Set dist flink-python dependency to provided

Chesnay Schepler created FLINK-8011: --- Summary: Set dist flink-python dependency to provided Key: FLINK-8011 URL: https://issues.apache.org/jira/browse/FLINK-8011 Project: Flink Issue Type:

[GitHub] flink pull request #4971: [FLINK-8010][build] Bump remaining flink-shaded ve...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4971 [FLINK-8010][build] Bump remaining flink-shaded versions ## What is the purpose of the change This PR bumps the remaining flink-shaded dependencies to 2.0. ## Brief change log

[jira] [Commented] (FLINK-8010) Bump remaining flink-shaded dependencies

[ https://issues.apache.org/jira/browse/FLINK-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242153#comment-16242153 ] ASF GitHub Bot commented on FLINK-8010: --- GitHub user zentol opened a pull request:

[jira] [Assigned] (FLINK-8005) Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues

[ https://issues.apache.org/jira/browse/FLINK-8005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8005: --- Assignee: Gary Yao > Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues >

[jira] [Commented] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview

[ https://issues.apache.org/jira/browse/FLINK-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242111#comment-16242111 ] ASF GitHub Bot commented on FLINK-7806: --- Github user tillrohrmann closed the pull request at:

[GitHub] flink pull request #4805: [FLINK-7806] [flip6] Register CurrentJobsOverviewH...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/4805 ---

[jira] [Created] (FLINK-8010) Bump remaining flink-shaded dependencies

Chesnay Schepler created FLINK-8010: --- Summary: Bump remaining flink-shaded dependencies Key: FLINK-8010 URL: https://issues.apache.org/jira/browse/FLINK-8010 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8000) Sort REST handler URLs in RestServerEndpoint

[ https://issues.apache.org/jira/browse/FLINK-8000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242098#comment-16242098 ] ASF GitHub Bot commented on FLINK-8000: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4958: [FLINK-8000] Sort Rest handler URLS in RestServerE...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4958#discussion_r149382049 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java --- @@ -268,4 +287,69 @@ private static void

[jira] [Deleted] (FLINK-7893) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann deleted FLINK-7893: - > Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint >

[jira] [Deleted] (FLINK-7884) Port CheckpointConfigHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann deleted FLINK-7884: - > Port CheckpointConfigHandler to new REST endpoint >

[jira] [Deleted] (FLINK-7885) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann deleted FLINK-7885: - > Port CheckpointStatsDetailsHandler to new REST endpoint >

[jira] [Deleted] (FLINK-7892) Port CheckpointStatsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann deleted FLINK-7892: - > Port CheckpointStatsHandler to new REST endpoint >

[jira] [Commented] (FLINK-8000) Sort REST handler URLs in RestServerEndpoint

[ https://issues.apache.org/jira/browse/FLINK-8000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242081#comment-16242081 ] ASF GitHub Bot commented on FLINK-8000: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4958: [FLINK-8000] Sort Rest handler URLS in RestServerE...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4958#discussion_r149379485 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java --- @@ -268,4 +287,69 @@ private static void

[jira] [Updated] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8009: Description: The promotion of transitive dependencies in flink-runtime causes flink-dist to

[jira] [Closed] (FLINK-7872) Set ACCESS_CONTROL_ALLOW_ORIGIN header in HandlerUtils#sendResponse

[ https://issues.apache.org/jira/browse/FLINK-7872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7872. Resolution: Fixed Fix Version/s: 1.5.0 Fixed via eddb5b0a4c3acc5ec2a07686a50b088303f8 >

[jira] [Closed] (FLINK-7914) Expose Akka gated interval as user option

[ https://issues.apache.org/jira/browse/FLINK-7914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7914. Resolution: Done Fix Version/s: 1.5.0 Added via 3e36fd6b2efc8fbbe41dceac66da355dd20f5a47 >

[jira] [Resolved] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7648. -- Resolution: Done Fix Version/s: (was: 1.4.0) 1.5.0 Added via

[jira] [Resolved] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7706. -- Resolution: Fixed Fixed via 0c62c5278fc5581ea3485977a562df4445cf9dc9 > Port

[jira] [Closed] (FLINK-7862) Add TaskManagerDetailsHandler

[ https://issues.apache.org/jira/browse/FLINK-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7862. Resolution: Done Fix Version/s: 1.5.0 Added via fdf684427165e8068d4229a340b8e03548e022ef >

[jira] [Resolved] (FLINK-7705) Port JobDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7705. -- Resolution: Fixed Fixed via de201a6c0f8739c12918817d2ef571abb2898f37 > Port JobDetailsHandler

[jira] [Closed] (FLINK-7815) Remove grouping from MultipleJobsDetails

[ https://issues.apache.org/jira/browse/FLINK-7815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7815. Resolution: Fixed Fix Version/s: (was: 1.4.0) 1.5.0 Fixed via

[jira] [Resolved] (FLINK-7941) Port SubtasksTimesHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7941. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via

[jira] [Closed] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview

[ https://issues.apache.org/jira/browse/FLINK-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7806. Resolution: Fixed Fix Version/s: (was: 1.4.0) 1.5.0 Fixed via

[jira] [Resolved] (FLINK-7870) SlotPool should cancel the slot request to RM if not need any more.

[ https://issues.apache.org/jira/browse/FLINK-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7870. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via

[jira] [Commented] (FLINK-7872) Set ACCESS_CONTROL_ALLOW_ORIGIN header in HandlerUtils#sendResponse

[ https://issues.apache.org/jira/browse/FLINK-7872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242052#comment-16242052 ] ASF GitHub Bot commented on FLINK-7872: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7941) Port SubtasksTimesHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242056#comment-16242056 ] ASF GitHub Bot commented on FLINK-7941: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7705) Port JobDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242055#comment-16242055 ] ASF GitHub Bot commented on FLINK-7705: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7870) SlotPool should cancel the slot request to RM if not need any more.

[ https://issues.apache.org/jira/browse/FLINK-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242058#comment-16242058 ] ASF GitHub Bot commented on FLINK-7870: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7862) Add TaskManagerDetailsHandler

[ https://issues.apache.org/jira/browse/FLINK-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242053#comment-16242053 ] ASF GitHub Bot commented on FLINK-7862: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7815) Remove grouping from MultipleJobsDetails

[ https://issues.apache.org/jira/browse/FLINK-7815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242057#comment-16242057 ] ASF GitHub Bot commented on FLINK-7815: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7914) Expose Akka gated interval as user option

[ https://issues.apache.org/jira/browse/FLINK-7914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242050#comment-16242050 ] ASF GitHub Bot commented on FLINK-7914: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4930: [FLINK-7941][flip6] Port SubtasksTimesHandler to n...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4930 ---

[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242051#comment-16242051 ] ASF GitHub Bot commented on FLINK-7648: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242054#comment-16242054 ] ASF GitHub Bot commented on FLINK-7706: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4806: [FLINK-7815] Remove grouping from MultipleJobsDeta...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4806 ---

[GitHub] flink pull request #4824: [FLINK-7648] [flip6] Add TaskManagersHandler

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4824 ---

[GitHub] flink pull request #4859: [FLINK-7872] Allow to pass in additional HTTP head...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4859 ---

[GitHub] flink pull request #4903: [FLINK-7914] Introduce AkkaOptions.RETRY_GATE_CLOS...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4903 ---

[GitHub] flink pull request #4887: [FLINK-7870] [runtime] Cancel slot allocation to R...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4887 ---

[GitHub] flink pull request #4884: [FLINK-7705] Add JobDetailsHandler

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4884 ---

[GitHub] flink pull request #4862: [FLINK-7862] [flip6] Add TaskManagerDetailsHandler

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4862 ---

[GitHub] flink pull request #4898: [FLINK-7706] [flip6] Add JobAccumulatorsHandler fo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4898 ---

[jira] [Issue Comment Deleted] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8009: Comment: was deleted (was: False alarm, dependencies came in from other modules) >

[jira] [Reopened] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8009: - > flink-dist contains flink-runtime's transitive hadoop dependencies >

[jira] [Closed] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8009. --- Resolution: Not A Problem False alarm, dependencies came in from other modules > flink-dist

[jira] [Updated] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8009: Description: The promotion of transitive dependencies in flink-runtime causes flink-dist to

[jira] [Updated] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8009: Description: The promotion of transitive dependencies in flink-runtime causes flink-dist to

[jira] [Updated] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muhammad Imran Tariq updated FLINK-8008: Summary: PojoTypeInfo should sort fields fields based on boolean (was:

[jira] [Updated] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8009: Description: The promotion of transitive dependencies in flink-runtime causes flink-dist to

[jira] [Updated] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8009: Fix Version/s: 1.5.0 1.4.0 > flink-dist contains flink-runtime's

[jira] [Created] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

Chesnay Schepler created FLINK-8009: --- Summary: flink-dist contains flink-runtime's transitive hadoop dependencies Key: FLINK-8009 URL: https://issues.apache.org/jira/browse/FLINK-8009 Project:

[jira] [Commented] (FLINK-7419) Shade jackson dependency in flink-avro

[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241999#comment-16241999 ] Chesnay Schepler commented on FLINK-7419: - Even worse, we still pull the unshaded codehaus.jackson

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242000#comment-16242000 ] ASF GitHub Bot commented on FLINK-8001: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4969: (release-1.3) [FLINK-8001] [kafka] Mark subtask as IDLE i...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4969 These also look good! 👌 ---

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241997#comment-16241997 ] ASF GitHub Bot commented on FLINK-8001: --- Github user aljoscha commented on the issue:

[jira] [Created] (FLINK-8008) PojoTypeInfo should not sort fields

Muhammad Imran Tariq created FLINK-8008: --- Summary: PojoTypeInfo should not sort fields Key: FLINK-8008 URL: https://issues.apache.org/jira/browse/FLINK-8008 Project: Flink Issue Type:

[GitHub] flink issue #4967: [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmitter fro...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4967 The changes look good! Thanks for fixing it this quickly. 😃 ---

[jira] [Commented] (FLINK-7997) Avro should be always in the user code

[ https://issues.apache.org/jira/browse/FLINK-7997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241991#comment-16241991 ] Chesnay Schepler commented on FLINK-7997: - So we always assume that avro users add flink-avro to

[jira] [Commented] (FLINK-7996) Add support for (left.time = right.time) predicates to window join.

[ https://issues.apache.org/jira/browse/FLINK-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241981#comment-16241981 ] Xingcan Cui commented on FLINK-7996: That's fine. I'll provide a temporary solution for this as soon

[jira] [Reopened] (FLINK-7419) Shade jackson dependency in flink-avro

[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-7419: - This isn't really fixed. We added a relocation for codehaus.jackson, but since avro itself

[jira] [Commented] (FLINK-7822) Add documentation for the new queryable state client.

[ https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241964#comment-16241964 ] ASF GitHub Bot commented on FLINK-7822: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-7823) Adjust queryable state configuration parameters

[ https://issues.apache.org/jira/browse/FLINK-7823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7823. - Resolution: Fixed Fixed with 84746a861ae02dd1dbcf1938d7ae2bf0d604e35f > Adjust queryable state

[GitHub] flink pull request #4966: [FLINK-7822][FLINK-7823] Adds documentation and fi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4966 ---

[jira] [Closed] (FLINK-7822) Add documentation for the new queryable state client.

[ https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7822. - Resolution: Fixed Merged at a19d8bfa9ab964e49fc29da037f862bafe7a853b > Add documentation for the

[jira] [Commented] (FLINK-8007) Move TestMeter class to test scope

[ https://issues.apache.org/jira/browse/FLINK-8007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241960#comment-16241960 ] ASF GitHub Bot commented on FLINK-8007: --- GitHub user zentol opened a pull request:

[jira] [Updated] (FLINK-8007) Move TestMeter class to test scope

[ https://issues.apache.org/jira/browse/FLINK-8007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8007: Priority: Trivial (was: Major) > Move TestMeter class to test scope >

[jira] [Updated] (FLINK-8007) Move TestMeter class to test scope

[ https://issues.apache.org/jira/browse/FLINK-8007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8007: Fix Version/s: 1.5.0 > Move TestMeter class to test scope >

[jira] [Updated] (FLINK-8007) Move TestMeter class to test scope

[ https://issues.apache.org/jira/browse/FLINK-8007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8007: Affects Version/s: 1.5.0 > Move TestMeter class to test scope >

[GitHub] flink pull request #4970: [FLINK-8007][metrics] Move TestMeter into test sco...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4970 [FLINK-8007][metrics] Move TestMeter into test scope This PR moves the TestMeter class into the test scope where it belongs. You can merge this pull request into a Git repository by running: $

[jira] [Created] (FLINK-8007) Move TestMeter class to test scope

Chesnay Schepler created FLINK-8007: --- Summary: Move TestMeter class to test scope Key: FLINK-8007 URL: https://issues.apache.org/jira/browse/FLINK-8007 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7765) Enable dependency convergence

[ https://issues.apache.org/jira/browse/FLINK-7765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241945#comment-16241945 ] ASF GitHub Bot commented on FLINK-7765: --- Github user pnowojski commented on the issue:

[GitHub] flink issue #4777: [FLINK-7765] Enable dependency convergence

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4777 @aljoscha `combine.self="override"` couldn't work because `` can not be empty, so I couldn't override `maven-enforcer-plugin` with an empty configuration. Instead I have enabled convergence by

[jira] [Commented] (FLINK-7978) Kafka011 exactly-once Producer sporadically fails to commit under high parallelism

[ https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241939#comment-16241939 ] ASF GitHub Bot commented on FLINK-7978: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4955: [FLINK-7978][kafka] Ensure that transactional ids will ne...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4955 LGTM once Travis is green. ---

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241927#comment-16241927 ] ASF GitHub Bot commented on FLINK-8001: --- GitHub user tzulitai opened a pull request:

[GitHub] flink pull request #4969: (release-1.3) [FLINK-8001] [kafka] Mark subtask as...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4969 (release-1.3) [FLINK-8001] [kafka] Mark subtask as IDLE instead of emitting Long.MAX_VALUE watermark ## What is the purpose of the change This is a backport of #4967 to `release-1.3`.

[jira] [Commented] (FLINK-7998) Make case classes in TPCHQuery3.java public to allow dynamic instantiation

[ https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241918#comment-16241918 ] Keren Zhu commented on FLINK-7998: -- [~Zentol] Yes it's straight-up not working. It triggers an

[jira] [Updated] (FLINK-8006) flink-daemon.sh: line 103: binary operator expected

[ https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alejandro updated FLINK-8006: -- External issue URL: https://github.com/apache/flink/pull/4968 > flink-daemon.sh: line 103: binary

[jira] [Commented] (FLINK-8006) flink-daemon.sh: line 103: binary operator expected

[ https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241913#comment-16241913 ] ASF GitHub Bot commented on FLINK-8006: --- GitHub user elbaulp opened a pull request:

[jira] [Assigned] (FLINK-7907) Flink Metrics documentation missing Scala examples

[ https://issues.apache.org/jira/browse/FLINK-7907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reassigned FLINK-7907: - Assignee: Hai Zhou UTC+8 > Flink Metrics documentation missing Scala examples >

[GitHub] flink pull request #4968: [FLINK-8006] [Startup Shell Scripts] Enclosing $pi...

GitHub user elbaulp opened a pull request: https://github.com/apache/flink/pull/4968 [FLINK-8006] [Startup Shell Scripts] Enclosing $pid in quotes ## What is the purpose of the change When executing `./bin/start-local.sh` The following errors appears:

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241891#comment-16241891 ] ASF GitHub Bot commented on FLINK-8001: --- GitHub user tzulitai opened a pull request:

[GitHub] flink pull request #4967: [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmit...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4967 [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmitter from violating … ## What is the purpose of the change Prior to this PR, a bug exists such that if a Kafka consumer subtask

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241884#comment-16241884 ] ASF GitHub Bot commented on FLINK-7973: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241885#comment-16241885 ] ASF GitHub Bot commented on FLINK-7973: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241886#comment-16241886 ] ASF GitHub Bot commented on FLINK-7973: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4961: [FLINK-7973] fix shading and relocating Hadoop for...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4961#discussion_r149344188 --- Diff: flink-filesystems/flink-s3-fs-presto/pom.xml --- @@ -284,6 +322,7 @@ under the License.

[GitHub] flink pull request #4961: [FLINK-7973] fix shading and relocating Hadoop for...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4961#discussion_r149344386 --- Diff: flink-filesystems/flink-s3-fs-hadoop/pom.xml --- @@ -33,6 +33,7 @@ under the License. jar + --- End diff

[GitHub] flink pull request #4961: [FLINK-7973] fix shading and relocating Hadoop for...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4961#discussion_r149344106 --- Diff: flink-filesystems/flink-s3-fs-hadoop/pom.xml --- @@ -277,6 +336,7 @@ under the License.

[jira] [Updated] (FLINK-8004) Sample code in Debugging & Monitoring Metrics documentation section is not valid java

[ https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8004: Affects Version/s: 1.5.0 1.4.0 > Sample code in Debugging &

[jira] [Updated] (FLINK-8004) Sample code in Debugging & Monitoring Metrics documentation section is not valid java

[ https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8004: Fix Version/s: 1.5.0 1.4.0 > Sample code in Debugging & Monitoring

[jira] [Commented] (FLINK-7822) Add documentation for the new queryable state client.

[ https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241861#comment-16241861 ] ASF GitHub Bot commented on FLINK-7822: --- Github user kl0u commented on a diff in the pull request:

[jira] [Updated] (FLINK-8004) Sample code in Debugging & Monitoring Metrics documentation section is not valid java

[ https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8004: Component/s: Metrics Documentation > Sample code in Debugging & Monitoring

[GitHub] flink pull request #4966: [FLINK-7822][FLINK-7823] Adds documentation and fi...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/4966#discussion_r149340569 --- Diff: docs/dev/stream/state/queryable_state.md --- @@ -32,38 +32,67 @@ under the License. likely that there will be breaking API changes on the

[jira] [Commented] (FLINK-7822) Add documentation for the new queryable state client.

[ https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241855#comment-16241855 ] ASF GitHub Bot commented on FLINK-7822: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-7822) Add documentation for the new queryable state client.

[ https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241853#comment-16241853 ] ASF GitHub Bot commented on FLINK-7822: --- Github user aljoscha commented on a diff in the pull

<    1   2   3   >