Re: [DISCUSS] Project build time and possible restructuring

be done :) ) >>>>> >>>>> I'm against creating two new repositories. I fear that this >> introduces >>>> too >>>>> much complexity and too many repositories. >>>>> "flink" and "flink-libraries&qu

[DISCUSS] TravisCI status on GitHub Page

We are now showing the TravisCI build status on Flink’s GitHub page. I think Robert’s comment in Jira may have gone unnoticed when the PR was committed. https://issues.apache.org/jira/browse/FLINK-6122 If not yet seeing the benefit even if bui

Re: [DISCUSS] Project build time and possible restructuring

to do only the library split initially, to see > what the challenges are in setting up the multi-repo build and release > tooling. Once we gathered experience there, we can probably easily see what > else we can split out. > > Stephan > > > On Fri, Mar 17, 2017 at 8:37 PM

Re: [Disuss]Permission of checkpoint directory

Prior discussion at https://github.com/apache/flink/pull/3335 > On Mar 19, 2017, at 11:34 PM, Wangtao (WangTao) wrote: > > Hi All, > > Checkpoint directory will store user data and it is better to keep it with > minimum access right, like 700, in c

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Welcome, Theo, and great to have you onboard with Flink and ML! > On Mar 21, 2017, at 4:35 AM, Robert Metzger wrote: > > Hi everybody, > > On behalf of the PMC I am delighted to announce Theodore Vasiloudis as a > new Flink committer! > > Theo has been a community member for a very long time

Re: [DISCUSS] FLIP-18: Code Generation for improving sorting performance

I would be more than happy to shepherd and review this PR. I have two discussion points. First, a strategy for developing with templates. IntelliJ has a FreeMarker plugin but we lose formatting and code completion. To minimize this issue we can retain the untemplated code in an abstract class w

Re: [DISCUSS] Flink dist directory management

Hi Jinkui, +1 to moving gelly-examples into examples/. Also sounds nice to similarly organize the Python examples. Docs will also need to be updated (docs/dev/lib/gelly/index.md). Greg > On Mar 25, 2017, at 3:46 AM, shijinkui wrote: > > Hi, all > > The Flink distributionĄ¯s directory have

[DISCUSS] TravisCI auto cancellation

Hi, Just saw this TravisCI beta feature. I think this would be worthwhile to enable on pull request builds. We could leave branch builds unchanged since there are fewer builds of this type and skipping builds would make it harder to locate a broken build. It’s not uncommon to see three or more

Re: [DISCUSS] TravisCI auto cancellation

rs, > Till > > On Sun, Mar 26, 2017 at 11:57 PM, Ted Yu wrote: > >> +1 to Greg's suggestion. >> >> On Sun, Mar 26, 2017 at 2:22 PM, Greg Hogan wrote: >> >>> Hi, >>> >>> Just saw this TravisCI beta feature. I think this wou

Re: [DISCUSS] TravisCI auto cancellation

Wow, that was a quick response that this feature was already enabled. > On Mar 29, 2017, at 9:31 AM, Greg Hogan wrote: > > Ticket: https://issues.apache.org/jira/browse/INFRA-13778 > <https://issues.apache.org/jira/browse/INFRA-13778> > > >> On Mar 29, 2

Re: [DISCUSS] Project build time and possible restructuring

t;>> flink-gelly-examples >>> flink-gelly-scala >>> flink-gelly >>> flink-ml >>> >>> All other modules (e.g. in flink-contrib) are rather connectors. I think >>> it would be better to move those in a connectors repository later. >>>

Re: [DISCUSS] Code style / checkstyle

ld like to have a well defined code style, such as the Google >>> Code >>>>>> style, that has nice tooling and support but I don't think we will >>> ever >>>>>> convince enough people to do this kind of massive change. Even I >>> think &

Re: [DISCUSS] FLIP-18: Code Generation for improving sorting performance

Pat, Thanks for running additional tests and continuing to work on this contribution. My testing is also showing that the performance gains remain even when multiple classes are used for sorting. I think we should proceed in the order of FLINK-3722, FLINK-4705, and FLINK-5734. Gabor has review

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

