[GitHub] [flink] JingsongLi commented on a change in pull request #12314: [FLINK-17756][table-api-java] Drop table/view shouldn't take effect o…

2020-05-25 Thread GitBox
JingsongLi commented on a change in pull request #12314: URL: https://github.com/apache/flink/pull/12314#discussion_r429745539 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -682,20 +682,60 @@ public void

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-05-25 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115740#comment-17115740 ] Robert Metzger commented on FLINK-16572: Thanks a lot. Merged as part of

[jira] [Closed] (FLINK-17894) RowGenerator in datagen connector should be serializable

2020-05-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17894. Resolution: Fixed master: edfb7c4d7a004fe60c8cd34ebca88d2f7cc5f212 release-1.11: 

[GitHub] [flink] aljoscha commented on pull request #11972: [FLINK-17058] Adding ProcessingTimeoutTrigger of nested triggers.

2020-05-25 Thread GitBox
aljoscha commented on pull request #11972: URL: https://github.com/apache/flink/pull/11972#issuecomment-633411543 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-15507) Activate local recovery for RocksDB backends by default

2020-05-25 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115767#comment-17115767 ] Zakelly Lan commented on FLINK-15507: - PR submitted. I have run all UTs and e2e tests, and tried the

[jira] [Commented] (FLINK-17907) flink-table-api-java: Compilation failure

2020-05-25 Thread Aihua Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115770#comment-17115770 ] Aihua Li commented on FLINK-17907: -- java version:openjdk version "1.8.0_242" mvn version:Apache Maven

[GitHub] [flink-web] klion26 commented on a change in pull request #247: [FLINK-13683] Translate "Code Style - Component Guide" page into Chinese

2020-05-25 Thread GitBox
klion26 commented on a change in pull request #247: URL: https://github.com/apache/flink-web/pull/247#discussion_r429771409 ## File path: contributing/code-style-and-quality-components.zh.md ## @@ -48,96 +48,95 @@ How to name config keys: } ``` -* The resulting config

[GitHub] [flink] JingsongLi commented on a change in pull request #12314: [FLINK-17756][table-api-java] Drop table/view shouldn't take effect o…

2020-05-25 Thread GitBox
JingsongLi commented on a change in pull request #12314: URL: https://github.com/apache/flink/pull/12314#discussion_r429745539 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -682,20 +682,60 @@ public void

[GitHub] [flink] JingsongLi commented on a change in pull request #12314: [FLINK-17756][table-api-java] Drop table/view shouldn't take effect o…

2020-05-25 Thread GitBox
JingsongLi commented on a change in pull request #12314: URL: https://github.com/apache/flink/pull/12314#discussion_r429745290 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -682,20 +682,60 @@ public void

[GitHub] [flink] zjuwangg commented on pull request #12310: [FLINK-17894][table] RowGenerator in datagen connector should be serializable

2020-05-25 Thread GitBox
zjuwangg commented on pull request #12310: URL: https://github.com/apache/flink/pull/12310#issuecomment-633397428 LGTM. Thanks for your fix. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] KarmaGYZ commented on pull request #12301: [FLINK-16572] [pubsub,e2e] Add check to see if adding a timeout to th…

2020-05-25 Thread GitBox
KarmaGYZ commented on pull request #12301: URL: https://github.com/apache/flink/pull/12301#issuecomment-633401619 It seems something went wrong with the commit message in master branch: `Merge pull request #12301 from Xeli/FLINK-16572-logs`

[jira] [Updated] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs

2020-05-25 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-17916: - Summary: Provide API to separate KafkaShuffle's Producer and Consumer to different jobs (was: Separate

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12260: URL: https://github.com/apache/flink/pull/12260#issuecomment-631229314 ## CI report: * a3a71c5920058f4bbbdc5f11022b8b7736b291cf UNKNOWN * 081a62a66ef0a1b687b10e6b41ed8066b0c7992d Azure:

[GitHub] [flink] flinkbot commented on pull request #12315: [FLINK-17917][yarn] Ignore the external resource with a value of 0 in…

