[GitHub] [flink] flinkbot commented on pull request #16155: [hotfix][ci] Make NoticeFileChecker log severe issues at error level.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16070: [HOTFIX][docs] Fix typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

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

[GitHub] [flink] maver1ck commented on pull request #16154: [FLINK-22982][python] Fix the wrong matching in PythonMapMergeRule

maver1ck commented on pull request #16154: URL: https://github.com/apache/flink/pull/16154#issuecomment-861178781 @HuangXingBo Don't we want any test for the case from Jira ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #16154: [FLINK-22982][python] Fix the wrong matching in PythonMapMergeRule

flinkbot edited a comment on pull request #16154: URL: https://github.com/apache/flink/pull/16154#issuecomment-861162116 ## CI report: * eecf2f97b39793896e1b56ea86aa5f6933dde515 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

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

[GitHub] [flink] flinkbot edited a comment on pull request #16146: [FLINK-22927][python] Fix the bug of JobStatus

flinkbot edited a comment on pull request #16146: URL: https://github.com/apache/flink/pull/16146#issuecomment-859379229 ## CI report: * 08ffe3adfa0399106c7a7e82e682323adf4e4519 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16070: [HOTFIX][docs] Fix typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

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

[GitHub] [flink] flinkbot commented on pull request #16155: [hotfix][ci] Make NoticeFileChecker log severe issues at error level.

flinkbot commented on pull request #16155: URL: https://github.com/apache/flink/pull/16155#issuecomment-861174618 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] xintongsong commented on pull request #16155: [hotfix][ci] Make NoticeFileChecker log severe issues at error level.

xintongsong commented on pull request #16155: URL: https://github.com/apache/flink/pull/16155#issuecomment-861168367 cc @rmetzger -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] xintongsong opened a new pull request #16155: [hotfix][ci] Make NoticeFileChecker log severe issues at error level.

xintongsong opened a new pull request #16155: URL: https://github.com/apache/flink/pull/16155 This PR upgrades logging level of severe issues in NoticeFileChecker from WARN to ERROR Currently, it's a bit confusing which issue is causing the check failure when there are multiple

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363378#comment-17363378 ] Jingsong Lee commented on FLINK-22073: -- [~luoyuxia] Maybe we have set parallelism parameters. You

[GitHub] [flink] flinkbot commented on pull request #16154: [FLINK-22982][python] Fix the wrong matching in PythonMapMergeRule

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

[GitHub] [flink] flinkbot commented on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

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

[GitHub] [flink] flinkbot edited a comment on pull request #16146: [FLINK-22927][python] Fix the bug of JobStatus

flinkbot edited a comment on pull request #16146: URL: https://github.com/apache/flink/pull/16146#issuecomment-859379229 ## CI report: * 08ffe3adfa0399106c7a7e82e682323adf4e4519 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16070: [HOTFIX][docs] Fix typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

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

[jira] [Commented] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363374#comment-17363374 ] Bhagi commented on FLINK-22965: --- waiting for your response. > Association with remote system has failed,

[jira] [Comment Edited] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363368#comment-17363368 ] luoyuxia edited comment on FLINK-22073 at 6/15/21, 4:20 AM: >From the detail

[jira] [Comment Edited] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363368#comment-17363368 ] luoyuxia edited comment on FLINK-22073 at 6/15/21, 4:19 AM: >From the detail

[jira] [Comment Edited] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363368#comment-17363368 ] luoyuxia edited comment on FLINK-22073 at 6/15/21, 4:19 AM: >From the detail

[jira] [Comment Edited] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363368#comment-17363368 ] luoyuxia edited comment on FLINK-22073 at 6/15/21, 4:18 AM: >From the detail

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363368#comment-17363368 ] luoyuxia commented on FLINK-22073: -- >From the detail log, there are three streaming-writer, two of them

[GitHub] [flink] flinkbot commented on pull request #16154: [FLINK-22982][python] Fix the wrong matching in PythonMapMergeRule

flinkbot commented on pull request #16154: URL: https://github.com/apache/flink/pull/16154#issuecomment-861153559 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 #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

flinkbot commented on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861152936 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] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-861150767 Thanks for updating the PR, @galenwarren. - The Azure build has been triggered, on your latest commit (e751250). It's probably not very timely. - It's good to hear

