[jira] [Assigned] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22113: --- Assignee: Xu Guangheng > UniqueKey constraint is lost with multiple sources join in SQL >

[jira] [Closed] (FLINK-22267) Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered.

[ https://issues.apache.org/jira/browse/FLINK-22267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22267. --- Resolution: Not A Problem > Savepoint an application for source of upsert-kafka, then restart the >

[jira] [Comment Edited] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321916#comment-17321916 ] hayden zhou edited comment on FLINK-22054 at 4/15/21, 5:53 AM: ---

[jira] [Commented] (FLINK-22267) Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered.

[ https://issues.apache.org/jira/browse/FLINK-22267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321920#comment-17321920 ] Jark Wu commented on FLINK-22267: - >From the log information, it did restore source offset state from

[jira] [Closed] (FLINK-22169) Beautify the CliTableauResultView when print

[ https://issues.apache.org/jira/browse/FLINK-22169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22169. -- Resolution: Fixed fixed: 326a564ebc0e397654ccd4e5a83a77ef811c6a76 > Beautify the

[GitHub] [flink] KurtYoung merged pull request #15603: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

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

[GitHub] [flink] KurtYoung commented on a change in pull request #15603: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

KurtYoung commented on a change in pull request #15603: URL: https://github.com/apache/flink/pull/15603#discussion_r613735406 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java ## @@ -233,22 +233,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15607: [FLINK-20779][python][docs] Add documentation for row-based operation in Python Table API

flinkbot edited a comment on pull request #15607: URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925 ## CI report: * 8a62da0c014fc75b3bad145c2fd46fc1809a9c28 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

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

[jira] [Comment Edited] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321916#comment-17321916 ] hayden zhou edited comment on FLINK-22054 at 4/15/21, 5:48 AM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #15438: [FLINK-22000] Set a default character set in InputStreamReader to sol…

flinkbot edited a comment on pull request #15438: URL: https://github.com/apache/flink/pull/15438#issuecomment-810469495 ## CI report: * d16ff5596d58f30aa2752007efc8f7908059596d Azure:

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321917#comment-17321917 ] xx chai commented on FLINK-22281: - Yes, I have added this parameter correctly > flink sql consumer

[jira] [Commented] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321916#comment-17321916 ] hayden zhou commented on FLINK-22054: - [~trohrmann] [~yittg] I can't submit batch jobs more than

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321914#comment-17321914 ] Jark Wu commented on FLINK-22281: - [~chaixiaoxue] you should add the configuration by

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

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

[GitHub] [flink] kezhuw commented on a change in pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

kezhuw commented on a change in pull request #15605: URL: https://github.com/apache/flink/pull/15605#discussion_r613758218 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java ## @@ -64,6 +69,17 @@

[GitHub] [flink] kezhuw commented on a change in pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

kezhuw commented on a change in pull request #15605: URL: https://github.com/apache/flink/pull/15605#discussion_r613755154 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java ## @@ -64,6 +69,17 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

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

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * e16ddc3fb9157cc0b70ea07023202a2ebdd9fe15 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

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

[jira] [Commented] (FLINK-22280) Add XML output format for Flink Table

[ https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321901#comment-17321901 ] Kurt Young commented on FLINK-22280: I also think this would be helpful. [~flacombe] > Add XML

[GitHub] [flink] flinkbot edited a comment on pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

flinkbot edited a comment on pull request #15605: URL: https://github.com/apache/flink/pull/15605#issuecomment-819212302 ## CI report: * e9f7f5526078a9ed65d6403eab5cde7fc82b177b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15607: [FLINK-20779][python][docs] Add documentation for row-based operation in Python Table API

flinkbot edited a comment on pull request #15607: URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925 ## CI report: * 58d729cf2d2ecb4239cd3a2ee380e64f484e7df0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

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

[GitHub] [flink] lirui-apache commented on a change in pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

lirui-apache commented on a change in pull request #15549: URL: https://github.com/apache/flink/pull/15549#discussion_r613742399 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java ## @@ -442,6

[jira] [Commented] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321885#comment-17321885 ] Yang Wang commented on FLINK-22262: --- Could you please share the JobManager logs when you cancel the

[jira] [Updated] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-22262: -- Component/s: Deployment / Kubernetes > Flink on Kubernetes ConfigMaps are created without

[GitHub] [flink] flinkbot edited a comment on pull request #15607: [FLINK-20779][python][docs] Add documentation for row-based operation in Python Table API

flinkbot edited a comment on pull request #15607: URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925 ## CI report: * 58d729cf2d2ecb4239cd3a2ee380e64f484e7df0 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

flinkbot edited a comment on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-785804760 ## CI report: * 4a4f8a643c603007519ebefc4c1e732347b6d3d2 UNKNOWN * 6ebcd56d7080224fcd21f0f22ee467a951feb2e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14484: [FLINK-20722][hive] HiveTableSink should copy the record when convert…

flinkbot edited a comment on pull request #14484: URL: https://github.com/apache/flink/pull/14484#issuecomment-750730068 ## CI report: * adaac76c0ae0a62ca7f156340653128a43bf7b20 Azure:

[GitHub] [flink] KurtYoung commented on a change in pull request #15603: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

KurtYoung commented on a change in pull request #15603: URL: https://github.com/apache/flink/pull/15603#discussion_r613735406 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java ## @@ -233,22 +233,7 @@

[GitHub] [flink] KurtYoung commented on a change in pull request #15603: [FLINK-22169][sql-client] Beautify the CliTableauResultView when print

KurtYoung commented on a change in pull request #15603: URL: https://github.com/apache/flink/pull/15603#discussion_r613735406 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java ## @@ -233,22 +233,7 @@

[GitHub] [flink] KurtYoung commented on a change in pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

KurtYoung commented on a change in pull request #15549: URL: https://github.com/apache/flink/pull/15549#discussion_r613734122 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java ## @@ -442,6

[jira] [Commented] (FLINK-22140) Test the unified binary savepoint

[ https://issues.apache.org/jira/browse/FLINK-22140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321879#comment-17321879 ] Yun Gao commented on FLINK-22140: - Tested the unified binary save-point with [an artificial

[GitHub] [flink] flinkbot edited a comment on pull request #15618: [FLINK-22125][python] Returns None when a key doesn't exist when calling MapState.get()

flinkbot edited a comment on pull request #15618: URL: https://github.com/apache/flink/pull/15618#issuecomment-820024114 ## CI report: * a5030e29742e58a6df2dbca7d7e1ce27a90e8722 Azure:

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

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

[jira] [Comment Edited] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321868#comment-17321868 ] Xu Guangheng edited comment on FLINK-22113 at 4/15/21, 3:25 AM: Hello

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321878#comment-17321878 ] xx chai commented on FLINK-22281: - thanks [~jark] I solve the question . > flink sql consumer kakfa

[GitHub] [flink] flinkbot edited a comment on pull request #14484: [FLINK-20722][hive] HiveTableSink should copy the record when convert…

flinkbot edited a comment on pull request #14484: URL: https://github.com/apache/flink/pull/14484#issuecomment-750730068 ## CI report: * adaac76c0ae0a62ca7f156340653128a43bf7b20 Azure:

[jira] [Comment Edited] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872 ] Yi Tang edited comment on FLINK-22275 at 4/15/21, 3:23 AM: --- Of course. How

[jira] [Comment Edited] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872 ] Yi Tang edited comment on FLINK-22275 at 4/15/21, 3:22 AM: --- Of course. How

[jira] [Commented] (FLINK-6113) Implement split/select with Side Outputs

[ https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321877#comment-17321877 ] Chen Qin commented on FLINK-6113: - Seems community already get rid of split and select transformation in

[jira] [Closed] (FLINK-6113) Implement split/select with Side Outputs

[ https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin closed FLINK-6113. --- Resolution: Fixed > Implement split/select with Side Outputs > > >

[jira] [Updated] (FLINK-6113) Implement split/select with Side Outputs

[ https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-6113: Attachment: split_select.patch > Implement split/select with Side Outputs >

[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: - Attachment: exception.png > Null address will be logged when channel is closed in >

[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: - Description: In NettyPartitionRequestClient#requestSubpartition, when a channel is closed, the

[GitHub] [flink] kezhuw commented on a change in pull request #15601: [FLINK-18071][FLINK-21996][coordination] - Part two: Ensure reliable OperatorEvent to running Task matching

kezhuw commented on a change in pull request #15601: URL: https://github.com/apache/flink/pull/15601#discussion_r613727138 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/CoordinatorEventsExactlyOnceITCase.java ## @@ -285,41 +348,130

[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: - Description: In NettyPartitionRequestClient#requestSubpartition, when a channel is closed, the

[GitHub] [flink] flinkbot commented on pull request #15618: [FLINK-22125][python] Returns None when a key doesn't exist when calling MapState.get()

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

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

Zhilong Hong created FLINK-22284: Summary: Null address will be logged when channel is closed in NettyPartitionRequestClient Key: FLINK-22284 URL: https://issues.apache.org/jira/browse/FLINK-22284

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872 ] Yi Tang commented on FLINK-22275: - Of course. First of all, it is obvious that this option can only be

[GitHub] [flink] flinkbot edited a comment on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

flinkbot edited a comment on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-785804760 ## CI report: * 4a4f8a643c603007519ebefc4c1e732347b6d3d2 UNKNOWN * 6ebcd56d7080224fcd21f0f22ee467a951feb2e0 Azure:

[jira] [Created] (FLINK-22283) GraphiteReporter Metrics named xxx alredy exists

HideOnBush created FLINK-22283: -- Summary: GraphiteReporter Metrics named xxx alredy exists Key: FLINK-22283 URL: https://issues.apache.org/jira/browse/FLINK-22283 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321868#comment-17321868 ] Xu Guangheng edited comment on FLINK-22113 at 4/15/21, 3:00 AM: Hello

[jira] [Commented] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321868#comment-17321868 ] Xu Guangheng commented on FLINK-22113: -- Hello [~jark], Thanks for you reply.  Yes, 

[jira] [Updated] (FLINK-22125) Revisit the return value of MapState.get when a key doesn't exist

[ https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22125: Summary: Revisit the return value of MapState.get when a key doesn't exist (was: Revisit the return

[jira] [Assigned] (FLINK-22125) Revisit the return value of MapState.get when the key doesn't exist

[ https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-22125: --- Assignee: Dian Fu > Revisit the return value of MapState.get when the key doesn't exist >

[jira] [Closed] (FLINK-22273) Add documentation for General Python Group Window Aggregation in Python Table API

[ https://issues.apache.org/jira/browse/FLINK-22273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22273. --- Resolution: Fixed Merged to master via 00a92b4fb188a8c1504279c07504b8fa10ca46e6 > Add documentation for

[GitHub] [flink] dianfu closed pull request #15609: [FLINK-22273][python][docs] Add documentation for General Python Group Window Aggregation in Python Table API

dianfu closed pull request #15609: URL: https://github.com/apache/flink/pull/15609 -- 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] flinkbot commented on pull request #15618: [FLINK-22125][python] Returns None when a key doesn't exist when calling MapState.get()

flinkbot commented on pull request #15618: URL: https://github.com/apache/flink/pull/15618#issuecomment-820020073 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22125) Revisit the return value of MapState.get when the key doesn't exist

[ https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22125: --- Labels: pull-request-available (was: ) > Revisit the return value of MapState.get when the

[GitHub] [flink] dianfu opened a new pull request #15618: [FLINK-22125][python] Returns None when a key doesn't exist when calling MapState.get()

dianfu opened a new pull request #15618: URL: https://github.com/apache/flink/pull/15618 ## What is the purpose of the change *Currently it will throw KeyError when a key doesn't exist when calling MapState.get. This pull request change the behavior of MapState.get to None when

[jira] [Comment Edited] (FLINK-22125) Revisit the return value of MapState.get when the key doesn't exist

[ https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321843#comment-17321843 ] Roc Marshal edited comment on FLINK-22125 at 4/15/21, 2:42 AM: --- When we

[jira] [Commented] (FLINK-22125) Revisit the return value of MapState.get when the key doesn't exist

[ https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321863#comment-17321863 ] Dian Fu commented on FLINK-22125: - Hi [~RocMarshal], there is a method named is_empty() in MapState. You

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321856#comment-17321856 ] xx chai commented on FLINK-22281: - i add the Parameter

[jira] [Closed] (FLINK-16325) A connection check is required, and it needs to be reopened when the JDBC connection is interrupted

[ https://issues.apache.org/jira/browse/FLINK-16325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-16325. Resolution: Invalid > A connection check is required, and it needs to be reopened when the JDBC > connection is

[jira] [Closed] (FLINK-22279) Upload the pipeline.classpaths file in yarn application mode

[ https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-22279. Resolution: Invalid > Upload the pipeline.classpaths file in yarn application mode >

[jira] [Commented] (FLINK-22279) Upload the pipeline.classpaths file in yarn application mode

[ https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321854#comment-17321854 ] todd commented on FLINK-22279: -- Thank you very much, what you said is right. I did not pay attention to

[jira] [Updated] (FLINK-14927) Remove LegacyTimestampTypeInfo/LegacyLocalDateTimeTypeInfo/LegacyInstantTypeInfo when the conversion is not needed

[ https://issues.apache.org/jira/browse/FLINK-14927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14927: Priority: Major (was: Minor) > Remove >

[jira] [Updated] (FLINK-14927) Remove LegacyTimestampTypeInfo/LegacyLocalDateTimeTypeInfo/LegacyInstantTypeInfo when the conversion is not needed

[ https://issues.apache.org/jira/browse/FLINK-14927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14927: Labels: (was: stale-minor) > Remove >

[jira] [Commented] (FLINK-16120) Update the hive section of the connectors doc

[ https://issues.apache.org/jira/browse/FLINK-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321852#comment-17321852 ] Rui Li commented on FLINK-16120: Hive connector doc has been moved to the {{Table & SQL Connectors}}.

[jira] [Updated] (FLINK-16120) Update the hive section of the connectors doc

[ https://issues.apache.org/jira/browse/FLINK-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-16120: --- Release Note: (was: Hive connector doc has been moved to the {{Table & SQL Connectors}}. Closing this

[jira] [Resolved] (FLINK-16120) Update the hive section of the connectors doc

[ https://issues.apache.org/jira/browse/FLINK-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-16120. Release Note: Hive connector doc has been moved to the {{Table & SQL Connectors}}. Closing this one.

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321851#comment-17321851 ] Jark Wu commented on FLINK-22275: - We should discuss about the API/options and behaviors first. >

[jira] [Assigned] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22275: --- Assignee: Yi Tang > Datagen add a max lag option for a series of timestamp-related types >

[jira] [Assigned] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22275: --- Assignee: (was: Yi Tang) > Datagen add a max lag option for a series of timestamp-related

[jira] [Closed] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22281. --- Resolution: Not A Problem > flink sql consumer kakfa canal-json message then sum(amount) >

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321850#comment-17321850 ] Jark Wu commented on FLINK-22281: - If you don't have the full historical data, only the incremental

[jira] [Updated] (FLINK-12085) Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint'

[ https://issues.apache.org/jira/browse/FLINK-12085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacky Yin updated FLINK-12085: -- Labels: (was: stale-minor) > Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint' >

[GitHub] [flink] lirui-apache commented on a change in pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

lirui-apache commented on a change in pull request #15549: URL: https://github.com/apache/flink/pull/15549#discussion_r613709681 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java ## @@ -442,6

[jira] [Updated] (FLINK-22279) Upload the pipeline.classpaths file in yarn application mode

[ https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-22279: -- Priority: Major (was: Blocker) > Upload the pipeline.classpaths file in yarn application mode >

[jira] [Commented] (FLINK-22279) Upload the pipeline.classpaths file in yarn application mode

[ https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321846#comment-17321846 ] Yang Wang commented on FLINK-22279: --- I do not think this is a bug of Flink. The config option 

[jira] [Updated] (FLINK-22280) Add XML output format for Flink Table

[ https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22280: Component/s: (was: Table SQL / API) Table SQL / Ecosystem Formats

[jira] [Commented] (FLINK-22280) Add XML output format for Flink Table

[ https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321845#comment-17321845 ] Jark Wu commented on FLINK-22280: - Yes. I think this can be a xml format. > Add XML output format for

[jira] [Commented] (FLINK-22125) Revisit the return value of MapState.get when the key doesn't exist

[ https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321843#comment-17321843 ] Roc Marshal commented on FLINK-22125: - When we judge whether mapstate is empty or not, there may be

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-22282: - Issue Type: Bug (was: Task) > Move creation of SplitEnumerator to the SourceCoordinator thread

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-22282: - Priority: Critical (was: Major) > Move creation of SplitEnumerator to the SourceCoordinator

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-22282: - Issue Type: Improvement (was: Bug) > Move creation of SplitEnumerator to the SourceCoordinator

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-22282: - Fix Version/s: 1.12.3 1.13.0 > Move creation of SplitEnumerator to the

[jira] [Assigned] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-22282: Assignee: Jiangjie Qin > Move creation of SplitEnumerator to the SourceCoordinator

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Description: I use flink sql to consumer kafka canal-json message the sql is CREATE TABLE

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Description: I use flink sql to consumer kafka canal-json message the sql is CREATE TABLE

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Attachment: screenshot-1.png > flink sql consumer kakfa canal-json message then sum(amount) >

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Description: I use flink sql to consumer kafka canal-json message the sql is CREATE TABLE

[jira] [Created] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

Jiangjie Qin created FLINK-22282: Summary: Move creation of SplitEnumerator to the SourceCoordinator thread Key: FLINK-22282 URL: https://issues.apache.org/jira/browse/FLINK-22282 Project: Flink

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321842#comment-17321842 ] Yi Tang commented on FLINK-22275: - [~jark] You can assign it to me, if no further more discussion

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Component/s: Table SQL / API Affects Version/s: 1.12.0 Description: I use flink sql to

[jira] [Created] (FLINK-22281) flink sql

xx chai created FLINK-22281: --- Summary: flink sql Key: FLINK-22281 URL: https://issues.apache.org/jira/browse/FLINK-22281 Project: Flink Issue Type: Improvement Reporter: xx chai

[GitHub] [flink] KurtYoung commented on a change in pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

KurtYoung commented on a change in pull request #15549: URL: https://github.com/apache/flink/pull/15549#discussion_r613693906 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java ## @@ -442,6

  1   2   3   4   5   6   7   8   9   10   >