summary |
shortlog | log |
commit |
commitdiff |
tree
first ⋅ prev ⋅ next
Nico Kruber [Fri, 22 Apr 2022 09:42:09 +0000 (11:42 +0200)]
[FLINK-27353] Update to Flink 1.15
T.C [Fri, 22 Apr 2022 09:09:26 +0000 (17:09 +0800)]
[FLINK-26382] Add Chinese documents for flink-training exercises (#46)
Co-authored-by: Victor Xu <victor.unique@gmail.com>
Co-authored-by: Nico Kruber <nico@ververica.com>
Nico Kruber [Wed, 20 Apr 2022 10:31:38 +0000 (12:31 +0200)]
[FLINK-27322][gradle] spotless apply (adding license headers)
Nico Kruber [Wed, 20 Apr 2022 10:24:39 +0000 (12:24 +0200)]
[FLINK-27322][gradle] add spotless license header checks for *.md, *.gradle, and Java files
Nico Kruber [Wed, 20 Apr 2022 10:23:11 +0000 (12:23 +0200)]
[FLINK-27322][gradle] update spotless plugin and format scala headers with a blank line after the license
The previous version of the plugin didn't support this style of formatting.
Now, we are more in line with the Java formatting.
Nico Kruber [Wed, 20 Apr 2022 10:51:17 +0000 (12:51 +0200)]
fixup! [FLINK-25313] Enable flink runtime web-ui (#45)
Junfan Zhang [Wed, 20 Apr 2022 10:47:07 +0000 (18:47 +0800)]
[FLINK-25313] Enable flink runtime web-ui (#45)
* [FLINK-25313] Enable flink runtime web-ui when running in the IDE
With this, when running Flink applications locally, you can browse Flink's web UI to see more details.
Co-authored-by: Junfan Zhang <zhangjunfan@qiyi.com>
sjwiesman [Thu, 4 Nov 2021 22:58:36 +0000 (17:58 -0500)]
[FLINK-24782] Upgrade training exercises to 1.14
This closes #42
Ali Bahadir Zeybek [Thu, 21 Oct 2021 13:56:30 +0000 (15:56 +0200)]
[hotfix] Fix links to old documentation
Pengcheng Huang [Sat, 6 Nov 2021 14:54:48 +0000 (22:54 +0800)]
[hotfix] update aliyun mirror repo url
Co-authored-by: gnuhpc <gnuhpc@gmail.com>
Nico Kruber [Mon, 4 Oct 2021 11:29:19 +0000 (13:29 +0200)]
[hotfix] remove extraneous files for non-existing modules
David Anderson [Fri, 3 Sep 2021 14:36:41 +0000 (08:36 -0600)]
[FLINK-24118] Allow TaxiFareGenerator to produce bounded streams (#40)
David Anderson [Wed, 1 Sep 2021 16:19:28 +0000 (10:19 -0600)]
[hotfix] collect rather than collectWithTimestamp
David Anderson [Thu, 2 Sep 2021 16:16:33 +0000 (10:16 -0600)]
[FLINK-23926] replace startTime and endTime with a single eventTime field
Nico Kruber [Wed, 1 Sep 2021 20:22:01 +0000 (22:22 +0200)]
[hotfix] trim whitespace before checking enable_scala
Nico Kruber [Wed, 1 Sep 2021 08:28:46 +0000 (10:28 +0200)]
[hotfix][CI] also verify tests with Scala disabled (default)
David Anderson [Wed, 1 Sep 2021 01:48:49 +0000 (19:48 -0600)]
[hotfix] test imports wrong solution class
David Anderson [Wed, 1 Sep 2021 01:46:50 +0000 (19:46 -0600)]
[hotfix] update flink version to 1.13.2
Nico Kruber [Fri, 6 Aug 2021 13:29:48 +0000 (15:29 +0200)]
[DO-NOT-MERGE][FLINK-23670] Add refactoring commit to .git-blame-ignore-revs
This file can be used to ignore refactoring commits via:
$ git config blame.ignoreRevsFile .git-blame-ignore-revs
This closes #34.
Rufus Refactor [Tue, 31 Aug 2021 16:17:17 +0000 (18:17 +0200)]
[FLINK-23670] Format Scala code with Spotless/scalafmt
Nico Kruber [Fri, 6 Aug 2021 12:08:18 +0000 (14:08 +0200)]
[FLINK-23670] add Scala checks using scalafmt via spotless
The format is slightly different because scamafmt cannot express everything
Flink uses in its scalastyle but it focuses on other things.
We get automatic formatting from spotless though!
David Anderson [Tue, 31 Aug 2021 14:05:16 +0000 (08:05 -0600)]
[FLINK-23653] exercise and test rework (#31)
* rename TaxiRideTestBase
* fix grammar in comment
* Add flink-test-utils and assertj-core
* Rework how the Long Rides exercise and solution are tested
* Update the README and DISCUSSION pages for the long rides exercise.
* Add test harness dependencies
* Make a few things public to make it easier to add test harness tests
* Add a test harness test as an example
* replace recursion with iteration
Co-authored-by: Nico Kruber <nico.kruber@gmail.com>
* cleaner iteration
Co-authored-by: Nico Kruber <nico.kruber@gmail.com>
* remove unnecessary type information
Co-authored-by: Nico Kruber <nico.kruber@gmail.com>
* Address review comments
* Rename longrides test classes
* remove more unnecessary type information
* apply spotless
* Apply suggestions from code review
Co-authored-by: Nico Kruber <nico.kruber@gmail.com>
* Rework the test sink to use an accumulator rather than a static list
* adjust javadoc
* Rework the exercises, solutions, and tests for the Rides and Fares exercise
* Apply suggestions from code review of rides-and-fares
Co-authored-by: Nico Kruber <nico.kruber@gmail.com>
* more complete implementations of equals and hashcode for taxiride and taxifare
* Redo the tests for rides-and-fares and include unit tests
* Update the exercise, solutions, and tests for the ride cleansing exercise
* Rework the hourly tips exercise
* Remove the remaining pieces of the legacy testing framework
* Change the sources to no longer include timestamps or watermarks
* Added a comment to explain the hourly tips Scala tests
* clean up long rides tests to avoid using raw types and unchecked operations
* Remove ExerciseBase
* Upgrade flink to 1.13.2
* Upgrade junit to 4.13
* Drop hamcrest
* remove checkpointing code from RidesAndFaresExercise.java
* Revert "Upgrade flink to 1.13.2"
This reverts commit
07e0776c9b28c27daa071df818c88d7af90379e2.
* simplify ComposedKeyedProcessFunction and ComposedRichCoFlatMapFunction
* clean up HourlyTipsExercise
* fixup HourlyTipsTest
* fixup tests
Co-authored-by: Nico Kruber <nico.kruber@gmail.com>
Nico Kruber [Fri, 27 Aug 2021 10:23:50 +0000 (12:23 +0200)]
[FLINK-24022] Change how to enable Scala and use in CI
Nico Kruber [Fri, 6 Aug 2021 11:55:45 +0000 (13:55 +0200)]
[FLINK-23669] avoid using Scala >= 2.12.8 when setting up an IDE
Nico Kruber [Fri, 6 Aug 2021 11:52:55 +0000 (13:52 +0200)]
[FLINK-23667] fix code formatting IDE instructions
google-java-format should only be applied to Java files.
Daisy T [Wed, 21 Jul 2021 10:12:28 +0000 (12:12 +0200)]
[FLINK-23448] update README
This closes #30
Nico Kruber [Fri, 16 Jul 2021 07:30:06 +0000 (09:30 +0200)]
[hotfix] fix formatting error for spotless
Nico Kruber [Fri, 9 Jul 2021 12:42:27 +0000 (14:42 +0200)]
[FLINK-23340] add more dev setup instructions
Nico Kruber [Fri, 9 Jul 2021 12:42:12 +0000 (14:42 +0200)]
[hotfix] minor improvements to the README
Nico Kruber [Tue, 13 Jul 2021 20:28:39 +0000 (22:28 +0200)]
[FLINK-23339] Make scala plugin optional
Nico Kruber [Fri, 2 Jul 2021 15:46:10 +0000 (17:46 +0200)]
[FLINK-23338] Add .git-blame-ignore-revs for ignoring refactor commit
This file can be used via:
$ git config blame.ignoreRevsFile .git-blame-ignore-revs
This closes #27.
Rufus Refactor [Tue, 13 Jul 2021 19:45:34 +0000 (21:45 +0200)]
[FLINK-23338] Format code with Spotless/google-java-format
Nico Kruber [Fri, 2 Jul 2021 15:36:31 +0000 (17:36 +0200)]
[FLINK-23338] Add Spotless plugin with Google AOSP style
Use the same format as defined by the main Flink project.
See https://issues.apache.org/jira/browse/FLINK-20651
Nico Kruber [Fri, 2 Jul 2021 13:43:13 +0000 (15:43 +0200)]
[FLINK-23335][gradle] add separate run tasks for Java/Scala exercises and solutions
This allows to quickly run the current state of the exercise or the solution
implementation from the command line / IDE.
Nico Kruber [Fri, 2 Jul 2021 15:10:03 +0000 (17:10 +0200)]
[FLINK-23337][gradle] Properly use the 'shadow' plugin
This removes the need for the custom `flinkShadowJar` configuration and instead
defines dependencies with the default ways that the 'shadow' plugin offers.
Nico Kruber [Fri, 2 Jul 2021 09:42:41 +0000 (11:42 +0200)]
[FLINK-23336][log4j] update Log4J to 2.12.1 as used by Flink 1.13
Nico Kruber [Fri, 2 Jul 2021 09:37:19 +0000 (11:37 +0200)]
[FLINK-23334][gradle] let the subprojects decide whether they implement an application
This gives a cleaner gradle project file layout.
Nico Kruber [Fri, 2 Jul 2021 09:36:27 +0000 (11:36 +0200)]
[hotfix][gradle] set project properties in a central place
Also, we actually only have the root project's description, so let's not set
it for all subprojects!
Nico Kruber [Fri, 2 Jul 2021 09:17:24 +0000 (11:17 +0200)]
[hotfix][gradle] update build-scan plugin version
Nico Kruber [Fri, 2 Jul 2021 09:09:02 +0000 (11:09 +0200)]
[FLINK-23332][gradle] update Gradle version
This also requires a newer 'shadow' version.
David Anderson [Thu, 3 Jun 2021 14:11:41 +0000 (16:11 +0200)]
[FLINK-22868] Update to use Flink 1.13.1
Tomas [Tue, 9 Feb 2021 08:55:25 +0000 (09:55 +0100)]
[hotfix] updated READMEs
* typo
* link to generators added
* Update ride-cleansing/README.md
Co-authored-by: David Anderson <david@alpinegizmo.com>
* deleted part about data downloading
Co-authored-by: David Anderson <david@alpinegizmo.com>
Svend Vanderveken [Sat, 16 Jan 2021 15:21:30 +0000 (16:21 +0100)]
[FLINK-20597] update for Flink 1.12
removed TimeCharacteristic, as it has been deprecated
David Anderson [Wed, 9 Sep 2020 12:46:02 +0000 (14:46 +0200)]
[hotfix] output examples in HourlyTips discussion should match actual output (#14)
David Anderson [Tue, 25 Aug 2020 17:49:55 +0000 (19:49 +0200)]
[FLINK-18630] Redo the LongRideAlerts solutions to cover a corner case (#13)
David Anderson [Thu, 2 Jul 2020 21:13:08 +0000 (23:13 +0200)]
[FLINK-18482] Replace file-based data sources with generators
This closes #11
David Anderson [Wed, 8 Jul 2020 15:25:44 +0000 (17:25 +0200)]
[FLINK-18499] Update for Flink 1.11: don’t use deprecated flavors of keyBy
This closes #12
Nico Kruber [Mon, 8 Jun 2020 12:05:56 +0000 (14:05 +0200)]
[FLINK-18178][build] fix Eclipse import not using flinkShadowJar dependencies
Nico Kruber [Mon, 8 Jun 2020 10:33:37 +0000 (12:33 +0200)]
[hotfix][training] git-ignore eclipse build files
David Anderson [Mon, 8 Jun 2020 10:31:46 +0000 (12:31 +0200)]
[hotfix] use correct main class references
David Anderson [Wed, 22 Apr 2020 06:47:29 +0000 (08:47 +0200)]
[FLINK-17316][docs-training-exercises] avoid using windows that depend on the time characteristic
Nico Kruber [Tue, 21 Apr 2020 20:32:14 +0000 (22:32 +0200)]
[hotfix] two description updates
Nico Kruber [Mon, 20 Apr 2020 12:05:32 +0000 (14:05 +0200)]
[FLINK-17279][travis] enable build scans
(accept license only on Travis)
Nico Kruber [Mon, 20 Apr 2020 10:03:48 +0000 (12:03 +0200)]
[FLINK-17278][travis] add Travis configuration
Nico Kruber [Sat, 18 Apr 2020 20:41:51 +0000 (22:41 +0200)]
[FLINK-17277] address IntelliJ warnings
Nico Kruber [Mon, 20 Apr 2020 10:47:49 +0000 (12:47 +0200)]
[FLINK-17276][checkstyle] add definitions from Flink and enforce them
- minor changes to the checkstyle profile were needed to cope with the newer
version we have here
Nico Kruber [Mon, 20 Apr 2020 10:47:03 +0000 (12:47 +0200)]
[FLINK-17275] port core training exercises, descriptions, solutions and tests
- use gradle build tooling
- add descriptions in appropriate markdown files (rendered with links to
navigate on github)
Chesnay Schepler [Tue, 21 Apr 2020 08:14:30 +0000 (10:14 +0200)]
[FLINK-17287][github] Disable merge commit button
Nico Kruber [Wed, 15 Apr 2020 17:30:00 +0000 (19:30 +0200)]
initalize repository