[jira] [Comment Edited] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118281#comment-17118281 ] Xintong Song edited comment on FLINK-15687 at 5/28/20, 5:55 AM: I've

[jira] [Comment Edited] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118281#comment-17118281 ] Xintong Song edited comment on FLINK-15687 at 5/28/20, 5:54 AM: I've

[jira] [Comment Edited] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118281#comment-17118281 ] Xintong Song edited comment on FLINK-15687 at 5/28/20, 5:54 AM: I've

[jira] [Created] (FLINK-17994) Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

Zhijiang created FLINK-17994: Summary: Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived Key: FLINK-17994 URL: https://issues.apache.org/jira/browse/FLINK-17994

[jira] [Commented] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118335#comment-17118335 ] Robert Metzger commented on FLINK-17825: Another case in the Scala 2.12 profile

[jira] [Updated] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17825: --- Description: CI (normal profile):

[GitHub] [flink] flinkbot commented on pull request #12370: [FLINK-17923][python] Allow Python worker to use off-heap memory

flinkbot commented on pull request #12370: URL: https://github.com/apache/flink/pull/12370#issuecomment-635117318 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] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118330#comment-17118330 ] Dian Fu commented on FLINK-17923: - [~sunjincheng121] [~xintongsong] [~zhuzh] I have submitted a PR

[GitHub] [flink] dianfu opened a new pull request #12370: [FLINK-17923][python] Allow Python worker to use off-heap memory

dianfu opened a new pull request #12370: URL: https://github.com/apache/flink/pull/12370 ## What is the purpose of the change *This pull request allows Python worker to use off-heap memory by default. This is to make it Python UDF could work together RocksDB state backend as

[jira] [Updated] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17923: --- Labels: pull-request-available (was: ) > It will throw MemoryAllocationException if

[GitHub] [flink] flinkbot edited a comment on pull request #12366: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

flinkbot edited a comment on pull request #12366: URL: https://github.com/apache/flink/pull/12366#issuecomment-635048579 ## CI report: * b96f10efb424c00ebac581db24c0b9440ebf0121 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12259: [hotfix][k8s] Remove unused constant variable

flinkbot edited a comment on pull request #12259: URL: https://github.com/apache/flink/pull/12259#issuecomment-631191345 ## CI report: * f8c349c435060ab3459f7f1de29d6ffc957fc895 Azure:

[jira] [Commented] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt

