[GitHub] [flink] flinkbot edited a comment on pull request #15730: [FLINK-22378][table] Fix timestamp handling in toDataStream

flinkbot edited a comment on pull request #15730: URL: https://github.com/apache/flink/pull/15730#issuecomment-825505437 ## CI report: * a97273467cc0217f438c3254c9625e470b0e64f1 UNKNOWN * d3978edc39bcdc776155f4539a99a169ed2d8b4e Azure:

[GitHub] [flink] beyond1920 commented on a change in pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

beyond1920 commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r620293959 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/window/WindowJoinOperator.java ## @@

[GitHub] [flink] beyond1920 commented on pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a common

beyond1920 commented on pull request #15752: URL: https://github.com/apache/flink/pull/15752#issuecomment-826830415 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] dawidwys commented on a change in pull request #15687: [FLINK-22373][docs] Add Flink 1.13 release notes

dawidwys commented on a change in pull request #15687: URL: https://github.com/apache/flink/pull/15687#discussion_r620283506 ## File path: docs/content.zh/release-notes/flink-1.13.md ## @@ -0,0 +1,227 @@ +--- +title: "Release Notes - Flink 1.13" +--- + + +# Release Notes -

[GitHub] [flink] beyond1920 commented on a change in pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

beyond1920 commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r620279497 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/window/WindowJoinOperator.java ## @@

[GitHub] [flink] flinkbot commented on pull request #15769: [FLINK-18952][python][docs] Add "10 minutes to DataStream API" documentation

flinkbot commented on pull request #15769: URL: https://github.com/apache/flink/pull/15769#issuecomment-826820127 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] dianfu opened a new pull request #15769: [FLINK-18952][python][docs] Add "10 minutes to DataStream API" documentation

dianfu opened a new pull request #15769: URL: https://github.com/apache/flink/pull/15769 ## What is the purpose of the change * This pull request add a "10 minutes to DataStream API" documentation for Python DataStream API* ## Verifying this change This change is a

[jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-22479: -- Description: *Background* This connector has been

[jira] [Created] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

Danny Cranmer created FLINK-22479: - Summary: [Kinesis][Consumer] Potential lock-up under error condition Key: FLINK-22479 URL: https://issues.apache.org/jira/browse/FLINK-22479 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15762: [FLINK-22469][runtime-web] Fix NoSuchFileException in HistoryServer

flinkbot edited a comment on pull request #15762: URL: https://github.com/apache/flink/pull/15762#issuecomment-826557889 ## CI report: * 98e782acc1647287f0504d29abbaf4f638772073 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * 91418c6481fcd8dca9d343cda91f0cf5010dfbf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15765: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all

flinkbot edited a comment on pull request #15765: URL: https://github.com/apache/flink/pull/15765#issuecomment-826604275 ## CI report: * fdf685340b39330a9d37060e97a08fbad0a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

flinkbot edited a comment on pull request #15767: URL: https://github.com/apache/flink/pull/15767#issuecomment-826633392 ## CI report: * 0d6fd33ea7384941d5a680e024cd79293f36579f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

flinkbot edited a comment on pull request #15755: URL: https://github.com/apache/flink/pull/15755#issuecomment-826346863 ## CI report: * d0435daa046d4a28c0b8c34161a9cc4a2ae91590 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15730: [FLINK-22378][table] Fix timestamp handling in toDataStream

flinkbot edited a comment on pull request #15730: URL: https://github.com/apache/flink/pull/15730#issuecomment-825505437 ## CI report: * a97273467cc0217f438c3254c9625e470b0e64f1 UNKNOWN * d3978edc39bcdc776155f4539a99a169ed2d8b4e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * 91418c6481fcd8dca9d343cda91f0cf5010dfbf7 Azure:

[jira] [Commented] (FLINK-22438) add numRecordsOut metric for Async IO

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332080#comment-17332080 ] Zhengqi Zhang commented on FLINK-22438: --- [~knaufk] In Flink 1.9,there is no problem with AsyncIO's 

[jira] [Updated] (FLINK-22478) confluent schema registry avro (de)serialization https support

[ https://issues.apache.org/jira/browse/FLINK-22478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lars Bachmann updated FLINK-22478: -- Description: Currently the _ConfluentRegistryAvroSerializationSchema_ and 

[jira] [Created] (FLINK-22478) confluent schema registry avro (de)serialization https support

Lars Bachmann created FLINK-22478: - Summary: confluent schema registry avro (de)serialization https support Key: FLINK-22478 URL: https://issues.apache.org/jira/browse/FLINK-22478 Project: Flink

[GitHub] [flink] akalash commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

akalash commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r620235679 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculatorTest.java ## @@ -149,23 +151,114 @@ public

[jira] [Commented] (FLINK-22477) Remove DefaultSlotPoolServiceFactory and SlotPoolImpl

[ https://issues.apache.org/jira/browse/FLINK-22477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332065#comment-17332065 ] lqjacklee commented on FLINK-22477: --- [~trohrmann] can I take the task ? > Remove

[GitHub] [flink] flinkbot edited a comment on pull request #15766: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all

flinkbot edited a comment on pull request #15766: URL: https://github.com/apache/flink/pull/15766#issuecomment-826604395 ## CI report: * 9fd31b0419d6695a1ed597429057a960c5420fef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15764: [FLINK-22471][flink-table][flink-connectors] Improvements to ConfigOption descriptions

flinkbot edited a comment on pull request #15764: URL: https://github.com/apache/flink/pull/15764#issuecomment-826589841 ## CI report: * f0ec66c153d735ef2766164aef8dac76444ef870 UNKNOWN * 99b5a1bdb1cb456489f9c85fbb0b0cd5953877b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15765: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all

flinkbot edited a comment on pull request #15765: URL: https://github.com/apache/flink/pull/15765#issuecomment-826604275 ## CI report: * fdf685340b39330a9d37060e97a08fbad0a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

flinkbot edited a comment on pull request #15755: URL: https://github.com/apache/flink/pull/15755#issuecomment-826346863 ## CI report: * 5c23fda1dfccdcfbd92281545a416bf5af348df2 Azure:

[jira] [Created] (FLINK-22477) Remove DefaultSlotPoolServiceFactory and SlotPoolImpl

Till Rohrmann created FLINK-22477: - Summary: Remove DefaultSlotPoolServiceFactory and SlotPoolImpl Key: FLINK-22477 URL: https://issues.apache.org/jira/browse/FLINK-22477 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15766: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all

flinkbot edited a comment on pull request #15766: URL: https://github.com/apache/flink/pull/15766#issuecomment-826604395 ## CI report: * 9fd31b0419d6695a1ed597429057a960c5420fef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15765: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all

flinkbot edited a comment on pull request #15765: URL: https://github.com/apache/flink/pull/15765#issuecomment-826604275 ## CI report: * fdf685340b39330a9d37060e97a08fbad0a5 Azure:

[jira] [Updated] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries

[ https://issues.apache.org/jira/browse/FLINK-19034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19034: - Fix Version/s: (was: 1.13.0) 1.14.0 > Remove deprecated

[jira] [Updated] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18887: - Fix Version/s: (was: 1.13.0) 1.14.0 > Add ElasticSearch

[jira] [Updated] (FLINK-18952) Add 10 minutes to DataStream API documentation

[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18952: - Fix Version/s: (was: 1.13.0) 1.14.0 > Add 10 minutes to

[jira] [Updated] (FLINK-18954) Add documentation for connectors in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-18954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18954: - Fix Version/s: (was: 1.13.0) 1.14.0 > Add documentation for

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * 8ced1a680e6dd45f09e39fc452fa4c2338aaa4c2 Azure:

[jira] [Updated] (FLINK-15718) Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15718: - Fix Version/s: (was: 1.13.0) > Update StatefulJobSavepointMigrationITCase to

[jira] [Updated] (FLINK-15716) Update WindowOperatorMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15716: - Fix Version/s: (was: 1.13.0) > Update WindowOperatorMigrationTest to restore from

[jira] [Updated] (FLINK-19683) Actively timeout aligned checkpoints on the output

[ https://issues.apache.org/jira/browse/FLINK-19683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19683: - Fix Version/s: (was: 1.13.0) 1.14.0 > Actively timeout aligned

[jira] [Updated] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18229: - Fix Version/s: (was: 1.13.0) 1.14.0 > Pending worker requests

[jira] [Updated] (FLINK-17741) Create integration or e2e test for out of order (savepoint) barriers

[ https://issues.apache.org/jira/browse/FLINK-17741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17741: - Fix Version/s: (was: 1.13.0) 1.14.0 > Create integration or e2e

[jira] [Updated] (FLINK-17372) SlotManager should expose total required resources

[ https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17372: - Fix Version/s: (was: 1.13.0) 1.14.0 > SlotManager should expose

[jira] [Updated] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17295: - Fix Version/s: (was: 1.13.0) 1.14.0 > Refactor the

[jira] [Updated] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17196: - Fix Version/s: (was: 1.13.0) 1.14.0 > Improve the implementation

[jira] [Updated] (FLINK-17232) Rethink the implicit behavior to use the Service externalIP as the address of the Endpoint

[ https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17232: - Fix Version/s: (was: 1.13.0) 1.14.0 > Rethink the implicit

[jira] [Updated] (FLINK-17078) Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id

[ https://issues.apache.org/jira/browse/FLINK-17078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17078: - Fix Version/s: (was: 1.13.0) 1.14.0 > Logging output is

[jira] [Updated] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17231: - Fix Version/s: (was: 1.13.0) 1.14.0 > Deprecate possible

[jira] [Updated] (FLINK-16952) Parquet file system format support filter pushdown

[ https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16952: - Fix Version/s: (was: 1.13.0) 1.14.0 > Parquet file system

[jira] [Updated] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16715: - Fix Version/s: (was: 1.13.0) 1.14.0 > Always use the

[jira] [Updated] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16601: - Fix Version/s: (was: 1.13.0) 1.14.0 > Correct the way to get

[jira] [Updated] (FLINK-15709) Update CEPMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15709: - Fix Version/s: (was: 1.13.0) > Update CEPMigrationTest to restore from 1.10

[jira] [Updated] (FLINK-16388) Bump orc-core to 1.4.5

[ https://issues.apache.org/jira/browse/FLINK-16388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16388: - Fix Version/s: (was: 1.13.0) 1.14.0 > Bump orc-core to 1.4.5 >

[jira] [Updated] (FLINK-16154) Translate "Operator/Join" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16154: - Fix Version/s: (was: 1.13.0) 1.14.0 > Translate "Operator/Join"

[jira] [Updated] (FLINK-16155) Translate "Operator/Process Function" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16155: - Fix Version/s: (was: 1.13.0) 1.14.0 > Translate

[jira] [Updated] (FLINK-16153) Translate "Operator/windows" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16153: - Fix Version/s: (was: 1.13.0) 1.14.0 > Translate

[jira] [Updated] (FLINK-16078) Translate "Tuning Checkpoints and Large State" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16078: - Fix Version/s: (was: 1.13.0) 1.14.0 > Translate "Tuning

[jira] [Updated] (FLINK-15857) Support --help for the kubernetes-session script

[ https://issues.apache.org/jira/browse/FLINK-15857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15857: - Fix Version/s: (was: 1.13.0) 1.14.0 > Support --help for the

[jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16077: - Fix Version/s: (was: 1.13.0) 1.14.0 > Translate "Custom State

[jira] [Updated] (FLINK-16152) Translate "Operator/index" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16152: - Fix Version/s: (was: 1.13.0) 1.14.0 > Translate "Operator/index"

[jira] [Updated] (FLINK-15721) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15721: - Fix Version/s: (was: 1.13.0) > Update StatefulJobWBroadcastStateMigrationITCase to

[jira] [Updated] (FLINK-15722) Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15722: - Fix Version/s: (was: 1.13.0) > Update TypeSerializerSnapshotMigrationITCase to

[jira] [Updated] (FLINK-15717) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15717: - Fix Version/s: (was: 1.13.0) > Update StatefulJobSavepointMigrationITCase.scala to

[jira] [Updated] (FLINK-15720) Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15720: - Fix Version/s: (was: 1.13.0) > Update

[jira] [Updated] (FLINK-15723) Update AbstractKeyedOperatorRestoreTestBase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15723: - Fix Version/s: (was: 1.13.0) > Update AbstractKeyedOperatorRestoreTestBase to

[jira] [Updated] (FLINK-15714) Update FlinkKafkaProducerMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15714: - Fix Version/s: (was: 1.13.0) > Update FlinkKafkaProducerMigrationTest to restore

[jira] [Updated] (FLINK-15715) Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15715: - Fix Version/s: (was: 1.13.0) > Update ContinuousFileProcessingMigrationTest to

[jira] [Updated] (FLINK-15725) Update FlinkKinesisConsumerMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15725: - Fix Version/s: (was: 1.13.0) > Update FlinkKinesisConsumerMigrationTest to restore

[jira] [Updated] (FLINK-15713) Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15713: - Fix Version/s: (was: 1.13.0) > Update FlinkKafkaProducerMigrationOperatorTest to

[jira] [Updated] (FLINK-15724) Update AbstractNonKeyedOperatorRestoreTestBase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15724: - Fix Version/s: (was: 1.13.0) > Update AbstractNonKeyedOperatorRestoreTestBase to

[jira] [Updated] (FLINK-15712) Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15712: - Fix Version/s: (was: 1.13.0) > Update FlinkKafkaConsumerBaseMigrationTest to

[jira] [Updated] (FLINK-15711) Update FlinkKafkaProducer011MigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15711: - Fix Version/s: (was: 1.13.0) > Update FlinkKafkaProducer011MigrationTest to restore

[jira] [Updated] (FLINK-15710) Update BucketingSinkMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15710: - Fix Version/s: (was: 1.13.0) > Update BucketingSinkMigrationTest to restore from

[jira] [Updated] (FLINK-13698) Rework threading model of CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-13698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13698: - Fix Version/s: (was: 1.13.0) 1.14.0 > Rework threading model of

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14971: - Fix Version/s: (was: 1.13.0) 1.14.0 > Make all the non-IO

[jira] [Updated] (FLINK-14920) Set up environment to run performance e2e tests

[ https://issues.apache.org/jira/browse/FLINK-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14920: - Fix Version/s: (was: 1.13.0) 1.14.0 > Set up environment to run

[jira] [Updated] (FLINK-14918) Add performance e2e test module and scripts

[ https://issues.apache.org/jira/browse/FLINK-14918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14918: - Fix Version/s: (was: 1.13.0) 1.14.0 > Add performance e2e test

[jira] [Updated] (FLINK-14820) Replace Time with Duration in FutureUtils

[ https://issues.apache.org/jira/browse/FLINK-14820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14820: - Fix Version/s: (was: 1.13.0) 1.14.0 > Replace Time with Duration

[jira] [Commented] (FLINK-22424) Writing to already released buffers potentially causing data corruption during job failover/cancellation

[ https://issues.apache.org/jira/browse/FLINK-22424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332007#comment-17332007 ] Piotr Nowojski commented on FLINK-22424: merged commit 19ca330 into apache:master > Writing to

[GitHub] [flink] pnowojski merged pull request #15734: [FLINK-22424][network] Prevent releasing PipelinedSubpartition while Task can still write to it

pnowojski merged pull request #15734: URL: https://github.com/apache/flink/pull/15734 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Updated] (FLINK-14471) Hide error message when metric api failed

[ https://issues.apache.org/jira/browse/FLINK-14471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14471: - Fix Version/s: (was: 1.13.0) 1.14.0 > Hide error message when

[jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14500: - Fix Version/s: (was: 1.13.0) 1.14.0 > Support Flink Python

[jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types

[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14383: - Fix Version/s: (was: 1.13.0) 1.14.0 > Support python UDFs with

[jira] [Updated] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values

[ https://issues.apache.org/jira/browse/FLINK-14222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14222: - Fix Version/s: (was: 1.13.0) 1.14.0 > Optimize for Python UDFs

[GitHub] [flink] todd5167 commented on pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

todd5167 commented on pull request #15755: URL: https://github.com/apache/flink/pull/15755#issuecomment-826736969 @wuchong done -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] flinkbot commented on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

flinkbot commented on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * 8ced1a680e6dd45f09e39fc452fa4c2338aaa4c2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

flinkbot edited a comment on pull request #15755: URL: https://github.com/apache/flink/pull/15755#issuecomment-826346863 ## CI report: * 09d4859c37fae4da954767c510bf4d03f6188c62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * 6b90c8249d142eb54d4b1bdf03be98db84074a6b Azure:

[jira] [Updated] (FLINK-14028) Support to configure the log level of the Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14028: - Fix Version/s: (was: 1.13.0) 1.14.0 > Support to configure the

[jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14122: - Fix Version/s: (was: 1.13.0) 1.14.0 > Extend State Processor API

[jira] [Updated] (FLINK-14023) Support accessing job parameters in Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14023: - Fix Version/s: (was: 1.13.0) 1.14.0 > Support accessing job

[jira] [Updated] (FLINK-11492) Support the full Blink SQL runtime

[ https://issues.apache.org/jira/browse/FLINK-11492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-11492: - Fix Version/s: (was: 1.13.0) > Support the full Blink SQL runtime >

[GitHub] [flink] ex34toway commented on a change in pull request #15742: [FLINK-22442][CEP] Fix Using scala api to change the TimeCharacteristic o…

ex34toway commented on a change in pull request #15742: URL: https://github.com/apache/flink/pull/15742#discussion_r620184703 ## File path: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala ## @@ -447,17 +447,17 @@ class

[jira] [Updated] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew.D.lin updated FLINK-13856: - Fix Version/s: 1.13.1 > Reduce the delete file api when the checkpoint is completed >

[GitHub] [flink] chendonglin521 closed pull request #15667: Reduce the delete file api when the checkpoint is completed. [FLINK-…

chendonglin521 closed pull request #15667: URL: https://github.com/apache/flink/pull/15667 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this

[jira] [Updated] (FLINK-21953) Add documentation on batch mode support of Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-21953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21953: --- Labels: auto-unassigned (was: stale-assigned) > Add documentation on batch mode support of

[jira] [Commented] (FLINK-21953) Add documentation on batch mode support of Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-21953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331999#comment-17331999 ] Flink Jira Bot commented on FLINK-21953: This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331997#comment-17331997 ] michaelli commented on FLINK-18199: --- Thanks for the detailed instruction and help, [~lzljs3620320] I

[GitHub] [flink] dawidwys commented on a change in pull request #15734: [FLINK-22424][network] Prevent releasing PipelinedSubpartition while Task can still write to it

dawidwys commented on a change in pull request #15734: URL: https://github.com/apache/flink/pull/15734#discussion_r620175240 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/UnpooledBufferPool.java ## @@ -0,0 +1,113 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #15762: [FLINK-22469][runtime-web] Fix NoSuchFileException in HistoryServer

flinkbot edited a comment on pull request #15762: URL: https://github.com/apache/flink/pull/15762#issuecomment-826557889 ## CI report: * c9f47fa8e680fd94de36e1c2451b41bf46aaf531 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

flinkbot edited a comment on pull request #15755: URL: https://github.com/apache/flink/pull/15755#issuecomment-826346863 ## CI report: * 09d4859c37fae4da954767c510bf4d03f6188c62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * 6b90c8249d142eb54d4b1bdf03be98db84074a6b Azure:

[GitHub] [flink-web] dawidwys commented on a change in pull request #436: Add Apache Flink release 1.13.0

dawidwys commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r620172874 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[GitHub] [flink] pnowojski commented on a change in pull request #15734: [FLINK-22424][network] Prevent releasing PipelinedSubpartition while Task can still write to it

pnowojski commented on a change in pull request #15734: URL: https://github.com/apache/flink/pull/15734#discussion_r620169288 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/UnpooledBufferPool.java ## @@ -0,0 +1,113 @@ +/* + * Licensed to

<    1   2   3   4   5   6   >