https://github.com/apache/flink

sort by:
Revision Author Date Message Commit Date
5a775c8 Commit for release 1.7.0 19 November 2018, 21:40:52 UTC
84cad5b [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 [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 [FLINK-10922] Refactor the placement of the Flink Kafka connector end to end test module 19 November 2018, 21:35:54 UTC
65ef428 [FLINK-10893] [tests] Export S3 credentials properly for test scripts 19 November 2018, 20:44:32 UTC
5d77007 [FLINK-8997] Added sliding window aggregation to datastream test job 19 November 2018, 16:45:07 UTC
571faf4 [FLINK-10481][e2e] Added retry logic for building docker image 19 November 2018, 16:38:06 UTC
76974bd [FLINK-10670] [table] Fix Correlate codegen error This closes #6923. 19 November 2018, 13:45:34 UTC
96e790a [FLINK-10925][py] Check for null when closing socket 19 November 2018, 10:18:13 UTC
3c1f14e [FLINK-10916][streaming] Include duplicated user-specified uid in error message 19 November 2018, 07:36:32 UTC
ab86d5d [FLINK-10625] [docs] Polishing MATCH_RECOGNIZE document 18 November 2018, 13:29:43 UTC
0642814 [FLINK-10625] [docs] Improvements to the MATCH_RECOGNIZE documentation 18 November 2018, 13:29:35 UTC
d61f3bc [FLINK-10625] [docs] Documentation for MATCH_RECOGNIZE clause 18 November 2018, 13:29:10 UTC
ef683c3 [FLINK-10880] Add release notes warning to not use Flink's failover strategies 17 November 2018, 19:51:08 UTC
63d3883 [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 [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 [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 [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 [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 [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 [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 [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 [hotfix] [s3] Minor fixes/code simplifications in S3 recoverable writer 16 November 2018, 20:14:16 UTC
6abd87b [hotfix] [tests] Make S3 Recoverable Writer tests ITCases 16 November 2018, 20:14:16 UTC
9517201 [FLINK-10869] [tests] Fix test_streaming_file_sink to use proper and unique output directory 16 November 2018, 20:14:16 UTC
ba66aed [hotfix] [e2e] Do not print S3 credentials in test scripts 16 November 2018, 20:14:16 UTC
d3bd21a [FLINK-10869] [tests] Adjust end-2-end tests to new S3 credentials 16 November 2018, 20:14:15 UTC
bbbb9aa [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 [FLINK-10869] [tests] Update all S3 tests to use new test credentials 16 November 2018, 20:14:15 UTC
68b4545 [FLINK-10869] [tests] Add S3Credentials to get access to S3 test credentials 16 November 2018, 20:14:15 UTC
0cc5df4 [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 [FLINK-10531][e2e] Fix unstable TTL end-to-end test. 16 November 2018, 19:32:17 UTC
6a15de1 [hotfix] Add release note that Flink's Scala shell does not work with Scala 2.12 16 November 2018, 17:53:36 UTC
7f30520 [FLINK-10891] Upgrade Kafka client version to 2.0.1 16 November 2018, 17:16:10 UTC
1891949 [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 [FLINK-10843] [connectors] Change Kafka table factory version '2.0' to 'universal' This closes #7087. 16 November 2018, 15:57:05 UTC
d02af7e [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 [hotfix][kafka][docs] Couple of minor fixes in Kafka 2.0 connector documentation 16 November 2018, 15:50:25 UTC
d6788bf [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 [FLINK-10642] [table] Fix CodeGen split errors when maxGeneratedCodeLength equals 1 This closes #6900. 16 November 2018, 14:10:57 UTC
f5db114 [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 [hotfix] Fix checkstyle violation in ExecutionGraph 16 November 2018, 08:21:05 UTC
6c21335 [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test 16 November 2018, 08:18:56 UTC
4c52cdb [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 [hotfix] Fix checkstyle violations in SlotReport and SlotStatus 15 November 2018, 16:38:15 UTC
074fecd [hotfix] Log SlotReport in SlotManager#reportSlotStatus 15 November 2018, 16:38:14 UTC
1bb55d1 [hotfix] Skip log verification for the heavy deployment e2e test 15 November 2018, 14:39:41 UTC
4597daf [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 [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 [FLINK-10857][metrics] Cache logical scopes separately for each reporter 15 November 2018, 12:05:52 UTC
d389e5a [hotfix][tests] Fix typo in FutureUtils#retrySuccessfulWithDelay 15 November 2018, 11:42:38 UTC
81fdad5 [FLINK-10634][metrics][rest] Add metrics availability e2e test 15 November 2018, 11:42:37 UTC
2f5435f [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 [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink This closes #6927. 15 November 2018, 10:58:04 UTC
b6f7551 [FLINK-10767] Updated savepoint compatibility matrix with 1.7 15 November 2018, 10:28:20 UTC
48cf0e4 [FLINK-10419] Call JobMasterGateway through RpcCheckpointResponder in test 15 November 2018, 09:15:15 UTC
ca28b07 [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests 15 November 2018, 09:12:48 UTC
d16e012 [FLINK-10419] Added IT test to check declineCheckpoint invocation 14 November 2018, 10:51:41 UTC
480d5e3 [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint 14 November 2018, 10:51:41 UTC
6c84103 [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 [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 [FLINK-10863][tests] Assign UIDs to all operators in DataStreamAllroundTestProgram This closes #7085. 13 November 2018, 15:45:49 UTC
eb2d942 [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 [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 [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 [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 [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase This closes #7061. 12 November 2018, 16:46:03 UTC
19c34ba [FLINK-10839][serializer] Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer 12 November 2018, 16:45:50 UTC
7dc4c70 [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 [FLINK-10826] [e2e] Increase network timeout 12 November 2018, 09:35:23 UTC
7d9fcba [FLINK-10826] [e2e] Decrease deployment size of heavy deplyment e2e test for Travis This closes #7066. 12 November 2018, 09:35:23 UTC
096918c [FLINK-10626] [docs] [table] Add documentation for temporal table joins This closes #7065. 12 November 2018, 08:29:06 UTC
302f25f [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 [hotfix] [cep] Remove duplicate getElementSerializer() method from LockableTypeSerializer 11 November 2018, 07:46:04 UTC
29e60a5 [hotfix] [core] Add missing precondition null checks in List-/MapSerializerSnapshot 11 November 2018, 04:36:17 UTC
a0720ab [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 [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 [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 [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 [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 [FLINK-10813][travis][scala] Automatically check scala-suffixes 09 November 2018, 08:37:11 UTC
6d138a8 [FLINK-10733][tests] Inline clean_log_files() 09 November 2018, 08:35:08 UTC
b95d69a [FLINK-10823][metrics][jmx] Add scala suffix 09 November 2018, 08:32:56 UTC
8132129 [FLINK-10823][metrics][prometheus] Add scala suffix 09 November 2018, 08:32:54 UTC
365eece [FLINK-10823][jdbc] Add scala suffix 09 November 2018, 08:32:52 UTC
b1e2406 [FLINK-10814][examples] Add scala suffix to Kafka example module 09 November 2018, 06:29:58 UTC
8c3a939 [FLINK-10825][tests] Increase request-backoff for high-parallelism e2e test 09 November 2018, 06:23:34 UTC
d608eef [hotfix][docs] Clarify unit for network.request-backoff 09 November 2018, 06:23:30 UTC
365e29d [hotfix][tests] Remove hard-coded scala versions 08 November 2018, 19:28:52 UTC
bc2cb22 [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 [FLINK-10803][docs] Update the StreamingFileSink documentation for S3. 08 November 2018, 13:31:41 UTC
4a174f7 [FLINK-10803][docs] Update the filesystem documentation for S3 (s3p). 08 November 2018, 13:31:34 UTC
e34f8af [FLINK-10361][tests][ES] Properly wait for ES to start This closes #7057. 08 November 2018, 12:57:54 UTC
ca66bed [FLINK-10765][test] Include s3p schema in S3 test This closes #7032. 08 November 2018, 10:06:29 UTC
df81b9d [FLINK-10770] [table] Ensure calling open/close of generated functions This closes #7014. 08 November 2018, 09:57:48 UTC
b975ea9 [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider deep duplication of element serializer This closes #7049. 08 November 2018, 09:52:59 UTC
a990f84 [FLINK-10811][hcatalog] Add scala suffix 08 November 2018, 08:17:57 UTC
34938c4 [hotfix] Add RocksDB config options to documentation 07 November 2018, 16:07:15 UTC
ef43941 [FLINK-10812][build] Skip javadoc plugin for e2e-test-utils 07 November 2018, 15:01:14 UTC
600869e [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
back to top