Чтение текстового файла мигать - PullRequest
0 голосов
/ 01 апреля 2019

Привет, я новичок в Flink. Я пытаюсь прочитать текстовый файл, и когда я его распечатываю, он кажется несортированным.

Это нормально?Почему это не заказано?Есть способ отсортировать его?

Исходный текстовый файл:

01-06-2018,June,Category5,Bat,12
01-06-2108,June,Category4,Perfume,10
13-07-2018,July,Category1,Television,50
24-06-2018,June,Category4,Shirt,38
18-06-2018,June,Category5,Bat,41
01-08-2018,August,Category5,PC,32
11-06-2018,June,Category2,Laptop,39
04-06-2018,June,Category1,PC,14
26-08-2018,August,Category4,Pendrive,42
12-06-2018,June,Category2,Tablet,41
25-08-2018,August,Category1,Shirt,34
17-07-2018,July,Category5,Steamer,27
....

Мой код: val env = ExecutionEnvironment.getExecutionEnvironment val dataset = env.readTextFile("text.txt") dataset.print()

И я получаю строки в различном порядке каждыйвремя выполнения, например:

31-08-2018,August,Category2,Jewelry,38
13-08-2018,August,Category2,Mouse,35
02-07-2018,July,Category3,PC,34
04-08-2018,August,Category2,Bottle,38
04-06-2018,June,Category1,Pendrive,30
24-08-2018,August,Category1,Phone,43
11-06-2018,June,Category4,Jeans,14
28-08-2018,August,Category3,Jeans,36
14-06-2018,June,Category1,Bottle,49
....

Любая помощь, чтобы понять это и сделать заказ, если это возможно, будет оценена

Спасибо!

1 Ответ

0 голосов
/ 02 апреля 2019

Попробуйте установить параллелизм в 1, локальный режим flink установит параллелизм в число ядер вашего процессора, что приведет к несортированному выводу.

...