flink-issues mailing list archives: September 2017

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · Next »Thread · Author · Date
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails Thu, 14 Sep, 13:30
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-5205) Asynchronous remove job messages can interfere with recovered or resubmitted jobs Thu, 14 Sep, 13:31
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-6331) StreamingOperatorsITCase.testAsyncWaitOperator spuriously failing on Travis Thu, 14 Sep, 13:32
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7530) Port existing REST handlers to support Flip-6 components Mon, 18 Sep, 14:04
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7638) Port CurrentJobsOverviewHandler to new REST endpoint Mon, 18 Sep, 14:05
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7458) Generalize GatewayRetriever for WebRuntimeMonitor Mon, 18 Sep, 21:01
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7459) Introduce RedirectHandler for the WebRuntimeMonitor Mon, 18 Sep, 21:02
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7533) Retry failed gateway retrievals in the LeaderGatewayRetriever Mon, 18 Sep, 21:11
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7580) Let LeaderGatewayRetriever implementations automatically retry failed gateway retrieval operations Mon, 18 Sep, 21:13
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7639) TaskExecutorITCase is flakey Mon, 18 Sep, 21:24
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7639) TaskExecutorITCase is flakey Mon, 18 Sep, 21:27
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-6838) RescalingITCase fails in master branch Tue, 19 Sep, 09:24
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-7064) test instability in WordCountMapreduceITCase Tue, 19 Sep, 09:26
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-7487) test instability in ClassLoaderITCase (no resources available) Tue, 19 Sep, 09:27
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration Tue, 19 Sep, 21:27
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7527) Add redirection logic to AbstractRestHandler Tue, 19 Sep, 22:30
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7528) Create Dispatcher REST endpoint Tue, 19 Sep, 22:35
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7529) Retrieve complete REST address from RestfulGateway Tue, 19 Sep, 22:40
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7531) Move existing REST handler to flink-runtime Tue, 19 Sep, 22:45
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7532) Add StaticFileServerHandler to DispatcherRestEndpoint Wed, 20 Sep, 08:37
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7651) RetryingRegistration does not wait between failed connection attempts Wed, 20 Sep, 09:07
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7655) Revisit default non-leader id for FencedRpcEndpoints Wed, 20 Sep, 12:46
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7534) Create LegacyRestHandlerAdapter for the old REST handlers Wed, 20 Sep, 15:52
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7486) flink-mesos: Support for adding unique attribute / group_by attribute constraints Wed, 20 Sep, 17:00
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7535) Port DashboardConfigHandler to new REST endpoint Thu, 21 Sep, 07:32
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7651) RetryingRegistration does not wait between failed connection attempts Thu, 21 Sep, 07:34
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7650) Port JobCancellationHandler to new REST endpoint Thu, 21 Sep, 08:42
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7649) Port JobStoppingHandler to new REST endpoint Thu, 21 Sep, 13:18
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-7649) Port JobStoppingHandler to new REST endpoint Thu, 21 Sep, 13:18
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7663) Allow AbstractRestHandler to handle bad requests Thu, 21 Sep, 15:12
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7664) Replace FlinkFutureException by CompletionException Thu, 21 Sep, 16:59
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7655) Revisit default non-leader id for FencedRpcEndpoints Thu, 21 Sep, 23:01
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling Thu, 21 Sep, 23:35
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6) Thu, 21 Sep, 23:36
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7667) Add serializable AccessExecutionGraph implementation Fri, 22 Sep, 08:15
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder Fri, 22 Sep, 08:18
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7667) Add serializable AccessExecutionGraph implementation Fri, 22 Sep, 08:26
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7667) Add serializable AccessExecutionGraph implementation Fri, 22 Sep, 08:29
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder Mon, 25 Sep, 12:23
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-3827) Flink modules include unused dependencies Mon, 25 Sep, 12:32
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7638) Port CurrentJobsOverviewHandler to new REST endpoint Mon, 25 Sep, 21:49
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7541) Redistribute operator state using OperatorID Tue, 26 Sep, 07:12
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7076) Implement container release to support dynamic scaling Tue, 26 Sep, 07:47
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint Tue, 26 Sep, 07:54
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7664) Replace FlinkFutureException by CompletionException Tue, 26 Sep, 09:27
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint Tue, 26 Sep, 09:38
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7693) Adapt web frontend to use proper DELETE REST call for job termination Tue, 26 Sep, 15:04
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7695) Port JobConfigHandler to new REST endpoint Tue, 26 Sep, 16:40
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint Wed, 27 Sep, 09:27
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7694) Port JobMetricsHandler to new REST handler Wed, 27 Sep, 09:30
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7663) Allow AbstractRestHandler to handle bad requests Wed, 27 Sep, 16:15
Till Rohrmann (JIRA) [jira] [Created] (FLINK-7723) DispatcherTest instable Wed, 27 Sep, 21:50
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7723) DispatcherTest instable Wed, 27 Sep, 23:05
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-7650) Port JobCancellationHandler to new REST endpoint Wed, 27 Sep, 23:08
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-7649) Port JobStoppingHandler to new REST endpoint Wed, 27 Sep, 23:09
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-7411) minor performance improvements in NettyMessage Thu, 28 Sep, 09:01
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7487) test instability in ClassLoaderITCase (no resources available) Thu, 28 Sep, 09:02
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-7513) remove TestBufferFactory#MOCK_BUFFER Thu, 28 Sep, 09:02
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-7514) fix BackPressureStatsTrackerITCase releasing buffers twice Thu, 28 Sep, 09:02
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-7487) test instability in ClassLoaderITCase (no resources available) Thu, 28 Sep, 09:02
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7715) Port JarRunHandler to new REST endpoint Thu, 28 Sep, 13:26
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint Thu, 28 Sep, 13:29
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7734) test instability in ResourceManagerTest Thu, 28 Sep, 15:39
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-7734) test instability in ResourceManagerTest Thu, 28 Sep, 16:56
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7704) Port JobPlanHandler to new REST endpoint Fri, 29 Sep, 08:23
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7694) Port JobMetricsHandler to new REST handler Fri, 29 Sep, 08:27
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint Fri, 29 Sep, 08:28
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7667) Add serializable AccessExecutionGraph implementation Fri, 29 Sep, 08:35
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint Fri, 29 Sep, 08:39
Timo Walther (JIRA) [jira] [Created] (FLINK-7594) Add a SQL CLI client Wed, 06 Sep, 12:14
Timo Walther (JIRA) [jira] [Commented] (FLINK-7594) Add a SQL CLI client Thu, 07 Sep, 10:12
Timo Walther (JIRA) [jira] [Commented] (FLINK-7614) Add a code snippet example of a valid POJO to "Data Types" documentation Thu, 14 Sep, 08:17
Timo Walther (JIRA) [jira] [Assigned] (FLINK-7614) Add a code snippet example of a valid POJO to "Data Types" documentation Thu, 14 Sep, 08:17
Timo Walther (JIRA) [jira] [Created] (FLINK-7681) Support arbitrary TypeInformation in Table API Mon, 25 Sep, 10:17
Timo Walther (JIRA) [jira] [Resolved] (FLINK-7439) Support variable arguments for UDTF in SQL Tue, 26 Sep, 08:52
Timo Walther (JIRA) [jira] [Assigned] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly Tue, 26 Sep, 09:03
Timo Walther (JIRA) [jira] [Commented] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly Tue, 26 Sep, 11:37
Timo Walther (JIRA) [jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException Tue, 26 Sep, 12:38
Timo Walther (JIRA) [jira] [Created] (FLINK-7691) Remove ClassTag in Scala DataSet API Tue, 26 Sep, 12:51
Timo Walther (JIRA) [jira] [Resolved] (FLINK-7596) fix bug when Set Operation handles ANY type Tue, 26 Sep, 15:00
Timo Walther (JIRA) [jira] [Comment Edited] (FLINK-7596) fix bug when Set Operation handles ANY type Tue, 26 Sep, 15:00
Timo Walther (JIRA) [jira] [Updated] (FLINK-7596) fix bug when Set Operation handles ANY type Tue, 26 Sep, 15:00
Timo Walther (JIRA) [jira] [Assigned] (FLINK-7426) Table API does not support null values in keys Wed, 27 Sep, 08:09
Timo Walther (JIRA) [jira] [Created] (FLINK-7698) Join with null literals leads to NPE Wed, 27 Sep, 09:34
Timo Walther (JIRA) [jira] [Updated] (FLINK-7698) Join with null literals leads to NPE Wed, 27 Sep, 09:35
Timo Walther (JIRA) [jira] [Assigned] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields Wed, 27 Sep, 11:20
Timo Walther (JIRA) [jira] [Assigned] (FLINK-7702) Javadocs link broken Wed, 27 Sep, 13:15
Timo Walther (JIRA) [jira] [Commented] (FLINK-7702) Javadocs link broken Wed, 27 Sep, 13:18
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer Thu, 07 Sep, 06:23
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer Thu, 07 Sep, 06:23
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7440) Add eager serializable checks on provided de-/serialization schemas for Kinesis consumer / producer Thu, 07 Sep, 06:24
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc) Thu, 07 Sep, 06:25
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc) Thu, 07 Sep, 06:25
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-7614) Add a code snippet example of a valid POJO to "Data Types" documentation Wed, 13 Sep, 09:26
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client Thu, 14 Sep, 12:36
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client Thu, 14 Sep, 12:37
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client Thu, 14 Sep, 12:41
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics Thu, 14 Sep, 12:56
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees Mon, 18 Sep, 09:17
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-7510) Move some connectors to Apache Bahir Mon, 18 Sep, 09:24
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · Next »Thread · Author · Date
Box list
Jan 20205882
Dec 201913015
Nov 201911280
Oct 201911647
Sep 20198451
Aug 201910193
Jul 201911502
Jun 20198159
May 20197326
Apr 20195671
Mar 20194764
Feb 20195750
Jan 20194225
Dec 20183613
Nov 20186764
Oct 20186946
Sep 20184634
Aug 20185670
Jul 20187170
Jun 20184380
May 20185152
Apr 20183465
Mar 20184883
Feb 20185764
Jan 20184880
Dec 20172682
Nov 20174639
Oct 20174859
Sep 20173958
Aug 20174518
Jul 20175392
Jun 20174893
May 20176475
Apr 20174390
Mar 20177839
Feb 20175379
Jan 20175351
Dec 20163688
Nov 20164834
Oct 20164002
Sep 20163620
Aug 20165065
Jul 20163523
Jun 20164191
May 20163116
Apr 20163318
Mar 20163053
Feb 20164198
Jan 20162281
Dec 20151770
Nov 20153847
Oct 20153578
Sep 20153866
Aug 20154488
Jul 20152905
Jun 20153211
May 20152758
Apr 20152329
Mar 20152558
Feb 20151980
Jan 20151685
Dec 2014836
Nov 20141506
Oct 2014575
Sep 2014744
Aug 2014435
Jul 20141002
Jun 2014300