clear query| facets| time Search criteria: .   Results from 11 to 20 from 80279 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-10253] Run MetricQueryService with lower priority - Flink - [issue]
...We should run the MetricQueryService with a lower priority than the main Flink components. An idea would be to start the underlying threads with a lower priority....
http://issues.apache.org/jira/browse/FLINK-10253    Author: Till Rohrmann , 2018-10-16, 02:10
[expand - 4 more] - Flink1.6 Confirm that flink supports the plan function? - Flink - [mail # user]
...Hi,    1.I think I have some questions.When I have not submitted my jobs,I needto read a job to contol jobs.It is mean that If I want to cancel a job whichis running , I can contol...
   Author: wangziyu , Amit Jain , ... , 2018-10-16, 02:01
[FLINK-10474] Don't translate IN with Literals to JOIN with VALUES for streaming queries - Flink - [issue]
...IN predicates with literals are translated to JOIN with VALUES if the number of elements in the IN clause exceeds a certain threshold. This should not be done, because a streaming join is ve...
http://issues.apache.org/jira/browse/FLINK-10474    Author: Fabian Hueske , 2018-10-16, 01:53
[FLINK-10527] Cleanup constant isNewMode in YarnTestBase - Flink - [issue]
...This seems to be a residual problem with FLINK-10396. It is set to true in that PR. Currently it has three usage scenarios:1. assert, caused an errorassumeTrue("The new mode does not start T...
http://issues.apache.org/jira/browse/FLINK-10527    Author: vinoyang , 2018-10-16, 01:14
[FLINK-10558] Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base - Flink - [issue]
...YARNHighAvailabilityITCase, YARNSessionCapacitySchedulerITCase#testClientStartup, YARNSessionCapacitySchedulerITCase#testTaskManagerFailure...
http://issues.apache.org/jira/browse/FLINK-10558    Author: vinoyang , 2018-10-16, 01:12
[expand - 1 more] - The best way to get processing time of each operator? - Flink - [mail # user]
...Hi Folani,I see one option that we can achieve this through metrics[1].Each operator can report it's processing time as a metric. These metricscan be gathered and queried later. For example,...
   Author: Hequn Cheng , Folani , ... , 2018-10-16, 01:11
[FLINK-10557] Checkpoint size metric incorrectly reports the same value until restart - Flink - [issue]
...We have seen the following several times, but have not found the root cause. The checkpoint size metric will sometimes report the same value over and over, even though the checkpoint size is...
http://issues.apache.org/jira/browse/FLINK-10557    Author: Ruby Andrews , 2018-10-15, 21:42
[FLINK-10553] Unified sink and source table name in SQL statement - Flink - [issue]
...Since sink table can now be registered using ExternalCatalog, just the same as source table, the source and sink name in SQL statement should also be treated equally. Now we can only use `ca...
http://issues.apache.org/jira/browse/FLINK-10553    Author: wangsan , 2018-10-15, 21:31
[FLINK-10556] Integration with Apache Hive - Flink - [issue]
...This is an umbrella JIRA tracking all enhancement and issues related to integrating Flink with Hive ecosystem. This is an outcome of a discussion in the community, and thanks go to everyone ...
http://issues.apache.org/jira/browse/FLINK-10556    Author: Xuefu Zhang , 2018-10-15, 21:29
[FLINK-2592] Rework of FlinkMiniCluster - Flink - [issue]
...Over the time, the FlinkMiniCluster has become quite complex to support all different execution modes (batch vs. streaming, standalone vs. ha with ZooKeeper, single ActorSystem vs. multiple ...
http://issues.apache.org/jira/browse/FLINK-2592    Author: Till Rohrmann , 2018-10-15, 20:30