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

---

- [flink] branch master updated: [hotfix] remove extra spaces in project's pom.xml - posted by bl...@apache.org on 2019/06/01 03:13:42 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor - posted by tz...@apache.org on 2019/06/01 07:38:44 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor - posted by tz...@apache.org on 2019/06/01 12:45:35 UTC, 0 replies.
- [flink] branch release-1.7 updated: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor - posted by tz...@apache.org on 2019/06/02 05:41:00 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12409][python] Adds from_elements in TableEnvironment - posted by ji...@apache.org on 2019/06/03 06:22:54 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12689][dist] Add flink-azure-fs-hadoop dependency to flink-dist - posted by tr...@apache.org on 2019/06/03 08:27:48 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Remove space in variable name - posted by ch...@apache.org on 2019/06/03 09:39:50 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12687][table-runtime-blink] ByteHashSet is always in dense mode - posted by ja...@apache.org on 2019/06/03 11:37:20 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12229][runtime] Add LazyFromSourcesSchedulingStrategy - posted by tr...@apache.org on 2019/06/03 13:03:37 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12547][blob] Add connection and socket timeouts for the blob client - posted by tr...@apache.org on 2019/06/03 13:05:01 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12547][blob] Add connection and socket timeouts for the blob client - posted by tr...@apache.org on 2019/06/03 13:06:26 UTC, 0 replies.
- [flink] branch master updated: [hotfix][hive] include jdo-api for hive-metastore to enable tests for profile hive-1.2.1 - posted by bl...@apache.org on 2019/06/03 17:13:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12568][hive] Implement OutputFormat to write Hive tables - posted by bl...@apache.org on 2019/06/03 20:38:28 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12712][table] deprecate ExternalCatalog and its subclasses and impls - posted by bl...@apache.org on 2019/06/03 23:17:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12713][table] deprecate descriptor, validator, and factory of ExternalCatalog - posted by bl...@apache.org on 2019/06/03 23:19:39 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12601][table] Wrapping DataStream & DataSet as TableOperations. - posted by dw...@apache.org on 2019/06/04 07:57:41 UTC, 0 replies.
- [flink] branch master updated (0f41719 -> 88c7d82) - posted by dw...@apache.org on 2019/06/04 09:56:47 UTC, 0 replies.
- [flink] 01/03: [hotfix][table-api] Port TableSource specific descriptors - posted by dw...@apache.org on 2019/06/04 09:56:48 UTC, 0 replies.
- [flink] 02/03: [hotfix][table-planner] Fix getting external catalog - posted by dw...@apache.org on 2019/06/04 09:56:49 UTC, 0 replies.
- [flink] 03/03: [FLINK-12604][table] Register a TableSource/Sink directly as CatalogTables - posted by dw...@apache.org on 2019/06/04 09:56:50 UTC, 0 replies.
- [flink] branch master updated (88c7d82 -> a36ec7f) - posted by pn...@apache.org on 2019/06/04 10:12:49 UTC, 0 replies.
- [flink] 01/03: [hotfix][tests] Refactor the creation of InputGate for StreamNetworkBenchmarkEnvironment - posted by pn...@apache.org on 2019/06/04 10:12:50 UTC, 0 replies.
- [flink] 02/03: [FLINK-12201][network, metrics] Introduce InputGateWithMetrics in Task to increment numBytesIn metric - posted by pn...@apache.org on 2019/06/04 10:12:51 UTC, 0 replies.
- [flink] 03/03: [hotfix][network] Drop redundant getSizeUnsafe from Buffer interface - posted by pn...@apache.org on 2019/06/04 10:12:52 UTC, 0 replies.
- [flink] branch master updated (a36ec7f -> 1de854a) - posted by pn...@apache.org on 2019/06/04 12:34:36 UTC, 0 replies.
- [flink] 01/03: [FLINK-11249][kafka] Use custom serializers for NextTransactionalIdHint in 0.11 and universal FlinkKafkaProducer - posted by pn...@apache.org on 2019/06/04 12:34:37 UTC, 0 replies.
- [flink] 02/03: [FLINK-11249][kafka, test] Update Kafka migration resources with new NextTransactionalIdHint serializer - posted by pn...@apache.org on 2019/06/04 12:34:38 UTC, 0 replies.
- [flink] 03/03: [FLINK-11249][kafka] Fix migration from FlinkKafkaProducer0.11 to universal - posted by pn...@apache.org on 2019/06/04 12:34:39 UTC, 0 replies.
- [flink] branch release-1.8 updated (ce73435 -> 61fa100) - posted by pn...@apache.org on 2019/06/04 12:51:56 UTC, 0 replies.
- [flink] 01/02: [hotfix][tests] Introduce NoOpTaskActions for avoiding mock in tests - posted by pn...@apache.org on 2019/06/04 12:51:57 UTC, 0 replies.
- [flink] 02/02: [FLINK-12544][network] Fix the deadlock while releasing memory triggered by multiple threads in SpillableSubpartition - posted by pn...@apache.org on 2019/06/04 12:51:58 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier for simplifying creation of ResultPartitionWriter - posted by tr...@apache.org on 2019/06/04 14:32:13 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12572][hive]Implement HiveInputFormat to read Hive tables - posted by bl...@apache.org on 2019/06/04 17:50:36 UTC, 0 replies.
- [flink] branch master updated (38557bf -> 5f5f02b) - posted by tw...@apache.org on 2019/06/05 06:10:25 UTC, 0 replies.
- [flink] 01/02: [hotfix][core] Add notice about TypeSerializerSnapshot serialization - posted by tw...@apache.org on 2019/06/05 06:10:26 UTC, 0 replies.
- [flink] 02/02: [FLINK-12726][table-common] Fix ANY type serialization - posted by tw...@apache.org on 2019/06/05 06:10:27 UTC, 0 replies.
- [flink] branch master updated (5f5f02b -> 3351993) - posted by tw...@apache.org on 2019/06/05 07:51:21 UTC, 0 replies.
- [flink] 01/02: [FLINK-12254][table] Update TableSource and related interfaces to new type system - posted by tw...@apache.org on 2019/06/05 07:51:22 UTC, 0 replies.
- [flink] 02/02: [FLINK-12254][table] Update TableSink and related interfaces to new type system - posted by tw...@apache.org on 2019/06/05 07:51:23 UTC, 0 replies.
- [flink] branch master updated (3351993 -> 5dfb95c) - posted by pn...@apache.org on 2019/06/05 08:03:04 UTC, 0 replies.
- [flink] 01/09: [hotfix][e2e] Refactor batch wordcount test to use different source types - posted by pn...@apache.org on 2019/06/05 08:03:05 UTC, 0 replies.
- [flink] 02/09: [FLINK-12556][e2e] Add read-only test FileSystem for end-to-end tests - posted by pn...@apache.org on 2019/06/05 08:03:06 UTC, 0 replies.
- [flink] 03/09: [hotfix][e2e] Refactor yarn kerberos test: setup Flink config by one command - posted by pn...@apache.org on 2019/06/05 08:03:07 UTC, 0 replies.
- [flink] 04/09: [hotfix][e2e] Refactor yarn kerberos test: use retry_times to start hadoop cluster - posted by pn...@apache.org on 2019/06/05 08:03:08 UTC, 0 replies.
- [flink] 05/09: [hotfix][e2e] Refactor yarn kerberos test: move Flink tarball creation to a later test step (just before when it's needed) - posted by pn...@apache.org on 2019/06/05 08:03:09 UTC, 0 replies.
- [flink] 06/09: [hotfix][e2e] Refactor yarn kerberos test: group and generalize expected result checks - posted by pn...@apache.org on 2019/06/05 08:03:10 UTC, 0 replies.
- [flink] 07/09: [hotfix][e2e] Refactor yarn kerberos test: move logs copying and printing into a separate function - posted by pn...@apache.org on 2019/06/05 08:03:11 UTC, 0 replies.
- [flink] 08/09: [hotfix][e2e] Refactor docker embedded job test: use pushd/popd instead of cd - posted by pn...@apache.org on 2019/06/05 08:03:12 UTC, 0 replies.
- [flink] 09/09: [FLINK-12556][e2e] Add some end-to-end tests with custom (input) file system plugin - posted by pn...@apache.org on 2019/06/05 08:03:13 UTC, 0 replies.
- [flink-web] branch asf-site updated (722f2d5 -> 8c641e5) - posted by nk...@apache.org on 2019/06/05 08:56:24 UTC, 0 replies.
- [flink-web] 01/03: Rebuild website. - posted by nk...@apache.org on 2019/06/05 08:56:25 UTC, 0 replies.
- [flink-web] 02/03: [Blog] A Deep-Dive into Flink's Network Stack - posted by nk...@apache.org on 2019/06/05 08:56:26 UTC, 0 replies.
- [flink-web] 03/03: Rebuild website. - posted by nk...@apache.org on 2019/06/05 08:56:27 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12650][docs] Redirect Users to Documentation Homepage if Requested Resource Does Not Exist - posted by rm...@apache.org on 2019/06/05 08:57:26 UTC, 0 replies.
- [flink] branch master updated: [hotfix][chck] Remove Nullable annotation from method with primitive return type - posted by tr...@apache.org on 2019/06/05 10:37:20 UTC, 0 replies.
- [flink] branch master updated (1f8c7ff -> 663b40d) - posted by tr...@apache.org on 2019/06/05 12:35:32 UTC, 0 replies.
- [flink] 01/02: [hotfix] Fix the typo issue - posted by tr...@apache.org on 2019/06/05 12:35:33 UTC, 0 replies.
- [flink] 02/02: [FLINK-12603][network] Remove getOwningTaskName method from InputGate - posted by tr...@apache.org on 2019/06/05 12:35:34 UTC, 0 replies.
- [flink] branch master updated (663b40d -> 9efce98) - posted by pn...@apache.org on 2019/06/05 12:59:11 UTC, 0 replies.
- [flink] 01/08: [hotfix][network] Fix JavaDoc of the InputGate - posted by pn...@apache.org on 2019/06/05 12:59:12 UTC, 0 replies.
- [flink] 02/08: [hotfix][network] Simplify SingleInputGate#isFinished - posted by pn...@apache.org on 2019/06/05 12:59:13 UTC, 0 replies.
- [flink] 03/08: [hotfix][network] Define AsyncDataInput interface - posted by pn...@apache.org on 2019/06/05 12:59:14 UTC, 0 replies.
- [flink] 04/08: [hotfix][test] Do not hide original exception in BarrierTrackerTest - posted by pn...@apache.org on 2019/06/05 12:59:15 UTC, 0 replies.
- [flink] 05/08: [hotfix][test] Deduplicate code in BarrerTrackerTest - posted by pn...@apache.org on 2019/06/05 12:59:16 UTC, 0 replies.
- [flink] 06/08: [hotfix][test] Deduplicate code in BarrierBufferTestBase - posted by pn...@apache.org on 2019/06/05 12:59:17 UTC, 0 replies.
- [flink] 07/08: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking - posted by pn...@apache.org on 2019/06/05 12:59:18 UTC, 0 replies.
- [flink] 08/08: [FLINK-12535][test] Drop deprecated blocking CheckpointBarrierHandler#getNext method - posted by pn...@apache.org on 2019/06/05 12:59:19 UTC, 0 replies.
- [flink] branch master updated (9efce98 -> 0bd3cf6) - posted by pn...@apache.org on 2019/06/05 13:00:49 UTC, 0 replies.
- [flink] 01/06: [hotfix][network] Simplify UnionInputGate#isFinished - posted by pn...@apache.org on 2019/06/05 13:00:50 UTC, 0 replies.
- [flink] 02/06: [hotfix][network] Fix InputGate#isAvailable not completed while InputGate#isFinished is true - posted by pn...@apache.org on 2019/06/05 13:00:51 UTC, 0 replies.
- [flink] 03/06: [FLINK-12490][network] Introduce Input interface - posted by pn...@apache.org on 2019/06/05 13:00:52 UTC, 0 replies.
- [flink] 04/06: [FLINK-12490][network] Implement NetworkInput and use it in StreamInputProcessor - posted by pn...@apache.org on 2019/06/05 13:00:53 UTC, 0 replies.
- [flink] 05/06: [hotfix][operator] Reorder if conditions in StreamInputProcessor - posted by pn...@apache.org on 2019/06/05 13:00:54 UTC, 0 replies.
- [flink] 06/06: [hotfix][operator] Remove unused field in StreamInputProcessor - posted by pn...@apache.org on 2019/06/05 13:00:55 UTC, 0 replies.
- [flink] branch master updated (0bd3cf6 -> 772b8ba) - posted by tw...@apache.org on 2019/06/05 14:45:39 UTC, 0 replies.
- [flink] 01/02: [FLINK-12254][table] Update value literals to new type system - posted by tw...@apache.org on 2019/06/05 14:45:40 UTC, 0 replies.
- [flink] 02/02: [FLINK-12254][table] Port and deprecate old types listing - posted by tw...@apache.org on 2019/06/05 14:45:41 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig - posted by ga...@apache.org on 2019/06/05 18:40:46 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig - posted by ga...@apache.org on 2019/06/05 18:42:29 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12734][table-planner-blink] remove getVolcanoPlanner method from FlinkOptimizeContext and make RelNodeBlock not depend on TableEnvironment - posted by ku...@apache.org on 2019/06/06 03:27:34 UTC, 0 replies.
- [flink] branch master updated (13a0900 -> 3508465) - posted by ch...@apache.org on 2019/06/06 08:08:44 UTC, 0 replies.
- [flink] 01/03: [hotfix][yarn][tests] Remove unused field - posted by ch...@apache.org on 2019/06/06 08:08:45 UTC, 0 replies.
- [flink] 02/03: [FLINK-12445][yarn] Disable test timeout - posted by ch...@apache.org on 2019/06/06 08:08:46 UTC, 0 replies.
- [flink] 03/03: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods - posted by ch...@apache.org on 2019/06/06 08:08:47 UTC, 0 replies.
- [flink] branch master updated (3508465 -> e64d070) - posted by ch...@apache.org on 2019/06/06 08:52:41 UTC, 0 replies.
- [flink] 01/02: [hotfix][network] Move partition release under registeredPartitions modification lock in ResultPartitionManager.onConsumedPartition - posted by ch...@apache.org on 2019/06/06 08:52:42 UTC, 0 replies.
- [flink] 02/02: [FLINK-12673][network] Introduce NetworkEnvironment.getUnreleasedPartitions instead of using getResultPartitionManager - posted by ch...@apache.org on 2019/06/06 08:52:43 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12740][tests] Fix unstable SpillableSubpartitionTest - posted by pn...@apache.org on 2019/06/06 09:13:37 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11391] Introduce shuffle master interface - posted by tr...@apache.org on 2019/06/06 09:40:47 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Fix flink-sql-parser can't compile with scala 2.12 - posted by ku...@apache.org on 2019/06/06 12:11:04 UTC, 0 replies.
- [flink] branch master updated (8c3e94c -> ac84e0c) - posted by tr...@apache.org on 2019/06/06 14:15:41 UTC, 0 replies.
- [flink] 01/04: [FLINK-12683] Provide task manager location information for checkpoint coordinator specific log messages - posted by tr...@apache.org on 2019/06/06 14:15:42 UTC, 0 replies.
- [flink] 02/04: [FLINK-12683][chkpt] Simplify task manager location info generation for logging statements - posted by tr...@apache.org on 2019/06/06 14:15:43 UTC, 0 replies.
- [flink] 03/04: [FLINK-12101] Race condition when concurrently running uploaded jars via REST - posted by tr...@apache.org on 2019/06/06 14:15:44 UTC, 0 replies.
- [flink] 04/04: [FLINK-12101] Deduplicate code by introducing ExecutionEnvironment#resolveFactory - posted by tr...@apache.org on 2019/06/06 14:15:45 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12715][hive] fix Hive-1.2.1 build - posted by bl...@apache.org on 2019/06/06 17:25:45 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12756][hive] migrate HiveCatalog from TypeInformation-based old type system to DataType-based new type system - posted by bl...@apache.org on 2019/06/06 17:39:03 UTC, 0 replies.
- [flink] branch master updated: [hotfix][hive] make HiveCatalog's HiveConf and client wrapper private - posted by bl...@apache.org on 2019/06/06 17:53:24 UTC, 0 replies.
- [flink] branch master updated (60d3fbb -> 81d2e35) - posted by dw...@apache.org on 2019/06/06 20:29:31 UTC, 0 replies.
- [flink] 01/04: [FLINK-12737][table-api][table-planner] Port TemporalTableFunctionImpl to java-api module - posted by dw...@apache.org on 2019/06/06 20:29:32 UTC, 0 replies.
- [flink] 02/04: [FLINK-12737][table-planner] Generate unique attributes for aggregations within a single operation rather than globally per TableEnvironment - posted by dw...@apache.org on 2019/06/06 20:29:33 UTC, 0 replies.
- [flink] 03/04: [FLINK-12737][table-planner] Remove getRelNode from TableImpl. - posted by dw...@apache.org on 2019/06/06 20:29:34 UTC, 0 replies.
- [flink] 04/04: [FLINK-12737][table-api][table-planner] Added insertInto method to TableEnvironment - posted by dw...@apache.org on 2019/06/06 20:29:35 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12718][hive] allow users to specify hive-site.xml location to configure hive metastore client in HiveCatalog - posted by bl...@apache.org on 2019/06/06 21:03:21 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12386][hive] Support mapping BinaryType, VarBinaryType, CharType, VarCharType, and DecimalType between Flink and Hive in HiveCatalog - posted by bl...@apache.org on 2019/06/06 22:52:14 UTC, 0 replies.
- [flink] branch master updated: [hotfix][hive] categorize primitive type conversions with AtomicDataType - posted by bl...@apache.org on 2019/06/06 23:58:31 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment-1.5 #302 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2019/06/07 02:50:15 UTC, 0 replies.
- [flink] branch master updated (1354773 -> 9770551) - posted by tr...@apache.org on 2019/06/07 07:24:21 UTC, 0 replies.
- [flink] 01/02: [hotfix][tests] refactor StandaloneJobClusterConfigurationParserFactoryTest to use temporary folder for global Flink configuration - posted by tr...@apache.org on 2019/06/07 07:24:22 UTC, 1 replies.
- [flink] 02/02: [FLINK-12617] [container] StandaloneJobClusterEntrypoint defaults to random JobID for non-HA setups - posted by tr...@apache.org on 2019/06/07 07:24:23 UTC, 1 replies.
- [flink] branch master updated: [FLINK-12643][runtime] Implement ExecutionGraph to FailoverTopology Adapter - posted by ch...@apache.org on 2019/06/07 08:08:55 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12775][build] Bump flink-shaded version to 7.0 - posted by ch...@apache.org on 2019/06/07 08:16:35 UTC, 0 replies.
- [flink] branch release-1.8 updated (c7bf460 -> 68910fa) - posted by tr...@apache.org on 2019/06/07 08:49:16 UTC, 0 replies.
- [flink] branch master updated (eaaf4fb -> 2ea0aba) - posted by dw...@apache.org on 2019/06/07 08:53:05 UTC, 0 replies.
- [flink] 01/04: [hotfix][datastream, core] Move StreamTransformation to flink-core - posted by dw...@apache.org on 2019/06/07 08:53:06 UTC, 0 replies.
- [flink] 02/04: [hotfix][table-api] Rename TableOperation to QueryTableOperation - posted by dw...@apache.org on 2019/06/07 08:53:07 UTC, 0 replies.
- [flink] 03/04: [hotfix][table-api] Renamed methods of TableOperationsVisitor - posted by dw...@apache.org on 2019/06/07 08:53:08 UTC, 0 replies.
- [flink] 04/04: [FLINK-12690][table-api] Introduce a Planner interface - posted by dw...@apache.org on 2019/06/07 08:53:09 UTC, 0 replies.
- [flink] branch master updated (2ea0aba -> ef150ee) - posted by tw...@apache.org on 2019/06/07 09:29:33 UTC, 0 replies.
- [flink] 01/03: [FLINK-12769][table-common] Introduce a symbol type - posted by tw...@apache.org on 2019/06/07 09:29:34 UTC, 0 replies.
- [flink] 02/03: [FLINK-12769][table-common] Simplify expression design for symbols - posted by tw...@apache.org on 2019/06/07 09:29:35 UTC, 0 replies.
- [flink] 03/03: [hotfix][table-common] Introduce an across-catalog object identifier - posted by tw...@apache.org on 2019/06/07 09:29:36 UTC, 0 replies.
- [flink] branch master updated (ef150ee -> a0cf205) - posted by tw...@apache.org on 2019/06/07 10:11:32 UTC, 0 replies.
- [flink] 01/03: [FLINK-12254][table] Update field references to new type system - posted by tw...@apache.org on 2019/06/07 10:11:33 UTC, 0 replies.
- [flink] 02/03: [hotfix][table] Rename to ValueLiteralExpession.getOutputDataType - posted by tw...@apache.org on 2019/06/07 10:11:34 UTC, 0 replies.
- [flink] 03/03: [hotfix][table] Rename to TypeLiteralExpession.getOutputDataType - posted by tw...@apache.org on 2019/06/07 10:11:35 UTC, 0 replies.
- [flink] branch master updated (a0cf205 -> 29f4e52) - posted by pn...@apache.org on 2019/06/07 12:44:39 UTC, 0 replies.
- [flink] 01/04: [FLINK-12513][e2e] Delegate Flink lib folder clean up to the test runner - posted by pn...@apache.org on 2019/06/07 12:44:40 UTC, 0 replies.
- [flink] 02/04: [FLINK-12513][e2e] Introduce on exit callback registry - posted by pn...@apache.org on 2019/06/07 12:44:41 UTC, 0 replies.
- [flink] 03/04: [hotfix][e2e] Add retries for downloading Kafka distribution - posted by pn...@apache.org on 2019/06/07 12:44:42 UTC, 0 replies.
- [flink] 04/04: [hotfix][e2e] Refactoring Flink config edits - posted by pn...@apache.org on 2019/06/07 12:44:43 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Fix typo in javadoc of StateSnapshotContextSynchronousImpl - posted by bl...@apache.org on 2019/06/07 21:21:50 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog - posted by bl...@apache.org on 2019/06/07 23:58:08 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment-1.5 #303 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2019/06/08 02:19:28 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12685][table-planner-blink] Supports UNNEST query in blink planner - posted by ku...@apache.org on 2019/06/08 09:14:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12588][python] Add TableSchema for Python Table API. - posted by ji...@apache.org on 2019/06/09 20:28:19 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12757][python] Improves the word_count example to use the descriptor API - posted by ji...@apache.org on 2019/06/10 06:09:02 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12789][table] Fix java docs in UserDefinedAggregateFunction. - posted by ji...@apache.org on 2019/06/10 08:59:08 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12780][hive] use Flink's LogicalTypeRoot for type comparison in HiveTypeUtil - posted by bl...@apache.org on 2019/06/10 16:49:49 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12772][hive] Support mapping ARRAY, MAP, ROW (STRUCT) between Flink and Hive in HiveCatalog - posted by bl...@apache.org on 2019/06/10 17:42:38 UTC, 0 replies.
- [flink] branch master updated (918dafb -> a21cc24) - posted by ku...@apache.org on 2019/06/11 00:55:26 UTC, 0 replies.
- [flink] 01/02: [hotfix][table-common] Add util method to logical RowType - posted by ku...@apache.org on 2019/06/11 00:55:27 UTC, 0 replies.
- [flink] 02/02: [FLINK-12443][table-planner-blink] Replace InternalType with LogicalType in blink planner - posted by ku...@apache.org on 2019/06/11 00:55:28 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12787][python] Allow to specify directory in option -pyfs - posted by ji...@apache.org on 2019/06/11 03:02:20 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12402][table] Make validation error message in ResolveCallByArguments more user friendly - posted by dw...@apache.org on 2019/06/11 07:11:21 UTC, 0 replies.
- [flink] branch master updated: [FLINK-10455][Connectors/Kafka] Ensure all the KafkaProducers closed on an exception - posted by pn...@apache.org on 2019/06/11 08:48:03 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12795][table-planner-blink] Extracted creation & configuration of FrameworkConfig & RelBuilder to separate class in blink planner - posted by ku...@apache.org on 2019/06/11 09:22:03 UTC, 0 replies.
- [flink] branch master updated (774ecea -> c104daf) - posted by tr...@apache.org on 2019/06/11 10:04:13 UTC, 0 replies.
- [flink] 01/03: [hotfix][network] Add NetworkEnviroment.fromConfiguration factory method - posted by tr...@apache.org on 2019/06/11 10:04:14 UTC, 0 replies.
- [flink] 02/03: [FLINK-11392][network] Introduce ShuffleEnvironment interface - posted by tr...@apache.org on 2019/06/11 10:04:15 UTC, 0 replies.
- [flink] 03/03: [FLINK-11392][network] Rename NetworkEnviroment to NettyShuffleEnviroment - posted by tr...@apache.org on 2019/06/11 10:04:16 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12178] Remove legacy Scheduler - posted by tr...@apache.org on 2019/06/11 11:50:37 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12646][runtime] Change the test IP of RestClientTest to 240.0.0.0 - posted by tr...@apache.org on 2019/06/11 12:58:01 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12646][runtime] Change the test IP of RestClientTest to 240.0.0.0 - posted by tr...@apache.org on 2019/06/11 12:59:12 UTC, 0 replies.
- [flink] branch release-1.7 updated: [FLINK-12646][runtime] Change the test IP of RestClientTest to 240.0.0.0 - posted by tr...@apache.org on 2019/06/11 13:00:21 UTC, 0 replies.
- [flink-web] branch asf-site updated (8c641e5 -> aa500dc) - posted by fh...@apache.org on 2019/06/11 13:03:42 UTC, 0 replies.
- [flink-web] 01/02: Add Klaviyo to the PoweredBy page. - posted by fh...@apache.org on 2019/06/11 13:03:43 UTC, 0 replies.
- [flink-web] 02/02: Rebuild website - posted by fh...@apache.org on 2019/06/11 13:03:44 UTC, 3 replies.
- [flink] branch master updated: [FLINK-12583][python] Add all format support align with the Java Table API. - posted by ji...@apache.org on 2019/06/12 03:40:12 UTC, 0 replies.
- [flink] branch release-1.7 updated: [FLINK-10455][Connectors/Kafka] Ensure all the KafkaProducers closed on an exception - posted by pn...@apache.org on 2019/06/12 09:26:33 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-10455][Connectors/Kafka] Ensure all the KafkaProducers closed on an exception - posted by pn...@apache.org on 2019/06/12 09:26:33 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12401][table] Support incremental emit under AccRetract mode for non-window streaming FlatAggregate on Table API. This closes #8550 - posted by ji...@apache.org on 2019/06/12 09:47:43 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11876] Introduce new InputSelectable, BoundedOneInput and BoundedMultiInput interfaces for stream operators - posted by pn...@apache.org on 2019/06/12 09:59:40 UTC, 0 replies.
- [flink] branch master updated (67fbe86 -> 48b54e3) - posted by pn...@apache.org on 2019/06/12 10:40:22 UTC, 0 replies.
- [flink] 01/03: [FLINK-11877][runtime] Introduce new BarrierDiscarder class - posted by pn...@apache.org on 2019/06/12 10:40:23 UTC, 0 replies.
- [flink] 02/03: [FLINK-11877][runtime] Abstract AbstractTwoInputStreamTask from TwoInputStreamTask - posted by pn...@apache.org on 2019/06/12 10:40:24 UTC, 0 replies.
- [flink] 03/03: [FLINK-11877][runtime] Implement the runtime handling of the InputSelectable interface - posted by pn...@apache.org on 2019/06/12 10:40:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12636] Check if proper JAR file in JobWithJars#checkJarFile - posted by tr...@apache.org on 2019/06/12 11:30:39 UTC, 0 replies.
- [flink] branch master updated: [hotfix][py] Fix typo in Python examples - posted by tr...@apache.org on 2019/06/12 13:34:03 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12727][hive] Make HiveTableOutputFormat support writing partitioned tables - posted by bl...@apache.org on 2019/06/12 18:06:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12801][table-planner-blink] Set parallelism for batch SQL - posted by ja...@apache.org on 2019/06/13 02:12:13 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-11107] [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured - posted by tz...@apache.org on 2019/06/13 03:58:37 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11107] [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured - posted by tz...@apache.org on 2019/06/13 04:00:15 UTC, 0 replies.
- [flink] branch master updated (c2316f6 -> 147022c) - posted by ja...@apache.org on 2019/06/13 06:39:19 UTC, 0 replies.
- [flink] 01/04: [FLINK-12708][table] Introduce InputFormatTableSource and make blink&flink planner support it - posted by ja...@apache.org on 2019/06/13 06:39:20 UTC, 0 replies.
- [flink] 02/04: [FLINK-12708][table] Introduce OutputFormatTableSink and make blink&flink planner support it - posted by ja...@apache.org on 2019/06/13 06:39:21 UTC, 0 replies.
- [flink] 03/04: [FLINK-12708][table] Introduce LookupableTableSource and make blink planner support it - posted by ja...@apache.org on 2019/06/13 06:39:22 UTC, 0 replies.
- [flink] 04/04: [FLINK-12708][table] Expose getTableStats() interface in TableSource - posted by ja...@apache.org on 2019/06/13 06:39:23 UTC, 0 replies.
- [flink] branch master updated (147022c -> 8be60e6) - posted by tr...@apache.org on 2019/06/13 07:09:01 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Use proper template format substitute for Preconditions - posted by ch...@apache.org on 2019/06/13 07:47:03 UTC, 0 replies.
- [flink] branch master updated (be419e2 -> 0256125) - posted by ch...@apache.org on 2019/06/13 07:51:58 UTC, 0 replies.
- [flink] branch master updated (0256125 -> 00d90a4) - posted by tr...@apache.org on 2019/06/13 08:56:38 UTC, 0 replies.
- [flink] branch master updated (00d90a4 -> 9e6ff81) - posted by pn...@apache.org on 2019/06/13 10:08:53 UTC, 0 replies.
- [flink] 01/10: [hotfix][dist] Rename FLINK_ROOT*_DIR to FLINK_HOME - posted by pn...@apache.org on 2019/06/13 10:08:54 UTC, 0 replies.
- [flink] 02/10: [hotfix][dist] Export variables in only one place (config.sh) - posted by pn...@apache.org on 2019/06/13 10:08:55 UTC, 0 replies.
- [flink] 03/10: [hotfix][runtime] Deduplicate and simplify environment variables handling in FlinkDistributionOverlay - posted by pn...@apache.org on 2019/06/13 10:08:56 UTC, 0 replies.
- [flink] 04/10: [hotfix][core] Deduplicate code and unify method names in GlobalConfiguration - posted by pn...@apache.org on 2019/06/13 10:08:57 UTC, 0 replies.
- [flink] 05/10: [FLINK-12143] Distribute FLINK_PLUGINS_DIR the same way as FLINK_LIB_DIR is distributed - posted by pn...@apache.org on 2019/06/13 10:08:58 UTC, 0 replies.
- [flink] 06/10: [FLINK-12143][dist] Ship plugins in the cluster the same way as lib jars - posted by pn...@apache.org on 2019/06/13 10:08:59 UTC, 0 replies.
- [flink] 07/10: [hotfix][dist] Use proper flink-python jar match pattern in pyflink.bat for Windows (FLINK-12409) - posted by pn...@apache.org on 2019/06/13 10:09:00 UTC, 0 replies.
- [flink] 08/10: [FLINK-12143] PluginLoader: use system level always parents first patterns in class loading - posted by pn...@apache.org on 2019/06/13 10:09:01 UTC, 0 replies.
- [flink] 09/10: [FLINK-12143][e2e] Introduce plugins helper function and test cleanup - posted by pn...@apache.org on 2019/06/13 10:09:02 UTC, 0 replies.
- [flink] 10/10: [FLINK-12143][e2e] Change end-to-end tests with file system to use plugins mechanism - posted by pn...@apache.org on 2019/06/13 10:09:03 UTC, 0 replies.
- [flink] branch master updated: [hotfix][FLINK-12830][table-planner] Fix fragile TableSinkITCase#testBoundedTableSink test - posted by ja...@apache.org on 2019/06/13 10:31:30 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12799][table] Improve expression based TableSchema extraction from DataStream/DataSet - posted by dw...@apache.org on 2019/06/13 11:32:46 UTC, 0 replies.
- [flink] branch master updated: [hotfix][runtime] Fix result partition redundantly added in TestingSchedulingTopology - posted by tr...@apache.org on 2019/06/13 12:04:40 UTC, 0 replies.
- [flink-web] branch asf-site updated (aa500dc -> 29579a5) - posted by fh...@apache.org on 2019/06/13 12:09:26 UTC, 0 replies.
- [flink-web] 01/02: Add OPPO to PowerBy page - posted by fh...@apache.org on 2019/06/13 12:09:27 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12163] User correct ClassLoader for Hadoop Writable TypeInfo - posted by al...@apache.org on 2019/06/13 12:25:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12088][table-runtime-blink] Introduce unbounded streaming inner/left/right/full join operator - posted by ja...@apache.org on 2019/06/13 12:51:30 UTC, 0 replies.
- [flink] branch master updated (da6d93c -> b86ba3b) - posted by ch...@apache.org on 2019/06/13 13:57:00 UTC, 0 replies.
- [flink] 01/02: [hotfix][docs] Minor clarification - posted by ch...@apache.org on 2019/06/13 13:57:01 UTC, 0 replies.
- [flink] 02/02: [FLINK-12667][runtime] Add JobID to TaskExecutorGateway#releasePartitions - posted by ch...@apache.org on 2019/06/13 13:57:02 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12822] Add explicit transformer from SerializableOptional to Optional - posted by tr...@apache.org on 2019/06/13 15:36:23 UTC, 0 replies.
- [flink] branch master updated (27a1c41 -> 8a39c84) - posted by ga...@apache.org on 2019/06/13 19:11:33 UTC, 0 replies.
- [flink] 01/02: [FLINK-12608][runtime] Add getVertexOrThrow and getResultPartitionOrThrow to SchedulingTopology - posted by ga...@apache.org on 2019/06/13 19:11:34 UTC, 0 replies.
- [flink] 02/02: [FLINK-12372] [runtime] implement ExecutionSlotAllocator - posted by ga...@apache.org on 2019/06/13 19:11:35 UTC, 0 replies.
- [flink] branch master updated: [hotfix][tests] Upgrade zookeeper package to 3.4.9-3+deb9u2 - posted by ga...@apache.org on 2019/06/13 20:06:59 UTC, 0 replies.
- [flink] branch master updated (bdcef35 -> c539333) - posted by pn...@apache.org on 2019/06/14 06:34:12 UTC, 0 replies.
- [flink] 01/03: [hotfix][tests] SynchronousCheckpointITCase: set test run timeout limit - posted by pn...@apache.org on 2019/06/14 06:34:13 UTC, 0 replies.
- [flink] 02/03: [FLINK-12313][tests] Workaround for SynchronousCheckpointITCase to avoid race condition - posted by pn...@apache.org on 2019/06/14 06:34:14 UTC, 0 replies.
- [flink] 03/03: [hotfix][tests] Simplify SynchronousCheckpointITCase - posted by pn...@apache.org on 2019/06/14 06:34:15 UTC, 0 replies.
- [flink] branch master updated (c539333 -> 3fa062a) - posted by tr...@apache.org on 2019/06/14 06:46:34 UTC, 0 replies.
- [flink] branch master updated (3fa062a -> 66b38ac) - posted by tr...@apache.org on 2019/06/14 07:20:49 UTC, 0 replies.
- [flink] 01/02: [FLINK-12670][runtime] Implement FailureRateRestartBackoffTimeStrategy - posted by tr...@apache.org on 2019/06/14 07:20:50 UTC, 0 replies.
- [flink] 02/02: [FLINK-12669][runtime] Implement FixedDelayRestartBackoffTimeStrategy - posted by tr...@apache.org on 2019/06/14 07:20:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12835][tests] Fix wrong conversion of ManualClock bug - posted by tr...@apache.org on 2019/06/14 07:28:47 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12835][tests] Fix wrong conversion of ManualClock bug - posted by tr...@apache.org on 2019/06/14 07:32:09 UTC, 0 replies.
- [flink] branch release-1.7 updated: [FLINK-12835][tests] Fix wrong conversion of ManualClock bug - posted by tr...@apache.org on 2019/06/14 07:34:42 UTC, 0 replies.
- [flink] branch master updated (e3c6885 -> 51724b7) - posted by dw...@apache.org on 2019/06/14 07:51:58 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12803][python] Correct the package name for python API - posted by ji...@apache.org on 2019/06/14 09:08:37 UTC, 0 replies.
- [flink] branch master updated: Revert "[FLINK-12143][e2e] Change end-to-end tests with file system to use plugins mechanism" - posted by pn...@apache.org on 2019/06/14 09:37:41 UTC, 0 replies.
- [flink] branch master updated (24246b8 -> 9e60763) - posted by ch...@apache.org on 2019/06/14 10:35:53 UTC, 0 replies.
- [flink] 01/02: [FLINK-12774][build] Pin build-helper-maven-plugin version to 1.7 - posted by ch...@apache.org on 2019/06/14 10:35:54 UTC, 0 replies.
- [flink] 02/02: [hotfix][build] Document required plugin execution order - posted by ch...@apache.org on 2019/06/14 10:35:55 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12716][python] Add an interactive shell for Python Table API - posted by ji...@apache.org on 2019/06/14 11:55:13 UTC, 0 replies.
- [flink] branch master updated (76ec612 -> e3612c5) - posted by tr...@apache.org on 2019/06/14 12:36:48 UTC, 0 replies.
- [flink] 01/02: [FLINK-11059][runtime] Add slot reconciliation between JM and TE - posted by tr...@apache.org on 2019/06/14 12:36:49 UTC, 2 replies.
- [flink] 02/02: [hotfix] Fix checkstyle violations in SlotPoolImplTest - posted by tr...@apache.org on 2019/06/14 12:36:50 UTC, 1 replies.
- [flink] branch release-1.8 updated (685d49b -> 7826142) - posted by tr...@apache.org on 2019/06/14 12:37:37 UTC, 0 replies.
- [flink] branch release-1.7 updated (3671388 -> 63d0ae6) - posted by tr...@apache.org on 2019/06/14 12:38:00 UTC, 0 replies.
- [flink] 02/02: [hotfix] Fix checkstyle violations in SlotPoolTest - posted by tr...@apache.org on 2019/06/14 12:38:02 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12719][python] Add the Python catalog API - posted by ji...@apache.org on 2019/06/14 14:21:21 UTC, 0 replies.
- [flink] branch master updated (e087c1e -> 22305ef) - posted by ch...@apache.org on 2019/06/14 18:23:13 UTC, 0 replies.
- [flink] 01/02: [FLINK-12851][travis] Move gelly/kafka to separate profile - posted by ch...@apache.org on 2019/06/14 18:23:14 UTC, 0 replies.
- [flink] 02/02: Revert "[hotfix][travis] Run pre-commit e2e tests in compile stage" - posted by ch...@apache.org on 2019/06/14 18:23:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12647][network] Make partition release on consumption optional - posted by ch...@apache.org on 2019/06/14 18:30:23 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12705][hive] Allow user to specify the Hive version in use - posted by bl...@apache.org on 2019/06/14 19:39:28 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12297] Make Java ClosureCleaner recursive to handle nested functions - posted by al...@apache.org on 2019/06/15 06:47:27 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12297] Make Java ClosureCleaner recursive to handle nested functions - posted by al...@apache.org on 2019/06/15 06:57:20 UTC, 0 replies.
- [flink] branch master updated (68cc21e -> 8558548) - posted by se...@apache.org on 2019/06/15 14:04:48 UTC, 0 replies.
- [flink] 01/05: [FLINK-12405] [runtime] Introduce BLOCKING_PERSISTENT ResultPartition type - posted by se...@apache.org on 2019/06/15 14:04:49 UTC, 0 replies.
- [flink] 02/05: [hotfix] [runtime] Improve JavaDoc comments for ResultPartitionType - posted by se...@apache.org on 2019/06/15 14:04:50 UTC, 0 replies.
- [flink] 03/05: [FLINK-12405] [DataSet] Introduce a way to generate BLOCKING_PERSISTENT ResultPartition through DataSet API - posted by se...@apache.org on 2019/06/15 14:04:51 UTC, 0 replies.
- [flink] 04/05: [hotfix] Reduce some code duplication in JobGraphGeneratorTest - posted by se...@apache.org on 2019/06/15 14:04:52 UTC, 0 replies.
- [flink] 05/05: [hotfix] Small code cleanups for Persistent Intermediate Results - posted by se...@apache.org on 2019/06/15 14:04:53 UTC, 0 replies.
- [flink] branch master updated (8558548 -> 11a7b3f) - posted by nk...@apache.org on 2019/06/15 23:03:00 UTC, 0 replies.
- [flink] 01/09: [hotfix][tests] remove rogue comment in common_ssl.sh - posted by nk...@apache.org on 2019/06/15 23:03:01 UTC, 0 replies.
- [flink] 02/09: [hotfix][docs] make LineBreakElement also implement InlineElement - posted by nk...@apache.org on 2019/06/15 23:03:02 UTC, 0 replies.
- [flink] 03/09: [FLINK-12838][network] netty-fy SSL configuration - posted by nk...@apache.org on 2019/06/15 23:03:03 UTC, 0 replies.
- [flink] 04/09: [FLINK-9816][network] allow configuring the SSL engine provider - posted by nk...@apache.org on 2019/06/15 23:03:04 UTC, 0 replies.
- [flink] 05/09: [FLINK-12839][dist] package flink-shaded-netty-tcnative-dynamic into opt/ - posted by nk...@apache.org on 2019/06/15 23:03:05 UTC, 0 replies.
- [flink] 06/09: [FLINK-12517][tests] enable openSSL tests via openSSL-enhanced flink-shaded version - posted by nk...@apache.org on 2019/06/15 23:03:06 UTC, 0 replies.
- [flink] 07/09: [FLINK-12518][tests][e2e] enable openSSL for test_streaming_file_sink - posted by nk...@apache.org on 2019/06/15 23:03:07 UTC, 0 replies.
- [flink] 08/09: [hotfix][docs] correctly escape ampersands - posted by nk...@apache.org on 2019/06/15 23:03:08 UTC, 0 replies.
- [flink] 09/09: [FLINK-12446][docs] update openSSL option documentation - posted by nk...@apache.org on 2019/06/15 23:03:09 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12857][table-common] move FilterableTableSource into flink-table-common - posted by ku...@apache.org on 2019/06/17 03:28:26 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12742][table-planner] Add insert into partition grammar as hive dialect - posted by ku...@apache.org on 2019/06/17 04:06:36 UTC, 0 replies.
- [flink] branch master updated: FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream - posted by al...@apache.org on 2019/06/17 11:16:47 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12823][datastream] Add ShuffleMode property to PartitionTransformation - posted by al...@apache.org on 2019/06/17 11:41:38 UTC, 0 replies.
- [flink] branch master updated: [hotfix][akka] Replace deprecated ExtensionKey - posted by tr...@apache.org on 2019/06/17 12:12:16 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL - posted by ja...@apache.org on 2019/06/17 12:18:09 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12806] Remove beta feature remark from the Universal Kafka connector - posted by pn...@apache.org on 2019/06/17 13:23:51 UTC, 0 replies.
- [flink] branch master updated: [hotfix][table-common] Move function definitions to functions package - posted by tw...@apache.org on 2019/06/17 14:27:53 UTC, 0 replies.
- [flink] branch master updated (290e218 -> 59b9a93) - posted by nk...@apache.org on 2019/06/17 15:12:07 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12711][table] Refactor function lookup - posted by tw...@apache.org on 2019/06/17 15:23:04 UTC, 0 replies.
- [flink] branch master updated (b88f23c -> 3d8889e) - posted by bl...@apache.org on 2019/06/17 17:52:55 UTC, 0 replies.
- [flink] 01/02: [FLINK-12853][table-api][table-planner] TableSourceUtils#validateTableSource method to common module - posted by bl...@apache.org on 2019/06/17 17:52:56 UTC, 0 replies.
- [flink] 02/02: [FLINK-12657][hive] Integrate Flink with Hive UDF - posted by bl...@apache.org on 2019/06/17 17:52:57 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12871][docs] fix separate keypass not compatible with PKCS12 stores - posted by nk...@apache.org on 2019/06/17 22:41:13 UTC, 0 replies.
- [flink] branch release-1.7 updated: [FLINK-12871][docs] fix separate keypass not compatible with PKCS12 stores - posted by nk...@apache.org on 2019/06/17 22:43:01 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12779][table] Avoid field conflicts when generate field names for non-composite Typeinformation - posted by ji...@apache.org on 2019/06/18 00:54:44 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12864][python][tests] Improves the Python Table API test cases performance - posted by ji...@apache.org on 2019/06/18 00:59:04 UTC, 0 replies.
- [flink] branch master updated: [hotfix][python][test] fix IDE test problems and unified assertion usage - posted by ji...@apache.org on 2019/06/18 08:38:28 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12867][sql-parser] Add insert overwrite grammar as HIVE dialect - posted by ku...@apache.org on 2019/06/18 10:06:16 UTC, 0 replies.
- [flink] branch master updated (14c140f -> 58b8cb0) - posted by al...@apache.org on 2019/06/18 11:29:34 UTC, 0 replies.
- [flink] 01/08: [FLINK-12686][datastream] Remove StreamExecutionEnvironment from StreamNode - posted by al...@apache.org on 2019/06/18 11:29:35 UTC, 0 replies.
- [flink] 02/08: [FLINK-12686][datastream] Remove StreamExecutionEnvironment from StreamGraph - posted by al...@apache.org on 2019/06/18 11:29:36 UTC, 0 replies.
- [flink] 03/08: [FLINK-12686][datastream] Remove StreamExecutionEnvironment from StreamGraphGenerator - posted by al...@apache.org on 2019/06/18 11:29:37 UTC, 0 replies.
- [flink] 04/08: [FLINK-12686][datastream] Add StreamExecutionEnvironment.getStreamGraph(name) - posted by al...@apache.org on 2019/06/18 11:29:38 UTC, 0 replies.
- [flink] 05/08: [FLINK-12686][datastream] Configure co-location group of iteration nodes in StreamGraph instread of in StreamingJobGraphGenerator - posted by al...@apache.org on 2019/06/18 11:29:39 UTC, 0 replies.
- [flink] 06/08: [FLINK-12832][datastream] Make slot sharing configurable in StreamGraphGenerator - posted by al...@apache.org on 2019/06/18 11:29:40 UTC, 0 replies.
- [flink] 07/08: [FLINK-12832][datastream] Make ScheduleMode configurable in StreamGraphGenerator - posted by al...@apache.org on 2019/06/18 11:29:41 UTC, 0 replies.
- [flink] 08/08: [FLINK-12832][datastream] Use new StreamGraphGenerator configurability in Blink Table Runner - posted by al...@apache.org on 2019/06/18 11:29:42 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12711][table] Separate function implementation and definition - posted by tw...@apache.org on 2019/06/18 14:09:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions - posted by bl...@apache.org on 2019/06/18 20:04:41 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service - posted by bl...@apache.org on 2019/06/18 22:52:06 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12874][table-common] Improve the semantics of zero length strings - posted by tw...@apache.org on 2019/06/19 08:15:01 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12878][travis] Move flink-table-planner-blink & flink-table-runtime-blink to separate profile - posted by ku...@apache.org on 2019/06/19 08:39:41 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12364] Introduce CheckpointFailureManager for centralized checkpoint failure handling - posted by sr...@apache.org on 2019/06/19 09:01:16 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12720][python][docs] Add the Python Table API Sphinx docs - posted by ji...@apache.org on 2019/06/19 09:41:32 UTC, 0 replies.
- [flink] branch master updated (d70e8e2 -> b3b7837) - posted by tw...@apache.org on 2019/06/19 10:04:06 UTC, 0 replies.
- [flink] 01/05: [hotfix][table] Replace constructor of expressions with util calls - posted by tw...@apache.org on 2019/06/19 10:04:07 UTC, 0 replies.
- [flink] 02/05: [hotfix][table] Refactor expression visitors to common naming scheme - posted by tw...@apache.org on 2019/06/19 10:04:08 UTC, 0 replies.
- [flink] 03/05: [FLINK-12710][table] Rename CallExpression to UnresolvedCallExpression - posted by tw...@apache.org on 2019/06/19 10:04:09 UTC, 0 replies.
- [flink] 04/05: [FLINK-12710][table] Rename ApiExpressionUtils.call() to unresolvedCall() - posted by tw...@apache.org on 2019/06/19 10:04:10 UTC, 0 replies.
- [flink] 05/05: [hotfix][table] Add a summary method to expressions - posted by tw...@apache.org on 2019/06/19 10:04:11 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12862][coordination] Remove legacy QuarantineHandler/-Monitor - posted by ch...@apache.org on 2019/06/19 11:07:11 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12861][coordination] Remove legacy ListeningBehaviour - posted by ch...@apache.org on 2019/06/19 11:07:50 UTC, 0 replies.
- [flink] branch master updated (2f13594 -> b1d5bf9) - posted by pn...@apache.org on 2019/06/19 11:17:11 UTC, 0 replies.
- [flink] 01/02: [FLINK-12143][runtime] Workaround for dynamic class loading in FS creation: set thread context class loader to plugin's class loader - posted by pn...@apache.org on 2019/06/19 11:17:12 UTC, 0 replies.
- [flink] 02/02: Revert "Revert "[FLINK-12143][e2e] Change end-to-end tests with file system to use plugins mechanism"" - posted by pn...@apache.org on 2019/06/19 11:17:13 UTC, 0 replies.
- [flink] branch master updated: [FLINK-10984][build] Remove flink-shaded-hadoop(-uber) modules - posted by ch...@apache.org on 2019/06/19 11:31:24 UTC, 0 replies.
- [flink] branch 12903 created (now 281d621) - posted by ch...@apache.org on 2019/06/19 12:02:00 UTC, 0 replies.
- [flink] 01/01: [FLINK-12903][py] Remove old Python APIs - posted by ch...@apache.org on 2019/06/19 12:02:01 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12257][table-api][table-planner] Instantiate TableSource from CatalogTable - posted by dw...@apache.org on 2019/06/19 12:41:20 UTC, 0 replies.
- [flink] branch master updated: [hotfix][streaming] Report correct value of currentProcessingTime in the exception - posted by pn...@apache.org on 2019/06/19 14:09:01 UTC, 0 replies.
- [flink] branch master updated (d79a377 -> 0afd7bc) - posted by ch...@apache.org on 2019/06/19 14:09:23 UTC, 0 replies.
- [flink] 01/02: [hotfix][network][tests] Add new unit tests for ReleaseOnConsumptionResultPartition - posted by ch...@apache.org on 2019/06/19 14:09:24 UTC, 0 replies.
- [flink] 02/02: [FLINK-12843][network] Refactor the pin logic in ReleaseOnConsumptionResultPartition - posted by ch...@apache.org on 2019/06/19 14:09:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12264][runtime] Remove unused methods in ExecutionGraphTestUtils - posted by ch...@apache.org on 2019/06/19 14:20:39 UTC, 0 replies.
- [flink] branch master updated (bc9c7a3 -> 22d84de) - posted by ch...@apache.org on 2019/06/19 14:25:58 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Fix error message in BatchTableSourceScan & StreamTableSourceScan - posted by dw...@apache.org on 2019/06/19 14:37:34 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12877][table][hive] Unify catalog database implementations - posted by bl...@apache.org on 2019/06/19 19:35:21 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF - posted by bl...@apache.org on 2019/06/19 20:39:20 UTC, 0 replies.
- [flink] branch master updated: [hotfix] fix imports of CatalogDatabaseImpl - posted by bl...@apache.org on 2019/06/19 22:53:56 UTC, 0 replies.
- [flink] branch master updated: [hotfix] use CatalogDatabaseImpl in CatalogStructureBuilder - posted by bl...@apache.org on 2019/06/19 23:29:46 UTC, 0 replies.
- buildbot failure in on flink-docs-master - posted by bu...@apache.org on 2019/06/20 00:26:49 UTC, 0 replies.
- buildbot failure in on flink-docs-release-1.8 - posted by bu...@apache.org on 2019/06/20 01:19:42 UTC, 0 replies.
- [flink] branch master updated: [hotfix][FLINK-12907][table-planner-blink] Adds override modifier to methods of MockTableSink to make scala 2.12 compiler pass - posted by ja...@apache.org on 2019/06/20 01:32:30 UTC, 0 replies.
- buildbot failure in on flink-docs-release-1.7 - posted by bu...@apache.org on 2019/06/20 02:20:16 UTC, 0 replies.
- [flink] branch master updated (671ac18 -> 829146d) - posted by tz...@apache.org on 2019/06/20 02:21:09 UTC, 0 replies.
- [flink] 01/05: [FLINK-11869] Make buffer size in checkpoint stream factory configurable - posted by tz...@apache.org on 2019/06/20 02:21:10 UTC, 0 replies.
- [flink] 02/05: [FLINK-11869] Improve description and variable naming for filesystem checkpoints stream write buffer size config - posted by tz...@apache.org on 2019/06/20 02:21:11 UTC, 0 replies.
- [flink] 03/05: [FLINK-11947] Support MapState value schema evolution for RocksDB - posted by tz...@apache.org on 2019/06/20 02:21:12 UTC, 0 replies.
- [flink] 04/05: [FLINK-11947] Fix exposure leak of NestedSerializerSnapshotsDelegate - posted by tz...@apache.org on 2019/06/20 02:21:13 UTC, 0 replies.
- [flink] 05/05: [FLINK-11947] Improve readability and fix raw type usage for RocksDBKeyedStateBackend#migrateStateValues - posted by tz...@apache.org on 2019/06/20 02:21:14 UTC, 0 replies.
- buildbot success in on flink-docs-release-1.7 - posted by bu...@apache.org on 2019/06/20 03:49:07 UTC, 0 replies.
- buildbot success in on flink-docs-master - posted by bu...@apache.org on 2019/06/20 04:59:28 UTC, 0 replies.
- [flink] branch master updated (829146d -> 800fe61) - posted by ku...@apache.org on 2019/06/20 05:54:07 UTC, 0 replies.
- [flink] branch master updated: [hotfix][table] fix imports of RexNodeExtractor. - posted by ku...@apache.org on 2019/06/20 07:39:00 UTC, 0 replies.
- [flink] branch 12903 deleted (was 281d621) - posted by ch...@apache.org on 2019/06/20 08:31:12 UTC, 0 replies.
- [flink] branch release-1.8 updated: [FLINK-12896][rest] Use JobID parameter for archiving - posted by ch...@apache.org on 2019/06/20 08:36:50 UTC, 0 replies.
- [flink] branch release-1.7 updated: [FLINK-12896][rest] Use JobID parameter for archiving - posted by ch...@apache.org on 2019/06/20 08:37:10 UTC, 0 replies.
- [flink] branch master updated (c5ff8e3 -> d8aac6f) - posted by tz...@apache.org on 2019/06/20 08:56:33 UTC, 0 replies.
- [flink] 01/11: [FLINK-11761] Update FlinkKafkaConsumerBaseMigrationTest for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:34 UTC, 0 replies.
- [flink] 02/11: [FLINK-11762] Update WindowOperatorMigrationTest for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:35 UTC, 0 replies.
- [flink] 03/11: [FLINK-11765] Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:36 UTC, 0 replies.
- [flink] 04/11: [FLINK-11766] Update Java / Scala StatefulJobSavepointMigrationITCase for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:37 UTC, 0 replies.
- [flink] 05/11: [FLINK-11763] Update AbstractKeyedOperatorRestoreTestBase for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:38 UTC, 0 replies.
- [flink] 06/11: [FLINK-11760] Update CEPMigrationTest for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:39 UTC, 0 replies.
- [flink] 07/11: [FLINK-11758] Update ContinuousFileProcessingMigrationTest for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:40 UTC, 0 replies.
- [flink] 08/11: [FLINK-11764] Update BucketingSinkMigrationTest for Flink 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:41 UTC, 0 replies.
- [flink] 09/11: [FLINK-11768] Update TypeSerializerSnapshotMigrationITCase for Flink 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:42 UTC, 0 replies.
- [flink] 10/11: [FLINK-11770] Update FlinkKinesisConsumerMigrationTest for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:43 UTC, 0 replies.
- [flink] 11/11: [FLINK-11759] Update AbstractNonKeyedOperatorRestoreTestBase for 1.8 - posted by tz...@apache.org on 2019/06/20 08:56:44 UTC, 0 replies.
- [flink] branch master updated (d8aac6f -> 4a727c0) - posted by ku...@apache.org on 2019/06/20 10:56:10 UTC, 0 replies.
- [flink] 01/03: [FLINK-12815] [table-planner-blink] Do not register the intermediate optimization result as a table in batch and stream CommonSubGraphBasedOptimizer - posted by ku...@apache.org on 2019/06/20 10:56:11 UTC, 0 replies.
- [flink] 02/03: [FLINK-12815] [table-planner-blink] TableImpl supports QueryOperation in blink planner - posted by ku...@apache.org on 2019/06/20 10:56:12 UTC, 0 replies.
- [flink] 03/03: [FLINK-12815] [table-planner-blink] Support CatalogManager in blink planner - posted by ku...@apache.org on 2019/06/20 10:56:13 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12910][hotfix][python][tests] Fix the Python catalog test failure caused by FLINK-12877 - posted by ji...@apache.org on 2019/06/20 13:20:51 UTC, 0 replies.
- [flink] branch master updated (7d8869d -> 318ce57) - posted by tr...@apache.org on 2019/06/20 17:21:02 UTC, 0 replies.
- [flink] 01/03: [hotfix][network] Rename taskExecutorLocation to taskExecutorResourceId and small fixes - posted by tr...@apache.org on 2019/06/20 17:21:03 UTC, 0 replies.
- [flink] 02/03: [hotfix] Convert ClassNotFoundException to FlinkException if the type implementing class is not found in InstantiationUtil.instantiate - posted by tr...@apache.org on 2019/06/20 17:21:04 UTC, 0 replies.
- [flink] 03/03: [FLINK-12706] Add the ShuffleMaster factory method to ShuffleService and its default Netty implementation - posted by tr...@apache.org on 2019/06/20 17:21:05 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12659][hive] Integrate Flink with Hive GenericUDTF - posted by bl...@apache.org on 2019/06/20 19:14:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12664][hive] Implement TableSink to write Hive tables - posted by bl...@apache.org on 2019/06/20 19:19:48 UTC, 0 replies.
- buildbot success in on flink-docs-release-1.8 - posted by bu...@apache.org on 2019/06/21 01:43:38 UTC, 0 replies.
- [flink] branch hotfix_MG created (now 3542796) - posted by ji...@apache.org on 2019/06/21 01:58:12 UTC, 0 replies.
- [flink] 01/01: [hotfix][python] Exclude header check for python Docs - posted by ji...@apache.org on 2019/06/21 01:58:13 UTC, 0 replies.
- [flink] branch master updated (f3a23d3 -> 3542796) - posted by ji...@apache.org on 2019/06/21 02:00:05 UTC, 0 replies.
- [flink] branch master updated (3542796 -> 6b8212c) - posted by tr...@apache.org on 2019/06/21 07:28:32 UTC, 0 replies.
- [flink] branch release-1.8 updated (9855ca8 -> 9190569) - posted by tr...@apache.org on 2019/06/21 07:30:53 UTC, 0 replies.
- [flink] branch release-1.7 updated (0abc0b6 -> 97537ea) - posted by tr...@apache.org on 2019/06/21 07:31:19 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12585][python] Add ExecutionEnvironment and StreamExecutionEnvironment with basic configuration APIs which do not depends on additional classes such as ExecutionConfig. - posted by ji...@apache.org on 2019/06/21 08:40:49 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12778][table] Fix derive row type bug for table aggregate This closes #8771 - posted by ji...@apache.org on 2019/06/21 10:10:38 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12899][table] Introduce a resolved expression with data type - posted by tw...@apache.org on 2019/06/21 11:49:17 UTC, 0 replies.
- [flink] branch master updated (c80be06 -> 89f7233) - posted by pn...@apache.org on 2019/06/21 14:02:14 UTC, 0 replies.
- [flink] 01/05: [hotfix][yarn, test] Deduplicate YarnClusterDescriptor construction in YarnClusterDescriptorTest - posted by pn...@apache.org on 2019/06/21 14:02:15 UTC, 0 replies.
- [flink] 02/05: [FLINK-12868][yarn] Fix yarn cluster can not be deployed if plugins dir does not exist - posted by pn...@apache.org on 2019/06/21 14:02:16 UTC, 0 replies.
- [flink] 03/05: [FLINK-12868][mesos] Fix mesos cluster can not be deployed if plugins dir does not exist - posted by pn...@apache.org on 2019/06/21 14:02:17 UTC, 0 replies.
- [flink] 04/05: [FLINK-12868][plugins] Log warnings if the plugins directory doesn't exist - posted by pn...@apache.org on 2019/06/21 14:02:18 UTC, 0 replies.
- [flink] 05/05: [FLINK-12868][plugins] Create an empty plugins directory in flink-dist - posted by pn...@apache.org on 2019/06/21 14:02:19 UTC, 0 replies.
- [flink-web] branch asf-site updated (29579a5 -> ff4c6dc) - posted by rm...@apache.org on 2019/06/21 14:36:35 UTC, 0 replies.
- [flink-web] 01/08: [FLINK-12605] Simplify how to contribute page - posted by rm...@apache.org on 2019/06/21 14:36:36 UTC, 0 replies.
- [flink-web] 02/08: [FLINK-12605] Add contributing/ directory - posted by rm...@apache.org on 2019/06/21 14:36:37 UTC, 0 replies.
- [flink-web] 03/08: [FLINK-12605] Add proper links to navbar - posted by rm...@apache.org on 2019/06/21 14:36:38 UTC, 0 replies.
- [flink-web] 04/08: [FLINK-12605] fix navbar styles - posted by rm...@apache.org on 2019/06/21 14:36:39 UTC, 0 replies.
- [flink-web] 05/08: [FLINK-12605] Describe new contribution process - posted by rm...@apache.org on 2019/06/21 14:36:40 UTC, 0 replies.
- [flink-web] 06/08: Update navigation in 'What is Flink?' - posted by rm...@apache.org on 2019/06/21 14:36:41 UTC, 0 replies.
- [flink-web] 07/08: [FLINK-12605] Address PR comments - posted by rm...@apache.org on 2019/06/21 14:36:42 UTC, 0 replies.
- [flink-web] 08/08: Rebuild website - posted by rm...@apache.org on 2019/06/21 14:36:43 UTC, 0 replies.
- [flink] branch master updated (89f7233 -> 7992e98) - posted by dw...@apache.org on 2019/06/21 14:49:18 UTC, 0 replies.
- [flink] 01/03: [FLINK-11884][table-api-java][table-planner] Port TableImpl to java-api module - posted by dw...@apache.org on 2019/06/21 14:49:19 UTC, 0 replies.
- [flink] 02/03: [hotfix][table-planner] Drop External catalog exceptions - posted by dw...@apache.org on 2019/06/21 14:49:20 UTC, 0 replies.
- [flink] 03/03: [FLINK-12798][table-planner][table-api-java] Port TableEnvironment to table-api-java module - posted by dw...@apache.org on 2019/06/21 14:49:21 UTC, 0 replies.
- [flink] branch master updated: [hotfix][python] Using fully qualified function names in python tests. - posted by dw...@apache.org on 2019/06/21 15:07:32 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink - posted by bl...@apache.org on 2019/06/21 22:04:10 UTC, 0 replies.
- [flink] branch master updated: [docs-sync] Synchronize the latest documentation changes (commits to 318ce571) into Chinese documents - posted by ja...@apache.org on 2019/06/22 04:00:54 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11612][docs-zh] Translate the "Project Template for Java" page into Chinese - posted by ja...@apache.org on 2019/06/22 04:24:28 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12903][py] Remove old Python APIs - posted by ch...@apache.org on 2019/06/22 06:57:57 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12917][hive] support complex type of array, map, struct for Hive functions - posted by bl...@apache.org on 2019/06/22 23:03:28 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12743][table-runtime-blink] Introduce unbounded streaming anti/semi join operator - posted by ja...@apache.org on 2019/06/23 12:27:11 UTC, 0 replies.
- [flink] annotated tag release-1.8.1-rc1 created (now 29976ef) - posted by ji...@apache.org on 2019/06/24 01:00:14 UTC, 0 replies.
- [flink] 01/01: Commit for release 1.8.1 - posted by ji...@apache.org on 2019/06/24 01:00:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11606][docs-zh] Translate the "Distributed Runtime Environment" page into Chinese - posted by ja...@apache.org on 2019/06/24 02:27:20 UTC, 0 replies.
- [flink-web] branch asf-site updated (ff4c6dc -> 7e6322b) - posted by ja...@apache.org on 2019/06/24 03:17:29 UTC, 0 replies.
- [flink-web] 01/02: [FLINK-11560][docs-zh] Translate "Flink Applications" page into Chinese - posted by ja...@apache.org on 2019/06/24 03:17:30 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12834][table-planner-blink] Support CharType and BinaryType - posted by ja...@apache.org on 2019/06/24 05:27:58 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput - posted by pn...@apache.org on 2019/06/24 07:35:59 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12923][runtime] Introduce Task termination future - posted by ch...@apache.org on 2019/06/24 07:42:33 UTC, 0 replies.
- [flink] branch master updated (16517f5 -> 067ee04) - posted by ch...@apache.org on 2019/06/24 07:44:56 UTC, 0 replies.
- [flink] 01/02: [FLINK-12842][network] Fix invalid check in ReleaseOnConsumptionResultPartition#createSubpartitionView - posted by ch...@apache.org on 2019/06/24 07:44:57 UTC, 0 replies.
- [flink] 02/02: [hotfix][network][tests] Refactor existing tests for reusing PartitionTestUtils - posted by ch...@apache.org on 2019/06/24 07:44:58 UTC, 0 replies.
- [flink] branch master updated (067ee04 -> 3c558d8) - posted by ch...@apache.org on 2019/06/24 10:06:07 UTC, 0 replies.
- [flink] 01/02: [FLINK-12555] Introduce an encapsulated metric group layout for shuffle API and deprecate old one - posted by ch...@apache.org on 2019/06/24 10:06:08 UTC, 0 replies.
- [flink] 02/02: [hotfix][network] Introduce NettyShuffleMetricFactory to encapsulate metrics creation - posted by ch...@apache.org on 2019/06/24 10:06:09 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/Sink from a Hive table - posted by bl...@apache.org on 2019/06/24 18:24:50 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12964][sql client] add commented-out defaults to sql client yaml file to make it easier for users to adopt - posted by bl...@apache.org on 2019/06/24 21:12:21 UTC, 0 replies.
- [flink] branch master updated: [FLIN-12663]Implement HiveTableSource to read Hive tables - posted by bl...@apache.org on 2019/06/24 22:12:10 UTC, 0 replies.
- [flink] branch master updated (2949166 -> 8d98223) - posted by ji...@apache.org on 2019/06/25 01:02:33 UTC, 0 replies.
- [flink] 01/02: [FLINK-12931][python] Fix lint-python.sh cannot find flake8 - posted by ji...@apache.org on 2019/06/25 01:02:34 UTC, 0 replies.
- [flink] 02/02: [hotfix][python]Use of a variable like $X instead of ${X} - posted by ji...@apache.org on 2019/06/25 01:02:35 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12920][python] Drop support of register_table_sink with parameters field_names and field_types - posted by ji...@apache.org on 2019/06/25 03:12:03 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12807][hive]Support Hive table columnstats related operations in HiveCatalog - posted by bl...@apache.org on 2019/06/25 03:29:27 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12932][table][sql client] support 'show catalogs' and 'show databases' end-2-end in TableEnvironment and SQL CLI - posted by bl...@apache.org on 2019/06/25 06:20:21 UTC, 0 replies.
- svn commit: r34621 - in /dev/flink/flink-1.8.1-rc1: ./ flink-1.8.1-bin-scala_2.12.tgz flink-1.8.1-src.tgz flink-1.8.1-src.tgz.asc flink-1.8.1-src.tgz.sha512 - posted by ji...@apache.org on 2019/06/25 06:35:23 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12904][table-api] Remove TableSource#getTableStats() interface - posted by ja...@apache.org on 2019/06/25 07:02:01 UTC, 0 replies.
- [flink] branch master updated (bf55c54 -> e9642f5) - posted by ch...@apache.org on 2019/06/25 07:51:44 UTC, 0 replies.
- [flink] 01/03: [FLINK-12890][coordination][shuffle] Introduce ShuffleDescriptor#hasLocalResources - posted by ch...@apache.org on 2019/06/25 07:51:45 UTC, 0 replies.
- [flink] 02/03: [FLINK-12890][coordination][shuffle] Introduce ShuffleMaster#removePartitionExternally - posted by ch...@apache.org on 2019/06/25 07:51:46 UTC, 0 replies.
- [flink] 03/03: [hotfix][shuffle] Rename ShuffleEnvironment#releasePartitions to ShuffleEnvironment#releasePartitionsLocally - posted by ch...@apache.org on 2019/06/25 07:51:47 UTC, 0 replies.
- [flink] branch master updated: [hotfix][config][docs] Fiy typo for `taskmanager.memory.preallocate` - posted by ch...@apache.org on 2019/06/25 08:15:48 UTC, 0 replies.
- svn commit: r34622 - /dev/flink/flink-1.8.1-rc1/ - posted by ji...@apache.org on 2019/06/25 08:27:18 UTC, 0 replies.
- [flink] branch master updated: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788 - posted by pn...@apache.org on 2019/06/25 08:53:05 UTC, 0 replies.
- [flink] branch master updated: [hotfix][python][docs] Fix python doc nav bar not showing and layout issue. - posted by ji...@apache.org on 2019/06/25 09:30:56 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12967][runtime] Change the processing that the input reaches the end to comply with the InputSelectable contract - posted by pn...@apache.org on 2019/06/25 09:37:24 UTC, 0 replies.
- [flink] branch master updated: [hotfix][network] Fix raw type usages - posted by ch...@apache.org on 2019/06/25 11:17:21 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12915][tests] Don't reuse minicluster in AbstractOperatorRestoreTestBase - posted by ch...@apache.org on 2019/06/25 11:55:14 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12913][runtime] Remove legacy InstanceManager and InstanceManagerTest - posted by ch...@apache.org on 2019/06/25 11:56:00 UTC, 0 replies.
- [flink] branch master updated (9c77ffc -> ab0ef7b) - posted by ch...@apache.org on 2019/06/25 11:57:30 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12969][table-planner-blink] Remove dependencies on RelNode from TableImpl in blink planner (#8866) - posted by ku...@apache.org on 2019/06/25 12:56:48 UTC, 0 replies.
- [flink] branch master updated (adb7aab -> cad94a0) - posted by ku...@apache.org on 2019/06/25 15:04:02 UTC, 0 replies.
- [flink] 01/02: [FLINK-12888] [table-planner-blink] remove FunctionCatalog in blink planner and use FunctionCatalog in flink-table-api-java - posted by ku...@apache.org on 2019/06/25 15:04:03 UTC, 0 replies.
- [flink] 02/02: [FLINK-12888] [table-planner-blink] Introduce planner rule to push filter into TableSource - posted by ku...@apache.org on 2019/06/25 15:04:04 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12975][table-planner-blink] UserDefinedFunctionUtils should distinguish overload any parameters methods - posted by ku...@apache.org on 2019/06/25 15:08:00 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12933][sql client] support 'use catalog' and 'use database' in SQL CLI - posted by bl...@apache.org on 2019/06/25 16:42:50 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter - posted by ga...@apache.org on 2019/06/25 17:40:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12918][table][hive] unify GenericCatalogTable, HiveCatalogTable and AbstractCatalogTable into CatalogTableImpl - posted by bl...@apache.org on 2019/06/25 19:31:16 UTC, 0 replies.
- [flink] branch master updated (7a57d1a -> 4b3544e) - posted by ch...@apache.org on 2019/06/25 19:51:05 UTC, 0 replies.
- [flink] 01/03: [hotfix][tests] Move ResultPartitionTEst#createPDD - posted by ch...@apache.org on 2019/06/25 19:51:06 UTC, 0 replies.
- [flink] 02/03: [FLINK-12612][coordination] Track stored partitions on TM - posted by ch...@apache.org on 2019/06/25 19:51:07 UTC, 0 replies.
- [flink] 03/03: [FLINK-12612][coordination] Maintain JM connection until all partitions are released - posted by ch...@apache.org on 2019/06/25 19:51:08 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12972][table-planner-blink] Ensure calling open/close in join condition of generated functions - posted by ku...@apache.org on 2019/06/26 02:52:49 UTC, 0 replies.
- [flink] branch master updated (5760379 -> f9681c0) - posted by tz...@apache.org on 2019/06/26 03:33:20 UTC, 0 replies.
- [flink] 01/20: [hotfix] Expose StateAssignmentOperation#reDistributePartitionableStates as public - posted by tz...@apache.org on 2019/06/26 03:33:21 UTC, 0 replies.
- [flink] 02/20: [hotfix] Expose AbstractFsCheckpointStorage#resolveCheckpointPointer as public - posted by tz...@apache.org on 2019/06/26 03:33:22 UTC, 0 replies.
- [flink] 03/20: [FLINK-12729] [state-processing-api] Add state reader for consuming non-partitioned operator state - posted by tz...@apache.org on 2019/06/26 03:33:23 UTC, 0 replies.
- [flink] 04/20: [FLINK-12729] [state-processing-api] Add missing serialVersionUids - posted by tz...@apache.org on 2019/06/26 03:33:24 UTC, 0 replies.
- [flink] 05/20: [FLINK-12729] [state-processing-api] Build operator state index within OnDiskSavepointMetadata - posted by tz...@apache.org on 2019/06/26 03:33:25 UTC, 0 replies.
- [flink] 06/20: [hotfix] Refactor NeverCompleteFuture into a reusable utility - posted by tz...@apache.org on 2019/06/26 03:33:26 UTC, 0 replies.
- [flink] 07/20: [FLINK-12732] [state-processing-api] Implement shim SavepointEnvironment on top of user RuntimeContext - posted by tz...@apache.org on 2019/06/26 03:33:27 UTC, 0 replies.
- [flink] 08/20: [FLINK-12732] [state-processing-api] Add savepoint reader for consuming partitioned operator state - posted by tz...@apache.org on 2019/06/26 03:33:28 UTC, 0 replies.
- [flink] 09/20: [FLINK-12732] [state-processing-api] Document reader for the State Processing API - posted by tz...@apache.org on 2019/06/26 03:33:29 UTC, 0 replies.
- [flink] 10/20: [FLINK-12732] [state-processing-api] Miscellaneous cleanup for read part of State Processing API - posted by tz...@apache.org on 2019/06/26 03:33:30 UTC, 0 replies.
- [flink] 11/20: [hotfix] [connectors] Fix shadowed NPE in elasticsearch sink connector - posted by tz...@apache.org on 2019/06/26 03:33:31 UTC, 0 replies.
- [flink] 12/20: [hotfix][docs] "data Artisans" -> "Ververica" - posted by tz...@apache.org on 2019/06/26 03:33:32 UTC, 0 replies.
- [flink] 13/20: [hotfix][docs] update latency metric name to cover for latency granularity - posted by tz...@apache.org on 2019/06/26 03:33:33 UTC, 0 replies.
- [flink] 14/20: [hotfix][docs] fix typo - posted by tz...@apache.org on 2019/06/26 03:33:34 UTC, 0 replies.
- [flink] 15/20: [FLINK-12957][docs] fix Thrift and Protobuf dependency examples - posted by tz...@apache.org on 2019/06/26 03:33:35 UTC, 0 replies.
- [flink] 16/20: [FLINK-12870][doc] Add missing warnings to schema evolution documentation - posted by tz...@apache.org on 2019/06/26 03:33:36 UTC, 0 replies.
- [flink] 17/20: [hotfix] [docs] Fix typo in Checkpoints doc - posted by tz...@apache.org on 2019/06/26 03:33:37 UTC, 0 replies.
- [flink] 18/20: [hotfix] [docs] Fix the typos in process_function.md and process_function.zh.md. - posted by tz...@apache.org on 2019/06/26 03:33:38 UTC, 0 replies.
- [flink] 19/20: [FLINK-12741] [docs] Update Kafka producer fault tolerance guarantees - posted by tz...@apache.org on 2019/06/26 03:33:39 UTC, 0 replies.
- [flink] 20/20: [FLINK-12190] [tests] Fix IllegalArgumentException throwed by FlinkKinesisConsumerMigrationTest#writeSnapshot - posted by tz...@apache.org on 2019/06/26 03:33:40 UTC, 0 replies.
- [flink] branch release-1.8 updated (9190569 -> 9ad7cda) - posted by nk...@apache.org on 2019/06/26 07:59:47 UTC, 0 replies.
- [flink] 01/04: [hotfix][docs] "data Artisans" -> "Ververica" - posted by nk...@apache.org on 2019/06/26 07:59:48 UTC, 1 replies.
- [flink] 02/04: [hotfix][docs] update latency metric name to cover for latency granularity - posted by nk...@apache.org on 2019/06/26 07:59:49 UTC, 1 replies.
- [flink] 03/04: [hotfix][docs] fix typo - posted by nk...@apache.org on 2019/06/26 07:59:50 UTC, 1 replies.
- [flink] 04/04: [FLINK-12957][docs] fix Thrift and Protobuf dependency examples - posted by nk...@apache.org on 2019/06/26 07:59:51 UTC, 1 replies.
- [flink] branch release-1.7 updated (97537ea -> 5b8154c) - posted by nk...@apache.org on 2019/06/26 08:02:31 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12911][table-api] Port AppendStreamTableSink, UpsertStreamTableSink, RetractStreamTableSink to flink-api-java-bridge - posted by ja...@apache.org on 2019/06/26 08:04:04 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12971][table-planner-blink] Remove the constraint that lookup join needs a primary key or index key - posted by ja...@apache.org on 2019/06/26 08:10:34 UTC, 0 replies.
- [flink] branch master updated (cb922bb -> 09a4a3a) - posted by dw...@apache.org on 2019/06/26 09:18:01 UTC, 0 replies.
- [flink] branch master updated (09a4a3a -> 03839f1) - posted by tw...@apache.org on 2019/06/26 09:31:31 UTC, 0 replies.
- [flink] 01/02: [FLINK-12924][table] Introduce basic type inference interfaces - posted by tw...@apache.org on 2019/06/26 09:31:32 UTC, 0 replies.
- [flink] 02/02: [FLINK-12924][table] Add basic type inference logic - posted by tw...@apache.org on 2019/06/26 09:31:33 UTC, 0 replies.
- [flink] branch master updated (03839f1 -> d1ce804) - posted by ch...@apache.org on 2019/06/26 10:00:23 UTC, 0 replies.
- [flink] 01/02: [hotfix][tests] ResultPartitionDeploymentDescriptorTest cleanup and test serialization of UnknownShuffleDescriptor without ResultPartitionDeploymentDescriptor - posted by ch...@apache.org on 2019/06/26 10:00:24 UTC, 0 replies.
- [flink] 02/02: [FLINK-12960][coordination][shuffle] Introduce ShuffleDescriptor#ReleaseType and ShuffleDescriptor#getSupportedReleaseTypes - posted by ch...@apache.org on 2019/06/26 10:00:25 UTC, 0 replies.
- [flink] branch master updated: [hotfix][python] Align the signature of type utility methods with Java - posted by ji...@apache.org on 2019/06/26 10:42:41 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12914][runtime] Remove legacy InstanceListener - posted by ch...@apache.org on 2019/06/26 12:15:01 UTC, 0 replies.
- [flink] branch master updated (126a489 -> 5233ba4) - posted by ch...@apache.org on 2019/06/26 13:08:19 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12993][runtime] Refactor forceReleaseOnConsumption to JM concept - posted by ch...@apache.org on 2019/06/26 14:47:58 UTC, 0 replies.
- [flink-web] branch asf-site updated (7e6322b -> 18bb152) - posted by fh...@apache.org on 2019/06/26 15:52:58 UTC, 0 replies.
- [flink-web] 01/02: [blog] Add blog post about broadcast state - posted by fh...@apache.org on 2019/06/26 15:52:59 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12988][table] restore AbstractCatalogTable as parent for CatalogTableImpl and ConnectorCatalogTable - posted by bl...@apache.org on 2019/06/26 17:16:01 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12970][hive] Support writing Hive complex types - posted by bl...@apache.org on 2019/06/26 17:19:06 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Fix invalid link in migration docs - posted by ch...@apache.org on 2019/06/26 17:20:20 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12990][python] Fix LocalTimeZone issue for Date type. - posted by ji...@apache.org on 2019/06/27 01:38:00 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12609][python] Add LocalZonedTimestampType/ZonedTimestampType/DayTimeIntervalType/YearMonthIntervalType - posted by ji...@apache.org on 2019/06/27 02:45:29 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12722][docs] Adds Python Table API tutorial - posted by ji...@apache.org on 2019/06/27 08:03:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12611][table-planner-blink] Make time indicator nullable in blink - posted by ja...@apache.org on 2019/06/27 11:17:08 UTC, 0 replies.
- [flink] branch master updated (dac9f78 -> 0004056) - posted by nk...@apache.org on 2019/06/27 11:30:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-11662] Disable task to fail on checkpoint errors - posted by sr...@apache.org on 2019/06/27 11:41:14 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12639] [docs] add "getting started" section to documentation to expand in FLIP-42 - posted by nk...@apache.org on 2019/06/27 12:04:49 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Fix FileSystem index link - posted by ch...@apache.org on 2019/06/27 12:32:20 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12965][table][hive] unify catalog view implementations - posted by bl...@apache.org on 2019/06/27 17:30:05 UTC, 0 replies.
- [flink] branch master updated: [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it - posted by bl...@apache.org on 2019/06/27 17:31:53 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12660][hive] Integrate Flink with Hive UDAF - posted by bl...@apache.org on 2019/06/27 17:36:33 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12962][python] Allows pyflink to be pip installed. - posted by ji...@apache.org on 2019/06/27 22:07:56 UTC, 0 replies.
- [flink] branch master updated (f059b19 -> a57ba1c) - posted by tw...@apache.org on 2019/06/28 06:14:16 UTC, 0 replies.
- [flink] 01/02: [hotfix][table-common] Add implicit precision to predefined types - posted by tw...@apache.org on 2019/06/28 06:14:17 UTC, 0 replies.
- [flink] 02/02: [hotfix][table-common] Add missing TIME type family - posted by tw...@apache.org on 2019/06/28 06:14:18 UTC, 0 replies.
- [flink-web] branch asf-site updated (18bb152 -> 3fd6f56) - posted by rm...@apache.org on 2019/06/28 07:20:14 UTC, 0 replies.
- [flink-web] 01/02: [hotfix][docs][contribute-code] Add correct link to "Code Style and Quality Guide" - posted by rm...@apache.org on 2019/06/28 07:20:15 UTC, 0 replies.
- [flink-web] 02/02: [hotfix][docs][improve-website] Document relative url path for Chinese translation - posted by rm...@apache.org on 2019/06/28 07:20:16 UTC, 0 replies.
- [flink] branch master updated (a57ba1c -> af0059c) - posted by al...@apache.org on 2019/06/28 07:30:02 UTC, 0 replies.
- [flink] 01/04: [hotfix] Remove unused method from Kafka Test Environments - posted by al...@apache.org on 2019/06/28 07:30:03 UTC, 0 replies.
- [flink] 02/04: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord - posted by al...@apache.org on 2019/06/28 07:30:04 UTC, 0 replies.
- [flink] 03/04: [FLINK-11693] Support FlinkKafkaPartitioner functionality with new KafkaSerializationSchema - posted by al...@apache.org on 2019/06/28 07:30:05 UTC, 0 replies.
- [flink] 04/04: [FLINK-11693] Deprecate old constructors in modern KafkaProducer - posted by al...@apache.org on 2019/06/28 07:30:06 UTC, 0 replies.
- [flink] branch master updated (af0059c -> 812a3f3) - posted by pn...@apache.org on 2019/06/28 07:56:48 UTC, 0 replies.
- [flink] 01/04: [hotfix][tests] Rewrite StreamTaskTest without reflection based fields setting - posted by pn...@apache.org on 2019/06/28 07:56:49 UTC, 0 replies.
- [flink] 02/04: [hotfix][tests] StreamTaskTestHarness: create StreamTask instance in the execution thread (task's thread) - posted by pn...@apache.org on 2019/06/28 07:56:50 UTC, 0 replies.
- [flink] 03/04: [hotfix][tests] Make SynchronousCheckpointTest create StreamTask instance in the main task's thread - posted by pn...@apache.org on 2019/06/28 07:56:51 UTC, 0 replies.
- [flink] 04/04: [hotfix][tests] StreamTaskTestHarness: use Preconditions.checkState instead of explicit throw IllegalStateException - posted by pn...@apache.org on 2019/06/28 07:56:52 UTC, 0 replies.
- [flink] branch master updated (812a3f3 -> 248995ce) - posted by tw...@apache.org on 2019/06/28 08:49:17 UTC, 0 replies.
- [flink] 01/02: [FLINK-12968][table-common] Add a utility for logical type casts - posted by tw...@apache.org on 2019/06/28 08:49:18 UTC, 0 replies.
- [flink] 02/02: [hotfix][table-common] Update LogicalTypeCastsTest to use logical types - posted by tw...@apache.org on 2019/06/28 08:49:19 UTC, 0 replies.
- [flink] branch master updated: [hotfix][table-common] Enrich the output type of InputTypeValidators#getExpectedSignature. - posted by tw...@apache.org on 2019/06/28 09:41:31 UTC, 0 replies.
- [flink] branch master updated: [hotfix][table-common] Fix argument count validation - posted by tw...@apache.org on 2019/06/28 09:44:46 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12985][core][streaming] Rename StreamTransformation to org.apache.flink.api.dag.Transformation - posted by dw...@apache.org on 2019/06/28 10:09:29 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12954][table-api] Supports create(drop) view grammar for sql parser - posted by ja...@apache.org on 2019/06/28 10:47:58 UTC, 0 replies.
- [flink] branch master updated: [hotfix][python] Aligns with Java Table API by removing methods exec_env and query_config - posted by ji...@apache.org on 2019/06/28 12:09:22 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12850][core] Introduce LocalDate/LocalTime/LocalDateTime TypeInfo - posted by ja...@apache.org on 2019/06/28 12:47:43 UTC, 0 replies.
- [flink] branch master updated: [FLINK-13003][table-planner-blink] Support Temporal TableFunction Join in processing time and event time - posted by ja...@apache.org on 2019/06/28 13:39:46 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12989][hive]: Generate HiveTableSink from from a Hive table - posted by bl...@apache.org on 2019/06/28 16:38:19 UTC, 0 replies.
- [flink] branch master updated (f172129 -> 34ce59b) - posted by ch...@apache.org on 2019/06/29 07:21:23 UTC, 0 replies.
- [flink] 01/03: [FLINK-12882][network] Remove ExecutionAttemptID argument from ResultPartitionFactory#create - posted by ch...@apache.org on 2019/06/29 07:21:24 UTC, 0 replies.
- [flink] 02/03: [hotfix][network, tests] Use the simple constructor of ResultPartitionID in tests - posted by ch...@apache.org on 2019/06/29 07:21:25 UTC, 0 replies.
- [flink] 03/03: [hotfix][runtime] add checkNotNull for parameters in ResultPartitionID constructor - posted by ch...@apache.org on 2019/06/29 07:21:26 UTC, 0 replies.
- [flink] branch master updated: [FLINK-13004][table-runtime-blink] Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState - posted by ja...@apache.org on 2019/06/29 13:31:05 UTC, 0 replies.
- [flink] branch master updated (0640f97 -> 27712bd) - posted by ch...@apache.org on 2019/06/29 15:01:37 UTC, 0 replies.
- [flink] 01/04: [FLINK-12615][coordination] Support generic key in PartitionTable - posted by ch...@apache.org on 2019/06/29 15:01:38 UTC, 0 replies.
- [flink] 02/04: [FLINK-12615][coordination] Track partitions on JM - posted by ch...@apache.org on 2019/06/29 15:01:39 UTC, 0 replies.
- [flink] 03/04: [FLINK-12641][coordination] Release partitions on job shutdown - posted by ch...@apache.org on 2019/06/29 15:01:40 UTC, 0 replies.
- [flink] 04/04: [FLINK-12612][coordination] Maintain JM connection until all partitions are released - posted by ch...@apache.org on 2019/06/29 15:01:41 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12641][coordination] Release partitions on every terminal job state - posted by ch...@apache.org on 2019/06/29 15:06:32 UTC, 0 replies.
- [flink] branch master updated: [hotfix][coordination] Remove outdated comment - posted by ch...@apache.org on 2019/06/29 15:07:37 UTC, 0 replies.
- [flink] branch master updated (cd7b212 -> 4c93e68) - posted by se...@apache.org on 2019/06/29 19:31:58 UTC, 0 replies.
- [flink] 01/04: [hotfix] Minor cleanups - posted by se...@apache.org on 2019/06/29 19:31:59 UTC, 0 replies.
- [flink] 02/04: [hotfix] [network] Rename BoundedBlockingSubpartitionReader 'memory' parameter - posted by se...@apache.org on 2019/06/29 19:32:00 UTC, 0 replies.
- [flink] 03/04: [FLINK-12986] [network] Add different implementations to store/serve the data from the BoundedBlockingSubpartition - posted by se...@apache.org on 2019/06/29 19:32:01 UTC, 0 replies.
- [flink] 04/04: [hotfix] [tests] Remove usage of Assume in BoundedDataTests to avoid warnings during build/testing - posted by se...@apache.org on 2019/06/29 19:32:02 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12881][ml] Add more functionalities for ML Params and ParamInfo class - posted by sh...@apache.org on 2019/06/30 08:24:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-12947][docs-zh] Translate "Twitter Connector" page into Chinese - posted by ja...@apache.org on 2019/06/30 09:19:17 UTC, 0 replies.