Re: flink-shaded-hadoop modules disconnected from parent pom

Hi Nick, I think the reason is to set some common settings for all flink shaded hadoop child modules in flink-shaded-hadoop if I’m not mistaken. But this might also be a historic artifact. Cheers, Till ​ On Fri, Jan 15, 2016 at 12:48 AM, Nick Dimiduk wrote: > Hi folks, > >

[jira] [Created] (FLINK-3241) Scala 2.11 Flink binaries pull in Scala 2.10 dependencies

Till Rohrmann created FLINK-3241: Summary: Scala 2.11 Flink binaries pull in Scala 2.10 dependencies Key: FLINK-3241 URL: https://issues.apache.org/jira/browse/FLINK-3241 Project: Flink

[jira] [Created] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled

Aljoscha Krettek created FLINK-3242: --- Summary: User-specified StateBackend is not Respected if Checkpointing is Disabled Key: FLINK-3242 URL: https://issues.apache.org/jira/browse/FLINK-3242

Re: FileNotFoundException thrown by BlobCache when running "mvn test" against flink-runtime 0.10 for Scala 2.11

Hi! I cannot access the gist. There are some tests that check proper error reporting in that case. Let's make sure there is nothing funky in the sense that this occurs also outside where this is tested for and goes unrecognized by the tests. Can you share more of the log? Thanks, Stephan On

Re: [DISCUSS] Remove Combinable Annotation from DataSet API

OK, I think we got a clear picture here. I'll update the corresponding JIRA issue FLINK-1045. Thanks, Fabian 2016-01-14 18:53 GMT+01:00 Henry Saputra : > +1 for approach #1 > > > > - Henry > > On Thu, Jan 14, 2016 at 5:35 AM, Chiwan Park >

Re: [DISCUSS] Git force pushing and deletion of branchs

+1 for a protected master. +1 for creating release tags under rel/. On Thu, Jan 14, 2016 at 10:07 AM, Chiwan Park wrote: > +1 for protecting all branches including master. > >> On Jan 14, 2016, at 1:20 AM, Aljoscha Krettek wrote: >> >> +1 on

Re: FileNotFoundException thrown by BlobCache when running "mvn test" against flink-runtime 0.10 for Scala 2.11

I’ve included the full log of a test run against flink-runtime here: https://gist.github.com/revprez/9d38749f6672d1bef9f1 Specific issue observed starts at 691, but you’ll see exceptions both before and after. As per Metzger's

Re: Release tag for 0.10.1

Hi Nick, That was an oversight when the release was created. As Stephan mentioned, we have a policy that the corresponding final release branch is read-only. Creating the tag is just a formality but of course important. I've pushed a 'release-0.10.1' release tag. The corresponding hash is

Re: Old Flink Graph Repository

Sounds good. Do you have push rights there to do that? On Fri, Jan 15, 2016 at 3:51 PM, Vasiliki Kalavri wrote: > Hey, > > we can delete the content, but I wouldn't remove the repository. > In the early Gelly days we shared the link of this repository in several >

Re: FileNotFoundException thrown by BlobCache when running "mvn test" against flink-runtime 0.10 for Scala 2.11

Recreated it here. https://gist.github.com/revprez/2e5d7b38a1b5fe1d704f Prez Cannady p: 617 500 3378 e: revp...@opencorrelate.org GH: https://github.com/opencorrelate

[jira] [Created] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

Aljoscha Krettek created FLINK-3243: --- Summary: Fix Interplay of TimeCharacteristic and Time Windows Key: FLINK-3243 URL: https://issues.apache.org/jira/browse/FLINK-3243 Project: Flink

Re: Release tag for 0.10.1

Thanks Max. I'm accustomed to projects advertising a release with a fixed ref such as a sha or tag, not a branch. Much obliged. -n On Friday, January 15, 2016, Maximilian Michels wrote: > Hi Nick, > > That was an oversight when the release was created. As Stephan > mentioned,

Re: Old Flink Graph Repository

I believe I do! On 15 January 2016 at 16:20, Stephan Ewen wrote: > Sounds good. Do you have push rights there to do that? > > On Fri, Jan 15, 2016 at 3:51 PM, Vasiliki Kalavri < > vasilikikala...@gmail.com > > wrote: > > > Hey, > > > > we can delete the content, but I wouldn't

[jira] [Created] (FLINK-3244) Add log messages to savepoint coordinator restore

Ufuk Celebi created FLINK-3244: -- Summary: Add log messages to savepoint coordinator restore Key: FLINK-3244 URL: https://issues.apache.org/jira/browse/FLINK-3244 Project: Flink Issue Type:

web-dashboard Bower dependencies

Happy Friday, I am looking to submit a pull request for FLINK-3160 which updates files in flink-runtime-web. What is the proper way to handle updated dependencies from bower.json? For example, bootstrap is specified with version "~3.3.5" which permits the patch update to 3.3.6. When I run `npm

[jira] [Created] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow()

Matthias J. Sax created FLINK-3238: -- Summary: EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow() Key: FLINK-3238 URL: https://issues.apache.org/jira/browse/FLINK-3238 Project: Flink

[jira] [Created] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

Niels Basjes created FLINK-3239: --- Summary: Support for Kerberos enabled Kafka 0.9.0.0 Key: FLINK-3239 URL: https://issues.apache.org/jira/browse/FLINK-3239 Project: Flink Issue Type: New

Re: 答复: Effort to add SQL / StreamSQL to Flink

Hi everybody, as previously announced, I pushed a feature branch called "tableOnCalcite" to the Flink repository. We will use this branch to work on FLINK-3221 and its sub-issues. Cheers, Fabian 2016-01-11 18:29 GMT+01:00 Fabian Hueske : > We haven't defined the StreamSQL