[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 7b2d7fd81dec029364a88670c0edd1207b756295 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * d372e5c7f645a95e62af48328c59589debf461d9 Azure:

[jira] [Updated] (FLINK-24776) Clarify semantics of DecodingFormat and its data type

[ https://issues.apache.org/jira/browse/FLINK-24776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24776: - Summary: Clarify semantics of DecodingFormat and its data type (was: Clarify DecodingFormat)

[jira] [Created] (FLINK-24776) Clarify DecodingFormat

Francesco Guardiani created FLINK-24776: --- Summary: Clarify DecodingFormat Key: FLINK-24776 URL: https://issues.apache.org/jira/browse/FLINK-24776 Project: Flink Issue Type: Bug

[GitHub] [flink] twalthr commented on a change in pull request #17662: [FLINK-24747][table-planner] Add producedDataType to SupportsProjectionPushDown.applyProjection

twalthr commented on a change in pull request #17662: URL: https://github.com/apache/flink/pull/17662#discussion_r742953576 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsProjectionPushDown.java ## @@ -49,6

[GitHub] [flink] flinkbot edited a comment on pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

flinkbot edited a comment on pull request #17671: URL: https://github.com/apache/flink/pull/17671#issuecomment-960546813 ## CI report: * 742f38c0c5e6662a4dea03b7dbd19d6f5104ac0f Azure:

[GitHub] [flink] XComp commented on a change in pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

XComp commented on a change in pull request #17593: URL: https://github.com/apache/flink/pull/17593#discussion_r742769282 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-scala/src/test/java/org/apache/flink/tests/scala/ScalaFreeITCase.java ## @@ -0,0 +1,130 @@ +/*

[GitHub] [flink] XComp commented on a change in pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

XComp commented on a change in pull request #17593: URL: https://github.com/apache/flink/pull/17593#discussion_r742968681 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-scala/src/main/scala/org/apache/flink/tests/scala/ScalaJob.scala ## @@ -0,0 +1,47 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist

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

[GitHub] [flink] nicoweidner commented on a change in pull request #17679: [FLINK-24770] Remove error from JobStatusListener

nicoweidner commented on a change in pull request #17679: URL: https://github.com/apache/flink/pull/17679#discussion_r742959695 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -1042,8 +1041,7 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist

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

[GitHub] [flink] JingGe commented on a change in pull request #17656: [FLINK-24741]Deprecate FileRecordFormat

JingGe commented on a change in pull request #17656: URL: https://github.com/apache/flink/pull/17656#discussion_r742955664 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/FileRecordFormat.java ## @@ -34,7 +34,14 @@

[GitHub] [flink] JingGe commented on a change in pull request #17656: [FLINK-24741]Deprecate FileRecordFormat

JingGe commented on a change in pull request #17656: URL: https://github.com/apache/flink/pull/17656#discussion_r742955664 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/FileRecordFormat.java ## @@ -34,7 +34,14 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17634: [FLINK-24691][table-common] Fix precision for sum on decimal types

flinkbot edited a comment on pull request #17634: URL: https://github.com/apache/flink/pull/17634#issuecomment-956440201 ## CI report: * 1b97204479d696f014537e96cc7260a77deed678 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17679: [FLINK-24770] Remove error from JobStatusListener

flinkbot edited a comment on pull request #17679: URL: https://github.com/apache/flink/pull/17679#issuecomment-960792789 ## CI report: * ce395f978116c656c0276cca8a08e86eb196dcb0 Azure:

[GitHub] [flink] twalthr closed pull request #17642: [hotfix][table-common] Add `DataType#excludeFields`

twalthr closed pull request #17642: URL: https://github.com/apache/flink/pull/17642 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] zentol commented on a change in pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

zentol commented on a change in pull request #17671: URL: https://github.com/apache/flink/pull/17671#discussion_r742949002 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java ## @@ -141,6 +158,93 @@ public

[GitHub] [flink] zentol commented on a change in pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

zentol commented on a change in pull request #17671: URL: https://github.com/apache/flink/pull/17671#discussion_r742948330 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java ## @@ -141,6 +158,93 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

flinkbot edited a comment on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-961148655 ## CI report: * 079d07698cfd206db55ad55596e7aab73ba44ef9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9

flinkbot edited a comment on pull request #17574: URL: https://github.com/apache/flink/pull/17574#issuecomment-952625580 ## CI report: * Unknown: [CANCELED](TBD) * d66e0a7a35d44f839942dafe28aa7df2cfd3d932 Azure:

[GitHub] [flink] flinkbot commented on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

flinkbot commented on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-961148655 ## CI report: * 079d07698cfd206db55ad55596e7aab73ba44ef9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

flinkbot commented on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-961147791 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

[jira] [Commented] (FLINK-24631) Avoiding directly use the labels as selector for deployment and service

[ https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438783#comment-17438783 ] Aitozi commented on FLINK-24631: I have open the PR for this, please help review when you are free :).

[jira] [Updated] (FLINK-24631) Avoiding directly use the labels as selector for deployment and service

[ https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24631: --- Labels: pull-request-available (was: ) > Avoiding directly use the labels as selector for

[GitHub] [flink] Aitozi opened a new pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

Aitozi opened a new pull request #17685: URL: https://github.com/apache/flink/pull/17685 ## What is the purpose of the change The PR is meant to use the minimal selector to select jobManager and taskManger pod. ## Verifying this change This change is already

[GitHub] [flink] nicoweidner commented on a change in pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

nicoweidner commented on a change in pull request #17671: URL: https://github.com/apache/flink/pull/17671#discussion_r742929075 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerClusterITCase.java ## @@ -141,6 +158,93 @@

[GitHub] [flink] JingGe commented on a change in pull request #17656: [FLINK-24741]Deprecate FileRecordFormat

JingGe commented on a change in pull request #17656: URL: https://github.com/apache/flink/pull/17656#discussion_r742935334 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/impl/FileRecordFormatAdapter.java ## @@ -37,7

[GitHub] [flink] MartijnVisser commented on pull request #17635: [FLINK-24724][buildsystem] Update Sun XML Bind dependencies to v3.0.2

MartijnVisser commented on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-961121494 @zentol What do you think? -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17677: [FLINK-24766][table] Ceiling/flooring dates to day returns wrong results

flinkbot edited a comment on pull request #17677: URL: https://github.com/apache/flink/pull/17677#issuecomment-960677604 ## CI report: * 94ad5ca8987d7eabc59104ea7c9f2d31dd6a5a42 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

twalthr commented on a change in pull request #17658: URL: https://github.com/apache/flink/pull/17658#discussion_r742622302 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CastRuleProvider.java ## @@ -44,10 +54,25

[GitHub] [flink] flinkbot edited a comment on pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 ## CI report: * 62f39de70a7c661eb2fe8062373d7c9a2eb46bcc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

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

[GitHub] [flink] flinkbot edited a comment on pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

flinkbot edited a comment on pull request #17645: URL: https://github.com/apache/flink/pull/17645#issuecomment-957822962 ## CI report: * 2525e7c4029e53a2dbb46cc55bdcdfdce60b69f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

flinkbot edited a comment on pull request #17645: URL: https://github.com/apache/flink/pull/17645#issuecomment-957822962 ## CI report: * 2525e7c4029e53a2dbb46cc55bdcdfdce60b69f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

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

[jira] [Created] (FLINK-24775) Move JobStatus-related metrics out of ExecutionGraph

Chesnay Schepler created FLINK-24775: Summary: Move JobStatus-related metrics out of ExecutionGraph Key: FLINK-24775 URL: https://issues.apache.org/jira/browse/FLINK-24775 Project: Flink

[jira] [Updated] (FLINK-24656) Add user document for Window Deduplication

[ https://issues.apache.org/jira/browse/FLINK-24656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24656: --- Fix Version/s: 1.15.0 > Add user document for Window Deduplication >

[jira] [Updated] (FLINK-24770) Remove error cause from JobStatusListener interface

[ https://issues.apache.org/jira/browse/FLINK-24770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24770: - Parent: FLINK-21510 Issue Type: Sub-task (was: Technical Debt) > Remove error

[jira] [Updated] (FLINK-24024) Support session Window TVF

[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24024: --- Fix Version/s: 1.15.0 > Support session Window TVF > --- > >

[jira] [Assigned] (FLINK-24760) Update user document for batch window tvf

[ https://issues.apache.org/jira/browse/FLINK-24760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24760: -- Assignee: JING ZHANG > Update user document for batch window tvf >

[jira] [Updated] (FLINK-24001) Support evaluating individual window table-valued function in runtime

[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24001: --- Fix Version/s: 1.15.0 > Support evaluating individual window table-valued function in

[jira] [Updated] (FLINK-23014) Support streaming window Deduplicate in planner

[ https://issues.apache.org/jira/browse/FLINK-23014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-23014: --- Fix Version/s: 1.15.0 > Support streaming window Deduplicate in planner >

[jira] [Updated] (FLINK-24760) Update user document for batch window tvf

[ https://issues.apache.org/jira/browse/FLINK-24760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24760: --- Fix Version/s: 1.15.0 > Update user document for batch window tvf >

[jira] [Assigned] (FLINK-23999) Support evaluating individual window table-valued function in planner

[ https://issues.apache.org/jira/browse/FLINK-23999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-23999: -- Assignee: JING ZHANG > Support evaluating individual window table-valued function in

[jira] [Assigned] (FLINK-24001) Support evaluating individual window table-valued function in runtime

[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24001: -- Assignee: JING ZHANG > Support evaluating individual window table-valued function in

[GitHub] [flink] echauchot commented on a change in pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

echauchot commented on a change in pull request #17640: URL: https://github.com/apache/flink/pull/17640#discussion_r742903374 ## File path: docs/content/docs/connectors/datastream/formats/avro.md ## @@ -0,0 +1,61 @@ +--- +title: "Avro" +weight: 4 +type: docs +aliases: +-

[jira] [Updated] (FLINK-24774) AdaptiveScheduler should inform job status listener of all state changes

[ https://issues.apache.org/jira/browse/FLINK-24774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24774: - Parent: FLINK-21510 Issue Type: Sub-task (was: Technical Debt) >

[GitHub] [flink] JingGe edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

JingGe edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-961072361 @tsreaper many thanks for your effort and for sharing the benchmark data. The option of using BulkFormat + ArrayList is almost the same as using

[GitHub] [flink] JingGe edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

JingGe edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-961072361 @tsreaper many thanks for your effort and for sharing the benchmark data. The option of using BulkFormat + ArrayList is almost the same as using

[jira] [Created] (FLINK-24774) AdaptiveScheduler should inform job status listener of all state changes

Chesnay Schepler created FLINK-24774: Summary: AdaptiveScheduler should inform job status listener of all state changes Key: FLINK-24774 URL: https://issues.apache.org/jira/browse/FLINK-24774

[GitHub] [flink] flinkbot edited a comment on pull request #17641: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

flinkbot edited a comment on pull request #17641: URL: https://github.com/apache/flink/pull/17641#issuecomment-957270143 ## CI report: * 4f7eb8397a272b0cd017df2f9669535f73c775ae Azure:

[GitHub] [flink] JingGe edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

JingGe edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-961072361 @tsreaper many thanks for your effort and for sharing the benchmark data. The option of using BulkFormat + ArrayList is almost the same as using

[GitHub] [flink] JingGe edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

JingGe edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-961072361 @tsreaper many thanks for your effort and for sharing the benchmark data. The option of using BulkFormat + ArrayList is almost the same as using

[GitHub] [flink] JingGe commented on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

JingGe commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-961072361 @tsreaper many thanks for your effort and for sharing the benchmark data. The option of using BulkFormat + ArrayList is almost the same as using

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 01a4524c33cf83bfa9f75004a5b960529cb8f660 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 ## CI report: * 7310e043a821d9bb5a58597566284d98df6988cc Azure:

[GitHub] [flink] akalash commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

akalash commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r742895929 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[GitHub] [flink] flinkbot edited a comment on pull request #17682: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

flinkbot edited a comment on pull request #17682: URL: https://github.com/apache/flink/pull/17682#issuecomment-960870159 ## CI report: * e4270687dcc245f8a8ee2c4a62f3ef5d8fe16678 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 ## CI report: * 7310e043a821d9bb5a58597566284d98df6988cc Azure:

[GitHub] [flink] akalash commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

akalash commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r742892354 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * 87b6a197aeaa3dff11b7779cd62f26dbc6e1d046 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 ## CI report: * 7310e043a821d9bb5a58597566284d98df6988cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * d372e5c7f645a95e62af48328c59589debf461d9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * 87b6a197aeaa3dff11b7779cd62f26dbc6e1d046 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17678: Highlight the fact that the Application Mode excpects user jars to be bundled with the Flink distribution.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * 52c5a34f17c5f2ec50f0e0c6326df1022cc98f4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * 52c5a34f17c5f2ec50f0e0c6326df1022cc98f4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * a89506ce35582d88432cd6ceecbf2caea233f0ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

flinkbot edited a comment on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-961007710 ## CI report: * 5218e0af11da5bf9c101c06cfb549c05d94bab14 Azure:

[jira] [Created] (FLINK-24773) KafkaCommitter should fail on unknown Exception

Fabian Paul created FLINK-24773: --- Summary: KafkaCommitter should fail on unknown Exception Key: FLINK-24773 URL: https://issues.apache.org/jira/browse/FLINK-24773 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * a89506ce35582d88432cd6ceecbf2caea233f0ac Azure:

[GitHub] [flink] flinkbot commented on pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

flinkbot commented on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-961009479 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] flinkbot commented on pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

flinkbot commented on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-961007710 ## CI report: * 5218e0af11da5bf9c101c06cfb549c05d94bab14 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17681: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

flinkbot edited a comment on pull request #17681: URL: https://github.com/apache/flink/pull/17681#issuecomment-960861704 ## CI report: * 1e4d3186bbefcceabac4ac27b2eede5891545e54 Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r742867867 ## File path: flink-ml-api/pom.xml ## @@ -38,6 +38,34 @@ under the License. ${flink.version} provided + + + org.apache.flink

[jira] [Updated] (FLINK-23999) Support evaluating individual window table-valued function in planner

[ https://issues.apache.org/jira/browse/FLINK-23999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23999: --- Labels: pull-request-available (was: ) > Support evaluating individual window table-valued

[jira] [Created] (FLINK-24772) Update user document for individual window table-valued function

JING ZHANG created FLINK-24772: -- Summary: Update user document for individual window table-valued function Key: FLINK-24772 URL: https://issues.apache.org/jira/browse/FLINK-24772 Project: Flink

[GitHub] [flink] beyond1920 opened a new pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

beyond1920 opened a new pull request #17684: URL: https://github.com/apache/flink/pull/17684 ## What is the purpose of the change This pr aims to support evaluating individual window table-valued function in planner ## Brief change log - Remove

[jira] [Commented] (FLINK-20625) Refactor Google Cloud PubSub Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438736#comment-17438736 ] Martijn Visser commented on FLINK-20625: Thanks for the heads-up [~Jakob Edding], it's a pity

[GitHub] [flink] fapaul commented on a change in pull request #17656: [FLINK-24741]Deprecate FileRecordFormat

fapaul commented on a change in pull request #17656: URL: https://github.com/apache/flink/pull/17656#discussion_r742857348 ## File path: flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/src/impl/FileRecordFormatAdapterTest.java ## @@ -37,6

[GitHub] [flink] flinkbot edited a comment on pull request #17673: [FLINK-24001][table-runtime] Window table-valued function operator support proctime window

flinkbot edited a comment on pull request #17673: URL: https://github.com/apache/flink/pull/17673#issuecomment-960580326 ## CI report: * 2383968f5682b5d74103f1c06abb0852911af2ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[jira] [Commented] (FLINK-20625) Refactor Google Cloud PubSub Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438732#comment-17438732 ] Jakob Edding commented on FLINK-20625: -- Hi [~MartijnVisser] I do not have the capacity at the

[GitHub] [flink] MartijnVisser commented on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

MartijnVisser commented on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-960970649 @infoverload Pinging you in case you also want to have a look! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] MartijnVisser commented on a change in pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

MartijnVisser commented on a change in pull request #17640: URL: https://github.com/apache/flink/pull/17640#discussion_r742836114 ## File path: docs/content/docs/connectors/datastream/formats/avro.md ## @@ -0,0 +1,61 @@ +--- +title: "Avro" +weight: 4 +type: docs +aliases: +-

[GitHub] [flink] flinkbot edited a comment on pull request #17683: [hotfix][table-planner][tests] Fix a few links to FLINK jira tickets

flinkbot edited a comment on pull request #17683: URL: https://github.com/apache/flink/pull/17683#issuecomment-960955131 ## CI report: * 3dc5e06e69c83ba62ca8957209f163ffb529918d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17578: [FLINK-24208][rest] Support user-supplied Savepoint triggerId

flinkbot edited a comment on pull request #17578: URL: https://github.com/apache/flink/pull/17578#issuecomment-952731483 ## CI report: * 76bbcdb19cc62e0794d2f566e3553dfa0426d8a6 Azure:

[GitHub] [flink] flinkbot commented on pull request #17683: [hotfix][table-planner][tests] Fix a few links to FLINK jira tickets

flinkbot commented on pull request #17683: URL: https://github.com/apache/flink/pull/17683#issuecomment-960956621 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] flinkbot commented on pull request #17683: [hotfix][table-planner][tests] Fix a few links to FLINK jira tickets

flinkbot commented on pull request #17683: URL: https://github.com/apache/flink/pull/17683#issuecomment-960955131 ## CI report: * 3dc5e06e69c83ba62ca8957209f163ffb529918d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] matriv opened a new pull request #17683: [hotfix][table-planner][tests] Fix a few links to FLINK jira tickets

matriv opened a new pull request #17683: URL: https://github.com/apache/flink/pull/17683 Fixed some links to FLINK Jira tickets in the `CAST` integration tests. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #17641: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

flinkbot edited a comment on pull request #17641: URL: https://github.com/apache/flink/pull/17641#issuecomment-957270143 ## CI report: * 4f7eb8397a272b0cd017df2f9669535f73c775ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

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

[jira] [Commented] (FLINK-24414) Casting a decimal to a String doesn't do left zero padding

[ https://issues.apache.org/jira/browse/FLINK-24414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438714#comment-17438714 ] Marios Trivyzas commented on FLINK-24414: - [~twalthr] Do you also agree to close and not fix

[GitHub] [flink] flinkbot edited a comment on pull request #17641: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

flinkbot edited a comment on pull request #17641: URL: https://github.com/apache/flink/pull/17641#issuecomment-957270143 ## CI report: * 4f7eb8397a272b0cd017df2f9669535f73c775ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

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

[GitHub] [flink] flinkbot edited a comment on pull request #17527: [hotfix][docs] Add link from README.md to 'Building Flink from Source'

flinkbot edited a comment on pull request #17527: URL: https://github.com/apache/flink/pull/17527#issuecomment-947535485 ## CI report: * d65d5d3d68e46a5649d762c45a3b973602586607 Azure:

[jira] [Commented] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover

[ https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438711#comment-17438711 ] Aitozi commented on FLINK-24633: Pod may stuck in some case: 1. allocate ip timeout 2. mount volume

[GitHub] [flink] echauchot commented on pull request #17641: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

echauchot commented on pull request #17641: URL: https://github.com/apache/flink/pull/17641#issuecomment-960903622 -- 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. To

[GitHub] [flink] echauchot commented on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

echauchot commented on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-960903048 -- 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. To

[GitHub] [flink] flinkbot edited a comment on pull request #17527: [hotfix][docs] Add link from README.md to 'Building Flink from Source'

flinkbot edited a comment on pull request #17527: URL: https://github.com/apache/flink/pull/17527#issuecomment-947535485 ## CI report: * d65d5d3d68e46a5649d762c45a3b973602586607 Azure:

<    1   2   3   4   5   6   7   8   >