[GitHub] [flink] klion26 commented on a change in pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

klion26 commented on a change in pull request #11971: URL: https://github.com/apache/flink/pull/11971#discussion_r422456499 ## File path: docs/training/datastream_api.zh.md ## @@ -24,30 +24,27 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] klion26 commented on a change in pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

klion26 commented on a change in pull request #11971: URL: https://github.com/apache/flink/pull/11971#discussion_r422456361 ## File path: docs/training/datastream_api.zh.md ## @@ -104,63 +99,56 @@ public class Example { public static void main(String[] args) throws

[GitHub] [flink] flinkbot commented on pull request #12050: [FLINK-17586][python] Let the BatchTableEnvImpl use the cached files registered in the ExecutionEnvironment to create the job pipeline.

flinkbot commented on pull request #12050: URL: https://github.com/apache/flink/pull/12050#issuecomment-626110903 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] WeiZhong94 commented on a change in pull request #12048: [FLINK-17586][python] get the real Configuration object from DummyStreamExecutionEnvironment when translating the Python UDF p

WeiZhong94 commented on a change in pull request #12048: URL: https://github.com/apache/flink/pull/12048#discussion_r422456225 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonBase.scala ## @@ -136,6 +140,16 @@ trait

[GitHub] [flink] WeiZhong94 opened a new pull request #12050: [FLINK-17586][python] Let the BatchTableEnvImpl use the cached files registered in the ExecutionEnvironment to create the job pipeline.

WeiZhong94 opened a new pull request #12050: URL: https://github.com/apache/flink/pull/12050 ## What is the purpose of the change *This pull request fixes the issue that the BatchTableEnvImpl use an empty cached file list to create the job pipeline.* ## Brief change log

[jira] [Closed] (FLINK-17291) Translate training lesson on event-driven applications to chinese

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

[GitHub] [flink] dianfu commented on a change in pull request #12048: [FLINK-17586][python] get the real Configuration object from DummyStreamExecutionEnvironment when translating the Python UDF physi

dianfu commented on a change in pull request #12048: URL: https://github.com/apache/flink/pull/12048#discussion_r422455758 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/CommonPythonBase.scala ## @@ -136,6 +140,16 @@ trait

