tag with ShortCodes in document - posted by GitBox <gi...@apache.org> on 2021/09/23 18:54:13 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re… - posted by GitBox <gi...@apache.org> on 2021/09/23 18:54:15 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #15822: npm update - posted by GitBox <gi...@apache.org> on 2021/09/23 18:54:17 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #16580: [hotfix][runtime] Fix log info - posted by GitBox <gi...@apache.org> on 2021/09/23 18:54:17 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re… - posted by GitBox <gi...@apache.org> on 2021/09/23 18:54:31 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #16693: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re… - posted by GitBox <gi...@apache.org> on 2021/09/23 18:54:33 UTC, 0 replies.
- [GitHub] [flink] CrynetLogistics opened a new pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i… - posted by GitBox <gi...@apache.org> on 2021/09/23 19:07:44 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i… - posted by GitBox <gi...@apache.org> on 2021/09/23 19:10:45 UTC, 1 replies.
- [GitHub] [flink] CrynetLogistics commented on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i… - posted by GitBox <gi...@apache.org> on 2021/09/23 19:26:52 UTC, 0 replies.
- [GitHub] [flink] NickBurkard commented on a change in pull request #17340: [FLINK-24360] Drop Scala Shell - posted by GitBox <gi...@apache.org> on 2021/09/23 19:45:20 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i… - posted by GitBox <gi...@apache.org> on 2021/09/23 20:21:44 UTC, 15 replies.
- [GitHub] [flink] syhily opened a new pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document - posted by GitBox <gi...@apache.org> on 2021/09/23 20:26:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document - posted by GitBox <gi...@apache.org> on 2021/09/23 20:30:10 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document - posted by GitBox <gi...@apache.org> on 2021/09/23 21:24:22 UTC, 1 replies.
- [jira] [Updated] (FLINK-16152) Translate "Operator/index" into Chinese - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/23 22:38:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-23842) Add log messages for reader registrations and split requests. - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/23 22:38:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-23935) Flink docs: the browser will unexpectedly scroll after clicking the tabs - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/23 22:38:00 UTC, 0 replies.
- [GitHub] [flink] lindong28 commented on pull request #17342: [FLINK-20928] Fix flaky test by retrying notifyCheckpointComplete until either commit success or timeout - posted by GitBox <gi...@apache.org> on 2021/09/24 01:15:51 UTC, 2 replies.
- [GitHub] [flink] lindong28 removed a comment on pull request #17342: [FLINK-20928] Fix flaky test by retrying notifyCheckpointComplete until either commit success or timeout - posted by GitBox <gi...@apache.org> on 2021/09/24 01:25:17 UTC, 1 replies.
- [GitHub] [flink] xintongsong closed pull request #17338: [FLINK-24358][formats] Fix flink-avro-glue-schema-registry dependency convergence. - posted by GitBox <gi...@apache.org> on 2021/09/24 01:38:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-24358) flink-avro-glue-schema-registry fails compiling with scala 2.12 due to dependency convergence - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/24 01:39:00 UTC, 1 replies.
- [GitHub] [flink] dianfu closed pull request #17322: [FLINK-24336][python] Fix the issue that jar url may be a empty string. - posted by GitBox <gi...@apache.org> on 2021/09/24 01:40:19 UTC, 0 replies.
- [jira] [Closed] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/09/24 01:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24320) Show in the Job / Checkpoints / Configuration if checkpoints are incremental - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2021/09/24 02:47:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-24320) Show in the Job / Checkpoints / Configuration if checkpoints are incremental - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2021/09/24 02:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-16201) Support JSON_VALUE - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/09/24 03:08:00 UTC, 2 replies.
- [GitHub] [flink] iyupeng commented on a change in pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner - posted by GitBox <gi...@apache.org> on 2021/09/24 03:59:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-23519) Aggregate State Backend Latency by State Level - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/09/24 05:42:00 UTC, 0 replies.
- [GitHub] [flink] matriv commented on pull request #17341: [hotfix][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/24 06:07:38 UTC, 0 replies.
- [GitHub] [flink] skyguard1 closed pull request #17169: [FLINK-24177][runtime/network] Add epoll available check exception - posted by GitBox <gi...@apache.org> on 2021/09/24 06:16:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms. - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/24 06:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms. - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/24 06:39:00 UTC, 1 replies.
- [GitHub] [flink] dawidwys closed pull request #17278: [FLINK-24280] Support manual checkpoints triggering from a MiniCluster - posted by GitBox <gi...@apache.org> on 2021/09/24 06:43:19 UTC, 0 replies.
- [jira] [Closed] (FLINK-24280) Support manual checkpoints triggering from a MiniCluster - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/24 06:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-22530) RuntimeException after subsequent windowed grouping in TableAPI - posted by "Christopher Rost (Jira)" <ji...@apache.org> on 2021/09/24 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24368) Collect logs of Flink container in e2e source test suite - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/24 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24367) Add a fallback AkkaRpcSystemLoader for tests in the IDE - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/24 07:20:00 UTC, 0 replies.
- [GitHub] [flink] fapaul commented on a change in pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document - posted by GitBox <gi...@apache.org> on 2021/09/24 07:22:39 UTC, 0 replies.
- [GitHub] [flink-web] xintongsong commented on a change in pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/24 07:31:55 UTC, 1 replies.
- [GitHub] [flink] fapaul opened a new pull request #17347: [hotfix][docs] Remove flink-connector-base as required dependency fro… - posted by GitBox <gi...@apache.org> on 2021/09/24 07:51:46 UTC, 0 replies.
- [GitHub] [flink] fapaul opened a new pull request #17348: [BP-1.14][hotfix][docs] Remove flink-connector-base as required dependency fro… - posted by GitBox <gi...@apache.org> on 2021/09/24 07:54:08 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17348: [BP-1.14][hotfix][docs] Remove flink-connector-base as required dependency fro… - posted by GitBox <gi...@apache.org> on 2021/09/24 07:58:21 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17347: [hotfix][docs] Remove flink-connector-base as required dependency fro… - posted by GitBox <gi...@apache.org> on 2021/09/24 07:58:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-24346) Flink on yarn application mode,LinkageError - posted by "李伟高 (Jira)" <ji...@apache.org> on 2021/09/24 08:11:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-24346) Flink on yarn application mode,LinkageError - posted by "李伟高 (Jira)" <ji...@apache.org> on 2021/09/24 08:26:00 UTC, 0 replies.
- [GitHub] [flink] lirui-apache commented on a change in pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy - posted by GitBox <gi...@apache.org> on 2021/09/24 08:36:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-24350) Resuming Savepoint (hashmap, sync, scale up) end-to-end test fails due to ask timeout - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/24 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24369) Resource Leak may happen if flink cluster runs abnormally and repeatedly retry - posted by "turtlebin (Jira)" <ji...@apache.org> on 2021/09/24 08:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24369) Resource Leak may happen if flink cluster runs abnormally and repeatedly retry - posted by "turtlebin (Jira)" <ji...@apache.org> on 2021/09/24 08:51:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17347: [hotfix][docs] Remove flink-connector-base as required dependency fro… - posted by GitBox <gi...@apache.org> on 2021/09/24 09:09:23 UTC, 1 replies.
- [GitHub] [flink] fapaul commented on pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document - posted by GitBox <gi...@apache.org> on 2021/09/24 09:09:40 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17348: [BP-1.14][hotfix][docs] Remove flink-connector-base as required dependency fro… - posted by GitBox <gi...@apache.org> on 2021/09/24 09:09:40 UTC, 1 replies.
- [GitHub] [flink] zentol merged pull request #17340: [FLINK-24360] Drop Scala Shell - posted by GitBox <gi...@apache.org> on 2021/09/24 09:31:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-24360) Drop Scala Shell - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/24 09:32:00 UTC, 0 replies.
- [GitHub] [flink] todd5167 commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state… - posted by GitBox <gi...@apache.org> on 2021/09/24 09:33:25 UTC, 0 replies.
- [jira] [Created] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/09/24 09:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/09/24 09:38:00 UTC, 0 replies.
- [GitHub] [flink] CrynetLogistics opened a new pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/24 09:49:27 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/24 09:56:43 UTC, 1 replies.
- [jira] [Closed] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication. - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/24 10:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-2709) line editing in scala shell - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/24 10:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5744) Check remote connection in Flink-shell - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/24 10:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-10911) Enable flink-scala-shell with Scala 2.12 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/24 10:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-12596) Unify all kinds of cluster via ClusterClient in FlinkShell - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/24 10:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18285) solution for 'For input string: “0x100” ' make bash command 'reset' fail to work - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/24 10:06:00 UTC, 0 replies.
- [GitHub] [flink] MartijnVisser commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support - posted by GitBox <gi...@apache.org> on 2021/09/24 10:09:42 UTC, 9 replies.
- [jira] [Closed] (FLINK-10911) Enable flink-scala-shell with Scala 2.12 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/24 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24371) Support SinkWriter preCommit without the need of a committer - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/24 10:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24371) Support SinkWriter preCommit without the need of a committer - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/24 10:41:00 UTC, 0 replies.
- [GitHub] [flink-ml] becketqin commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables - posted by GitBox <gi...@apache.org> on 2021/09/24 10:50:08 UTC, 0 replies.
- [GitHub] [flink] slinkydeveloper opened a new pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable - posted by GitBox <gi...@apache.org> on 2021/09/24 10:56:17 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable - posted by GitBox <gi...@apache.org> on 2021/09/24 10:58:52 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/24 10:59:19 UTC, 1 replies.
- [jira] [Assigned] (FLINK-24359) Migrate FileSystem connector to ResolvedSchema - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/24 11:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22530) RuntimeException after subsequent windowed grouping in TableAPI - posted by "Christopher Rost (Jira)" <ji...@apache.org> on 2021/09/24 11:30:00 UTC, 0 replies.
- [GitHub] [flink] fapaul opened a new pull request #17351: Flink 24371 - posted by GitBox <gi...@apache.org> on 2021/09/24 12:00:04 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable - posted by GitBox <gi...@apache.org> on 2021/09/24 12:02:53 UTC, 15 replies.
- [GitHub] [flink] flinkbot commented on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/24 12:04:17 UTC, 1 replies.
- [jira] [Updated] (FLINK-24371) Support SinkWriter preCommit without the need of a committer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/24 12:05:00 UTC, 1 replies.
- [GitHub] [flink] RocMarshal opened a new pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view - posted by GitBox <gi...@apache.org> on 2021/09/24 12:40:38 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view - posted by GitBox <gi...@apache.org> on 2021/09/24 12:55:42 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/24 13:05:50 UTC, 10 replies.
- [jira] [Commented] (FLINK-21582) COALESCE not works when cast a variable return null - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/09/24 13:10:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-24200) CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/09/24 13:12:00 UTC, 0 replies.
- [GitHub] [flink] Airblader commented on a change in pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view - posted by GitBox <gi...@apache.org> on 2021/09/24 13:51:14 UTC, 2 replies.
- [jira] [Created] (FLINK-24372) Deprecate Elasticsearch Sinkfunctions - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/24 13:53:00 UTC, 0 replies.
- [GitHub] [flink] Airblader commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable - posted by GitBox <gi...@apache.org> on 2021/09/24 13:58:17 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view - posted by GitBox <gi...@apache.org> on 2021/09/24 14:07:13 UTC, 20 replies.
- [GitHub] [flink] sjwiesman commented on a change in pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/24 15:09:49 UTC, 0 replies.
- [GitHub] [flink] RocMarshal commented on a change in pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view - posted by GitBox <gi...@apache.org> on 2021/09/24 15:11:15 UTC, 4 replies.
- [jira] [Created] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/24 16:06:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-16504) Add a AWS DynamoDB sink - posted by "Yuri Gusev (Jira)" <ji...@apache.org> on 2021/09/24 16:24:00 UTC, 1 replies.
- [GitHub] [flink] sjwiesman opened a new pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs - posted by GitBox <gi...@apache.org> on 2021/09/24 16:42:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/24 16:43:00 UTC, 1 replies.
- [GitHub] [flink] sjwiesman commented on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs - posted by GitBox <gi...@apache.org> on 2021/09/24 16:43:46 UTC, 1 replies.
- [GitHub] [flink-benchmarks] dawidwys opened a new pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate - posted by GitBox <gi...@apache.org> on 2021/09/24 16:55:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-24230) Buffer debloating microbenchmark for single gate - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/24 16:56:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs - posted by GitBox <gi...@apache.org> on 2021/09/24 16:59:38 UTC, 1 replies.
- [GitHub] [flink] StephanEwen merged pull request #17347: [hotfix][docs] Remove flink-connector-base as required dependency fro… - posted by GitBox <gi...@apache.org> on 2021/09/24 17:00:21 UTC, 0 replies.
- [GitHub] [flink] StephanEwen merged pull request #17348: [BP-1.14][hotfix][docs] Remove flink-connector-base as required dependency fro… - posted by GitBox <gi...@apache.org> on 2021/09/24 17:01:12 UTC, 0 replies.
- [GitHub] [flink] akalash opened a new pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value - posted by GitBox <gi...@apache.org> on 2021/09/24 17:17:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-24200) CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/24 17:18:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value - posted by GitBox <gi...@apache.org> on 2021/09/24 17:20:39 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs - posted by GitBox <gi...@apache.org> on 2021/09/24 17:59:25 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value - posted by GitBox <gi...@apache.org> on 2021/09/24 18:26:02 UTC, 1 replies.
- [GitHub] [flink] NickBurkard commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support - posted by GitBox <gi...@apache.org> on 2021/09/24 18:41:22 UTC, 7 replies.
- [jira] [Updated] (FLINK-23928) Test the buffer debloating - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/24 22:38:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-23425) The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/24 22:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23647) UnalignedCheckpointStressITCase crashed on azure - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/24 22:38:00 UTC, 1 replies.
- [GitHub] [flink] dugenkui03 closed pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue - posted by GitBox <gi...@apache.org> on 2021/09/25 17:19:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/25 22:38:00 UTC, 0 replies.
- [GitHub] [flink] RocMarshal commented on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view - posted by GitBox <gi...@apache.org> on 2021/09/26 01:05:56 UTC, 3 replies.
- [GitHub] [flink] leonardBang commented on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs - posted by GitBox <gi...@apache.org> on 2021/09/26 01:23:28 UTC, 0 replies.
- [GitHub] [flink] paul8263 commented on pull request #17297: [FLINK-24307][docs] Some lines in Scala code example end with unneces… - posted by GitBox <gi...@apache.org> on 2021/09/26 02:01:52 UTC, 0 replies.
- [jira] [Created] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/26 02:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/26 02:17:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1> - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/26 02:22:00 UTC, 0 replies.
- [GitHub] [flink] JingsongLi merged pull request #17275: [FLINK-24271][docs] Add document for special char in JSON_VALUE and JSON_QUERY - posted by GitBox <gi...@apache.org> on 2021/09/26 02:35:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-24271) Add document for special char in JSON_VALUE - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/09/26 02:37:00 UTC, 0 replies.
- [GitHub] [flink] curcur commented on pull request #17287: [FLINK-23950] Revert [FLINK-23738][state] to re-enable ChangelogBackend - posted by GitBox <gi...@apache.org> on 2021/09/26 03:04:27 UTC, 0 replies.
- [GitHub] [flink] curcur merged pull request #17287: [FLINK-23950] Revert [FLINK-23738][state] to re-enable ChangelogBackend - posted by GitBox <gi...@apache.org> on 2021/09/26 03:05:05 UTC, 0 replies.
- [jira] [Created] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/09/26 03:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/09/26 03:11:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-23950) Revert FLINK-23738 (i.e. unhide config, API, docs) - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/09/26 03:20:00 UTC, 0 replies.
- [GitHub] [flink] xuyangzhong commented on pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition - posted by GitBox <gi...@apache.org> on 2021/09/26 03:51:41 UTC, 0 replies.
- [GitHub] [flink] zoltar9264 commented on pull request #17292: [FLINK-24274][docs] Wrong parameter order in documentation of State Processor API - posted by GitBox <gi...@apache.org> on 2021/09/26 04:06:29 UTC, 0 replies.
- [GitHub] [flink] ruanhang1993 commented on pull request #17134: [FLINK-24108][docs] Kafka documentation - posted by GitBox <gi...@apache.org> on 2021/09/26 05:58:00 UTC, 0 replies.
- [GitHub] [flink] ruanhang1993 closed pull request #17134: [FLINK-24108][docs] Kafka documentation - posted by GitBox <gi...@apache.org> on 2021/09/26 05:58:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-23826) Verify optimized scheduler performance for large-scale jobs - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/09/26 06:45:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-23826) Verify optimized scheduler performance for large-scale jobs - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/09/26 06:49:00 UTC, 1 replies.
- [GitHub] [flink-ml] gaoyunhaii opened a new pull request #5: [FLINK-1] Adds the iteration module and API - posted by GitBox <gi...@apache.org> on 2021/09/26 07:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-1) [GitHub] Hide auxiliary tasks for iterative data flows in visualization - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/26 07:43:00 UTC, 0 replies.
- [GitHub] [flink-ml] gaoyunhaii opened a new pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks - posted by GitBox <gi...@apache.org> on 2021/09/26 07:50:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-2) [GitHub] Implement Post Pass Phase for Workset Iterations, Pact Record Based - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/26 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/09/26 07:52:00 UTC, 0 replies.
- [GitHub] [flink] PatrickRen opened a new pull request #17355: [FLINK-24376][runtime] Use operator name for constructing OperatorCoordinatorProvider instead of chained name - posted by GitBox <gi...@apache.org> on 2021/09/26 07:57:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/26 07:58:00 UTC, 0 replies.
- [GitHub] [flink-ml] gaoyunhaii opened a new pull request #7: [FLINK-3][iteration] Implements the feedback mechanism and the controller operators. - posted by GitBox <gi...@apache.org> on 2021/09/26 08:03:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-3) [GitHub] Implement JobGraph Generation Phase for Workset Iterations - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/26 08:04:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17355: [FLINK-24376][runtime] Use operator name for constructing OperatorCoordinatorProvider instead of chained name - posted by GitBox <gi...@apache.org> on 2021/09/26 08:04:39 UTC, 1 replies.
- [jira] [Created] (FLINK-24377) TM resource may not be properly released after heartbeat timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/26 08:09:00 UTC, 0 replies.
- [GitHub] [flink-ml] lindong28 commented on pull request #7: [FLINK-3][iteration] Implements the feedback mechanism and the controller operators. - posted by GitBox <gi...@apache.org> on 2021/09/26 08:24:15 UTC, 0 replies.
- [GitHub] [flink-ml] lindong28 commented on pull request #5: [FLINK-1][iteration] Adds the iteration module and API - posted by GitBox <gi...@apache.org> on 2021/09/26 08:24:27 UTC, 0 replies.
- [GitHub] [flink] leonardBang opened a new pull request #17356: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/26 08:30:31 UTC, 0 replies.
- [jira] [Updated] (FLINK-23313) Reintroduce temporal table function documentation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/26 08:31:00 UTC, 1 replies.
- [GitHub] [flink] leonardBang commented on pull request #17356: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/26 08:31:56 UTC, 3 replies.
- [GitHub] [flink] flinkbot commented on pull request #17356: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/26 08:32:48 UTC, 1 replies.
- [GitHub] [flink-ml] lindong28 commented on a change in pull request #5: [FLINK-1][iteration] Adds the iteration module and API - posted by GitBox <gi...@apache.org> on 2021/09/26 08:56:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/09/26 09:14:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17355: [FLINK-24376][runtime] Use operator name for constructing OperatorCoordinatorProvider instead of chained name - posted by GitBox <gi...@apache.org> on 2021/09/26 09:15:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/09/26 09:19:00 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17356: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/26 09:39:45 UTC, 1 replies.
- [GitHub] [flink-ml] becketqin commented on pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables - posted by GitBox <gi...@apache.org> on 2021/09/26 09:43:12 UTC, 0 replies.
- [GitHub] [flink-ml] becketqin merged pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables - posted by GitBox <gi...@apache.org> on 2021/09/26 09:43:29 UTC, 0 replies.
- [jira] [Assigned] (FLINK-22915) FLIP-173: Support DAG of algorithms - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2021/09/26 09:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-22915) FLIP-173: Support DAG of algorithms - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2021/09/26 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24378) Dim table join operator Push down - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2021/09/26 10:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24378) Dim table join operator Push down - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2021/09/26 11:19:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-24377) TM resource may not be properly released after heartbeat timeout - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/09/26 11:59:00 UTC, 1 replies.
- [GitHub] [flink-ml] lindong28 commented on pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks - posted by GitBox <gi...@apache.org> on 2021/09/26 12:36:19 UTC, 0 replies.
- [GitHub] [flink-ml] lindong28 commented on a change in pull request #7: [FLINK-3][iteration] Implements the feedback mechanism and the controller operators. - posted by GitBox <gi...@apache.org> on 2021/09/26 12:47:37 UTC, 0 replies.
- [GitHub] [flink] wanglijie95 opened a new pull request #17357: [FLINK-24375] Let name of flush thread in RecordWriter contain subtask index. - posted by GitBox <gi...@apache.org> on 2021/09/26 14:19:13 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17357: [FLINK-24375] Let name of flush thread in RecordWriter contain subtask index. - posted by GitBox <gi...@apache.org> on 2021/09/26 14:21:56 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17357: [FLINK-24375] Let name of flush thread in RecordWriter contain subtask index. - posted by GitBox <gi...@apache.org> on 2021/09/26 15:34:29 UTC, 4 replies.
- [GitHub] [flink] qianchutao opened a new pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka' - posted by GitBox <gi...@apache.org> on 2021/09/26 16:41:59 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka' - posted by GitBox <gi...@apache.org> on 2021/09/26 16:45:01 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka' - posted by GitBox <gi...@apache.org> on 2021/09/26 17:32:24 UTC, 5 replies.
- [jira] [Updated] (FLINK-23526) py36-cython: commands failed on Azure - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/26 22:38:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/26 22:38:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-23995) Hive dialect: `insert overwrite table partition if not exists` will throw exception when tablename is like 'database.table' - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/26 22:38:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-23604) 'csv.disable-quote-character' can not take effect during deserialization for old csv format - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/26 22:38:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-23595) Allow JSON format deserialize non-numeric numbers - posted by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2021/09/26 22:38:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-13247) Implement external shuffle service for YARN - posted by "LI Mingkun (Jira)" <ji...@apache.org> on 2021/09/27 02:29:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24379) AWS Glue Schema Registry support doesn't work for table API - posted by "Brad Davis (Jira)" <ji...@apache.org> on 2021/09/27 02:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/27 03:02:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/27 03:04:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-24358) flink-avro-glue-schema-registry fails compiling with scala 2.12 due to dependency convergence - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/27 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/09/27 03:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/09/27 03:10:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-21032) JsonFileCompactionITCase fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/27 03:12:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/09/27 03:15:00 UTC, 0 replies.
- [GitHub] [flink] jherico opened a new pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/27 05:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24379) AWS Glue Schema Registry support doesn't work for table API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/27 05:02:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-24379) AWS Glue Schema Registry support doesn't work for table API - posted by "Brad Davis (Jira)" <ji...@apache.org> on 2021/09/27 05:04:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/27 06:07:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/27 06:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24379) AWS Glue Schema Registry support doesn't work for table API - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/27 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24381) Hidden password value when Flink SQL connector throw exception. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/09/27 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24382) RecordsOut metric for sinks is inaccurate - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/27 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/09/27 07:05:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/27 07:09:12 UTC, 17 replies.
- [GitHub] [flink-ml] gaoyunhaii opened a new pull request #8: [FLINK-4][iteration] Add operator wrapper for all-round iterations. - posted by GitBox <gi...@apache.org> on 2021/09/27 07:09:31 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17359: [FLINK-24358] Fix glue schema e2e dependency convergence - posted by GitBox <gi...@apache.org> on 2021/09/27 07:09:36 UTC, 0 replies.
- [GitHub] [flink] fapaul commented on a change in pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/27 07:09:41 UTC, 2 replies.
- [jira] [Updated] (FLINK-4) [GitHub] Rework Post pass Phase to be generic for all tuple-like data models - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/27 07:10:01 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/27 07:10:06 UTC, 0 replies.
- [GitHub] [flink] AHeise commented on a change in pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/27 07:10:18 UTC, 4 replies.
- [GitHub] [flink] RocMarshal edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view - posted by GitBox <gi...@apache.org> on 2021/09/27 07:10:21 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17359: [FLINK-24358] Fix glue schema e2e dependency convergence - posted by GitBox <gi...@apache.org> on 2021/09/27 07:10:24 UTC, 1 replies.
- [GitHub] [flink] fapaul edited a comment on pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document - posted by GitBox <gi...@apache.org> on 2021/09/27 07:10:43 UTC, 0 replies.
- [GitHub] [flink-ml] zhipeng93 opened a new pull request #9: [hotfix]bugfix in pom and delete some codes in old Flink ML API (as opposed to FLIP-173). - posted by GitBox <gi...@apache.org> on 2021/09/27 07:10:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/27 07:11:00 UTC, 0 replies.
- [GitHub] [flink-ml] zhipeng93 commented on pull request #9: [hotfix]bugfix in pom and delete some codes in old Flink ML API (as opposed to FLIP-173). - posted by GitBox <gi...@apache.org> on 2021/09/27 07:11:12 UTC, 0 replies.
- [GitHub] [flink] jherico commented on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/27 07:12:46 UTC, 2 replies.
- [GitHub] [flink] Airblader commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/27 07:13:19 UTC, 2 replies.
- [GitHub] [flink] slinkydeveloper commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable - posted by GitBox <gi...@apache.org> on 2021/09/27 07:16:21 UTC, 3 replies.
- [GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/27 07:16:33 UTC, 17 replies.
- [GitHub] [flink] qianchutao commented on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka' - posted by GitBox <gi...@apache.org> on 2021/09/27 07:21:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-24381) Hidden password value when Flink SQL connector throw exception. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/09/27 07:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/09/27 07:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24215) Timeout exception in submitting a job by RemoteStreamEnvironment/RemoteEnvironment - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/09/27 07:40:00 UTC, 0 replies.
- [GitHub] [flink] KarmaGYZ opened a new pull request #17361: [FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/27 07:52:25 UTC, 0 replies.
- [GitHub] [flink] xintongsong opened a new pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/27 07:52:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-24377) TM resource may not be properly released after heartbeat timeout - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/27 07:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/27 07:53:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24384) Count checkpoints failed in trigger phase into numberOfFailedCheckpoints - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/09/27 08:07:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17361: [FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/27 08:09:25 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/27 08:09:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/27 08:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24384) Count checkpoints failed in trigger phase into numberOfFailedCheckpoints - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/09/27 08:13:00 UTC, 0 replies.
- [GitHub] [flink] slinkydeveloper commented on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable - posted by GitBox <gi...@apache.org> on 2021/09/27 08:18:48 UTC, 0 replies.
- [GitHub] [flink] slinkydeveloper edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable - posted by GitBox <gi...@apache.org> on 2021/09/27 08:19:10 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-24379) AWS Glue Schema Registry support doesn't work for table API - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/09/27 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24385) Add TRY_CAST function to be able to handle errors - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/27 08:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24385) Add TRY_CAST function to be able to handle errors - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/27 08:30:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-24290) Support STRUCTURED_TYPE for JSON_OBJECT / JSON_ARRAY - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/27 08:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9465) Specify a separate savepoint timeout option via CLI - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/09/27 08:51:00 UTC, 0 replies.
- [GitHub] [flink-benchmarks] pnowojski commented on a change in pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate - posted by GitBox <gi...@apache.org> on 2021/09/27 09:03:38 UTC, 7 replies.
- [GitHub] [flink] pnowojski commented on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers - posted by GitBox <gi...@apache.org> on 2021/09/27 09:05:32 UTC, 0 replies.
- [GitHub] [flink-benchmarks] dawidwys commented on a change in pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate - posted by GitBox <gi...@apache.org> on 2021/09/27 09:12:32 UTC, 9 replies.
- [jira] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception. - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/27 09:16:00 UTC, 2 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17361: [FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/27 09:18:16 UTC, 5 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/27 09:18:21 UTC, 5 replies.
- [jira] [Closed] (FLINK-24378) Dim table join operator Push down - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/27 09:23:00 UTC, 0 replies.
- [GitHub] [flink] xintongsong closed pull request #17359: [FLINK-24358] Fix glue schema e2e dependency convergence - posted by GitBox <gi...@apache.org> on 2021/09/27 09:27:24 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24381) Hidden password value when Flink SQL connector throw exception. - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/27 09:43:00 UTC, 0 replies.
- [GitHub] [flink] wangyang0918 commented on a change in pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/27 10:00:48 UTC, 0 replies.
- [GitHub] [flink] fapaul opened a new pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143 - posted by GitBox <gi...@apache.org> on 2021/09/27 10:02:28 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143 - posted by GitBox <gi...@apache.org> on 2021/09/27 10:10:00 UTC, 1 replies.
- [GitHub] [flink-web] StephanEwen closed pull request #466: Add Apache Flink release 1.14.0 - posted by GitBox <gi...@apache.org> on 2021/09/27 10:38:27 UTC, 0 replies.
- [GitHub] [flink-web] StephanEwen commented on pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/27 10:38:27 UTC, 2 replies.
- [GitHub] [flink-web] StephanEwen commented on a change in pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/27 10:49:35 UTC, 12 replies.
- [GitHub] [flink-web] joemoe commented on a change in pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/27 11:09:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-22533) Allow creating custom metrics - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/09/27 11:13:00 UTC, 0 replies.
- [GitHub] [flink] fapaul opened a new pull request #17364: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/27 11:18:07 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17364: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/27 11:22:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-16024) support filter pushdown in jdbc connector - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2021/09/27 11:24:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143 - posted by GitBox <gi...@apache.org> on 2021/09/27 11:32:26 UTC, 15 replies.
- [jira] [Comment Edited] (FLINK-24293) Tasks from the same job on a machine share user jar - posted by "huntercc (Jira)" <ji...@apache.org> on 2021/09/27 11:51:00 UTC, 0 replies.
- [GitHub] [flink] Airblader commented on pull request #17325: [FLINK-24197] fix WEB UI build failure on windows - posted by GitBox <gi...@apache.org> on 2021/09/27 12:04:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-24327) Integrate Elasticsearch 7 sink with Table API - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/27 12:06:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/09/27 12:07:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17364: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/27 12:36:32 UTC, 5 replies.
- [GitHub] [flink] alpreu commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143 - posted by GitBox <gi...@apache.org> on 2021/09/27 12:56:04 UTC, 0 replies.
- [GitHub] [flink] AHeise merged pull request #17346: [hotfix][docs] Remove the explicit requirement of flink-connector-base in pulsar connector document - posted by GitBox <gi...@apache.org> on 2021/09/27 13:04:56 UTC, 0 replies.
- [GitHub] [flink] AHeise commented on pull request #17061: [FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing - posted by GitBox <gi...@apache.org> on 2021/09/27 13:13:57 UTC, 2 replies.
- [GitHub] [flink-benchmarks] dawidwys commented on pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate - posted by GitBox <gi...@apache.org> on 2021/09/27 13:23:19 UTC, 4 replies.
- [GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143 - posted by GitBox <gi...@apache.org> on 2021/09/27 13:34:01 UTC, 26 replies.
- [GitHub] [flink] MartijnVisser edited a comment on pull request #14544: [FLINK-20845] Drop Scala 2.11 support - posted by GitBox <gi...@apache.org> on 2021/09/27 13:46:52 UTC, 0 replies.
- [GitHub] [flink-web] infoverload commented on a change in pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/27 13:50:23 UTC, 28 replies.
- [jira] [Commented] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/27 14:00:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/27 14:01:00 UTC, 0 replies.
- [GitHub] [flink] MartijnVisser commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/27 14:18:19 UTC, 2 replies.
- [GitHub] [flink] sjwiesman closed pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs - posted by GitBox <gi...@apache.org> on 2021/09/27 14:22:05 UTC, 0 replies.
- [jira] [Created] (FLINK-24387) Support a "to JSON" function - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/27 14:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-16205) Support JSON_OBJECTAGG - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/27 14:24:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/27 14:25:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/27 14:25:00 UTC, 0 replies.
- [GitHub] [flink] rionmonster commented on pull request #17061: [FLINK-23977][elasticsearch] Added DynamicElasticsearchSink for Dynamic ES Cluster Routing - posted by GitBox <gi...@apache.org> on 2021/09/27 14:48:20 UTC, 1 replies.
- [jira] [Created] (FLINK-24388) Modules can provide a Factory for factory discovery - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/27 14:49:00 UTC, 0 replies.
- [GitHub] [flink-ml] lindong28 opened a new pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface - posted by GitBox <gi...@apache.org> on 2021/09/27 15:12:51 UTC, 0 replies.
- [jira] [Updated] (FLINK-24354) FLIP-174: Improve the WithParam interface - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/27 15:13:00 UTC, 0 replies.
- [GitHub] [flink-benchmarks] pnowojski commented on pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate - posted by GitBox <gi...@apache.org> on 2021/09/27 15:18:02 UTC, 2 replies.
- [GitHub] [flink-benchmarks] pnowojski edited a comment on pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate - posted by GitBox <gi...@apache.org> on 2021/09/27 15:19:41 UTC, 1 replies.
- [GitHub] [flink-ml] lindong28 commented on pull request #9: [hotfix]bugfix in pom and delete some codes in old Flink ML API (as opposed to FLIP-173). - posted by GitBox <gi...@apache.org> on 2021/09/27 15:35:29 UTC, 1 replies.
- [GitHub] [flink-ml] lindong28 edited a comment on pull request #9: [hotfix]bugfix in pom and delete some codes in old Flink ML API (as opposed to FLIP-173). - posted by GitBox <gi...@apache.org> on 2021/09/27 15:36:00 UTC, 0 replies.
- [GitHub] [flink] CrynetLogistics commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/27 16:49:36 UTC, 2 replies.
- [GitHub] [flink-ml] gaoyunhaii opened a new pull request #11: [FLINK-5][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time - posted by GitBox <gi...@apache.org> on 2021/09/27 18:13:03 UTC, 1 replies.
- [jira] [Updated] (FLINK-5) [GitHub] Configurable Iteration Aggregators - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/27 18:14:00 UTC, 0 replies.
- [GitHub] [flink] jherico removed a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/27 20:14:39 UTC, 1 replies.
- [GitHub] [flink] sjwiesman commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/27 21:07:57 UTC, 1 replies.
- [jira] [Created] (FLINK-24389) getDescription() in `CatalogTableImpl` should check null - posted by "Neng Lu (Jira)" <ji...@apache.org> on 2021/09/28 01:40:00 UTC, 0 replies.
- [GitHub] [flink-web] xintongsong commented on pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/28 01:52:19 UTC, 1 replies.
- [GitHub] [flink-ml] zhipeng93 commented on pull request #9: [hotfix] Fix pom.xml and delete outdated files - posted by GitBox <gi...@apache.org> on 2021/09/28 02:04:19 UTC, 2 replies.
- [GitHub] [flink] xintongsong commented on a change in pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/28 02:33:02 UTC, 1 replies.
- [GitHub] [flink] zekai-li opened a new pull request #17365: [hotfix][web]Modify the configuration of prettier - posted by GitBox <gi...@apache.org> on 2021/09/28 02:33:34 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17365: [hotfix][web]Modify the configuration of prettier - posted by GitBox <gi...@apache.org> on 2021/09/28 02:37:40 UTC, 2 replies.
- [GitHub] [flink] xintongsong commented on pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/28 02:39:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-24355) Expose the flag for enabling checkpoints after tasks finish in the Web UI - posted by "jackwangcs (Jira)" <ji...@apache.org> on 2021/09/28 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24390) Python 'build_wheels mac' fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 02:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24390) Python 'build_wheels mac' fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 02:51:00 UTC, 2 replies.
- [GitHub] [flink] zhuzhurk closed pull request #17357: [FLINK-24375] Let name of flush thread in RecordWriter contain subtask index. - posted by GitBox <gi...@apache.org> on 2021/09/28 03:03:02 UTC, 1 replies.
- [jira] [Closed] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/09/28 03:04:00 UTC, 0 replies.
- [GitHub] [flink-ml] gaoyunhaii commented on pull request #9: [hotfix] Fix pom.xml and delete outdated files - posted by GitBox <gi...@apache.org> on 2021/09/28 03:27:48 UTC, 1 replies.
- [GitHub] [flink-ml] gaoyunhaii closed pull request #9: [hotfix] Fix pom.xml and delete outdated files - posted by GitBox <gi...@apache.org> on 2021/09/28 03:31:17 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-9465) Specify a separate savepoint timeout option via CLI - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/09/28 03:33:00 UTC, 0 replies.
- [GitHub] [flink] zekai-li commented on pull request #17365: [hotfix][web]Modify the configuration of prettier - posted by GitBox <gi...@apache.org> on 2021/09/28 03:43:29 UTC, 6 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier - posted by GitBox <gi...@apache.org> on 2021/09/28 04:10:33 UTC, 14 replies.
- [jira] [Commented] (FLINK-23957) KafkaProducerAtLeastOnceITCase.testOneToOneAtLeastOnceRegularSink fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 05:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes - posted by "Gunjan Sharma (Jira)" <ji...@apache.org> on 2021/09/28 06:14:00 UTC, 1 replies.
- [GitHub] [flink-web] pnowojski commented on a change in pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/28 06:23:31 UTC, 2 replies.
- [GitHub] [flink] dawidwys opened a new pull request #17366: [FLINK-24374] Retry querying for checkpoint stats - posted by GitBox <gi...@apache.org> on 2021/09/28 06:45:53 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17366: [FLINK-24374] Retry querying for checkpoint stats - posted by GitBox <gi...@apache.org> on 2021/09/28 06:49:18 UTC, 2 replies.
- [jira] [Updated] (FLINK-20845) Drop support for Scala 2.11 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/28 07:06:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-24389) getDescription() in `CatalogTableImpl` should check null - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/28 07:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24389) getDescription() in `CatalogTableImpl` should check null - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/28 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24391) flink-json formats should support an option to extract the raw message into a column - posted by "Shengnan YU (Jira)" <ji...@apache.org> on 2021/09/28 07:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24391) flink-json formats should support an option to extract the raw message into a column - posted by "Shengnan YU (Jira)" <ji...@apache.org> on 2021/09/28 07:38:00 UTC, 0 replies.
- [GitHub] [flink] xintongsong closed pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/28 07:39:25 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17366: [FLINK-24374] Retry querying for checkpoint stats - posted by GitBox <gi...@apache.org> on 2021/09/28 07:42:16 UTC, 1 replies.
- [GitHub] [flink] fapaul opened a new pull request #17367: [FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat… - posted by GitBox <gi...@apache.org> on 2021/09/28 07:49:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-24382) RecordsOut metric for sinks is inaccurate - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/28 07:50:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17367: [FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat… - posted by GitBox <gi...@apache.org> on 2021/09/28 07:51:57 UTC, 2 replies.
- [GitHub] [flink] zentol commented on a change in pull request #14544: [FLINK-20845] Drop Scala 2.11 support - posted by GitBox <gi...@apache.org> on 2021/09/28 08:09:28 UTC, 4 replies.
- [GitHub] [flink] fapaul commented on a change in pull request #17342: [FLINK-20928] Fix flaky test by retrying notifyCheckpointComplete until either commit success or timeout - posted by GitBox <gi...@apache.org> on 2021/09/28 08:25:46 UTC, 1 replies.
- [jira] [Updated] (FLINK-24379) Support AWS Glue Schema Registry Avro for Table API - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/09/28 08:27:00 UTC, 0 replies.
- [GitHub] [flink] twalthr commented on a change in pull request #17341: [hotfix][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/28 08:33:09 UTC, 1 replies.
- [GitHub] [flink] dannycranmer commented on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/28 08:33:41 UTC, 2 replies.
- [GitHub] [flink] dannycranmer commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/28 08:34:05 UTC, 2 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17367: [FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat… - posted by GitBox <gi...@apache.org> on 2021/09/28 08:45:41 UTC, 2 replies.
- [GitHub] [flink] matriv commented on a change in pull request #17341: [hotfix][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/28 08:54:24 UTC, 4 replies.
- [GitHub] [flink] slinkydeveloper opened a new pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors - posted by GitBox <gi...@apache.org> on 2021/09/28 09:02:09 UTC, 1 replies.
- [GitHub] [flink] slinkydeveloper opened a new pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate - posted by GitBox <gi...@apache.org> on 2021/09/28 09:10:09 UTC, 1 replies.
- [GitHub] [flink] Airblader commented on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors - posted by GitBox <gi...@apache.org> on 2021/09/28 09:10:34 UTC, 1 replies.
- [jira] [Updated] (FLINK-19792) Interval join with equal time attributes is not recognized - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/28 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24392) Upgrade presto s3 fs implementation to Trinio >= 348 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/28 09:13:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate - posted by GitBox <gi...@apache.org> on 2021/09/28 09:13:35 UTC, 2 replies.
- [GitHub] [flink] flinkbot commented on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors - posted by GitBox <gi...@apache.org> on 2021/09/28 09:13:37 UTC, 2 replies.
- [GitHub] [flink] MartijnVisser commented on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/28 09:17:06 UTC, 1 replies.
- [GitHub] [flink] KarmaGYZ opened a new pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/28 09:24:47 UTC, 1 replies.
- [GitHub] [flink] KarmaGYZ opened a new pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/28 09:25:18 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/28 09:27:52 UTC, 2 replies.
- [GitHub] [flink] flinkbot commented on pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/28 09:27:53 UTC, 2 replies.
- [GitHub] [flink] flinkbot commented on pull request #17372: [BP-1.13][FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/28 09:30:17 UTC, 2 replies.
- [GitHub] [flink] slinkydeveloper commented on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors - posted by GitBox <gi...@apache.org> on 2021/09/28 09:33:53 UTC, 1 replies.
- [GitHub] [flink] slinkydeveloper edited a comment on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors - posted by GitBox <gi...@apache.org> on 2021/09/28 09:37:15 UTC, 1 replies.
- [GitHub] [flink] infoverload commented on pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/28 09:50:23 UTC, 1 replies.
- [GitHub] [flink] CrynetLogistics closed pull request #17349: [FLINK-24370][documentation] Added documentation for Asynchronous Sin… - posted by GitBox <gi...@apache.org> on 2021/09/28 09:53:48 UTC, 1 replies.
- [GitHub] [flink] LB-Yu opened a new pull request #17373: [hotfix] [docs-zh] Add auxiliary words to make the sentence flow smoothly - posted by GitBox <gi...@apache.org> on 2021/09/28 09:54:00 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17373: [hotfix] [docs-zh] Add auxiliary words to make the sentence flow smoothly - posted by GitBox <gi...@apache.org> on 2021/09/28 09:56:22 UTC, 1 replies.
- [jira] [Updated] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 09:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 09:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23778) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue hangs on Azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 09:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23932) KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:00:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-9477) FLIP-90: Support SQL 2016 JSON functions in Flink SQL - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:02:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:02:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:03:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:03:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:03:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-14023) Support accessing job parameters in Python user-defined functions - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:03:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-14028) Support to configure the log level of the Python user-defined functions - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24393) Add tests for all currently supported cast combinations - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/28 10:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24387) Support a "to JSON" function - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/09/28 10:05:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:06:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-14918) Add performance e2e test module and scripts - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-14471) Hide error message when metric api failed - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:06:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-14920) Set up environment to run performance e2e tests - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:06:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-15507) Activate local recovery for RocksDB backends by default - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16126) Translate all connector related pages into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16137) Translate all DataStream API related pages into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16078) Translate "Tuning Checkpoints and Large State" page into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16153) Translate "Operator/windows" into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:10:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-16155) Translate "Operator/Process Function" into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:10:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-16154) Translate "Operator/Join" into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:10:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-16388) Bump orc-core to 1.4.5 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 10:10:01 UTC, 0 replies.
- [jira] [Created] (FLINK-24394) Refactor scalar function testing infrastructure to allow testing multiple columns - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/28 10:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24395) Checkpoint trigger time difference between log statement and web frontend - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/28 10:23:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24395) Checkpoint trigger time difference between log statement and web frontend - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/28 10:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/28 10:40:00 UTC, 3 replies.
- [jira] [Created] (FLINK-24396) Add @Public annotations to Table & SQL API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 10:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24396) Add @Public annotations to Table & SQL API classes - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 10:46:00 UTC, 0 replies.
- [GitHub] [flink] dawidwys merged pull request #17366: [FLINK-24374] Retry querying for checkpoint stats - posted by GitBox <gi...@apache.org> on 2021/09/28 10:46:21 UTC, 1 replies.
- [jira] [Closed] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/28 10:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job - posted by "Peidian Li (Jira)" <ji...@apache.org> on 2021/09/28 10:50:00 UTC, 0 replies.
- [GitHub] [flink-web] dmvk commented on a change in pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/28 10:58:03 UTC, 2 replies.
- [jira] [Assigned] (FLINK-24397) Reduce TableSchema usage in Table API connectors - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/28 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24397) Reduce TableSchema usage in Table API connectors - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/28 11:03:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17341: [FLINK-24394][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/28 11:12:15 UTC, 8 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17373: [hotfix] [docs-zh] Add auxiliary words to make the sentence flow smoothly - posted by GitBox <gi...@apache.org> on 2021/09/28 11:12:37 UTC, 2 replies.
- [jira] [Updated] (FLINK-24394) Refactor scalar function testing infrastructure to allow testing multiple columns - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/28 11:13:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-24396) Add @Public annotations to Table & SQL API classes - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/28 11:56:00 UTC, 0 replies.
- [GitHub] [flink] alpreu opened a new pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API - posted by GitBox <gi...@apache.org> on 2021/09/28 12:09:49 UTC, 1 replies.
- [jira] [Closed] (FLINK-7156) Re-enabled external jar ScalaShellITCase - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/28 12:11:00 UTC, 0 replies.
- [GitHub] [flink] zentol commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support - posted by GitBox <gi...@apache.org> on 2021/09/28 12:11:24 UTC, 5 replies.
- [GitHub] [flink] flinkbot commented on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API - posted by GitBox <gi...@apache.org> on 2021/09/28 12:14:27 UTC, 2 replies.
- [GitHub] [flink] fapaul commented on a change in pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API - posted by GitBox <gi...@apache.org> on 2021/09/28 12:21:16 UTC, 1 replies.
- [GitHub] [flink] lindong28 commented on a change in pull request #17342: [FLINK-20928] Fix flaky test by retrying notifyCheckpointComplete until either commit success or timeout - posted by GitBox <gi...@apache.org> on 2021/09/28 12:30:08 UTC, 2 replies.
- [jira] [Updated] (FLINK-22257) Clarify Flink ConfigOptions Usage - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/28 12:31:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24398) KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/09/28 12:40:00 UTC, 0 replies.
- [GitHub] [flink] twalthr commented on a change in pull request #17341: [FLINK-24394][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/28 12:43:19 UTC, 1 replies.
- [GitHub] [flink] lindong28 opened a new pull request #17375: [FLINK-24398][connectors/kafka] KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible - posted by GitBox <gi...@apache.org> on 2021/09/28 12:47:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-24398) KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/28 12:48:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17375: [FLINK-24398][connectors/kafka] KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible - posted by GitBox <gi...@apache.org> on 2021/09/28 12:50:16 UTC, 2 replies.
- [jira] [Commented] (FLINK-24398) KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/28 12:52:00 UTC, 0 replies.
- [GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143 - posted by GitBox <gi...@apache.org> on 2021/09/28 12:57:58 UTC, 12 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate - posted by GitBox <gi...@apache.org> on 2021/09/28 13:19:41 UTC, 11 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17368: [hotfix] Add a docs page with module specific guides for flink contributors - posted by GitBox <gi...@apache.org> on 2021/09/28 13:19:41 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/28 13:19:43 UTC, 5 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/28 13:19:56 UTC, 5 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API - posted by GitBox <gi...@apache.org> on 2021/09/28 13:20:00 UTC, 4 replies.
- [jira] [Created] (FLINK-24399) Make handling of DataType less verbose - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 13:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24397) Reduce TableSchema usage in Table API connectors - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 13:25:00 UTC, 0 replies.
- [GitHub] [flink] AHeise merged pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/28 13:26:00 UTC, 1 replies.
- [GitHub] [flink] AHeise merged pull request #17364: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by GitBox <gi...@apache.org> on 2021/09/28 13:27:18 UTC, 1 replies.
- [jira] [Resolved] (FLINK-24371) Support SinkWriter preCommit without the need of a committer - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/28 13:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24399) Make handling of DataType less verbose - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 13:31:00 UTC, 8 replies.
- [jira] [Updated] (FLINK-23652) Implement FLIP-179: Expose Standardized Operator Metrics - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/28 13:33:00 UTC, 0 replies.
- [GitHub] [flink] AHeise closed pull request #12052: [FLINK-17588][scala-shell] Throw exception when hadoop jar is missing in flink scala's yarn mode - posted by GitBox <gi...@apache.org> on 2021/09/28 13:44:52 UTC, 1 replies.
- [GitHub] [flink] AHeise commented on pull request #12052: [FLINK-17588][scala-shell] Throw exception when hadoop jar is missing in flink scala's yarn mode - posted by GitBox <gi...@apache.org> on 2021/09/28 13:44:55 UTC, 1 replies.
- [GitHub] [flink] AHeise closed pull request #11895: [FLINK-10911][scala-shell] Enable flink-scala-shell with Scala 2.12 - posted by GitBox <gi...@apache.org> on 2021/09/28 13:45:07 UTC, 1 replies.
- [GitHub] [flink] AHeise commented on pull request #11895: [FLINK-10911][scala-shell] Enable flink-scala-shell with Scala 2.12 - posted by GitBox <gi...@apache.org> on 2021/09/28 13:45:09 UTC, 1 replies.
- [GitHub] [flink] AHeise commented on pull request #7229: [FLINK-11060][scala-shell] Unable to set number of task manager and slot per task manager in scala shell local mode - posted by GitBox <gi...@apache.org> on 2021/09/28 13:45:21 UTC, 1 replies.
- [GitHub] [flink] AHeise closed pull request #7229: [FLINK-11060][scala-shell] Unable to set number of task manager and slot per task manager in scala shell local mode - posted by GitBox <gi...@apache.org> on 2021/09/28 13:45:24 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17372: [BP-1.13][FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/28 13:47:34 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17375: [FLINK-24398][connectors/kafka] KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible - posted by GitBox <gi...@apache.org> on 2021/09/28 13:47:52 UTC, 2 replies.
- [jira] [Closed] (FLINK-17588) Throw exception when hadoop jar is missing in flink scala's yarn mode. - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/28 13:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/28 13:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24399) Make handling of DataType less verbose - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/28 13:55:00 UTC, 9 replies.
- [jira] [Assigned] (FLINK-24399) Make handling of DataType less verbose - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/28 13:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23388) Non-static Scala case classes cannot be serialised - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/28 13:56:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-21913) Update DynamicTableFactory.Context to use ResolvedCatalogTable - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 13:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-21913) Update DynamicTableFactory.Context to use ResolvedCatalogTable - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 14:00:03 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-24399) Make handling of DataType less verbose - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 14:23:00 UTC, 1 replies.
- [GitHub] [flink] sjwiesman commented on pull request #17356: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/28 14:28:59 UTC, 1 replies.
- [GitHub] [flink] matriv commented on a change in pull request #17341: [FLINK-24394][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/28 14:37:46 UTC, 2 replies.
- [GitHub] [flink] twalthr commented on pull request #17341: [FLINK-24394][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/28 15:07:17 UTC, 3 replies.
- [GitHub] [flink] matriv commented on pull request #17341: [FLINK-24394][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/28 15:08:35 UTC, 1 replies.
- [GitHub] [flink] leonardBang opened a new pull request #17376: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/28 15:24:30 UTC, 1 replies.
- [GitHub] [flink] matriv commented on a change in pull request #17343: [hotfix][docs] Various doc enhancements around filesystem table connector and json - posted by GitBox <gi...@apache.org> on 2021/09/28 15:26:20 UTC, 3 replies.
- [GitHub] [flink] flinkbot commented on pull request #17376: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/28 15:27:58 UTC, 2 replies.
- [GitHub] [flink] leonardBang opened a new pull request #17377: [hotfix][docs] Move out the time zone page from streaming concepts section - posted by GitBox <gi...@apache.org> on 2021/09/28 16:05:13 UTC, 1 replies.
- [GitHub] [flink] leonardBang opened a new pull request #17378: [hotfix][docs] Move out the time zone page from streaming concepts section #17377 - posted by GitBox <gi...@apache.org> on 2021/09/28 16:05:49 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17377: [hotfix][docs] Move out the time zone page from streaming concepts section - posted by GitBox <gi...@apache.org> on 2021/09/28 16:15:11 UTC, 2 replies.
- [GitHub] [flink] flinkbot commented on pull request #17378: [hotfix][docs] Move out the time zone page from streaming concepts section #17377 - posted by GitBox <gi...@apache.org> on 2021/09/28 16:15:11 UTC, 2 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17376: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/28 16:39:03 UTC, 2 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17377: [hotfix][docs] Move out the time zone page from streaming concepts section - posted by GitBox <gi...@apache.org> on 2021/09/28 17:15:23 UTC, 6 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17378: [hotfix][docs] Move out the time zone page from streaming concepts section #17377 - posted by GitBox <gi...@apache.org> on 2021/09/28 17:15:36 UTC, 6 replies.
- [jira] [Commented] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348 - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/28 19:37:00 UTC, 0 replies.
- [GitHub] [flink] sjwiesman commented on a change in pull request #17377: [hotfix][docs] Move out the time zone page from streaming concepts section - posted by GitBox <gi...@apache.org> on 2021/09/28 21:55:38 UTC, 1 replies.
- [GitHub] [flink] hhkkxxx133 commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/28 23:05:19 UTC, 1 replies.
- [GitHub] [flink] leonardBang commented on pull request #17377: [hotfix][docs] Move out the time zone page from streaming concepts section - posted by GitBox <gi...@apache.org> on 2021/09/28 23:30:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/09/28 23:58:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-19830) Properly implements processing-time temporal table join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/09/28 23:58:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-19830) Properly implements processing-time temporal table join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/09/29 00:10:00 UTC, 0 replies.
- [GitHub] [flink] xintongsong closed pull request #17372: [BP-1.13][FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/29 01:36:01 UTC, 1 replies.
- [GitHub] [flink] xintongsong commented on pull request #17372: [BP-1.13][FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout. - posted by GitBox <gi...@apache.org> on 2021/09/29 01:36:15 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-24377) TM resource may not be properly released after heartbeat timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-24377) TM resource may not be properly released after heartbeat timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-17987) KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error reading field - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19615) HBaseConnectorITCase.testTableSink is instable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18958) Lose column comment when create table - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20523) OffsetsInitializerTest test failed with "java.net.BindException: Address already in use" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:45:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:45:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:45:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:45:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:45:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21302) Fix NPE when use row_number() in over agg - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22465) KafkaSourceITCase.testValueOnlyDeserializer hangs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22344) KafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue times out - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22520) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22562) Translate recent updates to backpressure and checkpointing docs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:48:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22821) FlinkKafkaProducerMigrationTest fails with "Address already in use" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23387) WindowRankITCase.testEventTimeTumbleWindowWithoutRankNumber fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23105) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23236) FanOutShardSubscriberTest.testTimeoutEnqueuingEvent fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23390) FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23601) TPC-DS end-to-end test fail with "File upload failed." - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23576) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to Artificial Failure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23431) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails with "The topic metadata failed to propagate to Kafka broker." - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23530) JoinITCase.testJoinOnCustomTypeInputWithKeyExtractorAndTupleInputWithKeyFieldSelector fails on Azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23405) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to BindException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:52:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23611) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23694) KafkaWriterITCase hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23679) PyFlink end-to-end test fail due to test script contains errors - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23795) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23880) WindowAggregateITCase.testCascadeEventTimeTumbleWindowWithOffset fail with Artificial Failure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23921) WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23881) SemiJoinITCase.testExistsWithOver4 fails with "failed to fetch next result" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24045) KafkaTableITCase.testPerPartitionWatermarkKafka fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24333) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredOnCheckpoint fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:57:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-10134) UTF-16 support for TextInputFormat - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 01:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-10134) UTF-16 support for TextInputFormat - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-13692) Make CompletedCheckpointStore backwards compatible? - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-13692) Make CompletedCheckpointStore backwards compatible? - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:02:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-13976) Make modern kafka E2E test runnable on Java 11 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:02:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-14998) Remove FileUtils#deletePathIfEmpty - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:03:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-13976) Make modern kafka E2E test runnable on Java 11 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-15524) Some links in Chinese documents points to English documents by mistake - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-15298) Wrong dependencies in the DataStream API tutorial (the wiki-edits example) - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-15524) Some links in Chinese documents points to English documents by mistake - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-15992) Incorrect classloader when finding TableFactory - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-15876) The alternative code for GroupedProcessingTimeWindowExample don't compile pass current version - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-16116) Remove shading from oss filesystems build - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-16324) Checkpoint tasks progress would display 100% in web UI even not all tasks finished - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-16612) Submit job through the rest api, job name will be lost - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:08:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/09/29 02:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-17168) TPC-DS end-to-end test failed on travis due to failed to download data generator - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-17329) Quickstarts Scala nightly e2e test failed on travis - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-17742) Blob file not removed after task was cancelled in standalone mode - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-17683) Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction， but not when it is a field of case class. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:12:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18060) Add notice for heap-based state backend of state access reference problem - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-17855) UDF with parameter Array(Row) can not work - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:12:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18276) NullPointerException (and potential leak) when closing KafkaConsumer after exception in reassignPartitions - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18334) Exclude .dumpstream files that only contain JAVA_TOOL_OPTIONS logging - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18503) bug occurs when `HeapReducingState#add` method handles null - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18365) The same sql in a batch env and a streaming env has different value. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-18460) If the Python UDFs are called before calling the Python Dependency Management API, the Python Dependency Management would not will not take effect. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18777) Supports schema registry catalog - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:15:00 UTC, 0 replies.
- [GitHub] [flink] RocMarshal commented on a change in pull request #15902: [FLINK-19028][docs] Translate the "application_parameters.md" into Chinese - posted by GitBox <gi...@apache.org> on 2021/09/29 02:15:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19254) Invalid UTF-8 start byte exception - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19370) FileSourceTextLinesITCase.testContinuousTextFileSource failed as results mismatch - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20474) flink cep results of doc is not right - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19670) Query on a view of temporal join throws ParseException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20643) flink-connector-elasticsearch7 causes Direct buffer memory OOM - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20818) End to end test produce excessive amount of logs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21125) Sum or Sum0 overflow quietly - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21340) CheckForbiddenMethodsUsage is not run and fails - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21438) Broken links in content.zh/docs/concepts/flink-architecture.md - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21582) COALESCE not works when cast a variable return null - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21789) Make FileChannelManagerImpl#getNextPathNum select data directories fairly - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21726) Fix checkpoint stuck - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21962) SQL Group Windows do not work on Flink 1.11 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21898) JobRetrievalITCase crash - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22572) JsonFsStreamSinkITCase.testPart fails running in a timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:23:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-22567) OrcFsStreamingSinkITCase crashes JVM - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:23:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:23:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-22558) testcontainers fail to start ResourceReaper - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:23:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:23:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-22701) "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:23:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:23:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-22892) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23310) Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is an update stream - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22842) Streaming File Sink end-to-end test fail due to not finish after 900s - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22834) KafkaITCase.testBigRecordJob times out on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22742) Lookup join condition with process time throws org.codehaus.commons.compiler.CompileException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22311) Flink JDBC XA connector need to set maxRetries to 0 to properly working - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23493) python tests hang on Azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:26:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:26:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-23528) stop-with-savepoint can fail with FlinkKinesisConsumer - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:26:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:26:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID' - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:26:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-23946) Application mode fails fatally when being shut down - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:26:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-21556) StreamingKafkaITCase hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18986) KubernetesSessionCli creates RestClusterClient for detached deployments - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment (Buffer debloat) - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 1 replies.
- [jira] [Updated] (FLINK-23914) Make connector testing framework more verbose on test failure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23545) Use new schema in SqlCreateTableConverter - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23870) Test the ability for ignoring in-flight data on recovery - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23533) Split InputSelection into public and internal parts - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23752) Add document for using HiveSource API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23902) Support Hive version 2.3.8 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23427) Translate the page of "Blocking Shuffle" into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23589) Support Avro Microsecond precision - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23412) Improve sourceSink description - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23825) Test SQL Client manually - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23887) Check thread pollution for 1.14 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-23798) Avoid using reflection to get filter when partition filter is enabled - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22209) Make StreamTask#triggerCheckpointAsync return void - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22222) Global config is logged twice by the client for batch jobs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 1 replies.
- [jira] [Updated] (FLINK-22975) Specify port or range for k8s service - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21966) Support Kinesis connector in Python DataStream API. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22336) [umbrella] Enhance testing for built-in functions - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22553) Improve error reporting on TM connection failures - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22960) Temporal join TTL should use enableTimeToLive of state instead of timer - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21871) Support watermark for Hive and Filesystem streaming source - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-23358) Refactor CoreOptions parent-first patterns to List options - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22805) Dynamic configuration of Flink checkpoint interval - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-23254) Upgrade Test Framework to JUnit 5 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22909) Supports change log inputs for event time operators - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22243) Reactive Mode parallelism changes are not shown in the job graph visualization in the UI - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 1 replies.
- [jira] [Updated] (FLINK-21953) Add documentation on batch mode support of Python DataStream API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21796) SQLClientKafkaITCase.testKafka fails to download Kafka - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22230) Misleading TaskExecutorResourceUtils log messages - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 1 replies.
- [jira] [Updated] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21790) Shuffle data directories to make directory selection of different TaskManagers fairer - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22146) Migrate StateBackend related Chinese docs to latest state backend - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-23000) Allow downloading all Flink logs from the UI - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22578) deployment configuration page miss content navigate menu - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22237) Flamegraph component calls draw method from template - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22226) Insufficient slots when submitting jobs results in massive stacktrace - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 1 replies.
- [jira] [Updated] (FLINK-22228) Random log exception when tasks finish after a checkpoint was started - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 1 replies.
- [jira] [Updated] (FLINK-22371) Chinese grammatical error - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-23086) Add getRuntimeExecutionMode to StreamExecutionEnvironment - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-23403) Decrease default values for heartbeat timeout and interval - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21971) Support FLIP-27 based kafka source connector in PyFlink DataStream API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-21649) Refactor CopyOnWrite state classes - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-21783) Allow extension of HeapBackend SnapshotStrategy - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-21784) Allow extension of HeapBackend RestoreOperation - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-21769) Encapsulate component meta data - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:30:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-21636) Setup a global timeout for all tests - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-21639) docs still state that AsyncWaitOperator is not chainable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-21408) Clarify which DataStream sources support Batch execution - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20895) Support LocalAggregatePushDown in Blink planner - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20920) Document how to connect to kerberized HMS - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20767) add nested field support for SupportsFilterPushDown - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21407) Clarify which sources and APIs support which formats - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20794) Support to select distinct columns in the Table API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21053) Prevent potential RejectedExecutionExceptions in CheckpointCoordinator failing JM - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20946) Optimize Python ValueState Implementation In PyFlink - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20896) Support SupportsAggregatePushDown for JDBC TableSource - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21184) Support temporary table/function for hive connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21409) Add Avro to DataTypes & Serialization docs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20787) Improve the Table API to make it usable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20726) Introduce Pulsar connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21179) Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20865) Prevent potential resource deadlock in fine-grained resource management - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20952) Changelog json formats should support inherit options from JSON format - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-20036) Join Has NoUniqueKey when using mini-batch - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-19965) Refactor HiveMapredSplitReader to adapt to the new hive source - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka) - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20154) Improve error messages when using CLI with wrong target - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20518) WebUI should escape characters in metric names - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20103) Improve test coverage with chaos testing & side-by-side tests - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20484) Improve hive temporal table exception - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20578) Cannot create empty array using ARRAY[] - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-19935) Supports configure heap memory of sql-client to avoid OOM - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20057) Use docker images instead of direct downloads in all end to end tests - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-19967) Clean legacy classes for Parquet and Orc - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-20280) Support batch mode for Python DataStream API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19527) Update SQL Pages - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19230) Support Python UDAF on blink batch planner - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19743) Add Source metrics definitions - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18742) Some configuration args do not take effect at client - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19647) Support the limit push down for the hbase connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19432) Whether to capture the updates which don't change any monitored columns - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18887) Add ElasticSearch connector for Python DataStream API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18753) Support local recovery for Unaligned checkpoints - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18981) Support column comment for Hive tables - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18873) Make the WatermarkStrategy API more scala friendly - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19103) The PushPartitionIntoTableSourceScanRule will lead a performance problem when there are still many partitions after pruning - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18954) Add documentation for connectors in Python DataStream API. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source) - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19845) Migrate all FileSystemFormatFactory implementations - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19085) Remove deprecated methods for writing CSV and Text files from DataStream - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19774) Introduce Sub Partition View Version for Approximate Local Recovery - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-18229) Pending worker requests should be properly cleared - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18405) Add watermark support for unaligned checkpoints - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18213) refactor kafka sql connector to use just one shade to compatible 0.10.0.2 + - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18231) flink kafka connector exists same qualified class name, whch will cause conflicts when user has all the versions of flink-kafka-connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18442) Move `testSessionWindowsWithContinuousEventTimeTrigger` to `ContinuousEventTimeTriggerTest` - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18202) Introduce Protobuf format - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18556) Drop the unused options in TableConfig - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-18201) Support create_function in Python Table API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:31:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16323) Support to join a static table in streaming mode - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17372) SlotManager should expose total required resources - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16799) add hive partition limit when read from hive - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17755) Support side-output of expiring states with TTL. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16952) Parquet file system format support filter pushdown - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16701) Elasticsearch sink support alias for indices. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-16775) expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-12590) Replace http links in documentation - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15012) Checkpoint directory not cleaned up - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15585) Improve function identifier string in plan digest - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-9407) Support orc rolling sink writer - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15000) WebUI Metrics is very slow in large parallelism - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14379) Supplement documentation about raw state - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15130) Drop "RequiredParameters" and "Options" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14867) Move TextInputFormat & TextOutputFormat to flink-core - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15003) Improve hive test performance - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-13698) Rework threading model of CheckpointCoordinator - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 1 replies.
- [jira] [Updated] (FLINK-14934) Remove error log statement in ES connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14479) Strange exceptions found in log file after executing `test_udf.py` - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-12412) Allow ListTypeInfo used for java.util.List and MapTypeInfo used for java.util.Map - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15018) Add event time page to Concepts - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15845) Add java-based StreamingFileSink test using s3 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14690) Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL Client - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15460) planner dependencies won't be necessary for JDBC connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14707) Refactor checkpoint related methods within Environment - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15351) develop PostgresCatalog to connect Flink with Postgres tables and ecosystem - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15860) Store temporary functions as CatalogFunctions in FunctionCatalog - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-13809) The log directory of Flink Python API is unwritable if it is installed via "sudo" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15973) Optimize the execution plan where it refers the Python UDF result field in the where clause - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14125) Display memory and CPU usage in the overview page - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14684) Add Pinterest to Chinese Powered By page - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-13876) Remove ExecutionConfig field from PojoSerializer - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft() - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-15922) Show "Warn - received late message for checkpoint" only when checkpoint actually expired - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 1 replies.
- [jira] [Updated] (FLINK-16024) support filter pushdown in jdbc connector - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:32:09 UTC, 0 replies.
- [GitHub] [flink] iyupeng commented on pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner - posted by GitBox <gi...@apache.org> on 2021/09/29 02:34:35 UTC, 1 replies.
- [jira] [Updated] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/29 02:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/09/29 03:00:00 UTC, 0 replies.
- [GitHub] [flink] BradyYue opened a new pull request #17379: Update kafka.md - posted by GitBox <gi...@apache.org> on 2021/09/29 03:02:09 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17379: Update kafka.md - posted by GitBox <gi...@apache.org> on 2021/09/29 03:18:55 UTC, 2 replies.
- [jira] [Created] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest? - posted by "jacky jia (Jira)" <ji...@apache.org> on 2021/09/29 03:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest? - posted by "jacky jia (Jira)" <ji...@apache.org> on 2021/09/29 03:38:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest? - posted by "jacky jia (Jira)" <ji...@apache.org> on 2021/09/29 03:54:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24401) TM cannot exit after Metaspace OOM - posted by "future (Jira)" <ji...@apache.org> on 2021/09/29 03:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24401) TM cannot exit after Metaspace OOM - posted by "future (Jira)" <ji...@apache.org> on 2021/09/29 04:00:00 UTC, 4 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17379: Update kafka.md - posted by GitBox <gi...@apache.org> on 2021/09/29 04:18:07 UTC, 2 replies.
- [jira] [Updated] (FLINK-24387) Support a "to JSON" function - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/29 06:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24387) Support a JSON_STRING function - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/29 06:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24387) Support a JSON_STRING function - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/29 06:35:00 UTC, 0 replies.
- [GitHub] [flink] ljdavns commented on pull request #17325: [FLINK-24337] fix WEB UI build failure on windows - posted by GitBox <gi...@apache.org> on 2021/09/29 06:50:00 UTC, 1 replies.
- [GitHub] [flink] ljdavns edited a comment on pull request #17325: [FLINK-24337] fix WEB UI build failure on windows - posted by GitBox <gi...@apache.org> on 2021/09/29 06:50:35 UTC, 1 replies.
- [jira] [Closed] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest? - posted by "jacky jia (Jira)" <ji...@apache.org> on 2021/09/29 06:51:00 UTC, 0 replies.
- [GitHub] [flink-ml] gaoyunhaii opened a new pull request #12: [FLINK-6][iteration] add unbounded iteration. - posted by GitBox <gi...@apache.org> on 2021/09/29 06:52:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-6) [GitHub] Fix the delimited record format double/decimal parsers. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/29 06:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24270) Rewrite tests for illegal job modification against VertexFinishedStateChecker - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/29 07:21:00 UTC, 0 replies.
- [GitHub] [flink] slinkydeveloper commented on a change in pull request #17343: [hotfix][docs] Various doc enhancements around filesystem table connector and json - posted by GitBox <gi...@apache.org> on 2021/09/29 07:36:53 UTC, 1 replies.
- [jira] [Closed] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment (Buffer debloat) - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/29 07:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-23928) Test the buffer debloating - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/29 07:46:00 UTC, 0 replies.
- [GitHub] [flink] wangyang0918 merged pull request #17361: [FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/29 07:46:15 UTC, 1 replies.
- [GitHub] [flink] wangyang0918 merged pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/29 07:47:07 UTC, 1 replies.
- [GitHub] [flink] wangyang0918 merged pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed - posted by GitBox <gi...@apache.org> on 2021/09/29 07:47:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-23273) Implement basic authentication handler - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/09/29 07:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-23273) Implement basic authentication handler - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/09/29 07:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-23273) Implement basic authentication handler - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/09/29 07:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-22562) Translate recent updates to backpressure and checkpointing docs - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/29 07:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-23274) Implement SPNEGO authentication handler - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/09/29 07:51:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-23274) Implement SPNEGO authentication handler - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/09/29 07:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-23274) Implement SPNEGO authentication handler - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/09/29 07:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-23272) FLIP-181: Custom netty HTTP request inbound/outbound handlers - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/09/29 07:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-23272) FLIP-181: Custom netty HTTP request inbound/outbound handlers - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/09/29 07:53:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/09/29 07:55:00 UTC, 0 replies.
- [GitHub] [flink-docker] dawidwys commented on pull request #92: Add GPG key for 1.14.0 release - posted by GitBox <gi...@apache.org> on 2021/09/29 07:56:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink - posted by "Alice Friry (Jira)" <ji...@apache.org> on 2021/09/29 08:18:00 UTC, 0 replies.
- [GitHub] [flink-ml] gaoyunhaii opened a new pull request #13: [FLINK-7][iteration] Add bounded all-round iteration - posted by GitBox <gi...@apache.org> on 2021/09/29 08:23:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/29 08:24:00 UTC, 0 replies.
- [GitHub] [flink-docker] dawidwys merged pull request #92: Add GPG key for 1.14.0 release - posted by GitBox <gi...@apache.org> on 2021/09/29 08:35:50 UTC, 1 replies.
- [GitHub] [flink-docker] dawidwys merged pull request #93: Update Dockerfiles for 1.14.0 release - posted by GitBox <gi...@apache.org> on 2021/09/29 08:36:00 UTC, 1 replies.
- [GitHub] [flink] jongillham opened a new pull request #17380: [hotfix][docs] Fix typo in sources doc - posted by GitBox <gi...@apache.org> on 2021/09/29 08:36:00 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17380: [hotfix][docs] Fix typo in sources doc - posted by GitBox <gi...@apache.org> on 2021/09/29 08:40:26 UTC, 2 replies.
- [GitHub] [flink] MartijnVisser commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API - posted by GitBox <gi...@apache.org> on 2021/09/29 09:17:33 UTC, 2 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17380: [hotfix][docs] Fix typo in sources doc - posted by GitBox <gi...@apache.org> on 2021/09/29 09:42:18 UTC, 2 replies.
- [GitHub] [flink] slinkydeveloper opened a new pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers - posted by GitBox <gi...@apache.org> on 2021/09/29 10:11:48 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers - posted by GitBox <gi...@apache.org> on 2021/09/29 10:18:47 UTC, 2 replies.
- [GitHub] [flink-web] dawidwys commented on pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/29 10:41:47 UTC, 1 replies.
- [GitHub] [flink-web] dawidwys closed pull request #468: Release blog post 1.14 draft iteration - posted by GitBox <gi...@apache.org> on 2021/09/29 10:42:08 UTC, 1 replies.
- [GitHub] [flink] YuriGusev opened a new pull request #17382: Flink 16504 dynamodb connector backpressure - posted by GitBox <gi...@apache.org> on 2021/09/29 11:00:41 UTC, 1 replies.
- [GitHub] [flink] YuriGusev closed pull request #17382: Flink 16504 dynamodb connector backpressure - posted by GitBox <gi...@apache.org> on 2021/09/29 11:11:30 UTC, 1 replies.
- [GitHub] [flink] YuriGusev commented on pull request #17382: Flink 16504 dynamodb connector backpressure - posted by GitBox <gi...@apache.org> on 2021/09/29 11:11:54 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17382: Flink 16504 dynamodb connector backpressure - posted by GitBox <gi...@apache.org> on 2021/09/29 11:16:12 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers - posted by GitBox <gi...@apache.org> on 2021/09/29 11:23:29 UTC, 15 replies.
- [GitHub] [flink] leo65535 opened a new pull request #17383: [hotfix][build] Add java8 profile - posted by GitBox <gi...@apache.org> on 2021/09/29 11:39:29 UTC, 1 replies.
- [GitHub] [flink] leo65535 commented on pull request #17383: [hotfix][build] Add java8 profile - posted by GitBox <gi...@apache.org> on 2021/09/29 11:40:11 UTC, 1 replies.
- [GitHub] [flink] twalthr commented on a change in pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers - posted by GitBox <gi...@apache.org> on 2021/09/29 11:40:43 UTC, 2 replies.
- [GitHub] [flink] flinkbot commented on pull request #17383: [hotfix][build] Add java8 profile - posted by GitBox <gi...@apache.org> on 2021/09/29 11:44:26 UTC, 2 replies.
- [GitHub] [flink] slinkydeveloper commented on a change in pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers - posted by GitBox <gi...@apache.org> on 2021/09/29 11:47:18 UTC, 3 replies.
- [GitHub] [flink] lirui-apache closed pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy - posted by GitBox <gi...@apache.org> on 2021/09/29 11:51:49 UTC, 1 replies.
- [jira] [Resolved] (FLINK-23316) There's no test for custom PartitionCommitPolicy - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/09/29 11:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24388) Modules can provide table source/sink factories - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/29 12:15:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-24388) Modules can provide table source/sink factories - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/29 12:16:00 UTC, 0 replies.
- [GitHub] [flink] Airblader opened a new pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory - posted by GitBox <gi...@apache.org> on 2021/09/29 12:20:38 UTC, 1 replies.
- [GitHub] [flink] Airblader commented on a change in pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory - posted by GitBox <gi...@apache.org> on 2021/09/29 12:22:39 UTC, 5 replies.
- [GitHub] [flink] flinkbot commented on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory - posted by GitBox <gi...@apache.org> on 2021/09/29 12:24:02 UTC, 2 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17383: [hotfix][build] Add java8 profile - posted by GitBox <gi...@apache.org> on 2021/09/29 12:54:51 UTC, 2 replies.
- [GitHub] [flink] zentol opened a new pull request #17385: [FLINK-24367][tests] Add FallbackAkkaRpcSystemLoader - posted by GitBox <gi...@apache.org> on 2021/09/29 12:59:40 UTC, 1 replies.
- [jira] [Updated] (FLINK-24367) Add a fallback AkkaRpcSystemLoader for tests in the IDE - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/29 13:00:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17385: [FLINK-24367][tests] Add FallbackAkkaRpcSystemLoader - posted by GitBox <gi...@apache.org> on 2021/09/29 13:03:14 UTC, 2 replies.
- [GitHub] [flink] nirtsruya opened a new pull request #17386: Flink 16504 dynamodb connector rebased batchsize - posted by GitBox <gi...@apache.org> on 2021/09/29 13:21:35 UTC, 1 replies.
- [GitHub] [flink] nirtsruya closed pull request #17386: Flink 16504 dynamodb connector rebased batchsize - posted by GitBox <gi...@apache.org> on 2021/09/29 13:23:00 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17386: Flink 16504 dynamodb connector rebased batchsize - posted by GitBox <gi...@apache.org> on 2021/09/29 13:24:55 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory - posted by GitBox <gi...@apache.org> on 2021/09/29 13:30:48 UTC, 13 replies.
- [GitHub] [flink] rkhachatryan opened a new pull request #17387: [WIP][FLINK-23486][state] Changelog Backend metrics - posted by GitBox <gi...@apache.org> on 2021/09/29 13:42:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-23486) Add monitoring/metrics for the ChangelogStateBackend - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/29 13:43:00 UTC, 2 replies.
- [jira] [Created] (FLINK-24402) Add back-pressure metrics for the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/09/29 13:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24402) Add back-pressure metrics for the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/09/29 13:45:00 UTC, 2 replies.
- [GitHub] [flink] flinkbot commented on pull request #17387: [WIP][FLINK-23486][state] Changelog Backend metrics - posted by GitBox <gi...@apache.org> on 2021/09/29 13:46:29 UTC, 2 replies.
- [GitHub] [flink] flinkbot commented on pull request #17388: [release] Make dependency names changes more prominent in the release notes - posted by GitBox <gi...@apache.org> on 2021/09/29 13:46:31 UTC, 1 replies.
- [jira] [Created] (FLINK-24403) Improve behaviour of CAST - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/29 13:50:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24393) Add tests for all currently supported cast combinations - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/29 13:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24402) Add back-pressure metrics for the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/09/29 13:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24393) Add tests for all currently supported cast combinations - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/29 13:52:00 UTC, 2 replies.
- [GitHub] [flink] twalthr opened a new pull request #17389: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers - posted by GitBox <gi...@apache.org> on 2021/09/29 13:53:51 UTC, 1 replies.
- [jira] [Assigned] (FLINK-24394) Refactor scalar function testing infrastructure to allow testing multiple columns - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/29 13:54:00 UTC, 0 replies.
- [GitHub] [flink] dawidwys closed pull request #17388: [release] Make dependency names changes more prominent in the release notes - posted by GitBox <gi...@apache.org> on 2021/09/29 13:54:47 UTC, 1 replies.
- [jira] [Assigned] (FLINK-23486) Add monitoring/metrics for the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/09/29 14:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24402) Add a metric for back-pressure from the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/09/29 14:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23486) Add metrics for the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/09/29 14:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23271) RuntimeException: while resolving method 'booleanValue' in class class java.math.BigDecimal - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/29 14:06:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17389: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers - posted by GitBox <gi...@apache.org> on 2021/09/29 14:15:22 UTC, 2 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17385: [FLINK-24367][tests] Add FallbackAkkaRpcSystemLoader - posted by GitBox <gi...@apache.org> on 2021/09/29 14:16:27 UTC, 2 replies.
- [jira] [Updated] (FLINK-21566) Improve error message for "Unsupported casting" - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/29 14:40:00 UTC, 0 replies.
- [GitHub] [flink] NickBurkard commented on a change in pull request #14544: [FLINK-20845] Drop Scala 2.11 support - posted by GitBox <gi...@apache.org> on 2021/09/29 14:42:05 UTC, 1 replies.
- [jira] [Created] (FLINK-24404) Support to submit job with the ID user provided - posted by "Eui Heo (Jira)" <ji...@apache.org> on 2021/09/29 14:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-24365) Support to make Flink job more programmatically controlled via CLI - posted by "Eui Heo (Jira)" <ji...@apache.org> on 2021/09/29 15:00:00 UTC, 0 replies.
- [GitHub] [flink-web] rionmonster opened a new pull request #469: [hotfix] Various Typos / Grammar / Clarity Fixes Across Documentations - posted by GitBox <gi...@apache.org> on 2021/09/29 15:10:25 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] Changelog Backend metrics - posted by GitBox <gi...@apache.org> on 2021/09/29 15:20:44 UTC, 2 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17389: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers - posted by GitBox <gi...@apache.org> on 2021/09/29 15:20:46 UTC, 2 replies.
- [GitHub] [flink] twalthr closed pull request #17341: [FLINK-24394][test] Refactor BuiltInFunctions IT Tests - posted by GitBox <gi...@apache.org> on 2021/09/29 15:42:34 UTC, 1 replies.
- [jira] [Closed] (FLINK-24394) Refactor scalar function testing infrastructure to allow testing multiple columns - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/29 15:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-19792) Interval join with equal time attributes is not recognized - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/09/29 15:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23972) NoClassDefFoundError: Jars from yarn.ship-files are missing in the classpath of the client - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2021/09/29 15:58:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17390: [FLINK-24275][rest] Idempotent job cancellation - posted by GitBox <gi...@apache.org> on 2021/09/29 16:21:17 UTC, 2 replies.
- [jira] [Updated] (FLINK-24275) Allow idempotent job cancellation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/29 16:22:00 UTC, 0 replies.
- [GitHub] [flink-benchmarks] akalash commented on pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate - posted by GitBox <gi...@apache.org> on 2021/09/29 16:45:35 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17390: [FLINK-24275][rest] Idempotent job cancellation - posted by GitBox <gi...@apache.org> on 2021/09/29 17:26:06 UTC, 2 replies.
- [GitHub] [flink] brachi-wernick commented on pull request #16596: [FLINK-23495] [Connectors / Google Cloud PubSub] Make checkpoint optional for preview/staging mode - posted by GitBox <gi...@apache.org> on 2021/09/29 19:08:22 UTC, 1 replies.
- [jira] [Updated] (FLINK-21884) Reduce TaskManager failure detection time - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/09/29 19:12:00 UTC, 3 replies.
- [GitHub] [flink] joemoe opened a new pull request #17391: emphasised the changes of dependency names for the 1.14 release - posted by GitBox <gi...@apache.org> on 2021/09/29 20:45:21 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17391: emphasised the changes of dependency names for the 1.14 release - posted by GitBox <gi...@apache.org> on 2021/09/29 20:48:14 UTC, 2 replies.
- [GitHub] [flink] sjwiesman closed pull request #17356: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/29 21:26:02 UTC, 1 replies.
- [GitHub] [flink] sjwiesman closed pull request #17377: [hotfix][docs] Move out the time zone page from streaming concepts section - posted by GitBox <gi...@apache.org> on 2021/09/29 21:26:04 UTC, 1 replies.
- [GitHub] [flink] sjwiesman commented on pull request #17376: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/29 21:27:30 UTC, 1 replies.
- [GitHub] [flink] sjwiesman closed pull request #17376: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by GitBox <gi...@apache.org> on 2021/09/29 21:27:32 UTC, 1 replies.
- [GitHub] [flink] sjwiesman closed pull request #17378: [hotfix][docs] Move out the time zone page from streaming concepts section #17377 - posted by GitBox <gi...@apache.org> on 2021/09/29 21:27:45 UTC, 1 replies.
- [GitHub] [flink] sjwiesman commented on pull request #17378: [hotfix][docs] Move out the time zone page from streaming concepts section #17377 - posted by GitBox <gi...@apache.org> on 2021/09/29 21:27:45 UTC, 1 replies.
- [jira] [Closed] (FLINK-23313) Reintroduce temporal table function documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/29 21:32:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17391: emphasised the changes of dependency names for the 1.14 release - posted by GitBox <gi...@apache.org> on 2021/09/29 22:18:46 UTC, 3 replies.
- [GitHub] [flink] infoverload opened a new pull request #17392: [release][docs] clean up release notes - posted by GitBox <gi...@apache.org> on 2021/09/30 00:51:31 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17392: [release][docs] clean up release notes - posted by GitBox <gi...@apache.org> on 2021/09/30 00:55:10 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17392: [release][docs] clean up release notes - posted by GitBox <gi...@apache.org> on 2021/09/30 01:47:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-24390) Python 'build_wheels mac' fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/30 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/30 01:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21834) org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset fail - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/30 01:55:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-21834) org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset fail - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/30 01:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-23405) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to BindException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/30 01:56:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24406) JSONKeyValueDeserializationSchema code bug - posted by "胡剑 (Jira)" <ji...@apache.org> on 2021/09/30 02:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2021/09/30 03:42:00 UTC, 3 replies.
- [jira] [Created] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2021/09/30 03:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2021/09/30 03:44:00 UTC, 0 replies.
- [GitHub] [flink] curcur commented on a change in pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value - posted by GitBox <gi...@apache.org> on 2021/09/30 04:29:34 UTC, 1 replies.
- [GitHub] [flink] curcur commented on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value - posted by GitBox <gi...@apache.org> on 2021/09/30 04:30:50 UTC, 0 replies.
- [GitHub] [flink] curcur edited a comment on pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value - posted by GitBox <gi...@apache.org> on 2021/09/30 04:31:13 UTC, 0 replies.
- [GitHub] [flink] Airblader commented on a change in pull request #17391: emphasised the changes of dependency names for the 1.14 release - posted by GitBox <gi...@apache.org> on 2021/09/30 06:11:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-20683) TaskSlotTableImplTest failed with "The slot timeout should have been deactivated." - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/30 06:16:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-20683) TaskSlotTableImplTest failed with "The slot timeout should have been deactivated." - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/30 06:16:00 UTC, 0 replies.
- [GitHub] [flink] Airblader commented on a change in pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers - posted by GitBox <gi...@apache.org> on 2021/09/30 06:26:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-20683) TaskSlotTableImplTest failed with "The slot timeout should have been deactivated." - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/30 06:28:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-20683) TaskSlotTableImplTest failed with "The slot timeout should have been deactivated." - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/30 06:28:00 UTC, 0 replies.
- [GitHub] [flink-ml] gaoyunhaii opened a new pull request #14: [FLINK-8][iteration] Add per-round operator wrappers - posted by GitBox <gi...@apache.org> on 2021/09/30 06:36:51 UTC, 0 replies.
- [jira] [Updated] (FLINK-8) [GitHub] Implement automatic sample histogram building for Range Partitioning - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/30 06:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-23405) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to BindException - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/30 06:42:00 UTC, 1 replies.
- [GitHub] [flink] zentol opened a new pull request #17393: [FLINK-23405][tests] Use free ports for Zookeeper - posted by GitBox <gi...@apache.org> on 2021/09/30 06:44:44 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17393: [FLINK-23405][tests] Use free ports for Zookeeper - posted by GitBox <gi...@apache.org> on 2021/09/30 06:49:03 UTC, 0 replies.
- [GitHub] [flink] joemoe commented on pull request #17391: emphasised the changes of dependency names for the 1.14 release - posted by GitBox <gi...@apache.org> on 2021/09/30 06:51:27 UTC, 0 replies.
- [GitHub] [flink] zentol closed pull request #17393: [FLINK-23405][tests] Use free ports for Zookeeper - posted by GitBox <gi...@apache.org> on 2021/09/30 06:51:37 UTC, 0 replies.
- [GitHub] [flink] twalthr closed pull request #17389: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers - posted by GitBox <gi...@apache.org> on 2021/09/30 07:07:24 UTC, 0 replies.
- [GitHub] [flink] twalthr commented on pull request #17389: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers - posted by GitBox <gi...@apache.org> on 2021/09/30 07:07:31 UTC, 0 replies.
- [jira] [Reopened] (FLINK-23895) Upsert materializer is not inserted for all sink providers - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 07:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-23895) Upsert materializer is not inserted for all sink providers - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 07:15:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 07:16:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 07:16:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-23895) Upsert materializer is not inserted for all sink providers - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 07:16:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-23895) Upsert materializer is not inserted for all sink providers - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21200) User defined functions refuse to accept multi-set arguments without type hints - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 07:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24385) Add TRY_CAST function to be able to handle errors - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecValues$200" grows beyond 64 KB - posted by "shengkui leng (Jira)" <ji...@apache.org> on 2021/09/30 07:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecValues$200" grows beyond 64 KB - posted by "shengkui leng (Jira)" <ji...@apache.org> on 2021/09/30 07:25:00 UTC, 2 replies.
- [GitHub] [flink] dawidwys closed pull request #17392: [release][docs] clean up release notes - posted by GitBox <gi...@apache.org> on 2021/09/30 07:33:13 UTC, 0 replies.
- [GitHub] [flink] dawidwys commented on pull request #17391: emphasised the changes of dependency names for the 1.14 release - posted by GitBox <gi...@apache.org> on 2021/09/30 07:34:15 UTC, 0 replies.
- [GitHub] [flink] twalthr opened a new pull request #17394: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer emit +U instead of only +I - posted by GitBox <gi...@apache.org> on 2021/09/30 07:34:26 UTC, 0 replies.
- [GitHub] [flink] dawidwys closed pull request #17391: emphasised the changes of dependency names for the 1.14 release - posted by GitBox <gi...@apache.org> on 2021/09/30 07:34:28 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17394: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer emit +U instead of only +I - posted by GitBox <gi...@apache.org> on 2021/09/30 07:37:35 UTC, 1 replies.
- [jira] [Created] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors - posted by "Brad Davis (Jira)" <ji...@apache.org> on 2021/09/30 07:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors - posted by "Brad Davis (Jira)" <ji...@apache.org> on 2021/09/30 07:46:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-24410) Upgrade Confluent Platform OSS version in end-to-end tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/30 07:46:00 UTC, 3 replies.
- [jira] [Created] (FLINK-24410) Upgrade Confluent Platform OSS version in end-to-end tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/30 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24411) Add docs navigation for release notes - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/09/30 07:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24410) Upgrade Confluent Platform OSS version in end-to-end tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/30 07:49:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-24411) Add docs navigation for release notes - posted by "Daisy Tsang (Jira)" <ji...@apache.org> on 2021/09/30 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24412) retract stream join on topN error - posted by "sandy du (Jira)" <ji...@apache.org> on 2021/09/30 08:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24412) retract stream join on topN error - posted by "sandy du (Jira)" <ji...@apache.org> on 2021/09/30 08:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24412) retract stream join on topN error - posted by "sandy du (Jira)" <ji...@apache.org> on 2021/09/30 08:07:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-24071) Flink 1.12 HDFS sink have a problem,reported as OOM - posted by "zhuzhengjun (Jira)" <ji...@apache.org> on 2021/09/30 08:09:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-24128) StreamingFileCommiter receive commit message but checkpoint did't ready - posted by "zhuzhengjun (Jira)" <ji...@apache.org> on 2021/09/30 08:10:00 UTC, 0 replies.
- [GitHub] [flink] MartijnVisser opened a new pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests - posted by GitBox <gi...@apache.org> on 2021/09/30 08:15:48 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests - posted by GitBox <gi...@apache.org> on 2021/09/30 08:22:57 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17394: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer emit +U instead of only +I - posted by GitBox <gi...@apache.org> on 2021/09/30 08:29:02 UTC, 0 replies.
- [GitHub] [flink] twalthr commented on a change in pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory - posted by GitBox <gi...@apache.org> on 2021/09/30 08:36:32 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/09/30 08:41:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/09/30 08:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/30 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trip the string to the specified precision - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 08:57:00 UTC, 0 replies.
- [GitHub] [flink-web] MartijnVisser opened a new pull request #471: [hotfix] Fixing incorrect ID for download tracking - posted by GitBox <gi...@apache.org> on 2021/09/30 09:00:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trip the string to the specified precision - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24414) Casting a decimal to a String doesn't do left zero padding - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:06:00 UTC, 0 replies.
- [GitHub] [flink] GOODBOY008 closed pull request #16627: [FLINK-23427][chinese-translation] Translate the page of "Blocking Sh… - posted by GitBox <gi...@apache.org> on 2021/09/30 09:06:25 UTC, 0 replies.
- [jira] [Created] (FLINK-24415) Casting a STRING to a TIME() results in loss of fractional seconds - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:09:00 UTC, 0 replies.
- [GitHub] [flink-web] dawidwys commented on pull request #471: [hotfix] Fixing incorrect ID for download tracking - posted by GitBox <gi...@apache.org> on 2021/09/30 09:12:29 UTC, 0 replies.
- [jira] [Assigned] (FLINK-23972) NoClassDefFoundError: Jars from yarn.ship-files are missing in the classpath of the client - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/30 09:13:00 UTC, 0 replies.
- [GitHub] [flink-web] MartijnVisser commented on pull request #471: [hotfix] Fixing incorrect ID for download tracking - posted by GitBox <gi...@apache.org> on 2021/09/30 09:13:33 UTC, 0 replies.
- [jira] [Created] (FLINK-24416) Casting a TIMESTAMP_LTZ to STRING doesn't include timezone id - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24417) Add Flink 1.14 MigrationVersion - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/30 09:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-24411) Add docs navigation for release notes - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/30 09:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24417) Add Flink 1.14 MigrationVersion - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/30 09:18:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-24417) Add Flink 1.14 MigrationVersion - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/30 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24418) Support cast of RAW() to BINARY/VARBINARY/BYTES - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24419) Casting to a bounded BINARY/VARBANIRY doesn't trim to the specified precision - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:30:00 UTC, 0 replies.
- [GitHub] [flink-web] tillrohrmann commented on pull request #471: [hotfix] Fixing incorrect ID for download tracking - posted by GitBox <gi...@apache.org> on 2021/09/30 09:30:56 UTC, 0 replies.
- [GitHub] [flink-web] tillrohrmann closed pull request #471: [hotfix] Fixing incorrect ID for download tracking - posted by GitBox <gi...@apache.org> on 2021/09/30 09:30:56 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests - posted by GitBox <gi...@apache.org> on 2021/09/30 09:33:03 UTC, 6 replies.
- [jira] [Created] (FLINK-24420) Casting to a "narrower" type doesn't throw exception but follows Java overflow - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24421) Casting from a string to a DATE and TIME allows incomplete strings - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:45:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-24058) TaskSlotTableImplTest.testMarkSlotActiveDeactivatesSlotTimeout fails on azure - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/30 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24422) When creating a TIMESTAMP_LTZ only allow Instant - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trim the string to the specified precision - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/30 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24423) Cast from TIME to TIMESTAMP currently uses Epoch Date - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24419) Casting to a bounded BINARY/VARBINARY doesn't trim to the specified precision - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/30 10:18:00 UTC, 0 replies.
- [GitHub] [flink] zentol merged pull request #14544: [FLINK-20845] Drop Scala 2.11 support - posted by GitBox <gi...@apache.org> on 2021/09/30 10:19:47 UTC, 0 replies.
- [jira] [Created] (FLINK-24424) CAST from invalid CHAR/VARCHAR/STRING to TIMESTAMP_LTZ throws NPE - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:21:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-20845) Drop support for Scala 2.11 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/30 10:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-23996) Make Scala 2.12 default build target - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/30 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24425) Add support for casting from a single type to the corresponding array - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:31:00 UTC, 0 replies.
- [GitHub] [flink] zentol commented on a change in pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests - posted by GitBox <gi...@apache.org> on 2021/09/30 10:32:40 UTC, 0 replies.
- [jira] [Created] (FLINK-24426) Add support for cast from a string to an INTERVAL - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-23358) Refactor CoreOptions parent-first patterns to List options - posted by "Horace Lee (Jira)" <ji...@apache.org> on 2021/09/30 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24427) Hide Scala in flink-table-planner from API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24428) Fix casting between interval types - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 11:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24426) Add support for cast from a string to an INTERVAL - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 11:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24428) Fix casting between interval types - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 11:27:00 UTC, 0 replies.
- [GitHub] [flink] twalthr closed pull request #17394: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer emit +U instead of only +I - posted by GitBox <gi...@apache.org> on 2021/09/30 11:50:27 UTC, 0 replies.
- [GitHub] [flink] twalthr commented on pull request #17394: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer emit +U instead of only +I - posted by GitBox <gi...@apache.org> on 2021/09/30 11:50:29 UTC, 0 replies.
- [jira] [Reopened] (FLINK-24130) RowDataSerializerTest fails on Azure - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 11:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 11:52:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 11:52:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-24247) Uniformly limit the value of ABS(offset) in all window - posted by "liwei li (Jira)" <ji...@apache.org> on 2021/09/30 11:52:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-24247) Uniformly limit the value of ABS(offset) in all window - posted by "liwei li (Jira)" <ji...@apache.org> on 2021/09/30 11:59:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24429) Port FileSystemTableSink to new Unified Sink API (FLIP-143) - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/09/30 12:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24387) Support a JSON_STRING - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/30 12:27:00 UTC, 0 replies.
- [GitHub] [flink] matriv opened a new pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations - posted by GitBox <gi...@apache.org> on 2021/09/30 12:29:21 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations - posted by GitBox <gi...@apache.org> on 2021/09/30 12:34:10 UTC, 1 replies.
- [GitHub] [flink] slinkydeveloper commented on a change in pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations - posted by GitBox <gi...@apache.org> on 2021/09/30 13:28:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-23974) Lower throughput for buffer debloat in case of different load profile - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/30 13:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-23974) Decreased throughput with enabled buffer debloat - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/30 13:33:00 UTC, 0 replies.
- [GitHub] [flink-web] infoverload commented on pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post - posted by GitBox <gi...@apache.org> on 2021/09/30 13:45:45 UTC, 0 replies.
- [GitHub] [flink-web] infoverload edited a comment on pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post - posted by GitBox <gi...@apache.org> on 2021/09/30 13:46:25 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations - posted by GitBox <gi...@apache.org> on 2021/09/30 13:47:24 UTC, 4 replies.
- [GitHub] [flink-web] infoverload commented on a change in pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post - posted by GitBox <gi...@apache.org> on 2021/09/30 13:51:04 UTC, 0 replies.
- [GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support - posted by GitBox <gi...@apache.org> on 2021/09/30 13:54:45 UTC, 0 replies.
- [GitHub] [flink] sjwiesman commented on pull request #17380: [hotfix][docs] Fix typo in sources doc - posted by GitBox <gi...@apache.org> on 2021/09/30 14:04:06 UTC, 0 replies.
- [GitHub] [flink] sjwiesman closed pull request #17380: [hotfix][docs] Fix typo in sources doc - posted by GitBox <gi...@apache.org> on 2021/09/30 14:05:26 UTC, 0 replies.
- [GitHub] [flink] matriv commented on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations - posted by GitBox <gi...@apache.org> on 2021/09/30 14:19:21 UTC, 1 replies.
- [jira] [Created] (FLINK-24430) Clean up log pollution - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/30 14:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-23668) Check Log Pollution for 1.14 release - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/30 14:22:00 UTC, 0 replies.
- [GitHub] [flink] twalthr commented on pull request #17141: Revert "[FLINK-22770][docs] Update usage of SET in docs to use quotes" - posted by GitBox <gi...@apache.org> on 2021/09/30 14:25:55 UTC, 0 replies.
- [GitHub] [flink] twalthr closed pull request #17141: Revert "[FLINK-22770][docs] Update usage of SET in docs to use quotes" - posted by GitBox <gi...@apache.org> on 2021/09/30 14:26:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/30 14:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/30 14:27:00 UTC, 0 replies.
- [GitHub] [flink] AHeise closed pull request #14277: [FLINK-20443][API/DataStream]fix lost data in last interval in per window - posted by GitBox <gi...@apache.org> on 2021/09/30 14:29:00 UTC, 0 replies.
- [GitHub] [flink] AHeise commented on pull request #14277: [FLINK-20443][API/DataStream]fix lost data in last interval in per window - posted by GitBox <gi...@apache.org> on 2021/09/30 14:29:02 UTC, 0 replies.
- [GitHub] [flink] AHeise commented on a change in pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window - posted by GitBox <gi...@apache.org> on 2021/09/30 14:44:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/30 14:53:00 UTC, 4 replies.
- [GitHub] [flink] twalthr closed pull request #16012: [FLINK-21142][connector-hive] Hide Guava from Hadoop and security tools - posted by GitBox <gi...@apache.org> on 2021/09/30 14:54:42 UTC, 0 replies.
- [jira] [Assigned] (FLINK-21142) Flink guava Dependence problem - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 14:55:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-21142) Flink guava Dependence problem - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 14:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-21142) Flink guava Dependence problem - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 14:56:00 UTC, 1 replies.
- [GitHub] [flink] tillrohrmann opened a new pull request #17397: [BP-1.14][FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver - posted by GitBox <gi...@apache.org> on 2021/09/30 15:01:20 UTC, 0 replies.
- [GitHub] [flink] akalash commented on a change in pull request #17354: [FLINK-24200][streaming] Calculating maximum alignment time rather than using the constant value - posted by GitBox <gi...@apache.org> on 2021/09/30 15:03:09 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17397: [BP-1.14][FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver - posted by GitBox <gi...@apache.org> on 2021/09/30 15:04:20 UTC, 1 replies.
- [GitHub] [flink] twalthr commented on a change in pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate - posted by GitBox <gi...@apache.org> on 2021/09/30 15:10:57 UTC, 0 replies.
- [GitHub] [flink] twalthr commented on pull request #10838: [hotfix][table-common] Simplify formatted exceptions - posted by GitBox <gi...@apache.org> on 2021/09/30 15:13:34 UTC, 0 replies.
- [GitHub] [flink] twalthr closed pull request #10838: [hotfix][table-common] Simplify formatted exceptions - posted by GitBox <gi...@apache.org> on 2021/09/30 15:13:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-24387) Support a JSON_STRING - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 15:19:00 UTC, 0 replies.
- [GitHub] [flink] slinkydeveloper commented on a change in pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate - posted by GitBox <gi...@apache.org> on 2021/09/30 15:22:50 UTC, 0 replies.
- [GitHub] [flink] rmetzger commented on pull request #16166: [FLINK-23000] Add log bundler to collect and compress logs - posted by GitBox <gi...@apache.org> on 2021/09/30 15:24:19 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/30 15:26:00 UTC, 0 replies.
- [GitHub] [flink] tillrohrmann opened a new pull request #17398: [FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest - posted by GitBox <gi...@apache.org> on 2021/09/30 15:28:58 UTC, 0 replies.
- [GitHub] [flink] tillrohrmann opened a new pull request #17399: [BP-1.14][FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest - posted by GitBox <gi...@apache.org> on 2021/09/30 15:29:55 UTC, 0 replies.
- [GitHub] [flink] tillrohrmann commented on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover - posted by GitBox <gi...@apache.org> on 2021/09/30 15:32:03 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17398: [FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest - posted by GitBox <gi...@apache.org> on 2021/09/30 15:33:06 UTC, 1 replies.
- [GitHub] [flink] flinkbot commented on pull request #17399: [BP-1.14][FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest - posted by GitBox <gi...@apache.org> on 2021/09/30 15:33:08 UTC, 1 replies.
- [GitHub] [flink] tillrohrmann commented on a change in pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog - posted by GitBox <gi...@apache.org> on 2021/09/30 15:44:29 UTC, 0 replies.
- [GitHub] [flink] tillrohrmann commented on pull request #17137: [FLINK-21853][e2e] Harden common_ha.sh#ha_tm_watchdog - posted by GitBox <gi...@apache.org> on 2021/09/30 15:46:44 UTC, 0 replies.
- [jira] [Created] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/09/30 15:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/09/30 15:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/09/30 16:08:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17397: [BP-1.14][FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver - posted by GitBox <gi...@apache.org> on 2021/09/30 16:21:01 UTC, 1 replies.
- [jira] [Resolved] (FLINK-23519) Aggregate State Backend Latency by State Level - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/09/30 16:37:00 UTC, 0 replies.
- [GitHub] [flink-ml] zhipeng93 opened a new pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables - posted by GitBox <gi...@apache.org> on 2021/09/30 16:37:09 UTC, 0 replies.
- [jira] [Resolved] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/09/30 16:40:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17398: [FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest - posted by GitBox <gi...@apache.org> on 2021/09/30 16:48:18 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17399: [BP-1.14][FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest - posted by GitBox <gi...@apache.org> on 2021/09/30 16:48:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-13414) Add support for Scala 2.13 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/30 17:56:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-24427) Hide Scala in flink-table-planner from API - posted by "Erwan Loisant (Jira)" <ji...@apache.org> on 2021/09/30 19:01:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-24427) Hide Scala in flink-table-planner from API - posted by "Erwan Loisant (Jira)" <ji...@apache.org> on 2021/09/30 19:09:00 UTC, 1 replies.
- [jira] [Created] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method - posted by "Victor Xu (Jira)" <ji...@apache.org> on 2021/09/30 21:10:00 UTC, 0 replies.
- [GitHub] [flink] victorunique opened a new pull request #17400: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo - posted by GitBox <gi...@apache.org> on 2021/09/30 21:27:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/09/30 21:28:00 UTC, 0 replies.
- [GitHub] [flink] flinkbot commented on pull request #17400: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo - posted by GitBox <gi...@apache.org> on 2021/09/30 21:31:47 UTC, 1 replies.
- [GitHub] [flink] flinkbot edited a comment on pull request #17400: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo - posted by GitBox <gi...@apache.org> on 2021/09/30 22:30:18 UTC, 0 replies.