[ https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118328#comment-17118328 ] Robert Metzger commented on FLINK-17194: Again Hadoop 3.1.3:

[jira] [Commented] (FLINK-16681) Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to write.

[ https://issues.apache.org/jira/browse/FLINK-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118324#comment-17118324 ] Jark Wu commented on FLINK-16681: - [~wanglijie95], please also fix {{JdbcRowDataOutputFormat}}. > Jdbc

[jira] [Assigned] (FLINK-16681) Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to write.

[ https://issues.apache.org/jira/browse/FLINK-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16681: --- Assignee: Lijie Wang (was: LakeShen) > Jdbc JDBCOutputFormat and JDBCLookupFunction

[jira] [Updated] (FLINK-16496) Improve default flush strategy for HBase sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16496: Fix Version/s: (was: 1.12.0) 1.11.0 > Improve default flush strategy for HBase

[jira] [Updated] (FLINK-15339) Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15339: Fix Version/s: (was: 1.12.0) 1.11.0 > Correct the terminology of "Time-windowed

[jira] [Updated] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16497: Fix Version/s: (was: 1.12.0) 1.11.0 > Improve default flush strategy for JDBC sink

[jira] [Commented] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid

[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118322#comment-17118322 ] Robert Metzger commented on FLINK-17404: {code}Running HA per-job cluster (file, async)

[GitHub] [flink] flinkbot edited a comment on pull request #12367: [FLINK-17960][python][docs] Improve commands in the "Common Questions" document for PyFlink

flinkbot edited a comment on pull request #12367: URL: https://github.com/apache/flink/pull/12367#issuecomment-635056734 ## CI report: * 164103e96608f5dd8c00e020f55716de23bd3019 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

flinkbot edited a comment on pull request #12290: URL: https://github.com/apache/flink/pull/12290#issuecomment-632566330 ## CI report: * 83457318b700d7baff1d80ee25f5a244740bb16e Azure:

[jira] [Created] (FLINK-17993) read schema from orc file

dingli123 created FLINK-17993: - Summary: read schema from orc file Key: FLINK-17993 URL: https://issues.apache.org/jira/browse/FLINK-17993 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #12369: Flink 17678

flinkbot edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635090403 ## CI report: * f49fb611425fd075c0818233472ece2a4a824d71 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12367: [FLINK-17960][python][docs] Improve commands in the "Common Questions" document for PyFlink

flinkbot edited a comment on pull request #12367: URL: https://github.com/apache/flink/pull/12367#issuecomment-635056734 ## CI report: * 164103e96608f5dd8c00e020f55716de23bd3019 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

flinkbot edited a comment on pull request #12290: URL: https://github.com/apache/flink/pull/12290#issuecomment-632566330 ## CI report: * 83457318b700d7baff1d80ee25f5a244740bb16e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11586: [FLINK-5552][runtime] make JMXServer static per JVM

flinkbot edited a comment on pull request #11586: URL: https://github.com/apache/flink/pull/11586#issuecomment-606958289 ## CI report: * 613a5fd798911229926144246b94635cde46c6ed Azure:

[jira] [Commented] (FLINK-14356) Introduce "single-field" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118310#comment-17118310 ] Jark Wu commented on FLINK-14356: - Responsed in the PR. > Introduce "single-field" format to

[GitHub] [flink] wuchong commented on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

wuchong commented on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-635094908 Hi @hackergin , thanks a lot for the contribution. However, the community is moving to a new format factory interface called `DeserializationFormatFactory` and

[jira] [Closed] (FLINK-17991) Add JdbcAsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-17991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17991. --- Fix Version/s: (was: 1.12.0) Resolution: Duplicate Let's move the discussion to FLINK-14902, we

[jira] [Updated] (FLINK-17869) Fix the race condition of aborting unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17869: - Description: On ChannelStateWriter side, the lifecycle of checkpoint should be as follows: start -> in

[jira] [Closed] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17600. --- Resolution: Duplicate close since it is fixed by FLINK-16160 > Blink Planner fails to generate

[jira] [Commented] (FLINK-17967) Could not find document *** in docs

[ https://issues.apache.org/jira/browse/FLINK-17967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118298#comment-17118298 ] Jark Wu commented on FLINK-17967: - I didn't get what's the problem. There is already a file

[GitHub] [flink] flinkbot commented on pull request #12369: Flink 17678

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

[GitHub] [flink] flinkbot edited a comment on pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

flinkbot edited a comment on pull request #12355: URL: https://github.com/apache/flink/pull/12355#issuecomment-634548726 ## CI report: * 578b299f37b20eab2cd6ce64160cbbfc3ba10479 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

flinkbot edited a comment on pull request #12313: URL: https://github.com/apache/flink/pull/12313#issuecomment-633389597 ## CI report: * b67b757ed5193ab53f899e9501e4ce96551f8c40 Azure:

[jira] [Closed] (FLINK-17284) Support serial field type in PostgresCatalog

[ https://issues.apache.org/jira/browse/FLINK-17284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17284. --- Fix Version/s: 1.11.0 Resolution: Fixed master (1.12.0): b0dd0aa639ef973db0341ade7d2fe73384cf2ed3

[GitHub] [flink] wuchong merged pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

wuchong merged pull request #11900: URL: https://github.com/apache/flink/pull/11900 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

[jira] [Commented] (FLINK-17991) Add JdbcAsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-17991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118285#comment-17118285 ] 底限 commented on FLINK-17991: Some functions overlap, but the implementation is different: 1. I did not use

[jira] [Commented] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118281#comment-17118281 ] Xintong Song commented on FLINK-15687: -- I've printed the thread names for all testing scope

[GitHub] [flink] flinkbot commented on pull request #12369: Flink 17678

flinkbot commented on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635081028 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] hequn8128 commented on a change in pull request #12367: [FLINK-17960][document] Improve commands in the "Common Questions" document for PyFlink

hequn8128 commented on a change in pull request #12367: URL: https://github.com/apache/flink/pull/12367#discussion_r431566416 ## File path: docs/dev/table/python/common_questions.md ## @@ -33,10 +33,11 @@ You can download a [convenience script]({{ site.baseurl

[GitHub] [flink] hequn8128 commented on a change in pull request #12367: [FLINK-17960][document] Improve commands in the "Common Questions" document for PyFlink

hequn8128 commented on a change in pull request #12367: URL: https://github.com/apache/flink/pull/12367#discussion_r431566416 ## File path: docs/dev/table/python/common_questions.md ## @@ -33,10 +33,11 @@ You can download a [convenience script]({{ site.baseurl

[GitHub] [flink] DashShen opened a new pull request #12369: Flink 17678

DashShen opened a new pull request #12369: URL: https://github.com/apache/flink/pull/12369 ## What is the purpose of the change Flink doesn't contains a hbase shade jar right now, so users have to add hbase dependency manually. This pull request is trying to solve this problem.

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

flinkbot edited a comment on pull request #12290: URL: https://github.com/apache/flink/pull/12290#issuecomment-632566330 ## CI report: * 83457318b700d7baff1d80ee25f5a244740bb16e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

flinkbot edited a comment on pull request #12355: URL: https://github.com/apache/flink/pull/12355#issuecomment-634548726 ## CI report: * 578b299f37b20eab2cd6ce64160cbbfc3ba10479 Azure:

[GitHub] [flink] lirui-apache commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

lirui-apache commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r431563579 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,355 @@ +--- +title: "FileSystem Connector" +nav-title: FileSystem Connector

[jira] [Commented] (FLINK-17991) Add JdbcAsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-17991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118265#comment-17118265 ] Benchao Li commented on FLINK-17991: [~ChaseDream] Does this issue a duplicate of

[GitHub] [flink] lirui-apache commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

lirui-apache commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r431551933 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,355 @@ +--- +title: "FileSystem Connector" +nav-title: FileSystem Connector

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

flinkbot edited a comment on pull request #12290: URL: https://github.com/apache/flink/pull/12290#issuecomment-632566330 ## CI report: * 83457318b700d7baff1d80ee25f5a244740bb16e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12368: [FLINK-15507][state backends] Activate local recovery by default (on release-1.11)

flinkbot edited a comment on pull request #12368: URL: https://github.com/apache/flink/pull/12368#issuecomment-635063638 ## CI report: * d346d64a63a3b91f18251b7e30bb9f839ffe68cd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12284: [FLINK-17689][kafka][table] Add integration tests for changelog sourc…

flinkbot edited a comment on pull request #12284: URL: https://github.com/apache/flink/pull/12284#issuecomment-632089951 ## CI report: * dac757cc5a0f392c8f0ef7b9a7796a2fc8fe9768 Azure:

[GitHub] [flink] klion26 commented on pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

klion26 commented on pull request #11978: URL: https://github.com/apache/flink/pull/11978#issuecomment-635072086 @wuchong @caozhen1937 I'll give a final review today. This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-17942) Count distinct could not clean state in WindowOperator

[ https://issues.apache.org/jira/browse/FLINK-17942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17942. --- Resolution: Fixed master (1.12.0): b6f92febd1f03152541432492820a5f2a12be6c4 1.11.0:

[GitHub] [flink] wuchong merged pull request #12358: [FLINK-17942][table-planner-blink] Fix WindowOperator not call StateM…

wuchong merged pull request #12358: URL: https://github.com/apache/flink/pull/12358 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

[jira] [Comment Edited] (FLINK-17788) scala shell in yarn mode is broken

[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118249#comment-17118249 ] Jeff Zhang edited comment on FLINK-17788 at 5/28/20, 3:09 AM: -- [~kkl0u]

[GitHub] [flink] wuchong commented on a change in pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

wuchong commented on a change in pull request #12289: URL: https://github.com/apache/flink/pull/12289#discussion_r431556847 ## File path: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/util/HBaseTypeUtils.java ## @@ -81,13 +81,16 @@ public static

[jira] [Updated] (FLINK-17944) Wrong output in sql client's table mode

[ https://issues.apache.org/jira/browse/FLINK-17944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-17944: --- Issue Type: Bug (was: Improvement) > Wrong output in sql client's table mode >

[jira] [Updated] (FLINK-17944) Wrong output in sql client's table mode

[ https://issues.apache.org/jira/browse/FLINK-17944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17944: --- Fix Version/s: (was: 1.12.0) 1.11.0 > Wrong output in sql client's table

[GitHub] [flink] wuchong commented on a change in pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

wuchong commented on a change in pull request #12289: URL: https://github.com/apache/flink/pull/12289#discussion_r431556847 ## File path: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/util/HBaseTypeUtils.java ## @@ -81,13 +81,16 @@ public static

[jira] [Updated] (FLINK-15556) Add a switch for PushProjectIntoTableSourceScanRule

[ https://issues.apache.org/jira/browse/FLINK-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15556: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Add a switch for

[jira] [Updated] (FLINK-15003) Improve hive test performance

[ https://issues.apache.org/jira/browse/FLINK-15003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15003: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Improve hive test performance >

[jira] [Updated] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15123: --- Fix Version/s: (was: 1.11.0) 1.12.0 > remove uniqueKeys from FlinkStatistic

[jira] [Updated] (FLINK-15408) Interval join support no equi-condition

[ https://issues.apache.org/jira/browse/FLINK-15408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15408: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Interval join support no

[jira] [Updated] (FLINK-14659) add 'LOAD MODULE' and 'UNLOAD MODULE' sql commands to sql parser

[ https://issues.apache.org/jira/browse/FLINK-14659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-14659: --- Fix Version/s: (was: 1.11.0) 1.12.0 > add 'LOAD MODULE' and 'UNLOAD MODULE'

[jira] [Updated] (FLINK-15498) Using HiveCatalog in TPC-DS e2e

[ https://issues.apache.org/jira/browse/FLINK-15498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15498: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Using HiveCatalog in TPC-DS e2e >

[jira] [Updated] (FLINK-15555) Delete TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED option for subplaner reuse

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-1: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Delete

[jira] [Updated] (FLINK-15419) Validate SQL syntax not need to depend on connector jar

[ https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15419: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Validate SQL syntax not need to depend

[GitHub] [flink] wuchong commented on pull request #11822: [FLINK-16788][Connector]ElasticSearch Connector SQL DDL add optional config (eg: username/password)

wuchong commented on pull request #11822: URL: https://github.com/apache/flink/pull/11822#issuecomment-635066650 Hi @zhisheng17 , is there any problems to add a end-to-end test or IT case? This is an automated message from

[jira] [Updated] (FLINK-15588) check registered udf via catalog API cannot be a scala inner class

[ https://issues.apache.org/jira/browse/FLINK-15588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15588: --- Fix Version/s: (was: 1.11.0) 1.12.0 > check registered udf via catalog API

[jira] [Updated] (FLINK-15733) Add min number memory pages check for BytesHashMap

[ https://issues.apache.org/jira/browse/FLINK-15733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15733: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Add min number memory pages check for

[jira] [Updated] (FLINK-15734) Support spill in batch hash window aggregation

[ https://issues.apache.org/jira/browse/FLINK-15734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15734: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support spill in batch hash window

[GitHub] [flink] wuchong closed pull request #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink

wuchong closed pull request #11716: URL: https://github.com/apache/flink/pull/11716 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

[jira] [Updated] (FLINK-15677) TableSource#explainSource should return the field names from getProducedDataType instead of getTableSchema

[ https://issues.apache.org/jira/browse/FLINK-15677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15677: --- Fix Version/s: (was: 1.11.0) 1.12.0 > TableSource#explainSource should

[GitHub] [flink] wuchong commented on pull request #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink

wuchong commented on pull request #11716: URL: https://github.com/apache/flink/pull/11716#issuecomment-635066025 Sorry, I didn't notice this pull request before. There is already a pull request (#11822) for this feature which is a good shape to be merged. So I will close this then. Thanks

[jira] [Updated] (FLINK-15677) TableSource#explainSource should return the field names from getProducedDataType instead of getTableSchema

[ https://issues.apache.org/jira/browse/FLINK-15677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15677: --- Issue Type: Bug (was: Improvement) > TableSource#explainSource should return the field names from

[jira] [Created] (FLINK-17992) Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler

Zhijiang created FLINK-17992: Summary: Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler Key: FLINK-17992 URL: https://issues.apache.org/jira/browse/FLINK-17992

[jira] [Closed] (FLINK-15469) Update UpsertStreamTableSink and RetractStreamTableSink and related interface to new type system

[ https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-15469. -- Release Note: Close because after FLIP-95, we actually have no "upsert" or "retract sink" anymore,

[jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column

[ https://issues.apache.org/jira/browse/FLINK-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15553: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Create table ddl support comment

[jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result

[ https://issues.apache.org/jira/browse/FLINK-16466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16466: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Group by on event time should produce

[jira] [Updated] (FLINK-16496) Improve default flush strategy for HBase sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16496: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Improve default flush strategy for

[jira] [Updated] (FLINK-16495) Improve default flush strategy for Elasticsearch sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16495: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Improve default flush strategy for

[jira] [Updated] (FLINK-16295) Optimize BinaryString.copy to not materialize if there is javaObject

[ https://issues.apache.org/jira/browse/FLINK-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16295: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Optimize BinaryString.copy to not

[jira] [Updated] (FLINK-17968) Hadoop Configuration is not properly serialized in HBaseRowInputFormat

[ https://issues.apache.org/jira/browse/FLINK-17968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17968: --- Labels: pull-request-available (was: ) > Hadoop Configuration is not properly serialized

[GitHub] [flink] wuchong commented on pull request #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

wuchong commented on pull request #12146: URL: https://github.com/apache/flink/pull/12146#issuecomment-635064897 Thanks for the contribution @Tartarus0zm . I ajusted the title to the corresponding JIRA issue. Regarding to the fix, I agree with @rmetzger , we should use

[jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI

[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16609: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Promotes the column name

[jira] [Updated] (FLINK-15845) Add java-based StreamingFileSink test using s3

[ https://issues.apache.org/jira/browse/FLINK-15845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15845: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Add java-based StreamingFileSink test

[jira] [Updated] (FLINK-15339) Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15339: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Correct the terminology of

[jira] [Updated] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16497: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Improve default flush strategy for

[jira] [Updated] (FLINK-14764) The final Explicit conversion matrix we should support in our planner

[ https://issues.apache.org/jira/browse/FLINK-14764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-14764: --- Fix Version/s: (was: 1.11.0) 1.12.0 > The final Explicit conversion matrix

[jira] [Updated] (FLINK-15509) Use sql cilents create view occur Unexpected exception

[ https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15509: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Use sql cilents create view occur

[jira] [Updated] (FLINK-15625) flink sql multiple statements syntatic validation supports

[ https://issues.apache.org/jira/browse/FLINK-15625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15625: --- Fix Version/s: (was: 1.11.0) 1.12.0 > flink sql multiple statements syntatic

[GitHub] [flink] JingsongLi commented on a change in pull request #12333: [FLINK-17937][hive] Change some hive connector tests to IT cases

JingsongLi commented on a change in pull request #12333: URL: https://github.com/apache/flink/pull/12333#discussion_r431553269 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveLookupJoinTest.java ## @@ -50,7 +48,6 @@ /**

[jira] [Updated] (FLINK-17099) Refactoring State TTL solution in Group Agg、Deduplication、TopN operators replace Timer with StateTtlConfig

[ https://issues.apache.org/jira/browse/FLINK-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17099: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Refactoring State TTL solution in

[jira] [Updated] (FLINK-15064) Remove XmlOutput util class in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15064: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Remove XmlOutput util class in blink

[GitHub] [flink] flinkbot commented on pull request #12368: [FLINK-15507][state backends] Activate local recovery by default (on release-1.11)

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

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16048: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support read/write confluent schema

[GitHub] [flink] flinkbot edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

flinkbot edited a comment on pull request #12313: URL: https://github.com/apache/flink/pull/12313#issuecomment-633389597 ## CI report: * 07ab8aa279380cc6584c9602a1c344dfb2294074 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12284: [FLINK-17689][kafka][table] Add integration tests for changelog sourc…

flinkbot edited a comment on pull request #12284: URL: https://github.com/apache/flink/pull/12284#issuecomment-632089951 ## CI report: * dac757cc5a0f392c8f0ef7b9a7796a2fc8fe9768 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12367: [FLINK-17960][document] Improve commands in the "Common Questions" document for PyFlink

flinkbot edited a comment on pull request #12367: URL: https://github.com/apache/flink/pull/12367#issuecomment-635056734 ## CI report: * 164103e96608f5dd8c00e020f55716de23bd3019 Azure:

[jira] [Updated] (FLINK-17371) Failed to cast decimal from string or double

[ https://issues.apache.org/jira/browse/FLINK-17371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17371: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Failed to cast decimal from string or

  1   2   3   4   5   6   7   >