flink-issues mailing list archives: May 2021

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 · Next »Thread · Author · Date
Timo Walther (Jira) [jira] [Created] (FLINK-22619) Drop usages of BatchTableEnvironment Mon, 10 May, 11:05
Timo Walther (Jira) [jira] [Created] (FLINK-22620) Uncouple OrcTableSource from legacy planner Mon, 10 May, 11:07
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-22407) Bump log4j to 2.14.1 Mon, 10 May, 11:08
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-22407) Bump log4j to 2.14.1 Mon, 10 May, 11:08
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-22407) Bump log4j to 2.14.1 Mon, 10 May, 11:09
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-22407) Bump log4j to 2.14.1 Mon, 10 May, 11:09
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-22407) Bump log4j to 2.14.1 Mon, 10 May, 11:09
GitBox [GitHub] [flink-jira-bot] zentol commented on a change in pull request #13: [FLINK-22576] Set status to 'Open' when unassigning Mon, 10 May, 11:10
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-15648) Support to configure limit for CPU requirement Mon, 10 May, 11:17
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-15648) Support to configure limit for CPU requirement Mon, 10 May, 11:17
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample Mon, 10 May, 11:17
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15873: [FLINK-22413][runtime-web] Hide Checkpointing page in the UI for batch jobs Mon, 10 May, 11:19
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15881: [BP-1.12][FLINK-22566][test] Adds NodeManager log extraction to YARN-related e2e tests Mon, 10 May, 11:19
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15880: [BP-1.13][FLINK-22566][test] Adds NodeManager log extraction to YARN-related e2e tests Mon, 10 May, 11:19
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-21756) Move JMXServer to flink-core Mon, 10 May, 11:25
Chesnay Schepler (Jira) [jira] [Assigned] (FLINK-21756) Move JMXServer to flink-core Mon, 10 May, 11:25
GitBox [GitHub] [flink-jira-bot] zentol commented on pull request #13: [FLINK-22576] Set status to 'Open' when unassigning Mon, 10 May, 11:25
Jark Wu (Jira) [jira] [Commented] (FLINK-22595) RocksDBStateBackendWindowITCase fails on Azure Mon, 10 May, 11:36
Robert Metzger (Jira) [jira] [Commented] (FLINK-22614) Provide build artifacts for YARN e2e tests Mon, 10 May, 11:44
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15872: [FLINK-21469] Implement advanceToEndOfEventTime for MultipleInputStreamTask Mon, 10 May, 11:44
GitBox [GitHub] [flink] zhengyifanvp commented on pull request #8400: [FLINK-12472][yarn] Support setting attemptFailuresValidityInterval o… Mon, 10 May, 11:50
GitBox [GitHub] [flink] dianfu commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives Mon, 10 May, 11:53
GitBox [GitHub] [flink] dianfu commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives Mon, 10 May, 11:56
GitBox [GitHub] [flink] dianfu commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives Mon, 10 May, 11:57
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15803: [FLINK-22523][table-planner-blink] TUMBLE TVF should throw helpful exception when specifying second interval parameter Mon, 10 May, 12:05
GitBox [GitHub] [flink] rkhachatryan commented on pull request #15871: [BP-1.12][FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources Mon, 10 May, 12:13
GitBox [GitHub] [flink] rkhachatryan merged pull request #15871: [BP-1.12][FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources Mon, 10 May, 12:14
Timo Walther (Jira) [jira] [Updated] (FLINK-22620) Drop BatchTableSource OrcTableSource Mon, 10 May, 12:17
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers Mon, 10 May, 12:19
Roman Khachatryan (Jira) [jira] [Created] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure Mon, 10 May, 12:23
GitBox [GitHub] [flink] rkhachatryan commented on pull request #15870: [BP-1.13][FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources Mon, 10 May, 12:24
Roman Khachatryan (Jira) [jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails Mon, 10 May, 12:26
GitBox [GitHub] [flink] rkhachatryan merged pull request #15870: [BP-1.13][FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources Mon, 10 May, 12:26
GitBox [GitHub] [flink] dianfu commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives Mon, 10 May, 12:27
Roman Khachatryan (Jira) [jira] [Comment Edited] (FLINK-21181) Buffer pool is destroyed error when outputting data over a timer after cancellation. Mon, 10 May, 12:29
Roman Khachatryan (Jira) [jira] [Updated] (FLINK-21181) Buffer pool is destroyed error when outputting data over a timer after cancellation. Mon, 10 May, 12:30
Roman Khachatryan (Jira) [jira] [Resolved] (FLINK-21181) Buffer pool is destroyed error when outputting data over a timer after cancellation. Mon, 10 May, 12:30
Roman Khachatryan (Jira) [jira] [Updated] (FLINK-21181) Buffer pool is destroyed error when outputting data over a timer after cancellation. Mon, 10 May, 12:30
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample Mon, 10 May, 12:40
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15806: [FLINK-22313][table-planner-blink] Redundant CAST in plan when selecting window start and window end in window agg Mon, 10 May, 12:42
GitBox [GitHub] [flink] SteNicholas commented on pull request #15873: [FLINK-22413][runtime-web] Hide Checkpointing page in the UI for batch jobs Mon, 10 May, 12:48
GitBox [GitHub] [flink] lqjack commented on pull request #15812: remove slotpoolImpl Mon, 10 May, 12:52
GitBox [GitHub] [flink] JingsongLi merged pull request #15863: [FLINK-22604] [table-runtime-blink] fix NPE on bundle close when task failover after a failed task open Mon, 10 May, 12:55
Jingsong Lee (Jira) [jira] [Closed] (FLINK-22604) NPE on bundle close when task failover after a failed task open Mon, 10 May, 12:57
GitBox [GitHub] [flink] fsk119 commented on a change in pull request #15664: [FLINK-22155][table-api][parser] fix explain insert or select two case,sql convert separate selection. Mon, 10 May, 12:57
GitBox [GitHub] [flink] JingsongLi commented on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari… Mon, 10 May, 12:59
GitBox [GitHub] [flink] YikSanChan commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives Mon, 10 May, 13:03
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15873: [FLINK-22413][runtime-web] Hide Checkpointing page in the UI for batch jobs Mon, 10 May, 13:03
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15874: [FLINK-22525][table-api] Fix gmt format in Flink from GMT-8:00 to GMT-08:00 Mon, 10 May, 13:03
Timo Walther (Jira) [jira] [Updated] (FLINK-22620) Drop BatchTableSource OrcTableSource Mon, 10 May, 13:05
GitBox [GitHub] [flink] YikSanChan commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives Mon, 10 May, 13:05
Timo Walther (Jira) [jira] [Created] (FLINK-22622) Drop BatchTableSource ParquetTableSource Mon, 10 May, 13:07
Timo Walther (Jira) [jira] [Created] (FLINK-22623) Drop BatchTableSource HBaseTableSource Mon, 10 May, 13:10
GitBox [GitHub] [flink] rmetzger commented on pull request #15878: [hotfix] Disable broken savepoint tests tracked in FLINK-22067 Mon, 10 May, 13:10
GitBox [GitHub] [flink] rmetzger merged pull request #15878: [hotfix] Disable broken savepoint tests tracked in FLINK-22067 Mon, 10 May, 13:10
Robert Metzger (Jira) [jira] [Comment Edited] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader Mon, 10 May, 13:12
Robert Metzger (Jira) [jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader Mon, 10 May, 13:12
Arvid Heise (Jira) [jira] [Updated] (FLINK-22502) DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently Mon, 10 May, 13:29
Arvid Heise (Jira) [jira] [Updated] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema Mon, 10 May, 13:30
Arvid Heise (Jira) [jira] [Updated] (FLINK-19743) Add Source metrics definitions Mon, 10 May, 13:31
Arvid Heise (Jira) [jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1> Mon, 10 May, 13:31
Arvid Heise (Jira) [jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread Mon, 10 May, 13:31
Arvid Heise (Jira) [jira] [Updated] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer Mon, 10 May, 13:32
Arvid Heise (Jira) [jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error Mon, 10 May, 13:32
Arvid Heise (Jira) [jira] [Updated] (FLINK-22494) Avoid discarding checkpoints in case of failure Mon, 10 May, 13:32
Arvid Heise (Jira) [jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection Mon, 10 May, 13:32
Arvid Heise (Jira) [jira] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27. Mon, 10 May, 13:32
Arvid Heise (Jira) [jira] [Updated] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source Mon, 10 May, 13:33
Arvid Heise (Jira) [jira] [Updated] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram Mon, 10 May, 13:33
Arvid Heise (Jira) [jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource Mon, 10 May, 13:33
Arvid Heise (Jira) [jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector. Mon, 10 May, 13:33
Arvid Heise (Jira) [jira] [Updated] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints Mon, 10 May, 13:33
Arvid Heise (Jira) [jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync Mon, 10 May, 13:34
Arvid Heise (Jira) [jira] [Updated] (FLINK-22564) Kubernetes-related ITCases do not fail even in case of failure Mon, 10 May, 13:34
Arvid Heise (Jira) [jira] [Updated] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store Mon, 10 May, 13:34
Arvid Heise (Jira) [jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism Mon, 10 May, 13:34
Arvid Heise (Jira) [jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message Mon, 10 May, 13:34
Arvid Heise (Jira) [jira] [Updated] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests Mon, 10 May, 13:34
Arvid Heise (Jira) [jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type Mon, 10 May, 13:34
Arvid Heise (Jira) [jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition Mon, 10 May, 13:35
Arvid Heise (Jira) [jira] [Resolved] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition Mon, 10 May, 13:35
Arvid Heise (Jira) [jira] [Updated] (FLINK-18952) Add 10 minutes to DataStream API documentation Mon, 10 May, 13:36
Arvid Heise (Jira) [jira] [Updated] (FLINK-20114) Fix a few KafkaSource-related bugs Mon, 10 May, 13:38
Arvid Heise (Jira) [jira] [Updated] (FLINK-20114) Fix a few KafkaSource-related bugs Mon, 10 May, 13:38
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15813: [FLINK-22519][flink-python] support tar python archives Mon, 10 May, 13:41
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15873: [FLINK-22413][runtime-web] Hide Checkpointing page in the UI for batch jobs Mon, 10 May, 13:42
Robert Metzger (Jira) [jira] [Updated] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails Mon, 10 May, 13:46
Robert Metzger (Jira) [jira] [Commented] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` Mon, 10 May, 13:46
Robert Metzger (Jira) [jira] [Updated] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` Mon, 10 May, 13:46
Robert Metzger (Jira) [jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails Mon, 10 May, 13:46
GitBox [GitHub] [flink] rmetzger opened a new pull request #15882: [FLINK-22574] Adaptive Scheduler: Fix cancellation while in Restarting state Mon, 10 May, 13:51
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-22574) Adaptive Scheduler: Can not cancel restarting job Mon, 10 May, 13:52
GitBox [GitHub] [flink] flinkbot commented on pull request #15882: [FLINK-22574] Adaptive Scheduler: Fix cancellation while in Restarting state Mon, 10 May, 13:53
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample Mon, 10 May, 14:00
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15813: [FLINK-22519][flink-python] support tar python archives Mon, 10 May, 14:02
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink Mon, 10 May, 14:02
GitBox [GitHub] [flink] flinkbot commented on pull request #15882: [FLINK-22574] Adaptive Scheduler: Fix cancellation while in Restarting state Mon, 10 May, 14:02
GitBox [GitHub] [flink] XComp commented on pull request #15131: [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster Mon, 10 May, 14:11
Danny Cranmer (Jira) [jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition Mon, 10 May, 14:12
Danny Cranmer (Jira) [jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition Mon, 10 May, 14:21
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 · Next »Thread · Author · Date
Box list
Jul 20218572
Jun 202110018
May 20218192
Apr 202125421
Mar 202112878
Feb 20217802
Jan 20218278
Dec 20208216
Nov 202011656
Oct 202010635
Sep 20208763
Aug 20207154
Jul 20206500
Jun 202011245
May 202012632
Apr 202014175
Mar 202012382
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