[jira] [Updated] (FLINK-16570) Difficulties to select correct metric with long name in dropdown of Flink UI task menu

[ https://issues.apache.org/jira/browse/FLINK-16570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16570: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20281) Window aggregation supports changelog stream input

[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20281: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-16574) StreamingFileSink should rename files or fail if destination file already exists

[ https://issues.apache.org/jira/browse/FLINK-16574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16574: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20340) Use StreamFormat instead of DelimitedInputFormat in DeserializationSchemaAdapter

[ https://issues.apache.org/jira/browse/FLINK-20340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20340: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-23719) Support switch WAL in Flink SQL DDL options for HBase sink

[ https://issues.apache.org/jira/browse/FLINK-23719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23719: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-16596) Support Enum-Values as part of a Key

[ https://issues.apache.org/jira/browse/FLINK-16596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16596: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20294) Expose value format metadata in Kinesis table source

[ https://issues.apache.org/jira/browse/FLINK-20294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20294: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23324: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-20346) Explain ChangelogMode for sinks

[ https://issues.apache.org/jira/browse/FLINK-20346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20346: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-20255) Nested decorrelate failed

[ https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20255: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-23545) Use new schema in SqlCreateTableConverter

[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23545: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-20248) `ParquetSchemaConverter` can not convert Array type to parquet Type

[ https://issues.apache.org/jira/browse/FLINK-20248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20248: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-20257) Flink web-ui metrics page add metrics selector Can't see the full name of the metics

[ https://issues.apache.org/jira/browse/FLINK-20257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20257: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-23000) Allow downloading all Flink logs from the UI

[ https://issues.apache.org/jira/browse/FLINK-23000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23000: --- Labels: pull-request-available stale-assigned usability (was: pull-request-available

[jira] [Updated] (FLINK-23528) stop-with-savepoint can fail with FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-23528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23528: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-23582) Add documentation for session window

[ https://issues.apache.org/jira/browse/FLINK-23582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23582: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-23602) org.codehaus.commons.compiler.CompileException: Line 84, Column 78: No applicable constructor/method found for actual parameters "org.apache.flink.table.data.DecimalData

[ https://issues.apache.org/jira/browse/FLINK-23602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23602: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

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

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 95ad572805a3aa45e9c78e07f83cd820abe00a52 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17729: [FLINK-24738][runtime] Ignoring buffer size announcement if the subpa…

flinkbot edited a comment on pull request #17729: URL: https://github.com/apache/flink/pull/17729#issuecomment-963388468 ## CI report: * db74e5a1381af5e9c045cf35dd308966e48c175f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

flinkbot edited a comment on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-961206353 ## CI report: * ac30525a9fee3aeb772f7f61858f615414490e72 Azure:

[GitHub] [flink] Airblader commented on a change in pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

Airblader commented on a change in pull request #17711: URL: https://github.com/apache/flink/pull/17711#discussion_r745122619 ## File path: flink-runtime-web/web-dashboard/package.json ## @@ -9,72 +9,73 @@ "lint": "eslint --cache src --ext .ts,.html && stylelint

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

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

[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: * 7255961d5deef5f150679ca64753ccf886faae75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17716: [FLINK-24738][runtime] Ignoring buffer size announcement if the chann…

flinkbot edited a comment on pull request #17716: URL: https://github.com/apache/flink/pull/17716#issuecomment-963029802 ## CI report: * 20d35424067cb0fd28611e0e8dd1118c6fcf6452 Azure:

[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: * 7255961d5deef5f150679ca64753ccf886faae75 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

MartijnVisser commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-963594207 @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] flinkbot edited a comment on pull request #17728: [FLINK-24832][tests][testinfrastructure] Update JUnit5 to v5.8.1

flinkbot edited a comment on pull request #17728: URL: https://github.com/apache/flink/pull/17728#issuecomment-963302913 ## CI report: * 5233d825d4f57bb7c375c810a7c174dc7e4a8bcd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17700: [FLINK-24773][kafka] Fail job if unhandled exception occurs during committing

flinkbot edited a comment on pull request #17700: URL: https://github.com/apache/flink/pull/17700#issuecomment-961972204 ## CI report: * 4173fa3fe4e0ee4ecff6844a026b6042c309db63 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

flinkbot edited a comment on pull request #17660: URL: https://github.com/apache/flink/pull/17660#issuecomment-958945516 ## CI report: * 45f9a69a33d96a6134dc6d68308e43cd992f0e58 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 47b6d1194869dc00a6d326bf87127da8c6d667a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 47b6d1194869dc00a6d326bf87127da8c6d667a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17727: [FLINK-24828][tests][testinfrastructure] Bump Powermock to v2.0.9

flinkbot edited a comment on pull request #17727: URL: https://github.com/apache/flink/pull/17727#issuecomment-963292829 ## CI report: * e8a1d04fc99ca81f5eddc591bd4d252fb3e1b450 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] 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: * a4bfd1285575f38165a928dd0a0ed1c4efe213e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

flinkbot edited a comment on pull request #17731: URL: https://github.com/apache/flink/pull/17731#issuecomment-963552076 ## CI report: * 85ea82b249c6bee70d296e25d1b324d8f43fe67b Azure:

[GitHub] [flink] flinkbot commented on pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

flinkbot commented on pull request #17731: URL: https://github.com/apache/flink/pull/17731#issuecomment-963552076 ## CI report: * 85ea82b249c6bee70d296e25d1b324d8f43fe67b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

flinkbot commented on pull request #17731: URL: https://github.com/apache/flink/pull/17731#issuecomment-963551844 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] sjwiesman commented on pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

sjwiesman commented on pull request #17731: URL: https://github.com/apache/flink/pull/17731#issuecomment-963550085 @fapaul would you want to take a look at this? Its a small QOL improvement I ran across when working on the examples. -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-24834) Add typed builders to DefaultRollingPolicy

[ https://issues.apache.org/jira/browse/FLINK-24834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24834: --- Labels: pull-request-available (was: ) > Add typed builders to DefaultRollingPolicy >

[GitHub] [flink] sjwiesman opened a new pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

sjwiesman opened a new pull request #17731: URL: https://github.com/apache/flink/pull/17731 ## What is the purpose of the change The default RollingPolicy is configured based on durations and memory sizes, but these parameters are specified via longs (milliseconds and bytes). We can

[GitHub] [flink] flinkbot edited a comment on pull request #17726: [FLINK-24827][buildsystem] Bump maven-dependency-plugin to v3.2.0

flinkbot edited a comment on pull request #17726: URL: https://github.com/apache/flink/pull/17726#issuecomment-963284326 ## CI report: * efc8b2181658aa947ebac4c01352a9178de64bf5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

flinkbot edited a comment on pull request #17583: URL: https://github.com/apache/flink/pull/17583#issuecomment-953378438 ## CI report: * 293fa0d578b8ab4f4ef71bd19e4d968111dd65d8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

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

[jira] [Created] (FLINK-24834) Add typed builders to DefaultRollingPolicy

Seth Wiesman created FLINK-24834: Summary: Add typed builders to DefaultRollingPolicy Key: FLINK-24834 URL: https://issues.apache.org/jira/browse/FLINK-24834 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] 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: * b30d37d05bb85cae471379073cd58298619f43ca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] 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: * b30d37d05bb85cae471379073cd58298619f43ca Azure:

[jira] [Assigned] (FLINK-24830) Update DataStream WordCount example

[ https://issues.apache.org/jira/browse/FLINK-24830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24830: Assignee: Seth Wiesman > Update DataStream WordCount example >

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24615][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * 89b9e48aacedba0ff4d47dc8f7fdb3e5315945be Azure:

[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: * 7255961d5deef5f150679ca64753ccf886faae75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17730: [FLINK-24829][examples] Rename example directories based on API

flinkbot edited a comment on pull request #17730: URL: https://github.com/apache/flink/pull/17730#issuecomment-963506792 ## CI report: * 32df2c2cc81d26abc28dd0aec014e7c84cd191b4 Azure:

[GitHub] [flink] flinkbot commented on pull request #17730: [FLINK-24829][examples] Rename example directories based on API

flinkbot commented on pull request #17730: URL: https://github.com/apache/flink/pull/17730#issuecomment-963506792 ## CI report: * 32df2c2cc81d26abc28dd0aec014e7c84cd191b4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] sjwiesman commented on pull request #17730: [FLINK-24829][examples] Rename example directories based on API

sjwiesman commented on pull request #17730: URL: https://github.com/apache/flink/pull/17730#issuecomment-963505559 cc @zentol could you take a look at the changes to `assemblies/bin` and ` tools/ci/java-ci-tools/src/main/resources/modules-skipping-deployment.modulelist` ? -- This is

[GitHub] [flink] flinkbot commented on pull request #17730: [FLINK-24829][examples] Rename example directories based on API

flinkbot commented on pull request #17730: URL: https://github.com/apache/flink/pull/17730#issuecomment-963505407 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] [Updated] (FLINK-24829) Rename example directories based on API

[ https://issues.apache.org/jira/browse/FLINK-24829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24829: --- Labels: pull-request-available (was: ) > Rename example directories based on API >

[GitHub] [flink] sjwiesman opened a new pull request #17730: [FLINK-24829][examples] Rename example directories based on API

sjwiesman opened a new pull request #17730: URL: https://github.com/apache/flink/pull/17730 ## What is the purpose of the change Rename the example folders to be named based on API now that DataStream supports both batch and streaming execution. ## Brief change log

[jira] [Created] (FLINK-24833) Prevent use of deprecated APIs in flink-examples

Seth Wiesman created FLINK-24833: Summary: Prevent use of deprecated APIs in flink-examples Key: FLINK-24833 URL: https://issues.apache.org/jira/browse/FLINK-24833 Project: Flink Issue Type:

[GitHub] [flink] dmvk commented on a change in pull request #17693: [FLINK-24789][runtime] Trigger checkpoint disposal prior completing t…

dmvk commented on a change in pull request #17693: URL: https://github.com/apache/flink/pull/17693#discussion_r745025015 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/PendingCheckpointTest.java ## @@ -578,6 +580,55 @@ public void

[GitHub] [flink] dmvk commented on a change in pull request #17693: [FLINK-24789][runtime] Trigger checkpoint disposal prior completing t…

dmvk commented on a change in pull request #17693: URL: https://github.com/apache/flink/pull/17693#discussion_r745020426 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/PendingCheckpointTest.java ## @@ -578,6 +580,55 @@ public void

[GitHub] [flink] dmvk commented on a change in pull request #17693: [FLINK-24789][runtime] Trigger checkpoint disposal prior completing t…

dmvk commented on a change in pull request #17693: URL: https://github.com/apache/flink/pull/17693#discussion_r745020273 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/PendingCheckpointTest.java ## @@ -578,6 +580,55 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #17656: [FLINK-24741]Deprecate FileRecordFormat

flinkbot edited a comment on pull request #17656: URL: https://github.com/apache/flink/pull/17656#issuecomment-958746092 ## CI report: * 82a491e75a1121bb7bafbcd6f49489076b6dc80b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17723: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

flinkbot edited a comment on pull request #17723: URL: https://github.com/apache/flink/pull/17723#issuecomment-963153415 ## CI report: * 2f4c6603733bdd34346318fb593486f85557d2ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17724: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

flinkbot edited a comment on pull request #17724: URL: https://github.com/apache/flink/pull/17724#issuecomment-963167087 ## CI report: * c9ce7f29985ef0b82983c86ca24920b54ebb67f3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * e4c2a930b6421b410e1e11c65c99b5008fc361b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * b48104914a31c05ad902cb0c36aef52b2b4093a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * b48104914a31c05ad902cb0c36aef52b2b4093a8 Azure:

[jira] [Assigned] (FLINK-24829) Rename example directories based on API

[ https://issues.apache.org/jira/browse/FLINK-24829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24829: Assignee: Seth Wiesman > Rename example directories based on API >

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] 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: * b30d37d05bb85cae471379073cd58298619f43ca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * ba5cd272656848b9e0308870ab3395124257d81b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17721: [FLINK-24822][table-planner]Improve CatalogTableSpecBase and its subclass related method parameter

flinkbot edited a comment on pull request #17721: URL: https://github.com/apache/flink/pull/17721#issuecomment-963145399 ## CI report: * d52449c9e030acb1936ee2b5429fedcd2b6f2744 Azure:

[GitHub] [flink] nlu90 commented on a change in pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

nlu90 commented on a change in pull request #17643: URL: https://github.com/apache/flink/pull/17643#discussion_r744956865 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderBase.java

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

flinkbot edited a comment on pull request #17583: URL: https://github.com/apache/flink/pull/17583#issuecomment-953378438 ## CI report: * 308e3f7d2ce15ce4434dddccbb4f53350e1f081a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

flinkbot edited a comment on pull request #17583: URL: https://github.com/apache/flink/pull/17583#issuecomment-953378438 ## CI report: * 308e3f7d2ce15ce4434dddccbb4f53350e1f081a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17719: [BP-1.13][FLINK-21289][deployment] FIX missing load pipeline.classpaths in application mode, for both k8s and yarn

flinkbot edited a comment on pull request #17719: URL: https://github.com/apache/flink/pull/17719#issuecomment-963077947 ## CI report: * 9354ac1cfa1d7440b5d17972b2bcc3482a132c7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

flinkbot edited a comment on pull request #17583: URL: https://github.com/apache/flink/pull/17583#issuecomment-953378438 ## CI report: * 308e3f7d2ce15ce4434dddccbb4f53350e1f081a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17722: [FLINK-24774] Adaptive scheduler notifies listeners for all job state transitions

flinkbot edited a comment on pull request #17722: URL: https://github.com/apache/flink/pull/17722#issuecomment-963149329 ## CI report: * 71cfbc8ea9a642b8cbef6b67e5c51bf45dea9600 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

flinkbot edited a comment on pull request #17583: URL: https://github.com/apache/flink/pull/17583#issuecomment-953378438 ## CI report: * 308e3f7d2ce15ce4434dddccbb4f53350e1f081a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17729: [FLINK-24738][runtime] Ignoring buffer size announcement if the subpa…

flinkbot edited a comment on pull request #17729: URL: https://github.com/apache/flink/pull/17729#issuecomment-963388468 ## CI report: * db74e5a1381af5e9c045cf35dd308966e48c175f Azure:

[GitHub] [flink] flinkbot commented on pull request #17729: [FLINK-24738][runtime] Ignoring buffer size announcement if the subpa…

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

[GitHub] [flink] flinkbot commented on pull request #17729: [FLINK-24738][runtime] Ignoring buffer size announcement if the subpa…

flinkbot commented on pull request #17729: URL: https://github.com/apache/flink/pull/17729#issuecomment-963388020 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 edited a comment on pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

flinkbot edited a comment on pull request #17696: URL: https://github.com/apache/flink/pull/17696#issuecomment-961875755 ## CI report: * f0568b0b45ec0de9a230181130e2fafb25029bf1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

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

[GitHub] [flink] akalash opened a new pull request #17729: [FLINK-24738][runtime] Ignoring buffer size announcement if the subpa…

akalash opened a new pull request #17729: URL: https://github.com/apache/flink/pull/17729 …rtition view has not created yet ## What is the purpose of the change *The second part of https://github.com/apache/flink/pull/17663 that ignores buffer size announcement when

[GitHub] [flink] CrynetLogistics commented on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

CrynetLogistics commented on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-963373207 @fapaul Let me know if you think the changes are good. Thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-24826) Performance regression in HeapState benchmarks on Nov 8 2021

[ https://issues.apache.org/jira/browse/FLINK-24826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440596#comment-17440596 ] Zakelly Lan commented on FLINK-24826: - Hi, [~roman]. I think that is because the

[GitHub] [flink] flinkbot edited a comment on pull request #17725: [FLINK-24750][table][docs] Code blocks to prevent sql quotes convertion

flinkbot edited a comment on pull request #17725: URL: https://github.com/apache/flink/pull/17725#issuecomment-963191520 ## CI report: * 472be86049919833eceb17604ecc04c0ec69fa16 Azure:

[GitHub] [flink] dannycranmer commented on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

dannycranmer commented on pull request #17583: URL: https://github.com/apache/flink/pull/17583#issuecomment-963368030 Looks good to me, besides one comment about `cn` comments. Please rebase to resolve conflicts and I will merge one CI passes -- This is an automated message from the

[GitHub] [flink] dannycranmer commented on a change in pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

dannycranmer commented on a change in pull request #17583: URL: https://github.com/apache/flink/pull/17583#discussion_r744921228 ## File path: docs/content/docs/connectors/datastream/kinesis.md ## @@ -121,10 +121,13 @@ then some consumer subtasks will simply be idle and wait

[GitHub] [flink] flinkbot edited a comment on pull request #17718: [BP-1.14][FLINK-21289][deployment] FIX missing load pipeline.classpaths in application mode, for both k8s and yarn

flinkbot edited a comment on pull request #17718: URL: https://github.com/apache/flink/pull/17718#issuecomment-963077874 ## CI report: * cdb34e1a90f8cb61648e75a94d2c4d58df6fb80a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

flinkbot edited a comment on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-961206353 ## CI report: * f3af034035c0951ac03f479a5f5ac71efd557fab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17600: [FLINK-24680][runtime/coordinator] Use UserCodeClassLoader when closing coordinator and register hook in ClassLoader to prevent relea

flinkbot edited a comment on pull request #17600: URL: https://github.com/apache/flink/pull/17600#issuecomment-954461335 ## CI report: * 95cf147b70466341ed06935a2b59937afefa4642 Azure:

[jira] [Closed] (FLINK-24684) Port to string casting rules to the new CastRule interface

[ https://issues.apache.org/jira/browse/FLINK-24684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24684. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] flinkbot edited a comment on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

flinkbot edited a comment on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-961206353 ## CI report: * f3af034035c0951ac03f479a5f5ac71efd557fab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17664: [FLINK-24658][runtime] Added debug logs for BufferDebloater

flinkbot edited a comment on pull request #17664: URL: https://github.com/apache/flink/pull/17664#issuecomment-959645843 ## CI report: * 870734d94d659b1e2284ac721322b33c4550ef8d Azure:

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

twalthr closed pull request #17658: URL: https://github.com/apache/flink/pull/17658 -- 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] CrynetLogistics commented on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

CrynetLogistics commented on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-963361430 Please squash the commits when merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

CrynetLogistics commented on a change in pull request #17687: URL: https://github.com/apache/flink/pull/17687#discussion_r744912709 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -219,25

[GitHub] [flink] flinkbot edited a comment on pull request #17693: [FLINK-24789][runtime] Trigger checkpoint disposal prior completing t…

flinkbot edited a comment on pull request #17693: URL: https://github.com/apache/flink/pull/17693#issuecomment-961795148 ## CI report: * f274212c4713ff49a50a834947950d229de01bff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

flinkbot edited a comment on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-961206353 ## CI report: * f3af034035c0951ac03f479a5f5ac71efd557fab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

flinkbot edited a comment on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-961206353 ## CI report: * f3af034035c0951ac03f479a5f5ac71efd557fab Azure:

<    1   2   3   4   5   6   7   8   >