flink-training.git
5 months ago[FLINK-27353] Update to Flink 1.15 master release-1.15
Nico Kruber [Fri, 22 Apr 2022 09:42:09 +0000 (11:42 +0200)] 
[FLINK-27353] Update to Flink 1.15

5 months ago[FLINK-26382] Add Chinese documents for flink-training exercises (#46)
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>
5 months ago[FLINK-27322][gradle] spotless apply (adding license headers)
Nico Kruber [Wed, 20 Apr 2022 10:31:38 +0000 (12:31 +0200)] 
[FLINK-27322][gradle] spotless apply (adding license headers)

5 months ago[FLINK-27322][gradle] add spotless license header checks for *.md, *.gradle, and...
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

5 months ago[FLINK-27322][gradle] update spotless plugin and format scala headers with a blank...
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.

5 months agofixup! [FLINK-25313] Enable flink runtime web-ui (#45)
Nico Kruber [Wed, 20 Apr 2022 10:51:17 +0000 (12:51 +0200)] 
fixup! [FLINK-25313] Enable flink runtime web-ui (#45)

5 months ago[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>
10 months ago[FLINK-24782] Upgrade training exercises to 1.14
sjwiesman [Thu, 4 Nov 2021 22:58:36 +0000 (17:58 -0500)] 
[FLINK-24782] Upgrade training exercises to 1.14

This closes #42

10 months ago[hotfix] Fix links to old documentation
Ali Bahadir Zeybek [Thu, 21 Oct 2021 13:56:30 +0000 (15:56 +0200)] 
[hotfix] Fix links to old documentation

10 months ago[hotfix] update aliyun mirror repo url
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>
12 months ago[hotfix] remove extraneous files for non-existing modules
Nico Kruber [Mon, 4 Oct 2021 11:29:19 +0000 (13:29 +0200)] 
[hotfix] remove extraneous files for non-existing modules

13 months ago[FLINK-24118] Allow TaxiFareGenerator to produce bounded streams (#40)
David Anderson [Fri, 3 Sep 2021 14:36:41 +0000 (08:36 -0600)] 
[FLINK-24118] Allow TaxiFareGenerator to produce bounded streams (#40)

13 months ago[hotfix] collect rather than collectWithTimestamp
David Anderson [Wed, 1 Sep 2021 16:19:28 +0000 (10:19 -0600)] 
[hotfix] collect rather than collectWithTimestamp

13 months ago[FLINK-23926] replace startTime and endTime with a single eventTime field
David Anderson [Thu, 2 Sep 2021 16:16:33 +0000 (10:16 -0600)] 
[FLINK-23926] replace startTime and endTime with a single eventTime field

13 months ago[hotfix] trim whitespace before checking enable_scala
Nico Kruber [Wed, 1 Sep 2021 20:22:01 +0000 (22:22 +0200)] 
[hotfix] trim whitespace before checking enable_scala

13 months ago[hotfix][CI] also verify tests with Scala disabled (default)
Nico Kruber [Wed, 1 Sep 2021 08:28:46 +0000 (10:28 +0200)] 
[hotfix][CI] also verify tests with Scala disabled (default)

13 months ago[hotfix] test imports wrong solution class
David Anderson [Wed, 1 Sep 2021 01:48:49 +0000 (19:48 -0600)] 
[hotfix] test imports wrong solution class

13 months ago[hotfix] update flink version to 1.13.2
David Anderson [Wed, 1 Sep 2021 01:46:50 +0000 (19:46 -0600)] 
[hotfix] update flink version to 1.13.2

13 months ago[DO-NOT-MERGE][FLINK-23670] Add refactoring commit to .git-blame-ignore-revs 34/head
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.

13 months ago[FLINK-23670] Format Scala code with Spotless/scalafmt
Rufus Refactor [Tue, 31 Aug 2021 16:17:17 +0000 (18:17 +0200)] 
[FLINK-23670] Format Scala code with Spotless/scalafmt

13 months ago[FLINK-23670] add Scala checks using scalafmt via spotless
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!

13 months ago[FLINK-23653] exercise and test rework (#31)
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>
13 months ago[FLINK-24022] Change how to enable Scala and use in CI
Nico Kruber [Fri, 27 Aug 2021 10:23:50 +0000 (12:23 +0200)] 
[FLINK-24022] Change how to enable Scala and use in CI

14 months ago[FLINK-23669] avoid using Scala >= 2.12.8 when setting up an IDE
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

14 months ago[FLINK-23667] fix code formatting IDE instructions
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.

14 months ago[FLINK-23448] update README
Daisy T [Wed, 21 Jul 2021 10:12:28 +0000 (12:12 +0200)] 
[FLINK-23448] update README

This closes #30

14 months ago[hotfix] fix formatting error for spotless
Nico Kruber [Fri, 16 Jul 2021 07:30:06 +0000 (09:30 +0200)] 
[hotfix] fix formatting error for spotless

14 months ago[FLINK-23340] add more dev setup instructions
Nico Kruber [Fri, 9 Jul 2021 12:42:27 +0000 (14:42 +0200)] 
[FLINK-23340] add more dev setup instructions

14 months ago[hotfix] minor improvements to the README
Nico Kruber [Fri, 9 Jul 2021 12:42:12 +0000 (14:42 +0200)] 
[hotfix] minor improvements to the README

14 months ago[FLINK-23339] Make scala plugin optional
Nico Kruber [Tue, 13 Jul 2021 20:28:39 +0000 (22:28 +0200)] 
[FLINK-23339] Make scala plugin optional

14 months ago[FLINK-23338] Add .git-blame-ignore-revs for ignoring refactor commit
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.

14 months ago[FLINK-23338] Format code with Spotless/google-java-format
Rufus Refactor [Tue, 13 Jul 2021 19:45:34 +0000 (21:45 +0200)] 
[FLINK-23338] Format code with Spotless/google-java-format

14 months ago[FLINK-23338] Add Spotless plugin with Google AOSP style
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

14 months ago[FLINK-23335][gradle] add separate run tasks for Java/Scala exercises and solutions
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.

14 months ago[FLINK-23337][gradle] Properly use the 'shadow' plugin
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.

14 months ago[FLINK-23336][log4j] update Log4J to 2.12.1 as used by Flink 1.13
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

14 months ago[FLINK-23334][gradle] let the subprojects decide whether they implement an application
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.

14 months ago[hotfix][gradle] set project properties in a central place
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!

14 months ago[hotfix][gradle] update build-scan plugin version
Nico Kruber [Fri, 2 Jul 2021 09:17:24 +0000 (11:17 +0200)] 
[hotfix][gradle] update build-scan plugin version

14 months ago[FLINK-23332][gradle] update Gradle 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.

16 months ago[FLINK-22868] Update to use Flink 1.13.1 release-1.13 19/head
David Anderson [Thu, 3 Jun 2021 14:11:41 +0000 (16:11 +0200)] 
[FLINK-22868] Update to use Flink 1.13.1

19 months ago[hotfix] updated READMEs
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>
20 months ago[FLINK-20597] update for Flink 1.12 release-1.12
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

2 years ago[hotfix] output examples in HourlyTips discussion should match actual output (#14)
David Anderson [Wed, 9 Sep 2020 12:46:02 +0000 (14:46 +0200)] 
[hotfix] output examples in HourlyTips discussion should match actual output (#14)

2 years ago[FLINK-18630] Redo the LongRideAlerts solutions to cover a corner case (#13) release-1.11
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)

2 years ago[FLINK-18482] Replace file-based data sources with generators
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

2 years ago[FLINK-18499] Update for Flink 1.11: don’t use deprecated flavors of keyBy
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

2 years ago[FLINK-18178][build] fix Eclipse import not using flinkShadowJar dependencies
Nico Kruber [Mon, 8 Jun 2020 12:05:56 +0000 (14:05 +0200)] 
[FLINK-18178][build] fix Eclipse import not using flinkShadowJar dependencies

2 years ago[hotfix][training] git-ignore eclipse build files
Nico Kruber [Mon, 8 Jun 2020 10:33:37 +0000 (12:33 +0200)] 
[hotfix][training] git-ignore eclipse build files

2 years ago[hotfix] use correct main class references
David Anderson [Mon, 8 Jun 2020 10:31:46 +0000 (12:31 +0200)] 
[hotfix] use correct main class references

2 years ago[FLINK-17316][docs-training-exercises] avoid using windows that depend on the time...
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

2 years ago[hotfix] two description updates
Nico Kruber [Tue, 21 Apr 2020 20:32:14 +0000 (22:32 +0200)] 
[hotfix] two description updates

2 years ago[FLINK-17279][travis] enable build scans
Nico Kruber [Mon, 20 Apr 2020 12:05:32 +0000 (14:05 +0200)] 
[FLINK-17279][travis] enable build scans

(accept license only on Travis)

2 years ago[FLINK-17278][travis] add Travis configuration
Nico Kruber [Mon, 20 Apr 2020 10:03:48 +0000 (12:03 +0200)] 
[FLINK-17278][travis] add Travis configuration

2 years ago[FLINK-17277] address IntelliJ warnings
Nico Kruber [Sat, 18 Apr 2020 20:41:51 +0000 (22:41 +0200)] 
[FLINK-17277] address IntelliJ warnings

2 years ago[FLINK-17276][checkstyle] add definitions from Flink and enforce them
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

2 years ago[FLINK-17275] port core training exercises, descriptions, solutions and tests
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)

2 years ago[FLINK-17287][github] Disable merge commit button
Chesnay Schepler [Tue, 21 Apr 2020 08:14:30 +0000 (10:14 +0200)] 
[FLINK-17287][github] Disable merge commit button

2 years agoinitalize repository
Nico Kruber [Wed, 15 Apr 2020 17:30:00 +0000 (19:30 +0200)] 
initalize repository