commits@flink.apache.org, 2018-06

You are viewing a plain text version of this content. The canonical link for it is here.

- [1/8] flink git commit: [hotfix] Remove unnecessary flink-test-utils-junit dependency from flink-connector-filesystem - posted by tr...@apache.org on 2018/06/02 12:47:20 UTC, 0 replies.
- [2/8] flink git commit: [hotfix] Remove Category marker interface New from flink-test-utils-junit - posted by tr...@apache.org on 2018/06/02 12:47:21 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-9464] Remove version and scope from flink-test-utils-junit and maven-shade-plugin in flink-swift-fs-hadoop pom.xml - posted by tr...@apache.org on 2018/06/02 12:47:22 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-9464] Remove version and scope from flink-test-utils-junit dependency in flink-statebackend-rocksdb pom.xml - posted by tr...@apache.org on 2018/06/02 12:47:23 UTC, 0 replies.
- [5/8] flink git commit: [hotfix] Use ConfigConstants.DEFAULT_CHARSET in KvStateRequest - posted by tr...@apache.org on 2018/06/02 12:47:24 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-9464] Remove duplicate maven-jar-plugin entry in flink-clients pom.xml - posted by tr...@apache.org on 2018/06/02 12:47:25 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-9464] Remove version and scope from flink-test-utils-junit in flink-json pom.xml - posted by tr...@apache.org on 2018/06/02 12:47:26 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-9464] Remove version and scope from flink-test-utils-junit dependency in multiple modules - posted by tr...@apache.org on 2018/06/02 12:47:27 UTC, 0 replies.
- flink git commit: [FLINK-7789] Add handler for Async IO operator timeouts - posted by kk...@apache.org on 2018/06/02 13:42:08 UTC, 1 replies.
- flink git commit: [FLINK-9468] [core] Set outputLimit in LimitedConnectionsFileSystem#createStream() correctly. - posted by se...@apache.org on 2018/06/04 12:58:11 UTC, 2 replies.
- flink git commit: [hotfix] [docs] Remove unsupported SQL Client jars - posted by tw...@apache.org on 2018/06/04 14:33:57 UTC, 1 replies.
- flink git commit: [FLINK-9476][cep] Emit late elements in CEP as sideOutput - posted by dw...@apache.org on 2018/06/04 14:41:05 UTC, 0 replies.
- flink git commit: [FLINK-7866][runtime] Order preferred locations by score for scheduling. - posted by sr...@apache.org on 2018/06/04 15:30:57 UTC, 0 replies.
- [flink] Git Push Summary - posted by sh...@apache.org on 2018/06/04 20:09:04 UTC, 1 replies.
- flink git commit: [hotfix][docs] add comment for TestTableSourceFactory - posted by sh...@apache.org on 2018/06/04 23:31:12 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #851 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/06/05 03:51:41 UTC, 0 replies.
- flink git commit: [hotfix][cep] Fix checkstyle violation in CEPOperatorTest - posted by ch...@apache.org on 2018/06/05 06:46:30 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-9517][docs] Fix broken links in CLI and Upgrade docs - posted by ch...@apache.org on 2018/06/05 06:48:44 UTC, 2 replies.
- [2/2] flink git commit: [FLINK-9518][docs] Adjust password in SSL setup config example - posted by ch...@apache.org on 2018/06/05 06:48:45 UTC, 2 replies.
- flink git commit: [FLINK-8518] [table] Support EXTRACT(DOW ...) and document supported extraction units - posted by tw...@apache.org on 2018/06/05 08:08:39 UTC, 0 replies.
- flink git commit: [FLINK-8790][State] Improve performance of rescaling an incremental checkpoint - posted by sr...@apache.org on 2018/06/05 12:19:02 UTC, 0 replies.
- flink git commit: [FLINK-9440][streaming] Expose cancelation of timers through timer service interface. - posted by sr...@apache.org on 2018/06/05 12:27:27 UTC, 0 replies.
- [1/2] flink-web git commit: Fix typo in contribute-code: "sensitive" vs "sensible" - posted by fh...@apache.org on 2018/06/05 12:47:12 UTC, 0 replies.
- [2/2] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/05 12:47:13 UTC, 0 replies.
- flink git commit: [FLINK-7917] The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex - posted by dw...@apache.org on 2018/06/05 12:57:24 UTC, 0 replies.
- flink git commit: [FLINK-8430] [table] Implement stream-stream non-window full outer join - posted by tw...@apache.org on 2018/06/05 13:37:26 UTC, 0 replies.
- flink git commit: [hotfix] [tests] Skip annotation processing for compiling tests - posted by tw...@apache.org on 2018/06/05 15:35:17 UTC, 0 replies.
- flink git commit: [FLINK-9109] [doc] Update documentation for CLI - posted by tr...@apache.org on 2018/06/05 21:10:55 UTC, 1 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #852 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/06/06 04:20:03 UTC, 0 replies.
- [flink-shaded] branch master updated: [hotfix] Delete redundant release script - posted by ch...@apache.org on 2018/06/06 06:59:18 UTC, 0 replies.
- [flink-shaded] tag 4.0 created (now 33e8699) - posted by ch...@apache.org on 2018/06/06 07:01:53 UTC, 0 replies.
- svn commit: r27278 - in /release/flink/flink-shaded-4.0: ./ flink-shaded-4.0-src.tgz flink-shaded-4.0-src.tgz.asc flink-shaded-4.0-src.tgz.sha512 - posted by ch...@apache.org on 2018/06/06 07:07:52 UTC, 0 replies.
- svn commit: r27279 - in /dev/flink: flink-shaded-4.0-rc1/ flink-shaded-4.0-rc2/ - posted by ch...@apache.org on 2018/06/06 07:08:47 UTC, 0 replies.
- flink git commit: [hotfix] [docs] Fix Scala code examples for Table API and SQL. - posted by fh...@apache.org on 2018/06/07 19:56:28 UTC, 2 replies.
- flink git commit: [FLINK-9482] [table] EXTRACT function argument validation whether it is applicable for TIME type - posted by sh...@apache.org on 2018/06/08 00:55:22 UTC, 0 replies.
- flink git commit: [FLINK-9398][cli] Only list non-terminal jobs in running section - posted by ch...@apache.org on 2018/06/11 12:16:07 UTC, 0 replies.
- flink git commit: [hotfix][javadocs] Update OptionsFactory javadocs - posted by ch...@apache.org on 2018/06/11 12:36:21 UTC, 2 replies.
- flink git commit: [FLINK-9549][cep][docs] Fix broken links and missing quotes - posted by ch...@apache.org on 2018/06/11 12:41:14 UTC, 1 replies.
- flink git commit: [hotfix][docs] Properly initialize scala variable - posted by ch...@apache.org on 2018/06/11 12:45:58 UTC, 2 replies.
- flink git commit: [FLINK-9539][build] Integrate flink-shaded 4.0 - posted by ch...@apache.org on 2018/06/11 12:49:16 UTC, 0 replies.
- flink git commit: [FLINK-9508][docs] Fix spelling/punctuation errors - posted by ch...@apache.org on 2018/06/11 13:03:00 UTC, 2 replies.
- flink git commit: [FLINK-8861] [sql-client] Add support for batch queries in SQL Client - posted by tw...@apache.org on 2018/06/11 13:41:58 UTC, 0 replies.
- flink git commit: [hotfix] [sql-client] Fix NPE when column is null - posted by tw...@apache.org on 2018/06/11 14:24:09 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-8946][metrics] Do not close TM MetricGroup on JobManager failover - posted by ch...@apache.org on 2018/06/12 09:34:04 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-9398][cli] Only list non-terminal jobs in running section - posted by ch...@apache.org on 2018/06/12 09:34:05 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-9564][tests] Expose flink-end-to-end module directory to tests - posted by ch...@apache.org on 2018/06/12 09:36:59 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-9398][cli] Only list non-terminal jobs in running section - posted by ch...@apache.org on 2018/06/12 09:37:00 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-9451][tests] Add scala quickstart end-to-end test - posted by ch...@apache.org on 2018/06/12 09:37:01 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-9566][cli] Support listing all jobs - posted by ch...@apache.org on 2018/06/12 09:37:02 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-8946][metrics] Do not close TM MetricGroup on JobManager failover - posted by ch...@apache.org on 2018/06/12 09:37:03 UTC, 0 replies.
- flink git commit: [FLINK-9564][tests] Expose flink-end-to-end module directory to tests - posted by ch...@apache.org on 2018/06/12 09:39:13 UTC, 0 replies.
- flink git commit: [FLINK-9368][py][tests] Add Python API E2E test - posted by ch...@apache.org on 2018/06/12 09:43:00 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8759][network] preparations for the update of netty to version 4.1 - posted by tr...@apache.org on 2018/06/12 09:45:34 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8768][network] Let NettyMessageDecoder inherit from LengthFieldBasedFrameDecoder - posted by tr...@apache.org on 2018/06/12 09:45:35 UTC, 0 replies.
- flink git commit: [FLINK-8946][metrics] Do not close TM MetricGroup on JobManager failover - posted by ch...@apache.org on 2018/06/12 12:32:25 UTC, 0 replies.
- flink git commit: [hotfix] Correct preconditions check in TypeExtractor#getBinaryOperatorReturnType - posted by tr...@apache.org on 2018/06/13 07:19:22 UTC, 0 replies.
- flink git commit: [FLINK-9458] Ignore SharedSlot in CoLocationConstraint when not using legacy mode - posted by tr...@apache.org on 2018/06/13 07:42:49 UTC, 1 replies.
- [1/6] flink git commit: [hotfix] Remove Netty shutdown work around in RestServerEndpoint - posted by tr...@apache.org on 2018/06/13 07:52:16 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-9463][runtime] Fix support for epoll transport type in netty - posted by tr...@apache.org on 2018/06/13 07:52:17 UTC, 0 replies.
- [3/6] flink git commit: [hotfix][runtime-test] Rename BufferTest to NetworkBufferTest - posted by tr...@apache.org on 2018/06/13 07:52:18 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-3952][runtine] Upgrade to Netty 4.1 - posted by tr...@apache.org on 2018/06/13 07:52:19 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-3952][runtine] Upgrade to Netty 4.1 - posted by tr...@apache.org on 2018/06/13 07:52:20 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-3952][runtine] Upgrade to Netty 4.1 - posted by tr...@apache.org on 2018/06/13 07:52:21 UTC, 0 replies.
- flink git commit: [FLINK-9570] [sql-client] Fix merging of environments - posted by tw...@apache.org on 2018/06/13 12:44:11 UTC, 1 replies.
- [01/10] flink git commit: [FLINK-8725] Reverted backward compatibility with <=1.5 - posted by dw...@apache.org on 2018/06/13 14:54:18 UTC, 0 replies.
- [02/10] flink git commit: [FLINK-8725] Separate state from NFA in CEP library - posted by dw...@apache.org on 2018/06/13 14:54:19 UTC, 0 replies.
- [03/10] flink git commit: [FLINK-8725] Separate state from NFA in CEP library - posted by dw...@apache.org on 2018/06/13 14:54:20 UTC, 0 replies.
- [04/10] flink git commit: [FLINK-9418] Migrate SharedBuffer to use MapState - posted by dw...@apache.org on 2018/06/13 14:54:21 UTC, 0 replies.
- [05/10] flink git commit: [FLINK-9418] Migrate SharedBuffer to use MapState - posted by dw...@apache.org on 2018/06/13 14:54:22 UTC, 0 replies.
- [06/10] flink git commit: [FLINK-9418] Migrate SharedBuffer to use MapState - posted by dw...@apache.org on 2018/06/13 14:54:23 UTC, 0 replies.
- [07/10] flink git commit: [FLINK-9418] Migrate SharedBuffer to use MapState - posted by dw...@apache.org on 2018/06/13 14:54:24 UTC, 0 replies.
- [08/10] flink git commit: [FLINK-9418] Migrate SharedBuffer to use MapState - posted by dw...@apache.org on 2018/06/13 14:54:25 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-9418] Separated pruning and element processing paths - posted by dw...@apache.org on 2018/06/13 14:54:26 UTC, 0 replies.
- [10/10] flink git commit: [FLINK-9538] Make KeyedStateFunction an interface - posted by dw...@apache.org on 2018/06/13 14:54:27 UTC, 0 replies.
- flink git commit: [FLINK-9572] Extend InternalAppendingState with internal stored state access - posted by sr...@apache.org on 2018/06/14 09:40:50 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-9494] Fix race condition in Dispatcher with granting and revoking leadership - posted by tr...@apache.org on 2018/06/14 16:07:54 UTC, 1 replies.
- [2/5] flink git commit: [hotfix] Fix checkstyle violations in SingleLeaderElectionService - posted by tr...@apache.org on 2018/06/14 16:07:55 UTC, 1 replies.
- [3/5] flink git commit: [hotfix] Remove Scala dependency from ZooKeeperLeaderElectionTest - posted by tr...@apache.org on 2018/06/14 16:07:56 UTC, 1 replies.
- [4/5] flink git commit: [hotfix] Make TestingDispatcher and TestingJobManagerRunnerFactory standalone testing classes - posted by tr...@apache.org on 2018/06/14 16:07:57 UTC, 1 replies.
- [5/5] flink git commit: [FLINK-9573] Extend LeaderElectionService#hasLeadership to take leader session id - posted by tr...@apache.org on 2018/06/14 16:07:58 UTC, 1 replies.
- [1/7] flink git commit: [FLINK-9530][metrics] Fix numRecords task metric for chains - posted by ch...@apache.org on 2018/06/14 23:49:28 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-9257][tests] Fix wrong "All tests pass" message - posted by ch...@apache.org on 2018/06/14 23:49:29 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-8744][docs] Add CommonOption annotation - posted by ch...@apache.org on 2018/06/14 23:49:30 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-9589][py] Make PythonOperationInfo immutable - posted by ch...@apache.org on 2018/06/14 23:49:31 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-9590][metrics] Make HistogramDump immutable - posted by ch...@apache.org on 2018/06/14 23:49:32 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-9591][py] Remove remnants of distributed-cache logic - posted by ch...@apache.org on 2018/06/14 23:49:33 UTC, 0 replies.
- [7/7] flink git commit: [hotfix] Remove duplicate lines - posted by ch...@apache.org on 2018/06/14 23:49:34 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-9530][metrics] Fix numRecords task metric for chains - posted by ch...@apache.org on 2018/06/14 23:49:42 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-9257][tests] Fix wrong "All tests pass" message - posted by ch...@apache.org on 2018/06/14 23:49:43 UTC, 0 replies.
- flink git commit: [FLINK-8573] Extend ProgramInvocationException message with Job ID where applicable - posted by tr...@apache.org on 2018/06/15 07:09:38 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-9366] DistributedCache works with Distributed File System - posted by dw...@apache.org on 2018/06/15 15:32:22 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-9579][CEP]Remove unneeded clear on elementQueueState - posted by dw...@apache.org on 2018/06/15 15:32:23 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-9551][DOCS]FlinkCEP Scala Combining Patterns table has a missing pattern - posted by dw...@apache.org on 2018/06/15 15:32:24 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-9487][state] Prepare InternalTimerHeap for asynchronous snapshots - posted by sr...@apache.org on 2018/06/15 19:06:51 UTC, 0 replies.
- [2/2] flink git commit: [hotfix][state] Introduce hard size limit for CopyOnWriteStateTable - posted by sr...@apache.org on 2018/06/15 19:06:52 UTC, 0 replies.
- flink git commit: [FLINK-9601][state] Make sure that the copied array in `CopyOnWriteStateTable#snapshotTableArrays()` is big enough to hold all (flattened) entries - posted by sr...@apache.org on 2018/06/18 07:47:06 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-9571] Repace StateBinder with internal backend-specific state factories - posted by sr...@apache.org on 2018/06/18 12:42:25 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-9571] Repace StateBinder with internal backend-specific state factories - posted by sr...@apache.org on 2018/06/18 12:42:26 UTC, 0 replies.
- flink git commit: [FLINK-8982][e2e tests] Add E2E Tests for queryable state. - posted by kk...@apache.org on 2018/06/21 11:43:39 UTC, 0 replies.
- [01/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:00 UTC, 0 replies.
- [02/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:01 UTC, 0 replies.
- [03/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:02 UTC, 0 replies.
- [04/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:03 UTC, 0 replies.
- [05/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:04 UTC, 0 replies.
- [06/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:05 UTC, 0 replies.
- [07/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:06 UTC, 0 replies.
- [08/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:07 UTC, 0 replies.
- [09/12] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/06/21 15:29:08 UTC, 0 replies.
- [10/12] flink-web git commit: [FLINK-9522] Restructure Flink website - posted by fh...@apache.org on 2018/06/21 15:29:09 UTC, 0 replies.
- [11/12] flink-web git commit: [FLINK-9522] Restructure Flink website - posted by fh...@apache.org on 2018/06/21 15:29:10 UTC, 0 replies.
- [12/12] flink-web git commit: [FLINK-9522] Restructure Flink website - posted by fh...@apache.org on 2018/06/21 15:29:11 UTC, 0 replies.
- [1/7] flink git commit: [hotfix][tests] JobGraphTest extends TestLogger - posted by ch...@apache.org on 2018/06/21 15:30:08 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-9623][runtime] Move zipping logic out of blobservice - posted by ch...@apache.org on 2018/06/21 15:30:09 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-9467][metrics][WebUI] Fix watermark display - posted by ch...@apache.org on 2018/06/21 15:30:10 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-9467][metrics] Rebuild UI - posted by ch...@apache.org on 2018/06/21 15:30:11 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-9467][metrics] Rebuild UI - posted by ch...@apache.org on 2018/06/21 15:30:12 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-9467][metrics] Rebuild UI - posted by ch...@apache.org on 2018/06/21 15:30:13 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-9599][rest] Implement generic mechanism to access uploaded files - posted by ch...@apache.org on 2018/06/21 15:30:14 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-9467][metrics][WebUI] Fix watermark display - posted by ch...@apache.org on 2018/06/21 17:59:09 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-9467][metrics] Rebuild UI - posted by ch...@apache.org on 2018/06/21 17:59:10 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-9467][metrics] Rebuild UI - posted by ch...@apache.org on 2018/06/21 17:59:11 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-9467][metrics] Rebuild UI - posted by ch...@apache.org on 2018/06/21 17:59:12 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-9599][rest] Implement generic mechanism to access uploaded files - posted by ch...@apache.org on 2018/06/21 17:59:13 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-9594][E2E tests] Improve docs for new test runner - posted by tz...@apache.org on 2018/06/22 07:31:33 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-9638][E2E Tests] Add helper script to run single test - posted by tz...@apache.org on 2018/06/22 07:31:34 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-8795] Fixed local scala shell for Flip6 - posted by tz...@apache.org on 2018/06/22 07:31:35 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-8944] [Kinesis Connector] Use listShards instead of DescribeStream for shard discovery as it offer higher rate limits - posted by tz...@apache.org on 2018/06/22 07:31:36 UTC, 0 replies.
- [5/7] flink git commit: [hotfix] [docs] Fix a typo in index.md - posted by tz...@apache.org on 2018/06/22 07:31:37 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-9394] [e2e] Test rescaling when resuming from externalized checkpoints - posted by tz...@apache.org on 2018/06/22 07:31:38 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer backpressuring - posted by tz...@apache.org on 2018/06/22 07:31:39 UTC, 0 replies.
- flink git commit: [FLINK-9599][rest] RestClient supports FileUploads - posted by ch...@apache.org on 2018/06/22 09:04:36 UTC, 1 replies.
- [1/6] flink git commit: [FLINK-8795] Fixed local scala shell for Flip6 - posted by tz...@apache.org on 2018/06/22 09:21:54 UTC, 0 replies.
- [2/6] flink git commit: [hotfix] [docs] Fix a typo in index.md - posted by tz...@apache.org on 2018/06/22 09:21:55 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-9394] [e2e] Test rescaling when resuming from externalized checkpoints - posted by tz...@apache.org on 2018/06/22 09:21:56 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-9638][E2E Tests] Add helper script to run single test - posted by tz...@apache.org on 2018/06/22 09:21:57 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-9594][E2E tests] Improve docs for new test runner - posted by tz...@apache.org on 2018/06/22 09:21:58 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer backpressuring - posted by tz...@apache.org on 2018/06/22 09:21:59 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-9266] [kinesis] Updates Kinesis connector to use newer version of kcl to limit describe streams calls - posted by tz...@apache.org on 2018/06/22 09:34:29 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-8945] [kinesis] Allow customization of KinesisProxy - posted by tz...@apache.org on 2018/06/22 09:34:30 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-8516] [kinesis] Allow for custom hash function for shard to subtask mapping in Kinesis consumer - posted by tz...@apache.org on 2018/06/22 09:34:31 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-8648] [kinesis] Allow for customization of emitRecordAndUpdateState in Kinesis connector. - posted by tz...@apache.org on 2018/06/22 09:34:32 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-9124] [kinesis] Allow customization of KinesisProxy.getRecords read timeout and retry. - posted by tz...@apache.org on 2018/06/22 09:34:33 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for flink kinesis connector - posted by tz...@apache.org on 2018/06/22 09:34:34 UTC, 0 replies.
- flink git commit: [FLINK-9595] [kinesis, docs] Add instructions to docs about ceased support of KPL version used in Kinesis connector - posted by tz...@apache.org on 2018/06/22 10:16:49 UTC, 2 replies.
- flink git commit: [FLINK-9550][DOC]FlinkCEP snippet example has some syntax errors - posted by dw...@apache.org on 2018/06/22 14:00:30 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-9646] [tests] Harden ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by tr...@apache.org on 2018/06/22 15:45:34 UTC, 0 replies.
- [2/9] flink git commit: [hotfix] Start always ClusterClient for MiniClusterResource - posted by tr...@apache.org on 2018/06/22 15:45:35 UTC, 0 replies.
- [3/9] flink git commit: [hotfix] Pass CodebaseType via the MiniClusterResourceConfiguration - posted by tr...@apache.org on 2018/06/22 15:45:36 UTC, 0 replies.
- [4/9] flink git commit: [hotfix] Only run MiniClusterResource if specified CodebaseType equals actual CodebaseType - posted by tr...@apache.org on 2018/06/22 15:45:37 UTC, 0 replies.
- [5/9] flink git commit: [hotfix] Introduce builder for MiniClusterResourceConfiguration - posted by tr...@apache.org on 2018/06/22 15:45:38 UTC, 0 replies.
- [6/9] flink git commit: [hotfix] Introduce builder for MiniClusterResourceConfiguration - posted by tr...@apache.org on 2018/06/22 15:45:39 UTC, 0 replies.
- [7/9] flink git commit: [hotfix] Make ActorSystemLoader in ClusterClient configurable - posted by tr...@apache.org on 2018/06/22 15:45:40 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-9493] Forward cause when releasing a TaskManager at the SlotPool - posted by tr...@apache.org on 2018/06/22 15:45:41 UTC, 0 replies.
- [9/9] flink git commit: [hotfix] Add DefaultActorSystemLoader which returns the given ActorSystem - posted by tr...@apache.org on 2018/06/22 15:45:42 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-9646] [tests] Harden ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by tr...@apache.org on 2018/06/22 15:49:26 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-9493] Forward cause when releasing a TaskManager at the SlotPool - posted by tr...@apache.org on 2018/06/22 15:49:27 UTC, 0 replies.
- flink git commit: [FLINK-9585] Logger in ZooKeeperStateHandleStore is public and non-final - posted by si...@apache.org on 2018/06/24 16:11:19 UTC, 0 replies.
- flink git commit: [FLINK-7897] Use nio.Files for file deletion in TransientBlobCleanupTask - posted by sr...@apache.org on 2018/06/26 08:12:04 UTC, 0 replies.
- flink git commit: [FLINK-9557] [formats] Parse 'integer' type as BigDecimal - posted by tw...@apache.org on 2018/06/26 12:52:05 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] Remove SlotIdleTimeout from JobMasterConfiguration - posted by tr...@apache.org on 2018/06/27 13:10:41 UTC, 1 replies.
- [2/4] flink git commit: [hotfix] Introduce SlotPoolFactory to make SlotPool instantiation configurable - posted by tr...@apache.org on 2018/06/27 13:10:42 UTC, 1 replies.
- [3/4] flink git commit: [FLINK-9634] Disable local recovery scheduling if local recovery is disabled - posted by tr...@apache.org on 2018/06/27 13:10:43 UTC, 1 replies.
- [4/4] flink git commit: [hotfix] Introduce SlotPoolResource and TestingRpcServiceResource - posted by tr...@apache.org on 2018/06/27 13:10:44 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-8468][RabbitMQ] Improve RabbitMQ connector - posted by tr...@apache.org on 2018/06/27 14:40:45 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8468][RabbitMQ] Make RabbitMQ connector to take advantage of AMQP features (routing key, exchange and message properties) - posted by tr...@apache.org on 2018/06/27 14:40:46 UTC, 0 replies.
- flink git commit: [FLINK-9524] [table] Check for expired clean-up timers to prevent NPE in ProcTimeBoundedRangeOver. - posted by fh...@apache.org on 2018/06/27 17:18:57 UTC, 2 replies.
- [1/5] flink git commit: [hotfix][table] Fix misleading exception message - posted by ch...@apache.org on 2018/06/28 05:42:06 UTC, 0 replies.
- [2/5] flink git commit: [hotfix][docs] Remove duplicate line - posted by ch...@apache.org on 2018/06/28 05:42:07 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-9580][rest] Close streams in RestClient#readRawResponse - posted by ch...@apache.org on 2018/06/28 05:42:08 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-9629][metrics] Include dependencies in datadog reporter jar - posted by ch...@apache.org on 2018/06/28 05:42:09 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-9677][rest] Cleanup encoder after request has been processed - posted by ch...@apache.org on 2018/06/28 05:42:10 UTC, 0 replies.
- flink git commit: [FLINK-9677][rest] Simplify logging - posted by ch...@apache.org on 2018/06/28 06:54:21 UTC, 0 replies.
- [1/4] flink git commit: [hotfix][table] Fix misleading exception message - posted by ch...@apache.org on 2018/06/28 09:04:20 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-9629][metrics] Include dependencies in datadog reporter jar - posted by ch...@apache.org on 2018/06/28 09:04:21 UTC, 0 replies.
- [3/4] flink git commit: [hotfix][docs] Remove duplicate line - posted by ch...@apache.org on 2018/06/28 09:04:22 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-9580][rest] Close streams in RestClient#readRawResponse - posted by ch...@apache.org on 2018/06/28 09:04:23 UTC, 0 replies.
- flink-web git commit: [hotfix] Fix broken link to blog. - posted by fh...@apache.org on 2018/06/28 09:16:53 UTC, 0 replies.
- flink git commit: [FLINK-9624][runtime] Move jar/artifact upload out of jobgraph - posted by ch...@apache.org on 2018/06/28 10:21:23 UTC, 0 replies.
- flink git commit: [FLINK-9666] Use short-circuit logic in boolean contexts - posted by tr...@apache.org on 2018/06/28 11:35:51 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8983] End-to-end test: Confluent schema registry - posted by tr...@apache.org on 2018/06/28 16:35:37 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8983] Integrate test_confluent_schema_registry.sh into run-nightly-tests.sh - posted by tr...@apache.org on 2018/06/28 16:35:38 UTC, 0 replies.
- flink git commit: [FLINK-9217][kafka-tests] Ignore testTimestamps for Kafka 0.10 - posted by pn...@apache.org on 2018/06/29 07:44:44 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-9514, FLINK-9515, FLINK-9516] Introduce wrapper to enhance state with ttl - posted by sr...@apache.org on 2018/06/29 12:20:22 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-9514, FLINK-9515, FLINK-9516] Introduce wrapper to enhance state with ttl - posted by sr...@apache.org on 2018/06/29 12:20:23 UTC, 0 replies.
- flink git commit: [FLINK-8067] User code ClassLoader not set before calling ProcessingTimeCallback - posted by pn...@apache.org on 2018/06/29 12:31:09 UTC, 0 replies.
- flink git commit: [FLINK-7775] Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs - posted by sr...@apache.org on 2018/06/29 14:03:11 UTC, 0 replies.
- flink git commit: [FLINK-9627] [table] Extending KafkaJsonTableSource according to comments will result in NPE. - posted by fh...@apache.org on 2018/06/29 16:50:48 UTC, 2 replies.
- [1/2] flink git commit: [FLINK-9672] Fail fatally if job submission fails on added JobGraph signal - posted by tr...@apache.org on 2018/06/30 05:45:19 UTC, 1 replies.
- [2/2] flink git commit: [hotfix] Remove unnecessary logging in Dispatcher#listJobs - posted by tr...@apache.org on 2018/06/30 05:45:20 UTC, 1 replies.
- flink git commit: [FLINK-9532] Flink Overview of Jobs Documentation Incorrect - posted by tr...@apache.org on 2018/06/30 17:54:55 UTC, 0 replies.
- flink git commit: [hotfix] Remove deprecated parameter high-availability.zookeeper.storageDir from doc - posted by tr...@apache.org on 2018/06/30 20:13:53 UTC, 0 replies.
- flink git commit: [FLINK-9684][historyserver] HistoryServer should initialize FileSystem before using it - posted by tr...@apache.org on 2018/06/30 20:34:42 UTC, 1 replies.
- flink git commit: [hotfix] Fixed typo in docs - posted by tr...@apache.org on 2018/06/30 21:10:30 UTC, 0 replies.
- flink git commit: [FLINK-9660] Allow passing custom artifacts to Mesos workers - posted by tr...@apache.org on 2018/06/30 21:22:03 UTC, 0 replies.