flink-issues mailing list archives: January 2020

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 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · 80 · 81 · 82 · 83 · 84 · 85 · 86 · 87 · 88 · 89 · Next »Thread · Author · Date
GitBox [GitHub] [flink] gaoyunhaii commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 09:27
GitBox [GitHub] [flink] gaoyunhaii commented on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 09:28
GitBox [GitHub] [flink] zhijiangW merged pull request #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull Tue, 21 Jan, 09:35
Gary Yao (Jira) [jira] [Commented] (FLINK-11781) Reject "DISABLED" as value for yarn.per-job-cluster.include-user-jar Tue, 21 Jan, 09:37
zhijiang (Jira) [jira] [Closed] (FLINK-15444) Make the component AbstractInvokable in CheckpointBarrierHandler NonNull Tue, 21 Jan, 09:38
GitBox [GitHub] [flink] pnowojski commented on a change in pull request #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11. Tue, 21 Jan, 09:39
vinoyang (Jira) [jira] [Updated] (FLINK-15707) Update state migration tests for Flink 1.10 Tue, 21 Jan, 09:41
vinoyang (Jira) [jira] [Created] (FLINK-15707) Update state migration tests for Flink 1.10 Tue, 21 Jan, 09:41
Gary Yao (Jira) [jira] [Commented] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache Tue, 21 Jan, 09:41
vinoyang (Jira) [jira] [Updated] (FLINK-15707) Update state migration tests for Flink 1.10 Tue, 21 Jan, 09:42
Gary Yao (Jira) [jira] [Comment Edited] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache Tue, 21 Jan, 09:43
vinoyang (Jira) [jira] [Updated] (FLINK-15708) Add MigrationVersion.v1_10 Tue, 21 Jan, 09:43
Aljoscha Krettek (Jira) [jira] [Commented] (FLINK-15674) Let Java and Scala Type Extraction go through the same stack Tue, 21 Jan, 09:43
vinoyang (Jira) [jira] [Created] (FLINK-15708) Add MigrationVersion.v1_10 Tue, 21 Jan, 09:43
Aljoscha Krettek (Jira) [jira] [Commented] (FLINK-15674) Let Java and Scala Type Extraction go through the same stack Tue, 21 Jan, 09:43
vinoyang (Jira) [jira] [Commented] (FLINK-15707) Update state migration tests for Flink 1.10 Tue, 21 Jan, 09:44
Aljoscha Krettek (Jira) [jira] [Commented] (FLINK-11746) Add thrift format support in Flink Tue, 21 Jan, 09:46
Aljoscha Krettek (Jira) [jira] [Commented] (FLINK-9651) Add a Kafka table source factory with Protobuf format support Tue, 21 Jan, 09:46
vinoyang (Jira) [jira] [Created] (FLINK-15709) Update CEPMigrationTest to restore from 1.10 savepoint Tue, 21 Jan, 09:46
Aljoscha Krettek (Jira) [jira] [Commented] (FLINK-7050) RFC Compliant CSV Parser for Table Source Tue, 21 Jan, 09:47
vinoyang (Jira) [jira] [Created] (FLINK-15710) Update BucketingSinkMigrationTest to restore from 1.10 savepoint Tue, 21 Jan, 09:48
vinoyang (Jira) [jira] [Created] (FLINK-15711) Update FlinkKafkaProducer011MigrationTest to restore from 1.10 savepoint Tue, 21 Jan, 09:49
vinoyang (Jira) [jira] [Created] (FLINK-15712) Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.10 savepoint Tue, 21 Jan, 09:50
Yang Wang (Jira) [jira] [Commented] (FLINK-15275) Update CLI documentation to include only current valid options Tue, 21 Jan, 09:50
vinoyang (Jira) [jira] [Created] (FLINK-15713) Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.10 savepoint Tue, 21 Jan, 09:50
Piotr Nowojski (Jira) [jira] [Closed] (FLINK-15074) Connection timed out, Standalone cluster Tue, 21 Jan, 09:51
Yang Wang (Jira) [jira] [Commented] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache Tue, 21 Jan, 09:52
Aljoscha Krettek (Jira) [jira] [Assigned] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot Tue, 21 Jan, 09:53
vinoyang (Jira) [jira] [Created] (FLINK-15714) Update FlinkKafkaProducerMigrationTest to restore from 1.10 savepoint Tue, 21 Jan, 09:53
Aljoscha Krettek (Jira) [jira] [Assigned] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot Tue, 21 Jan, 09:53
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 09:53
Aljoscha Krettek (Jira) [jira] [Assigned] (FLINK-15276) Update CLI documentation to reflect the addition of the ExecutorCLI Tue, 21 Jan, 09:54
vinoyang (Jira) [jira] [Created] (FLINK-15715) Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint Tue, 21 Jan, 09:55
Aljoscha Krettek (Jira) [jira] [Updated] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase Tue, 21 Jan, 09:55
Till Rohrmann (Jira) [jira] [Assigned] (FLINK-15684) Add "taskmanager.memory.flink.size" to the common options Tue, 21 Jan, 09:55
vinoyang (Jira) [jira] [Created] (FLINK-15716) Update WindowOperatorMigrationTest to restore from 1.10 savepoint Tue, 21 Jan, 09:57
vinoyang (Jira) [jira] [Created] (FLINK-15717) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint Tue, 21 Jan, 09:57
vinoyang (Jira) [jira] [Created] (FLINK-15718) Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint Tue, 21 Jan, 09:58
Ying Z (Jira) [jira] [Created] (FLINK-15719) Exceptions when using scala types directly with the State Process API Tue, 21 Jan, 09:59
Gary Yao (Jira) [jira] [Updated] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable. Tue, 21 Jan, 10:00
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 10:00
Yu Li (Jira) [jira] [Assigned] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types Tue, 21 Jan, 10:01
Yu Li (Jira) [jira] [Assigned] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types Tue, 21 Jan, 10:01
Yu Li (Jira) [jira] [Updated] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types Tue, 21 Jan, 10:02
Yu Li (Jira) [jira] [Updated] (FLINK-13554) ResourceManager should have a timeout on starting new TaskExecutors. Tue, 21 Jan, 10:03
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 10:19
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 10:24
vinoyang (Jira) [jira] [Created] (FLINK-15720) Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.10 savepoint Tue, 21 Jan, 10:25
vinoyang (Jira) [jira] [Created] (FLINK-15721) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint Tue, 21 Jan, 10:26
vinoyang (Jira) [jira] [Created] (FLINK-15723) Update AbstractKeyedOperatorRestoreTestBase to restore from 1.10 savepoint Tue, 21 Jan, 10:27
vinoyang (Jira) [jira] [Created] (FLINK-15722) Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint Tue, 21 Jan, 10:27
vinoyang (Jira) [jira] [Created] (FLINK-15724) Update AbstractNonKeyedOperatorRestoreTestBase to restore from 1.10 savepoint Tue, 21 Jan, 10:28
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 10:28
Piotr Nowojski (Jira) [jira] [Updated] (FLINK-15226) Running job with application parameters fails on a job cluster Tue, 21 Jan, 10:29
vinoyang (Jira) [jira] [Created] (FLINK-15725) Update FlinkKinesisConsumerMigrationTest to restore from 1.10 savepoint Tue, 21 Jan, 10:29
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 10:29
Timo Walther (Jira) [jira] [Updated] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API Tue, 21 Jan, 10:35
Timo Walther (Jira) [jira] [Commented] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API Tue, 21 Jan, 10:36
Piotr Nowojski (Jira) [jira] [Updated] (FLINK-15253) Accumulators are not checkpointed Tue, 21 Jan, 10:36
Benoit Hanotte (Jira) [jira] [Commented] (FLINK-15574) DataType to LogicalType conversion issue Tue, 21 Jan, 10:40
Piotr Nowojski (Jira) [jira] [Commented] (FLINK-15305) MemoryMappedBoundedDataTest fails with IOException on ppc64le Tue, 21 Jan, 10:41
Benoit Hanotte (Jira) [jira] [Comment Edited] (FLINK-15574) DataType to LogicalType conversion issue Tue, 21 Jan, 10:42
Shi Feng (Jira) [jira] [Commented] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig Tue, 21 Jan, 10:59
BenoƮt Paris (Jira) [jira] [Created] (FLINK-15726) Fixing error message in StreamExecTableSourceScan Tue, 21 Jan, 11:07
GitBox [GitHub] [flink] benoitparis opened a new pull request #10914: [FLINK-15726] [Blink Planner] [hotfix] Fix error message in StreamExecTableSourceScan Tue, 21 Jan, 11:09
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-15726) Fixing error message in StreamExecTableSourceScan Tue, 21 Jan, 11:10
GitBox [GitHub] [flink] JingsongLi opened a new pull request #10915: [FLINK-15706][table-planner-blink] Not use Arrays.asList to avoid incompatible error Tue, 21 Jan, 11:12
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types Tue, 21 Jan, 11:13
GitBox [GitHub] [flink] benoitparis commented on issue #10914: [FLINK-15726] [Blink Planner] [hotfix] Fix error message in StreamExecTableSourceScan Tue, 21 Jan, 11:13
GitBox [GitHub] [flink] JingsongLi commented on issue #10915: [FLINK-15706][table-planner-blink] Not use Arrays.asList to avoid incompatible error Tue, 21 Jan, 11:17
GitBox [GitHub] [flink] flinkbot commented on issue #10915: [FLINK-15706][table-planner-blink] Not use Arrays.asList to avoid incompatible error Tue, 21 Jan, 11:18
GitBox [GitHub] [flink] flinkbot commented on issue #10914: [FLINK-15726] [Blink Planner] [hotfix] Fix error message in StreamExecTableSourceScan Tue, 21 Jan, 11:18
GitBox [GitHub] [flink] zentol commented on a change in pull request #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11. Tue, 21 Jan, 11:46
GitBox [GitHub] [flink] pnowojski merged pull request #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11. Tue, 21 Jan, 12:13
Piotr Nowojski (Jira) [jira] [Closed] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop Tue, 21 Jan, 12:17
GitBox [GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler Tue, 21 Jan, 12:18
Piotr Nowojski (Jira) [jira] [Commented] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation Tue, 21 Jan, 12:19
GitBox [GitHub] [flink] flinkbot edited a comment on issue #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes Tue, 21 Jan, 12:20
GitBox [GitHub] [flink] flinkbot edited a comment on issue #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11. Tue, 21 Jan, 12:20
GitBox [GitHub] [flink] flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration Tue, 21 Jan, 12:21
GitBox [GitHub] [flink] flinkbot edited a comment on issue #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler Tue, 21 Jan, 12:21
GitBox [GitHub] [flink] pnowojski merged pull request #10906: [FLINK-15601] Remove useless constant field NUM_STOP_CALL_TRIES in Execution Tue, 21 Jan, 12:22
Piotr Nowojski (Jira) [jira] [Closed] (FLINK-15601) Remove useless constant field NUM_STOP_CALL_TRIES in Execution Tue, 21 Jan, 12:23
GitBox [GitHub] [flink] flinkbot commented on issue #10914: [FLINK-15726] [Blink Planner] [hotfix] Fix error message in StreamExecTableSourceScan Tue, 21 Jan, 12:23
GitBox [GitHub] [flink] flinkbot commented on issue #10915: [FLINK-15706][table-planner-blink] Not use Arrays.asList to avoid incompatible error Tue, 21 Jan, 12:23
GitBox [GitHub] [flink] dawidwys opened a new pull request #10916: [FLINK-15684][docs] Add taskmanager.memory.flink.size to common options Tue, 21 Jan, 12:26
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-15684) Add "taskmanager.memory.flink.size" to the common options Tue, 21 Jan, 12:27
GitBox [GitHub] [flink] flinkbot commented on issue #10916: [FLINK-15684][docs] Add taskmanager.memory.flink.size to common options Tue, 21 Jan, 12:29
GitBox [GitHub] [flink] dawidwys commented on issue #10914: [FLINK-15726] [Blink Planner] [hotfix] Fix error message in StreamExecTableSourceScan Tue, 21 Jan, 12:30
GitBox [GitHub] [flink] flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories Tue, 21 Jan, 12:36
GitBox [GitHub] [flink] benoitparis commented on issue #10914: [FLINK-15726] [Blink Planner] [hotfix] Fix error message in StreamExecTableSourceScan Tue, 21 Jan, 12:39
GitBox [GitHub] [flink] twalthr opened a new pull request #10917: [FLINK-15162][table] Refactor DataTypeLookup to DataTypeFactory Tue, 21 Jan, 12:41
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-15162) Merge Java and Scala ClosureCleaner Tue, 21 Jan, 12:42
Tzu-Li (Gordon) Tai (Jira) [jira] [Commented] (FLINK-15719) Exceptions when using scala types directly with the State Process API Tue, 21 Jan, 12:49
GitBox [GitHub] [flink] dawidwys opened a new pull request #10918: [FLINK-15684][docs][bp-1.10] Add taskmanager.memory.flink.size to common options Tue, 21 Jan, 12:50
GitBox [GitHub] [flink] dawidwys commented on issue #10916: [FLINK-15684][docs] Add taskmanager.memory.flink.size to common options Tue, 21 Jan, 12:50
GitBox [GitHub] [flink] flinkbot commented on issue #10918: [FLINK-15684][docs][bp-1.10] Add taskmanager.memory.flink.size to common options Tue, 21 Jan, 12:53
GitBox [GitHub] [flink] flinkbot commented on issue #10917: [FLINK-15162][table] Refactor DataTypeLookup to DataTypeFactory Tue, 21 Jan, 12:53
GitBox [GitHub] [flink] tillrohrmann commented on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability. Tue, 21 Jan, 13:01
Yun Tang (Jira) [jira] [Assigned] (FLINK-15692) Enable limiting RocksDB memory consumption by default Tue, 21 Jan, 13:06
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 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · 80 · 81 · 82 · 83 · 84 · 85 · 86 · 87 · 88 · 89 · Next »Thread · Author · Date
Box list
Mar 202011676
Feb 202010561
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