[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #14868: URL: https://github.com/apache/flink/pull/14868#issuecomment-773192044 ## CI report: * 016599e0bd95c07d502810e2e3129e4f6cb82184 Azure:

[GitHub] [flink] flinkbot commented on pull request #15070: [FLINK-21542][docs] Add documentation for supporting INSERT INTO spec…

2021-03-02 Thread GitBox
flinkbot commented on pull request #15070: URL: https://github.com/apache/flink/pull/15070#issuecomment-789518377 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-21542) Add documentation for supporting INSERT INTO specific columns

2021-03-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21542: --- Labels: pull-request-available (was: ) > Add documentation for supporting INSERT INTO

[GitHub] [flink] docete opened a new pull request #15070: [FLINK-21542][docs] Add documentation for supporting INSERT INTO spec…

2021-03-02 Thread GitBox
docete opened a new pull request #15070: URL: https://github.com/apache/flink/pull/15070 …ific columns ## What is the purpose of the change We have supported INSERT INTO specific columns in [FLINK-18726](https://issues.apache.org/jira/browse/FLINK-18726), this PR add

[jira] [Commented] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294354#comment-17294354 ] Dawid Wysakowicz commented on FLINK-21553: -- Is FLINK-21482 the root cause? The test fails quite

[GitHub] [flink] tillrohrmann commented on a change in pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-03-02 Thread GitBox
tillrohrmann commented on a change in pull request #14662: URL: https://github.com/apache/flink/pull/14662#discussion_r586187938 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java ## @@ -353,13 +359,17 @@ public void

[jira] [Commented] (FLINK-21135) Reactive Mode: Change Adaptive Scheduler to set infinite parallelism in JobGraph

2021-03-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294352#comment-17294352 ] Robert Metzger commented on FLINK-21135: Yes! The Jira description is actually out of sync with

[jira] [Updated] (FLINK-21550) ZooKeeperHaServicesTest.testSimpleClose fail

2021-03-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21550: -- Priority: Critical (was: Major) > ZooKeeperHaServicesTest.testSimpleClose fail >

[jira] [Updated] (FLINK-21577) SimpleType.simpleTypeFrom(...) complains with "Collection is empty"

2021-03-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21577: --- Labels: pull-request-available (was: ) > SimpleType.simpleTypeFrom(...) complains with

[GitHub] [flink-statefun] tzulitai opened a new pull request #206: [FLINK-21577] [java] Fix instantiation error with SimpleType.simpleTypeFrom()

2021-03-02 Thread GitBox
tzulitai opened a new pull request #206: URL: https://github.com/apache/flink-statefun/pull/206 This was failing with an `Collection is empty` when attempting to copy the enum set of `TypeCharacteristic`s. I think the only reason we need to do a copy, is if users instantiate a

[GitHub] [flink] wangyang0918 commented on pull request #15056: [FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

2021-03-02 Thread GitBox
wangyang0918 commented on pull request #15056: URL: https://github.com/apache/flink/pull/15056#issuecomment-789513555 Rebase master branch and resolve conflicts. This is an automated message from the Apache Git Service. To

[GitHub] [flink] wangyang0918 removed a comment on pull request #15056: [FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

2021-03-02 Thread GitBox
wangyang0918 removed a comment on pull request #15056: URL: https://github.com/apache/flink/pull/15056#issuecomment-789468060 Rebase master branch and resolve conflicts. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-21558) DeclarativeSlotManager starts logging "Could not fulfill resource requirements of job xxx"

2021-03-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21558: -- Parent: FLINK-21075 Issue Type: Sub-task (was: Bug) > DeclarativeSlotManager starts

[jira] [Commented] (FLINK-21436) Speed ​​up the restore of UnionListState

2021-03-02 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294349#comment-17294349 ] fanrui commented on FLINK-21436: h1. Give some test results of increasing the

[jira] [Updated] (FLINK-21436) Speed ​​up the restore of UnionListState

2021-03-02 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-21436: --- Attachment: JM 启动火焰图.svg > Speed ​​up the restore of UnionListState >

[jira] [Updated] (FLINK-21436) Speed ​​up the restore of UnionListState

2021-03-02 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-21436: --- Attachment: akka timeout Exception.png > Speed ​​up the restore of UnionListState >

[jira] [Created] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

2021-03-02 Thread Kezhu Wang (Jira)
Kezhu Wang created FLINK-21578: -- Summary: Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition Key: FLINK-21578 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789495972 ## CI report: * 91cd7acb32af72a0f4d1aba2735fb9e7c4130eff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15062: [FLINK-21549][table-planner-blink] Support json serialization/deserialization for the push-down result of DynamicTableSource and Dyna

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15062: URL: https://github.com/apache/flink/pull/15062#issuecomment-788890431 ## CI report: * bc8213ca609dc86c8d3383502a60b5894ea50678 Azure:

[GitHub] [flink] KarmaGYZ commented on pull request #15032: [FLINK-21511][Connectors/Elasticsearch]Fix BulkProcessor hangs for threads deadlocked

2021-03-02 Thread GitBox
KarmaGYZ commented on pull request #15032: URL: https://github.com/apache/flink/pull/15032#issuecomment-789506319 @zhangmeng0426 The commit message could be changed to "[FLINK-21511][es] Bump Elasticsearch6 version to 6.8.12". You can try to rerun the CI.

[GitHub] [flink] wenlong88 commented on a change in pull request #15062: [FLINK-21549][table-planner-blink] Support json serialization/deserialization for the push-down result of DynamicTableSource an

2021-03-02 Thread GitBox
wenlong88 commented on a change in pull request #15062: URL: https://github.com/apache/flink/pull/15062#discussion_r586163272 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/RexNodeExtractor.scala ## @@ -108,18

[GitHub] [flink] Thesharing commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

2021-03-02 Thread GitBox
Thesharing commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r586086067 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java ## @@ -0,0 +1,143 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-21542) Add documentation for supporting INSERT INTO specific columns

2021-03-02 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294341#comment-17294341 ] Zhenghua Gao commented on FLINK-21542: -- Is it enough to update the syntax of [insert

[GitHub] [flink] Thesharing removed a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-02 Thread GitBox
Thesharing removed a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789489512 Since there's no reference of `Execution#calculatePreferredLocations`, I think it's safe to remove it. I'll rebase my PR

[GitHub] [flink] flinkbot commented on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-02 Thread GitBox
flinkbot commented on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789495972 ## CI report: * 91cd7acb32af72a0f4d1aba2735fb9e7c4130eff UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15062: [FLINK-21549][table-planner-blink] Support json serialization/deserialization for the push-down result of DynamicTableSource and Dyna

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15062: URL: https://github.com/apache/flink/pull/15062#issuecomment-788890431 ## CI report: * 8cb2f9ce280a52bf5be662c458d8b9005ca1728a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15063: [FLINK-21434][python] Fix encoding error when using the fast coder to encode a row-type field containing more than 14 fields

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15063: URL: https://github.com/apache/flink/pull/15063#issuecomment-788890531 ## CI report: * 2effd19d74334e7da661d4774eedbaf303cb3ba8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15056: [FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15056: URL: https://github.com/apache/flink/pull/15056#issuecomment-788712841 ## CI report: * ce5ae5eb11368269976029a47eded3951a4702d5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15018: [FLINK-21460][table api] Use Configuration to create TableEnvironment

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15018: URL: https://github.com/apache/flink/pull/15018#issuecomment-785717193 ## CI report: * 8da9084ba0c7dad6d6b14252ee8ae2d5879f9070 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15028: [FLINK-21115][python] Add AggregatingState and corresponding StateDescriptor for Python DataStream API

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15028: URL: https://github.com/apache/flink/pull/15028#issuecomment-786507942 ## CI report: * 75560398365a84a3493325a4ccb6b55ab667becb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14878: [FLINK-21245][table-planner-blink] Support StreamExecCalc json serialization/deserialization

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #14878: URL: https://github.com/apache/flink/pull/14878#issuecomment-773880848 ## CI report: * 7eed4a448147c00eb56b70e588eaa770a473996a UNKNOWN * 0e30f3541608abedd18beece54297e6815d6ae3c Azure:

[jira] [Closed] (FLINK-21502) Reduce frequency of global re-allocate resources

2021-03-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-21502. Fix Version/s: 1.13.0 Resolution: Done Merged via: * master (1.13):

[jira] [Updated] (FLINK-21502) Reduce frequency of global re-allocate resources

2021-03-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21502: - Component/s: (was: Runtime / Checkpointing) Runtime / Coordination >

[GitHub] [flink] xintongsong closed pull request #15047: [FLINK-21502][coordination] Reduce frequency of global re-allocate re…

2021-03-02 Thread GitBox
xintongsong closed pull request #15047: URL: https://github.com/apache/flink/pull/15047 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

[jira] [Created] (FLINK-21577) SimpleType.simpleTypeFrom(...) complains with "Collection is empty"

2021-03-02 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-21577: --- Summary: SimpleType.simpleTypeFrom(...) complains with "Collection is empty" Key: FLINK-21577 URL: https://issues.apache.org/jira/browse/FLINK-21577

[GitHub] [flink] Thesharing commented on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-02 Thread GitBox
Thesharing commented on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789489512 Since there's no reference of `Execution#calculatePreferredLocations`, I think it's safe to remove it. I'll rebase my PR

[jira] [Commented] (FLINK-11536) cannot start standalone cluster - failed to bind to /0.0.0.0:6123

2021-03-02 Thread nobleyd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294328#comment-17294328 ] nobleyd commented on FLINK-11536: - [~yunta] Hi. I also met this problem, but my taskmanager is not

[GitHub] [flink] flinkbot edited a comment on pull request #15063: [FLINK-21434][python] Fix encoding error when using the fast coder to encode a row-type field containing more than 14 fields

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15063: URL: https://github.com/apache/flink/pull/15063#issuecomment-788890531 ## CI report: * 2effd19d74334e7da661d4774eedbaf303cb3ba8 Azure:

[GitHub] [flink] flinkbot commented on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-02 Thread GitBox
flinkbot commented on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789485774 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 #15056: [FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15056: URL: https://github.com/apache/flink/pull/15056#issuecomment-788712841 ## CI report: * ce5ae5eb11368269976029a47eded3951a4702d5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15057: [FLINK-21552][runtime] Unreserve managed memory if OpaqueMemoryResour…

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15057: URL: https://github.com/apache/flink/pull/15057#issuecomment-788739246 ## CI report: * 5d6398e75a471f89c8e00df6968d6a32493175c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15047: [FLINK-21502][coordination] Reduce frequency of global re-allocate re…

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15047: URL: https://github.com/apache/flink/pull/15047#issuecomment-787603325 ## CI report: * ec740e36bf9c727139ed108ac44c9aca0f7c6838 UNKNOWN * ab02a8b97b3c96f61a5c7d1c0c747c1b3fcde881 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15028: [FLINK-21115][python] Add AggregatingState and corresponding StateDescriptor for Python DataStream API

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15028: URL: https://github.com/apache/flink/pull/15028#issuecomment-786507942 ## CI report: * 75560398365a84a3493325a4ccb6b55ab667becb Azure:

[jira] [Updated] (FLINK-21576) Remove ExecutionVertex#getPreferredLocations

2021-03-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21576: --- Labels: pull-request-available (was: ) > Remove ExecutionVertex#getPreferredLocations >

[GitHub] [flink] zhuzhurk opened a new pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-02 Thread GitBox
zhuzhurk opened a new pull request #15069: URL: https://github.com/apache/flink/pull/15069 ## What is the purpose of the change ExecutionVertex#getPreferredLocations() is superseded by DefaultPreferredLocationsRetriever and is no longer used. Hence, we can remove it. Its test

[GitHub] [flink] godfreyhe commented on a change in pull request #14878: [FLINK-21245][table-planner-blink] Support StreamExecCalc json serialization/deserialization

2021-03-02 Thread GitBox
godfreyhe commented on a change in pull request #14878: URL: https://github.com/apache/flink/pull/14878#discussion_r586155957 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RelDataTypeJsonSerializer.java

[jira] [Assigned] (FLINK-21576) Remove ExecutionVertex#getPreferredLocations

2021-03-02 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-21576: --- Assignee: Zhu Zhu > Remove ExecutionVertex#getPreferredLocations >

[jira] [Created] (FLINK-21576) Remove ExecutionVertex#getPreferredLocations

2021-03-02 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-21576: --- Summary: Remove ExecutionVertex#getPreferredLocations Key: FLINK-21576 URL: https://issues.apache.org/jira/browse/FLINK-21576 Project: Flink Issue Type: Improvement

[GitHub] [flink] wenlong88 commented on a change in pull request #14878: [FLINK-21245][table-planner-blink] Support StreamExecCalc json serialization/deserialization

2021-03-02 Thread GitBox
wenlong88 commented on a change in pull request #14878: URL: https://github.com/apache/flink/pull/14878#discussion_r586102431 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RelDataTypeJsonSerializer.java

[jira] [Created] (FLINK-21575) Replace InputFormat with BulkFormat in HivePartition Reader

2021-03-02 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-21575: -- Summary: Replace InputFormat with BulkFormat in HivePartition Reader Key: FLINK-21575 URL: https://issues.apache.org/jira/browse/FLINK-21575 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15068: [FLINK-21523][Connectors / Hive] Bug fix: ArrayIndexOutOfBoundsException occurs while run a hive strea…

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15068: URL: https://github.com/apache/flink/pull/15068#issuecomment-789459239 ## CI report: * 624bf85a6820617768b5a7a20032e2001641cd27 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15057: [FLINK-21552][runtime] Unreserve managed memory if OpaqueMemoryResour…

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15057: URL: https://github.com/apache/flink/pull/15057#issuecomment-788739246 ## CI report: * 5d6398e75a471f89c8e00df6968d6a32493175c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15039: [FLINK-19763][metrics][tests] Add testNonHeapMetricUsageNotStatic and refine testMetaspaceMetricUsageNotStatic

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15039: URL: https://github.com/apache/flink/pull/15039#issuecomment-786732475 ## CI report: * 82fd66b56c3f1f934f3d1f8164d6284afb44d0c2 Azure:

[GitHub] [flink] wangyang0918 commented on pull request #15056: [FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

2021-03-02 Thread GitBox
wangyang0918 commented on pull request #15056: URL: https://github.com/apache/flink/pull/15056#issuecomment-789468060 Rebase master branch and resolve conflicts. This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source

2021-03-02 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294299#comment-17294299 ] Rui Li commented on FLINK-21523: So if {{HivePartitionFetcherContextBase}} needs the full field

[jira] [Created] (FLINK-21574) WindowDistinctAggregateITCase.testCumulateWindow_GroupingSets unstable

2021-03-02 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21574: - Summary: WindowDistinctAggregateITCase.testCumulateWindow_GroupingSets unstable Key: FLINK-21574 URL: https://issues.apache.org/jira/browse/FLINK-21574 Project: Flink

[jira] [Commented] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source

2021-03-02 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294296#comment-17294296 ] zouyunhe commented on FLINK-21523: -- I print some debug log , the partition field is not found in the

[jira] [Commented] (FLINK-21428) AdaptiveSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing fail

2021-03-02 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294295#comment-17294295 ] Guowei Ma commented on FLINK-21428: ---

[jira] [Commented] (FLINK-20723) testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed due to NoHostAvailableException

2021-03-02 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294294#comment-17294294 ] Guowei Ma commented on FLINK-20723: ---

[GitHub] [flink] flinkbot commented on pull request #15068: [FLINK-21523][Connectors / Hive] Bug fix: ArrayIndexOutOfBoundsException occurs while run a hive strea…

2021-03-02 Thread GitBox
flinkbot commented on pull request #15068: URL: https://github.com/apache/flink/pull/15068#issuecomment-789459239 ## CI report: * 624bf85a6820617768b5a7a20032e2001641cd27 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15067: [FLINK-21178] Task failure will not trigger master hook's reset()

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15067: URL: https://github.com/apache/flink/pull/15067#issuecomment-789445509 ## CI report: * 2748160748dcde3538202320ec4b87e5d07b775f Azure:

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

2021-03-02 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294293#comment-17294293 ] Guowei Ma commented on FLINK-15493: ---

[jira] [Commented] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source

2021-03-02 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294292#comment-17294292 ] Rui Li commented on FLINK-21523: I guess it's because the projection pushdown doesn't include the

[jira] [Commented] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-02 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294291#comment-17294291 ] Guowei Ma commented on FLINK-21553: ---

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-03-02 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294290#comment-17294290 ] Guowei Ma commented on FLINK-20329: ---

[jira] [Updated] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source

2021-03-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21523: --- Labels: pull-request-available (was: ) > ArrayIndexOutOfBoundsException occurs while run a

[GitHub] [flink] flinkbot commented on pull request #15068: [FLINK-21523][Connectors / Hive] ArrayIndexOutOfBoundsException occurs while run a hive strea…

2021-03-02 Thread GitBox
flinkbot commented on pull request #15068: URL: https://github.com/apache/flink/pull/15068#issuecomment-789449204 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 #15067: [FLINK-21178] Task failure will not trigger master hook's reset()

2021-03-02 Thread GitBox
flinkbot commented on pull request #15067: URL: https://github.com/apache/flink/pull/15067#issuecomment-789445509 ## CI report: * 2748160748dcde3538202320ec4b87e5d07b775f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] KevinyhZou opened a new pull request #15068: ArrayIndexOutOfBoundsException occurs while run a hive strea…

2021-03-02 Thread GitBox
KevinyhZou opened a new pull request #15068: URL: https://github.com/apache/flink/pull/15068 ## What is the purpose of the change Bug fix for array out of bounds exception while running a hive streaming job with partitioned table source, the partition feilds is not found in the

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-03-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294288#comment-17294288 ] xiaogang zhou commented on FLINK-21543: --- And Can we support a fifo auto compaction java api? I

[GitHub] [flink] flinkbot commented on pull request #15067: [FLINK-21178] Task failure will not trigger master hook's reset()

2021-03-02 Thread GitBox
flinkbot commented on pull request #15067: URL: https://github.com/apache/flink/pull/15067#issuecomment-789442851 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] crazyzhou opened a new pull request #15067: [FLINK-21178] Task failure will not trigger master hook's reset()

2021-03-02 Thread GitBox
crazyzhou opened a new pull request #15067: URL: https://github.com/apache/flink/pull/15067 ## What is the purpose of the change This supersedes #14890 that fixes failure master builds. With FLINK-20222 fix, it brings the regression that the master hook's `reset()` is

[GitHub] [flink] flinkbot edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-788795982 ## CI report: * 1ecb25b4192385c392fe43e0b3d7f3244ba9ca84 Azure:

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-03-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294281#comment-17294281 ] xiaogang zhou commented on FLINK-21543: --- !image-2021-03-03-13-09-01-695.png! 主要还是想问下为啥这个creation

[jira] [Updated] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-03-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-21543: -- Attachment: image-2021-03-03-13-09-01-695.png > when using FIFO compaction, I found sst being

[GitHub] [flink] flinkbot edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-788795982 ## CI report: * 1ecb25b4192385c392fe43e0b3d7f3244ba9ca84 Azure:

[GitHub] [flink] shouweikun commented on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-02 Thread GitBox
shouweikun commented on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-789420079 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-21570) Add Job ID to RuntimeContext

