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-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc Wed, 22 Aug, 14:46
GitBox [GitHub] GJL commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint Wed, 22 Aug, 14:55
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10193) Default RPC timeout is used when triggering savepoint via JobMasterGateway Wed, 22 Aug, 14:56
GitBox [GitHub] twalthr commented on issue #6585: [FLINK-10172][table]re-adding asc & desc suffix expression to expressionParser Wed, 22 Aug, 15:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc Wed, 22 Aug, 15:04
GitBox [GitHub] yanghua commented on a change in pull request #6593: [hotfix][flink-streaming-java] modify typo in the StreamingJobGraphGenerator.java Wed, 22 Aug, 15:11
Dawid Wysakowicz (JIRA) [jira] [Created] (FLINK-10199) StandaloneSessionClusterEntrypoint does not respect host/ui-port given from jobmanager.sh Wed, 22 Aug, 15:24
Stefan Richter (JIRA) [jira] [Created] (FLINK-10200) Consolidate FileBasedStateOutputStream and FsCheckpointStateOutputStream Wed, 22 Aug, 15:34
Andrew Roberts (JIRA) [jira] [Commented] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala Wed, 22 Aug, 17:09
GitBox [GitHub] FredTing commented on a change in pull request #6105: [FLINK-8500] Get the timestamp of the Kafka message from kafka consumer Wed, 22 Aug, 19:39
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 22 Aug, 19:40
GitBox [GitHub] StephanEwen opened a new pull request #6604: [FLINK-9061] Optionally add entropy to checkpoint paths better S3 scalability Wed, 22 Aug, 21:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability Wed, 22 Aug, 21:02
GitBox [GitHub] StephanEwen commented on issue #6302: [FLINK-9061][checkpointing] add entropy to s3 path for better scalability Wed, 22 Aug, 21:04
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability Wed, 22 Aug, 21:05
GitBox [GitHub] walterddr commented on issue #6585: [FLINK-10172][table]re-adding asc & desc suffix expression to expressionParser Wed, 22 Aug, 23:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc Wed, 22 Aug, 23:03
GitBox [GitHub] walterddr edited a comment on issue #6585: [FLINK-10172][table]re-adding asc & desc suffix expression to expressionParser Wed, 22 Aug, 23:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc Wed, 22 Aug, 23:04
Xingcan Cui (JIRA) [jira] [Created] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests Thu, 23 Aug, 02:55
GitBox [GitHub] xccui opened a new pull request #6605: [FLINK-10201] [table] [test] The batchTestUtil was mistakenly used in some stream sql tests Thu, 23 Aug, 04:23
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests Thu, 23 Aug, 04:24
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests Thu, 23 Aug, 04:24
GitBox [GitHub] twalthr opened a new pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client Thu, 23 Aug, 05:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10163) Support CREATE VIEW in SQL Client Thu, 23 Aug, 05:41
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-10163) Support CREATE VIEW in SQL Client Thu, 23 Aug, 05:41
GitBox [GitHub] yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures Thu, 23 Aug, 06:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures Thu, 23 Aug, 06:13
GitBox [GitHub] StefanRRichter commented on a change in pull request #6604: [FLINK-9061] Optionally add entropy to checkpoint paths better S3 scalability Thu, 23 Aug, 07:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability Thu, 23 Aug, 07:46
GitBox [GitHub] pnowojski commented on a change in pull request #6574: [FLINK-8868] [table] Support Table Function as Table Source for Stream Sql Thu, 23 Aug, 07:54
vinoyang (JIRA) [jira] [Updated] (FLINK-9928) Add LOG2 function for table/sql API Thu, 23 Aug, 07:55
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8868) Support Table Function as Table for Stream Sql Thu, 23 Aug, 07:55
GitBox [GitHub] StefanRRichter commented on a change in pull request #6604: [FLINK-9061] Optionally add entropy to checkpoint paths better S3 scalability Thu, 23 Aug, 08:05
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability Thu, 23 Aug, 08:06
GitBox [GitHub] twalthr commented on issue #6585: [FLINK-10172][table]re-adding asc & desc suffix expression to expressionParser Thu, 23 Aug, 08:06
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc Thu, 23 Aug, 08:07
GitBox [GitHub] zentol commented on a change in pull request #6602: [FLINK-7551][rest] Add versioning to REST API Thu, 23 Aug, 08:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7551) Add VERSION to the REST urls. Thu, 23 Aug, 08:19
GitBox [GitHub] TisonKun commented on issue #6251: [FLINK-9693] Set Execution#taskRestore to null after deployment Thu, 23 Aug, 08:20
buptljy (JIRA) [jira] [Created] (FLINK-10202) Enable configuration for state.checkpoint.dir with environment Thu, 23 Aug, 08:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9693) Possible memory leak in jobmanager retaining archived checkpoints Thu, 23 Aug, 08:21
buptljy (JIRA) [jira] [Updated] (FLINK-10202) Enable configuration for state.checkpoint.dir in environment Thu, 23 Aug, 08:24
buptljy (JIRA) [jira] [Updated] (FLINK-10202) Enable configuration for state.checkpoint.dir in StreamExecutionEnvironment Thu, 23 Aug, 08:24
buptljy (JIRA) [jira] [Updated] (FLINK-10202) Enable configuration for state.checkpoint.dir with environment Thu, 23 Aug, 08:24
buptljy (JIRA) [jira] [Updated] (FLINK-10202) Enable configuration for state.checkpoint.dir in StreamExecutionEnvironment Thu, 23 Aug, 08:25
GitBox [GitHub] aljoscha commented on a change in pull request #6105: [FLINK-8500] Get the timestamp of the Kafka message from kafka consumer Thu, 23 Aug, 08:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Thu, 23 Aug, 08:27
GitBox [GitHub] kisimple opened a new pull request #6607: [docs] Remove the redundant <th> tag Thu, 23 Aug, 08:34
GitBox [GitHub] StephanEwen commented on issue #6604: [FLINK-9061] Optionally add entropy to checkpoint paths better S3 scalability Thu, 23 Aug, 10:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability Thu, 23 Aug, 10:04
GitBox [GitHub] tzulitai commented on a change in pull request #6105: [FLINK-8500] Get the timestamp of the Kafka message from kafka consumer Thu, 23 Aug, 10:06
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Thu, 23 Aug, 10:07
GitBox [GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins Thu, 23 Aug, 10:24
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9713) Support versioned joins in planning phase Thu, 23 Aug, 10:25
GitBox [GitHub] zentol closed pull request #6607: [docs] Remove the redundant <th> tag Thu, 23 Aug, 10:29
Mikhail (JIRA) [jira] [Commented] (FLINK-9391) Support UNNEST in Table API Thu, 23 Aug, 10:38
GitBox [GitHub] NicoK commented on issue #6603: [FLINK-10198][state] Set Env object in DBOptions for RocksDB Thu, 23 Aug, 11:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10198) Set Env object in DBOptions for RocksDB Thu, 23 Aug, 11:34
GitBox [GitHub] FredTing commented on a change in pull request #6105: [FLINK-8500] Get the timestamp of the Kafka message from kafka consumer Thu, 23 Aug, 13:31
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Thu, 23 Aug, 13:32
Artsem Semianenka (JIRA) [jira] [Created] (FLINK-10203) HadoopRecoverableWriter does not support Hadoop Thu, 23 Aug, 13:42
Artsem Semianenka (JIRA) [jira] [Updated] (FLINK-10203) HadoopRecoverableFsDataOutputStream does not support Hadoop 2.6 Thu, 23 Aug, 13:43
Artsem Semianenka (JIRA) [jira] [Updated] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 13:44
GitBox [GitHub] pnowojski commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR Thu, 23 Aug, 13:48
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR Thu, 23 Aug, 13:49
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams Thu, 23 Aug, 13:57
GitBox [GitHub] art4ul opened a new pull request #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 14:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 14:18
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 14:18
GitBox [GitHub] pnowojski commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR Thu, 23 Aug, 14:42
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR Thu, 23 Aug, 14:43
GitBox [GitHub] pnowojski edited a comment on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR Thu, 23 Aug, 14:43
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR Thu, 23 Aug, 14:44
GitBox [GitHub] StephanEwen commented on issue #6603: [FLINK-10198][state] Set Env object in DBOptions for RocksDB Thu, 23 Aug, 14:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10198) Set Env object in DBOptions for RocksDB Thu, 23 Aug, 14:58
GitBox [GitHub] StephanEwen commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 15:05
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 15:06
Artsem Semianenka (JIRA) [jira] [Updated] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 15:07
Artsem Semianenka (JIRA) [jira] [Updated] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 15:09
GitBox [GitHub] art4ul commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 15:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 15:11
GitBox [GitHub] StephanEwen commented on issue #6604: [FLINK-9061] Optionally add entropy to checkpoint paths better S3 scalability Thu, 23 Aug, 15:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability Thu, 23 Aug, 15:13
GitBox [GitHub] hequn8128 commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR Thu, 23 Aug, 15:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR Thu, 23 Aug, 15:29
GitBox [GitHub] art4ul commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 15:46
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream Thu, 23 Aug, 15:47
GitBox [GitHub] StefanRRichter commented on issue #6604: [FLINK-9061] Optionally add entropy to checkpoint paths better S3 scalability Thu, 23 Aug, 16:15
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability Thu, 23 Aug, 16:16
GitBox [GitHub] yanghua commented on issue #6597: [FLINK-10136] [table] Add REPEAT supported in Table API and SQL Thu, 23 Aug, 16:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10136) Add REPEAT supported in Table API and SQL Thu, 23 Aug, 16:22
GitBox [GitHub] azagrebin commented on a change in pull request #6587: [FLINK-10011] Release JobGraph from SubmittedJobGraphStore Thu, 23 Aug, 16:53
GitBox [GitHub] azagrebin commented on a change in pull request #6587: [FLINK-10011] Release JobGraph from SubmittedJobGraphStore Thu, 23 Aug, 16:53
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10011) Old job resurrected during HA failover Thu, 23 Aug, 16:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10011) Old job resurrected during HA failover Thu, 23 Aug, 16:54
GitBox [GitHub] fhueske commented on issue #6605: [FLINK-10201] [table] [test] The batchTestUtil was mistakenly used in some stream sql tests Thu, 23 Aug, 17:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests Thu, 23 Aug, 17:11
GitBox [GitHub] Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition Thu, 23 Aug, 17:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Thu, 23 Aug, 17:20
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 20205533
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