[jira] [Comment Edited] (FLINK-10984) Move flink-shaded-hadoop to flink-shaded

[ https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852693#comment-16852693 ] sunjincheng edited comment on FLINK-10984 at 5/31/19 6:05 AM:

[jira] [Closed] (FLINK-12440) Add all connector support align Java Table API

[ https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12440. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 836fdfff0db64ff8241f38e8dd362dd50a9d1

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852565#comment-16852565 ] sunjincheng commented on FLINK-10455: - Hi, [~cslotterback] thanks for your reply. an

[jira] [Assigned] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-10455: --- Assignee: Jiangjie Qin > Potential Kafka producer leak in case of failures > --

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852563#comment-16852563 ] sunjincheng commented on FLINK-10455: - Hi [~becket_qin], I am very glad that you are

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851414#comment-16851414 ] sunjincheng commented on FLINK-10455: - Thanks for the quick reply [~azagrebin]! and

[jira] [Commented] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

[ https://issues.apache.org/jira/browse/FLINK-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850721#comment-16850721 ] sunjincheng commented on FLINK-12602: - I have open the PR, I appreciate if you can h

[jira] [Comment Edited] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

[ https://issues.apache.org/jira/browse/FLINK-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848836#comment-16848836 ] sunjincheng edited comment on FLINK-12602 at 5/29/19 10:09 AM: ---

[jira] [Comment Edited] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850556#comment-16850556 ] sunjincheng edited comment on FLINK-10455 at 5/29/19 9:40 AM:

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850556#comment-16850556 ] sunjincheng commented on FLINK-10455: - What is the current situation of this JIRA, i

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850421#comment-16850421 ] sunjincheng commented on FLINK-12296: - Thanks for double check this JIRA, and close

[jira] [Closed] (FLINK-12327) Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test).

[ https://issues.apache.org/jira/browse/FLINK-12327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12327. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 8510e294802c096418cdc121b21d64de630c2

[jira] [Comment Edited] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

[ https://issues.apache.org/jira/browse/FLINK-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848836#comment-16848836 ] sunjincheng edited comment on FLINK-12602 at 5/27/19 11:07 AM: ---

[jira] [Comment Edited] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

[ https://issues.apache.org/jira/browse/FLINK-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848836#comment-16848836 ] sunjincheng edited comment on FLINK-12602 at 5/27/19 11:06 AM: ---

[jira] [Commented] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

[ https://issues.apache.org/jira/browse/FLINK-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848836#comment-16848836 ] sunjincheng commented on FLINK-12602: - Sounds good [~Zentol]! I have a few updates

[jira] [Closed] (FLINK-12408) Support to define all kinds of types in Python API

[ https://issues.apache.org/jira/browse/FLINK-12408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12408. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: a22443c9f083ea98f065b9631fea261968871

[jira] [Commented] (FLINK-12592) StreamTableEnvironment object has no attribute connect

[ https://issues.apache.org/jira/browse/FLINK-12592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847256#comment-16847256 ] sunjincheng commented on FLINK-12592: - PR #8525 merged in master: 873bb4d63881942676

[jira] [Comment Edited] (FLINK-12592) StreamTableEnvironment object has no attribute connect

[ https://issues.apache.org/jira/browse/FLINK-12592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847196#comment-16847196 ] sunjincheng edited comment on FLINK-12592 at 5/24/19 2:55 AM:

[jira] [Commented] (FLINK-12592) StreamTableEnvironment object has no attribute connect

[ https://issues.apache.org/jira/browse/FLINK-12592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847196#comment-16847196 ] sunjincheng commented on FLINK-12592: - It seems the python code not be updated, due

[jira] [Updated] (FLINK-12592) StreamTableEnvironment object has no attribute connect

[ https://issues.apache.org/jira/browse/FLINK-12592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12592: Attachment: (was: image-2019-05-24-10-46-40-288.png) > StreamTableEnvironment object has no at

[jira] [Updated] (FLINK-12592) StreamTableEnvironment object has no attribute connect

[ https://issues.apache.org/jira/browse/FLINK-12592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12592: Attachment: image-2019-05-24-10-46-40-288.png > StreamTableEnvironment object has no attribute con

[jira] [Assigned] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

[ https://issues.apache.org/jira/browse/FLINK-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-12602: --- Assignee: sunjincheng > Correct the flink pom `artifactId` config and scala-free check logi

[jira] [Commented] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

[ https://issues.apache.org/jira/browse/FLINK-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846636#comment-16846636 ] sunjincheng commented on FLINK-12602: - Thank you for confirming this is an issue，and

[jira] [Created] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

sunjincheng created FLINK-12602: --- Summary: Correct the flink pom `artifactId` config and scala-free check logic Key: FLINK-12602 URL: https://issues.apache.org/jira/browse/FLINK-12602 Project: Flink

[jira] [Commented] (FLINK-12592) StreamTableEnvironment object has no attribute connect

[ https://issues.apache.org/jira/browse/FLINK-12592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846459#comment-16846459 ] sunjincheng commented on FLINK-12592: - Thanks [~till.rohrmann]! I'll try to fix it.

[jira] [Assigned] (FLINK-12592) StreamTableEnvironment object has no attribute connect

[ https://issues.apache.org/jira/browse/FLINK-12592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-12592: --- Assignee: sunjincheng > StreamTableEnvironment object has no attribute connect > --

[jira] [Closed] (FLINK-12439) Add FileSystem Connector with CSV format support in Python Table API

[ https://issues.apache.org/jira/browse/FLINK-12439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12439. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: e16fa9fe1506ec725f5c5abb2b24afa246e17

[jira] [Updated] (FLINK-12397) Drop flink-shaded-asm-5

[ https://issues.apache.org/jira/browse/FLINK-12397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12397: Fix Version/s: (was: shaded-8.0) shaded-7.0 > Drop flink-shaded-asm-5 > ---

[jira] [Created] (FLINK-12585) Align Stream/BatchTableEnvironment with JAVA Table API

sunjincheng created FLINK-12585: --- Summary: Align Stream/BatchTableEnvironment with JAVA Table API Key: FLINK-12585 URL: https://issues.apache.org/jira/browse/FLINK-12585 Project: Flink Issue Ty

[jira] [Created] (FLINK-12583) Add all format support align with the Java Table API

sunjincheng created FLINK-12583: --- Summary: Add all format support align with the Java Table API Key: FLINK-12583 URL: https://issues.apache.org/jira/browse/FLINK-12583 Project: Flink Issue Type

[jira] [Closed] (FLINK-12407) Add all table operators align Java Table API

[ https://issues.apache.org/jira/browse/FLINK-12407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12407. --- Resolution: Fixed Fixed in master: b3604f7bee7456b8533e9ea222a833a2624e36c2 > Add all table operato

[jira] [Closed] (FLINK-11051) Add Bounded(Group Window) FlatAggregate operator to streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-11051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11051. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 142462fa4224c3435736ae21d32aaeb1586f1

[jira] [Closed] (FLINK-12534) Reduce the test cost for Python API

[ https://issues.apache.org/jira/browse/FLINK-12534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12534. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 063ee1bb11a580123ea0212b2c617ec6f71fc

[jira] [Updated] (FLINK-12534) Reduce the test cost for Python API

[ https://issues.apache.org/jira/browse/FLINK-12534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12534: Issue Type: Sub-task (was: Improvement) Parent: FLINK-12308 > Reduce the test cost for Py

[jira] [Created] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

sunjincheng created FLINK-12541: --- Summary: Add deploy a Python Flink job and session cluster on Kubernetes support. Key: FLINK-12541 URL: https://issues.apache.org/jira/browse/FLINK-12541 Project: Flink

[jira] [Commented] (FLINK-12533) Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

[ https://issues.apache.org/jira/browse/FLINK-12533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841207#comment-16841207 ] sunjincheng commented on FLINK-12533: - +1 for this change! [~hequn8128] > Introduce

[jira] [Created] (FLINK-12534) Reduce the test cost for Python API

sunjincheng created FLINK-12534: --- Summary: Reduce the test cost for Python API Key: FLINK-12534 URL: https://issues.apache.org/jira/browse/FLINK-12534 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-12515) Sync flink-shaded-hadoop with dependency management entries

[ https://issues.apache.org/jira/browse/FLINK-12515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-12515: --- Assignee: sunjincheng > Sync flink-shaded-hadoop with dependency management entries > -

[jira] [Closed] (FLINK-12485) Add a tool to check the user interface of Python Table API aligns with Java Table API.

[ https://issues.apache.org/jira/browse/FLINK-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12485. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 505b54c182867ccac5d1724d72f4085425ac0

[jira] [Closed] (FLINK-12370) Integrated Travis for Python Table API

[ https://issues.apache.org/jira/browse/FLINK-12370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12370. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: d95d395d92acca210e107663ed0e96c3285f0

[jira] [Closed] (FLINK-12495) Move PythonGatewayServer into flink-clients

[ https://issues.apache.org/jira/browse/FLINK-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12495. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: d1542e9561c6235feb902c9c6d781ba416b8f

[jira] [Assigned] (FLINK-12495) Move PythonGatewayServer into flink-clients

[ https://issues.apache.org/jira/browse/FLINK-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-12495: --- Assignee: sunjincheng > Move PythonGatewayServer into flink-clients > -

[jira] [Created] (FLINK-12495) Move PythonGatewayServer into flink-clients

sunjincheng created FLINK-12495: --- Summary: Move PythonGatewayServer into flink-clients Key: FLINK-12495 URL: https://issues.apache.org/jira/browse/FLINK-12495 Project: Flink Issue Type: Sub-tas

[jira] [Updated] (FLINK-12485) Add a tool to check the user interface of Python Table API aligns with Java Table API.

[ https://issues.apache.org/jira/browse/FLINK-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12485: Description: After FLINK-12407 Python Table API will align with current Java Table API. So, In th

[jira] [Updated] (FLINK-12485) Add a tool to check the user interface of Python Table API aligns with Java Table API.

[ https://issues.apache.org/jira/browse/FLINK-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12485: Environment:     was: After FLINK-12407 Python Table API will align with current Java Table AP

[jira] [Created] (FLINK-12485) Add a tool to check the user interface of Python Table API aligns with Java Table API.

sunjincheng created FLINK-12485: --- Summary: Add a tool to check the user interface of Python Table API aligns with Java Table API. Key: FLINK-12485 URL: https://issues.apache.org/jira/browse/FLINK-12485

[jira] [Commented] (FLINK-11580) Provide a shaded netty-tcnative

[ https://issues.apache.org/jira/browse/FLINK-11580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836794#comment-16836794 ] sunjincheng commented on FLINK-11580: - And I have mentioned this Jira’s situation in

[jira] [Commented] (FLINK-11580) Provide a shaded netty-tcnative

[ https://issues.apache.org/jira/browse/FLINK-11580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836793#comment-16836793 ] sunjincheng commented on FLINK-11580: - Thanks for the update, I am not pretty sure a

[jira] [Issue Comment Deleted] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12308: Comment: was deleted (was: Fixed in master: 478956c32323ddfa29cf9b673f4854bfe5767dbc) > Support p

[jira] [Reopened] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reopened FLINK-12308: - > Support python language in Flink Table API > -- > >

[jira] [Closed] (FLINK-12454) Add custom check options for lint-python.sh

[ https://issues.apache.org/jira/browse/FLINK-12454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12454. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 478956c32323ddfa29cf9b673f4854bfe5767

[jira] [Updated] (FLINK-12455) Move the packaging of pyflink to flink-dist

[ https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12455: Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-12308) > Move the packagi

[jira] [Closed] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12308. --- Resolution: Fixed Fixed in master: 478956c32323ddfa29cf9b673f4854bfe5767dbc > Support python langua

[jira] [Commented] (FLINK-12455) Move the packaging of pyflink to flink-dist

[ https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836159#comment-16836159 ] sunjincheng commented on FLINK-12455: - close this due to the conversation in PR.  >

[jira] [Issue Comment Deleted] (FLINK-12455) Move the packaging of pyflink to flink-dist

[ https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12455: Comment: was deleted (was: Thanks, [~dian.fu] this issue can be done in FLINK-12327, but I think i

[jira] [Closed] (FLINK-12455) Move the packaging of pyflink to flink-dist

[ https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12455. --- Resolution: Won't Fix > Move the packaging of pyflink to flink-dist > --

[jira] [Commented] (FLINK-12455) Move the packaging of pyflink to flink-dist

[ https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836126#comment-16836126 ] sunjincheng commented on FLINK-12455: - Thanks, [~dian.fu] this issue can be done in

[jira] [Commented] (FLINK-12456) Wrong CharType convertion in type_utils.py

[ https://issues.apache.org/jira/browse/FLINK-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836120#comment-16836120 ] sunjincheng commented on FLINK-12456: - Thanks for mention this issue. [~lzljs3620320

[jira] [Updated] (FLINK-12456) Wrong CharType convertion in type_utils.py

[ https://issues.apache.org/jira/browse/FLINK-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12456: Component/s: API / Python > Wrong CharType convertion in type_utils.py > -

[jira] [Updated] (FLINK-12454) Add custom check options for lint-python.sh

[ https://issues.apache.org/jira/browse/FLINK-12454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12454: Labels: (was: Python) > Add custom check options for lint-python.sh > --

[jira] [Updated] (FLINK-12454) Add custom check options for lint-python.sh

[ https://issues.apache.org/jira/browse/FLINK-12454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12454: Labels: Python (was: ) > Add custom check options for lint-python.sh > --

[jira] [Updated] (FLINK-12454) Add custom check options for lint-python.sh

[ https://issues.apache.org/jira/browse/FLINK-12454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12454: Description: At present, int-python.sh has Python compatibility checks and code style checks. By d

[jira] [Created] (FLINK-12454) Add custom check options for lint-python.sh

sunjincheng created FLINK-12454: --- Summary: Add custom check options for lint-python.sh Key: FLINK-12454 URL: https://issues.apache.org/jira/browse/FLINK-12454 Project: Flink Issue Type: Sub-tas

[jira] [Commented] (FLINK-11580) Provide a shaded netty-tcnative

[ https://issues.apache.org/jira/browse/FLINK-11580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835594#comment-16835594 ] sunjincheng commented on FLINK-11580: - Yes, I agree with [~Zentol] and you, And beca

[jira] [Commented] (FLINK-11580) Provide a shaded netty-tcnative

[ https://issues.apache.org/jira/browse/FLINK-11580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835554#comment-16835554 ] sunjincheng commented on FLINK-11580: - Hi @Nico, +1 for this change! I have complet

[jira] [Assigned] (FLINK-12440) Add all connector support align Java Table API

[ https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-12440: --- Assignee: (was: sunjincheng) > Add all connector support align Java Table API > ---

[jira] [Closed] (FLINK-12326) Add a basic test framework, just like the existing Java TableAPI, abstract some TestBase.

[ https://issues.apache.org/jira/browse/FLINK-12326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12326. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 84eec21108f2c05fa872c9a3735457d73f75d

[jira] [Created] (FLINK-12440) Add all connector support align Java Table API

sunjincheng created FLINK-12440: --- Summary: Add all connector support align Java Table API Key: FLINK-12440 URL: https://issues.apache.org/jira/browse/FLINK-12440 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-12439) Add FileSystem Connector with CSV format support in Python Table API

sunjincheng created FLINK-12439: --- Summary: Add FileSystem Connector with CSV format support in Python Table API Key: FLINK-12439 URL: https://issues.apache.org/jira/browse/FLINK-12439 Project: Flink

[jira] [Closed] (FLINK-12330) Add integrated Tox for ensuring compatibility with the python2/3 version

[ https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12330. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 5991d15149cd949a3545fb87881fecb43daba

[jira] [Closed] (FLINK-10976) Add Aggregate operator to Table API

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10976. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 560b2bd84f0f20def8b41c3c7b2c3dd3bc7cb

[jira] [Created] (FLINK-12407) Add all table operators align Java Table API

sunjincheng created FLINK-12407: --- Summary: Add all table operators align Java Table API Key: FLINK-12407 URL: https://issues.apache.org/jira/browse/FLINK-12407 Project: Flink Issue Type: Sub-ta

[jira] [Closed] (FLINK-12311) Add base python framework and Add Scan, Projection, and Filter operator support

[ https://issues.apache.org/jira/browse/FLINK-12311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12311. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: a09bd4c6f1dc5d83d6634bad53af6237a9cd4

[jira] [Issue Comment Deleted] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12308: Comment: was deleted (was: Fixed in master: a09bd4c6f1dc5d83d6634bad53af6237a9cd4fe5) > Support p

[jira] [Reopened] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reopened FLINK-12308: - > Support python language in Flink Table API > -- > >

[jira] [Closed] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12308. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: a09bd4c6f1dc5d83d6634bad53af6237a9cd4

[jira] [Closed] (FLINK-11732) Add a language switch to the sidebar for Flink documents

[ https://issues.apache.org/jira/browse/FLINK-11732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11732. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: c538b01caa1949c3d7ddc02edf4eed4abbb4a

[jira] [Commented] (FLINK-12402) Make validation error message for CallExpression more user friendly

[ https://issues.apache.org/jira/browse/FLINK-12402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833271#comment-16833271 ] sunjincheng commented on FLINK-12402: - +1 to improve the error message. We really n

[jira] [Closed] (FLINK-10977) Add FlatAggregate operator to unbounded streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-10977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10977. --- Resolution: Fixed Fixed in master: e5cadf69d176181af7d097928bf2a6cade1b6c76 > Add FlatAggregate ope

[jira] [Created] (FLINK-12370) Integrated Travis for Python Table API

sunjincheng created FLINK-12370: --- Summary: Integrated Travis for Python Table API Key: FLINK-12370 URL: https://issues.apache.org/jira/browse/FLINK-12370 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-12330) Add integrated Tox for ensuring compatibility with the python2/3 version

[ https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-12330: --- Assignee: sunjincheng > Add integrated Tox for ensuring compatibility with the python2/3 ve

[jira] [Commented] (FLINK-12330) Add integrated Tox for ensuring compatibility with the python2/3 version

[ https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825924#comment-16825924 ] sunjincheng commented on FLINK-12330: - Thanks for mention this [~Fokko]！ IMO. Tox al

[jira] [Created] (FLINK-12330) Add integrated Tox for ensuring compatibility with the python2/3 version

sunjincheng created FLINK-12330: --- Summary: Add integrated Tox for ensuring compatibility with the python2/3 version Key: FLINK-12330 URL: https://issues.apache.org/jira/browse/FLINK-12330 Project: Flink

[jira] [Created] (FLINK-12327) Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test).

sunjincheng created FLINK-12327: --- Summary: Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test). Key: FLINK-12327 URL: https://i

[jira] [Commented] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825623#comment-16825623 ] sunjincheng commented on FLINK-12308: - Hi [~dian.fu], Thank you for your approval th

[jira] [Created] (FLINK-12326) Add a basic test framework, just like the existing Java TableAPI, abstract some TestBase.

sunjincheng created FLINK-12326: --- Summary: Add a basic test framework, just like the existing Java TableAPI, abstract some TestBase. Key: FLINK-12326 URL: https://issues.apache.org/jira/browse/FLINK-12326

[jira] [Updated] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12308: Description: At the Flink API level, we have DataStreamAPI/DataSetAPI/TableAPI&SQL, the Table API

[jira] [Created] (FLINK-12311) Add base python framework and Add Scan, Projection, and Filter operator support

sunjincheng created FLINK-12311: --- Summary: Add base python framework and Add Scan, Projection, and Filter operator support Key: FLINK-12311 URL: https://issues.apache.org/jira/browse/FLINK-12311 Project

[jira] [Comment Edited] (FLINK-12298) Make column functions accept custom Range class rather than Expression

[ https://issues.apache.org/jira/browse/FLINK-12298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824860#comment-16824860 ] sunjincheng edited comment on FLINK-12298 at 4/24/19 7:09 AM:

[jira] [Commented] (FLINK-12298) Make column functions accept custom Range class rather than Expression

[ https://issues.apache.org/jira/browse/FLINK-12298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824860#comment-16824860 ] sunjincheng commented on FLINK-12298: - Hi Dawid, Thanks for mentioning the typesafe

[jira] [Created] (FLINK-12308) Support python language in Flink Table API

sunjincheng created FLINK-12308: --- Summary: Support python language in Flink Table API Key: FLINK-12308 URL: https://issues.apache.org/jira/browse/FLINK-12308 Project: Flink Issue Type: New Feat

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10972: Affects Version/s: 1.9.0 > Enhancements to Flink Table API > --- > >

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10972: Description: [link title|http://example.com/]With the continuous efforts from the community, the

[jira] [Closed] (FLINK-11290) BatchTableEnvironment and StreamTableEnvironment should transparent to users

[ https://issues.apache.org/jira/browse/FLINK-11290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11290. --- Resolution: Fixed FLIP-32 will deal with the unifycation of TableEnvironment. so close this JIRA. >

[jira] [Closed] (FLINK-11967) Add Column Operators/Operations

[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11967. --- Resolution: Fixed > Add Column Operators/Operations > --- > >

[jira] [Closed] (FLINK-10974) Add FlatMap to TableAPI

[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10974. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 58e69a0f6951d99d38ba5462afbb94d5bef47

[jira] [Closed] (FLINK-12029) Add Column selections

[ https://issues.apache.org/jira/browse/FLINK-12029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12029. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: e41b6d4784801677c60b75e353fcf7866106c

[jira] [Closed] (FLINK-12026) Remove the `xxxInternal` method from TableImpl

[ https://issues.apache.org/jira/browse/FLINK-12026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12026. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: c96a4d7afe379a291cc538ca36af896df8dc2

[jira] [Commented] (FLINK-10984) Move flink-shaded-hadoop to flink-shaded

[ https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821833#comment-16821833 ] sunjincheng commented on FLINK-10984: - Hi, [~Zentol] I have had open the PR about Re

[jira] [Closed] (FLINK-11474) Add ReadableCatalog, ReadableWritableCatalog, and other related interfaces

[ https://issues.apache.org/jira/browse/FLINK-11474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11474. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 92ae67d788050f2e2d457692bc0c638bc142a

<    1   2   3   4   5   6   7   8   9   10   >