[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * 43550b885f3b52e7db0f82cbbf84c4086b66456c UNKNOWN * 087283320d89633e8c0cb08a331a0c0fe135549e Azure:

[jira] [Closed] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception

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

[GitHub] [flink] wuchong merged pull request #16301: [FLINK-23162][docs] Updated column expression which throws exception

wuchong merged pull request #16301: URL: https://github.com/apache/flink/pull/16301 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception

[ https://issues.apache.org/jira/browse/FLINK-23162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370157#comment-17370157 ] Jark Wu commented on FLINK-23162: - Good catch! > Create table uses time_ltz in the column name and it's

[jira] [Assigned] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception

[ https://issues.apache.org/jira/browse/FLINK-23162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-23162: --- Assignee: Mans Singh > Create table uses time_ltz in the column name and it's expression which >

[jira] [Updated] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception

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

[jira] [Commented] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370154#comment-17370154 ] godfrey he commented on FLINK-23135: [~zhengjiewen] could you provide the ddl statements, I can not

[GitHub] [flink] tisonkun commented on pull request #16300: [Hotfix][docs] Fixed typos.

tisonkun commented on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869092410 https://github.com/apache/flink/blob/2a7e7d7e92f0610502e59f6104391a83dc8b5692/flink-yarn/pom.xml#L44-L54 @RocMarshal nope. Our codebase is in the pattern

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * c4cfa5cb3a3e5c862c5107db1a67711dc6c4b8ea Azure:

[GitHub] [flink] RocMarshal edited a comment on pull request #16300: [Hotfix][docs] Fixed typos.

RocMarshal edited a comment on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869091110 https://user-images.githubusercontent.com/64569824/123531173-dc58a400-d734-11eb-8509-b97fbbbdbdab.png;>

[GitHub] [flink] RocMarshal commented on pull request #16300: [Hotfix][docs] Fixed typos.

RocMarshal commented on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869091110 https://user-images.githubusercontent.com/64569824/123531173-dc58a400-d734-11eb-8509-b97fbbbdbdab.png;>

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * c4cfa5cb3a3e5c862c5107db1a67711dc6c4b8ea Azure:

[jira] [Closed] (FLINK-23120) ByteArrayWrapperSerializer.serialize should use writeInt to serialize the length

[ https://issues.apache.org/jira/browse/FLINK-23120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23120. --- Resolution: Fixed Fixed in - master via 2a7e7d7e92f0610502e59f6104391a83dc8b5692 - release-1.13 via 

[GitHub] [flink] dianfu closed pull request #16258: [FLINK-23120][python] Fix ByteArrayWrapperSerializer.serialize to use writeInt to serialize the length

dianfu closed pull request #16258: URL: https://github.com/apache/flink/pull/16258 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] tisonkun commented on pull request #16300: [Hotfix][docs] Fixed typos.

tisonkun commented on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869088182  It is not a typo. Closing... -- This is an

[GitHub] [flink] tisonkun closed pull request #16300: [Hotfix][docs] Fixed typos.

tisonkun closed pull request #16300: URL: https://github.com/apache/flink/pull/16300 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] gaoyunhaii commented on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

gaoyunhaii commented on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-869088100 Hi @dawidwys very thanks for the reviewing! I have updated the PR according to the comments~ -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

gaoyunhaii commented on a change in pull request #15055: URL: https://github.com/apache/flink/pull/15055#discussion_r659249409 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -695,6 +697,27 @@ protected void

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

gaoyunhaii commented on a change in pull request #15055: URL: https://github.com/apache/flink/pull/15055#discussion_r659249409 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -695,6 +697,27 @@ protected void

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

gaoyunhaii commented on a change in pull request #15055: URL: https://github.com/apache/flink/pull/15055#discussion_r659249409 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -695,6 +697,27 @@ protected void

[GitHub] [flink] dianfu commented on pull request #16258: [FLINK-23120][python] Fix ByteArrayWrapperSerializer.serialize to use writeInt to serialize the length

dianfu commented on pull request #16258: URL: https://github.com/apache/flink/pull/16258#issuecomment-869087703 @StephanEwen @HuangXingBo Thanks a lot for the review. I'm merging this PR to catch up with the bugfix release of 1.13 as this is a series bug for MapState in Python DataStream

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * c4cfa5cb3a3e5c862c5107db1a67711dc6c4b8ea Azure:

[jira] [Updated] (FLINK-21086) Support checkpoint alignment with finished input channels

[ https://issues.apache.org/jira/browse/FLINK-21086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21086: Description: For a non-source task, if one of its precedent task has finished, the precedent task would

[GitHub] [flink] flinkbot edited a comment on pull request #16301: [FLINK-23162][docs] Updated column expression which throws exception

flinkbot edited a comment on pull request #16301: URL: https://github.com/apache/flink/pull/16301#issuecomment-869067859 ## CI report: * aac82eeaa2d944ecce4f420cb600c8ed74bce531 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16301: [FLINK-23162][docs] Updated column expression which throws exception

flinkbot edited a comment on pull request #16301: URL: https://github.com/apache/flink/pull/16301#issuecomment-869067859 ## CI report: * aac82eeaa2d944ecce4f420cb600c8ed74bce531 Azure:

[jira] [Updated] (FLINK-21716)  Support higher precision for Data Type TIME(p)

[ https://issues.apache.org/jira/browse/FLINK-21716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21716: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client

[ https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22065: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21559: --- Labels: auto-deprioritized-critical auto-deprioritized-major test-stability (was:

[jira] [Updated] (FLINK-22128) Window aggregation should have unique keys

[ https://issues.apache.org/jira/browse/FLINK-22128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22128: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21538: --- Labels: auto-deprioritized-major auto-unassigned test-stability (was: auto-unassigned

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20696: --- Labels: auto-deprioritized-major stale-major (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22357: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

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

[ https://issues.apache.org/jira/browse/FLINK-22178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22178: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-21877) Add E2E test for upsert-kafka connector

[ https://issues.apache.org/jira/browse/FLINK-21877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21877: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-22397) OrcFileSystemITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22397: --- Labels: auto-deprioritized-critical stale-major test-stability (was:

[jira] [Updated] (FLINK-22551) checkpoints: strange behaviour

[ https://issues.apache.org/jira/browse/FLINK-22551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22551: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am

[jira] [Updated] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22955: --- Labels: stale-critical (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22517) Fix pickle compatibility problem in different Python versions

[ https://issues.apache.org/jira/browse/FLINK-22517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22517: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-22311) Flink JDBC XA connector need to set maxRetries to 0 to properly working

[ https://issues.apache.org/jira/browse/FLINK-22311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22311: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka

[ https://issues.apache.org/jira/browse/FLINK-22190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22190: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22017) Regions may never be scheduled when there are cross-region blocking edges

[ https://issues.apache.org/jira/browse/FLINK-22017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22017: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am

[jira] [Updated] (FLINK-22075) Incorrect null outputs in left join

[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22075: --- Labels: auto-deprioritized-critical auto-unassigned stale-major (was:

[jira] [Updated] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-22306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22306: --- Labels: auto-deprioritized-critical auto-deprioritized-major test-stability (was:

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22342: --- Labels: auto-deprioritized-critical auto-deprioritized-major test-stability (was:

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21876: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-22388) KafkaITCase.testMetricsAndEndOfStream times out on topic creation

[ https://issues.apache.org/jira/browse/FLINK-22388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22388: --- Labels: auto-deprioritized-critical auto-deprioritized-major test-stability (was:

[jira] [Updated] (FLINK-22631) Metrics are incorrect when task finished

[ https://issues.apache.org/jira/browse/FLINK-22631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22631: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

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

[ https://issues.apache.org/jira/browse/FLINK-22004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22004: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked

[ https://issues.apache.org/jira/browse/FLINK-22605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22605: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22705) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to fail to download the tar

[ https://issues.apache.org/jira/browse/FLINK-22705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22705: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration

[ https://issues.apache.org/jira/browse/FLINK-21336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21336: --- Labels: auto-unassigned stale-assigned (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-22710) ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed

[ https://issues.apache.org/jira/browse/FLINK-22710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22710: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[GitHub] [flink] flinkbot commented on pull request #16301: [FLINK-23162][docs] Updated column expression which throws exception

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

[jira] [Updated] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception

[ https://issues.apache.org/jira/browse/FLINK-23162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mans Singh updated FLINK-23162: --- Description: The create table example in

[jira] [Commented] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception

[ https://issues.apache.org/jira/browse/FLINK-23162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370075#comment-17370075 ] Mans Singh commented on FLINK-23162: Please assign this ticket to me.  Thank > Create table uses

[GitHub] [flink] flinkbot commented on pull request #16301: [FLINK-23162][docs] Updated column expression which throws exception

flinkbot commented on pull request #16301: URL: https://github.com/apache/flink/pull/16301#issuecomment-869064663 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-23162) Create table uses time_ltz in the column name and it's expression which results in exception

[ https://issues.apache.org/jira/browse/FLINK-23162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23162: --- Labels: doc example pull-request-available sql (was: doc example sql) > Create table uses

[GitHub] [flink] mans2singh opened a new pull request #16301: [FLINK-23162][docs] Updated column used in expression for creating table

mans2singh opened a new pull request #16301: URL: https://github.com/apache/flink/pull/16301 ## What is the purpose of the change * Create table uses time_ltz in the column name and it's expression which results in exception ## Brief change log * Create table uses

[jira] [Created] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception

Mans Singh created FLINK-23162: -- Summary: Create table uses time_ltz in the column name and it's expression which results in exception Key: FLINK-23162 URL: https://issues.apache.org/jira/browse/FLINK-23162

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369943#comment-17369943 ] Chesnay Schepler commented on FLINK-23147: -- > I don't see why this is different for

[GitHub] [flink] flinkbot edited a comment on pull request #16299: Remove extra commas from the "create" page

flinkbot edited a comment on pull request #16299: URL: https://github.com/apache/flink/pull/16299#issuecomment-868995159 ## CI report: * e2e758de4bdb0eef6cc56752250bc9afd4274ff5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16300: [Hotfix][docs] Fixed typos.

flinkbot edited a comment on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869008061 ## CI report: * 601bd5d457672104c5fe2c69963116af36b0ea34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16299: Remove extra commas from the "create" page

flinkbot edited a comment on pull request #16299: URL: https://github.com/apache/flink/pull/16299#issuecomment-868995159 ## CI report: * 9bc98631ec8726b866311a41f2dd528e4e72acb9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16300: [Hotfix][docs] Fixed typos.

flinkbot edited a comment on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869008061 ## CI report: * 601bd5d457672104c5fe2c69963116af36b0ea34 Azure:

[GitHub] [flink] flinkbot commented on pull request #16300: [Hotfix][docs] Fixed typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16299: Remove extra commas from the "create" page

flinkbot edited a comment on pull request #16299: URL: https://github.com/apache/flink/pull/16299#issuecomment-868995159 ## CI report: * 9bc98631ec8726b866311a41f2dd528e4e72acb9 Azure:

[GitHub] [flink] flinkbot commented on pull request #16300: [Hotfix][docs] Fixed typos.

flinkbot commented on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869002179 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] RocMarshal opened a new pull request #16300: [Hotfix][docs] Fixed typos.

RocMarshal opened a new pull request #16300: URL: https://github.com/apache/flink/pull/16300 ## What is the purpose of the change *Fixed typos* ## Brief change log *Fixed typos* ## Verifying this change *Fixed typos* ## Does this

[GitHub] [flink] flinkbot edited a comment on pull request #16299: Remove extra commas from the "create" page

flinkbot edited a comment on pull request #16299: URL: https://github.com/apache/flink/pull/16299#issuecomment-868995159 ## CI report: * 9bc98631ec8726b866311a41f2dd528e4e72acb9 Azure:

[GitHub] [flink] flinkbot commented on pull request #16299: Remove extra commas from the "create" page

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

[GitHub] [flink] flinkbot commented on pull request #16299: Remove extra commas from the "create" page

flinkbot commented on pull request #16299: URL: https://github.com/apache/flink/pull/16299#issuecomment-868992492 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] wangjunyou opened a new pull request #16299: Remove extra commas from the "create" page

wangjunyou opened a new pull request #16299: URL: https://github.com/apache/flink/pull/16299 ###What is the purpose of the change *** Remove extra commas from the "create" page ###Verifying this change *** alter file: /flink/docs/content/docs/dev/table/sql/create.md

[GitHub] [flink] flinkbot edited a comment on pull request #16290: [FLINK-23067][table-api-java] Introduce Table#executeInsert(TableDescriptor)

flinkbot edited a comment on pull request #16290: URL: https://github.com/apache/flink/pull/16290#issuecomment-868395028 ## CI report: * f7d3d618d7f73fceabe136cefeda2cb210f1d463 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16285: [FLINK-23070][table-api-java] Introduce TableEnvironment#createTable

flinkbot edited a comment on pull request #16285: URL: https://github.com/apache/flink/pull/16285#issuecomment-868253867 ## CI report: * 3a7708ead7c69816ae9debe89df06f06abed3381 Azure:

[jira] [Closed] (FLINK-22940) Make SQL client column max width configurable

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

[GitHub] [flink] wuchong merged pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

wuchong merged pull request #16245: URL: https://github.com/apache/flink/pull/16245 -- 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. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-4088) Add interface to save and load TableSources

[ https://issues.apache.org/jira/browse/FLINK-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-4088. -- Resolution: Won't Fix This can be achieved by FLIP-129. > Add interface to save and load TableSources >

[GitHub] [flink] wangjunyou closed pull request #16298: Remove extra commas from the create table page

wangjunyou closed pull request #16298: URL: https://github.com/apache/flink/pull/16298 -- 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. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-3462) Add position and magic number checks to record (de)serializers

[ https://issues.apache.org/jira/browse/FLINK-3462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3462: -- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) This

[jira] [Updated] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings

[ https://issues.apache.org/jira/browse/FLINK-4004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4004: -- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-3857) Add reconnect attempt to Elasticsearch host

[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3857: -- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API

[ https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3850: -- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3769: -- Labels: auto-deprioritized-major auto-unassigned rabbitmq (was: auto-unassigned rabbitmq

[jira] [Updated] (FLINK-4088) Add interface to save and load TableSources

[ https://issues.apache.org/jira/browse/FLINK-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4088: -- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector

[ https://issues.apache.org/jira/browse/FLINK-4043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4043: -- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) This

[jira] [Updated] (FLINK-3473) Add partial aggregate support in Flink

[ https://issues.apache.org/jira/browse/FLINK-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3473: -- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4194: -- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-4498) Better Cassandra sink documentation

[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4498: -- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-3957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3957: -- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) This

[jira] [Updated] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java

[ https://issues.apache.org/jira/browse/FLINK-4642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4642: -- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-3997) PRNG Skip-ahead

[ https://issues.apache.org/jira/browse/FLINK-3997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3997: -- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4785: -- Labels: auto-deprioritized-major csv (was: csv stale-major) Priority: Minor (was:

[jira] [Resolved] (FLINK-22757) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-22757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankush Khanna resolved FLINK-22757. --- Fix Version/s: 1.13.3 1.12.6 Resolution: Fixed

[GitHub] [flink] flinkbot edited a comment on pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

flinkbot edited a comment on pull request #16245: URL: https://github.com/apache/flink/pull/16245#issuecomment-866278518 ## CI report: * c333291b38c611e884641b75092501bd841109ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16298: Remove extra commas from the create table page

flinkbot edited a comment on pull request #16298: URL: https://github.com/apache/flink/pull/16298#issuecomment-868974627 ## CI report: * 8626d3c3d2c523c5617a24871b7024856238f18f Azure:

[GitHub] [flink] flinkbot commented on pull request #16298: Remove extra commas from the create table page

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

[jira] [Commented] (FLINK-23128) Translate update to operations playground docs to Chinese

[ https://issues.apache.org/jira/browse/FLINK-23128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369838#comment-17369838 ] kevin commented on FLINK-23128: --- Hi [~alpinegizmo], I have created PR and link it to this issue, can you

[GitHub] [flink] flinkbot commented on pull request #16298: Remove extra commas from the create table page

flinkbot commented on pull request #16298: URL: https://github.com/apache/flink/pull/16298#issuecomment-868972180 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] wangjunyou opened a new pull request #16298: Remove extra commas from the create table page

wangjunyou opened a new pull request #16298: URL: https://github.com/apache/flink/pull/16298 Remove extra commas from the create table page -- 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

  1   2   >