+1 (binding) for the release - checked all checksums and signatures - started standalone clusters and ran Gelly example Greg > On Apr 12, 2017, at 7:06 PM, Robert Metzger wrote: > > Dear Flink community, > > Please vote on releasing the following candidate as Apache Flink version 1.2 > .1. >

Supported Hadoop versions

Hi Flink, I filed a ticket [0] that our download page [1] still states “You don’t have to install Hadoop to use Flink, but if you plan to use Flink with data stored in Hadoop, pick the version matching your installed Hadoop version. If you don’t want to do this, pick the Hadoop 1 version.” 1)

Re: Supported Hadoop versions

For #2, we can reference Hadoop 2.7 > BTW I think we can bump to 2.7.3 as dependency. > > For #3, Hadoop 2.8.0 was marked not production ready. Junping is in the > process of releasing 2.8.1 > It would be good idea to start testing against 2.8.0 now > > Cheers > > O

Re: [DISCUSS] What is a "Blocker" in our JIRA?

+1 to restricting use of “blocker" -1 to post-hoc documentation and unreleased publication [0] [0] http://www.apache.org/dev/release-publishing.html > On May 5, 2017, at 5:06 AM, Ufuk Celebi wrote: > > Thanks for this discussion Robert. I agree with your points. +1 > > Regarding the document

Re: [DISCUSS] What is a "Blocker" in our JIRA?

“How to Contribute” works well to filter “developers” but we do link to the GitHub repo from the left panel. > On May 5, 2017, at 9:13 AM, Ufuk Celebi wrote: > > On Fri, May 5, 2017 at 2:24 PM, Greg Hogan wrote: >> -1 to post-hoc documentation and unreleased publication [0]

git overwritten by checkout

