[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104099#comment-17104099 ] Yun Tang commented on FLINK-16850: -- [~tzulitai], would you please kindly help to create the 1st commit

[GitHub] [flink-web] klion26 commented on pull request #267: [FLINK-13682][docs-zh] Translate "Code Style - Scala Guide" page into Chinese

klion26 commented on pull request #267: URL: https://github.com/apache/flink-web/pull/267#issuecomment-626486117 @yangjf2019 thanks for addressing my comments, LGTM ping @wuchong This is an automated message from the

[GitHub] [flink-statefun] tzulitai opened a new pull request #107: [FLINK-17605] Consolidate flink.version property in parent POM

tzulitai opened a new pull request #107: URL: https://github.com/apache/flink-statefun/pull/107 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-17605) Consolidate flink.version in Stateful Functions POM files

[ https://issues.apache.org/jira/browse/FLINK-17605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17605: --- Labels: pull-request-available (was: ) > Consolidate flink.version in Stateful Functions

[GitHub] [flink] zhijiangW commented on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-626483029 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-17605) Consolidate flink.version in Stateful Functions POM files

Tzu-Li (Gordon) Tai created FLINK-17605: --- Summary: Consolidate flink.version in Stateful Functions POM files Key: FLINK-17605 URL: https://issues.apache.org/jira/browse/FLINK-17605 Project:

[GitHub] [flink] zjffdu commented on pull request #11895: [FLINK-10911][scala-shell] Enable flink-scala-shell with Scala 2.12

zjffdu commented on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-626482480 @aljoscha I found that the case class issue is caused by `FLINK-10493` which introduce `ScalaCaseClassSerializer`. In our internal flink branch which is based on 1.5 that has no

[GitHub] [flink] flinkbot edited a comment on pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

flinkbot edited a comment on pull request #11297: URL: https://github.com/apache/flink/pull/11297#issuecomment-593931358 ## CI report: * bd7ca0b4407e126739f17292b8a6a0561508351e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

flinkbot edited a comment on pull request #12066: URL: https://github.com/apache/flink/pull/12066#issuecomment-626471650 ## CI report: * fa88acd466c5c1d22389d73610009b0c25c69fbb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

flinkbot edited a comment on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626441217 ## CI report: * 11d3939cde0deeac80e4642bb946622e7ee4d850 UNKNOWN * 64ffbab011482e857ba986b2116d9dfb94138259 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

flinkbot edited a comment on pull request #12061: URL: https://github.com/apache/flink/pull/12061#issuecomment-626432764 ## CI report: * da1bf1e181793e94b1c9147546e15101e87e066f Azure:

[GitHub] [flink] flinkbot commented on pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

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

[GitHub] [flink] flinkbot edited a comment on pull request #12064: [hotfix][javadocs]java doc error fix

flinkbot edited a comment on pull request #12064: URL: https://github.com/apache/flink/pull/12064#issuecomment-626450834 ## CI report: * a799713860db44d58407123f19236b68e231094b Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/165085794) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 44df52a0ff62e1b4ec65efd6a14a8b07d7712e75 Azure:

[GitHub] [flink] flinkbot commented on pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

flinkbot commented on pull request #12066: URL: https://github.com/apache/flink/pull/12066#issuecomment-626467290 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] zhengcanbin opened a new pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

zhengcanbin opened a new pull request #12066: URL: https://github.com/apache/flink/pull/12066 Remove useless local variable `taskStates` in `CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained` This is an

[GitHub] [flink] flinkbot edited a comment on pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

flinkbot edited a comment on pull request #12061: URL: https://github.com/apache/flink/pull/12061#issuecomment-626432764 ## CI report: * d07c04b5ac978764112af3bf1d35285195e3440d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

flinkbot edited a comment on pull request #11297: URL: https://github.com/apache/flink/pull/11297#issuecomment-593931358 ## CI report: * bbf0bc3e167ac3aa30f1044a352f4bdac4a416a2 Azure:

[GitHub] [flink] KurtYoung commented on a change in pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

KurtYoung commented on a change in pull request #11297: URL: https://github.com/apache/flink/pull/11297#discussion_r422772319 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/utils/TableEnvUtil.scala ## @@ -0,0 +1,41 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12065: [FLINK-17604] Implement format factory for CSV serialization and

flinkbot edited a comment on pull request #12065: URL: https://github.com/apache/flink/pull/12065#issuecomment-626450869 ## CI report: * a2a08d561137d48bdff518491863b331765df2a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

flinkbot edited a comment on pull request #12061: URL: https://github.com/apache/flink/pull/12061#issuecomment-626432764 ## CI report: * d07c04b5ac978764112af3bf1d35285195e3440d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12049: [FLINK-17252] [table] supports SELECT statement in TableEnvironment#executeSql and introduce Table#execute api

flinkbot edited a comment on pull request #12049: URL: https://github.com/apache/flink/pull/12049#issuecomment-626106371 ## CI report: * 3640d760380b6b527a115e09363f596fd0134c82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

flinkbot edited a comment on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626441217 ## CI report: * 11d3939cde0deeac80e4642bb946622e7ee4d850 UNKNOWN * 64ffbab011482e857ba986b2116d9dfb94138259 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

flinkbot edited a comment on pull request #12037: URL: https://github.com/apache/flink/pull/12037#issuecomment-625870801 ## CI report: * c06e5db9e64a2b39d857babff53d401697b87262 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 44df52a0ff62e1b4ec65efd6a14a8b07d7712e75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

flinkbot edited a comment on pull request #11297: URL: https://github.com/apache/flink/pull/11297#issuecomment-593931358 ## CI report: * bbf0bc3e167ac3aa30f1044a352f4bdac4a416a2 Azure:

[GitHub] [flink] xintongsong commented on pull request #11191: [FLINK-16094][docs] Translate /dev/table/functions/udfs.zh.md

xintongsong commented on pull request #11191: URL: https://github.com/apache/flink/pull/11191#issuecomment-626457779 Thanks @libenchao, I'm reviewing this right now. This is an automated message from the Apache Git Service.

[GitHub] [flink] JingsongLi commented on a change in pull request #11755: [FLINK-14257][Connectors / FileSystem]Integrate csv to FileSystemTableFactory

JingsongLi commented on a change in pull request #11755: URL: https://github.com/apache/flink/pull/11755#discussion_r422441201 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataFileSystemFormatFactory.java ## @@ -0,0 +1,354 @@ +package

[jira] [Closed] (FLINK-17601) TableEnvironmentITCase.testStatementSet fails on travis

[ https://issues.apache.org/jira/browse/FLINK-17601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17601. -- Resolution: Fixed master: 51c7d61f3e7661f6aad331245ca94ecb82be3994 >

[GitHub] [flink] shuiqiangchen commented on a change in pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

shuiqiangchen commented on a change in pull request #12061: URL: https://github.com/apache/flink/pull/12061#discussion_r422764493 ## File path: flink-python/pyflink/java_gateway.py ## @@ -49,15 +49,19 @@ def get_gateway(): # if Java Gateway is already running

[GitHub] [flink] shuiqiangchen commented on a change in pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

shuiqiangchen commented on a change in pull request #12061: URL: https://github.com/apache/flink/pull/12061#discussion_r422764356 ## File path: flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java ## @@ -300,6 +294,48 @@ static GatewayServer

[jira] [Comment Edited] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104040#comment-17104040 ] Canbin Zheng edited comment on FLINK-17598 at 5/11/20, 3:48 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #12049: [FLINK-17252] [table] supports SELECT statement in TableEnvironment#executeSql and introduce Table#execute api

flinkbot edited a comment on pull request #12049: URL: https://github.com/apache/flink/pull/12049#issuecomment-626106371 ## CI report: * 50dfd19d62da7a39f2004934703344b7f3d95573 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

flinkbot edited a comment on pull request #12037: URL: https://github.com/apache/flink/pull/12037#issuecomment-625870801 ## CI report: * c06e5db9e64a2b39d857babff53d401697b87262 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

flinkbot edited a comment on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626441217 ## CI report: * 11d3939cde0deeac80e4642bb946622e7ee4d850 UNKNOWN * 64ffbab011482e857ba986b2116d9dfb94138259 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

flinkbot edited a comment on pull request #12010: URL: https://github.com/apache/flink/pull/12010#issuecomment-624746999 ## CI report: * d7445e68ed77a6b1b88fdf0dac8638ff62ac8967 UNKNOWN * edacdf8f0062fdae68a1581936a7410c1b35baa2 Azure:

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104040#comment-17104040 ] Canbin Zheng commented on FLINK-17598: -- [~fly_in_gis] Not exactly. The *StatefulSet* could ensure

[GitHub] [flink] flinkbot edited a comment on pull request #12065: [FLINK-17604] Implement format factory for CSV serialization and

flinkbot edited a comment on pull request #12065: URL: https://github.com/apache/flink/pull/12065#issuecomment-626450869 ## CI report: * a2a08d561137d48bdff518491863b331765df2a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 44df52a0ff62e1b4ec65efd6a14a8b07d7712e75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12064: [hotfix][javadocs]java doc error fix

flinkbot edited a comment on pull request #12064: URL: https://github.com/apache/flink/pull/12064#issuecomment-626450834 ## CI report: * a799713860db44d58407123f19236b68e231094b Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/165085794) Azure:

[GitHub] [flink] lirui-apache commented on a change in pull request #11935: [FLINK-17431][sql-parser-hive][hive] Implement table DDLs for Hive di…

lirui-apache commented on a change in pull request #11935: URL: https://github.com/apache/flink/pull/11935#discussion_r422763697 ## File path: flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl ## @@ -218,4 +218,549 @@ SqlNode TableOption() : {

[GitHub] [flink] danny0405 commented on a change in pull request #11935: [FLINK-17431][sql-parser-hive][hive] Implement table DDLs for Hive di…

danny0405 commented on a change in pull request #11935: URL: https://github.com/apache/flink/pull/11935#discussion_r422761906 ## File path: flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl ## @@ -218,4 +218,549 @@ SqlNode TableOption() : {

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104036#comment-17104036 ] Yang Wang commented on FLINK-17598: --- Hi [~felixzheng], if we do not have the leader election, i think

[jira] [Commented] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104034#comment-17104034 ] Yang Wang commented on FLINK-17416: --- Some updates on this ticket. After more investigation and

[GitHub] [flink] flinkbot commented on pull request #12064: [hotfix][javadocs]java doc error fix

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

[GitHub] [flink] flinkbot commented on pull request #12065: [FLINK-17604] Implement format factory for CSV serialization and

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

[GitHub] [flink] flinkbot edited a comment on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

flinkbot edited a comment on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626441217 ## CI report: * 11d3939cde0deeac80e4642bb946622e7ee4d850 UNKNOWN * 64ffbab011482e857ba986b2116d9dfb94138259 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 44df52a0ff62e1b4ec65efd6a14a8b07d7712e75 Azure:

[jira] [Commented] (FLINK-17601) TableEnvironmentITCase.testStatementSet fails on travis

[ https://issues.apache.org/jira/browse/FLINK-17601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104030#comment-17104030 ] godfrey he commented on FLINK-17601: thanks for reporting this [~dwysakowicz], I have opened a pr

[GitHub] [flink] JingsongLi commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

JingsongLi commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422757793 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java ## @@ -0,0

[GitHub] [flink] TsReaper commented on a change in pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

TsReaper commented on a change in pull request #12037: URL: https://github.com/apache/flink/pull/12037#discussion_r422757580 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/CoordinationResponser.java ## @@ -0,0 +1,34 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #12065: [FLINK-17604] Implement format factory for CSV serialization and

flinkbot commented on pull request #12065: URL: https://github.com/apache/flink/pull/12065#issuecomment-626447843 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] JingsongLi commented on a change in pull request #12065: [FLINK-17604] Implement format factory for CSV serialization and

JingsongLi commented on a change in pull request #12065: URL: https://github.com/apache/flink/pull/12065#discussion_r422757205 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -0,0 +1,247 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #12064: [hotfix][javadocs]java doc error fix

flinkbot commented on pull request #12064: URL: https://github.com/apache/flink/pull/12064#issuecomment-626447459 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-17604) Implement format factory for CSV serialization and deseriazation schema of RowData type

[ https://issues.apache.org/jira/browse/FLINK-17604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17604: --- Labels: pull-request-available (was: ) > Implement format factory for CSV serialization

[GitHub] [flink] danny0405 opened a new pull request #12065: [FLINK-17604] Implement format factory for CSV serialization and

danny0405 opened a new pull request #12065: URL: https://github.com/apache/flink/pull/12065 deseriazation schema of RowData type ## What is the purpose of the change Implements format factory for CSV RowData Se/De schema so that they can use in SQL. ## Brief change

[GitHub] [flink] zhenxianyimeng opened a new pull request #12064: [hotfix][javadocs]java doc error fix

zhenxianyimeng opened a new pull request #12064: URL: https://github.com/apache/flink/pull/12064 ## What is the purpose of the change java doc in ExecutionEnvironment.readTextFile is error ## Brief change log change Default is UTF-0 to UTF-8 ## Verifying this change

[GitHub] [flink] lirui-apache commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

lirui-apache commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422756417 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java ## @@ -0,0

[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: * 38d4e669261a6fde7595223bf804b45e838476b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

flinkbot edited a comment on pull request #12061: URL: https://github.com/apache/flink/pull/12061#issuecomment-626432764 ## CI report: * d07c04b5ac978764112af3bf1d35285195e3440d Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

godfreyhe commented on a change in pull request #12037: URL: https://github.com/apache/flink/pull/12037#discussion_r422751031 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorSchedulerTest.java ## @@ -163,6 +163,36

[GitHub] [flink] flinkbot edited a comment on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

flinkbot edited a comment on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626441217 ## CI report: * 11d3939cde0deeac80e4642bb946622e7ee4d850 UNKNOWN * 64ffbab011482e857ba986b2116d9dfb94138259 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

flinkbot edited a comment on pull request #12010: URL: https://github.com/apache/flink/pull/12010#issuecomment-624746999 ## CI report: * d7445e68ed77a6b1b88fdf0dac8638ff62ac8967 UNKNOWN * 410e972bd87875f3ebc7eb8c3b1f39279397473a Azure:

[jira] [Commented] (FLINK-17521) Remove `com.ibm.icu` dependency from table-common

[ https://issues.apache.org/jira/browse/FLINK-17521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104026#comment-17104026 ] Jark Wu commented on FLINK-17521: - I found that `com.ibm.icu` contains some classes with the same name

[GitHub] [flink] JingsongLi commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

JingsongLi commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422753767 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOptions.java ## @@ -0,0 +1,95 @@ +/* +

[GitHub] [flink] JingsongLi commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

JingsongLi commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422753438 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOptions.java ## @@ -0,0 +1,95 @@ +/* +

[GitHub] [flink] JingsongLi commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

JingsongLi commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422753019 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOptions.java ## @@ -0,0 +1,95 @@ +/* +

[GitHub] [flink] JingsongLi commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

JingsongLi commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422752654 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java ## @@ -0,0

[GitHub] [flink] JingsongLi commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

JingsongLi commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422752473 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java ## @@ -0,0

[GitHub] [flink] JingsongLi commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

JingsongLi commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422751974 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOptions.java ## @@ -0,0 +1,95 @@ +/* +

[jira] [Assigned] (FLINK-17604) Implement format factory for CSV serialization and deseriazation schema of RowData type

[ https://issues.apache.org/jira/browse/FLINK-17604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17604: --- Assignee: Danny Chen > Implement format factory for CSV serialization and deseriazation schema of

[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: * 38d4e669261a6fde7595223bf804b45e838476b2 Azure:

[jira] [Updated] (FLINK-17146) Support conversion between PyFlink Table and Pandas DataFrame

[ https://issues.apache.org/jira/browse/FLINK-17146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17146: Priority: Blocker (was: Major) > Support conversion between PyFlink Table and Pandas DataFrame >

[GitHub] [flink] flinkbot commented on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

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

[GitHub] [flink] flinkbot edited a comment on pull request #12059: [FLINK-17602][docs] Corrected method name in dev/stream/broadcast_sta…

flinkbot edited a comment on pull request #12059: URL: https://github.com/apache/flink/pull/12059#issuecomment-626403738 ## CI report: * f4cf0b903582264f5f5b53e23b3c86d19e213450 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

flinkbot edited a comment on pull request #11297: URL: https://github.com/apache/flink/pull/11297#issuecomment-593931358 ## CI report: * bbf0bc3e167ac3aa30f1044a352f4bdac4a416a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

flinkbot edited a comment on pull request #12010: URL: https://github.com/apache/flink/pull/12010#issuecomment-624746999 ## CI report: * d7445e68ed77a6b1b88fdf0dac8638ff62ac8967 UNKNOWN * 410e972bd87875f3ebc7eb8c3b1f39279397473a Azure:

[jira] [Created] (FLINK-17604) Implement format factory for CSV serialization and deseriazation schema of RowData type

Danny Chen created FLINK-17604: -- Summary: Implement format factory for CSV serialization and deseriazation schema of RowData type Key: FLINK-17604 URL: https://issues.apache.org/jira/browse/FLINK-17604

[GitHub] [flink] zhijiangW commented on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-626440767 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

flinkbot commented on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626439751 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-17603) Prepare Hive partitioned streaming source

[ https://issues.apache.org/jira/browse/FLINK-17603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17603: --- Labels: pull-request-available (was: ) > Prepare Hive partitioned streaming source >

[GitHub] [flink] JingsongLi opened a new pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

JingsongLi opened a new pull request #12063: URL: https://github.com/apache/flink/pull/12063 ## What is the purpose of the change Prepare Hive partitioned streaming source, refactor codes. ## Brief change log - Refactor ContinuousFileReaderOperator to read generic

[GitHub] [flink] JingsongLi commented on a change in pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

JingsongLi commented on a change in pull request #12004: URL: https://github.com/apache/flink/pull/12004#discussion_r422748256 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputFormat.java ## @@ -248,7

[GitHub] [flink] dianfu commented on a change in pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

dianfu commented on a change in pull request #12061: URL: https://github.com/apache/flink/pull/12061#discussion_r422746320 ## File path: flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java ## @@ -300,6 +294,48 @@ static GatewayServer

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #12049: [FLINK-17252] [table] supports SELECT statement in TableEnvironment#executeSql and introduce Table#execute api

flinkbot edited a comment on pull request #12049: URL: https://github.com/apache/flink/pull/12049#issuecomment-626106371 ## CI report: * 50dfd19d62da7a39f2004934703344b7f3d95573 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

flinkbot edited a comment on pull request #12061: URL: https://github.com/apache/flink/pull/12061#issuecomment-626432764 ## CI report: * d07c04b5ac978764112af3bf1d35285195e3440d Azure:

[jira] [Created] (FLINK-17603) Prepare Hive partitioned streaming source

Jingsong Lee created FLINK-17603: Summary: Prepare Hive partitioned streaming source Key: FLINK-17603 URL: https://issues.apache.org/jira/browse/FLINK-17603 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

flinkbot edited a comment on pull request #11297: URL: https://github.com/apache/flink/pull/11297#issuecomment-593931358 ## CI report: * a62c733033b7de8e7d61271da25a465ec544e78c Azure:

[jira] [Assigned] (FLINK-17601) TableEnvironmentITCase.testStatementSet fails on travis

[ https://issues.apache.org/jira/browse/FLINK-17601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17601: --- Assignee: godfrey he > TableEnvironmentITCase.testStatementSet fails on travis >

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104007#comment-17104007 ] Canbin Zheng commented on FLINK-17565: -- Hi [~tison]! At the moment this ticket first aims to solve

[jira] [Updated] (FLINK-17452) Support creating Hive tables with constraints

[ https://issues.apache.org/jira/browse/FLINK-17452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17452: - Fix Version/s: 1.11.0 > Support creating Hive tables with constraints >

[jira] [Assigned] (FLINK-17452) Support creating Hive tables with constraints

[ https://issues.apache.org/jira/browse/FLINK-17452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17452: Assignee: Rui Li > Support creating Hive tables with constraints >

[jira] [Closed] (FLINK-17452) Support creating Hive tables with constraints

[ https://issues.apache.org/jira/browse/FLINK-17452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17452. Resolution: Fixed master: 25cbce12d7201642b6031e38583489cd803fb1a5 > Support creating Hive

[GitHub] [flink] JingsongLi commented on pull request #12017: [FLINK-17452][hive] Support creating Hive tables with constraints

JingsongLi commented on pull request #12017: URL: https://github.com/apache/flink/pull/12017#issuecomment-626434551 Thanks for updating. Merged. This is an automated message from the Apache Git Service. To respond to the

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

flinkbot commented on pull request #12062: URL: https://github.com/apache/flink/pull/12062#issuecomment-626434311 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] [Assigned] (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 reassigned FLINK-17587: Assignee: Jingsong Lee > Filesystem streaming sink support partition commit (success

[jira] [Updated] (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 ] ASF GitHub Bot updated FLINK-17587: --- Labels: pull-request-available (was: ) > Filesystem streaming sink support partition

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

JingsongLi opened a new pull request #12062: URL: https://github.com/apache/flink/pull/12062 ## What is the purpose of the change Committing a partition is to notify the downstream application that the partition has finished writing, the partition is ready to be read. Add

[GitHub] [flink] flinkbot edited a comment on pull request #12060: [hotfix] [table-planner-blink] correct the table scan node name in the explain result of TableEnvironmentITCase#testStatementSet

flinkbot edited a comment on pull request #12060: URL: https://github.com/apache/flink/pull/12060#issuecomment-626425753 ## CI report: * ad83387d0a550034ecfe9daa5a8f7b644e195954 Azure:

  1   2   3   >