2021-03-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21570: --- Labels: pull-request-available (was: ) > Add Job ID to RuntimeContext >

[GitHub] [flink] kezhuw commented on pull request #15053: [FLINK-21570][runtime] Add job ID to RuntimeContext

2021-03-02 Thread GitBox
kezhuw commented on pull request #15053: URL: https://github.com/apache/flink/pull/15053#issuecomment-789410967 Hi @rkhachatryan, I am a bit worry about whether the type `Optional` is a right choice for reasons: * Most `getJobId` expect a not nullable `JobID`. * The only path

[GitHub] [flink] crazyzhou commented on pull request #14890: [FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset()

2021-03-02 Thread GitBox
crazyzhou commented on pull request #14890: URL: https://github.com/apache/flink/pull/14890#issuecomment-789410205 > I have reverted this commit to make master can compile. Please open another PR to fix the conflicts. Sorry for not rebasing master, I can raise another one based on

[GitHub] [flink] wuchong commented on pull request #14890: [FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset()

2021-03-02 Thread GitBox
wuchong commented on pull request #14890: URL: https://github.com/apache/flink/pull/14890#issuecomment-789406159 I have reverted this commit to make master can compile. Please open another PR to fix the conflicts. This is

[GitHub] [flink] wangyang0918 commented on pull request #14890: [FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset()

