[jira] [Commented] (FLINK-17737) KeyedStateCheckpointingITCase fails in UC mode

[ https://issues.apache.org/jira/browse/FLINK-17737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108892#comment-17108892 ] Roman Khachatryan commented on FLINK-17737: --- Thanks for offering your help [~c

[GitHub] [flink] flinkbot edited a comment on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 6d7ff00d684de2f19cce74d766824613fb86dc86 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] KurtYoung commented on a change in pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

KurtYoung commented on a change in pull request #12145: URL: https://github.com/apache/flink/pull/12145#discussion_r426120399 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala ## @@ -60,7 +60,7

[GitHub] [flink] wuchong commented on a change in pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

wuchong commented on a change in pull request #12133: URL: https://github.com/apache/flink/pull/12133#discussion_r426125279 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowDataDeSerializationSchemaTest.java ## @@ -0,0 +1,155 @@ +/* + *

[GitHub] [flink] wuchong commented on a change in pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

wuchong commented on a change in pull request #12133: URL: https://github.com/apache/flink/pull/12133#discussion_r426125279 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowDataDeSerializationSchemaTest.java ## @@ -0,0 +1,155 @@ +/* + *

[GitHub] [flink] godfreyhe commented on a change in pull request #12171: [FLINK-17715][sql client] Supports function DDLs in SQL-CLI

godfreyhe commented on a change in pull request #12171: URL: https://github.com/apache/flink/pull/12171#discussion_r426125201 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/Executor.java ## @@ -133,6 +133,21 @@ */

[GitHub] [flink] wuchong commented on a change in pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

wuchong commented on a change in pull request #12133: URL: https://github.com/apache/flink/pull/12133#discussion_r426121118 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -157,4 +166,118 @@ private Av

[GitHub] [flink] curcur edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629595539 Resolved 3. the last one. remove getTypeSerializer() from TypeInformationSerializationSchema; Done --

[GitHub] [flink] flinkbot edited a comment on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

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

[GitHub] [flink] flinkbot commented on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

flinkbot commented on pull request #12188: URL: https://github.com/apache/flink/pull/12188#issuecomment-629595773 ## CI report: * 7111bcfcc655d8d6b0ee5f9ff66e80e732f7272e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * ba9ee6228cf9eea60df403e37b41b907fef21a28 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Closed] (FLINK-17587) Filesystem streaming sink support partition commit (success file)

