flink-issues mailing list archives: December 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 · Next »Thread · Author · Date
[jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState Mon, 17 Dec, 15:57
[jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException Mon, 17 Dec, 15:57
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException Tue, 18 Dec, 15:26
[jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures Mon, 17 Dec, 15:58
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures Tue, 18 Dec, 15:27
[jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' unstable
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' unstable Mon, 17 Dec, 15:58
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' unstable Tue, 18 Dec, 15:29
[jira] [Updated] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase) Mon, 17 Dec, 15:58
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase) Tue, 18 Dec, 15:28
[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics Mon, 17 Dec, 15:58
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics Mon, 17 Dec, 16:01
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics Tue, 18 Dec, 15:28
[jira] [Updated] (FLINK-10694) ZooKeeperHaServices Cleanup
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10694) ZooKeeperHaServices Cleanup Mon, 17 Dec, 15:58
[jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException Mon, 17 Dec, 15:59
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException Tue, 18 Dec, 15:32
[jira] [Updated] (FLINK-9485) Improving Flink’s timer management for large state
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9485) Improving Flink’s timer management for large state Mon, 17 Dec, 15:59
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9485) Improving Flink’s timer management for large state Mon, 17 Dec, 16:00
[jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations Mon, 17 Dec, 15:59
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations Tue, 18 Dec, 15:33
vinoyang (JIRA)   [jira] [Assigned] (FLINK-9457) Cancel container requests when cancelling pending slot allocations Wed, 19 Dec, 01:48
boshu Zheng (JIRA)   [jira] [Assigned] (FLINK-9457) Cancel container requests when cancelling pending slot allocations Thu, 27 Dec, 02:12
[jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect Mon, 17 Dec, 15:59
[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Mon, 17 Dec, 16:00
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Tue, 18 Dec, 15:34
[jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests Mon, 17 Dec, 16:00
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests Tue, 18 Dec, 15:36
[jira] [Updated] (FLINK-9749) Rework Bucketing Sink
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9749) Rework Bucketing Sink Mon, 17 Dec, 16:02
[jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters Mon, 17 Dec, 16:02
[jira] [Updated] (FLINK-9776) Interrupt TaskThread only while in User/Operator code
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9776) Interrupt TaskThread only while in User/Operator code Mon, 17 Dec, 16:02
[jira] [Updated] (FLINK-10079) Support external sink table in INSERT INTO statement
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10079) Support external sink table in INSERT INTO statement Mon, 17 Dec, 16:02
[jira] [Updated] (FLINK-10317) Configure Metaspace size by default
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10317) Configure Metaspace size by default Mon, 17 Dec, 16:02
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-10317) Configure Metaspace size by default Tue, 18 Dec, 15:37
Nawaid Shamim (JIRA)   [jira] [Commented] (FLINK-10317) Configure Metaspace size by default Wed, 19 Dec, 15:40
Nawaid Shamim (JIRA)   [jira] [Updated] (FLINK-10317) Configure Metaspace size by default Wed, 19 Dec, 15:40
Nico Kruber (JIRA)   [jira] [Comment Edited] (FLINK-10317) Configure Metaspace size by default Thu, 20 Dec, 11:02
Nico Kruber (JIRA)   [jira] [Commented] (FLINK-10317) Configure Metaspace size by default Thu, 20 Dec, 11:02
Nawaid Shamim (JIRA)   [jira] [Commented] (FLINK-10317) Configure Metaspace size by default Thu, 20 Dec, 14:07
Nawaid Shamim (JIRA)   [jira] [Comment Edited] (FLINK-10317) Configure Metaspace size by default Thu, 20 Dec, 14:14
Nico Kruber (JIRA)   [jira] [Commented] (FLINK-10317) Configure Metaspace size by default Thu, 20 Dec, 15:31
[jira] [Updated] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method Mon, 17 Dec, 16:03
[jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C Mon, 17 Dec, 16:03
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C Tue, 18 Dec, 15:38
[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices Mon, 17 Dec, 16:05
[jira] [Updated] (FLINK-9812) SpanningRecordSerializationTest fails on travis
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9812) SpanningRecordSerializationTest fails on travis Mon, 17 Dec, 16:06
[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down Mon, 17 Dec, 16:06
[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once Mon, 17 Dec, 16:08
GitBox [GitHub] azagrebin opened a new pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer Mon, 17 Dec, 16:19
GitBox [GitHub] walterddr commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation Mon, 17 Dec, 17:33
[jira] [Created] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues
Addison Higham (JIRA)   [jira] [Created] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues Mon, 17 Dec, 21:50
Addison Higham (JIRA)   [jira] [Commented] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues Mon, 17 Dec, 21:51
Steve Loughran (JIRA)   [jira] [Commented] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues Thu, 20 Dec, 15:36
[GitHub] sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor…
GitBox   [GitHub] sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… Mon, 17 Dec, 23:30
GitBox   [GitHub] sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… Mon, 17 Dec, 23:32
GitBox   [GitHub] sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… Mon, 17 Dec, 23:33
[jira] [Created] (FLINK-11188) Bounded over should not enable state retention time
Hequn Cheng (JIRA)   [jira] [Created] (FLINK-11188) Bounded over should not enable state retention time Tue, 18 Dec, 02:05
Fabian Hueske (JIRA)   [jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time Fri, 21 Dec, 21:16
Hequn Cheng (JIRA)   [jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time Sat, 22 Dec, 06:36
Fabian Hueske (JIRA)   [jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time Sat, 22 Dec, 13:01
Hequn Cheng (JIRA)   [jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time Sat, 22 Dec, 13:17
Hequn Cheng (JIRA)   [jira] [Comment Edited] (FLINK-11188) Bounded over should not enable state retention time Sat, 22 Dec, 13:42
GitBox [GitHub] XiaoZYang commented on issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector Tue, 18 Dec, 02:08
GitBox [GitHub] XiaoZYang closed pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector Tue, 18 Dec, 02:08
[GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction
GitBox   [GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction Tue, 18 Dec, 03:14
GitBox   [GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction Tue, 18 Dec, 03:14
GitBox   [GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction Tue, 18 Dec, 03:14
GitBox   [GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction Wed, 19 Dec, 17:54
GitBox   [GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction Wed, 19 Dec, 17:54
GitBox   [GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction Thu, 20 Dec, 04:39
[GitHub] Clarkkkkk commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation
GitBox   [GitHub] Clarkkkkk commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation Tue, 18 Dec, 03:30
GitBox   [GitHub] Clarkkkkk commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation Thu, 20 Dec, 01:57
GitBox [GitHub] asfgit closed pull request #7267: [FLINK-11083][Table&SQL] CRowSerializerConfigSnapshot is not instantiable Tue, 18 Dec, 04:08
GitBox [GitHub] kisimple opened a new pull request #7321: [hotfix] Fix typo in AbstractStreamOperator Tue, 18 Dec, 06:08
GitBox [GitHub] leesf removed a comment on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID Tue, 18 Dec, 06:24
[GitHub] sunjincheng121 commented on issue #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor…
GitBox   [GitHub] sunjincheng121 commented on issue #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… Tue, 18 Dec, 06:33
GitBox   [GitHub] sunjincheng121 commented on issue #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… Mon, 24 Dec, 00:44
GitBox [GitHub] xueyumusic commented on issue #7318: [FLINK-11099][Table API&SQL] Migrate flink-table runtime CRow Types classes Tue, 18 Dec, 06:46
[jira] [Commented] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component
Alexander Lehmann (JIRA)   [jira] [Commented] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component Tue, 18 Dec, 07:13
[GitHub] KarmaGYZ commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend
GitBox   [GitHub] KarmaGYZ commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend Tue, 18 Dec, 07:23
GitBox   [GitHub] KarmaGYZ commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend Tue, 18 Dec, 07:23
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 · Next »Thread · Author · Date
Box list
Feb 20204480
Jan 20208835
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