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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Jark Wu (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Jark Wu (Jira)
[ 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

2021-06-26 Thread Jark Wu (Jira)
[ 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

2021-06-26 Thread Jark Wu (Jira)
[ 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

2021-06-26 Thread godfrey he (Jira)
[ 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.

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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.

2021-06-26 Thread GitBox
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.

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Dian Fu (Jira)
[ 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

2021-06-26 Thread GitBox
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.

2021-06-26 Thread GitBox
tisonkun commented on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869088182 ![image](https://user-images.githubusercontent.com/18818196/123530671-b8469400-d72f-11eb-81c0-e04b1e08be5e.png) It is not a typo. Closing... -- This is an

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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Yun Gao (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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)

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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.

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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.

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Mans Singh (Jira)
[ 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

2021-06-26 Thread Mans Singh (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread ASF GitHub Bot (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Mans Singh (Jira)
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

2021-06-26 Thread Chesnay Schepler (Jira)
[ 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

2021-06-26 Thread GitBox
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.

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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.

2021-06-26 Thread GitBox
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.

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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.

2021-06-26 Thread GitBox
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.

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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)

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Jark Wu (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Jark Wu (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Flink Jira Bot (Jira)
[ 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

2021-06-26 Thread Ankush Khanna (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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

2021-06-26 Thread kevin (Jira)
[ 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

2021-06-26 Thread GitBox
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

2021-06-26 Thread GitBox
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   >