[GitHub] [flink] flinkbot edited a comment on pull request #15170: [FLINK-21610][tests] Do not attempt to cancel the job

flinkbot edited a comment on pull request #15170: URL: https://github.com/apache/flink/pull/15170#issuecomment-797471124 ## CI report: * 46acace127aa09a4804d77a6b09f921dae83f2ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

flinkbot edited a comment on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-796866720 ## CI report: * 18a8fb0c34cfff0c5f7974c5d1571db09b50a1fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

flinkbot edited a comment on pull request #15140: URL: https://github.com/apache/flink/pull/15140#issuecomment-795409010 ## CI report: * 828662a5ad5fb5163f993cee40148f95b9856aed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15086: [FLINK-21561] Predownload/Cache large E2E test artifacts

flinkbot edited a comment on pull request #15086: URL: https://github.com/apache/flink/pull/15086#issuecomment-790506153 ## CI report: * 3f85a1bad5fb751a05590c7acfaae898549f9a21 UNKNOWN * 2394febfc54a6db9e1c5aac8896cc2b508c227dc UNKNOWN *

[jira] [Updated] (FLINK-21829) create HiveCatalog with custom hadoopconfdir first

[ https://issues.apache.org/jira/browse/FLINK-21829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21829: --- Labels: pull-request-available (was: ) > create HiveCatalog with custom hadoopconfdir

[GitHub] [flink] flinkbot commented on pull request #15245: [FLINK-21822][table] Support the new factory stack for CatalogFactory

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

[GitHub] [flink] flinkbot commented on pull request #15244: [FLINK-21829][Hive Connect]Fix to create HiveCatalog with custom hadoopconfdir first

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

[GitHub] [flink] flinkbot edited a comment on pull request #15243: [FLINK-21801][table-common] Deprecate TableSchema and related classes

flinkbot edited a comment on pull request #15243: URL: https://github.com/apache/flink/pull/15243#issuecomment-800364260 ## CI report: * 61e269e1c17ba65cc5bf0b9797b71fd01e99c11b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15236: [FLINK-21818][table] Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType

flinkbot edited a comment on pull request #15236: URL: https://github.com/apache/flink/pull/15236#issuecomment-800154343 ## CI report: * a4b23175ae924c5ea608ecdd5d3c6f3751d1b252 UNKNOWN * da23c74b9c1bb5a857a0777de9a9ac4b063122e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15242: [FLINK-21801][table-api] Use ResolvedSchema in QueryOperation

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

[GitHub] [flink] flinkbot edited a comment on pull request #15241: [FLINK-11408][datastream] Fix NPE and lost timer during window merging for ContinuousProcessingTimeTrigger

flinkbot edited a comment on pull request #15241: URL: https://github.com/apache/flink/pull/15241#issuecomment-800363939 ## CI report: * 925773cc81d871683719e418fb042b15c9de0d6c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

flinkbot edited a comment on pull request #15140: URL: https://github.com/apache/flink/pull/15140#issuecomment-795409010 ## CI report: * 39aa4d5f2dbb992ae0fcb2c7612e904baabbd244 Azure:

[GitHub] [flink] Airblader commented on a change in pull request #15242: [FLINK-21801][table-api] Use ResolvedSchema in QueryOperation

Airblader commented on a change in pull request #15242: URL: https://github.com/apache/flink/pull/15242#discussion_r595297408 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/DataStreamQueryOperation.java ## @@ -49,7

[GitHub] [flink] flinkbot commented on pull request #15245: [FLINK-21822][table] Support the new factory stack for CatalogFactory

flinkbot commented on pull request #15245: URL: https://github.com/apache/flink/pull/15245#issuecomment-800366412 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-21622) Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

[ https://issues.apache.org/jira/browse/FLINK-21622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302620#comment-17302620 ] Leonard Xu commented on FLINK-21622: Thanks for you information [~twalthr], I'll consider the new

[jira] [Updated] (FLINK-21822) Migrate CatalogFactory to the new Factory stack

[ https://issues.apache.org/jira/browse/FLINK-21822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21822: --- Labels: pull-request-available (was: ) > Migrate CatalogFactory to the new Factory stack >

[jira] [Closed] (FLINK-16829) Pass PrometheusReporter arguments via constructor

[ https://issues.apache.org/jira/browse/FLINK-16829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16829. Resolution: Fixed master: df3b61867a3c891e8b6e3f77b8af5a4540f7ab3a > Pass

[GitHub] [flink] flinkbot commented on pull request #15243: [FLINK-21801][table-common] Deprecate TableSchema and related classes

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

[GitHub] [flink] zentol merged pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

zentol merged pull request #15175: URL: https://github.com/apache/flink/pull/15175 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

[jira] [Created] (FLINK-21829) create HiveCatalog with custom hadoopconfdir first

hehuiyuan created FLINK-21829: - Summary: create HiveCatalog with custom hadoopconfdir first Key: FLINK-21829 URL: https://issues.apache.org/jira/browse/FLINK-21829 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #15242: [FLINK-21801][table-api] Use ResolvedSchema in QueryOperation

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

[GitHub] [flink] Airblader opened a new pull request #15245: [FLINK-21822][table] Support the new factory stack for CatalogFactory

Airblader opened a new pull request #15245: URL: https://github.com/apache/flink/pull/15245 ## What is the purpose of the change Support the newer factory stack based on `Factory` for `CatalogFactory`. This still supports the old `TableFactory` stack as well, but deprecates it, for

[GitHub] [flink] flinkbot commented on pull request #15241: [FLINK-11408][datastream] Fix NPE and lost timer during window merging for ContinuousProcessingTimeTrigger

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

[GitHub] [flink] flinkbot edited a comment on pull request #15159: [FLINK-21136] Adjust timeouts for reactive mode

flinkbot edited a comment on pull request #15159: URL: https://github.com/apache/flink/pull/15159#issuecomment-797005525 ## CI report: * 30724c1ba85f417b86d00337257b2180f03d376a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15146: [FLINK-19682] Actively timeout checkpoint barriers on the inputs

flinkbot edited a comment on pull request #15146: URL: https://github.com/apache/flink/pull/15146#issuecomment-796572408 ## CI report: * a15cdcdea094d3df4dfe639620ea05f45893bafd UNKNOWN * c0abba7949421eacc0337d57a63fa0d3ab1b7582 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

flinkbot edited a comment on pull request #15140: URL: https://github.com/apache/flink/pull/15140#issuecomment-795409010 ## CI report: * 39aa4d5f2dbb992ae0fcb2c7612e904baabbd244 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15032: [FLINK-21511][es] Bump Elasticsearch6 version to 6.8.12

flinkbot edited a comment on pull request #15032: URL: https://github.com/apache/flink/pull/15032#issuecomment-786551299 ## CI report: * f5dc7ee6e585da4e03c2485f57832fede5001593 Azure:

[GitHub] [flink] flinkbot commented on pull request #15244: Fix to create HiveCatalog with custom hadoopconfdir first

flinkbot commented on pull request #15244: URL: https://github.com/apache/flink/pull/15244#issuecomment-800360956 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] hehuiyuan opened a new pull request #15244: Fix to create HiveCatalog with custom hadoopconfdir first

hehuiyuan opened a new pull request #15244: URL: https://github.com/apache/flink/pull/15244 ## What is the purpose of the change There is no prompt when the the path to hadoop conf configured is wrong unintentional. It is better to load hadoop conf from possiable hadoop path when

[GitHub] [flink] flinkbot commented on pull request #15243: [FLINK-21801][table-common] Deprecate TableSchema and related classes

flinkbot commented on pull request #15243: URL: https://github.com/apache/flink/pull/15243#issuecomment-800353812 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] twalthr opened a new pull request #15243: [FLINK-21801][table-common] Deprecate TableSchema and related classes

twalthr opened a new pull request #15243: URL: https://github.com/apache/flink/pull/15243 ## What is the purpose of the change Deprecates the old `TableSchema` class. ## Brief change log Deprecates the old `TableSchema` class and subclasses. ## Verifying this

[GitHub] [flink] flinkbot commented on pull request #15242: [FLINK-21801][table-api] Use ResolvedSchema in QueryOperation

flinkbot commented on pull request #15242: URL: https://github.com/apache/flink/pull/15242#issuecomment-800350618 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] [Closed] (FLINK-17549) Support running Stateful Functions on native Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-17549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman closed FLINK-17549. Resolution: Feedback Received Adding a native k8s integration would be added to our roadmap.

[GitHub] [flink] wuchong commented on a change in pull request #15236: [FLINK-21818][table] Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType

wuchong commented on a change in pull request #15236: URL: https://github.com/apache/flink/pull/15236#discussion_r595262116 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java ## @@ -120,6 +120,10 @@

[jira] [Updated] (FLINK-21801) Update use new schema in Table, TableResult, TableOperation

[ https://issues.apache.org/jira/browse/FLINK-21801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21801: --- Labels: pull-request-available (was: ) > Update use new schema in Table, TableResult,

[jira] [Resolved] (FLINK-21721) Add a generic egress message builder to the SDK

[ https://issues.apache.org/jira/browse/FLINK-21721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman resolved FLINK-21721. -- Fix Version/s: statefun-3.0.0 Release Note: Fixed at b5cd78d0. Resolution: Fixed

[GitHub] [flink] twalthr opened a new pull request #15242: [FLINK-21801][table-api] Use ResolvedSchema in QueryOperation

twalthr opened a new pull request #15242: URL: https://github.com/apache/flink/pull/15242 ## What is the purpose of the change Updates the `QueryOperation` to use `ResolvedSchema`. ## Brief change log All occurrences and utilities are updated. ## Verifying this

[GitHub] [flink] flinkbot edited a comment on pull request #15220: [FLINK-21744][table-planner-blink]Support StreamExecDeduplicate json serialization/deserialization

flinkbot edited a comment on pull request #15220: URL: https://github.com/apache/flink/pull/15220#issuecomment-799585276 ## CI report: * 74e0fa120e1c0a259972ccbce3b655482a3fc367 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * 546bb52a009fee535df450c4ce569f1d8019ff6a UNKNOWN * 76d9a8b15ac0ef331a6a6d1da7282aca273b029b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15146: [FLINK-19682] Actively timeout checkpoint barriers on the inputs

flinkbot edited a comment on pull request #15146: URL: https://github.com/apache/flink/pull/15146#issuecomment-796572408 ## CI report: * a15cdcdea094d3df4dfe639620ea05f45893bafd UNKNOWN * c0abba7949421eacc0337d57a63fa0d3ab1b7582 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 86a185665e2451b37335326535795576429f8cde Azure:

[jira] [Created] (FLINK-21828) Add an AWS-λ example to stateful-playground

Igal Shilman created FLINK-21828: Summary: Add an AWS-λ example to stateful-playground Key: FLINK-21828 URL: https://issues.apache.org/jira/browse/FLINK-21828 Project: Flink Issue Type: Task

[GitHub] [flink] flinkbot commented on pull request #15241: [FLINK-11408][datastream] Fix NPE and lost timer during window merging for ContinuousProcessingTimeTrigger

flinkbot commented on pull request #15241: URL: https://github.com/apache/flink/pull/15241#issuecomment-800338027 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] wuchong commented on a change in pull request #15213: [FLINK-21774][sql-client] Do not display column names when return set is emtpy in SQL Client

wuchong commented on a change in pull request #15213: URL: https://github.com/apache/flink/pull/15213#discussion_r595252949 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java ## @@ -145,36 +145,30 @@ public static void

[GitHub] [flink] wuchong commented on a change in pull request #15213: [FLINK-21774][sql-client] Do not display column names when return set is emtpy in SQL Client

wuchong commented on a change in pull request #15213: URL: https://github.com/apache/flink/pull/15213#discussion_r595252949 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java ## @@ -145,36 +145,30 @@ public static void

[jira] [Updated] (FLINK-11408) ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge

[ https://issues.apache.org/jira/browse/FLINK-11408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11408: --- Labels: pull-request-available (was: ) > ContinuousProcessingTimeTrigger: NPE on clear()

[GitHub] [flink] kezhuw opened a new pull request #15241: [FLINK-11408][datastream] Fix NPE and lost timer during window merging for ContinuousProcessingTimeTrigger

kezhuw opened a new pull request #15241: URL: https://github.com/apache/flink/pull/15241 ## What is the purpose of the change Fix NPE and lost timer during window merging for ContinuousProcessingTimeTrigger. ## Brief change log * Register timer for new window in `onMerge`.

[GitHub] [flink] wuchong commented on a change in pull request #15213: [FLINK-21774][sql-client] Do not display column names when return set is emtpy in SQL Client

wuchong commented on a change in pull request #15213: URL: https://github.com/apache/flink/pull/15213#discussion_r595240053 ## File path: flink-table/flink-sql-client/src/test/resources/sql/function.q ## @@ -145,9 +170,14 @@ drop function if exists non_func; # should

[jira] [Created] (FLINK-21827) Migrate the Python examples to the new SDK

Igal Shilman created FLINK-21827: Summary: Migrate the Python examples to the new SDK Key: FLINK-21827 URL: https://issues.apache.org/jira/browse/FLINK-21827 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-21826) Migrate the shopping-cart-example to the new SDK.

Igal Shilman created FLINK-21826: Summary: Migrate the shopping-cart-example to the new SDK. Key: FLINK-21826 URL: https://issues.apache.org/jira/browse/FLINK-21826 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #15215: [FLINK-21785][blink-table-planner] Support json ser/de for StreamExecCorrelate

flinkbot edited a comment on pull request #15215: URL: https://github.com/apache/flink/pull/15215#issuecomment-799415392 ## CI report: * bc8ac05b4db95e83d09acd6764c24f5a65f1ff9b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

flinkbot edited a comment on pull request #15212: URL: https://github.com/apache/flink/pull/15212#issuecomment-799172540 ## CI report: * 55bf3a050d7c3d1c49914d3942e900da3eb39eb1 Azure:

[jira] [Updated] (FLINK-21824) Add a simple Json Kafka producer script

[ https://issues.apache.org/jira/browse/FLINK-21824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21824: --- Labels: pull-request-available (was: ) > Add a simple Json Kafka producer script >

[GitHub] [flink-statefun-playground] igalshilman opened a new pull request #1: [FLINK-21824] Add JSON Kafka Producer

igalshilman opened a new pull request #1: URL: https://github.com/apache/flink-statefun-playground/pull/1 # Kafak Producer # What This is a simple, single threaded `Python` script that produces JSONs into a `Kafka` topic. Since in StateFun world, we also require keys (they are

[jira] [Created] (FLINK-21825) AvroInputFormat doesn't honor -1 length on FileInputSplits

Nicolas Ferrario created FLINK-21825: Summary: AvroInputFormat doesn't honor -1 length on FileInputSplits Key: FLINK-21825 URL: https://issues.apache.org/jira/browse/FLINK-21825 Project: Flink

[jira] [Created] (FLINK-21824) Add a simple Json Kafka producer script

Igal Shilman created FLINK-21824: Summary: Add a simple Json Kafka producer script Key: FLINK-21824 URL: https://issues.apache.org/jira/browse/FLINK-21824 Project: Flink Issue Type: Task

[GitHub] [flink] wuchong commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

wuchong commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r595227921 ## File path: flink-table/flink-sql-client/src/test/resources/sql/catalog_database.q ## @@ -203,10 +203,12 @@ describe

[GitHub] [flink] wuchong commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

wuchong commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r595108991 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -180,6 +180,13 @@ private CliStrings()

[GitHub] [flink] flinkbot edited a comment on pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

flinkbot edited a comment on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-796866720 ## CI report: * fe461efef25b604dcbfd4a1d13034ea2642beeec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

flinkbot edited a comment on pull request #15140: URL: https://github.com/apache/flink/pull/15140#issuecomment-795409010 ## CI report: * d8420cc37e859ff8c4fbe4e596aab2e75e0ce754 Azure:

[GitHub] [flink] DomWos commented on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

DomWos commented on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-800292782 > > Hey :) Thanks for CC. Looks good! > > One thing to consider, is there is anything stopping us from going even futher and adding possibility to deserialize `SpecificRecord`

[GitHub] [flink] flinkbot edited a comment on pull request #15239: [FLINK-21811][blink-table-planner]Support StreamExecJoin json serialization/deserialization

flinkbot edited a comment on pull request #15239: URL: https://github.com/apache/flink/pull/15239#issuecomment-800209760 ## CI report: * e0c78a03c659940590517ccce0148dcf460a6c2d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

flinkbot edited a comment on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-798833303 ## CI report: * 3136ca8bd04e9590bbc13468ee3e89a0de46a988 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

flinkbot edited a comment on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-796866720 ## CI report: * fe461efef25b604dcbfd4a1d13034ea2642beeec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

flinkbot edited a comment on pull request #15112: URL: https://github.com/apache/flink/pull/15112#issuecomment-792620617 ## CI report: * 601d6cca0f61145903eecb7432d8b45f35e621c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

flinkbot edited a comment on pull request #15140: URL: https://github.com/apache/flink/pull/15140#issuecomment-795409010 ## CI report: * d8420cc37e859ff8c4fbe4e596aab2e75e0ce754 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15032: [FLINK-21511][es] Bump Elasticsearch6 version to 6.8.12

flinkbot edited a comment on pull request #15032: URL: https://github.com/apache/flink/pull/15032#issuecomment-786551299 ## CI report: * d867dcc50c2044fb2f5579ae3509e1af490f5cf4 Azure:

[jira] [Commented] (FLINK-21622) Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

[ https://issues.apache.org/jira/browse/FLINK-21622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302549#comment-17302549 ] Timo Walther commented on FLINK-21622: -- [~Leonard Xu] just for your information, it is way easier

[GitHub] [flink] flinkbot edited a comment on pull request #15239: [FLINK-21811][blink-table-planner]Support StreamExecJoin json serialization/deserialization

flinkbot edited a comment on pull request #15239: URL: https://github.com/apache/flink/pull/15239#issuecomment-800209760 ## CI report: * e0c78a03c659940590517ccce0148dcf460a6c2d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15232: [FLINK-20130][core] Add ZStandard to FileInputFormat

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

[GitHub] [flink] flinkbot edited a comment on pull request #15213: [FLINK-21774][sql-client] Do not display column names when return set is emtpy in SQL Client

flinkbot edited a comment on pull request #15213: URL: https://github.com/apache/flink/pull/15213#issuecomment-799172628 ## CI report: * c2cc618f010e55bcaa8157221b4dcaf3f5bd3231 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * 546bb52a009fee535df450c4ce569f1d8019ff6a UNKNOWN * 76d9a8b15ac0ef331a6a6d1da7282aca273b029b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

flinkbot edited a comment on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-798833303 ## CI report: * 3136ca8bd04e9590bbc13468ee3e89a0de46a988 Azure:

[GitHub] [flink] echauchot edited a comment on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

echauchot edited a comment on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-800273221 @JingsongLi @HuangZhenQiu I just added field deep copy (in case the source schema is multi-level) and fixed serialization issues that I found testing on flink 1.11.

[GitHub] [flink] flinkbot edited a comment on pull request #15032: [FLINK-21511][es] Bump Elasticsearch6 version to 6.8.12

flinkbot edited a comment on pull request #15032: URL: https://github.com/apache/flink/pull/15032#issuecomment-786551299 ## CI report: * d867dcc50c2044fb2f5579ae3509e1af490f5cf4 Azure:

[GitHub] [flink] echauchot commented on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

echauchot commented on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-800273221 @JingsongLi @HuangZhenQiu I just added field deep copy (in case the source schema is multi-level) and fixed serialization issues that I found testing on flink 1.11

[GitHub] [flink] wsry commented on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

wsry commented on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-800272033 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Created] (FLINK-21823) RocksDB on FreeBSD

Mårten Lindblad created FLINK-21823: --- Summary: RocksDB on FreeBSD Key: FLINK-21823 URL: https://issues.apache.org/jira/browse/FLINK-21823 Project: Flink Issue Type: Bug

[GitHub] [flink] westphal-jan closed pull request #15240: Update Rabbitmq connector source

westphal-jan closed pull request #15240: URL: https://github.com/apache/flink/pull/15240 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

[GitHub] [flink] westphal-jan opened a new pull request #15240: Update Rabbitmq connector source

westphal-jan opened a new pull request #15240: URL: https://github.com/apache/flink/pull/15240 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] zuston commented on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-800262780 Do i need to submit another PR about changing `identify` to `service` in credentials? Actually there is no relationship between this PR and `identify` changes. @XComp

[jira] [Comment Edited] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302508#comment-17302508 ] Piotr Nowojski edited comment on FLINK-21416 at 3/16/21, 1:15 PM: -- The

[jira] [Comment Edited] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302508#comment-17302508 ] Piotr Nowojski edited comment on FLINK-21416 at 3/16/21, 1:15 PM: -- The

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

flinkbot edited a comment on pull request #15237: URL: https://github.com/apache/flink/pull/15237#issuecomment-800167686 ## CI report: * b583664ae588c709ded3961764cc9ccb686e6dde Azure:

[jira] [Assigned] (FLINK-21822) Migrate CatalogFactory to the new Factory stack

[ https://issues.apache.org/jira/browse/FLINK-21822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-21822: Assignee: Ingo Bürk > Migrate CatalogFactory to the new Factory stack >

[jira] [Commented] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302508#comment-17302508 ] Piotr Nowojski commented on FLINK-21416: The amount of those failures is a bit suspicious. Has

[GitHub] [flink] flinkbot edited a comment on pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * 546bb52a009fee535df450c4ce569f1d8019ff6a UNKNOWN * 76d9a8b15ac0ef331a6a6d1da7282aca273b029b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15170: [FLINK-21610][tests] Do not attempt to cancel the job

flinkbot edited a comment on pull request #15170: URL: https://github.com/apache/flink/pull/15170#issuecomment-797471124 ## CI report: * fe89069b85465252e01528d6b92f092da7daf3fd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15159: [FLINK-21136] Adjust timeouts for reactive mode

flinkbot edited a comment on pull request #15159: URL: https://github.com/apache/flink/pull/15159#issuecomment-797005525 ## CI report: * aab6b14a76ca84b1fab62d698c2c5914a8f37807 Azure:

[jira] [Created] (FLINK-21822) Migrate CatalogFactory to the new Factory stack

Ingo Bürk created FLINK-21822: - Summary: Migrate CatalogFactory to the new Factory stack Key: FLINK-21822 URL: https://issues.apache.org/jira/browse/FLINK-21822 Project: Flink Issue Type:

[jira] [Closed] (FLINK-21622) Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

[ https://issues.apache.org/jira/browse/FLINK-21622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21622. -- Fix Version/s: 1.13.0 Resolution: Fixed fixed via: c2f74dc8a33f7bcd859a71905877b0a9a70bb76a >

[GitHub] [flink] KurtYoung closed pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

KurtYoung closed pull request #15136: URL: https://github.com/apache/flink/pull/15136 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] fsk119 commented on pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

fsk119 commented on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-800243481 The PR is mainly designed for compatibility between `ExecutionEntry` and `Configuration`. However, it does introduce some incompatibility. I think the incompatibility is from 2

[jira] [Commented] (FLINK-21820) JDBC connector shouldn't read all rows in per statement by default

[ https://issues.apache.org/jira/browse/FLINK-21820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302498#comment-17302498 ] Nicholas Jiang commented on FLINK-21820: [~Leonard Xu], by default, [most JDBC drivers use a

[jira] [Closed] (FLINK-21396) Update the Catalog APIs

[ https://issues.apache.org/jira/browse/FLINK-21396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-21396. Fix Version/s: 1.13.0 Resolution: Fixed > Update the Catalog APIs >

[jira] [Commented] (FLINK-21396) Update the Catalog APIs

[ https://issues.apache.org/jira/browse/FLINK-21396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302494#comment-17302494 ] Timo Walther commented on FLINK-21396: -- Fixed in 1.13.0: [table-planner-blink] Use

[GitHub] [flink] twalthr closed pull request #15217: [FLINK-21396][table-planner-blink] Use ResolvedCatalogTable within the planner

twalthr closed pull request #15217: URL: https://github.com/apache/flink/pull/15217 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

[GitHub] [flink] AHeise commented on pull request #15222: [FLINK-21535][tests] Improved the detection of the attempt number in UnalignedCheckpointITCase. [1.12]

AHeise commented on pull request #15222: URL: https://github.com/apache/flink/pull/15222#issuecomment-800236522 Failure unrelated (FLINK-20420). This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-21416: - Priority: Critical (was: Major) > FileBufferReaderITCase.testSequentialReading fails

<    1   2   3   4   5   6   7   >