2020-05-25 Thread GitBox
flinkbot commented on pull request #12315: URL: https://github.com/apache/flink/pull/12315#issuecomment-633409833 ## CI report: * 9108fb04b2b8cc0eebc941f7e179fcffed296138 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12309: [FLINK-17889][hive] Hive can not work with filesystem connector

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12309: URL: https://github.com/apache/flink/pull/12309#issuecomment-633345845 ## CI report: * c0f98fc48c889443462b8a1056e50ce8082d0314 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12314: [FLINK-17756][table-api-java] Drop table/view shouldn't take effect o…

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12314: URL: https://github.com/apache/flink/pull/12314#issuecomment-633403476 ## CI report: * b7a68f0f07ab9bb2abc3182d72c0dc80ed59dda1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12028: [FLINK-17553][table]fix plan error when constant exists in group window key

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12028: URL: https://github.com/apache/flink/pull/12028#issuecomment-625656822 ## CI report: * e51960bfa9933fc5515fde87896dbee100ef41f8 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #12316: [FLINK-17896][hive] HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread GitBox
JingsongLi commented on a change in pull request #12316: URL: https://github.com/apache/flink/pull/12316#discussion_r429772225 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicTableFactory.java ## @@ -0,0 +1,88 @@

[jira] [Comment Edited] (FLINK-15507) Activate local recovery for RocksDB backends by default

2020-05-25 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115767#comment-17115767 ] Zakelly Lan edited comment on FLINK-15507 at 5/25/20, 7:23 AM: --- PR

[GitHub] [flink] Myasuka commented on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-25 Thread GitBox
Myasuka commented on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-633393969 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] JingsongLi merged pull request #12310: [FLINK-17894][table] RowGenerator in datagen connector should be serializable

2020-05-25 Thread GitBox
JingsongLi merged pull request #12310: URL: https://github.com/apache/flink/pull/12310 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] rmetzger merged pull request #12301: [FLINK-16572] [pubsub,e2e] Add check to see if adding a timeout to th…

2020-05-25 Thread GitBox
rmetzger merged pull request #12301: URL: https://github.com/apache/flink/pull/12301 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] [Updated] (FLINK-17916) Separate KafkaShuffle's Producer and Consumer to different jobs

2020-05-25 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-17916: - Description: Follow up of FLINK-15670 *Separate sink (producer) and source (consumer) to different

[GitHub] [flink] carp84 commented on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-25 Thread GitBox
carp84 commented on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-633404190 Please also rebase on the latest code base to resolve conflicts. Thanks. This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * edab8aef00bcac9a530501fa64165f344d7c74e7 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #12316: [FLINK-17896][hive] HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread GitBox
twalthr commented on a change in pull request #12316: URL: https://github.com/apache/flink/pull/12316#discussion_r429769415 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicTableFactory.java ## @@ -0,0 +1,88 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12278: URL: https://github.com/apache/flink/pull/12278#issuecomment-632060550 ## CI report: * 30dbfc08b3a4147d18dc00aebb2e31773f1fdbc1 Azure:

[GitHub] [flink] flinkbot commented on pull request #12316: [FLINK-17896][hive] HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread GitBox
flinkbot commented on pull request #12316: URL: https://github.com/apache/flink/pull/12316#issuecomment-633419287 ## CI report: * 2dfb5f41be178ba4f03d8f2627894d3cbc2ea519 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12028: [FLINK-17553][table]fix plan error when constant exists in group window key

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12028: URL: https://github.com/apache/flink/pull/12028#issuecomment-625656822 ## CI report: * e51960bfa9933fc5515fde87896dbee100ef41f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12315: [FLINK-17917][yarn] Ignore the external resource with a value of 0 in…

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12315: URL: https://github.com/apache/flink/pull/12315#issuecomment-633409833 ## CI report: * 9108fb04b2b8cc0eebc941f7e179fcffed296138 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224 ## CI report: * c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN * 9fa966f648aa7d97e6000938970039e83b8e73f2 Travis:

[GitHub] [flink] azagrebin closed pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

2020-05-25 Thread GitBox
azagrebin closed pull request #12270: URL: https://github.com/apache/flink/pull/12270 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-25 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r429777322 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java ## @@ -67,23 +76,211 @@

[GitHub] [flink] cyq89051127 commented on a change in pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

2020-05-25 Thread GitBox
cyq89051127 commented on a change in pull request #12289: URL: https://github.com/apache/flink/pull/12289#discussion_r429744678 ## File path: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/util/HBaseTypeUtils.java ## @@ -81,13 +81,16 @@ public static

[jira] [Commented] (FLINK-17911) K8s e2e: error: timed out waiting for the condition on deployments/flink-native-k8s-session-1

2020-05-25 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115736#comment-17115736 ] Robert Metzger commented on FLINK-17911: Thanks for looking into the issue! I would propose to

[jira] [Updated] (FLINK-17406) Add documentation about dynamic table options

2020-05-25 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17406: --- Summary: Add documentation about dynamic table options (was: add documentation about dynamic table

[GitHub] [flink] flinkbot edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12313: URL: https://github.com/apache/flink/pull/12313#issuecomment-633389597 ## CI report: * c225fa8b2a774a8579501e136004a9d64db89244 Azure:

[GitHub] [flink] flinkbot commented on pull request #12314: [FLINK-17756][table-api-java] Drop table/view shouldn't take effect o…

2020-05-25 Thread GitBox
flinkbot commented on pull request #12314: URL: https://github.com/apache/flink/pull/12314#issuecomment-633403476 ## CI report: * b7a68f0f07ab9bb2abc3182d72c0dc80ed59dda1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12315: [FLINK-17917][yarn] Ignore the external resource with a value of 0 in…

2020-05-25 Thread GitBox
flinkbot commented on pull request #12315: URL: https://github.com/apache/flink/pull/12315#issuecomment-633403452 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] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-25 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r429753738 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SingleLogicalSlot.java ## @@ -168,6 +185,11 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #12309: [FLINK-17889][hive] Hive can not work with filesystem connector

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12309: URL: https://github.com/apache/flink/pull/12309#issuecomment-633345845 ## CI report: * c0f98fc48c889443462b8a1056e50ce8082d0314 Azure:

[GitHub] [flink] carp84 commented on a change in pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-25 Thread GitBox
carp84 commented on a change in pull request #12078: URL: https://github.com/apache/flink/pull/12078#discussion_r429752787 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlStateTestBase.java ## @@ -208,7 +209,7 @@ public void

[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-25 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r429754093 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java ## @@ -67,23 +76,211 @@

[GitHub] [flink] flinkbot commented on pull request #12316: [FLINK-17896][hive] HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread GitBox
flinkbot commented on pull request #12316: URL: https://github.com/apache/flink/pull/12316#issuecomment-633413192 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] [Created] (FLINK-17917) ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0

2020-05-25 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17917: -- Summary: ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0 Key: FLINK-17917 URL:

[jira] [Commented] (FLINK-17911) K8s e2e: error: timed out waiting for the condition on deployments/flink-native-k8s-session-1

2020-05-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115737#comment-17115737 ] Yang Wang commented on FLINK-17911: --- Totally agree with you. Let's keep this ticket open. > K8s e2e:

[jira] [Updated] (FLINK-17916) Separate KafkaShuffle read/write to different environments

2020-05-25 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-17916: - Description: Follow up of FLINK-15670 Separate sink (producer) and source (consumer) to different

[jira] [Updated] (FLINK-17916) Separate KafkaShuffle's Producer and Consumer to different jobs

2020-05-25 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-17916: - Summary: Separate KafkaShuffle's Producer and Consumer to different jobs (was: Separate KafkaShuffle

[GitHub] [flink] JingsongLi commented on pull request #12310: [FLINK-17894][table] RowGenerator in datagen connector should be serializable

2020-05-25 Thread GitBox
JingsongLi commented on pull request #12310: URL: https://github.com/apache/flink/pull/12310#issuecomment-633399177 Thanks @zjuwangg for the review, merging... This is an automated message from the Apache Git Service. To

[GitHub] [flink] rmetzger commented on pull request #12301: [FLINK-16572] [pubsub,e2e] Add check to see if adding a timeout to th…

2020-05-25 Thread GitBox
rmetzger commented on pull request #12301: URL: https://github.com/apache/flink/pull/12301#issuecomment-633399279 Thanks a lot! Merging. This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-25 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r429755150 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkTracker.java ## @@ -0,0 +1,86 @@ +/* + *

[GitHub] [flink] rmetzger commented on pull request #12301: [FLINK-16572] [pubsub,e2e] Add check to see if adding a timeout to th…

2020-05-25 Thread GitBox
rmetzger commented on pull request #12301: URL: https://github.com/apache/flink/pull/12301#issuecomment-633404724 Yes, that's my fault. The GitHub "merge" button hat an error and then produced this merge commit when I clicked "try again" :( Merge commits are actually disabled for

[GitHub] [flink] Zakelly commented on pull request #12312: [FLINK-15507][state backends] Activate local recovery by default

2020-05-25 Thread GitBox
Zakelly commented on pull request #12312: URL: https://github.com/apache/flink/pull/12312#issuecomment-633422736 I have run all UTs and e2e tests, and tried the WordCount streaming job with default settings to make sure the local recovery is activated by checking the local state

[GitHub] [flink] wuchong commented on a change in pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

2020-05-25 Thread GitBox
wuchong commented on a change in pull request #12290: URL: https://github.com/apache/flink/pull/12290#discussion_r429759431 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@ -0,0

[GitHub] [flink] wuchong commented on pull request #12284: [FLINK-17689][kafka][table] Add integration tests for changelog sourc…

2020-05-25 Thread GitBox
wuchong commented on pull request #12284: URL: https://github.com/apache/flink/pull/12284#issuecomment-633432428 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Created] (FLINK-17915) TransitiveClosureITCase>JavaProgramTestBase.testJobWithObjectReuse:113 Error while calling the test program: Could not retrieve JobResult

2020-05-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17915: -- Summary: TransitiveClosureITCase>JavaProgramTestBase.testJobWithObjectReuse:113 Error while calling the test program: Could not retrieve JobResult Key: FLINK-17915 URL:

[jira] [Commented] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots th

2020-05-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115728#comment-17115728 ] Yang Wang commented on FLINK-13009: --- This is a duplicate of FLINK-15534. Since it is a bug of hadoop

[jira] [Created] (FLINK-17916) Separate KafkaShuffle read/write to different environments

2020-05-25 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-17916: Summary: Separate KafkaShuffle read/write to different environments Key: FLINK-17916 URL: https://issues.apache.org/jira/browse/FLINK-17916 Project: Flink Issue

[jira] [Updated] (FLINK-17917) ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0

2020-05-25 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17917: --- Description: *Background*: In FLINK-17390, we leverage

[jira] [Closed] (FLINK-17542) Unify slot request timeout handling for streaming and batch tasks

2020-05-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17542. --- Resolution: Abandoned Superseded by FLINK-17018. > Unify slot request timeout handling for streaming and

[GitHub] [flink] wuchong commented on pull request #12254: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

2020-05-25 Thread GitBox
wuchong commented on pull request #12254: URL: https://github.com/apache/flink/pull/12254#issuecomment-633405996 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] wuchong commented on pull request #12252: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

2020-05-25 Thread GitBox
wuchong commented on pull request #12252: URL: https://github.com/apache/flink/pull/12252#issuecomment-633405699 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] azagrebin commented on pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

2020-05-25 Thread GitBox
azagrebin commented on pull request #12270: URL: https://github.com/apache/flink/pull/12270#issuecomment-633425077 Thanks for the review @tillrohrmann merging this This is an automated message from the Apache Git

[jira] [Created] (FLINK-17918) Jobs with two input operators are loosing data in unaligned checkpoints

2020-05-25 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-17918: -- Summary: Jobs with two input operators are loosing data in unaligned checkpoints Key: FLINK-17918 URL: https://issues.apache.org/jira/browse/FLINK-17918 Project:

[jira] [Commented] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-05-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115789#comment-17115789 ] Yang Wang commented on FLINK-15792: --- [~trohrmann] I have attached a PR for this issue. Since this is a

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

2020-05-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17784: - Fix Version/s: 1.12.0 > Better detection for parquet and orc in hive >

[jira] [Assigned] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

2020-05-25 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-13553: Assignee: (was: Gary Yao) > KvStateServerHandlerTest.readInboundBlocking unstable on Travis

[jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive

2020-05-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17785: - Fix Version/s: 1.12.0 > Refactor orc shim to create a OrcShimFactory in hive >

[jira] [Updated] (FLINK-17896) HiveCatalog can't work with new table factory because of is_generic

2020-05-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17896: Summary: HiveCatalog can't work with new table factory because of is_generic (was: HiveCatalog can work

[jira] [Updated] (FLINK-17916) Separate KafkaShuffle read/write to different environments

2020-05-25 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-17916: - Fix Version/s: (was: 1.12.0) 1.11.0 > Separate KafkaShuffle read/write to

[jira] [Closed] (FLINK-17017) Implement Bulk Slot Allocation

2020-05-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17017. --- Resolution: Abandoned Superseded by FLINK-17018. > Implement Bulk Slot Allocation >

[GitHub] [flink] KarmaGYZ opened a new pull request #12315: [FLINK-17917][yarn] Ignore the external resource with a value of 0 in…

2020-05-25 Thread GitBox
KarmaGYZ opened a new pull request #12315: URL: https://github.com/apache/flink/pull/12315 … ResourceInformationReflector#getExternalResources ## What is the purpose of the change ResourceInformationReflector#getExternalResources should ignore the external resource with a

[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-25 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r429758061 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequest.java ## @@ -0,0 +1,79 @@ +/* + * Licensed to

[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-25 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r429758351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulk.java ## @@ -0,0 +1,57 @@ +/* + * Licensed

[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-25 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r429758258 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequest.java ## @@ -0,0 +1,79 @@ +/* + * Licensed to

[GitHub] [flink] aljoscha commented on a change in pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-25 Thread GitBox
aljoscha commented on a change in pull request #12297: URL: https://github.com/apache/flink/pull/12297#discussion_r429763639 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java ## @@ -46,28

[jira] [Updated] (FLINK-17918) Jobs with two input operators are loosing data with unaligned checkpoints

2020-05-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17918: --- Summary: Jobs with two input operators are loosing data with unaligned checkpoints (was:

[jira] [Updated] (FLINK-17918) Jobs with two input operators are loosing data with unaligned checkpoints

2020-05-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17918: --- Component/s: Runtime / Checkpointing > Jobs with two input operators are loosing data with

[jira] [Assigned] (FLINK-17918) Jobs with two input operators are loosing data in unaligned checkpoints

2020-05-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17918: -- Assignee: Yingjie Cao > Jobs with two input operators are loosing data in unaligned

[GitHub] [flink] fpompermaier commented on a change in pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-25 Thread GitBox
fpompermaier commented on a change in pull request #11900: URL: https://github.com/apache/flink/pull/11900#discussion_r429776768 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalogTestBase.java ## @@ -289,4

[GitHub] [flink] flinkbot edited a comment on pull request #12316: [FLINK-17896][hive] HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12316: URL: https://github.com/apache/flink/pull/12316#issuecomment-633419287 ## CI report: * 2dfb5f41be178ba4f03d8f2627894d3cbc2ea519 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * edab8aef00bcac9a530501fa64165f344d7c74e7 Azure:

[jira] [Created] (FLINK-17914) HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0>

2020-05-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17914: -- Summary: HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0> Key: FLINK-17914 URL:

[jira] [Updated] (FLINK-17896) HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17896: --- Labels: pull-request-available (was: ) > HiveCatalog can work with new table factory

[jira] [Assigned] (FLINK-17896) HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17896: Assignee: Jingsong Lee > HiveCatalog can work with new table factory because of

[GitHub] [flink] JingsongLi opened a new pull request #12316: [FLINK-17896][hive] HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread GitBox
JingsongLi opened a new pull request #12316: URL: https://github.com/apache/flink/pull/12316 ## What is the purpose of the change ``` [ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.ValidationException: Unsupported options found for connector

[GitHub] [flink] wangyang0918 commented on a change in pull request #12296: [FLINK-17814][chinese-translation]Translate native kubernetes document to Chinese

2020-05-25 Thread GitBox
wangyang0918 commented on a change in pull request #12296: URL: https://github.com/apache/flink/pull/12296#discussion_r429757191 ## File path: docs/ops/deployment/native_kubernetes.zh.md ## @@ -24,43 +24,41 @@ specific language governing permissions and limitations under the

[jira] [Updated] (FLINK-17917) ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0

2020-05-25 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17917: --- Description: *Background*: In FLINK-17390, we leverage

[jira] [Closed] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

2020-05-25 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-17822. --- Resolution: Fixed merged into master by 702a339fff03402342362d6f98107150638eef67 merged

[jira] [Updated] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

2020-05-25 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17822: Affects Version/s: (was: 1.10.1) > Nightly Flink CLI end-to-end test failed with >

[GitHub] [flink] flinkbot edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-626611802 ## CI report: * e3ffb15cc38bdbbf1f5a11014782d081edaecea6 UNKNOWN * 1142276931ccfd3ab42da2f44369e649c911aafc Azure:

[jira] [Updated] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

2020-05-25 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17822: Affects Version/s: 1.10.1 > Nightly Flink CLI end-to-end test failed with >

[jira] [Updated] (FLINK-17018) Allocates slots in bulks on pipelined region scheduling

2020-05-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Summary: Allocates slots in bulks on pipelined region scheduling (was: DefaultExecutionSlotAllocator

[jira] [Updated] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

2020-05-25 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17822: Fix Version/s: 1.10.2 > Nightly Flink CLI end-to-end test failed with >

[jira] [Updated] (FLINK-17896) HiveCatalog can work with new table factory because of is_generic

2020-05-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17896: - Description: {code:java} [ERROR] Could not execute SQL statement. Reason:

[jira] [Commented] (FLINK-17911) K8s e2e: error: timed out waiting for the condition on deployments/flink-native-k8s-session-1

2020-05-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115735#comment-17115735 ] Yang Wang commented on FLINK-17911: --- [~rmetzger] Thanks for creating this issue. The root cause is we

[GitHub] [flink] wuchong commented on a change in pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

2020-05-25 Thread GitBox
wuchong commented on a change in pull request #12289: URL: https://github.com/apache/flink/pull/12289#discussion_r429753647 ## File path: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/util/HBaseTypeUtils.java ## @@ -81,13 +81,16 @@ public static

[GitHub] [flink] wuchong commented on a change in pull request #12275: [FLINK-16021][table-common] DescriptorProperties.putTableSchema does …

2020-05-25 Thread GitBox
wuchong commented on a change in pull request #12275: URL: https://github.com/apache/flink/pull/12275#discussion_r429746785 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java ## @@ -241,6 +244,19 @@ public

[jira] [Updated] (FLINK-17917) ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0

2020-05-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17917: --- Labels: pull-request-available (was: ) > ResourceInformationReflector#getExternalResources

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

2020-05-25 Thread GitBox
flinkbot edited a comment on pull request #12260: URL: https://github.com/apache/flink/pull/12260#issuecomment-631229314 ## CI report: * a3a71c5920058f4bbbdc5f11022b8b7736b291cf UNKNOWN * 081a62a66ef0a1b687b10e6b41ed8066b0c7992d Azure:

  1   2   3   4   5   >