2021-03-02 Thread GitBox
wangyang0918 commented on pull request #14890: URL: https://github.com/apache/flink/pull/14890#issuecomment-789404500 cc @becketqin It seems that this PR breaks the master branch. Because the `CheckpointCoordinatorBuilder#setJobId` has been removed. Now the Flink master branch could not

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-03-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294250#comment-17294250 ] xiaogang zhou commented on FLINK-21543: --- !image-2021-03-03-11-35-11-458.png! evidence can be

[jira] [Updated] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-03-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-21543: -- Attachment: image-2021-03-03-11-35-11-458.png > when using FIFO compaction, I found sst being

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-03-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294247#comment-17294247 ] xiaogang zhou commented on FLINK-21543: --- [~yunta] As level compaction can cause too many

[jira] [Updated] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-03-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-21543: -- Attachment: LOG (2) > when using FIFO compaction, I found sst being deleted on the first

[GitHub] [flink] xiaoHoly commented on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disable for

2021-03-02 Thread GitBox
xiaoHoly commented on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-789396324 @becketqin ,Hi qin ,Is the current PR continuing to review? This is an automated message from the Apache Git

[jira] [Created] (FLINK-21573) Support expression reuse in codegen

2021-03-02 Thread Benchao Li (Jira)
Benchao Li created FLINK-21573: -- Summary: Support expression reuse in codegen Key: FLINK-21573 URL: https://issues.apache.org/jira/browse/FLINK-21573 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-21298) Support 'USE MODULES' syntax