[jira] [Updated] (FLINK-22982) java.lang.ClassCastException when using Python UDF

[ https://issues.apache.org/jira/browse/FLINK-22982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22982: --- Labels: pull-request-available (was: ) > java.lang.ClassCastException when using Python

[GitHub] [flink] HuangXingBo opened a new pull request #16154: [FLINK-22982][python] Fix the wrong matching in PythonMapMergeRule

HuangXingBo opened a new pull request #16154: URL: https://github.com/apache/flink/pull/16154 ## What is the purpose of the change *This pull request makes will fix the wrong matching in PythonMapMergeRule* ## Brief change log - *Fix the wrong matching in

[jira] [Commented] (FLINK-22983) Support lazy evaluation in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363362#comment-17363362 ] Jingsong Lee commented on FLINK-22983: -- Hi [~maver1ck], can you check the generated code? I think

[jira] [Updated] (FLINK-22678) Hide ChangelogStateBackend From Users

[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22678: --- Labels: pull-request-available (was: ) > Hide ChangelogStateBackend From Users >

[GitHub] [flink] Zakelly opened a new pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

Zakelly opened a new pull request #16153: URL: https://github.com/apache/flink/pull/16153 ## What is the purpose of the change This change provides configurations as well as APIs to configure ChangelogStateBackend. Base on the discussion before

[jira] [Commented] (FLINK-21736) Introduce latency tracking state

[ https://issues.apache.org/jira/browse/FLINK-21736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363360#comment-17363360 ] Yun Tang commented on FLINK-21736: -- [~trohrmann], sure.

[jira] [Assigned] (FLINK-22528) Document latency tracking metrics for state accesses

[ https://issues.apache.org/jira/browse/FLINK-22528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-22528: Assignee: Yun Tang > Document latency tracking metrics for state accesses >

[jira] [Updated] (FLINK-22985) NullPointerException when cast string literal to date or time

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22985: - Summary: NullPointerException when cast string literal to date or time (was: sql syntax,

[jira] [Commented] (FLINK-22985) sql syntax, NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363357#comment-17363357 ] Jingsong Lee commented on FLINK-22985: -- There is bug in

[jira] [Comment Edited] (FLINK-22985) sql syntax, NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363357#comment-17363357 ] Jingsong Lee edited comment on FLINK-22985 at 6/15/21, 3:46 AM: Thanks

[GitHub] [flink] flinkbot edited a comment on pull request #16152: [FLINK-22963][doc][1.12] correct the description of taskmanager.memory.task.heap.size.

flinkbot edited a comment on pull request #16152: URL: https://github.com/apache/flink/pull/16152#issuecomment-861137345 ## CI report: * b108c8a55ea791013c4eb477b01135629d0ed3f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16128: [FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer

flinkbot edited a comment on pull request #16128: URL: https://github.com/apache/flink/pull/16128#issuecomment-858396590 ## CI report: * c1496ae5f3e3f74ac121791bdf3b1f82bede643a Azure:

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363353#comment-17363353 ] Anton Kalashnikov commented on FLINK-20495: ---

[GitHub] [flink] zuston edited a comment on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

zuston edited a comment on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-859462105 @lirui-apache Updated. The ci failure looks unrelated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-22386) Introduce cache for docker images

[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22386: - Labels: (was: stale-major) > Introduce cache for docker images >

[jira] [Updated] (FLINK-22386) Introduce cache for docker images

[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22386: - Priority: Critical (was: Major) > Introduce cache for docker images >

[jira] [Updated] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22986: - Affects Version/s: 1.13.1 >

[jira] [Commented] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363348#comment-17363348 ] Xintong Song commented on FLINK-22986: --

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363347#comment-17363347 ] Xintong Song commented on FLINK-22702: --

[GitHub] [flink] flinkbot commented on pull request #16152: [FLINK-22963][doc][1.12] correct the description of taskmanager.memory.task.heap.size.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16128: [FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer

flinkbot edited a comment on pull request #16128: URL: https://github.com/apache/flink/pull/16128#issuecomment-858396590 ## CI report: * c1496ae5f3e3f74ac121791bdf3b1f82bede643a Azure:

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363345#comment-17363345 ] Xintong Song commented on FLINK-22068: -- Hi [~dannycranmer], would you mind help take a look into

[jira] [Commented] (FLINK-22985) sql syntax, NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363344#comment-17363344 ] Jark Wu commented on FLINK-22985: - [~simen] looks like a bug in code generation. Could you help to have

[jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22068: - Priority: Major (was: Minor) > FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure >

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363340#comment-17363340 ] Xintong Song commented on FLINK-22068: --

[jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22068: - Labels: test-stability (was: auto-deprioritized-major test-stability) >

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363339#comment-17363339 ] Xintong Song commented on FLINK-22387: --

[jira] [Commented] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363338#comment-17363338 ] Xintong Song commented on FLINK-22986: -- cc [~chesnay] Could this be related to the recent changes

[jira] [Created] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

Xintong Song created FLINK-22986: Summary: FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure Key: FLINK-22986 URL: https://issues.apache.org/jira/browse/FLINK-22986

[jira] [Commented] (FLINK-22985) sql syntax, NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363335#comment-17363335 ] simenliuxing commented on FLINK-22985: -- [~jark] hello jark , Is my grammar wrong？ > sql syntax,

[jira] [Created] (FLINK-22985) sql syntax, NullPointerException

simenliuxing created FLINK-22985: Summary: sql syntax, NullPointerException Key: FLINK-22985 URL: https://issues.apache.org/jira/browse/FLINK-22985 Project: Flink Issue Type: Bug

[GitHub] [flink] JingsongLi commented on a change in pull request #16096: [FLINK-22901][table] Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

JingsongLi commented on a change in pull request #16096: URL: https://github.com/apache/flink/pull/16096#discussion_r651412169 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/metadata/FlinkMetadata.java ## @@ -238,4

[GitHub] [flink] JingsongLi commented on a change in pull request #16096: [FLINK-22901][table] Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

JingsongLi commented on a change in pull request #16096: URL: https://github.com/apache/flink/pull/16096#discussion_r651411785 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/metadata/FlinkMetadata.java ## @@ -238,4

[jira] [Commented] (FLINK-22818) IgnoreInFlightDataITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363332#comment-17363332 ] Xintong Song commented on FLINK-22818: --

[jira] [Commented] (FLINK-22459) FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)

[ https://issues.apache.org/jira/browse/FLINK-22459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363330#comment-17363330 ] Xintong Song commented on FLINK-22459: -- This is likely caused by FLINK-22971. >

[jira] [Commented] (FLINK-22459) FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)

[ https://issues.apache.org/jira/browse/FLINK-22459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363329#comment-17363329 ] Xintong Song commented on FLINK-22459: --

[jira] [Closed] (FLINK-22730) Lookup join condition with CURRENT_DATE fails to filter records

[ https://issues.apache.org/jira/browse/FLINK-22730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22730. Fix Version/s: 1.13.2 Resolution: Fixed Fixed via: master: 

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363327#comment-17363327 ] Xintong Song commented on FLINK-22869: -- This is likely caused by FLINK-22971. >

[jira] [Assigned] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22085: Assignee: (was: Dong Lin) > KafkaSourceLegacyITCase hangs/fails on azure >

[jira] [Commented] (FLINK-22730) Lookup join condition with CURRENT_DATE fails to filter records

[ https://issues.apache.org/jira/browse/FLINK-22730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363325#comment-17363325 ] Jingsong Lee commented on FLINK-22730: -- [~xmarker] Sorry, [~TsReaper] already create a PR for this.

[jira] [Assigned] (FLINK-22730) Lookup join condition with CURRENT_DATE fails to filter records

[ https://issues.apache.org/jira/browse/FLINK-22730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22730: Assignee: Caizhi Weng > Lookup join condition with CURRENT_DATE fails to filter records

[GitHub] [flink] flinkbot commented on pull request #16152: [FLINK-22963][doc][1.12] correct the description of taskmanager.memory.task.heap.size.

flinkbot commented on pull request #16152: URL: https://github.com/apache/flink/pull/16152#issuecomment-861128316 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] JingsongLi merged pull request #16104: [FLINK-22730][table-planner-blink] Add per record code when generating table function collector code for lookup joins

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

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363324#comment-17363324 ] Dong Lin commented on FLINK-22085: -- [~xintongsong] Sure, please feel free to un-assign me. Thanks! >

[GitHub] [flink] xintongsong opened a new pull request #16152: [FLINK-22963][doc][1.12] correct the description of taskmanager.memory.task.heap.size.

xintongsong opened a new pull request #16152: URL: https://github.com/apache/flink/pull/16152 port #16143 to 1.12 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For

[GitHub] [flink] flinkbot edited a comment on pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

flinkbot edited a comment on pull request #16102: URL: https://github.com/apache/flink/pull/16102#issuecomment-856195315 ## CI report: * 66fd2567fbcffdc54265d7a63fae0373b88e22e5 Azure:

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363321#comment-17363321 ] Xintong Song commented on FLINK-22869: --

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363320#comment-17363320 ] Xintong Song commented on FLINK-22085: -- [~lindong], thanks for the updates. I'll try to find

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363319#comment-17363319 ] Xintong Song commented on FLINK-22085: --

[jira] [Updated] (FLINK-22984) UnsupportedOperationException when using Python UDF to generate watermark

[ https://issues.apache.org/jira/browse/FLINK-22984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22984: Affects Version/s: 1.13.0 > UnsupportedOperationException when using Python UDF to generate watermark >

[jira] [Commented] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363314#comment-17363314 ] Xintong Song commented on FLINK-22963: -- Fixed via: - master (1.14):

[jira] [Updated] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22963: - Fix Version/s: 1.13.2 1.12.5 1.14.0 > The description of

[jira] [Resolved] (FLINK-22712) Support accessing Row fields by attribute name in PyFlink Row-based Operation

[ https://issues.apache.org/jira/browse/FLINK-22712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22712. -- Resolution: Done Merged into master via 722a6d75ad87749273ca1c2d4c66c0c56a5db7bf > Support

[GitHub] [flink] HuangXingBo closed pull request #16065: [FLINK-22712][python] Support accessing Row fields by attribute name in PyFlink Row-based Operation

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

[GitHub] [flink] xintongsong closed pull request #16143: [FLINK-22963] correct description of taskmanager.memory.task.heap.size

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

[jira] [Updated] (FLINK-22982) java.lang.ClassCastException when using Python UDF

[ https://issues.apache.org/jira/browse/FLINK-22982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22982: Priority: Critical (was: Major) > java.lang.ClassCastException when using Python UDF >

[jira] [Closed] (FLINK-18438) TaskManager start failed

[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18438. Resolution: Resolved > TaskManager start failed > > >

[jira] [Updated] (FLINK-22982) java.lang.ClassCastException when using Python UDF

[ https://issues.apache.org/jira/browse/FLINK-22982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22982: Fix Version/s: 1.13.2 1.14.0 > java.lang.ClassCastException when using Python UDF >

[jira] [Commented] (FLINK-18438) TaskManager start failed

[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363312#comment-17363312 ] Xintong Song commented on FLINK-18438: -- Thanks [~derekm], the pointer is very helpful. Seems this

[jira] [Commented] (FLINK-22982) java.lang.ClassCastException when using Python UDF

[ https://issues.apache.org/jira/browse/FLINK-22982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363311#comment-17363311 ] Dian Fu commented on FLINK-22982: - cc [~hxbks2ks] > java.lang.ClassCastException when using Python UDF

[jira] [Updated] (FLINK-16428) Fine-grained network buffer management for backpressure

[ https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16428: Labels: (was: stale-critical) > Fine-grained network buffer management for backpressure >

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Labels: pull-request-available (was: pull-request-available stale-assigned) > Reduce the default

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363298#comment-17363298 ] Dong Lin commented on FLINK-22085: -- [~xintongsong] No... after spending 2+ hours over the weekend to

[jira] [Updated] (FLINK-7360) Support Scala map type in Table API

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

[jira] [Updated] (FLINK-7016) Move inputFormat to InputFormatVertex from TaskConfig

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

[jira] [Updated] (FLINK-7277) Weighted PageRank

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

[jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files

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

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20374: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was:

[jira] [Updated] (FLINK-7065) separate the flink-streaming-java module from flink-clients

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

[jira] [Updated] (FLINK-7144) Optimize multiple LogicalAggregate into one

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

[jira] [Updated] (FLINK-7339) aggregationToString fails when user defined aggregation contains constants

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

[jira] [Updated] (FLINK-7018) Refactor streamGraph to make interfaces clear

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

  1   2   3   4   >