[ https://issues.apache.org/jira/browse/FLINK-17587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17587. Resolution: Implemented master: 25279ed0a3cf7c5fa8d1ad1b3b44990782924362 b8434803367a8360b5f5b9a

[GitHub] [flink] curcur commented on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629595539 Resolved 3. the last one. remove getTypeSerializer() from TypeInformationSerializationSchema This is an au

[GitHub] [flink] JingsongLi merged pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

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

[GitHub] [flink] flinkbot commented on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

flinkbot commented on pull request #12188: URL: https://github.com/apache/flink/pull/12188#issuecomment-629594206 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 pro

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426121598 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[] bu

[jira] [Updated] (FLINK-17728) sql client supports parser statements via sql parser

[ https://issues.apache.org/jira/browse/FLINK-17728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17728: --- Labels: pull-request-available (was: ) > sql client supports parser statements via sql pars

[GitHub] [flink] godfreyhe opened a new pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

godfreyhe opened a new pull request #12188: URL: https://github.com/apache/flink/pull/12188 ## What is the purpose of the change *currently, all statements in sql client are parsed via regex matching, which has many limitations, such as it can't handle comments. To avoid that li

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * ba9ee6228cf9eea60df403e37b41b907fef21a28 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-17428) Support SupportsProjectionPushDown in planner

[ https://issues.apache.org/jira/browse/FLINK-17428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17428: --- Labels: pull-request-available (was: ) > Support SupportsProjectionPushDown in planner > --

[GitHub] [flink] flinkbot edited a comment on pull request #12179: [FLINK-16144] get client.timeout for the client, with a fallback to the akka.client…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

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

[GitHub] [flink] flinkbot edited a comment on pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

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

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * 0ea67ded38cbd339a5f67656b50b874625a911b9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

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

[GitHub] [flink] flinkbot edited a comment on pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

flinkbot edited a comment on pull request #12062: URL: https://github.com/apache/flink/pull/12062#issuecomment-626437386 ## CI report: * 89b43558a39741f04114f95011f784fd5414b22c UNKNOWN * 196579752867c527af380839b1f9c3f559ae4bf0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 6d7ff00d684de2f19cce74d766824613fb86dc86 Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-17728) sql client supports parser statements via sql parser

[ https://issues.apache.org/jira/browse/FLINK-17728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17728: --- Description: Current, all statements in sql client are parsed via regex matching, which has many li

[jira] [Updated] (FLINK-17728) sql client supports parser statements via sql parser

[ https://issues.apache.org/jira/browse/FLINK-17728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17728: --- Description: Current, all statements in sql client are parsed via regex matching, which has many li

[jira] [Updated] (FLINK-17728) sql client supports parser statements via sql parser

[ https://issues.apache.org/jira/browse/FLINK-17728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17728: --- Description: Current, all statements in sql client are parsed via regex matching, which has many li

[GitHub] [flink] klion26 commented on pull request #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

klion26 commented on pull request #11722: URL: https://github.com/apache/flink/pull/11722#issuecomment-629592972 @StephanEwen thanks for your great work. the rework(introduce a context to extract exclusive directory) is better for future expansion. the new pr LGTM. For the first comm

[GitHub] [flink] wuchong commented on a change in pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

wuchong commented on a change in pull request #12178: URL: https://github.com/apache/flink/pull/12178#discussion_r426120819 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseDynamicTableSink.java ## @@ -0,0 +1,108 @@

[GitHub] [flink] wuchong commented on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

wuchong commented on pull request #12178: URL: https://github.com/apache/flink/pull/12178#issuecomment-629591752 Resolve conflicts and address comments. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] wuchong commented on a change in pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

wuchong commented on a change in pull request #12178: URL: https://github.com/apache/flink/pull/12178#discussion_r426120337 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseSerde.java ## @@ -0,0 +1,371 @@ +/* + * Lic

[GitHub] [flink] leonardBang closed pull request #12046: [hotfix][typo]Fix typo in catalogs docs

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

[GitHub] [flink] wuchong commented on a change in pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

wuchong commented on a change in pull request #12178: URL: https://github.com/apache/flink/pull/12178#discussion_r426120300 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseSerde.java ## @@ -0,0 +1,371 @@ +/* + * Lic

[GitHub] [flink] leonardBang commented on pull request #12046: [hotfix][typo]Fix typo in catalogs docs

leonardBang commented on pull request #12046: URL: https://github.com/apache/flink/pull/12046#issuecomment-629590898 fixed in https://github.com/apache/flink/pull/12036 This is an automated message from the Apache Git Service

[GitHub] [flink] flinkbot edited a comment on pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

flinkbot edited a comment on pull request #12062: URL: https://github.com/apache/flink/pull/12062#issuecomment-626437386 ## CI report: * 89b43558a39741f04114f95011f784fd5414b22c UNKNOWN * 196579752867c527af380839b1f9c3f559ae4bf0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

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

[GitHub] [flink] godfreyhe commented on pull request #12103: [FLINK-16998][core] Add a changeflag to Row

godfreyhe commented on pull request #12103: URL: https://github.com/apache/flink/pull/12103#issuecomment-629590293 @twalthr any progress ? This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] flinkbot edited a comment on pull request #12179: [FLINK-16144] get client.timeout for the client, with a fallback to the akka.client…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

flinkbot edited a comment on pull request #12062: URL: https://github.com/apache/flink/pull/12062#issuecomment-626437386 ## CI report: * 89b43558a39741f04114f95011f784fd5414b22c UNKNOWN * b5c04196e6d3c0f0e88c688216913001930d3a20 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * 7710f1698ed5a88b5947b61cc9498ad1b825a1b4 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

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

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 8ecf08d5549084a4cd65d22bc7c29b2431c932d2 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-17741) Create integration or e2e test for out of order (savepoint) barriers

[ https://issues.apache.org/jira/browse/FLINK-17741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17741: --- Parent: FLINK-14551 Issue Type: Sub-task (was: Test) > Create integration or e2e te

[jira] [Closed] (FLINK-17467) Implement aligned savepoint in UC mode

[ https://issues.apache.org/jira/browse/FLINK-17467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17467. -- Resolution: Fixed Test reimplemented/re-enabled in FLINK-17727 as 91932ccc05 on master > Impl

[jira] [Closed] (FLINK-17727) Can't subsume checkpoint with no channel state in UC mode

[ https://issues.apache.org/jira/browse/FLINK-17727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17727. -- Resolution: Fixed Fixed on master as 9207b81cb1 and 91932ccc05 > Can't subsume checkpoint wit

[GitHub] [flink] pnowojski merged pull request #12173: [FLINK-17727][task] don't create output stream with no channel state (unaligned checkpoints)

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

[GitHub] [flink] pnowojski commented on pull request #12173: [FLINK-17727][task] don't create output stream with no channel state (unaligned checkpoints)

pnowojski commented on pull request #12173: URL: https://github.com/apache/flink/pull/12173#issuecomment-629587874 e2e tests failed because of https://issues.apache.org/jira/browse/FLINK-17724 but the job upgrade test passed (this PR was fixing it & re-enabling it) --

[GitHub] [flink] pnowojski commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

pnowojski commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426117545 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -174,7 +174,9 @@

[jira] [Closed] (FLINK-17450) Implement function & catalog DDLs for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17450. -- Assignee: Rui Li Resolution: Fixed master: 677867ab89549d33654b7fad69d8bc586febd848 > Implement

[GitHub] [flink] KurtYoung merged pull request #12161: [FLINK-17450][sql-parser][hive] Implement function & catalog DDLs for Hive dialect

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

[GitHub] [flink] danny0405 commented on a change in pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

danny0405 commented on a change in pull request #12178: URL: https://github.com/apache/flink/pull/12178#discussion_r426112993 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseDynamicTableSink.java ## @@ -0,0 +1,108 @

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 4:26 AM:

[GitHub] [flink] Myasuka commented on a change in pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

Myasuka commented on a change in pull request #12153: URL: https://github.com/apache/flink/pull/12153#discussion_r426116917 ## File path: flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/InfluxdbReporterFactory.java ## @@ -0,0 +1,14 @@ +pack

[GitHub] [flink] flinkbot edited a comment on pull request #12179: [FLINK-16144] get client.timeout for the client, with a fallback to the akka.client…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12161: [FLINK-17450][sql-parser][hive] Implement function & catalog DDLs for Hive dialect

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

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * 7710f1698ed5a88b5947b61cc9498ad1b825a1b4 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-15896) Stop using TableSource::getTableSchema

[ https://issues.apache.org/jira/browse/FLINK-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15896. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Closed] (FLINK-15895) Stop using TableSource::getReturnType except for compatibility purpose

[ https://issues.apache.org/jira/browse/FLINK-15895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15895. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Closed] (FLINK-15877) Stop using deprecated methods from TableSource interface

[ https://issues.apache.org/jira/browse/FLINK-15877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15877. -- Fix Version/s: (was: 1.11.0) Resolution: Not A Problem This will be fixed by design after w

[jira] [Closed] (FLINK-15892) Stop overriding TableSource::getTableSchema in csv table source

[ https://issues.apache.org/jira/browse/FLINK-15892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15892. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Won't Fi

[jira] [Closed] (FLINK-15894) Stop overriding TableSource::getTableSchema in flink walkthrough

[ https://issues.apache.org/jira/browse/FLINK-15894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15894. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Closed] (FLINK-15893) Stop overriding TableSource::getTableSchema in python table source

[ https://issues.apache.org/jira/browse/FLINK-15893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15893. -- Fix Version/s: (was: 1.11.0) Resolution: Won't Fix This will be fixed by design after we us

[jira] [Closed] (FLINK-15891) Stop overriding TableSource::getTableSchema in parquet table source

[ https://issues.apache.org/jira/browse/FLINK-15891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15891. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Won't Fi

[jira] [Closed] (FLINK-15889) Stop overriding TableSource::getTableSchema in jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-15889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15889. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Zhenghua Gao) Resolution: Won't Fi

[jira] [Closed] (FLINK-15890) Stop overriding TableSource::getTableSchema in orc table source

[ https://issues.apache.org/jira/browse/FLINK-15890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15890. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Won't Fi

[jira] [Closed] (FLINK-15888) Stop overriding TableSource::getTableSchema in hbase

[ https://issues.apache.org/jira/browse/FLINK-15888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15888. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Leonard Xu) Resolution: Won't Fix

[jira] [Closed] (FLINK-15887) Stop overriding TableSource::getTableSchema in kafka

[ https://issues.apache.org/jira/browse/FLINK-15887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15887. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jark Wu) Resolution: Won't Fix Th

[jira] [Closed] (FLINK-15886) Stop overriding TableSource::getTableSchema in hive table source

[ https://issues.apache.org/jira/browse/FLINK-15886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15886. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Rui Li) Resolution: Won't Fix Thi

[jira] [Closed] (FLINK-15884) Stop overriding TableSource::getReturnType in python table source

[ https://issues.apache.org/jira/browse/FLINK-15884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15884. -- Fix Version/s: (was: 1.11.0) Resolution: Won't Fix This will be fixed by design after we us

[jira] [Closed] (FLINK-15883) Stop overriding TableSource::getReturnType in parquet table source

[ https://issues.apache.org/jira/browse/FLINK-15883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15883. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Fixed T

[jira] [Closed] (FLINK-15885) Stop overriding TableSource::getTableSchema in tests

[ https://issues.apache.org/jira/browse/FLINK-15885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15885. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Closed] (FLINK-15879) Stop overriding TableSource::getReturnType in kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15879. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jark Wu) Resolution: Won't Fix Th

[jira] [Closed] (FLINK-15880) Stop overriding TableSource::getReturnType in hbase connector

[ https://issues.apache.org/jira/browse/FLINK-15880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15880. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Leonard Xu) Resolution: Won't Fix

[jira] [Closed] (FLINK-15882) Stop overriding TableSource::getReturnType in orc table source

[ https://issues.apache.org/jira/browse/FLINK-15882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15882. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Jingsong Lee) Resolution: Won't Fi

[jira] [Closed] (FLINK-15878) Stop overriding TableSource::getReturnType in tests

[ https://issues.apache.org/jira/browse/FLINK-15878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15878. -- Fix Version/s: (was: 1.11.0) Assignee: (was: Danny Chen) Resolution: Won't Fix

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 3:44 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

flinkbot edited a comment on pull request #12153: URL: https://github.com/apache/flink/pull/12153#issuecomment-628618072 ## CI report: * 670bf0c510cee2e656e3ca9633f9da66506746b0 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/166440422) Azure: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on pull request #12161: [FLINK-17450][sql-parser][hive] Implement function & catalog DDLs for Hive dialect

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

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

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

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 8ecf08d5549084a4cd65d22bc7c29b2431c932d2 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN * 2238559b0e2245e77204e7c7d0ef34c7a97e

[jira] [Updated] (FLINK-17749) Remove fromTableSource method from TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17749: --- Parent: (was: FLINK-15950) Issue Type: Improvement (was: Sub-task) > Remove fromTableSo

[jira] [Updated] (FLINK-17749) Remove fromTableSource method from TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17749: --- Fix Version/s: (was: 1.11.0) > Remove fromTableSource method from TableEnvironment > --

[jira] [Assigned] (FLINK-17749) Remove fromTableSource method from TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17749: -- Assignee: (was: Kurt Young) > Remove fromTableSource method from TableEnvironment >

[GitHub] [flink] lirui-apache commented on a change in pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

lirui-apache commented on a change in pull request #12029: URL: https://github.com/apache/flink/pull/12029#discussion_r426113993 ## File path: flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl ## @@ -958,3 +958,90 @@ void TableApiIdentifierSegment(Lis

[jira] [Created] (FLINK-17749) Remove fromTableSource method from TableEnvironment

Kurt Young created FLINK-17749: -- Summary: Remove fromTableSource method from TableEnvironment Key: FLINK-17749 URL: https://issues.apache.org/jira/browse/FLINK-17749 Project: Flink Issue Type:

[GitHub] [flink] leonardBang commented on a change in pull request #12162: [FLINK-17718][avro] Integrate avro to file system connector

leonardBang commented on a change in pull request #12162: URL: https://github.com/apache/flink/pull/12162#discussion_r426111526 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileSystemFormatFactory.java ## @@ -0,0 +1,267 @@ +/* + * Lice

[jira] [Closed] (FLINK-17748) Remove registration of TableSource/TableSink in Table Env

[ https://issues.apache.org/jira/browse/FLINK-17748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17748. -- Resolution: Fixed master: 32b79d1cdbf3fd463048d5b98a0c4893dfd6ae28 > Remove registration of TableSour

[GitHub] [flink] KurtYoung closed pull request #12076: [FLINK-17748][table] Remove registration of TableSource/TableSink in Table Env

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

[jira] [Updated] (FLINK-17748) Remove registration of TableSource/TableSink in Table Env

[ https://issues.apache.org/jira/browse/FLINK-17748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17748: --- Labels: pull-request-available (was: ) > Remove registration of TableSource/TableSink in Ta

[GitHub] [flink] lirui-apache commented on a change in pull request #12161: [FLINK-17450][sql-parser][hive] Implement function & catalog DDLs for Hive dialect

lirui-apache commented on a change in pull request #12161: URL: https://github.com/apache/flink/pull/12161#discussion_r426112904 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectTest.java ## @@ -222,6 +225,26 @@ priv

[GitHub] [flink] KurtYoung commented on pull request #12076: [FLINK-17748][table] Remove registration of TableSource/TableSink in Table Env

KurtYoung commented on pull request #12076: URL: https://github.com/apache/flink/pull/12076#issuecomment-629581166 I fixed the compilation error and python tests, AZP: https://dev.azure.com/ykt836/Flink/_build/results?buildId=7&view=results

[jira] [Created] (FLINK-17748) Remove registration of TableSource/TableSink in Table Env

Kurt Young created FLINK-17748: -- Summary: Remove registration of TableSource/TableSink in Table Env Key: FLINK-17748 URL: https://issues.apache.org/jira/browse/FLINK-17748 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12185: [FLINK-7267][connectors/rabbitmq] Allow overriding RMQ connection setup

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

[GitHub] [flink] flinkbot edited a comment on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster

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

  1   2   3   4   5   6   7   8   9   >