5a775c8 | Till Rohrmann | 19 November 2018, 21:40:52 UTC | Commit for release 1.7.0 | 19 November 2018, 21:40:52 UTC |
84cad5b | Till Rohrmann | 19 November 2018, 20:03:13 UTC | [FLINK-10922] Exclude transitive kafka-clients dependency from base flink-connector-kafka In order to satisfy dependency convergence we need to exclude the kafka-clients from the base flink-connector-kafka-x dependency in every flink-connector-kafka-y module. | 19 November 2018, 21:35:54 UTC |
b992afa | Till Rohrmann | 19 November 2018, 15:57:12 UTC | [FLINK-10922] Remove Scala Kafka010Example from flink-end-to-end-tests This commit removes the Scala based Kafka010Example from flink-end-to-end-tests/ flink-streaming-kafka010-test module. Moreover, it adds relative paths to their parent pom's and cleans up the flink-streaming-kafka*/pom.xml. | 19 November 2018, 21:35:54 UTC |
8c1bee6 | yanghua | 19 November 2018, 12:13:29 UTC | [FLINK-10922] Refactor the placement of the Flink Kafka connector end to end test module | 19 November 2018, 21:35:54 UTC |
65ef428 | Stephan Ewen | 19 November 2018, 20:42:37 UTC | [FLINK-10893] [tests] Export S3 credentials properly for test scripts | 19 November 2018, 20:44:32 UTC |
5d77007 | Dawid Wysakowicz | 19 November 2018, 16:43:39 UTC | [FLINK-8997] Added sliding window aggregation to datastream test job | 19 November 2018, 16:45:07 UTC |
571faf4 | Dawid Wysakowicz | 09 November 2018, 13:58:38 UTC | [FLINK-10481][e2e] Added retry logic for building docker image | 19 November 2018, 16:38:06 UTC |
76974bd | Xpray | 24 October 2018, 16:02:13 UTC | [FLINK-10670] [table] Fix Correlate codegen error This closes #6923. | 19 November 2018, 13:45:34 UTC |
96e790a | kkolman | 19 November 2018, 10:11:14 UTC | [FLINK-10925][py] Check for null when closing socket | 19 November 2018, 10:18:13 UTC |
3c1f14e | Mododo | 19 November 2018, 07:36:32 UTC | [FLINK-10916][streaming] Include duplicated user-specified uid in error message | 19 November 2018, 07:36:32 UTC |
ab86d5d | David Anderson | 16 November 2018, 10:49:33 UTC | [FLINK-10625] [docs] Polishing MATCH_RECOGNIZE document | 18 November 2018, 13:29:43 UTC |
0642814 | Timo Walther | 14 November 2018, 11:50:09 UTC | [FLINK-10625] [docs] Improvements to the MATCH_RECOGNIZE documentation | 18 November 2018, 13:29:35 UTC |
d61f3bc | Dawid Wysakowicz | 09 November 2018, 11:40:21 UTC | [FLINK-10625] [docs] Documentation for MATCH_RECOGNIZE clause | 18 November 2018, 13:29:10 UTC |
ef683c3 | Till Rohrmann | 16 November 2018, 17:32:21 UTC | [FLINK-10880] Add release notes warning to not use Flink's failover strategies | 17 November 2018, 19:51:08 UTC |
63d3883 | Till Rohrmann | 16 November 2018, 16:53:22 UTC | [FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation This commit excludes the JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from Flink's configuration documentation. | 17 November 2018, 19:51:08 UTC |
ac30938 | Till Rohrmann | 16 November 2018, 16:47:45 UTC | [FLINK-10880] Add Documentation.ExcludeFromDocumentation to exclude ConfigOptions from documentation The annotation Documentation.ExcludeFromDocumentation can be used to annotate ConfigOptions with in order to not include them in the documentation. | 17 November 2018, 19:51:08 UTC |
1b8b7ae | Till Rohrmann | 17 November 2018, 10:42:42 UTC | [FLINK-10913] Harden ExecutionGraphRestartTest#testRestartAutomatically Wait until all Executions reach the state DEPLOYING instead of having a resource assigned. | 17 November 2018, 10:44:45 UTC |
1acf5ee | Till Rohrmann | 16 November 2018, 15:38:55 UTC | [FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh In order to not leak secrets we should not print the configuration in docker-entrypoint.sh. | 17 November 2018, 10:03:55 UTC |
db9b538 | Andrey Zagrebin | 16 November 2018, 17:04:24 UTC | [FLINK-10736] [tests] Use staticly hosted test data for S3 wordcount tests This avoids issues with eventual consistency/visibility on S3. | 16 November 2018, 20:14:17 UTC |
fad09e4 | Stephan Ewen | 15 November 2018, 20:30:31 UTC | [hotfix] [tests] Simplify and speed up S3 filesystem tests Rather then reinitializing the S3 file system in each test, use one file system across tests. This reduces code and speeds up the test. | 16 November 2018, 20:14:16 UTC |
f3dc54c | Stephan Ewen | 15 November 2018, 20:17:13 UTC | [hotfix] [tests] Check for s3a and s3 schemes in a unit test This avoid duplicating the very expensive and time consuming execution of the S3 file system integration tests. The scheme is an artifact purely of the factory with no need to test it in an integration test of the actual file system. | 16 November 2018, 20:14:16 UTC |
44e6061 | Stephan Ewen | 15 November 2018, 19:49:04 UTC | [hotfix] [tests] Make S3 config key forwarding a proper unit test This avoids unnecessary and expensive connections to S3 just to validate whether config keys of various formats are forwarded. | 16 November 2018, 20:14:16 UTC |
376cc22 | Stephan Ewen | 15 November 2018, 16:05:16 UTC | [hotfix] [s3] Minor fixes/code simplifications in S3 recoverable writer | 16 November 2018, 20:14:16 UTC |
6abd87b | Stephan Ewen | 13 November 2018, 17:21:04 UTC | [hotfix] [tests] Make S3 Recoverable Writer tests ITCases | 16 November 2018, 20:14:16 UTC |
9517201 | Andrey Zagrebin | 16 November 2018, 17:11:36 UTC | [FLINK-10869] [tests] Fix test_streaming_file_sink to use proper and unique output directory | 16 November 2018, 20:14:16 UTC |
ba66aed | Stephan Ewen | 15 November 2018, 22:34:28 UTC | [hotfix] [e2e] Do not print S3 credentials in test scripts | 16 November 2018, 20:14:16 UTC |
d3bd21a | Stephan Ewen | 15 November 2018, 22:23:30 UTC | [FLINK-10869] [tests] Adjust end-2-end tests to new S3 credentials | 16 November 2018, 20:14:15 UTC |
bbbb9aa | Stephan Ewen | 15 November 2018, 21:52:36 UTC | [FLINK-10869] [tests] Remove Yarn staging test for deprecated Hadoop s3:// filesystem. That filesystem is no longer supported by Hadoop, is discouraged to use, and is unable to work with any non-overall-permissive permission setup. | 16 November 2018, 20:14:15 UTC |
fe358d6 | Stephan Ewen | 15 November 2018, 15:36:23 UTC | [FLINK-10869] [tests] Update all S3 tests to use new test credentials | 16 November 2018, 20:14:15 UTC |
68b4545 | Stephan Ewen | 15 November 2018, 12:34:13 UTC | [FLINK-10869] [tests] Add S3Credentials to get access to S3 test credentials | 16 November 2018, 20:14:15 UTC |
0cc5df4 | Stephan Ewen | 13 November 2018, 16:44:17 UTC | [FLINK-10869] [build] Remove outdated secrets from travis build The secrets are replaced with build server environment variables. | 16 November 2018, 20:14:15 UTC |
a66b267 | kkloudas | 06 November 2018, 17:02:10 UTC | [FLINK-10531][e2e] Fix unstable TTL end-to-end test. | 16 November 2018, 19:32:17 UTC |
6a15de1 | Till Rohrmann | 16 November 2018, 17:51:23 UTC | [hotfix] Add release note that Flink's Scala shell does not work with Scala 2.12 | 16 November 2018, 17:53:36 UTC |
7f30520 | yanghua | 15 November 2018, 06:26:34 UTC | [FLINK-10891] Upgrade Kafka client version to 2.0.1 | 16 November 2018, 17:16:10 UTC |
1891949 | yanghua | 15 November 2018, 14:15:51 UTC | [FLINK-10872] [e2e] Extend SQL Client end-to-end to for Kafka 0.11 connector This closes #7100. | 16 November 2018, 16:12:17 UTC |
d2c2773 | Timo Walther | 16 November 2018, 08:23:28 UTC | [FLINK-10843] [connectors] Change Kafka table factory version '2.0' to 'universal' This closes #7087. | 16 November 2018, 15:57:05 UTC |
d02af7e | Piotr Nowojski | 15 November 2018, 14:15:03 UTC | [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta Because of frequent deadlocks and other failures in tests the connector is marked as beta. Those errors are probably only test issues or Kafka bugs but as for now it's not confirmed. | 16 November 2018, 15:50:27 UTC |
89b3d97 | Piotr Nowojski | 15 November 2018, 14:11:20 UTC | [hotfix][kafka][docs] Couple of minor fixes in Kafka 2.0 connector documentation | 16 November 2018, 15:50:25 UTC |
d6788bf | Piotr Nowojski | 15 November 2018, 14:24:29 UTC | [hotfix][kafka][docs] Split long lines in kafka.md Long lines are not diff/conflict resolution friendly, while md ignores new lines, so this change has no visible effect for the user. | 16 November 2018, 15:50:24 UTC |
146f434 | xueyu | 22 October 2018, 16:16:48 UTC | [FLINK-10642] [table] Fix CodeGen split errors when maxGeneratedCodeLength equals 1 This closes #6900. | 16 November 2018, 14:10:57 UTC |
f5db114 | Till Rohrmann | 15 November 2018, 16:27:22 UTC | [FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out Instead of failing the ExecutionGraph with a generic TimeoutException if a slot request times out, this commit changes the exception to a more meaningful NoResourceAvailableException. | 16 November 2018, 08:21:05 UTC |
a2a23b2 | Till Rohrmann | 15 November 2018, 16:27:09 UTC | [hotfix] Fix checkstyle violation in ExecutionGraph | 16 November 2018, 08:21:05 UTC |
6c21335 | Till Rohrmann | 15 November 2018, 15:05:56 UTC | [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test | 16 November 2018, 08:18:56 UTC |
4c52cdb | Till Rohrmann | 14 November 2018, 10:00:53 UTC | [FLINK-10877] Cleanup flink-connector-kafka pom file Remove duplicate flink-connector-kafka-base test dependencies and exclusions. | 16 November 2018, 08:17:20 UTC |
113418c | Till Rohrmann | 15 November 2018, 13:58:05 UTC | [hotfix] Fix checkstyle violations in SlotReport and SlotStatus | 15 November 2018, 16:38:15 UTC |
074fecd | Till Rohrmann | 15 November 2018, 13:56:49 UTC | [hotfix] Log SlotReport in SlotManager#reportSlotStatus | 15 November 2018, 16:38:14 UTC |
1bb55d1 | Till Rohrmann | 15 November 2018, 14:38:38 UTC | [hotfix] Skip log verification for the heavy deployment e2e test | 15 November 2018, 14:39:41 UTC |
4597daf | Gary Yao | 15 November 2018, 10:59:24 UTC | [FLINK-10764][tests] Add ITCase for checkpoint path entropy injection. (#7075) Add a test that verifies that checkpoint data on the file system has additional entropy added to its path. Remove code duplication in SavepointITCase. | 15 November 2018, 13:57:02 UTC |
60e9dcb | Till Rohrmann | 15 November 2018, 12:43:44 UTC | [FLINK-10899] Remove explicit version tag from flink-metrics-availability-test and flink-metrics-reporter-prometheus-test | 15 November 2018, 13:48:11 UTC |
16925c2 | Chesnay Schepler | 15 November 2018, 12:05:07 UTC | [FLINK-10857][metrics] Cache logical scopes separately for each reporter | 15 November 2018, 12:05:52 UTC |
d389e5a | zentol | 14 November 2018, 10:40:35 UTC | [hotfix][tests] Fix typo in FutureUtils#retrySuccessfulWithDelay | 15 November 2018, 11:42:38 UTC |
81fdad5 | zentol | 07 November 2018, 14:47:48 UTC | [FLINK-10634][metrics][rest] Add metrics availability e2e test | 15 November 2018, 11:42:37 UTC |
2f5435f | Piotr Nowojski | 13 November 2018, 10:24:35 UTC | [FLINK-10861]][e2e] Do not fail stop_kafka_cluster if a process terminates before we kill it | 15 November 2018, 10:58:04 UTC |
62f9fbb | yanghua | 13 November 2018, 14:00:01 UTC | [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink This closes #6927. | 15 November 2018, 10:58:04 UTC |
b6f7551 | Dawid Wysakowicz | 14 November 2018, 09:17:23 UTC | [FLINK-10767] Updated savepoint compatibility matrix with 1.7 | 15 November 2018, 10:28:20 UTC |
48cf0e4 | Dawid Wysakowicz | 14 November 2018, 12:24:52 UTC | [FLINK-10419] Call JobMasterGateway through RpcCheckpointResponder in test | 15 November 2018, 09:15:15 UTC |
ca28b07 | azagrebin | 15 November 2018, 09:09:59 UTC | [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests | 15 November 2018, 09:12:48 UTC |
d16e012 | Dawid Wysakowicz | 13 November 2018, 10:42:08 UTC | [FLINK-10419] Added IT test to check declineCheckpoint invocation | 14 November 2018, 10:51:41 UTC |
480d5e3 | Dawid Wysakowicz | 12 November 2018, 17:21:40 UTC | [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint | 14 November 2018, 10:51:41 UTC |
6c84103 | Till Rohrmann | 13 November 2018, 14:04:11 UTC | [FLINK-10856] Take latest checkpoint to resume from in resume from externalized checkpoint e2e test Since it can happen that some empty checkpoint directories are left, we have to take the latest checkpoint directory in order to resume from an externalized checkpoint. This commit changes the test_resume_externalized_checkpoint.sh to sort the checkpoint directories in descending order and then takes the head checkpoint directory. | 14 November 2018, 10:06:47 UTC |
b7ba497 | azagrebin | 14 November 2018, 09:08:39 UTC | [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination (#6989) This commit addresses the problem of potential leak of resources associated with unclosed Kafka transactional producers in case of commitment failure or task shutdown. 1. always close producer even if commit fails in TwoPhaseCommitSinkFunction#notifyCheckpointComplete 2. close pending transactions in close method of Kafka Flink function in case of task shutdown 3. continue trying to commit other transactions in TwoPhaseCommitSinkFunction#notifyCheckpointComplete if any of them failed | 14 November 2018, 09:10:15 UTC |
44777b6 | Stefan Richter | 13 November 2018, 11:32:56 UTC | [FLINK-10863][tests] Assign UIDs to all operators in DataStreamAllroundTestProgram This closes #7085. | 13 November 2018, 15:45:49 UTC |
eb2d942 | Stefan Richter | 13 November 2018, 08:31:45 UTC | [hotfix] CheckpointDeclineException should lead to pendingCheckpoint.abortDecline() We also avoid logging exceptions that are cause by instances of CheckpointDeclineException | 13 November 2018, 14:40:13 UTC |
eb5ff6d | Timo Walther | 13 November 2018, 08:46:31 UTC | [FLINK-10826] [e2e] Further decrease heavy deployment size In order to enable stable nightly Travis cron jobs. | 13 November 2018, 08:48:48 UTC |
9477b6a | Stefan Richter | 08 November 2018, 14:51:16 UTC | [FLINK-10753] Improve propagation and logging of snapshot exceptions This closes #7064. Signed-off-by: Stefan Richter <s.richter@data-artisans.com> | 12 November 2018, 17:34:30 UTC |
45ad36f | Stefan Richter | 07 November 2018, 13:05:07 UTC | [FLINK-10809][state] Include keyed state that is not from head operators in state assignment This closes #7048. Signed-off-by: Stefan Richter <s.richter@data-artisans.com> | 12 November 2018, 17:23:05 UTC |
bd75a06 | Stefan Richter | 08 November 2018, 13:44:08 UTC | [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase This closes #7061. | 12 November 2018, 16:46:03 UTC |
19c34ba | Stefan Richter | 09 November 2018, 11:56:02 UTC | [FLINK-10839][serializer] Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer | 12 November 2018, 16:45:50 UTC |
7dc4c70 | Igal Shilman | 09 November 2018, 12:59:24 UTC | [FLINK-10821] E2E now uses externalized checkpoint This commit fixes the test_resume_externalized_checkpoints.sh script, by providing the path to the externalized checkpoint taken. | 12 November 2018, 11:59:13 UTC |
78ea392 | Timo Walther | 12 November 2018, 09:28:51 UTC | [FLINK-10826] [e2e] Increase network timeout | 12 November 2018, 09:35:23 UTC |
7d9fcba | Stefan Richter | 08 November 2018, 14:08:35 UTC | [FLINK-10826] [e2e] Decrease deployment size of heavy deplyment e2e test for Travis This closes #7066. | 12 November 2018, 09:35:23 UTC |
096918c | Timo Walther | 08 November 2018, 16:32:35 UTC | [FLINK-10626] [docs] [table] Add documentation for temporal table joins This closes #7065. | 12 November 2018, 08:29:06 UTC |
302f25f | Till Rohrmann | 11 November 2018, 13:38:15 UTC | [hotfix] Make test_sql_client independent of unzip Some platforms might not have installed the unzip command. Therefore it is better to use the jar command to extract jar files. | 11 November 2018, 13:39:27 UTC |
0cdc1c5 | Tzu-Li (Gordon) Tai | 11 November 2018, 07:46:04 UTC | [hotfix] [cep] Remove duplicate getElementSerializer() method from LockableTypeSerializer | 11 November 2018, 07:46:04 UTC |
29e60a5 | Tzu-Li (Gordon) Tai | 06 November 2018, 06:28:28 UTC | [hotfix] [core] Add missing precondition null checks in List-/MapSerializerSnapshot | 11 November 2018, 04:36:17 UTC |
a0720ab | Tzu-Li (Gordon) Tai | 06 November 2018, 06:26:54 UTC | [FLINK-10789] [scala] ScalaEitherSerializerSnapshot should be a TypeSerializerSnapshot This also adds a migration test for the Scala EitherSerializer. This closes #7028. | 11 November 2018, 04:36:11 UTC |
8daf04b | Tzu-Li (Gordon) Tai | 06 November 2018, 06:04:27 UTC | [FLINK-10789] [table] MapViewSerializerSnapshot should be a TypeSerializerSnapshot This also adds a migration test for the MapViewSerializer. | 11 November 2018, 04:36:06 UTC |
5ce0a91 | Tzu-Li (Gordon) Tai | 06 November 2018, 05:48:37 UTC | [FLINK-10789] [table] ListViewSerializerSnapshot should be a TypeSerializerSnapshot This also adds a migration test for the ListViewSerializer. | 11 November 2018, 04:36:00 UTC |
822023c | Tzu-Li (Gordon) Tai | 06 November 2018, 04:54:13 UTC | [FLINK-10789] [cep] LockableTypeSerializerSnapshot should be a TypeSerializerSnapshot This also adds a migration test for the LockableTypeSerializer. | 11 November 2018, 04:35:54 UTC |
158e2c8 | Piotr Nowojski | 09 November 2018, 08:52:15 UTC | [FLINK-10801][e2e] Retry verify_result_hash in elastichsearch-common (#7060) Instead of looping the verification until the expected number of results loop until we get the correct output. This tries to solve the problem of some records (aggregated? updated?) arriving later. | 09 November 2018, 08:52:53 UTC |
789d8a7 | zentol | 08 November 2018, 10:13:29 UTC | [FLINK-10813][travis][scala] Automatically check scala-suffixes | 09 November 2018, 08:37:11 UTC |
6d138a8 | vinoyang | 09 November 2018, 08:34:32 UTC | [FLINK-10733][tests] Inline clean_log_files() | 09 November 2018, 08:35:08 UTC |
b95d69a | zentol | 08 November 2018, 10:32:45 UTC | [FLINK-10823][metrics][jmx] Add scala suffix | 09 November 2018, 08:32:56 UTC |
8132129 | zentol | 08 November 2018, 10:30:36 UTC | [FLINK-10823][metrics][prometheus] Add scala suffix | 09 November 2018, 08:32:54 UTC |
365eece | zentol | 08 November 2018, 10:30:16 UTC | [FLINK-10823][jdbc] Add scala suffix | 09 November 2018, 08:32:52 UTC |
b1e2406 | Hequn Cheng | 09 November 2018, 06:29:24 UTC | [FLINK-10814][examples] Add scala suffix to Kafka example module | 09 November 2018, 06:29:58 UTC |
8c3a939 | zentol | 08 November 2018, 14:13:36 UTC | [FLINK-10825][tests] Increase request-backoff for high-parallelism e2e test | 09 November 2018, 06:23:34 UTC |
d608eef | zentol | 08 November 2018, 14:11:20 UTC | [hotfix][docs] Clarify unit for network.request-backoff | 09 November 2018, 06:23:30 UTC |
365e29d | Chesnay Schepler | 08 November 2018, 19:28:52 UTC | [hotfix][tests] Remove hard-coded scala versions | 08 November 2018, 19:28:52 UTC |
bc2cb22 | vinoyang | 08 November 2018, 13:37:39 UTC | [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector (#7038) [FLINK-10791][e2e] Provide end-to-end test for Kafka 0.11 connector | 08 November 2018, 13:41:42 UTC |
87fe679 | Kostas Kloudas | 07 November 2018, 15:27:02 UTC | [FLINK-10803][docs] Update the StreamingFileSink documentation for S3. | 08 November 2018, 13:31:41 UTC |
4a174f7 | Kostas Kloudas | 07 November 2018, 14:22:36 UTC | [FLINK-10803][docs] Update the filesystem documentation for S3 (s3p). | 08 November 2018, 13:31:34 UTC |
e34f8af | zentol | 08 November 2018, 12:09:22 UTC | [FLINK-10361][tests][ES] Properly wait for ES to start This closes #7057. | 08 November 2018, 12:57:54 UTC |
ca66bed | Stefan Richter | 06 November 2018, 09:28:04 UTC | [FLINK-10765][test] Include s3p schema in S3 test This closes #7032. | 08 November 2018, 10:06:29 UTC |
df81b9d | jrthe42 | 03 November 2018, 13:24:57 UTC | [FLINK-10770] [table] Ensure calling open/close of generated functions This closes #7014. | 08 November 2018, 09:57:48 UTC |
b975ea9 | Stefan Richter | 07 November 2018, 17:06:34 UTC | [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider deep duplication of element serializer This closes #7049. | 08 November 2018, 09:52:59 UTC |
a990f84 | zentol | 07 November 2018, 12:07:46 UTC | [FLINK-10811][hcatalog] Add scala suffix | 08 November 2018, 08:17:57 UTC |
34938c4 | Till Rohrmann | 07 November 2018, 16:05:50 UTC | [hotfix] Add RocksDB config options to documentation | 07 November 2018, 16:07:15 UTC |
ef43941 | zentol | 07 November 2018, 13:20:50 UTC | [FLINK-10812][build] Skip javadoc plugin for e2e-test-utils | 07 November 2018, 15:01:14 UTC |
600869e | zentol | 07 November 2018, 08:44:36 UTC | [FLINK-10750][tests] Harden SocketClientSinkTest The tests attempts to re-bind a server to a specific port. If the port is taken the test will fail. The test is now skipped instead if this happens. This closes #7040. | 07 November 2018, 14:33:39 UTC |