The following file in the following commit throw the following error when rebasing to master. I agree that case insensitive filesystems are an abomination and hopefully never supported by APFS but just wanted to note the situation. With a clean working directory I solved this with `git fetch apa

Re: [DISCUSS] Release 1.3.0 RC0 (Non voting, testing release candidate)

+1 for sticking to the code freeze deadline and building a new release candidate but since the release is still two weeks off (5/26) I think it better to delay voting to give time for additional bug fixes. > On May 11, 2017, at 10:19 AM, Robert Metzger wrote: > > It seems that we found quite

Re: [DISCUSS] Release 1.3.0 RC1 (Non voting, testing release candidate)

The following tickets for 1.3.0 have a PR in need of review: [FLINK-6582] [docs] Project from maven archetype is not buildable by default [FLINK-6616] [docs] Clarify provenance of official Docker images > On May 18, 2017, at 5:40 AM, Fabian Hueske wrote: > > I have a couple of PRs ready with b

Re: [DISCUSS] Backwards compatibility policy.

I can’t find when the time-based maintenance schedule switched from “6 months” to “2 concurrent versions” (which has not yet made it into the website [0]). Is it correct to assume that most users are waiting until the first bug fix release or later to upgrade? That only leaves a narrow window of

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

+1 (binding) - verified source and binary signatures - verified source and binary checksums - verified LICENSEs - verified NOTICEs - built from source Greg > On May 26, 2017, at 12:58 PM, Robert Metzger wrote: > > Hi all, > > this is the second VOTEing release candidate for Flink 1.3.0 > >

[DISCUSS] NOTICE

In several locations we have copied code from external projects, for example flink-scala-shell/src/main/java/org/apache/flink/api/java/JarHelper.java links to the file from org.apache.xmlbeans/xmlbeans/2.4.0. We also have copied from Apache's Calcite, Spark, and Hadoop. None of these projects are

Re: [DISCUSS] Planning Release 1.4

I’d like to propose keeping the same schedule but move branch forking from the feature freeze to the code freeze. The early fork required duplicate verification and commits for numerous bug fixes and minor features which had been reviewed but were still queued. There did not look to be much new

Re: Update Netty version

Hi Alexey, Are you looking to create pull requests for upgrading Netty 4.0 and/or 4.1? Greg On Thu, May 18, 2017 at 4:41 AM, Alexey Demin wrote: > Hi > > Problem not directly in flink, but it you use flink with beam then in > classpath you have original netty 4.0.27 from flink and netty 4.1.x

Re: [POLL] Who still uses Java 7 with Flink ?

ll the potential future users, > i.e. slower moving organizations (banks etc.) which could be on Java 7 still. > > Whether those are relevant is up for debate. > > Cheers, > Theo > > On Thu, Mar 23, 2017 at 12:14 PM, Robert Metzger <mailto:rmetz...@apache.org>> wrot

[DISCUSS] GitBox

All, ASF now has available (and maybe mandatory for new projects or repos) GitBox [0] which enables bi-directional sync to GitHub and links committers' accounts, allowing for greater use of GitHub functionality by contributors and for committers to perform many tasks otherwise requiring INFRA tick

Re: [DISCUSS] GitBox

q. better track the oft-neglected contributions > > Do you have estimate on how many contributions were not paid attention in > the current infrastructure. > > Looking at #2, it seems Accumulo community hasn't reached consensus yet. > > Cheers > > On Fri, Jun 9, 2017

Re: [DISCUSS] GitBox

es of this? Actually, is there any ASF resource that >>> outlines what this would enable? >>> >>> In one of the threads i saw said that this would also allow committers to >>> close PR's, assign labels and such. >>> This sounds very interesting to

Re: [VOTE] Release Apache Flink 1.3.1

+1 (binding) - verified source and binary signatures - verified source and binary checksums - verified LICENSEs - verified NOTICEs - built from source Greg > On Jun 14, 2017, at 10:14 AM, Robert Metzger wrote: > > Dear Flink community, > > Please vote on releasing the following candidate as A

Re: [ANNOUNCE] New committer: Dawid Wysakowicz

Welcome and congrats Dawid! > On Jun 19, 2017, at 4:40 AM, Till Rohrmann wrote: > > Hi everybody, > > On behalf of the PMC I am delighted to announce Dawid Wysakowicz as a new > Flink committer! > > Dawid has been a community member for a very long time and among other > things he helped shap

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congrats and welcome, Shaoxuan! > On Jun 21, 2017, at 4:19 PM, Fabian Hueske wrote: > > Hi everybody, > > On behalf of the PMC, I'm very happy to announce that Shaoxuan Wang has > accepted the invitation of the PMC to become a Flink committer. > > Shaoxuan has contributed several major featur

Re: [VOTE] Release Apache Flink 1.3.1 (RC2)

+1 (binding) - verified source and binary signatures - verified source and binary checksums - verified LICENSEs - verified NOTICEs - built from source Greg > On Jun 21, 2017, at 3:46 AM, Robert Metzger wrote: > > Dear Flink community, > > Please vote on releasing the following candidate as Ap

Re: [DISCUSS] FLIP-21 - Improve object Copying/Reuse Mode for Streaming Runtime

Hi Stephan, Would this be an appropriate time to discuss allowing reuse to be a per-operator configuration? Object reuse for chained operators has lead to considerable surprise for some users of the DataSet API. This came up during the rework of the object reuse documentation for the DataSet AP

Re: Switch to Scala 2.11 as a default build profile

You don't need to use the build profile in IntelliJ, just change scala.version and scala.binary.version in the parent pom (recent refactorings made this possible without changing every pom). What is the benefit for changing the default without dropping older versions when contributions are still l

Re: Tips to fix IDEA strange problem after updating master code

I’m wondering if we can remove the ILoopCompat duplication by checking and reading the trait properties with reflection … but I have not discovered how to do this. > On Jul 4, 2017, at 3:57 AM, Piotr Nowojski wrote: > > Besides deactivating “scala-2.10” profile in the Intellij it might be >

Re: [ANNOUNCE] New Flink committer Jincheng Sun

Congrats and welcome, Jincheng! > On Jul 10, 2017, at 9:17 AM, Fabian Hueske wrote: > > Hi everybody, > > On behalf of the PMC, I'm very happy to announce that Jincheng Sun has > accepted the invitation of the PMC to become a Flink committer. > > Since more than nine month, Jincheng is one of

Akka dissassociated

Hi all, I’m having some issues with Akka running on a modest cluster where increasing the parallelism results in disassociation messages. I am running a batch job, Gelly’s TriangleListing (for simplicity) which is join-based. I have not seen this issue running AdamicAdar which is sort-based. I

Re: [DISCUSS] GitBox

e, and setup 2-factor-authorization for their github > account. > > While i would love to have the gitbox functionality for the Flink repository > I don't know whether we want to > impose these requirements on all committers. > > On 21.06.2017 19:49, Robert Metzger wrote: &

Re: [DISCUSS] GitBox

the flink repo. >>> >>> The git-wip-us.apache.org repo for flink-shaded was removed when we >>> switched. >>> >>> On 18.07.2017 13:27, Greg Hogan wrote: >>>> Linking is required to commit to the ASF hosted repo as well as the GitHub >>

Re: [DISCUSS] GitBox

s doesn't appear to change anything. > > On 18.07.2017 14:37, Greg Hogan wrote: >> You are not able to push to the ASF repo? This link implies that both work >> (and identify an issue now addressed): >> https://issues.apache.org/jira/browse/INFRA-14039 >>

Re: [DISCUSS] A more thorough Pull Request check list and template

Thanks for leading this discussion, Stephan. I don’t disagree with anything that has been said but am slightly concerned that the improvements in documenting pull requests won’t translate into the git commit messages. Acceptance of a higher standard will be swift as long as reviewers set the ex

Re: [DISCUSS] Release 1.3.2 planning

FLINK-7211 is a trivial change for excluding the gelly examples javadoc from the release assembly and would be good to have fixed for 1.3.2. > On Jul 13, 2017, at 3:34 AM, Tzu-Li (Gordon) Tai wrote: > > I agree that FLINK-6951 should also be a blocker for 1.3.2. I’ll update its > priority. >

Re: Dropping Java 7 support

I recently came across FLINK-3662 when debugging TaskManager timeouts but I’d go for opening a new ticket rather than re-opening an old ticket. It does link to FLINK-2821 and some work-in-progress depending on Akka 2.4+ so Robert and others may be able to pick this back up if still relevant. ht

Re: [VOTE] Release Apache Flink-shaded 1.0 (RC1)

Is there a pressing need to get the release out quickly? This being the first release, would it be better to change the versioning now to prevent future confusion? Even if Flink is the only intended consumer we’ll still be publishing the jars. > On Jul 23, 2017, at 9:41 AM, Stephan Ewen wrote

[ANNOUNCE] New Flink PMC member: Chesnay Schepler

Developers, On behalf of the Flink PMC I am delighted to announce Chesnay Schepler as a member of the Flink PMC. Chesnay is a longtime contributor, reviewer, and committer whose breadth of work and knowledge covers nearly the entire codebase. Please join me in congratulating Chesnay and welco

Re: [VOTE] Release 1.3.2, release candidate #2

-1 The Gelly examples jar is not included in the Scala 2.11 convenience binaries since change-scala-version.sh is not switching the hard-coded Scala version from 2.10 to 2.11 in ./flink-dist/src/main/assemblies/bin.xml. The simplest fix may be to revert FLINK-7211 and simply exclude the corresp

Re: [VOTE] Release 1.3.2, release candidate #3

Thanks Aljoscha! +1 (binding) - verified source and binary signatures - verified source and binary checksums - verified LICENSEs - verified NOTICEs - built from source Greg > On Aug 4, 2017, at 2:00 AM, Aljoscha Krettek wrote: > > Hi everyone, > > Please review and vote on the release candid

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

There’s an argument for delaying this change to 1.5 since the feature freeze is two weeks away. There is little time to realize benefits from removing this code. "The reason for that is that there is a lot of code mapping between the completely different legacy format (1.1.x, not re-scalable) a

Re: [DISCUSS] Flink 1.4 and time based release

Haven’t seen much discussion here. I see the benefit of time-based deadlines but also of focussing on release functionality and stability. I like the idea to keep the structure of time-based releases but soften the deadlines. The schedule would not be open-ended but we could wait on the complet

Re: System resource logger

What if we added these as system metrics and added a way to write metrics to a (separate?) log file? > On Oct 4, 2017, at 10:13 AM, Piotr Nowojski wrote: > > Hi, > > Lately I was debugging some weird test failures on Travis and I needed to > look into metrics like: > - User, System, IOWait,

Re: [ANNOUNCE] New committer: Haohui Mai

Welcome, Haohui! > On Nov 1, 2017, at 4:14 AM, Fabian Hueske wrote: > > Hi everybody, > > On behalf of the PMC I am delighted to announce Haohui Mai as a new Flink > committer! > > Haohui has been an active member of our community for several months. > Among other things, he made major contri

Updated checkstyle version

. Greg Hogan

[jira] [Created] (FLINK-2895) Duplicate immutable object creation

Greg Hogan created FLINK-2895: - Summary: Duplicate immutable object creation Key: FLINK-2895 URL: https://issues.apache.org/jira/browse/FLINK-2895 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

Greg Hogan created FLINK-2897: - Summary: Use distinct initial indices for OutputEmitter round-robin Key: FLINK-2897 URL: https://issues.apache.org/jira/browse/FLINK-2897 Project: Flink Issue

[jira] [Created] (FLINK-2898) Invert Travis CI build order

Greg Hogan created FLINK-2898: - Summary: Invert Travis CI build order Key: FLINK-2898 URL: https://issues.apache.org/jira/browse/FLINK-2898 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2902) Web interface sort tasks newest first

Greg Hogan created FLINK-2902: - Summary: Web interface sort tasks newest first Key: FLINK-2902 URL: https://issues.apache.org/jira/browse/FLINK-2902 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2903) Web interface numeric localization

Greg Hogan created FLINK-2903: - Summary: Web interface numeric localization Key: FLINK-2903 URL: https://issues.apache.org/jira/browse/FLINK-2903 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2904) Web interface truncated task counts

Greg Hogan created FLINK-2904: - Summary: Web interface truncated task counts Key: FLINK-2904 URL: https://issues.apache.org/jira/browse/FLINK-2904 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2907) Bloom filter for Join

Greg Hogan created FLINK-2907: - Summary: Bloom filter for Join Key: FLINK-2907 URL: https://issues.apache.org/jira/browse/FLINK-2907 Project: Flink Issue Type: New Feature Components

[jira] [Created] (FLINK-2908) Web interface redraw web plan when browser resized

Greg Hogan created FLINK-2908: - Summary: Web interface redraw web plan when browser resized Key: FLINK-2908 URL: https://issues.apache.org/jira/browse/FLINK-2908 Project: Flink Issue Type

[jira] [Created] (FLINK-2909) Gelly Graph Generators

Greg Hogan created FLINK-2909: - Summary: Gelly Graph Generators Key: FLINK-2909 URL: https://issues.apache.org/jira/browse/FLINK-2909 Project: Flink Issue Type: New Feature Components

[jira] [Created] (FLINK-3160) Aggregate operator statistics by TaskManager

Greg Hogan created FLINK-3160: - Summary: Aggregate operator statistics by TaskManager Key: FLINK-3160 URL: https://issues.apache.org/jira/browse/FLINK-3160 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3161) Externalize cluster start-up and tear-down when available

Greg Hogan created FLINK-3161: - Summary: Externalize cluster start-up and tear-down when available Key: FLINK-3161 URL: https://issues.apache.org/jira/browse/FLINK-3161 Project: Flink Issue Type

[jira] [Created] (FLINK-3162) Configure number of TaskManager slots as ratio of available processors

Greg Hogan created FLINK-3162: - Summary: Configure number of TaskManager slots as ratio of available processors Key: FLINK-3162 URL: https://issues.apache.org/jira/browse/FLINK-3162 Project: Flink

[jira] [Created] (FLINK-3163) Configure Flink for NUMA systems

Greg Hogan created FLINK-3163: - Summary: Configure Flink for NUMA systems Key: FLINK-3163 URL: https://issues.apache.org/jira/browse/FLINK-3163 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3164) Spread out scheduling strategy

Greg Hogan created FLINK-3164: - Summary: Spread out scheduling strategy Key: FLINK-3164 URL: https://issues.apache.org/jira/browse/FLINK-3164 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3206) Heap size for non-pre-allocated off-heap memory

Greg Hogan created FLINK-3206: - Summary: Heap size for non-pre-allocated off-heap memory Key: FLINK-3206 URL: https://issues.apache.org/jira/browse/FLINK-3206 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3218) Merging Hadoop configurations overrides user parameters

Greg Hogan created FLINK-3218: - Summary: Merging Hadoop configurations overrides user parameters Key: FLINK-3218 URL: https://issues.apache.org/jira/browse/FLINK-3218 Project: Flink Issue Type

[jira] [Created] (FLINK-3219) Implement DataSet.count using a single operator

Greg Hogan created FLINK-3219: - Summary: Implement DataSet.count using a single operator Key: FLINK-3219 URL: https://issues.apache.org/jira/browse/FLINK-3219 Project: Flink Issue Type

[jira] [Created] (FLINK-3262) Remove fuzzy versioning from Bower dependencies

Greg Hogan created FLINK-3262: - Summary: Remove fuzzy versioning from Bower dependencies Key: FLINK-3262 URL: https://issues.apache.org/jira/browse/FLINK-3262 Project: Flink Issue Type

[jira] [Created] (FLINK-3263) Log task statistics on TaskManager

Greg Hogan created FLINK-3263: - Summary: Log task statistics on TaskManager Key: FLINK-3263 URL: https://issues.apache.org/jira/browse/FLINK-3263 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3277) Use Value types in Gelly API

Greg Hogan created FLINK-3277: - Summary: Use Value types in Gelly API Key: FLINK-3277 URL: https://issues.apache.org/jira/browse/FLINK-3277 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3279) Optionally disable DistinctOperator combiner

Greg Hogan created FLINK-3279: - Summary: Optionally disable DistinctOperator combiner Key: FLINK-3279 URL: https://issues.apache.org/jira/browse/FLINK-3279 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3335) DataSourceTask object reuse when disabled

Greg Hogan created FLINK-3335: - Summary: DataSourceTask object reuse when disabled Key: FLINK-3335 URL: https://issues.apache.org/jira/browse/FLINK-3335 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found

Greg Hogan created FLINK-3337: - Summary: mvn test fails on flink-runtime because curator classes not found Key: FLINK-3337 URL: https://issues.apache.org/jira/browse/FLINK-3337 Project: Flink

[jira] [Created] (FLINK-3340) Fix object juggling in reduce drivers

Greg Hogan created FLINK-3340: - Summary: Fix object juggling in reduce drivers Key: FLINK-3340 URL: https://issues.apache.org/jira/browse/FLINK-3340 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper

Greg Hogan created FLINK-3382: - Summary: Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper Key: FLINK-3382 URL: https://issues.apache.org/jira/browse/FLINK-3382 Project: Flink

[jira] [Created] (FLINK-3385) Fix outer join skipping unprobed partitions

Greg Hogan created FLINK-3385: - Summary: Fix outer join skipping unprobed partitions Key: FLINK-3385 URL: https://issues.apache.org/jira/browse/FLINK-3385 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3393) ExternalProcessRunner wait to finish copying error stream

Greg Hogan created FLINK-3393: - Summary: ExternalProcessRunner wait to finish copying error stream Key: FLINK-3393 URL: https://issues.apache.org/jira/browse/FLINK-3393 Project: Flink Issue Type

[jira] [Created] (FLINK-3395) Polishing the web UI

Greg Hogan created FLINK-3395: - Summary: Polishing the web UI Key: FLINK-3395 URL: https://issues.apache.org/jira/browse/FLINK-3395 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-3437) Fix UI router state for job plan

Greg Hogan created FLINK-3437: - Summary: Fix UI router state for job plan Key: FLINK-3437 URL: https://issues.apache.org/jira/browse/FLINK-3437 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3447) Package Gelly algorithms by framework

Greg Hogan created FLINK-3447: - Summary: Package Gelly algorithms by framework Key: FLINK-3447 URL: https://issues.apache.org/jira/browse/FLINK-3447 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3453) Fix TaskManager logs exception when sampling backpressure while task completes

Greg Hogan created FLINK-3453: - Summary: Fix TaskManager logs exception when sampling backpressure while task completes Key: FLINK-3453 URL: https://issues.apache.org/jira/browse/FLINK-3453 Project

[jira] [Created] (FLINK-3454) Add test dependencies on packaged jars

Greg Hogan created FLINK-3454: - Summary: Add test dependencies on packaged jars Key: FLINK-3454 URL: https://issues.apache.org/jira/browse/FLINK-3454 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke

Greg Hogan created FLINK-3467: - Summary: Remove superfluous objects from DataSourceTask.invoke Key: FLINK-3467 URL: https://issues.apache.org/jira/browse/FLINK-3467 Project: Flink Issue Type

[jira] [Created] (FLINK-3469) Fix documentation for grouping keys

Greg Hogan created FLINK-3469: - Summary: Fix documentation for grouping keys Key: FLINK-3469 URL: https://issues.apache.org/jira/browse/FLINK-3469 Project: Flink Issue Type: Bug

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

Greg Hogan created FLINK-3589: - Summary: Allow setting Operator parallelism to default value Key: FLINK-3589 URL: https://issues.apache.org/jira/browse/FLINK-3589 Project: Flink Issue Type

[jira] [Created] (FLINK-3634) Fix documentation for DataSetUtils.zipWithUniqueId()

Greg Hogan created FLINK-3634: - Summary: Fix documentation for DataSetUtils.zipWithUniqueId() Key: FLINK-3634 URL: https://issues.apache.org/jira/browse/FLINK-3634 Project: Flink Issue Type

[jira] [Created] (FLINK-3623) Adjust MurmurHash algorithm

Greg Hogan created FLINK-3623: - Summary: Adjust MurmurHash algorithm Key: FLINK-3623 URL: https://issues.apache.org/jira/browse/FLINK-3623 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3625) Graph algorithms to permute graph labels and edges

Greg Hogan created FLINK-3625: - Summary: Graph algorithms to permute graph labels and edges Key: FLINK-3625 URL: https://issues.apache.org/jira/browse/FLINK-3625 Project: Flink Issue Type: New

[jira] [Created] (FLINK-3695) ValueArray types

Greg Hogan created FLINK-3695: - Summary: ValueArray types Key: FLINK-3695 URL: https://issues.apache.org/jira/browse/FLINK-3695 Project: Flink Issue Type: New Feature Components: Core

[jira] [Created] (FLINK-3721) Min and max accumulators

Greg Hogan created FLINK-3721: - Summary: Min and max accumulators Key: FLINK-3721 URL: https://issues.apache.org/jira/browse/FLINK-3721 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3768) Clustering Coefficient

Greg Hogan created FLINK-3768: - Summary: Clustering Coefficient Key: FLINK-3768 URL: https://issues.apache.org/jira/browse/FLINK-3768 Project: Flink Issue Type: New Feature Components

[jira] [Created] (FLINK-3770) Fix TriangleEnumerator performance

Greg Hogan created FLINK-3770: - Summary: Fix TriangleEnumerator performance Key: FLINK-3770 URL: https://issues.apache.org/jira/browse/FLINK-3770 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3771) Methods for translating Graphs

Greg Hogan created FLINK-3771: - Summary: Methods for translating Graphs Key: FLINK-3771 URL: https://issues.apache.org/jira/browse/FLINK-3771 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3772) Graph algorithms for vertex and edge degree

Greg Hogan created FLINK-3772: - Summary: Graph algorithms for vertex and edge degree Key: FLINK-3772 URL: https://issues.apache.org/jira/browse/FLINK-3772 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3780) Jaccard Similarity

Greg Hogan created FLINK-3780: - Summary: Jaccard Similarity Key: FLINK-3780 URL: https://issues.apache.org/jira/browse/FLINK-3780 Project: Flink Issue Type: New Feature Components

[jira] [Created] (FLINK-3789) Overload methods which trigger program execution to allow naming job

Greg Hogan created FLINK-3789: - Summary: Overload methods which trigger program execution to allow naming job Key: FLINK-3789 URL: https://issues.apache.org/jira/browse/FLINK-3789 Project: Flink

<    1   2   3   4   >