[jira] [Commented] (FLINK-21516) UpsertKafkaTableITCase.testTemporalJoin fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-21516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319460#comment-17319460 ] Leonard Xu commented on FLINK-21516: Yes, the same root cause with FLINK-21431, I've raised a PR for 

[GitHub] [flink-web] rmetzger commented on a change in pull request #427: Add reactive mode blog post

rmetzger commented on a change in pull request #427: URL: https://github.com/apache/flink-web/pull/427#discussion_r611636129 ## File path: _posts/2021-04-05-reactive-mode.md ## @@ -0,0 +1,149 @@ +--- +layout: post +title: "Scaling Flink automatically with Reactive Mode"

[jira] [Commented] (FLINK-21748) LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails

[ https://issues.apache.org/jira/browse/FLINK-21748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319458#comment-17319458 ] Shengkai Fang commented on FLINK-21748: --- Thanks for Kurt's tips. The problem is because of

[jira] [Updated] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang

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

[GitHub] [flink] leonardBang opened a new pull request #15578: [FLINK-21431][upsert-kafka] Use testcontainers for UpsertKafkaTableITCase

leonardBang opened a new pull request #15578: URL: https://github.com/apache/flink/pull/15578 ## What is the purpose of the change * This pull request use testcontainers for UpsertKafkaTableITCase to fix the hang tests in UpsertKafkaTableITCase reported in FLINK-21516 and

[GitHub] [flink-web] zentol merged pull request #432: [FLINK-22183] Update copyright to 2014-2021

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

[GitHub] [flink] KurtYoung commented on a change in pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

KurtYoung commented on a change in pull request #15570: URL: https://github.com/apache/flink/pull/15570#discussion_r611621323 ## File path:

[jira] [Updated] (FLINK-22035) Run Jira Bot periodically with Github Actions

[ https://issues.apache.org/jira/browse/FLINK-22035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22035: --- Labels: pull-request-available (was: ) > Run Jira Bot periodically with Github Actions >

[GitHub] [flink] KurtYoung commented on a change in pull request #15568: [FLINK-17371][table-runtime] Add cases for decimal casting

KurtYoung commented on a change in pull request #15568: URL: https://github.com/apache/flink/pull/15568#discussion_r611616344 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/DecimalCastTest.scala ## @@ -0,0 +1,203

[GitHub] [flink-jira-bot] knaufk opened a new pull request #2: [WIP] [FLINK-22035] Add Github Actions

knaufk opened a new pull request #2: URL: https://github.com/apache/flink-jira-bot/pull/2 -- 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] flinkbot commented on pull request #15577: [FLINK-22001] Forward exceptions thrown during initialization to the user

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

[GitHub] [flink] flinkbot edited a comment on pull request #15576: [hotfix] DescriptorProperties#validate has return error exception message

flinkbot edited a comment on pull request #15576: URL: https://github.com/apache/flink/pull/15576#issuecomment-817780683 ## CI report: * eb655bd42880adf60de66521a84ad65e0420e164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15543: [FLINK-17803][table] Should throw a readable exception when group by Map type

flinkbot edited a comment on pull request #15543: URL: https://github.com/apache/flink/pull/15543#issuecomment-816526178 ## CI report: * bd8ebbcaf2c9c2d018cdfe63e84687c99f207399 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15575: [FLINK-22152][python] Fix the bug of same timers are registered multiple times

flinkbot edited a comment on pull request #15575: URL: https://github.com/apache/flink/pull/15575#issuecomment-817762686 ## CI report: * f8e270a484f0f438c9036cb75037d4ccc5d4cad3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15562: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

flinkbot edited a comment on pull request #15562: URL: https://github.com/apache/flink/pull/15562#issuecomment-817610135 ## CI report: * 237ebdca2e429a3a9fc12a1e258ddcc709b31e43 Azure:

[jira] [Created] (FLINK-22241) Record AllocationID instead of JobID when marking slot active failed

Zhilong Hong created FLINK-22241: Summary: Record AllocationID instead of JobID when marking slot active failed Key: FLINK-22241 URL: https://issues.apache.org/jira/browse/FLINK-22241 Project: Flink

[jira] [Updated] (FLINK-22241) Log AllocationID instead of JobID when marking slot active failed

[ https://issues.apache.org/jira/browse/FLINK-22241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22241: - Summary: Log AllocationID instead of JobID when marking slot active failed (was: Record

[GitHub] [flink] flinkbot commented on pull request #15577: [FLINK-22001] Forward exceptions thrown during initialization to the user

flinkbot commented on pull request #15577: URL: https://github.com/apache/flink/pull/15577#issuecomment-817785196 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-22001) Exceptions from JobMaster initialization are not forwarded to the user

[ https://issues.apache.org/jira/browse/FLINK-22001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22001: --- Labels: pull-request-available (was: ) > Exceptions from JobMaster initialization are not

[GitHub] [flink] rmetzger opened a new pull request #15577: [FLINK-22001] Forward exceptions thrown during initialization to the user

rmetzger opened a new pull request #15577: URL: https://github.com/apache/flink/pull/15577 ## What is the purpose of the change - Exceptions during the initialization (thrown by the JobMaster) were not forwarded to the user. This is now guarded by the

[GitHub] [flink] flinkbot commented on pull request #15576: [hotfix] DescriptorProperties#validate has return error exception message

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

[GitHub] [flink] flinkbot edited a comment on pull request #15575: [FLINK-22152][python] Fix the bug of same timers are registered multiple times

flinkbot edited a comment on pull request #15575: URL: https://github.com/apache/flink/pull/15575#issuecomment-817762686 ## CI report: * f8e270a484f0f438c9036cb75037d4ccc5d4cad3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

flinkbot edited a comment on pull request #15570: URL: https://github.com/apache/flink/pull/15570#issuecomment-817676016 ## CI report: * d25d03d4b3793064e7ff77ae7c03bfb60e43536f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15553: [FLINK-22069] Reduce various logging issues

flinkbot edited a comment on pull request #15553: URL: https://github.com/apache/flink/pull/15553#issuecomment-816736380 ## CI report: * 101152d2c0e272d1e3a1d049d5b596d2af2f7fb2 Azure:

[jira] [Closed] (FLINK-21031) JobMasterStopWithSavepointIT test is not run due to wrong name

[ https://issues.apache.org/jira/browse/FLINK-21031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21031. Resolution: Fixed Reenabled in 30baa74b012ffa5e5e9ca149b18691467fc4911c >

[GitHub] [flink] dawidwys merged pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

dawidwys merged pull request #15550: URL: https://github.com/apache/flink/pull/15550 -- 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] dawidwys commented on pull request #15550: [FLINK-21031] Reenable JobMasterStopWithSavepointIT

dawidwys commented on pull request #15550: URL: https://github.com/apache/flink/pull/15550#issuecomment-817772783 Failures are unrelated. 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 above to go

[jira] [Comment Edited] (FLINK-22144) Test display last n exceptions/causes for job restarts in Web UI

[ https://issues.apache.org/jira/browse/FLINK-22144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319427#comment-17319427 ] Dawid Wysakowicz edited comment on FLINK-22144 at 4/12/21, 12:33 PM: -

[GitHub] [flink] hameizi edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

hameizi edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817708105 > Thanks for the fix, could you add a test case? hello , I test the bug in sql-client **Flink SQL>** alter table clickhousetableflink_append_stream set

[GitHub] [flink] hameizi edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

hameizi edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817708105 > Thanks for the fix, could you add a test case? hello , I test the bug in sql-client **Flink SQL>** alter table clickhousetableflink_append_stream set

[jira] [Closed] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long

[ https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16584. -- Fix Version/s: 1.13.0 Resolution: Fixed > Whether to support the long type field in table

[jira] [Commented] (FLINK-22144) Test display last n exceptions/causes for job restarts in Web UI

[ https://issues.apache.org/jira/browse/FLINK-22144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319427#comment-17319427 ] Dawid Wysakowicz commented on FLINK-22144: -- Overall very good job! I really like the feature. I

[jira] [Commented] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long

[ https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319426#comment-17319426 ] Kurt Young commented on FLINK-16584: with 1.13, you can convert Long to TIMESTAMP_LTZ with builtin

[GitHub] [flink] hameizi edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

hameizi edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817708105 > Thanks for the fix, could you add a test case? hello , I test the fix in sql-client **Flink SQL>** alter table clickhousetableflink_append_stream set

[GitHub] [flink] hameizi edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

hameizi edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817708105 > Thanks for the fix, could you add a test case? hello , I test the fix in sql-client **Flink SQL>** alter table clickhousetableflink_append_stream set

[jira] [Closed] (FLINK-15404) How to insert hive table in streaming mode and blink planner

[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15404. -- Resolution: Fixed > How to insert hive table in streaming mode and blink planner >

[jira] [Commented] (FLINK-15404) How to insert hive table in streaming mode and blink planner

[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319424#comment-17319424 ] Kurt Young commented on FLINK-15404: Closing this because streaming write to hive is already

[GitHub] [flink] Myasuka commented on pull request #14744: [FLINK-17511][tests] Rerun RocksDB memory control tests if necessary

Myasuka commented on pull request #14744: URL: https://github.com/apache/flink/pull/14744#issuecomment-817769158 @StephanEwen , sorry for missing this reply during my spring festival holidays. Flink-1.13 did not bump the RocksDB version finally and it seems there is no test failure

[GitHub] [flink] flinkbot commented on pull request #15576: [hotfix] DescriptorProperties#validate has return error exception message

flinkbot commented on pull request #15576: URL: https://github.com/apache/flink/pull/15576#issuecomment-817766384 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] spoon-lz opened a new pull request #15576: [hotfix] DescriptorProperties#validate has return error exception message

spoon-lz opened a new pull request #15576: URL: https://github.com/apache/flink/pull/15576 ## What is the purpose of the change Exceptions are repeatedly caught, resulting in an inability to return the correct error message ## Brief change log ## Verifying this

[GitHub] [flink] dianfu commented on a change in pull request #15575: [FLINK-22152][python] Fix the bug of same timers are registered multiple times

dianfu commented on a change in pull request #15575: URL: https://github.com/apache/flink/pull/15575#discussion_r611568620 ## File path: flink-python/pyflink/fn_execution/timerservice_impl.py ## @@ -59,6 +69,7 @@ def __init__(self, keyed_state_backend:

[GitHub] [flink] flinkbot edited a comment on pull request #15574: [hotfix][docs] Removed reference to fold in window function

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

[GitHub] [flink] flinkbot commented on pull request #15575: [FLINK-22152][python] Fix the bug of same timers are registered multiple times

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

[GitHub] [flink] flinkbot edited a comment on pull request #15573: [hotfix][docs] Fix the consumer committed destination in Kafka doc

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

[GitHub] [flink] flinkbot edited a comment on pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

flinkbot edited a comment on pull request #15570: URL: https://github.com/apache/flink/pull/15570#issuecomment-817676016 ## CI report: * d25d03d4b3793064e7ff77ae7c03bfb60e43536f Azure:

[jira] [Commented] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319415#comment-17319415 ] Stephan Ewen commented on FLINK-21996: -- [~kezhuw] Yes, for operators that are not sources, there

[GitHub] [flink] flinkbot edited a comment on pull request #15553: [FLINK-22069] Reduce various logging issues

flinkbot edited a comment on pull request #15553: URL: https://github.com/apache/flink/pull/15553#issuecomment-816736380 ## CI report: * 101152d2c0e272d1e3a1d049d5b596d2af2f7fb2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

flinkbot edited a comment on pull request #15498: URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824 ## CI report: * dd6519a660ff59adbfd0472ddc90745aa5f9c605 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

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

[jira] [Assigned] (FLINK-22223) Explicitly configure rest.address in distribution config

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3: Assignee: (was: Chesnay Schepler) > Explicitly configure rest.address in

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3: - Description: We should finally update the default config in the distribution: {code}

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3: - Fix Version/s: (was: 1.13.0) 1.14.0 > Explicitly configure

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

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

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3: - Description: We should finally update the default config in the distribution: {code}

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3: - Issue Type: Improvement (was: Bug) > Explicitly configure rest.address in distribution

[GitHub] [flink] zentol commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

zentol commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611565842 ## File path: flink-dist/src/main/resources/flink-conf.yaml ## @@ -145,7 +145,7 @@ jobmanager.execution.failover-strategy: region # The address to

[GitHub] [flink] zentol commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

zentol commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611565551 ## File path: flink-dist/src/main/resources/flink-conf.yaml ## @@ -145,7 +145,7 @@ jobmanager.execution.failover-strategy: region # The address to

[GitHub] [flink] flinkbot commented on pull request #15574: [hotfix][docs] Removed reference to fold in window function

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

[GitHub] [flink] flinkbot commented on pull request #15573: [hotfix][docs] Fix the consumer committed destination in Kafka doc

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

[GitHub] [flink] flinkbot edited a comment on pull request #15567: [FLINK-22215][runtime] RECOVERING state is renamed to RESTORING

flinkbot edited a comment on pull request #15567: URL: https://github.com/apache/flink/pull/15567#issuecomment-817660891 ## CI report: * 93afd72f497847dff4a1048e7ed942303d0e20d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

flinkbot edited a comment on pull request #15496: URL: https://github.com/apache/flink/pull/15496#issuecomment-814224240 ## CI report: * db7d0ea73a5272d44c744fa975520fb3c893a045 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

flinkbot edited a comment on pull request #15498: URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824 ## CI report: * dd6519a660ff59adbfd0472ddc90745aa5f9c605 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

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

[jira] [Comment Edited] (FLINK-22075) Incorrect null outputs in left join

[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319406#comment-17319406 ] Jamie Brandon edited comment on FLINK-22075 at 4/12/21, 11:57 AM: -- >

[jira] [Commented] (FLINK-22075) Incorrect null outputs in left join

[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319406#comment-17319406 ] Jamie Brandon commented on FLINK-22075: --- > remove the fix version tag I have no opinions on the

[jira] [Created] (FLINK-22240) Sanity/phrasing pass for ExternalResourceUtils

Chesnay Schepler created FLINK-22240: Summary: Sanity/phrasing pass for ExternalResourceUtils Key: FLINK-22240 URL: https://issues.apache.org/jira/browse/FLINK-22240 Project: Flink Issue

[GitHub] [flink] zentol commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

zentol commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611564187 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/ExternalResourceUtils.java ## @@ -116,10 +117,25 @@ private

[GitHub] [flink] flinkbot commented on pull request #15575: [FLINK-22152][python] Fix the bug of same timers are registered multiple times

flinkbot commented on pull request #15575: URL: https://github.com/apache/flink/pull/15575#issuecomment-817747692 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-22152) Fix the bug of same timers are registered multiple times

[ https://issues.apache.org/jira/browse/FLINK-22152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22152: --- Labels: pull-request-available (was: ) > Fix the bug of same timers are registered

[GitHub] [flink] HuangXingBo opened a new pull request #15575: [FLINK-22152][python] Fix the bug of same timers are registered multiple times

HuangXingBo opened a new pull request #15575: URL: https://github.com/apache/flink/pull/15575 ## What is the purpose of the change *This pull request will fix the bug of same timers are registered multiple times* ## Brief change log - *deduplicate same timers in Python

[GitHub] [flink] TsReaper commented on pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

TsReaper commented on pull request #15498: URL: https://github.com/apache/flink/pull/15498#issuecomment-817746059 @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] zentol commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

zentol commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611561370 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/ExternalResourceUtils.java ## @@ -116,10 +117,25 @@ private

[jira] [Commented] (FLINK-22134) Test the reactive mode

[ https://issues.apache.org/jira/browse/FLINK-22134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319405#comment-17319405 ] Robert Metzger commented on FLINK-22134: Thanks a lot for testing this feature and for your

[GitHub] [flink] TsReaper commented on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

TsReaper commented on pull request #15525: URL: https://github.com/apache/flink/pull/15525#issuecomment-817744999 @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

[jira] [Assigned] (FLINK-22035) Run Jira Bot periodically with Github Actions

[ https://issues.apache.org/jira/browse/FLINK-22035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-22035: Assignee: Konstantin Knauf > Run Jira Bot periodically with Github Actions >

[jira] [Commented] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319397#comment-17319397 ] Jark Wu commented on FLINK-22233: - Feel free to open pull request for this if you are interested

[GitHub] [flink] flinkbot commented on pull request #15574: [hotfix][docs] Removed reference to fold in window function

flinkbot commented on pull request #15574: URL: https://github.com/apache/flink/pull/15574#issuecomment-817739074 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 #15567: [FLINK-22215][runtime] RECOVERING state is renamed to RESTORING

flinkbot edited a comment on pull request #15567: URL: https://github.com/apache/flink/pull/15567#issuecomment-817660891 ## CI report: * 93afd72f497847dff4a1048e7ed942303d0e20d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15572: [FLINK-22202][parquet] Thread safety in ParquetColumnarRowInputFormat

flinkbot edited a comment on pull request #15572: URL: https://github.com/apache/flink/pull/15572#issuecomment-817715303 ## CI report: * a8680249e8ac09c5faf032f39f05028665ab08ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15548: [FLINK-22082][planner] Nested projection push down doesn't work for d…

flinkbot edited a comment on pull request #15548: URL: https://github.com/apache/flink/pull/15548#issuecomment-816538966 ## CI report: * 64160f09da52e0b873d1fbf1482bb7b6d7c7499e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

flinkbot edited a comment on pull request #15498: URL: https://github.com/apache/flink/pull/15498#issuecomment-814575824 ## CI report: * dd6519a660ff59adbfd0472ddc90745aa5f9c605 Azure:

[jira] [Updated] (FLINK-22075) Incorrect null outputs in left join

[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Brandon updated FLINK-22075: -- Description: I'm left joining a table with itself

[GitHub] [flink] tillrohrmann commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

tillrohrmann commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611550198 ## File path: flink-dist/src/main/resources/flink-conf.yaml ## @@ -145,7 +145,7 @@ jobmanager.execution.failover-strategy: region # The address

[GitHub] [flink] tillrohrmann commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

tillrohrmann commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611549702 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/ExternalResourceUtils.java ## @@ -116,10 +117,25 @@ private

[GitHub] [flink] mans2singh opened a new pull request #15574: [hotfix][docs] Removed reference to fold in window function

mans2singh opened a new pull request #15574: URL: https://github.com/apache/flink/pull/15574 ## What is the purpose of the change * Remove reference to fold function ## Brief change log * Removed deprecated fold function reference ## Verifying this change

[GitHub] [flink] tillrohrmann commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

tillrohrmann commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611549336 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -125,7 +127,13 @@

[jira] [Updated] (FLINK-22239) Improve support for JdbcXaSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22239: - Issue Type: Improvement (was: Task) > Improve support for JdbcXaSinkFunction >

[jira] [Updated] (FLINK-22239) Improve support for JdbcXaSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22239: - Fix Version/s: 1.14.0 > Improve support for JdbcXaSinkFunction > --

[jira] [Updated] (FLINK-22239) Improve support for JdbcXaSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22239: - Description: JdbcXaSinkFunction > Improve support for JdbcXaSinkFunction >

[jira] [Updated] (FLINK-22239) Improve support for JdbcXaSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22239: - Component/s: Connectors / JDBC > Improve support for JdbcXaSinkFunction >

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319388#comment-17319388 ] Dawid Wysakowicz commented on FLINK-18934: -- We agreed offline it is an important bug that

[jira] [Created] (FLINK-22239) Improve support for JdbcXaSinkFunction

Yuan Mei created FLINK-22239: Summary: Improve support for JdbcXaSinkFunction Key: FLINK-22239 URL: https://issues.apache.org/jira/browse/FLINK-22239 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-22231) Add Rule to deprioritize Critical/Blocker Non-Bugs

[ https://issues.apache.org/jira/browse/FLINK-22231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22231: - Description: According to

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319382#comment-17319382 ] Konstantin Knauf commented on FLINK-18934: -- [~dwysakowicz] Why is this a blocker? It is not an

[jira] [Comment Edited] (FLINK-22134) Test the reactive mode

[ https://issues.apache.org/jira/browse/FLINK-22134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319374#comment-17319374 ] Xintong Song edited comment on FLINK-22134 at 4/12/21, 11:22 AM: - cc

[jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18934: - Priority: Major (was: Blocker) > Idle stream does not advance watermark in connected

[jira] [Updated] (FLINK-21397) BufferUnderflowException when read parquet

[ https://issues.apache.org/jira/browse/FLINK-21397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21397: - Priority: Critical (was: Blocker) > BufferUnderflowException when read parquet >

[jira] [Commented] (FLINK-21397) BufferUnderflowException when read parquet

[ https://issues.apache.org/jira/browse/FLINK-21397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319381#comment-17319381 ] Konstantin Knauf commented on FLINK-21397: -- I've deprioritzed this ticket according to

[jira] [Updated] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

[ https://issues.apache.org/jira/browse/FLINK-21278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21278: - Priority: Critical (was: Blocker) > NullpointExecption error is reported when using

[jira] [Commented] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

[ https://issues.apache.org/jira/browse/FLINK-21278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319378#comment-17319378 ] Konstantin Knauf commented on FLINK-21278: -- I deprioritzied this ticket to Critical according

<    1   2   3   4   5   6   7   8   >