[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290443#comment-16290443 ] Xingcan Cui commented on FLINK-8236: We need to enable the batch query configuration first. > Allow

[jira] [Created] (FLINK-8258) Enable query configuration for batch queries

Xingcan Cui created FLINK-8258: -- Summary: Enable query configuration for batch queries Key: FLINK-8258 URL: https://issues.apache.org/jira/browse/FLINK-8258 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7956) Add support for scheduling with slot sharing

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

[jira] [Commented] (FLINK-7956) Add support for scheduling with slot sharing

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

[GitHub] flink pull request #5091: [FLINK-7956] [flip6] Add support for queued schedu...

Github user ifndef-SleePy commented on a diff in the pull request: https://github.com/apache/flink/pull/5091#discussion_r156621784 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java --- @@ -266,104 +279,367 @@ public void

[GitHub] flink pull request #5091: [FLINK-7956] [flip6] Add support for queued schedu...

Github user ifndef-SleePy commented on a diff in the pull request: https://github.com/apache/flink/pull/5091#discussion_r154871284 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduledUnit.java --- @@ -19,68 +19,104 @@ package

[jira] [Commented] (FLINK-8249) Kinesis Producer didnt configure region

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

[GitHub] flink issue #5160: [FLINK-8249] [KinesisConnector] [hotfix] aws region is ne...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5160 Merging .. ---

[jira] [Commented] (FLINK-8205) Multi key get

[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290345#comment-16290345 ] Martin Eden commented on FLINK-8205: [~kkl0u][~klalafaryan] My timescales wouldn't allow me to work on

[jira] [Closed] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4

[ https://issues.apache.org/jira/browse/FLINK-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jia liu closed FLINK-8248. -- Resolution: Fixed I've changed the stream event as below, all be right. {code:java} public class Behavior

[jira] [Commented] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager

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

[GitHub] flink pull request #4991: [FLINK-7928] [runtime] extend the resources in Res...

Github user shuai-xu commented on a diff in the pull request: https://github.com/apache/flink/pull/4991#discussion_r156848154 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java --- @@ -52,6 +63,15 @@ /** How many

[jira] [Updated] (FLINK-8257) Unify the value checks for setParallelism()

[ https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8257: --- Description: The {{setParallelism()}} method exist in many components from different levels. Some of

[jira] [Created] (FLINK-8257) Unify the value checks for setParallelism()

Xingcan Cui created FLINK-8257: -- Summary: Unify the value checks for setParallelism() Key: FLINK-8257 URL: https://issues.apache.org/jira/browse/FLINK-8257 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-8205) Multi key get

[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289969#comment-16289969 ] Kostas Kloudas edited comment on FLINK-8205 at 12/13/17 9:45 PM: - No

[jira] [Commented] (FLINK-8205) Multi key get

[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289969#comment-16289969 ] Kostas Kloudas commented on FLINK-8205: --- No problem [~klalafaryan]. Feel free to assign it to you.

[jira] [Updated] (FLINK-8100) Consider introducing log4j-extras

[ https://issues.apache.org/jira/browse/FLINK-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8100: -- Labels: log4j (was: ) > Consider introducing log4j-extras > -- > >

[jira] [Comment Edited] (FLINK-8205) Multi key get

[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289911#comment-16289911 ] Konstantin Lalafaryan edited comment on FLINK-8205 at 12/13/17 9:08 PM:

[jira] [Commented] (FLINK-8205) Multi key get

[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289911#comment-16289911 ] Konstantin Lalafaryan commented on FLINK-8205: -- [~kkl0u] I would like to work on this

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289884#comment-16289884 ] Konstantin Lalafaryan commented on FLINK-7913: -- [~tzulitai] So it means in the scope of this

[jira] [Created] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

Ryan Brideau created FLINK-8256: --- Summary: Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException Key: FLINK-8256 URL: https://issues.apache.org/jira/browse/FLINK-8256 Project:

[jira] [Commented] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

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

[GitHub] flink issue #5112: [FLINK-8175] [DataStream API java/scala] remove flink-str...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5112 @tillrohrmann I agree that `CollectSink` seems to be immature after taking another detailed look at it. I've sent an email to dev alias on Dec 2. Can you please respond to it and start a

[jira] [Commented] (FLINK-8085) Thin out the LogicalSlot interface

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

[GitHub] flink pull request #5087: [FLINK-8085] Thin out LogicalSlot interface

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5087#discussion_r156736950 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/instance/SimpleSlot.java --- @@ -208,27 +209,61 @@ public void setLocality(Locality

[jira] [Commented] (FLINK-8085) Thin out the LogicalSlot interface

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

[GitHub] flink pull request #5087: [FLINK-8085] Thin out LogicalSlot interface

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5087#discussion_r156732600 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/instance/LogicalSlot.java --- @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-8085) Thin out the LogicalSlot interface

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

[jira] [Commented] (FLINK-8085) Thin out the LogicalSlot interface

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

[GitHub] flink pull request #5087: [FLINK-8085] Thin out LogicalSlot interface

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5087#discussion_r156732177 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/instance/SimpleSlot.java --- @@ -37,16 +41,18 @@ * If this slot is part of a

[GitHub] flink pull request #5087: [FLINK-8085] Thin out LogicalSlot interface

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5087#discussion_r156731976 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -965,11 +965,20 @@ public void cancel() {

[jira] [Commented] (FLINK-8103) Flink 1.4 not writing to standard out log file

[ https://issues.apache.org/jira/browse/FLINK-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289607#comment-16289607 ] Ryan Brideau commented on FLINK-8103: - Apologies for the delay. Just pulled the latest updates,

[jira] [Closed] (FLINK-8103) Flink 1.4 not writing to standard out log file

[ https://issues.apache.org/jira/browse/FLINK-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Brideau closed FLINK-8103. --- Resolution: Fixed > Flink 1.4 not writing to standard out log file >

[jira] [Commented] (FLINK-8085) Thin out the LogicalSlot interface

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

[GitHub] flink pull request #5087: [FLINK-8085] Thin out LogicalSlot interface

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5087#discussion_r156728375 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionTest.java --- @@ -267,10 +270,77 @@ public void

[jira] [Commented] (FLINK-8085) Thin out the LogicalSlot interface

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

[GitHub] flink pull request #5087: [FLINK-8085] Thin out LogicalSlot interface

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5087#discussion_r156727881 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/SchedulerIsolatedTasksTest.java --- @@ -294,11 +297,11 @@ public

[jira] [Commented] (FLINK-8085) Thin out the LogicalSlot interface

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

[GitHub] flink pull request #5087: [FLINK-8085] Thin out LogicalSlot interface

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5087#discussion_r156727267 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java --- @@ -331,8 +334,19 @@ public void

[jira] [Commented] (FLINK-8078) Decouple Execution from actual slot implementation

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

[GitHub] flink issue #5086: [FLINK-8078] Introduce LogicalSlot interface

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5086 Thanks for the review @GJL. Merging this PR after Travis gives green light. ---

[jira] [Commented] (FLINK-8030) Start JobMasterRestEndpoint in JobClusterEntrypoint

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

[GitHub] flink issue #4988: [FLINK-8030] Instantiate JobMasterRestEndpoint in JobClus...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4988 Thanks for the review @shuai-xu and @GJL. Merging this PR after Travis gives green light. ---

[jira] [Commented] (FLINK-8030) Start JobMasterRestEndpoint in JobClusterEntrypoint

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

[GitHub] flink pull request #4988: [FLINK-8030] Instantiate JobMasterRestEndpoint in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4988#discussion_r156724507 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java --- @@ -0,0 +1,402 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-8029) Create common WebMonitorEndpoint

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

[GitHub] flink issue #4987: [FLINK-8029] Create WebMonitorEndpoint

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4987 Thanks for the review @GJL. Merging this PR after Travis gives green light. ---

[jira] [Commented] (FLINK-8029) Create common WebMonitorEndpoint

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

[GitHub] flink pull request #4987: [FLINK-8029] Create WebMonitorEndpoint

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4987#discussion_r156722826 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -757,6 +775,64 @@ public void

[jira] [Commented] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

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

[GitHub] flink issue #5112: [FLINK-8175] [DataStream API java/scala] remove flink-str...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5112 Thanks for your contribution @bowenli86. I think we should reach first some kind of consensus on the ML before moving the classes. I'm actually not sure whether `CollectSink` is something we

[GitHub] flink pull request #4991: [FLINK-7928] [runtime] extend the resources in Res...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4991#discussion_r156717761 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java --- @@ -61,16 +80,26 @@ * @param

[jira] [Commented] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager

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

[GitHub] flink pull request #4991: [FLINK-7928] [runtime] extend the resources in Res...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4991#discussion_r156719388 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java --- @@ -52,6 +63,15 @@ /** How many

[jira] [Commented] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager

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

[jira] [Commented] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager

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

[jira] [Commented] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager

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

[GitHub] flink pull request #4991: [FLINK-7928] [runtime] extend the resources in Res...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4991#discussion_r156715729 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java --- @@ -52,6 +63,15 @@ /** How many

[GitHub] flink pull request #4991: [FLINK-7928] [runtime] extend the resources in Res...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4991#discussion_r156717989 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/types/ResourceProfileTest.java --- @@ -18,19 +18,21 @@

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

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

[GitHub] flink issue #4911: [FLINK-7878] [api] make resource type extendible in Resou...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4911 Changes look good @shuai-xu. I have a single last question which is whether we want to expose the `GpuResource` to the user or not. Wouldn't it be enough to set the gpus via

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289451#comment-16289451 ] Xingcan Cui commented on FLINK-8236: Yes, maybe we should consider unifying them since in some classes

[jira] [Commented] (FLINK-8220) Implement set of network throughput benchmarks in Flink

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

[GitHub] flink issue #5134: [FLINK-8220] Implement set of network benchmarks

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5134 Would be great if someone could check with Apache legal if this is actually in line with policies. Either on the `LEGAL` Jira, or on the legal-disc...@apache.org mailing list. ---

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289433#comment-16289433 ] Timo Walther commented on FLINK-8236: - Ok, I think we can discuss this again once the PR is ready. You

[GitHub] flink pull request #5164: [hotfix][javadoc] fix typo in StreamExecutionEnvir...

GitHub user Matrix42 opened a pull request: https://github.com/apache/flink/pull/5164 [hotfix][javadoc] fix typo in StreamExecutionEnvironment javadoc ## What is the purpose of the change fix typo in StreamExecutionEnvironment javadoc You can merge this pull request into

[jira] [Commented] (FLINK-8254) REST API documentation wonky due to shading

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

[GitHub] flink pull request #5163: [FLINK-8254][REST][docs] Bandaid generated documen...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5163 [FLINK-8254][REST][docs] Bandaid generated documentation ## What is the purpose of the change This is a bandaid PR that replaces the generated file with a correct version and updates the

[jira] [Updated] (FLINK-8255) Key expressions on named row types do not work

[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8255: Summary: Key expressions on named row types do not work (was: Key expressions on named rows types

[jira] [Updated] (FLINK-8255) Key expressions on named row types do not work

[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8255: Affects Version/s: 1.5.0 1.4.0 > Key expressions on named row types do not

[jira] [Created] (FLINK-8255) Key expressions on named rows types do not work

Timo Walther created FLINK-8255: --- Summary: Key expressions on named rows types do not work Key: FLINK-8255 URL: https://issues.apache.org/jira/browse/FLINK-8255 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289414#comment-16289414 ] Xingcan Cui commented on FLINK-8236: Hi [~twalthr], thanks for your explanation. I think that won't be

[jira] [Created] (FLINK-8254) REST API documentation wonky due to shading

Chesnay Schepler created FLINK-8254: --- Summary: REST API documentation wonky due to shading Key: FLINK-8254 URL: https://issues.apache.org/jira/browse/FLINK-8254 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289380#comment-16289380 ] Timo Walther commented on FLINK-8236: - Hi [~xccui], I think this constant is actually mainly used

[jira] [Comment Edited] (FLINK-8236) Allow to set the parallelism of table queries

[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289369#comment-16289369 ] Xingcan Cui edited comment on FLINK-8236 at 12/13/17 3:15 PM: -- Hi [~twalthr],

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289369#comment-16289369 ] Xingcan Cui commented on FLINK-8236: Hi [~twalthr], thanks for raising this. I got a question about

[GitHub] flink issue #4626: [FLINK-7561][streaming] Implement PreAggregationOperator

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4626 I moved everything to `flink-streaming-contrib`. @StephanEwen I went one step further and created following helper function: ``` public static

[jira] [Commented] (FLINK-7561) Add support for pre-aggregation in DataStream API

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

[jira] [Closed] (FLINK-8253) flink-docs-stable still points to 1.3

[ https://issues.apache.org/jira/browse/FLINK-8253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-8253. -- Resolution: Fixed Fixed in revision 1022185 of

[jira] [Created] (FLINK-8253) flink-docs-stable still points to 1.3

Ufuk Celebi created FLINK-8253: -- Summary: flink-docs-stable still points to 1.3 Key: FLINK-8253 URL: https://issues.apache.org/jira/browse/FLINK-8253 Project: Flink Issue Type: Bug

[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 Release Note: REST API breaking changes: The return type of the jobs

[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 > Move CurrentJobsOverviewHandler to jobs/overview >

[jira] [Reopened] (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 reopened FLINK-7806: -- > Move CurrentJobsOverviewHandler to jobs/overview >

[jira] [Updated] (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 updated FLINK-7806: - Release Note: REST API breaking change: The jobs overview handler is now registered under

[jira] [Reopened] (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 reopened FLINK-7815: -- > Remove grouping from MultipleJobsDetails > > >

[jira] [Updated] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos

[ https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8247: Fix Version/s: 1.4.1 1.5.0 > Support Hadoop-free variant of Flink on

[jira] [Created] (FLINK-8252) Convert network benchmarks to streaming benchmarks

Nico Kruber created FLINK-8252: -- Summary: Convert network benchmarks to streaming benchmarks Key: FLINK-8252 URL: https://issues.apache.org/jira/browse/FLINK-8252 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8251) Add network (micro) benchmarks in Flink

[ https://issues.apache.org/jira/browse/FLINK-8251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8251: --- Summary: Add network (micro) benchmarks in Flink (was: Add some network micro-benchmarks in Flink)

[jira] [Updated] (FLINK-8221) Implement set of network latency benchmarks in Flink

[ https://issues.apache.org/jira/browse/FLINK-8221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8221: --- Labels: benchmarks (was: ) > Implement set of network latency benchmarks in Flink >

[GitHub] flink pull request #:

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/commit/8086e3bee8be4614359041c14786140edff19666#commitcomment-26240373 Valid point. I'll add the release notes. ---

[jira] [Commented] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

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

[jira] [Resolved] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8176. -- Resolution: Fixed Fixed via 7ddb674cb17c35f17aa073d3bfd6897d7fc13b9e > Dispatcher does not

[jira] [Updated] (FLINK-8220) Implement set of network throughput benchmarks in Flink

[ https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8220: --- Labels: benchmarks (was: ) > Implement set of network throughput benchmarks in Flink >

[jira] [Updated] (FLINK-8221) Implement set of network latency benchmarks in Flink

[ https://issues.apache.org/jira/browse/FLINK-8221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8221: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-8251 > Implement set of network

[jira] [Updated] (FLINK-8220) Implement set of network throughput benchmarks in Flink

[ https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8220: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-8251 > Implement set of network

[jira] [Created] (FLINK-8251) Add some network micro-benchmarks in Flink

Nico Kruber created FLINK-8251: -- Summary: Add some network micro-benchmarks in Flink Key: FLINK-8251 URL: https://issues.apache.org/jira/browse/FLINK-8251 Project: Flink Issue Type: Test

[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 Release Note: REST API breaking change: The jobs overview handler is now

[jira] [Reopened] (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 reopened FLINK-7806: -- Reopening it in order to add release note. > Move CurrentJobsOverviewHandler to jobs/overview >

[GitHub] flink pull request #5107: [FLINK-8176][flip6] Start SubmittedJobGraphStore i...

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

[GitHub] flink issue #4581: [FLINK-7499][io] fix double buffer release in SpillableSu...

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4581 ...rebased onto latest master ---

  1   2   >