[jira] [Updated] (FLINK-22004) Translate Flink Roadmap to Chinese.

2021-04-11 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22004: - Attachment: Screen Shot 2021-04-11 at 10.24.02 PM.png > Translate Flink Roadmap to Chinese. >

[jira] [Commented] (FLINK-22004) Translate Flink Roadmap to Chinese.

2021-04-11 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318795#comment-17318795 ] Yuan Mei commented on FLINK-22004: -- local build of the updated page: !Screen Shot 2021-04-11 at

[GitHub] [flink] flinkbot edited a comment on pull request #15373: [FLINK-21699][Runtime] Call SecurityUtils.uninstall() to clean up system properties

2021-04-11 Thread GitBox
flinkbot edited a comment on pull request #15373: URL: https://github.com/apache/flink/pull/15373#issuecomment-806878665 ## CI report: * 74eb04c596ea901aaa3b0d103630b02e09dab391 Azure:

[GitHub] [flink] guoweiM commented on a change in pull request #15490: [FLINK-21850][docs] Improve config descriptions of sort-merge blocking shuffle and remove outdated document

2021-04-11 Thread GitBox
guoweiM commented on a change in pull request #15490: URL: https://github.com/apache/flink/pull/15490#discussion_r611187544 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/NettyShuffleEnvironmentConfigurationTest.java ## @@ -76,4 +80,25 @@

[GitHub] [flink] guoweiM commented on a change in pull request #15490: [FLINK-21850][docs] Improve config descriptions of sort-merge blocking shuffle and remove outdated document

2021-04-11 Thread GitBox
guoweiM commented on a change in pull request #15490: URL: https://github.com/apache/flink/pull/15490#discussion_r611187544 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/NettyShuffleEnvironmentConfigurationTest.java ## @@ -76,4 +80,25 @@

[jira] [Commented] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager

2021-04-11 Thread Phil Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318802#comment-17318802 ] Phil Chen commented on FLINK-22189: --- It seems like this issue is only when using flink with hadoop

[jira] [Created] (FLINK-22200) Flink SQL Client Error with: Could not find any factory for identifier 'hudi' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory

2021-04-11 Thread Phil Chen (Jira)
Phil Chen created FLINK-22200: - Summary: Flink SQL Client Error with: Could not find any factory for identifier 'hudi' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory Key: FLINK-22200

[jira] [Commented] (FLINK-22129) OrcFileSystemITCase hangs on azure

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

[jira] [Updated] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