2021-03-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21298. --- Resolution: Fixed Fixed in master: 57decce1e52127b800226daf0a4706496994d9bb > Support 'USE MODULES' syntax

[GitHub] [flink] wuchong merged pull request #15005: [FLINK-21298][table] Support 'USE MODULES' syntax both in SQL parser, TableEnvironment and SQL CLI

2021-03-02 Thread GitBox
wuchong merged pull request #15005: URL: https://github.com/apache/flink/pull/15005 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] [Closed] (FLINK-21572) USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in Flink SQL client.

2021-03-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21572. --- Resolution: Duplicate > USE DATABASE & USE CATALOG fails with quoted identifiers containing > characters

[jira] [Updated] (FLINK-20977) USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in Flink SQL client

2021-03-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20977: Summary: USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in

[jira] [Assigned] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21553: --- Assignee: Andy > WindowDistinctAggregateITCase#testHopWindow_Cube is unstable >

[jira] [Commented] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-02 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294240#comment-17294240 ] Andy commented on FLINK-21553: -- Could you assign the issue to me ? I would like to find out the root cause.

[GitHub] [flink] flinkbot edited a comment on pull request #15047: [FLINK-21502][coordination] Reduce frequency of global re-allocate re…

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15047: URL: https://github.com/apache/flink/pull/15047#issuecomment-787603325 ## CI report: * ec740e36bf9c727139ed108ac44c9aca0f7c6838 UNKNOWN * 030b3a45312dddf7ba6e9de8fcfb8448f6af98ec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15018: [FLINK-21460][table api] Use Configuration to create TableEnvironment

2021-03-02 Thread GitBox
flinkbot edited a comment on pull request #15018: URL: https://github.com/apache/flink/pull/15018#issuecomment-785717193 ## CI report: * 79dcd94be9865e972c7be940d6e6d4ae35426fd0 Azure:

[jira] [Commented] (FLINK-21566) Improve error message for "Unsupported casting"

2021-03-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294239#comment-17294239 ] Jark Wu commented on FLINK-21566: - Improving error messages is always good. However, currently the

[jira] [Commented] (FLINK-21565) Support more integer types in TIMESTAMPADD

2021-03-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294238#comment-17294238 ] Jark Wu commented on FLINK-21565: - Sounds good to me. > Support more integer types in TIMESTAMPADD >

[jira] [Commented] (FLINK-21563) Support using computed columns when defining new computed columns

2021-03-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294237#comment-17294237 ] Jark Wu commented on FLINK-21563: - Not sure how SQL standard and other database vendors handle this. I

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-03-02 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294236#comment-17294236 ] Yun Tang commented on FLINK-21543: -- [~zhoujira86] First of all, do not use any third-party unofficial

  1   2   3   4   5   >