flink-issues mailing list archives: August 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 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client Sun, 12 Aug, 05:17
GitBox [GitHub] yanghua commented on a change in pull request #6540: [FLINK-9891] Added hook to shutdown cluster if a session was created in per-job mode. Sun, 12 Aug, 05:34
GitBox [GitHub] yanghua commented on a change in pull request #6540: [FLINK-9891] Added hook to shutdown cluster if a session was created in per-job mode. Sun, 12 Aug, 05:34
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped Sun, 12 Aug, 05:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped Sun, 12 Aug, 05:35
Guibo Pan (JIRA) [jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Sun, 12 Aug, 07:03
GitBox [GitHub] buptljy opened a new pull request #6541: [FLINK-9964][Table API & SQL] - Add a CSV table format factory Sun, 12 Aug, 07:44
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-9964) Add a CSV table format factory Sun, 12 Aug, 07:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9964) Add a CSV table format factory Sun, 12 Aug, 07:45
GitBox [GitHub] buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi Sun, 12 Aug, 07:50
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL Sun, 12 Aug, 07:51
buptljy (JIRA) [jira] [Assigned] (FLINK-10119) JsonRowDeserializationSchema deserialize kafka message Sun, 12 Aug, 07:57
buptljy (JIRA) [jira] [Commented] (FLINK-10119) JsonRowDeserializationSchema deserialize kafka message Sun, 12 Aug, 08:01
buptljy (JIRA) [jira] [Assigned] (FLINK-10120) Support string representation for types like array Sun, 12 Aug, 08:21
GitBox [GitHub] yanghua opened a new pull request #6542: [FLINK-6437][History Server] Move history server configuration to a separate file Sun, 12 Aug, 08:50
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-6437) Move history server configuration to a separate file Sun, 12 Aug, 08:51
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6437) Move history server configuration to a separate file Sun, 12 Aug, 08:51
GitBox [GitHub] yanghua commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file Sun, 12 Aug, 08:55
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6437) Move history server configuration to a separate file Sun, 12 Aug, 08:56
vinoyang (JIRA) [jira] [Assigned] (FLINK-9812) SpanningRecordSerializationTest fails on travis Sun, 12 Aug, 08:58
GitBox [GitHub] yanghua opened a new pull request #6543: [FLINK-9919] Remove unit from fullRestarts metric docs Sun, 12 Aug, 09:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9919) Remove unit from fullRestarts metric docs Sun, 12 Aug, 09:09
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-9919) Remove unit from fullRestarts metric docs Sun, 12 Aug, 09:09
GitBox [GitHub] yanghua commented on issue #6543: [FLINK-9919] Remove unit from fullRestarts metric docs Sun, 12 Aug, 09:09
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9919) Remove unit from fullRestarts metric docs Sun, 12 Aug, 09:10
GitBox [GitHub] Guibo-Pan opened a new pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition Sun, 12 Aug, 09:20
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Sun, 12 Aug, 09:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Sun, 12 Aug, 09:21
Alexis Sarda-Espinosa (JIRA) [jira] [Created] (FLINK-10126) There should be a Scala DataSource Sun, 12 Aug, 09:31
vinoyang (JIRA) [jira] [Assigned] (FLINK-10126) There should be a Scala DataSource Sun, 12 Aug, 12:57
GitBox [GitHub] Aitozi commented on issue #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process Sun, 12 Aug, 14:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9642) Reduce the count to deal with state during a CEP process Sun, 12 Aug, 14:02
Alexey Trenikhin (JIRA) [jira] [Created] (FLINK-10127) Add TypeInformation and serializers for JDK7 Instant Sun, 12 Aug, 15:28
GitBox [GitHub] Aitozi commented on issue #5058: [FLINK-5465] [streaming] Wait for pending timer threads to finish or … Sun, 12 Aug, 15:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear() Sun, 12 Aug, 15:37
GitBox [GitHub] StefanRRichter commented on issue #5058: [FLINK-5465] [streaming] Wait for pending timer threads to finish or … Sun, 12 Aug, 16:17
GitBox [GitHub] StefanRRichter edited a comment on issue #5058: [FLINK-5465] [streaming] Wait for pending timer threads to finish or … Sun, 12 Aug, 16:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear() Sun, 12 Aug, 16:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear() Sun, 12 Aug, 16:18
GitBox [GitHub] StefanRRichter edited a comment on issue #5058: [FLINK-5465] [streaming] Wait for pending timer threads to finish or … Sun, 12 Aug, 16:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear() Sun, 12 Aug, 16:22
Yuta Morisawa (JIRA) [jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Mon, 13 Aug, 00:29
GitBox [GitHub] maqingxiang commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 Mon, 13 Aug, 02:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8 Mon, 13 Aug, 02:26
GitBox [GitHub] tragicjun commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs Mon, 13 Aug, 02:39
buptljy (JIRA) [jira] [Commented] (FLINK-10126) There should be a Scala DataSource Mon, 13 Aug, 03:04
GitBox [GitHub] Guibo-Pan closed pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition Mon, 13 Aug, 03:07
GitBox [GitHub] Guibo-Pan opened a new pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition Mon, 13 Aug, 03:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Mon, 13 Aug, 03:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Mon, 13 Aug, 03:08
Alexey Trenikhin (JIRA) [jira] [Updated] (FLINK-10127) Add TypeInformation and serializers for JDK8 Instant Mon, 13 Aug, 03:50
Alexey Trenikhin (JIRA) [jira] [Updated] (FLINK-10127) Add TypeInformation and serializers for JDK8 Instant Mon, 13 Aug, 03:50
GitBox [GitHub] buptljy commented on a change in pull request #6359: [FLINK-6895][table]Add STR_TO_DATE supported in SQL Mon, 13 Aug, 05:42
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL Mon, 13 Aug, 05:43
buptljy (JIRA) [jira] [Created] (FLINK-10128) Timeout on transfering jars on travis-ci Mon, 13 Aug, 05:58
GitBox [GitHub] buptljy commented on issue #6541: [FLINK-9964][Table API & SQL] - Add a CSV table format factory Mon, 13 Aug, 05:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9964) Add a CSV table format factory Mon, 13 Aug, 05:59
buptljy (JIRA) [jira] [Commented] (FLINK-9964) Add a CSV table format factory Mon, 13 Aug, 06:01
vinoyang (JIRA) [jira] [Commented] (FLINK-10126) There should be a Scala DataSource Mon, 13 Aug, 06:11
Keshav Lodhi (JIRA) [jira] [Updated] (FLINK-10018) Want to have stop command with checkpointing Mon, 13 Aug, 06:17
Keshav Lodhi (JIRA) [jira] [Commented] (FLINK-10018) Want to have stop command with checkpointing Mon, 13 Aug, 06:18
buptljy (JIRA) [jira] [Commented] (FLINK-10126) There should be a Scala DataSource Mon, 13 Aug, 06:28
Gary Yao (JIRA) [jira] [Commented] (FLINK-10104) Job super slow to start Mon, 13 Aug, 06:38
Gary Yao (JIRA) [jira] [Comment Edited] (FLINK-10104) Job super slow to start Mon, 13 Aug, 06:39
GitBox [GitHub] GJL opened a new pull request #6545: [hotfix][kubernetes] Fix broken hyperlink in README.md Mon, 13 Aug, 06:46
Keshav Lodhi (JIRA) [jira] [Created] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster Mon, 13 Aug, 06:49
Dawid Wysakowicz (JIRA) [jira] [Commented] (FLINK-10128) Timeout on transfering jars on travis-ci Mon, 13 Aug, 07:03
Dawid Wysakowicz (JIRA) [jira] [Comment Edited] (FLINK-10128) Timeout on transfering jars on travis-ci Mon, 13 Aug, 07:04
Dawid Wysakowicz (JIRA) [jira] [Closed] (FLINK-10128) Timeout on transfering jars on travis-ci Mon, 13 Aug, 07:04
GitBox [GitHub] tillrohrmann closed pull request #6545: [hotfix][kubernetes] Fix broken hyperlink in README.md Mon, 13 Aug, 07:09
GitBox [GitHub] tillrohrmann commented on issue #6334: [FLINK-5232] Add a Thread default uncaught exception handler on the JobManager Mon, 13 Aug, 07:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager Mon, 13 Aug, 07:12
eugen yushin (JIRA) [jira] [Updated] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams Mon, 13 Aug, 07:20
GitBox [GitHub] zentol commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs Mon, 13 Aug, 07:20
GitBox [GitHub] zentol edited a comment on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs Mon, 13 Aug, 07:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases Mon, 13 Aug, 07:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases Mon, 13 Aug, 07:21
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped Mon, 13 Aug, 07:24
GitBox [GitHub] zentol commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file Mon, 13 Aug, 07:25
GitBox [GitHub] tillrohrmann commented on a change in pull request #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client Mon, 13 Aug, 07:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6437) Move history server configuration to a separate file Mon, 13 Aug, 07:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client Mon, 13 Aug, 07:26
GitBox [GitHub] zentol closed pull request #6543: [FLINK-9919] Remove unit from fullRestarts metric docs Mon, 13 Aug, 07:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9919) Remove unit from fullRestarts metric docs Mon, 13 Aug, 07:28
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-9919) Remove unit from fullRestarts metric docs Mon, 13 Aug, 07:28
GitBox [GitHub] yanghua commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file Mon, 13 Aug, 07:37
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6437) Move history server configuration to a separate file Mon, 13 Aug, 07:38
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-8893) NPE when netty try to allocate directBuffer Mon, 13 Aug, 07:38
Stefan Richter (JIRA) [jira] [Commented] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster Mon, 13 Aug, 07:46
GitBox [GitHub] yanghua commented on a change in pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition Mon, 13 Aug, 07:50
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-2739) Release script depends on the order of parent module information Mon, 13 Aug, 07:51
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-2435) Add support for custom CSV field parsers Mon, 13 Aug, 07:51
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-2739) Release script depends on the order of parent module information Mon, 13 Aug, 07:51
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Mon, 13 Aug, 07:51
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-2491) Checkpointing only works if all operators/tasks are still running Mon, 13 Aug, 07:51
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API Mon, 13 Aug, 07:51
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-3388) Expose task accumulators via JMX Mon, 13 Aug, 07:52
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-3249) Wrong "unknown partition state/input gate" error messages Mon, 13 Aug, 07:52
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-3448) WebRuntimeMonitor: Move initialization of handlers to start() method Mon, 13 Aug, 07:52
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3 Mon, 13 Aug, 07:52
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 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · Next »Thread · Author · Date
Box list
Jan 20205531
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