flink-issues mailing list archives: January 2018

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 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Tue, 23 Jan, 12:41
Hequn Cheng (JIRA) [jira] [Created] (FLINK-8492) Fix unsupported exception for udtf with multi calc Tue, 23 Jan, 12:51
Hequn Cheng (JIRA) [jira] [Updated] (FLINK-8492) Fix unsupported exception for udtf with multi calc Tue, 23 Jan, 12:54
Hequn Cheng (JIRA) [jira] [Updated] (FLINK-8492) Fix unsupported exception for udtf with multi calc Tue, 23 Jan, 12:54
Till Rohrmann (JIRA) [jira] [Created] (FLINK-8493) Integrate queryable state with Flip-6 Tue, 23 Jan, 12:59
asfgit [GitHub] flink pull request #5326: [FLINK-8365] [State Backend] Relax List type in He... Tue, 23 Jan, 13:07
asfgit [GitHub] flink pull request #5300: [FLINK-8411] [State Backends] HeapListState#add(nu... Tue, 23 Jan, 13:07
asfgit [GitHub] flink pull request #5325: [FLINK-8469] [State Backend] [RocksDB] relocate an... Tue, 23 Jan, 13:07
tillrohrmann [GitHub] flink pull request #5339: [FLINK-8493] [flip6] Integrate queryable state wit... Tue, 23 Jan, 13:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8469) relocate and unify RocksDB option params in RocksDBPerformanceTest Tue, 23 Jan, 13:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state Tue, 23 Jan, 13:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8365) Relax List type in HeapListState and HeapKeyedStateBackend Tue, 23 Jan, 13:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8493) Integrate queryable state with Flip-6 Tue, 23 Jan, 13:08
Hequn Cheng (JIRA) [jira] [Updated] (FLINK-8492) Fix unsupported exception for udtf with multi calc Tue, 23 Jan, 13:18
pluppens [GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co... Tue, 23 Jan, 13:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Tue, 23 Jan, 13:20
tzulitai [GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co... Tue, 23 Jan, 13:22
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Tue, 23 Jan, 13:23
Stefan Richter (JIRA) [jira] [Closed] (FLINK-8469) relocate and unify RocksDB option params in RocksDBPerformanceTest Tue, 23 Jan, 13:28
Stefan Richter (JIRA) [jira] [Closed] (FLINK-8411) HeapListState#add(null) will wipe out entire list state Tue, 23 Jan, 13:29
Stefan Richter (JIRA) [jira] [Closed] (FLINK-8365) Relax List type in HeapListState and HeapKeyedStateBackend Tue, 23 Jan, 13:30
Stefan Richter (JIRA) [jira] [Closed] (FLINK-8441) serialize values and value separator directly to stream in RocksDBListState Tue, 23 Jan, 13:30
Fabian Hueske (JIRA) [jira] [Commented] (FLINK-8492) Fix unsupported exception for udtf with multi calc Tue, 23 Jan, 13:44
pnowojski [GitHub] flink issue #5316: [FLINK-8022][kafka-tests] Disable at-least-once tests for... Tue, 23 Jan, 13:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8022) Kafka at-least-once tests fail occasionally Tue, 23 Jan, 13:46
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-4766) Migrate TaskManager configuration options Tue, 23 Jan, 14:02
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY Tue, 23 Jan, 14:04
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY Tue, 23 Jan, 14:05
Chesnay Schepler (JIRA) [jira] [Assigned] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY Tue, 23 Jan, 14:05
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY Tue, 23 Jan, 14:05
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY Tue, 23 Jan, 14:14
Shashank Agarwal (JIRA) [jira] [Commented] (FLINK-6883) Serializer for collection of Scala case classes are generated with different anonymous class names in 1.3 Tue, 23 Jan, 14:21
Till Rohrmann (JIRA) [jira] [Created] (FLINK-8495) Serve main cluster components log and stdout file Tue, 23 Jan, 14:26
zentol [GitHub] flink pull request #5340: [FLINK-8475][config][docs] Integrate more ConfigOp... Tue, 23 Jan, 14:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8475) Move remaining sections to generated tables Tue, 23 Jan, 14:28
tillrohrmann [GitHub] flink pull request #5341: [FLINK-8495] [flip6] Enable main cluster component... Tue, 23 Jan, 14:29
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8495) Serve main cluster components log and stdout file Tue, 23 Jan, 14:30
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Tue, 23 Jan, 14:45
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-8496) WebUI does not display TM MemorySegment metrics Tue, 23 Jan, 14:55
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-8496) WebUI does not display TM MemorySegment metrics Tue, 23 Jan, 15:00
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-8496) WebUI does not display TM MemorySegment metrics Tue, 23 Jan, 15:01
Hequn Cheng (JIRA) [jira] [Commented] (FLINK-8492) Fix unsupported exception for udtf with multi calc Tue, 23 Jan, 15:09
StephanEwen [GitHub] flink issue #5331: [FLINK-8473][webUI] Improve error behavior of JarListHand... Tue, 23 Jan, 15:23
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Tue, 23 Jan, 15:24
Fabian Hueske (JIRA) [jira] [Commented] (FLINK-8492) Fix unsupported exception for udtf with multi calc Tue, 23 Jan, 16:00
chris snow (JIRA) [jira] [Created] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist Tue, 23 Jan, 16:09
florianschmidt1994 [GitHub] flink pull request #5342: [FLINK-8470] Timebounded stream join Tue, 23 Jan, 16:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8470) DelayTrigger and DelayAndCountTrigger in Flink Streaming Window API Tue, 23 Jan, 16:39
pluppens [GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co... Tue, 23 Jan, 16:42
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Tue, 23 Jan, 16:43
zentol [GitHub] flink pull request #5343: [FLINK-8496][metrics] Create missing "Network" gro... Tue, 23 Jan, 16:44
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8496) WebUI does not display TM MemorySegment metrics Tue, 23 Jan, 16:45
Chesnay Schepler (JIRA) [jira] [Assigned] (FLINK-8496) WebUI does not display TM MemorySegment metrics Tue, 23 Jan, 16:45
Julian Bauß (JIRA) [jira] [Created] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator Tue, 23 Jan, 16:56
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-5227) Add warning to include flink-table in job fat jars Tue, 23 Jan, 16:57
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-6102) Update protobuf to latest version Tue, 23 Jan, 16:58
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-6142) RemoteStreamExecutionEnvironment throw class cast exception Tue, 23 Jan, 16:58
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1 Tue, 23 Jan, 17:02
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-5030) Support hostname verification Tue, 23 Jan, 17:02
Fabian Hueske (JIRA) [jira] [Commented] (FLINK-5227) Add warning to include flink-table in job fat jars Tue, 23 Jan, 17:04
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-5322) Clean up yarn configuration documentation Tue, 23 Jan, 17:05
Fabian Hueske (JIRA) [jira] [Resolved] (FLINK-5227) Add warning to include flink-table in job fat jars Tue, 23 Jan, 17:05
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator Tue, 23 Jan, 17:07
Fabian Hueske (JIRA) [jira] [Commented] (FLINK-8492) Fix unsupported exception for udtf with multi calc Tue, 23 Jan, 17:22
GJL [GitHub] flink issue #5339: [FLINK-8493] [flip6] Integrate queryable state with Flip-... Tue, 23 Jan, 17:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8493) Integrate queryable state with Flip-6 Tue, 23 Jan, 17:58
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0 Tue, 23 Jan, 19:16
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks Tue, 23 Jan, 19:23
Stephan Ewen (JIRA) [jira] [Updated] (FLINK-8466) ErrorInfo needs to hold Exception as SerializedThrowable Tue, 23 Jan, 19:24
Stephan Ewen (JIRA) [jira] [Updated] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected Tue, 23 Jan, 19:24
Stephan Ewen (JIRA) [jira] [Updated] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected Tue, 23 Jan, 19:24
Stephan Ewen (JIRA) [jira] [Updated] (FLINK-8466) ErrorInfo needs to hold Exception as SerializedThrowable Tue, 23 Jan, 19:25
Stephan Ewen (JIRA) [jira] [Assigned] (FLINK-8466) ErrorInfo needs to hold Exception as SerializedThrowable Tue, 23 Jan, 19:25
Stephan Ewen (JIRA) [jira] [Created] (FLINK-8499) Kryo must not be child-first loaded Tue, 23 Jan, 19:28
fhueske [GitHub] flink pull request #5344: [FLINK-8243] [orc] OrcTableSource reads input path... Tue, 23 Jan, 20:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8243) OrcTableSource should recursively read all files in nested directories of the input path. Tue, 23 Jan, 20:58
StephanEwen [GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co... Tue, 23 Jan, 21:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Tue, 23 Jan, 21:09
Xuan Nguyen (JIRA) [jira] [Commented] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0 Tue, 23 Jan, 21:12
Xuan Nguyen (JIRA) [jira] [Comment Edited] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0 Tue, 23 Jan, 21:12
fhueske [GitHub] flink pull request #5345: [FLINK-8242] [table] Fix predicate push-down of Or... Tue, 23 Jan, 21:14
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8242) ClassCastException in OrcTableSource.toOrcPredicate Tue, 23 Jan, 21:15
bowenli86 [GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co... Tue, 23 Jan, 21:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Tue, 23 Jan, 21:27
lishim [GitHub] flink pull request #5346: [FLINK-8490] [mesos] Allow custom docker parameter... Tue, 23 Jan, 22:22
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8490) Allow custom docker parameters for docker tasks on Mesos Tue, 23 Jan, 22:23
joerg84 [GitHub] flink issue #5346: [FLINK-8490] [mesos] Allow custom docker parameters for d... Tue, 23 Jan, 22:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8490) Allow custom docker parameters for docker tasks on Mesos Tue, 23 Jan, 22:37
cjolif [GitHub] flink issue #4675: [FLINK-7386] FIx Elasticsearch 5 connector is not compati... Tue, 23 Jan, 23:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client Tue, 23 Jan, 23:26
EronWright [GitHub] flink issue #5346: [FLINK-8490] [mesos] Allow custom docker parameters for d... Tue, 23 Jan, 23:37
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8490) Allow custom docker parameters for docker tasks on Mesos Tue, 23 Jan, 23:38
Hequn Cheng (JIRA) [jira] [Commented] (FLINK-8492) Fix unsupported exception for udtf with multi calc Wed, 24 Jan, 02:24
Hequn Cheng (JIRA) [jira] [Updated] (FLINK-8492) [FLINK-8492][table] Fix calc cost bug Wed, 24 Jan, 02:36
yanxiaobin (JIRA) [jira] [Created] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 24 Jan, 03:16
hequn8128 [GitHub] flink pull request #5347: [FLINK-8492][table] Fix calc cost bug Wed, 24 Jan, 05:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8492) [FLINK-8492][table] Fix calc cost bug Wed, 24 Jan, 05:28
aitozi (JIRA) [jira] [Commented] (FLINK-7129) Dynamically changing patterns Wed, 24 Jan, 06:10
toggm [GitHub] flink issue #5172: [FLINK-8275] [Security] fix keytab local path in YarnTask... Wed, 24 Jan, 07:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working Wed, 24 Jan, 07:14
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 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · Next »Thread · Author · Date
Box list
Jul 20195765
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