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
GitBox [GitHub] StefanRRichter commented on issue #6500: [FLINK-10066] Keep only archived version of previous executions Mon, 06 Aug, 08:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10066) Keep only archived version of previous executions Mon, 06 Aug, 08:21
GitBox [GitHub] asfgit closed pull request #6497: [FLINK-10064] [table] Fix a typo in ExternalCatalogTable Mon, 06 Aug, 08:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10064) Fix a typo in ExternalCatalogTable Mon, 06 Aug, 08:26
GitBox [GitHub] StefanRRichter commented on issue #6500: [FLINK-10066] Keep only archived version of previous executions Mon, 06 Aug, 08:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10066) Keep only archived version of previous executions Mon, 06 Aug, 08:28
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-10061) Fix unsupported reconfiguration in KafkaTableSink Mon, 06 Aug, 08:29
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-10064) Fix a typo in ExternalCatalogTable Mon, 06 Aug, 08:29
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-10064) Fix a typo in ExternalCatalogTable Mon, 06 Aug, 08:29
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-10051) SQL client E2E test is missing dependencies Mon, 06 Aug, 08:30
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large Mon, 06 Aug, 08:30
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9975) Netty dependency of Hadoop >= 2.7 is not relocated Mon, 06 Aug, 08:31
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9944) Cleanup end-to-end test poms Mon, 06 Aug, 08:31
Timo Walther (JIRA) [jira] [Resolved] (FLINK-10064) Fix a typo in ExternalCatalogTable Mon, 06 Aug, 08:31
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9943) Support TaskManagerMetricQueryServicePaths msg in JobManager Actor Mon, 06 Aug, 08:31
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase) Mon, 06 Aug, 08:32
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9812) SpanningRecordSerializationTest fails on travis Mon, 06 Aug, 08:32
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc Mon, 06 Aug, 08:32
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9913) Improve output serialization only once in RecordWriter Mon, 06 Aug, 08:32
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase Mon, 06 Aug, 08:33
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering Mon, 06 Aug, 08:33
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9776) Interrupt TaskThread only while in User/Operator code Mon, 06 Aug, 08:33
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc. Mon, 06 Aug, 08:33
Till Rohrmann (JIRA) [jira] [Assigned] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering Mon, 06 Aug, 08:33
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9727) Allow user to pass resource tag expression in command line Mon, 06 Aug, 08:34
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures Mon, 06 Aug, 08:34
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9725) Add tag support to standalone cluster manager. Mon, 06 Aug, 08:34
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9724) Add tag support to yarn resource manager Mon, 06 Aug, 08:34
GitBox [GitHub] twalthr commented on a change in pull request #6486: [FLINK-10051][tests][sql] Add missing depenendeices for sql client E2E test Mon, 06 Aug, 08:34
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10051) SQL client E2E test is missing dependencies Mon, 06 Aug, 08:35
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests Mon, 06 Aug, 08:35
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests Mon, 06 Aug, 08:35
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9723) Add tags support to mesos resource manager Mon, 06 Aug, 08:35
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9722) Add resource tag predicate into slot manager Mon, 06 Aug, 08:35
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9693) Possible memory leak in jobmanager retaining archived checkpoints Mon, 06 Aug, 08:35
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9721) Introduce ResourceTagExpression class Mon, 06 Aug, 08:35
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Mon, 06 Aug, 08:35
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis Mon, 06 Aug, 08:36
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers Mon, 06 Aug, 08:36
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Mon, 06 Aug, 08:36
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files Mon, 06 Aug, 08:36
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9582) dist assemblies access jars outside of flink-dist Mon, 06 Aug, 08:36
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Mon, 06 Aug, 08:37
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition Mon, 06 Aug, 08:37
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9478) Use Yarn application proxy to communicate with Flink cluster Mon, 06 Aug, 08:38
Aljoscha Krettek (JIRA) [jira] [Reopened] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator Mon, 06 Aug, 08:38
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect Mon, 06 Aug, 08:38
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator Mon, 06 Aug, 08:38
Aljoscha Krettek (JIRA) [jira] [Reopened] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator Mon, 06 Aug, 08:38
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState Mon, 06 Aug, 08:38
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-10026) Integrate heap based timers in RocksDB backend with incremental checkpoints Mon, 06 Aug, 08:38
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator Mon, 06 Aug, 08:38
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-8478) Add support for time-bounded joins in DataStream API Mon, 06 Aug, 08:38
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9400) change import statement for flink-scala Mon, 06 Aug, 08:39
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9462) Disentangle flink-json and flink-table Mon, 06 Aug, 08:39
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations Mon, 06 Aug, 08:39
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json Mon, 06 Aug, 08:39
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable Mon, 06 Aug, 08:40
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9382) Inconsistent file storage behavior in FileCache Mon, 06 Aug, 08:40
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-9364) Add doc of the memory usage in flink Mon, 06 Aug, 08:40
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers Mon, 06 Aug, 08:41
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down Mon, 06 Aug, 08:41
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors Mon, 06 Aug, 08:42
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9205) Delete non-well-defined SinkFunctions Mon, 06 Aug, 08:42
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job Mon, 06 Aug, 08:42
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9193) Deprecate non-well-defined output methods on DataStream Mon, 06 Aug, 08:42
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9195) Delete non-well-defined output methods on DataStream Mon, 06 Aug, 08:42
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-9690) Restoring state with FlinkKafkaProducer and Kafka 1.1.0 client fails Mon, 06 Aug, 08:43
GitBox [GitHub] TisonKun commented on issue #6499: [hotfix] loose dependency to mockito Mon, 06 Aug, 08:43
Timo Walther (JIRA) [jira] [Updated] (FLINK-10064) Fix a typo in ExternalCatalogTable Mon, 06 Aug, 08:47
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-9182) async checkpoints for timer service Mon, 06 Aug, 08:49
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1 Mon, 06 Aug, 08:49
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9168) Pulsar Sink Connector Mon, 06 Aug, 08:49
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-10062) Docs are not built due to git-commit-id-plugin Mon, 06 Aug, 08:49
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 08:49
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9116) Introduce getAll and removeAll for MapState Mon, 06 Aug, 08:50
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-10029) Refactor Streaming File Sink for better separation of concerns. Mon, 06 Aug, 08:50
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9752) Add an S3 RecoverableWriter Mon, 06 Aug, 08:50
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9117) Disable artifact download in mesos container environment. Mon, 06 Aug, 08:50
Aljoscha Krettek (JIRA) [jira] [Reopened] (FLINK-10029) Refactor the code for better separation of concerns. Mon, 06 Aug, 08:50
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-10029) Refactor Streaming File Sink for better separation of concerns. Mon, 06 Aug, 08:50
GitBox [GitHub] twalthr commented on issue #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support Mon, 06 Aug, 08:50
GitBox [GitHub] twalthr edited a comment on issue #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support Mon, 06 Aug, 08:50
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6847) Add TIMESTAMPDIFF supported in TableAPI Mon, 06 Aug, 08:51
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9050) Expose operator IO counter metrics Mon, 06 Aug, 08:51
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6847) Add TIMESTAMPDIFF supported in TableAPI Mon, 06 Aug, 08:51
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8970) Add more automated end-to-end tests Mon, 06 Aug, 08:51
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9036) Add default value via suppliers Mon, 06 Aug, 08:51
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6 Mon, 06 Aug, 08:51
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-9055) WebUI shows job as Running although not enough resources are available Mon, 06 Aug, 08:51
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException Mon, 06 Aug, 08:52
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8918) Introduce Runtime Filter Join Mon, 06 Aug, 08:52
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes Mon, 06 Aug, 08:52
GitBox [GitHub] aljoscha commented on issue #6481: [FLINK-10037] [Documentation] Add Event Time Details documentation page Mon, 06 Aug, 08:52
GitBox [GitHub] aljoscha commented on issue #6481: [FLINK-10037] [Documentation] Add Event Time Details documentation page Mon, 06 Aug, 08:52
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8672) Support continuous processing in CSV table source Mon, 06 Aug, 08:53
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable Mon, 06 Aug, 08:53
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures Mon, 06 Aug, 08:53
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8660) Enable the user to provide custom HAServices implementation Mon, 06 Aug, 08:53
Till Rohrmann (JIRA) [jira] [Updated] (FLINK-8779) ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis Mon, 06 Aug, 08:53
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
Feb 202010477
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