[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: * 7505ae67590462ee72054867d405a342effea1c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12040: [FLINK-13938][yarn] Use provided lib dirs to accelerate flink submission

flinkbot edited a comment on pull request #12040: URL: https://github.com/apache/flink/pull/12040#issuecomment-625870998 ## CI report: * 5e0bf74fa324d9c8f69c6ccb1f639a17b78d0837 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

flinkbot edited a comment on pull request #11971: URL: https://github.com/apache/flink/pull/11971#issuecomment-622521983 ## CI report: * f4082786bad837955dea7f68fce466c6b7719912 Azure:

[jira] [Updated] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

[ https://issues.apache.org/jira/browse/FLINK-17585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17585: Fix Version/s: 1.11.0 > "PythonProgramOptions" changes the entry point class when user submit a Java >

[jira] [Updated] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

[ https://issues.apache.org/jira/browse/FLINK-17585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17585: Affects Version/s: 1.11.0 > "PythonProgramOptions" changes the entry point class when user submit a Java

[jira] [Closed] (FLINK-16097) Translate "SQL Client" page of "Table API & SQL" into Chinese

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

[jira] [Assigned] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

[ https://issues.apache.org/jira/browse/FLINK-17585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17585: --- Assignee: Wei Zhong > "PythonProgramOptions" changes the entry point class when user submit a Java

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

TsReaper commented on a change in pull request #12049: URL: https://github.com/apache/flink/pull/12049#discussion_r422455370 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/sinks/StreamSelectTableSink.scala ## @@ -0,0 +1,64 @@ +/* + *

[jira] [Assigned] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17586: --- Assignee: Wei Zhong > Due to the new behavior of the flink-table module the Python dependency >

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17586: Fix Version/s: 1.11.0 > Due to the new behavior of the flink-table module the Python dependency >

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17586: Affects Version/s: 1.11.0 > Due to the new behavior of the flink-table module the Python dependency >

[GitHub] [flink] SteNicholas commented on a change in pull request #12009: [FLINK-17303][python]Return TableResult for Python TableEnvironment

SteNicholas commented on a change in pull request #12009: URL: https://github.com/apache/flink/pull/12009#discussion_r422454850 ## File path: flink-python/pyflink/table/tests/test_sql.py ## @@ -58,6 +56,40 @@ def test_sql_query(self): expected = ['2,Hi,Hello',

[GitHub] [flink] SteNicholas commented on a change in pull request #12009: [FLINK-17303][python]Return TableResult for Python TableEnvironment

SteNicholas commented on a change in pull request #12009: URL: https://github.com/apache/flink/pull/12009#discussion_r422454850 ## File path: flink-python/pyflink/table/tests/test_sql.py ## @@ -58,6 +56,40 @@ def test_sql_query(self): expected = ['2,Hi,Hello',

[GitHub] [flink] bowenli86 commented on a change in pull request #11990: [FLINK-17387][hive] Implement LookupableTableSource for Hive connector

bowenli86 commented on a change in pull request #11990: URL: https://github.com/apache/flink/pull/11990#discussion_r422454846 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableLookupFunction.java ## @@ -0,0 +1,142

[GitHub] [flink] SteNicholas commented on a change in pull request #12009: [FLINK-17303][python]Return TableResult for Python TableEnvironment

SteNicholas commented on a change in pull request #12009: URL: https://github.com/apache/flink/pull/12009#discussion_r422454749 ## File path: flink-python/pyflink/table/tests/test_sql.py ## @@ -58,6 +56,40 @@ def test_sql_query(self): expected = ['2,Hi,Hello',

[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_r422454432 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveContinuousMonitoringFunction.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #12034: [FLINK-17568][checkpointing] Fix the issue that task may consume input data after checkpoint barrier before checkpoint is performed f

flinkbot edited a comment on pull request #12034: URL: https://github.com/apache/flink/pull/12034#issuecomment-625870609 ## CI report: * a29ceddd394d563fe95f166a425380f0452ccd71 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: * 6d9891558892286ea495d638fdd602b49ceadd43 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: * 7505ae67590462ee72054867d405a342effea1c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12047: [FLINK-16990][table-planner-blink] Support LookupTableSource in blink planner

flinkbot edited a comment on pull request #12047: URL: https://github.com/apache/flink/pull/12047#issuecomment-626098845 ## CI report: * b718cd9e806a7ade0f9dca948a0b791b9d36cdc2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12040: [FLINK-13938][yarn] Use provided lib dirs to accelerate flink submission

flinkbot edited a comment on pull request #12040: URL: https://github.com/apache/flink/pull/12040#issuecomment-625870998 ## CI report: * 5e0bf74fa324d9c8f69c6ccb1f639a17b78d0837 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

flinkbot edited a comment on pull request #11971: URL: https://github.com/apache/flink/pull/11971#issuecomment-622521983 ## CI report: * f4082786bad837955dea7f68fce466c6b7719912 Azure:

[GitHub] [flink] hequn8128 commented on a change in pull request #12042: [FLINK-16367] [table] Introduce TableEnvironment#createStatementSet api

hequn8128 commented on a change in pull request #12042: URL: https://github.com/apache/flink/pull/12042#discussion_r422453409 ## File path: flink-python/pyflink/table/statement_set.py ## @@ -0,0 +1,93 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12034: [FLINK-17568][checkpointing] Fix the issue that task may consume input data after checkpoint barrier before checkpoint is performed f

flinkbot edited a comment on pull request #12034: URL: https://github.com/apache/flink/pull/12034#issuecomment-625870609 ## CI report: * a29ceddd394d563fe95f166a425380f0452ccd71 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: * 6d9891558892286ea495d638fdd602b49ceadd43 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #12045: [FLINK-15841][core] Clarify that TimeWindow.intersect returns true if…

flinkbot edited a comment on pull request #12045: URL: https://github.com/apache/flink/pull/12045#issuecomment-626081357 ## CI report: * 4da0ae83b0a78a2c74253237da73102e0e69a51f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12048: [FLINK-17586][python] get the real Configuration object from DummyStreamExecutionEnvironment when translating the Python UDF physical

flinkbot edited a comment on pull request #12048: URL: https://github.com/apache/flink/pull/12048#issuecomment-626103429 ## CI report: * 0ea24ccc576097b489d5f0d16d464318ce3949d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12005: [hotfix][runtime] Remove never thrown IOException in ContinuousFileMnitoringFunction

flinkbot edited a comment on pull request #12005: URL: https://github.com/apache/flink/pull/12005#issuecomment-624580456 ## CI report: * 86a0e04b0e1108673aef8083dc9beb5c51aed0f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL

flinkbot edited a comment on pull request #11892: URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534 ## CI report: * 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN * 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e Azure:

[GitHub] [flink] hequn8128 commented on a change in pull request #12009: [FLINK-17303][python]Return TableResult for Python TableEnvironment

hequn8128 commented on a change in pull request #12009: URL: https://github.com/apache/flink/pull/12009#discussion_r422449259 ## File path: flink-python/pyflink/common/__init__.py ## @@ -37,4 +40,7 @@ 'JobExecutionResult', 'RestartStrategies',

[jira] [Assigned] (FLINK-17590) Add Bucket lifecycle listener to support acquiring bucket state

[ https://issues.apache.org/jira/browse/FLINK-17590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17590: Assignee: Yun Gao > Add Bucket lifecycle listener to support acquiring bucket state >

[GitHub] [flink] xintongsong commented on a change in pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

xintongsong commented on a change in pull request #11920: URL: https://github.com/apache/flink/pull/11920#discussion_r422444245 ## File path: flink-external-resources/flink-external-resource-gpu/src/main/java/org/apache/flink/externalresource/gpu/GPUInfo.java ## @@ -29,12

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

flinkbot commented on pull request #12049: URL: https://github.com/apache/flink/pull/12049#issuecomment-626104558 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-17252) supports SELECT statement in TableEnvironment#executeSql and Table#execute api

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

[GitHub] [flink] godfreyhe opened a new pull request #12049: [FLINK-17252] [table] supports SELECT statement in TableEnvironment#executeSql and introduce Table#execute api

godfreyhe opened a new pull request #12049: URL: https://github.com/apache/flink/pull/12049 ## What is the purpose of the change *This pr aims to let TableEnvironment#executeSql support SELECT statement and introduce Table#execute api. Current BatchSelectTableSink and

[jira] [Updated] (FLINK-17590) Add Bucket lifecycle listener to support acquiring bucket state

[ https://issues.apache.org/jira/browse/FLINK-17590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17590: Parent: FLINK-17589 Issue Type: Sub-task (was: New Feature) > Add Bucket lifecycle listener to

[jira] [Created] (FLINK-17590) Add Bucket lifecycle listener to support acquiring bucket state

Yun Gao created FLINK-17590: --- Summary: Add Bucket lifecycle listener to support acquiring bucket state Key: FLINK-17590 URL: https://issues.apache.org/jira/browse/FLINK-17590 Project: Flink Issue

[GitHub] [flink] XBaith commented on a change in pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

XBaith commented on a change in pull request #11971: URL: https://github.com/apache/flink/pull/11971#discussion_r422451721 ## File path: docs/training/datastream_api.zh.md ## @@ -104,63 +99,56 @@ public class Example { public static void main(String[] args) throws

[GitHub] [flink] XBaith commented on a change in pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

XBaith commented on a change in pull request #11971: URL: https://github.com/apache/flink/pull/11971#discussion_r422451690 ## File path: docs/training/datastream_api.zh.md ## @@ -104,63 +99,56 @@ public class Example { public static void main(String[] args) throws

[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-626103732 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Assigned] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector

[ https://issues.apache.org/jira/browse/FLINK-17589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17589: Assignee: Yun Gao > Extend StreamingFileSink to Support Streaming Hive Connector >

[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: * 6d9891558892286ea495d638fdd602b49ceadd43 Azure:

[GitHub] [flink] flinkbot commented on pull request #12048: [FLINK-17586][python] get the real Configuration object from DummyStreamExecutionEnvironment when translating the Python UDF physical nodes

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

[jira] [Commented] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector

[ https://issues.apache.org/jira/browse/FLINK-17589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103105#comment-17103105 ] Jingsong Lee commented on FLINK-17589: -- Hi [~gaoyunhaii] can this be an umbrella jira? We can

[GitHub] [flink] flinkbot edited a comment on pull request #12005: [hotfix][runtime] Remove never thrown IOException in ContinuousFileMnitoringFunction

flinkbot edited a comment on pull request #12005: URL: https://github.com/apache/flink/pull/12005#issuecomment-624580456 ## CI report: * 86a0e04b0e1108673aef8083dc9beb5c51aed0f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

[GitHub] [flink] klion26 commented on a change in pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

klion26 commented on a change in pull request #11971: URL: https://github.com/apache/flink/pull/11971#discussion_r422451143 ## File path: docs/training/datastream_api.zh.md ## @@ -24,30 +24,27 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN *

[GitHub] [flink] wsry commented on pull request #12034: [FLINK-17568][checkpointing] Fix the issue that task may consume input data after checkpoint barrier before checkpoint is performed for unaligne

wsry commented on pull request #12034: URL: https://github.com/apache/flink/pull/12034#issuecomment-626102934 @pnowojski I found that the changed behavior of CheckpointedInputGate fails CheckpointBarrierTrackerTest and CreditBasedCheckpointBarrierAlignerTest. I have fixed them

[jira] [Created] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector

Yun Gao created FLINK-17589: --- Summary: Extend StreamingFileSink to Support Streaming Hive Connector Key: FLINK-17589 URL: https://issues.apache.org/jira/browse/FLINK-17589 Project: Flink Issue

[GitHub] [flink] liying919 commented on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

liying919 commented on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-626102606 @klion26 The left comments are resolved. Please help merge it. Thanks a lot :) This is an automated message

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

caozhen1937 commented on a change in pull request #11978: URL: https://github.com/apache/flink/pull/11978#discussion_r422450153 ## File path: docs/dev/table/streaming/temporal_tables.zh.md ## @@ -53,10 +53,9 @@ rowtime currency rate 11:49 Pounds 108 {% endhighlight

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

caozhen1937 commented on a change in pull request #11978: URL: https://github.com/apache/flink/pull/11978#discussion_r422450023 ## File path: docs/dev/table/streaming/temporal_tables.zh.md ## @@ -22,23 +22,23 @@ specific language governing permissions and limitations under

[GitHub] [flink] flinkbot edited a comment on pull request #12047: [FLINK-16990][table-planner-blink] Support LookupTableSource in blink planner

flinkbot edited a comment on pull request #12047: URL: https://github.com/apache/flink/pull/12047#issuecomment-626098845 ## CI report: * b718cd9e806a7ade0f9dca948a0b791b9d36cdc2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11990: [FLINK-17387][hive] Implement LookupableTableSource for Hive connector

flinkbot edited a comment on pull request #11990: URL: https://github.com/apache/flink/pull/11990#issuecomment-623910490 ## CI report: * 9a940870922bfb7e92ea199e3affd893cbadd745 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL

flinkbot edited a comment on pull request #11892: URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534 ## CI report: * 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN * 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e Azure:

[GitHub] [flink] flinkbot commented on pull request #12048: [FLINK-17586][python] get the real Configuration object from DummyStreamExecutionEnvironment when translating the Python UDF physical nodes

flinkbot commented on pull request #12048: URL: https://github.com/apache/flink/pull/12048#issuecomment-626101104 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] [Created] (FLINK-17588) Throw exception when hadoop jar is missing in flink scala's yarn mode.

Jeff Zhang created FLINK-17588: -- Summary: Throw exception when hadoop jar is missing in flink scala's yarn mode. Key: FLINK-17588 URL: https://issues.apache.org/jira/browse/FLINK-17588 Project: Flink

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17586: --- Labels: pull-request-available (was: ) > Due to the new behavior of the flink-table module

[GitHub] [flink] WeiZhong94 opened a new pull request #12048: [FLINK-17586][python] get the real Configuration object from DummyStreamExecutionEnvironment when translating the Python UDF physical node

WeiZhong94 opened a new pull request #12048: URL: https://github.com/apache/flink/pull/12048 ## What is the purpose of the change *This pull request gets the real Configuration object from DummyStreamExecutionEnvironment when translating the Python UDF physical nodes to operators.*

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

klion26 commented on a change in pull request #11978: URL: https://github.com/apache/flink/pull/11978#discussion_r422446310 ## File path: docs/dev/table/streaming/temporal_tables.zh.md ## @@ -22,23 +22,23 @@ specific language governing permissions and limitations under the

[GitHub] [flink] XBaith commented on a change in pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

XBaith commented on a change in pull request #11971: URL: https://github.com/apache/flink/pull/11971#discussion_r422448729 ## File path: docs/training/datastream_api.zh.md ## @@ -24,30 +24,27 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] JingsongLi commented on a change in pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

JingsongLi commented on a change in pull request #12010: URL: https://github.com/apache/flink/pull/12010#discussion_r422448183 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFileSystemFormatFactory.java ## @@ -0,0 +1,263 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #11990: [FLINK-17387][hive] Implement LookupableTableSource for Hive connector

flinkbot edited a comment on pull request #11990: URL: https://github.com/apache/flink/pull/11990#issuecomment-623910490 ## CI report: * 9a940870922bfb7e92ea199e3affd893cbadd745 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #12047: [FLINK-16990][table-planner-blink] Support LookupTableSource in blink planner

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

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

[GitHub] [flink] JingsongLi commented on a change in pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

JingsongLi commented on a change in pull request #12010: URL: https://github.com/apache/flink/pull/12010#discussion_r422448142 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFileSystemFormatFactory.java ## @@ -0,0 +1,263 @@ +/* + *

[GitHub] [flink] leonardBang commented on a change in pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

leonardBang commented on a change in pull request #12010: URL: https://github.com/apache/flink/pull/12010#discussion_r422448153 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFileSystemFormatFactory.java ## @@ -0,0 +1,263 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN *

[GitHub] [flink] JingsongLi commented on a change in pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

JingsongLi commented on a change in pull request #12010: URL: https://github.com/apache/flink/pull/12010#discussion_r422448021 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFileSystemFormatFactory.java ## @@ -0,0 +1,263 @@ +/* + *

[GitHub] [flink] leonardBang commented on a change in pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

leonardBang commented on a change in pull request #12010: URL: https://github.com/apache/flink/pull/12010#discussion_r422447807 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFileSystemFormatFactory.java ## @@ -0,0 +1,263 @@ +/* + *

[GitHub] [flink] leonardBang commented on a change in pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

leonardBang commented on a change in pull request #12010: URL: https://github.com/apache/flink/pull/12010#discussion_r422447826 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFileSystemFormatFactory.java ## @@ -0,0 +1,263 @@ +/* + *

[GitHub] [flink] wxplovecc commented on pull request #12035: [FLINK-17569][FileSystemsems]support ViewFileSystem when wait lease revoke of hadoop filesystem

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

[GitHub] [flink] leonardBang commented on a change in pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

leonardBang commented on a change in pull request #12010: URL: https://github.com/apache/flink/pull/12010#discussion_r422447556 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFileSystemFormatFactory.java ## @@ -0,0 +1,263 @@ +/* + *

[jira] [Commented] (FLINK-17566) Fix potential K8s resources leak after JobManager finishes in Applicaion mode

[ https://issues.apache.org/jira/browse/FLINK-17566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103095#comment-17103095 ] Yang Wang commented on FLINK-17566: --- Great. Bumping the fabric8 kubernetes-client version to 4.9.1

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

Jingsong Lee created FLINK-17587: Summary: Filesystem streaming sink support partition commit (success file) Key: FLINK-17587 URL: https://issues.apache.org/jira/browse/FLINK-17587 Project: Flink

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17586: -- Description: Currently the Python dependency management command line options does not work because

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17586: -- Description: Currently the Python dependency management command line options does not work because

[jira] [Closed] (FLINK-14267) Introduce Row Csv Encoder

[ https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-14267. Resolution: Fixed > Introduce Row Csv Encoder > - > >

[jira] [Commented] (FLINK-14267) Introduce Row Csv Encoder

[ https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103091#comment-17103091 ] Jingsong Lee commented on FLINK-14267: -- Encoder merged into FLINK-14257 > Introduce Row Csv

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

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #12047: [FLINK-16990][table-planner-blink] Support LookupTableSource in blink planner

flinkbot commented on pull request #12047: URL: https://github.com/apache/flink/pull/12047#issuecomment-626096320 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] wuchong opened a new pull request #12047: [FLINK-16990][table-planner-blink] Support LookupTableSource in blink planner

wuchong opened a new pull request #12047: URL: https://github.com/apache/flink/pull/12047 ## What is the purpose of the change Support the `LookupTableSource` interface in planner. ## Brief change log Update `CommonLookupJoin` to both handling legacy

[jira] [Updated] (FLINK-16990) Support LookupTableSource in planner

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

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17586: -- Description: Currently the  > Due to the new behavior of the flink-table module the Python dependency

[jira] [Updated] (FLINK-17586) Due to the new behavior of the flink-table module the Python dependency management command line options does not work

[ https://issues.apache.org/jira/browse/FLINK-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17586: -- Summary: Due to the new behavior of the flink-table module the Python dependency management command

[jira] [Created] (FLINK-17586) Due to the new behavior of the table planner the Python dependency management command line options does not work

Wei Zhong created FLINK-17586: - Summary: Due to the new behavior of the table planner the Python dependency management command line options does not work Key: FLINK-17586 URL:

[jira] [Comment Edited] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect

[ https://issues.apache.org/jira/browse/FLINK-17578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103074#comment-17103074 ] Danish Amjad edited comment on FLINK-17578 at 5/9/20, 3:07 AM: --- The *root

  1   2   3   4   5   6   >