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
Till Rohrmann (JIRA) [jira] [Created] (FLINK-8471) Add Flip-6 configuration switch Mon, 22 Jan, 08:53
Vijay Kansal (JIRA) [jira] [Updated] (FLINK-8470) DelayTrigger and DelayAndCountTrigger in Flink Streaming Window API Mon, 22 Jan, 09:25
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint() Mon, 22 Jan, 09:52
tillrohrmann [GitHub] flink pull request #5318: [FLINK-8462] [flip6] Filter invalid heartbeat time... Mon, 22 Jan, 09:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8462) TaskExecutor does not verify RM heartbeat timeouts Mon, 22 Jan, 10:00
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 Mon, 22 Jan, 10:07
GJL [GitHub] flink pull request #5312: [FLINK-8344][WIP] Add support for HA to RestCluste... Mon, 22 Jan, 10:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient Mon, 22 Jan, 10:12
Jelmer Kuperus (JIRA) [jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" Mon, 22 Jan, 10:13
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8286) Investigate Flink-Yarn-Kerberos integration for flip-6 Mon, 22 Jan, 10:16
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8042) retry individual failover-strategy for some time first before reverting to full job restart Mon, 22 Jan, 10:18
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7881) flink can't deployed on yarn with ha Mon, 22 Jan, 10:18
Jelmer Kuperus (JIRA) [jira] [Comment Edited] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" Mon, 22 Jan, 10:18
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8020) Deadlock found in Flink Streaming job Mon, 22 Jan, 10:18
StefanRRichter [GitHub] flink pull request #5323: [FLINK-8441] [State Backend] [RocksDB] change Rock... Mon, 22 Jan, 10:34
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8441) serialize values and value separator directly to stream in RocksDBListState Mon, 22 Jan, 10:35
StefanRRichter [GitHub] flink pull request #5323: [FLINK-8441] [State Backend] [RocksDB] change Rock... Mon, 22 Jan, 10:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8441) serialize values and value separator directly to stream in RocksDBListState Mon, 22 Jan, 10:36
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8230) NPE in OrcRowInputFormat on nested structs Mon, 22 Jan, 10:41
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8043) change fullRestarts (for fine grained recovery) from guage to counter Mon, 22 Jan, 10:41
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8202) Update queryable section on configuration page Mon, 22 Jan, 10:42
Ufuk Celebi (JIRA) [jira] [Commented] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher Mon, 22 Jan, 10:44
alpinegizmo [GitHub] flink pull request #5277: [hotfix][docs]Review to reduce passive voice, impr... Mon, 22 Jan, 10:51
StefanRRichter [GitHub] flink pull request #5326: [FLINK-8365] [State Backend] Relax List type in He... Mon, 22 Jan, 10:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8365) Relax List type in HeapListState and HeapKeyedStateBackend Mon, 22 Jan, 10:55
tzulitai [GitHub] flink issue #5301: [FLINK-8267] [Kinesis Connector] update Kinesis Producer ... Mon, 22 Jan, 10:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8267) update Kinesis Producer example for setting Region key Mon, 22 Jan, 10:57
tzulitai [GitHub] flink pull request #5301: [FLINK-8267] [Kinesis Connector] update Kinesis Pr... Mon, 22 Jan, 10:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8267) update Kinesis Producer example for setting Region key Mon, 22 Jan, 10:58
tzulitai [GitHub] flink issue #5298: [FLINK-8433] [doc] Remove ununsed CheckpointedRestoring i... Mon, 22 Jan, 10:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8433) Update code example for "Managed Operator State" documentation Mon, 22 Jan, 11:00
alpinegizmo [GitHub] flink pull request #5317: [FLINK-8458] Add the switch for keeping both the o... Mon, 22 Jan, 11:10
alpinegizmo [GitHub] flink pull request #5317: [FLINK-8458] Add the switch for keeping both the o... Mon, 22 Jan, 11:10
Stephan Ewen (JIRA) [jira] [Assigned] (FLINK-8406) BucketingSink does not detect hadoop file systems Mon, 22 Jan, 11:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8458) Add the switch for keeping both the old mode and the new credit-based mode Mon, 22 Jan, 11:11
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8020) Deadlock found in Flink Streaming job Mon, 22 Jan, 11:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8458) Add the switch for keeping both the old mode and the new credit-based mode Mon, 22 Jan, 11:11
StephanEwen [GitHub] flink issue #5328: [hotfix][codestyle] Refactor equals for StreamRecord Mon, 22 Jan, 11:13
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-8472) Extend migration tests for Flink 1.4 Mon, 22 Jan, 11:15
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-8472) Extend migration tests for Flink 1.4 Mon, 22 Jan, 11:15
satybald [GitHub] flink issue #5328: [hotfix][codestyle] Refactor equals for StreamRecord Mon, 22 Jan, 11:19
satybald [GitHub] flink pull request #5328: [hotfix][codestyle] Refactor equals for StreamReco... Mon, 22 Jan, 11:19
Chen Qin (JIRA) [jira] [Assigned] (FLINK-8437) SideOutput() API is ambiguous Mon, 22 Jan, 11:21
tillrohrmann [GitHub] flink issue #5318: [FLINK-8462] [flip6] Filter invalid heartbeat timeouts in... Mon, 22 Jan, 11:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8462) TaskExecutor does not verify RM heartbeat timeouts Mon, 22 Jan, 11:34
StephanEwen [GitHub] flink issue #5315: [hotfix][docs] Put HADOOP_CONF_DIR in <code> tag Mon, 22 Jan, 11:36
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-8406) BucketingSink does not detect hadoop file systems Mon, 22 Jan, 12:08
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 12:13
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8406) BucketingSink does not detect hadoop file systems Mon, 22 Jan, 12:14
asfgit [GitHub] flink pull request #5315: [hotfix][docs] Put HADOOP_CONF_DIR in <code> tag Mon, 22 Jan, 12:37
StephanEwen [GitHub] flink pull request #5330: [FLINK-8406] [bucketing sink] Fix proper access of... Mon, 22 Jan, 12:38
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-5018) Make source idle timeout user configurable Mon, 22 Jan, 12:39
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5018) Make source idle timeout user configurable Mon, 22 Jan, 12:39
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8406) BucketingSink does not detect hadoop file systems Mon, 22 Jan, 12:39
zentol [GitHub] flink pull request #5331: [FLINK-8473][webUI] Improve error behavior of JarL... Mon, 22 Jan, 12:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 12:42
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-8406) BucketingSink does not detect hadoop file systems Mon, 22 Jan, 12:45
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables Mon, 22 Jan, 12:50
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-6464) Metric name is not stable Mon, 22 Jan, 13:06
Chesnay Schepler (JIRA) [jira] [Assigned] (FLINK-6464) Metric name is not stable Mon, 22 Jan, 13:06
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-6464) Metric name is not stable Mon, 22 Jan, 13:06
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-6464) Metric name is not stable Mon, 22 Jan, 13:06
asfgit [GitHub] flink pull request #4745: [FLINK-7720] [state backends] Centralize creation ... Mon, 22 Jan, 13:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7720) Centralize creation of backends and state related resources Mon, 22 Jan, 13:11
uce [GitHub] flink pull request #5331: [FLINK-8473][webUI] Improve error behavior of JarL... Mon, 22 Jan, 13:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 13:18
zentol [GitHub] flink pull request #: Mon, 22 Jan, 13:19
zentol [GitHub] flink pull request #5331: [FLINK-8473][webUI] Improve error behavior of JarL... Mon, 22 Jan, 13:24
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 13:25
zentol [GitHub] flink pull request #5331: [FLINK-8473][webUI] Improve error behavior of JarL... Mon, 22 Jan, 13:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 13:26
uce [GitHub] flink pull request #5331: [FLINK-8473][webUI] Improve error behavior of JarL... Mon, 22 Jan, 13:29
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 13:30
zentol [GitHub] flink pull request #5331: [FLINK-8473][webUI] Improve error behavior of JarL... Mon, 22 Jan, 13:30
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 13:31
Fabian Hueske (JIRA) [jira] [Created] (FLINK-8474) Add documentation for HBaseTableSource Mon, 22 Jan, 13:35
Fabian Hueske (JIRA) [jira] [Updated] (FLINK-7593) Generated plan does not create correct groups Mon, 22 Jan, 13:41
Fabian Hueske (JIRA) [jira] [Updated] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client Mon, 22 Jan, 13:48
Fabian Hueske (JIRA) [jira] [Updated] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client Mon, 22 Jan, 13:48
zentol [GitHub] flink issue #5331: [FLINK-8473][webUI] Improve error behavior of JarListHand... Mon, 22 Jan, 14:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 14:03
StephanEwen [GitHub] flink issue #5330: [FLINK-8406] [bucketing sink] Fix proper access of Hadoop... Mon, 22 Jan, 14:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8406) BucketingSink does not detect hadoop file systems Mon, 22 Jan, 14:04
uce [GitHub] flink issue #5331: [FLINK-8473][webUI] Improve error behavior of JarListHand... Mon, 22 Jan, 14:06
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted Mon, 22 Jan, 14:07
zentol [GitHub] flink pull request #5332: [FLINK-6464][streaming] Stabilize default window o... Mon, 22 Jan, 14:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6464) Metric name is not stable Mon, 22 Jan, 14:08
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-6590) Integrate generated tables into documentation Mon, 22 Jan, 14:10
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-8475) Move remaining sections to generated tables Mon, 22 Jan, 14:12
tillrohrmann [GitHub] flink pull request #: Mon, 22 Jan, 14:14
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-8043) change fullRestarts (for fine grained recovery) from guage to counter Mon, 22 Jan, 14:27
zentol [GitHub] flink pull request #5333: Review5886 Mon, 22 Jan, 14:50
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5886) Python API for streaming applications Mon, 22 Jan, 14:51
zentol [GitHub] flink issue #5333: [FLINK-5886] Python API for streaming applications Mon, 22 Jan, 14:51
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-8476) ConfigConstants#DEFAULT_HA_JOB_MANAGER_PORT unused Mon, 22 Jan, 15:09
tillrohrmann [GitHub] flink pull request #5334: [FLINK-8471] [flip6] Introduce configuration switc... Mon, 22 Jan, 15:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8471) Add Flip-6 configuration switch Mon, 22 Jan, 15:13
tillrohrmann [GitHub] flink issue #5319: [FLINK-8463] [rest] Remove blocking of IO executor in Res... Mon, 22 Jan, 15:14
tzulitai [GitHub] flink pull request #5335: (master) [FLINK-8419] [kafka] Register metrics for... Mon, 22 Jan, 15:14
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8463) Remove unnecessary thread blocking in RestClient#submitRequest Mon, 22 Jan, 15:15
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
Oct 20197146
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