flink-issues mailing list archives: October 2016

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 · 41 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager Sun, 23 Oct, 09:21
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager Sun, 23 Oct, 09:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager Sun, 23 Oct, 09:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions Sun, 23 Oct, 09:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions Sun, 23 Oct, 09:21
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions Sun, 23 Oct, 09:22
Till Rohrmann (JIRA) [jira] [Created] (FLINK-4889) Make InstanceManager independent of ActorRef Sun, 23 Oct, 13:08
tfournier314 [GitHub] flink issue #2668: Add EvaluateDataSetOperation for LabeledVector. This clos... Sun, 23 Oct, 13:34
tfournier314 [GitHub] flink pull request #2668: Add EvaluateDataSetOperation for LabeledVector. Th... Sun, 23 Oct, 13:50
tfournier314 [GitHub] flink pull request #2684: Add EvaluateDataSet Operation for LabeledVector - ... Sun, 23 Oct, 14:05
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption Sun, 23 Oct, 15:44
aljoscha [GitHub] flink issue #2672: [FLINK-4866] [streaming] Make Trigger.clear() Abstract to... Sun, 23 Oct, 19:46
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation Sun, 23 Oct, 19:46
Kostas Kloudas (JIRA) [jira] [Updated] (FLINK-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests. Sun, 23 Oct, 20:14
Kostas Kloudas (JIRA) [jira] [Updated] (FLINK-4800) Introduce the TimestampedFileInputSplit in the Continuous File Processing Sun, 23 Oct, 20:16
Kostas Kloudas (JIRA) [jira] [Updated] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing Sun, 23 Oct, 20:17
kl0u [GitHub] flink issue #2618: [FLINK-4800] Refactor the ContinuousFileMonitoringFunctio... Sun, 23 Oct, 20:23
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing Sun, 23 Oct, 20:23
hzyuemeng1 [GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho... Mon, 24 Oct, 01:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink Mon, 24 Oct, 01:12
hzyuemeng1 [GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho... Mon, 24 Oct, 01:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink Mon, 24 Oct, 01:26
wuchong [GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho... Mon, 24 Oct, 01:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink Mon, 24 Oct, 01:57
tzulitai [GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho... Mon, 24 Oct, 02:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink Mon, 24 Oct, 02:18
wuchong [GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f... Mon, 24 Oct, 03:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL Mon, 24 Oct, 03:07
Renkai Ge (JIRA) [jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects Mon, 24 Oct, 04:17
tzulitai [GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con... Mon, 24 Oct, 05:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker Mon, 24 Oct, 05:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4517) scala code refactoring Mon, 24 Oct, 06:35
shijinkui [GitHub] flink pull request #2428: [FLINK-4517] scala code refactoring Mon, 24 Oct, 06:35
wuchong [GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta... Mon, 24 Oct, 06:48
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4864) Shade Calcite dependency in flink-table Mon, 24 Oct, 06:48
aljoscha [GitHub] flink pull request #2685: [FLINK-4884] Eagerly Store MergingWindowSet in Sta... Mon, 24 Oct, 07:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator Mon, 24 Oct, 07:18
aljoscha [GitHub] flink issue #2672: [FLINK-4866] [streaming] Make Trigger.clear() Abstract to... Mon, 24 Oct, 07:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation Mon, 24 Oct, 07:19
Aljoscha Krettek (JIRA) [jira] [Resolved] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation Mon, 24 Oct, 07:19
Stefan Richter (JIRA) [jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects Mon, 24 Oct, 07:58
Anton Solovev (JIRA) [jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types. Mon, 24 Oct, 07:59
wuchong [GitHub] flink issue #2672: [FLINK-4866] [streaming] Make Trigger.clear() Abstract to... Mon, 24 Oct, 08:01
wuchong [GitHub] flink pull request #2672: [FLINK-4866] [streaming] Make Trigger.clear() Abst... Mon, 24 Oct, 08:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation Mon, 24 Oct, 08:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation Mon, 24 Oct, 08:01
aljoscha [GitHub] flink issue #2671: [FLINK-4862] fix Timer register in ContinuousEventTimeTri... Mon, 24 Oct, 08:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger Mon, 24 Oct, 08:17
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-4890) FileInputFormatTest#testExcludeFiles fails on Windows OS Mon, 24 Oct, 08:32
uce [GitHub] flink issue #2646: [FLINK-4843] Test for FsCheckpointStateOutputStream::getP... Mon, 24 Oct, 09:05
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4843) Introduce Test for FsCheckpointStateOutputStream::getPos Mon, 24 Oct, 09:05
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4891) Remove flink-contrib/flink-operator-stats Mon, 24 Oct, 09:06
Ufuk Celebi (JIRA) [jira] [Commented] (FLINK-4891) Remove flink-contrib/flink-operator-stats Mon, 24 Oct, 09:07
Ufuk Celebi (JIRA) [jira] [Closed] (FLINK-4891) Remove flink-contrib/flink-operator-stats Mon, 24 Oct, 09:09
Ufuk Celebi (JIRA) [jira] [Closed] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch Mon, 24 Oct, 09:10
Ufuk Celebi (JIRA) [jira] [Closed] (FLINK-4843) Introduce Test for FsCheckpointStateOutputStream::getPos Mon, 24 Oct, 09:12
asfgit [GitHub] flink pull request #2646: [FLINK-4843] Test for FsCheckpointStateOutputStrea... Mon, 24 Oct, 09:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4843) Introduce Test for FsCheckpointStateOutputStream::getPos Mon, 24 Oct, 09:13
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4235) ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis Mon, 24 Oct, 09:14
Jark Wu (JIRA) [jira] [Commented] (FLINK-4565) Support for SQL IN operator Mon, 24 Oct, 09:17
Stefan Richter (JIRA) [jira] [Updated] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects Mon, 24 Oct, 09:38
tonycox [GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th... Mon, 24 Oct, 09:39
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types. Mon, 24 Oct, 09:39
Jark Wu (JIRA) [jira] [Assigned] (FLINK-4762) Use plural in time interval units Mon, 24 Oct, 09:42
StephanEwen [GitHub] flink issue #2644: [FLINK-4837] flink-streaming-akka source connector Mon, 24 Oct, 09:50
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4837) flink-streaming-akka source connector Mon, 24 Oct, 09:50
Nikolay Vasilishin (JIRA) [jira] [Commented] (FLINK-4565) Support for SQL IN operator Mon, 24 Oct, 09:57
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery. Mon, 24 Oct, 09:57
Aljoscha Krettek (JIRA) [jira] [Resolved] (FLINK-3202) Make Timer/Trigger Service Scoped to Key/Namespace Mon, 24 Oct, 09:59
fhueske [GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f... Mon, 24 Oct, 10:00
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL Mon, 24 Oct, 10:01
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-4892) Snapshot TimerService using Key-Grouped State Mon, 24 Oct, 10:01
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery. Mon, 24 Oct, 10:02
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4893) Use single RecordSerializer per RecordWriter Mon, 24 Oct, 10:03
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4894) Don't block on buffer request after broadcastEvent Mon, 24 Oct, 10:08
fhueske [GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta... Mon, 24 Oct, 10:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4864) Shade Calcite dependency in flink-table Mon, 24 Oct, 10:12
fhueske [GitHub] flink pull request #2521: [FLINK-4639] [table] Make Calcite features more pl... Mon, 24 Oct, 10:32
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4639) Make Calcite features more pluggable Mon, 24 Oct, 10:33
fhueske [GitHub] flink issue #2521: [FLINK-4639] [table] Make Calcite features more pluggable Mon, 24 Oct, 10:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4639) Make Calcite features more pluggable Mon, 24 Oct, 10:38
shijinkui (JIRA) [jira] [Updated] (FLINK-4630) add netty tcp/restful pushed source support Mon, 24 Oct, 10:40
rmetzger [GitHub] flink issue #2644: [FLINK-4837] flink-streaming-akka source connector Mon, 24 Oct, 10:42
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4837) flink-streaming-akka source connector Mon, 24 Oct, 10:42
tzulitai [GitHub] flink pull request #2687: [FLINK-3123] [kafka] Allow custom specific start o... Mon, 24 Oct, 10:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer Mon, 24 Oct, 10:45
Robert Metzger (JIRA) [jira] [Closed] (FLINK-4630) add netty tcp/restful pushed source support Mon, 24 Oct, 10:48
Tzu-Li (Gordon) Tai (JIRA) [jira] [Assigned] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer Mon, 24 Oct, 10:53
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer Mon, 24 Oct, 10:54
Shaoxuan Wang (JIRA) [jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL Mon, 24 Oct, 11:18
Jark Wu (JIRA) [jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL Mon, 24 Oct, 11:43
wuchong [GitHub] flink pull request #2688: [FLINK-4762] [table] Use plural in time interval u... Mon, 24 Oct, 12:17
rmetzger [GitHub] flink issue #2448: [FLINK-3030][web frontend] Enhance dashboard to show exec... Mon, 24 Oct, 12:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4762) Use plural in time interval units Mon, 24 Oct, 12:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3030) Enhance Dashboard to show Execution Attempts Mon, 24 Oct, 12:17
Anton Solovev (JIRA) [jira] [Commented] (FLINK-4623) Create Physical Execution Plan of a DataStream Mon, 24 Oct, 12:30
Anton Solovev (JIRA) [jira] [Comment Edited] (FLINK-4623) Create Physical Execution Plan of a DataStream Mon, 24 Oct, 12:31
rmetzger [GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta... Mon, 24 Oct, 12:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4864) Shade Calcite dependency in flink-table Mon, 24 Oct, 12:45
fhueske [GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta... Mon, 24 Oct, 12:47
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 · 41 · Next »Thread · Author · Date
Box list
Jul 20196683
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