2021-04-11 Thread Lsw_aka_laplace (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-22196: Component/s: Table SQL / Planner Affects Version/s: 1.12.2

[jira] [Created] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist

2021-04-11 Thread Lsw_aka_laplace (Jira)
Lsw_aka_laplace created FLINK-22196: --- Summary: FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist Key: FLINK-22196 URL:

[GitHub] [flink] xmarker commented on pull request #15523: [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

2021-04-11 Thread GitBox
xmarker commented on pull request #15523: URL: https://github.com/apache/flink/pull/15523#issuecomment-817269341 @flinkbot run travis -- 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] flinkbot edited a comment on pull request #15523: [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

2021-04-11 Thread GitBox
flinkbot edited a comment on pull request #15523: URL: https://github.com/apache/flink/pull/15523#issuecomment-815495525 ## CI report: * 550f2676535859243f738113dd5258edd0655e81 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15523: [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

2021-04-11 Thread GitBox
flinkbot edited a comment on pull request #15523: URL: https://github.com/apache/flink/pull/15523#issuecomment-815495525 ## CI report: * 550f2676535859243f738113dd5258edd0655e81 Azure:

[GitHub] [flink] JackWangCS commented on pull request #15373: [FLINK-21699][Runtime] Call SecurityUtils.uninstall() to clean up system properties

2021-04-11 Thread GitBox
JackWangCS commented on pull request #15373: URL: https://github.com/apache/flink/pull/15373#issuecomment-817274116 Hi @EronWright, thanks for your comment. I did not realize these properties are ephemeral, I agree that it's not necessary to call the uninstall() method before calling

[jira] [Commented] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

2021-04-11 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318706#comment-17318706 ] Yuan Mei commented on FLINK-17912: -- I did not see a single case failure for half-year, I guess we can

[GitHub] [flink] JackWangCS commented on pull request #15373: [FLINK-21699][Runtime] Call SecurityUtils.uninstall() to clean up system properties

2021-04-11 Thread GitBox
JackWangCS commented on pull request #15373: URL: https://github.com/apache/flink/pull/15373#issuecomment-817288859 Another thing is that if a user implements a new `SecurityModule`, the `uninstall()` may be used to do some cleanups such as destroying the screte file. If the `uninstall()`

[GitHub] [flink] JackWangCS edited a comment on pull request #15373: [FLINK-21699][Runtime] Call SecurityUtils.uninstall() to clean up system properties

2021-04-11 Thread GitBox
JackWangCS edited a comment on pull request #15373: URL: https://github.com/apache/flink/pull/15373#issuecomment-817274116 Hi @EronWright, thanks for your comment. I did not realize these properties are ephemeral, I agree that it's not necessary to call the uninstall() method before

[jira] [Created] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

2021-04-11 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22197: - Summary: UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException Key: FLINK-22197 URL: https://issues.apache.org/jira/browse/FLINK-22197

[jira] [Updated] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

2021-04-11 Thread Lsw_aka_laplace (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-22196: Description: Well since we have supported project push-down, some primary-key in original

[jira] [Commented] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

2021-04-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318682#comment-17318682 ] Jark Wu commented on FLINK-22196: - Looks like a bug. But if partial fields of primary key is projected,

[jira] [Commented] (FLINK-21699) SecurityUtils JaasModule make JVM dirty

2021-04-11 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318697#comment-17318697 ] jackwangcs commented on FLINK-21699: Hi [~tonychan], how does your microservice submit the job to

[jira] [Comment Edited] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

2021-04-11 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318706#comment-17318706 ] Yuan Mei edited comment on FLINK-17912 at 4/11/21, 9:22 AM: I did not see a

[GitHub] [flink] flinkbot edited a comment on pull request #15373: [FLINK-21699][Runtime] Call SecurityUtils.uninstall() to clean up system properties

2021-04-11 Thread GitBox
flinkbot edited a comment on pull request #15373: URL: https://github.com/apache/flink/pull/15373#issuecomment-806878665 ## CI report: * 14f4eb622efbea621544e5b0a9f2bc628285da73 Azure:

[jira] [Updated] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

2021-04-11 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22198: -- Description:

[jira] [Commented] (FLINK-22178) Support ignore-first-line option in new csv format

2021-04-11 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318678#comment-17318678 ] jinfeng commented on FLINK-22178: - [~ykt836]  I think ignore-first-line option is needed only when we

[GitHub] [flink] flinkbot edited a comment on pull request #15523: [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

2021-04-11 Thread GitBox
flinkbot edited a comment on pull request #15523: URL: https://github.com/apache/flink/pull/15523#issuecomment-815495525 ## CI report: * 550f2676535859243f738113dd5258edd0655e81 Azure:

[jira] [Created] (FLINK-22199) The JDBC connector does not support TIMESTAMP(6) WITH LOCAL TIME ZONE NOT NULL.

2021-04-11 Thread Tomoyuki NAKAMURA (Jira)
Tomoyuki NAKAMURA created FLINK-22199: - Summary: The JDBC connector does not support TIMESTAMP(6) WITH LOCAL TIME ZONE NOT NULL. Key: FLINK-22199 URL: https://issues.apache.org/jira/browse/FLINK-22199

[jira] [Commented] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

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

[jira] [Commented] (FLINK-22181) SourceNAryInputChainingITCase hangs on azure

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

[jira] [Commented] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

2021-04-11 Thread Lsw_aka_laplace (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318664#comment-17318664 ] Lsw_aka_laplace commented on FLINK-22196: - cc [~jark] cc [~godfreyhe]   >

[jira] [Comment Edited] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

2021-04-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318682#comment-17318682 ] Jark Wu edited comment on FLINK-22196 at 4/11/21, 7:50 AM: --- Looks like a bug.

[GitHub] [flink] flinkbot edited a comment on pull request #15373: [FLINK-21699][Runtime] Call SecurityUtils.uninstall() to clean up system properties

2021-04-11 Thread GitBox
flinkbot edited a comment on pull request #15373: URL: https://github.com/apache/flink/pull/15373#issuecomment-806878665 ## CI report: * 14f4eb622efbea621544e5b0a9f2bc628285da73 Azure:

[GitHub] [flink] JackWangCS edited a comment on pull request #15373: [FLINK-21699][Runtime] Call SecurityUtils.uninstall() to clean up system properties

2021-04-11 Thread GitBox
JackWangCS edited a comment on pull request #15373: URL: https://github.com/apache/flink/pull/15373#issuecomment-817288859 Another thing is that if a user implements a new `SecurityModule`, the `uninstall()` may be used to do some cleanups such as destroying the screte file. If the

[jira] [Created] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException

2021-04-11 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22195: - Summary: YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException Key: FLINK-22195 URL: https://issues.apache.org/jira/browse/FLINK-22195

[jira] [Created] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

2021-04-11 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22198: - Summary: org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang. Key: FLINK-22198 URL: https://issues.apache.org/jira/browse/FLINK-22198 Project: Flink

[GitHub] [flink] KurtYoung commented on a change in pull request #15155: [FLINK-21660][table-api-java][hive] Stop using is_generic to differen…

2021-04-11 Thread GitBox
KurtYoung commented on a change in pull request #15155: URL: https://github.com/apache/flink/pull/15155#discussion_r611144110 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -822,18 +843,15 @@ public

[jira] [Updated] (FLINK-22200) Flink SQL Client Error with: Could not find any factory for identifier 'hudi' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory

2021-04-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22200: Component/s: (was: Table SQL / Client) Table SQL / Ecosystem > Flink SQL Client

[jira] [Commented] (FLINK-22200) Flink SQL Client Error with: Could not find any factory for identifier 'hudi' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory

2021-04-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318871#comment-17318871 ] Jark Wu commented on FLINK-22200: - cc [~danny0405] > Flink SQL Client Error with: Could not find any

[GitHub] [flink] JohnTeslaa closed pull request #15118: Fix client

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

[jira] [Created] (FLINK-22201) Incorrect output for simple sql query

2021-04-11 Thread Jamie Brandon (Jira)
Jamie Brandon created FLINK-22201: - Summary: Incorrect output for simple sql query Key: FLINK-22201 URL: https://issues.apache.org/jira/browse/FLINK-22201 Project: Flink Issue Type: Bug

[GitHub] [flink] StephanEwen opened a new pull request #15557: [FLINK-21996][coordination] - Part one: Tests and adjusted threading model

2021-04-11 Thread GitBox
StephanEwen opened a new pull request #15557: URL: https://github.com/apache/flink/pull/15557 ## Purpose of this PR This is the first part of the fix for [FLINK-21996](https://issues.apache.org/jira/browse/FLINK-21996). ### (1) Refactoring of Number Sequence Source The

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

2021-04-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21996: --- Labels: pull-request-available (was: ) > Transient RPC failure without TaskManager failure

<    1   2