[jira] [Updated] (FLINK-20897) Support DataStream batch mode in StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-20897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-20897: --- Fix Version/s: 1.14.0 > Support DataStream batch mode in StreamTableEnvironment > --

[jira] [Updated] (FLINK-18840) Add StreamStatementSet.attachToStream

[ https://issues.apache.org/jira/browse/FLINK-18840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-18840: --- Fix Version/s: 1.14.0 > Add StreamStatementSet.attachToStream >

[jira] [Updated] (FLINK-14437) Drop the legacy planner

[ https://issues.apache.org/jira/browse/FLINK-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-14437: --- Fix Version/s: 1.14.0 > Drop the legacy planner > --- > >

[jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source

[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-18578: --- Fix Version/s: 1.14.0 > Add rejecting checkpoint logic in source > -

[jira] [Updated] (FLINK-21222) Support loopback mode to allow Python UDF worker and client reuse the same Python VM

[ https://issues.apache.org/jira/browse/FLINK-21222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-21222: --- Fix Version/s: 1.14.0 > Support loopback mode to allow Python UDF worker and client reuse th

[jira] [Updated] (FLINK-20435) Refactor ExecNode and ExecEdge

[ https://issues.apache.org/jira/browse/FLINK-20435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-20435: --- Fix Version/s: 1.14.0 > Refactor ExecNode and ExecEdge > -- > >

[jira] [Updated] (FLINK-21091) Support ExecNode json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-21091: --- Fix Version/s: 1.14.0 > Support ExecNode json serialization/deserialization > --

[jira] [Updated] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-22672: --- Fix Version/s: 1.14.0 > Some enhancements for pluggable shuffle service framework >

[jira] [Updated] (FLINK-22700) [FLIP-167] Propagate watermarks to Sink API

[ https://issues.apache.org/jira/browse/FLINK-22700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-22700: --- Fix Version/s: 1.14.0 > [FLIP-167] Propagate watermarks to Sink API > --

[jira] [Created] (FLINK-22915) Extend Flink ML API to support Estimator/Transformer DAG

Dong Lin created FLINK-22915: Summary: Extend Flink ML API to support Estimator/Transformer DAG Key: FLINK-22915 URL: https://issues.apache.org/jira/browse/FLINK-22915 Project: Flink Issue Type:

[jira] [Closed] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22815. Resolution: Fixed > Disable unaligned checkpoints for broadcast partitioning > ---

[jira] [Comment Edited] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356254#comment-17356254 ] Dawid Wysakowicz edited comment on FLINK-22815 at 6/8/21, 6:32 AM: ---

[GitHub] [flink] dawidwys merged pull request #16089: [FLINK-22815][checkpointing][bp-1.12] Disable unaligned checkpoints for broadcast partitioning

dawidwys merged pull request #16089: URL: https://github.com/apache/flink/pull/16089 -- 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, pleas

[jira] [Resolved] (FLINK-22789) Support Hive version 2.3.7

[ https://issues.apache.org/jira/browse/FLINK-22789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22789. Fix Version/s: 1.14.0 Assignee: houshitao Resolution: Fixed Pushed to master: 61cd8d9beff3

[GitHub] [flink] dawidwys merged pull request #16066: [FLINK-22815][checkpointing][bp-1.11] Disable unaligned checkpoints for broadcast partitioning

dawidwys merged pull request #16066: URL: https://github.com/apache/flink/pull/16066 -- 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, pleas

[GitHub] [flink] lirui-apache closed pull request #16015: FLINK-22789 Support Hive version 2.3.7

lirui-apache closed pull request #16015: URL: https://github.com/apache/flink/pull/16015 -- 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, p

[GitHub] [flink] JingsongLi commented on a change in pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

JingsongLi commented on a change in pull request #16027: URL: https://github.com/apache/flink/pull/16027#discussion_r647136489 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/PartitionCommitPredicate.java ## @@ -0,0 +1

[jira] [Created] (FLINK-22914) Use Kafka New Source in Table/SQL connector

Qingsheng Ren created FLINK-22914: - Summary: Use Kafka New Source in Table/SQL connector Key: FLINK-22914 URL: https://issues.apache.org/jira/browse/FLINK-22914 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-22914) Use Kafka new source in Table/SQL connector

[ https://issues.apache.org/jira/browse/FLINK-22914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-22914: -- Summary: Use Kafka new source in Table/SQL connector (was: Use Kafka New Source in Table/SQL

[jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359063#comment-17359063 ] Jun Zhang commented on FLINK-19830: --- May I know any updates for this? > Properly impl

[jira] [Created] (FLINK-22913) Support Python UDF chaining in Python DataStream API

Dian Fu created FLINK-22913: --- Summary: Support Python UDF chaining in Python DataStream API Key: FLINK-22913 URL: https://issues.apache.org/jira/browse/FLINK-22913 Project: Flink Issue Type: Improv

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

flinkbot edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * 9c2560bd72ef6f598231c30468ef0d33c0036b51 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22862) Support profiling for Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-22862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22862: Summary: Support profiling for Python user-defined functions (was: Support profiling in PyFlink) > Suppo

[jira] [Created] (FLINK-22912) Support state ttl in Python DataStream API

Dian Fu created FLINK-22912: --- Summary: Support state ttl in Python DataStream API Key: FLINK-22912 URL: https://issues.apache.org/jira/browse/FLINK-22912 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22911) Align FLIP-136 (Improve interoperability between DataStream and Table API) in PyFlink Table API

Dian Fu created FLINK-22911: --- Summary: Align FLIP-136 (Improve interoperability between DataStream and Table API) in PyFlink Table API Key: FLINK-22911 URL: https://issues.apache.org/jira/browse/FLINK-22911

[GitHub] [flink] dianfu commented on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

dianfu commented on pull request #15441: URL: https://github.com/apache/flink/pull/15441#issuecomment-856461371 @sjwiesman What's the status of this PR? -- 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 t

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359046#comment-17359046 ] Rui Li commented on FLINK-22890: I have pushed a fix to: * master: a2a637e91ea97871bf856

[GitHub] [flink] flinkbot edited a comment on pull request #16040: [FLINK-20926][maxwell][json] Allow to read metadata for maxwell-json format

flinkbot edited a comment on pull request #16040: URL: https://github.com/apache/flink/pull/16040#issuecomment-851972224 ## CI report: * 06a68be2dfa9478285b3231f5b673f8291fce730 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 4e605edcc4946eb4def80e3b97ab386df204dc6f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-10014) Fix the decimal literal parameter problem for arithmetic functions in Table

[ https://issues.apache.org/jira/browse/FLINK-10014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-10014: - Component/s: (was: Table SQL / Runtime) Table SQL / Legacy Planner > Fix th

[jira] [Comment Edited] (FLINK-22910) ShuffleMaster enhancement for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359026#comment-17359026 ] Yingjie Cao edited comment on FLINK-22910 at 6/8/21, 4:15 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #16040: [FLINK-20926][maxwell][json] Allow to read metadata for maxwell-json format

flinkbot edited a comment on pull request #16040: URL: https://github.com/apache/flink/pull/16040#issuecomment-851972224 ## CI report: * 06a68be2dfa9478285b3231f5b673f8291fce730 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 4e605edcc4946eb4def80e3b97ab386df204dc6f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22910) ShuffleMaster enhancement for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359026#comment-17359026 ] Yingjie Cao commented on FLINK-22910: - This ticket cover FLINK-22674 and FLINK-22674

[jira] [Comment Edited] (FLINK-22910) ShuffleMaster enhancement for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359026#comment-17359026 ] Yingjie Cao edited comment on FLINK-22910 at 6/8/21, 4:05 AM:

[jira] [Created] (FLINK-22910) ShuffleMaster enhancement for pluggable shuffle service framework

Yingjie Cao created FLINK-22910: --- Summary: ShuffleMaster enhancement for pluggable shuffle service framework Key: FLINK-22910 URL: https://issues.apache.org/jira/browse/FLINK-22910 Project: Flink

[GitHub] [flink] luoyuxia commented on a change in pull request #15703: [FLINK-22275][table] Support random past for timestamp types in datagen connector

luoyuxia commented on a change in pull request #15703: URL: https://github.com/apache/flink/pull/15703#discussion_r647076914 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenOptions.java ## @@ -77,6 +78,14 @@

[jira] [Closed] (FLINK-22905) Versioned Table's SQL Script was missing a "," at Line 7 which yields Could not execute SQL statement ERROR

[ https://issues.apache.org/jira/browse/FLINK-22905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22905. --- Fix Version/s: 1.13.2 1.14.0 Assignee: liuyan Resolution: Fixed Fixed in

[jira] [Updated] (FLINK-22905) Fix missing comma in SQL example in "Versioned Table" page

[ https://issues.apache.org/jira/browse/FLINK-22905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22905: Summary: Fix missing comma in SQL example in "Versioned Table" page (was: Versioned Table's SQL Script wa

[GitHub] [flink] wuchong merged pull request #16098: [FLINK-22905][docs] Versioned Table's SQL Script was missing a "," at Line 7 which yields Could not execute SQL statement ERROR

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

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

wuchong edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-856413047 Thanks a lot for the contribution @RocMarshal . I though this PR was aiming to add description for the missing `EXIST` command, but this seems adding all SQL synta

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

wuchong commented on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-856413047 Thanks a lot for the contribution @RocMarshal . I though this PR was aiming to add description for the missing `EXIST` command, but this seems adding all SQL syntax. I'm

[GitHub] [flink] lirui-apache closed pull request #16099: [FLINK-22890][hive] HiveTestUtils should create partition after the d…

lirui-apache closed pull request #16099: URL: https://github.com/apache/flink/pull/16099 -- 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, p

[jira] [Assigned] (FLINK-13538) Give field names in deserializers thrown exceptions

[ https://issues.apache.org/jira/browse/FLINK-13538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-13538: -- Assignee: luoyuxia > Give field names in deserializers thrown exceptions > --

[GitHub] [flink] SteNicholas commented on a change in pull request #16040: [FLINK-20926][maxwell][json] Allow to read metadata for maxwell-json format

SteNicholas commented on a change in pull request #16040: URL: https://github.com/apache/flink/pull/16040#discussion_r647080119 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java ## @@ -162,25 +209,7

[jira] [Resolved] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22776. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: dd34846a76484e69b2394ea624c8f0c787eb1a75

[GitHub] [flink] lirui-apache closed pull request #16058: [FLINK-22776][connector-jdbc] Delete casting to byte[] in AbstractJdbcRowConverter class

lirui-apache closed pull request #16058: URL: https://github.com/apache/flink/pull/16058 -- 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, p

[GitHub] [flink] SteNicholas commented on a change in pull request #16040: [FLINK-20926][maxwell][json] Allow to read metadata for maxwell-json format

SteNicholas commented on a change in pull request #16040: URL: https://github.com/apache/flink/pull/16040#discussion_r647078994 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDecodingFormat.java ## @@ -0,0 +1,194 @@ +/* +

[GitHub] [flink] lirui-apache commented on a change in pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

lirui-apache commented on a change in pull request #15653: URL: https://github.com/apache/flink/pull/15653#discussion_r647078775 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/util/JobConfUtils.java ## @@ -40,4 +44,24 @@ publ

[GitHub] [flink] flinkbot edited a comment on pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

flinkbot edited a comment on pull request #16027: URL: https://github.com/apache/flink/pull/16027#issuecomment-851232420 ## CI report: * b57fbad68b84f27f37380dc9202d228f5bdca95f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22889: Assignee: Roman Khachatryan (was: Roman Khachatryan) > JdbcExactlyOnceSinkE2eTest hangs

[jira] [Assigned] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22889: Assignee: Roman Khachatryan > JdbcExactlyOnceSinkE2eTest hangs on azure > ---

[jira] [Updated] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient

[ https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22284: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Null address will

[jira] [Created] (FLINK-22909) Supports change log inputs for event time operators

Jingsong Lee created FLINK-22909: Summary: Supports change log inputs for event time operators Key: FLINK-22909 URL: https://issues.apache.org/jira/browse/FLINK-22909 Project: Flink Issue Typ

[jira] [Updated] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22826: - Priority: Major (was: Blocker) > flink sql1.13.1 causes data loss based on change log stream da

[jira] [Updated] (FLINK-22907) SQL Client queries fails on select statement

[ https://issues.apache.org/jira/browse/FLINK-22907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22907: - Priority: Major (was: Blocker) > SQL Client queries fails on select statement > ---

[jira] [Updated] (FLINK-22904) Performance regression on 25.05.2020 in mapRebalanceMapSink

[ https://issues.apache.org/jira/browse/FLINK-22904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22904: - Fix Version/s: 1.14.0 > Performance regression on 25.05.2020 in mapRebalanceMapSink > --

[GitHub] [flink] leonardBang commented on pull request #16099: [FLINK-22890][hive] HiveTestUtils should create partition after the d…

leonardBang commented on pull request #16099: URL: https://github.com/apache/flink/pull/16099#issuecomment-856396390 Thanks @lirui-apache for the contribution, LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

flinkbot edited a comment on pull request #16027: URL: https://github.com/apache/flink/pull/16027#issuecomment-851232420 ## CI report: * 60e76bcac1cc18cd0e1ca7bad7a19c708bd3d285 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] leonardBang commented on pull request #16099: [FLINK-22890][hive] HiveTestUtils should create partition after the d…

leonardBang commented on pull request #16099: URL: https://github.com/apache/flink/pull/16099#issuecomment-856396203 I got it, and we ignore all orc writer tests for hive `2.0.x` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Updated] (FLINK-22905) Versioned Table's SQL Script was missing a "," at Line 7 which yields Could not execute SQL statement ERROR

[ https://issues.apache.org/jira/browse/FLINK-22905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22905: Component/s: Table SQL / API > Versioned Table's SQL Script was missing a "," at Line 7 which yields Could

[jira] [Commented] (FLINK-22907) SQL Client queries fails on select statement

[ https://issues.apache.org/jira/browse/FLINK-22907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359004#comment-17359004 ] Jark Wu commented on FLINK-22907: - Besides, this seems like a class conflict problem. Pl

[jira] [Commented] (FLINK-22907) SQL Client queries fails on select statement

[ https://issues.apache.org/jira/browse/FLINK-22907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359003#comment-17359003 ] Jark Wu commented on FLINK-22907: - Hi [~rdarling], could you {{set sql-client.verbose=tr

[jira] [Commented] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error

[ https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359002#comment-17359002 ] bigdataf commented on FLINK-22900: -- [~lzljs3620320] , thank you for your attention,I fo

[jira] [Closed] (FLINK-21742) Support REMOVE JAR statement in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-21742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21742. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: b162fbf8b5695ef2c99939c09e66172fec60e1b0 >

[GitHub] [flink] wuchong merged pull request #16013: [FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client

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

[jira] [Comment Edited] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358995#comment-17358995 ] Xintong Song edited comment on FLINK-22889 at 6/8/21, 2:33 AM: ---

[jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type

[ https://issues.apache.org/jira/browse/FLINK-21637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-21637: --- Priority: Major (was: Minor) > Wrong results when filtering by timestamp type > ---

[jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type

[ https://issues.apache.org/jira/browse/FLINK-21637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-21637: --- Labels: (was: auto-deprioritized-major auto-unassigned) > Wrong results when filtering by timestamp type >

[GitHub] [flink] lirui-apache commented on pull request #16099: [FLINK-22890][hive] HiveTestUtils should create partition after the d…

lirui-apache commented on pull request #16099: URL: https://github.com/apache/flink/pull/16099#issuecomment-856390622 > The `HiveTestUtils` change LGTM, `HiveInputFormatPartitionReaderITCase` changes means only hive 2.x version can work with `orc` format？ Thanks @leonardBang for rev

[jira] [Closed] (FLINK-22874) flink table partition trigger doesn't effect as expectation when sink into hive table

[ https://issues.apache.org/jira/browse/FLINK-22874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob closed FLINK-22874. - Release Note: my misunderstanding of streaming partition sink cause this issue, it worked normally after

[jira] [Commented] (FLINK-22874) flink table partition trigger doesn't effect as expectation when sink into hive table

[ https://issues.apache.org/jira/browse/FLINK-22874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358996#comment-17358996 ] Spongebob commented on FLINK-22874: --- Yes my misunderstanding of streaming partition si

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358995#comment-17358995 ] Xintong Song commented on FLINK-22889: -- Instances before the test is ignored: http

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358994#comment-17358994 ] Xintong Song commented on FLINK-22625: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358993#comment-17358993 ] Xintong Song commented on FLINK-22198: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358992#comment-17358992 ] Xintong Song commented on FLINK-22198: -- https://dev.azure.com/apache-flink/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358982#comment-17358982 ] Xintong Song commented on FLINK-20329: -- https://dev.azure.com/apache-flink/apache-f

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

flinkbot edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * a3178a694a6f6fb60a53f0158c020ce2b6d1a4ad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358981#comment-17358981 ] Xintong Song commented on FLINK-22625: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22908: - Description: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=18754&view=l

[jira] [Created] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

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

[jira] [Updated] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22889: - Priority: Critical (was: Blocker) > JdbcExactlyOnceSinkE2eTest hangs on azure > ---

[jira] [Comment Edited] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358977#comment-17358977 ] Xintong Song edited comment on FLINK-22889 at 6/8/21, 1:55 AM: ---

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358977#comment-17358977 ] Xintong Song commented on FLINK-22889: -- Test case is temporally disabled in ee432b2

[GitHub] [flink] flinkbot edited a comment on pull request #16088: [FLINK-22894][table-runtime-blink] Fix rankEnd validation of WindowRank to support top1

flinkbot edited a comment on pull request #16088: URL: https://github.com/apache/flink/pull/16088#issuecomment-855695288 ## CI report: * f4f31d569252bf7841c296990ea1d7cb2adaa35a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16084: [FLINK-22518][docs] Translate the page of "High Availability (HA)" in…

flinkbot edited a comment on pull request #16084: URL: https://github.com/apache/flink/pull/16084#issuecomment-855421865 ## CI report: * e63ab78a60595cd7433de63fa25e647abf0e36d6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * a3178a694a6f6fb60a53f0158c020ce2b6d1a4ad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xintongsong closed pull request #16090: [FLINK-22889][tests] Ignore JdbcExactlyOnceSinkE2eTest temporarily

xintongsong closed pull request #16090: URL: https://github.com/apache/flink/pull/16090 -- 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, pl

[jira] [Commented] (FLINK-22903) Code of method xxx of class "StreamExecCalc$1248" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-22903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358976#comment-17358976 ] Jingsong Lee commented on FLINK-22903: -- Thanks for the reporting, [~xlang] Can you

[jira] [Updated] (FLINK-19719) [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces

[ https://issues.apache.org/jira/browse/FLINK-19719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19719: - Fix Version/s: 1.13.0 > [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces >

[jira] [Updated] (FLINK-19719) [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces

[ https://issues.apache.org/jira/browse/FLINK-19719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19719: - Priority: Major (was: Minor) > [umbrella] FLIP-146: Improve new TableSource and TableSink inter

[jira] [Closed] (FLINK-19719) [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces

[ https://issues.apache.org/jira/browse/FLINK-19719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19719. Resolution: Fixed > [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces > --

[jira] [Updated] (FLINK-19845) Migrate all FileSystemFormatFactory implementations

[ https://issues.apache.org/jira/browse/FLINK-19845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19845: - Parent: (was: FLINK-19719) Issue Type: Improvement (was: Sub-task) > Migrate all Fi

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19722: - Parent: (was: FLINK-19719) Issue Type: Improvement (was: Sub-task) > Pushdown Water

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19722: - Priority: Critical (was: Major) > Pushdown Watermark to SourceProvider (new Source) > -

[jira] [Issue Comment Deleted] (FLINK-20544) ConcurrentModificationException when writing to hive and fail over happened

[ https://issues.apache.org/jira/browse/FLINK-20544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-20544: - Comment: was deleted (was: I think this problem is caused by the reason that the method  *StreamingFileW

[GitHub] [flink] beyond1920 commented on a change in pull request #16088: [FLINK-22894][table-runtime-blink] Fix rankEnd validation of WindowRank to support top1

beyond1920 commented on a change in pull request #16088: URL: https://github.com/apache/flink/pull/16088#discussion_r647045342 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/window/WindowRankOperatorBuilder.java

[GitHub] [flink] RocMarshal commented on pull request #16070: [HOTFIX][docs] Fix typos.

RocMarshal commented on pull request #16070: URL: https://github.com/apache/flink/pull/16070#issuecomment-856367715 @klion26 @xccui Could you help me to review this PR? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

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

RocMarshal removed a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-855849751 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

[GitHub] [flink] flinkbot edited a comment on pull request #16103: [hotfix][docs] Corrected timezone name and column alignment

flinkbot edited a comment on pull request #16103: URL: https://github.com/apache/flink/pull/16103#issuecomment-856293552 ## CI report: * 1c77a88feb1571858fd430fa723c64c49963d205 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   5   >